collectcompanyinfoimpl.java

电信的网厅的整站代码

package com.doone.fj1w.fjmgr.dsk;

import java.util.ArrayList;
import java.util.List;
import java.util.Map;

import com.doone.data.DacClient;
import com.doone.data.DataRow;
import com.doone.data.DataTable;
import com.doone.util.ExtString;
import com.doone.util.FileLogger;

public class CollectCompanyInfoImpl{
	
	private static CollectCompanyInfoImpl factory = null;
	private static Object initLock = new Object();
	
	public static CollectCompanyInfoImpl getInstance() {
		if (factory == null) {
			//使用synchronzed保证一次只有一个实例能访问对象
			synchronized (initLock) {
				if (factory == null) {
					try {
						//创建RemoteConFun的一个实例
						factory = new CollectCompanyInfoImpl();
					} catch (Exception e) {
						e.printStackTrace();
					}
				}
			}
		}
		return factory;
	}
	
	/**用于获取修改过的公司信息
	 * 
	 */
	private DataTable getCollectCompanyInfoList(Map _map) {
		DacClient db = new DacClient();
		try {
			StringBuffer sql = new StringBuffer();
			List oParam = new ArrayList();

			int pageSize = Integer.parseInt((String) _map.get("pageSize"));
			int currentPage = Integer.parseInt((String) _map.get("currentPage"));
			
			int startrecord = currentPage * pageSize;
			int endrecord = pageSize;
			if (startrecord < 0)
				startrecord = 0;
			if (endrecord > 0 && startrecord > 0)
				endrecord = startrecord + pageSize;
			
			buildSQL(_map,sql,oParam);
			
			StringBuffer _sb = new StringBuffer();
			_sb.append("SELECT * FROM ( SELECT row_.*, rownum rownum_ FROM(");
			_sb.append(sql);
			_sb.append(")row_ WHERE rownum <= ?");
			_sb.append(") WHERE rownum_ > ?");
			
			oParam.add(new Integer(endrecord));
			oParam.add(new Integer(startrecord));
			
			Object ap[] = new Object[oParam.size()];
			
			for (int i = 0; i < ap.length; i++) {
				ap[i] = oParam.get(i);
			}
			
			return db.executeQuery(_sb.toString(), ap);
		} catch (Exception e) {
			FileLogger.getLogger().warn(e.getMessage(), e);
		}
		
		return null;
	}
	
	/**用于分页
	 * 
	 */
	public int getCollectCompanyInfoListCount(Map _map) {
		DacClient db = new DacClient();
		try {
			
			StringBuffer sql = new StringBuffer();
			StringBuffer sql1 = new StringBuffer();
			List oParam = new ArrayList();
			
			buildSQL(_map,sql,oParam);
			
			sql1.append("select count(1) from(");
			sql1.append(sql).append(")");
			
			Object ap[] = new Object[oParam.size()];
			for (int i = 0; i < ap.length; i++) {
				ap[i] = oParam.get(i);
			}
			
			String count = db.getStringFromSqlQuery(sql1.toString(), ap);
			//System.out.println("记录数：" + count);
			return Integer.parseInt(count);
		} catch (Exception e) {
			FileLogger.getLogger().warn(e.getMessage(), e);
		}
		
		return 0;
	}
	
	public DataTable getCompanyInfoById(String custId) {
		DacClient db = new DacClient();
		try {
			StringBuffer sql = new StringBuffer();
			List oParam = new ArrayList();
			
			sql.append("select t.companyinfoid,t.custid,t.custpwd,t.citycode,c.cityname,");
			sql.append("t.areacode,a.areaname,t.custname,t.carttype,t.cartno,");
			sql.append("t.salecy,t.custadd,t.bossname,t.custmail,");
			sql.append("t.relationtel,t.relationfax,t.khykid,t.zczj,");
			sql.append("t.yyzzid,t.yearturnover,t.zzpzjg,t.zzzcdz,");
			sql.append("t.yhxkid,t.comkind,t.effdate,t.expdate,");
			sql.append("t.custforeign,t.salearea,t.postalcode,t.moreneed,");
			sql.append("t.comdesc,t.linkman,t.linkmantype,t.sex,");
			sql.append("t.linkmantel,t.linkmantel1,t.linkadd,t.linkmancartno,");
			sql.append("t.linkmanmail,t.hobby,t.eductionlevel,t.character,");
			sql.append("t.xsyh,t.getinfomethod,t.appealdesc,t.linkmandesc,t.custproductbj ");
			sql.append("from td_companyinfo t,td_city c,td_area a ");
			sql.append("where t.citycode = c.citycode and t.areacode = a.areacode ");
			
			if (!ExtString.isEmpty(custId) && !custId.equals("null") && !custId.equals("")) {
				sql.append("and t.companyinfoid = ? ");
				oParam.add(custId);
			}
			
			Object ap[] = new Object[oParam.size()];
			
			for (int i = 0; i < ap.length; i++) {
				ap[i] = oParam.get(i);
			}
			
			return db.executeQuery(sql.toString(), ap);
			
		} catch (Exception e) {
			FileLogger.getLogger().warn(e.getMessage(), e);
		}
		return null;
	}
	
	private void buildSQL(Map _map, StringBuffer sql, List oParam) {
		String custId = (String) _map.get("CUSTID");
		String cityCode = (String) _map.get("CITYCODE");
		
		sql.append("select t1.companyinfoid,t2.cityname \"城市名称\", t1.custid \"客户ID\",t1.custname \"客户名称\" ");
        sql.append("from td_companyinfo t1,td_city t2 ");
        sql.append("where t1.citycode = t2.citycode ");
		
		if (!ExtString.isEmpty(custId) && !custId.equals("null") && !custId.equals("")) {
			sql.append("and t1.custid = ? ");
			oParam.add(custId);
		}
		if (!ExtString.isEmpty(cityCode) && !cityCode.equals("null") && !cityCode.equals("0590")) {
			sql.append("and t1.citycode = ? ");
			oParam.add(cityCode);
		}	
	}
	
	public String genHtml(Map _map) {
		DataTable dt = getCollectCompanyInfoList(_map);
		StringBuffer _sb = new StringBuffer();
		if ( dt != null && dt.getRows().getCount() > 0) {
			_sb.append("<table>");
			try {
				com.doone.data.DataColumnCollection dcs = dt.getColumns();
				int colcount = dcs.getCount();
				_sb.append("<tr>");
				for (int icol = 1;icol<colcount-1;icol++){
					com.doone.data.DataColumn dc = dcs.getDataColumn(icol);
					_sb.append("<td class=\"body_td\" align=\"center\" nowrap><b>");
					_sb.append(dc.getColumnName());
					_sb.append("</b></TD>");
				}
				_sb.append("</tr>");
				
				for(int iresult=0;iresult<dt.getRows().getCount(); iresult++){	
					_sb.append("<tr height=\"20\">");			
					DataRow drresult = dt.getRow(iresult);
					for (int icol=1; icol<colcount-1;icol++){
						_sb.append("<td class=\"body_td\" align=\"left\" nowrap>");
						if(icol == 2) {
							if(!drresult.getString(icol).trim().equals("0")) {
								String companyinfoid = drresult.getString(0).trim();
								_sb.append("<a href='javascript:' title='查看修改信息' onclick='fn_dblClick(\""+companyinfoid+"\");'><font color=\"red\">");
								_sb.append(drresult.getString(icol).trim().equals("")?"&nbsp;":drresult.getString(icol).trim());
								_sb.append("</font></a>");
							}
							else {
								_sb.append(drresult.getString(icol).trim().equals("")?"&nbsp;":drresult.getString(icol).trim());
							}
						}
						else {
							_sb.append(drresult.getString(icol).trim().equals("")?"&nbsp;":drresult.getString(icol).trim());
						}
						_sb.append("</TD>");

					}
					_sb.append("</tr>");
				}
			} catch (Exception e) {
				FileLogger.getLogger().info(e.getMessage(),e);
			}
			_sb.append("</table>");
		}
		else if(dt == null || dt.getRows().getCount() == 0 ) {
			_sb.append("<table>");
			_sb.append("<tr key=\"-1\" type=\"\">");
			_sb.append("<td class=\"InnerHead\" style=\"cursor: default;\" onclick=\"\" colspan=\"10\">没有找到任何记录信息</td>");
			_sb.append("</tr>");
			_sb.append("</table>");
		}

		return _sb.toString();
	}
}