productbean.java

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

package com.doone.fj1w.fjmgr.config;

import com.doone.data.DacClient;
import com.doone.data.DataRow;
import com.doone.data.DataTable;
import com.doone.fj1w.fj1w.login.app.CommitDate;
import com.doone.util.FileLogger;

public class ProductBean  {
	private DataRow repositoryInfo;
	private final int pageSize = 20; // 默认每页20条
	private CommitDate cd = null;
	
	public ProductBean() {
		cd = CommitDate.getInstance();
	}
	
	/**
	 * 找出所有程控产品的顶级产品
	 * @param dbClient
	 * @return
	 */
	public DataTable getAllProductByCity(DacClient dbClient,String cityCode) {
		FileLogger.getLogger().debug(cityCode);
		try {
			StringBuffer sql = new StringBuffer();
			DataTable dt = null;
			sql.append("select ");
			sql.append("PRODUCTID, ");
			sql.append("PRODUCTNAME, ");
			sql.append("STATE ");
			sql.append("from ");
			sql.append("Td_Product");
			sql.append(" where upproductid=0");
			dt = dbClient.executeQuery(sql.toString());
			return dt;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	/**通过upproductid的条件查询产品配置情况
	 * 
	 * @param dbClient
	 * @param cityCode
	 * @param upproductid
	 * @return
	 */
	public DataTable getProductByCondition(DacClient dbClient,String cityCode,String condition,int pageNo) {
		FileLogger.getLogger().debug(cityCode);
		try {
			StringBuffer sql = new StringBuffer();
			DataTable dt = null;
			sql.append("select d.* from ");
			sql.append("(select c.*,rownum num  from td_product c where");
			if(cityCode==null || cityCode.equals("")){
				sql.append(" c.upproductid"+condition);
				sql.append(" and c.upproductid!=0 and c.upproductid between 1 and 100)d ");
				sql.append("where num>="+((pageNo - 1) * pageSize)+" and num<="+(pageNo * pageSize));
				dt = dbClient.executeQuery(sql.toString());
				return dt;
			}
			else{
				sql.append(" c.citycode=? and  c.upproductid"+condition);
				sql.append(" and c.upproductid!=0 and c.upproductid between 1 and 100)d ");
				sql.append("where num>="+((pageNo - 1) * pageSize)+" and num<="+(pageNo * pageSize));
				Object[] aParam = new Object[1];
				aParam[0] = cityCode;//按地域权限的
				dt = dbClient.executeQuery(sql.toString(),aParam);
				return dt;
			}//否则默认找所有的      
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	/**
	 * 通过upproductid的条件查询产品的页数
	 * @param dbClient
	 * @param cityCode
	 * @param condition
	 * @return
	 */
	public int getUpproductCount(DacClient dbClient,String cityCode,String condition) {
		FileLogger.getLogger().debug(cityCode);
		try {
			int count = 0;
			int pageNum = 0;
			StringBuffer sql = new StringBuffer();
			DataTable dt = null;
			sql.append("select count(*) cnt from td_product where");
			if(cityCode==null || cityCode.equals("")){
				sql.append(" upproductid"+condition);
				sql.append(" and upproductid!=0 and upproductid between 1 and 100");
				dt = dbClient.executeQuery(sql.toString());
				for(int i=0;i<dt.getRows().getCount();i++){
					count = Integer.parseInt(dt.getRow(i).getString("cnt"));
				}
				if((count%pageSize)==0){
					pageNum = count/pageSize;
				}
				else{
					pageNum = count/pageSize+1;
				}
				return pageNum;
			}
			else{
				sql.append(" citycode=? and upproductid"+condition);
				sql.append(" and upproductid!=0 and upproductid between 1 and 100");
				Object[] aParam = new Object[1];
				aParam[0] = cityCode;//按地域权限的
				dt = dbClient.executeQuery(sql.toString(),aParam);
				for(int i=0;i<dt.getRows().getCount();i++){
					count = Integer.parseInt(dt.getRow(i).getString("cnt"));
				}
				if((count%pageSize)==0){
					pageNum = count/pageSize;
				}
				else{
					pageNum = count/pageSize+1;
				}
				return pageNum;
			}//否则默认找所有的      
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	public DataTable[] getProductsById(DacClient dbClient,String[] sProductId) {
		try {
			DataTable[] dt = new DataTable[sProductId.length];
			if(dt.length > 0) {
				for(int i=0;i<dt.length;i++) {
					StringBuffer sql = new StringBuffer();
					sql.append("select ");
					sql.append("PRODUCTID, ");
					sql.append("CITYCODE, ");
					sql.append("BSSPRODUCTCODE, ");
					sql.append("PRODUCTNAME, ");
					sql.append("STATE, ");
					sql.append("UPPRODUCTID ");
					sql.append(" from ");
					sql.append("Td_Product");
					sql.append(" where PRODUCTID=?");
					Object[] aParam = new Object[1];
					aParam[0] = sProductId[i];
					dt[i] = dbClient.executeQuery(sql.toString(),aParam);
				}
			}
			return dt;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	public DataTable getProductById(DacClient dbClient,String sProductId) {
		try {
			StringBuffer sql = new StringBuffer();
			sql.append("select ");
			sql.append("PRODUCTID, ");
			sql.append("CITYCODE, ");
			sql.append("BSSPRODUCTCODE, ");
			sql.append("PRODUCTNAME, ");
			sql.append("STATE, ");
			sql.append("UPPRODUCTID ");
			sql.append(" from ");
			sql.append("Td_Product");
			sql.append(" where PRODUCTID=?");
			Object[] aParam = new Object[1];
			aParam[0] = sProductId;
			DataTable dt = dbClient.executeQuery(sql.toString(),aParam);
			return dt;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	/**用于获取条款协议中的affairId
	 * 
	 * @param dbClient
	 * @param productName
	 * @param cityCode
	 * @return
	 */
	public DataTable getProductId(DacClient dbClient,String productName,String cityCode) {
		try {
			StringBuffer sql = new StringBuffer();
			sql.append("select ");
			sql.append("PRODUCTID");
			sql.append(" from ");
			sql.append("Td_Product");
			sql.append(" where PRODUCTNAME=?");
			sql.append(" and upproductid=0");
			Object[] aParam = new Object[1];
			aParam[0] = productName;
			DataTable dt = dbClient.executeQuery(sql.toString(),aParam);
			return dt;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	
	public String UpdateProducts(String[] productIds,String upproductId,String state) {
		try {
			String ss = "";
			for(int i=0;i<productIds.length;i++) {
				StringBuffer sql = new StringBuffer();
				sql.append("update ");
				sql.append("Td_Product ");
				sql.append("set ");
				sql.append("upproductId=?,");
				sql.append("state=?");
				sql.append(" where productId="+productIds[i]);
				Object[] aParam = new Object[2];
				aParam[0] = upproductId;
				aParam[1] = state;
				ss = cd.commitUpdateDate(sql.toString(),aParam);
			}
			return ss;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	public String addProducts(String cityCode,String bss_productCode,String productName,String upproductId,String state) {
		try {
			String ss = "";
				StringBuffer sql = new StringBuffer();
				sql.append("Insert ");
				sql.append("into td_product(productid,citycode,bssproductcode,productname,upproductid,state) ");
				sql.append("values(seq_prodfunid.nextval,?,?,?,?,?) ");
				Object[] aParam = new Object[5];
				aParam[0] = cityCode;
				aParam[1] = bss_productCode;
				aParam[2] = productName;
				aParam[3] = upproductId;
				aParam[4] = state;

				ss = cd.commitUpdateDate(sql.toString(),aParam);
			return ss;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	
}