productdao.java

来自「电信的网厅的整站代码」· Java 代码 · 共 115 行

package com.doone.wskfmgr.business.netstore;

import java.util.LinkedList;
import java.util.Map;

import com.doone.data.DacClient;
import com.doone.data.DataTable;
import com.doone.fj1w.common.DAOHelper;
import com.doone.util.ExtString;
import com.doone.util.FileLogger;

public class ProductDAO {

	/**
	 * 
	 * @param map
	 * @return
	 * @throws Exception
	 */
	public static int getConditionResult(Map map) throws Exception{
		try {
			StringBuffer sql = new StringBuffer();
			sql.append("select count(s.netproductid) as count from tf_netproduct s ");
			sql.append("where s.goodsid = ?");
			LinkedList linkList = new LinkedList();
			linkList.add((String)map.get("GOODSID"));
			
			sql.append(parseCondition(map,linkList));

			DacClient client = new DacClient();
			DataTable dataTable = client.executeQuery(sql.toString(),linkList.toArray());
			return dataTable.getRow(0).getInt("count");
		} catch (Exception ex) {
			throw ex;
		}
	}
	
	/**
	 * 
	 * @param map
	 * @param startrecord
	 * @param recordnum
	 * @return
	 * @throws Exception
	 */
	public static DataTable getContextResult(Map map, int startrecord,int recordnum)throws Exception{
		try {
			int endrecord = recordnum;
			if (startrecord < 0) {startrecord = 0;}
			if (endrecord > 0 && startrecord > 0) {
				endrecord = startrecord + recordnum;
			}
			
			StringBuffer sql = new StringBuffer();
			sql.append("select s.netproductid,s.prodcutcode,s.name,s.intime,s.outtime ");
			sql.append("from tf_netproduct s ");
			sql.append("where s.goodsid = ?");
			LinkedList linkList = new LinkedList();
			linkList.add((String)map.get("GOODSID"));
			
			sql.append(parseCondition(map,linkList));
			
			return DAOHelper.executePageList(startrecord, endrecord, 
					                         sql.toString(),linkList.toArray());
		} catch (Exception ex) {
			throw ex;
		}
	}
	
	
	/**
	 * 解释条件入参.
	 * @param map
	 * @param linkList
	 * STOREID,CITYNAME,STORETYPE,STATE,CREDIT,,SORTSTARTTIME,ENDTIME,STORENAME
	 * @return
	 */
	public static String parseCondition(Map map,LinkedList linkList) {
		try {
			StringBuffer buffer = new StringBuffer();
			
			if(!ExtString.turnStr((String)map.get("PRODCUTCODE")).equals("")) {
				buffer.append(" and s.PRODCUTCODE = ? ");
				linkList.add((String)map.get("PRODCUTCODE"));
			}
			if(!ExtString.turnStr((String)map.get("OPARETION")).equals("")) {
				buffer.append(" and s.OPARETION = ?");
				linkList.add((String)map.get("OPARETION"));
			}
			if(!ExtString.turnStr((String)map.get("STARTTIME")).equals("")) {
				buffer.append(" and s.INTIME >= to_date(?,'YYYY-MM-DD HH24:MI:SS')");
				linkList.add((String)map.get("STARTTIME"));
			}
			if(!ExtString.turnStr((String)map.get("ENDTIME")).equals("")) {
				buffer.append(" and s.INTIME <= to_date(?,'YYYY-MM-DD HH24:MI:SS')");
				linkList.add((String)map.get("ENDTIME"));
			}
			if(!ExtString.turnStr((String)map.get("NAME")).equals("")) {
				buffer.append(" and s.NAME like ?");
				linkList.add((String)map.get("NAME")+"%");
			}
			if(!ExtString.turnStr((String)map.get("SORT")).equals("")) {
				buffer.append(" order by s.ORDERTIME ");
				buffer.append((String)map.get("SORT"));
			}
			return buffer.toString();
		} catch (Exception ex) {
			FileLogger.getLogger().warn(ex.getMessage(),ex);
		}
		return "";
	}

	
}