storedao.java

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

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.fj1w.common.entity.impl.TFNetStoreImpl;
import com.doone.util.ExtString;
import com.doone.util.FileLogger;

/**
 * 
 * @author wushaol
 *
 */
public class StoreDAO {

	public StoreDAO() {	}

	/**
	 * 
	 * @param map
	 * @return
	 */
	public static int getConditionResult(Map map) throws Exception{
		try {
			StringBuffer sql = new StringBuffer();
			sql.append("select count(s.storeid) as count from tf_netstore s ");
			LinkedList linkList = new LinkedList();
			if(!ExtString.turnStr((String)map.get("STATE")).equals("")) {
				sql.append("WHERE s.state = ? ");
				linkList.add((String)map.get("STATE"));
			}else {
				sql.append("WHERE s.state in('E','D') ");
			}
			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.STOREID,s.NAME,s.CREDIT,s.CREATETIME,decode(s.STATE,'E','可用','D','禁用') ");
			sql.append("as state,s.LOCKCODE,c.NETTYPEID from tf_netstore s ");
			sql.append("join tf_nettype c on c.UPNETTYPEID=0 and s.type = c.NETTYPEID ");
			LinkedList linkList = new LinkedList();
			if(!ExtString.turnStr((String)map.get("STATE")).equals("")) {
				sql.append("WHERE s.state = ? ");
				linkList.add((String)map.get("STATE"));
			}else {
				sql.append("WHERE s.state in('E','D') ");
			}
			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("STOREID")).equals("")) {
				buffer.append(" and s.storeid = ?");
				linkList.add((String)map.get("STOREID"));
			}
			if(!ExtString.turnStr((String)map.get("CITYNAME")).equals("")) {
				buffer.append(" and s.citycode = ?");
				linkList.add((String)map.get("CITYNAME"));
			}else {
				if(!ExtString.turnStr((String)map.get("CITYCODE")).equals("")) {
					buffer.append(" and s.citycode = ?");
					linkList.add((String)map.get("CITYCODE"));
				}
			}
			if(!ExtString.turnStr((String)map.get("STORETYPE")).equals("")) {
				buffer.append(" and s.type = ?");
				linkList.add((String)map.get("STORETYPE"));
			}
			if(!ExtString.turnStr((String)map.get("CREDIT")).equals("")) {
				buffer.append(" and s.credit = ?");
				linkList.add((String)map.get("CREDIT"));
			}
			if(!ExtString.turnStr((String)map.get("STARTTIME")).equals("")) {
				buffer.append(" and s.createtime >= 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.createtime <= to_date(?,'YYYY-MM-DD HH24:MI:SS')");
				linkList.add((String)map.get("ENDTIME"));
			}
			if(!ExtString.turnStr((String)map.get("STORENAME")).equals("")) {
				buffer.append(" and s.name like ?");
				linkList.add((String)map.get("STORENAME")+ "%");
			}
			if(!ExtString.turnStr((String)map.get("SORT")).equals("")) {
				buffer.append(" order by s.createtime ");
				buffer.append((String)map.get("SORT"));
			}
			return buffer.toString();
		} catch (Exception ex) {
			FileLogger.getLogger().warn(ex.getMessage(),ex);
		}
		return "";
	}
	
	/**
	 * 获取商店为父级为'0'
	 * @return
	 */
	public static DataTable getStoreParents(String cityCode) {
		try {
			TFNetStoreImpl impl = new TFNetStoreImpl(new DacClient());
			impl.setUpStoreId(0L);
			impl.setCityCode(cityCode);
			return (DataTable)impl.queryObj();
		} catch (Exception ex) {
			FileLogger.getLogger().warn(ex.getMessage(), ex);
		}
		return null;
	}
}