specailnobean.java

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

package com.doone.fj1w.fjmgr.config;

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

public class SpecailNoBean  {
	
	private CommitDate cd = null;
	
	public SpecailNoBean() {
		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);
		}
	}*/
	
	/**获取码号信息
	 * 
	 * @param SpecailNoIds
	 * @return
	 */
	public DataTable[] getSpecailNoById(DacClient dbClient,String[] sSpecailId) {
		try {
			DataTable[] dt = new DataTable[sSpecailId.length];
			if(dt.length > 0) {
				for(int i=0;i<dt.length;i++) {
					StringBuffer sql = new StringBuffer();
					sql.append("select ");
					sql.append("SPECACCNBRID, ");
					sql.append("CITYCODE, ");
					sql.append("SPECACCNBR, ");
					sql.append("SPECACCNBRREMARK, ");
					sql.append("to_char(EFF_DATE,'yyyy-mm-dd') eff_date, ");
					sql.append("to_char(EXP_DATE,'yyyy-mm-dd') exp_date, ");
					sql.append("SPECACCNBR_FLAG, ");
					sql.append("DISPLAYNAME ");
					sql.append(" from ");
					sql.append("td_specaccnbr");
					sql.append(" where SPECACCNBRID=?");
					Object[] aParam = new Object[1];
					aParam[0] = sSpecailId[i];
					dt[i] = dbClient.executeQuery(sql.toString(),aParam);
				}
			}
			return dt;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	/**码号批量发布
	 * 
	 * @param SpecailNoIds
	 * @return
	 */
	public String OpenSpecailNo(String[] SpecailNoIds ) {
		try {
			String ss = "";
			for(int i=0;i<SpecailNoIds.length;i++) {
				StringBuffer sql = new StringBuffer();
				sql.append("update ");
				sql.append("td_specaccnbr ");
				sql.append(" set SPECACCNBR_FLAG=1 where SPECACCNBRID="+SpecailNoIds[i]);
				ss = cd.commitUpdateDate(sql.toString());
			}
			return ss;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	/**用于批量删除码号
	 * 
	 * @param SpecailNoIds
	 * @return
	 */
	public String DelSpecailNo(String[] SpecailNoIds) {
		try {
			String ss = "";
			for(int i=0;i<SpecailNoIds.length;i++) {
				StringBuffer sql = new StringBuffer();
				sql.append("delete ");
				sql.append("td_specaccnbr ");
				sql.append(" where SPECACCNBRID="+SpecailNoIds[i]);
				ss = cd.commitUpdateDate(sql.toString());
			}
			return ss;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	
	public String UpdateSpecailNo(String[] SpecailNoIds,String SPECACCNBR,String SPECACCNBRREMARK,String EFF_DATE,String EXP_DATE,String SPECACCNBR_FLAG,String DISPLAYNAME) {
		try {
			String ss = "";
			//for(int i=0;i<SpecailNoIds.length;i++) {
			for(int i=0;i<1;i++) {
				StringBuffer sql = new StringBuffer();
				sql.append("update ");
				sql.append("td_specaccnbr ");
				sql.append("set ");
				sql.append("SPECACCNBR=?, ");
				sql.append("SPECACCNBRREMARK=?, ");
				sql.append("EFF_DATE=to_date(?,'yyyy-mm-dd'), ");
				sql.append("EXP_DATE=to_date(?,'yyyy-mm-dd'), ");
				sql.append("SPECACCNBR_FLAG=?, ");
				sql.append("DISPLAYNAME=? ");
				sql.append(" where SPECACCNBRID="+SpecailNoIds[i]);
				Object[] aParam = new Object[6];
				aParam[0] = SPECACCNBR;
				aParam[1] = SPECACCNBRREMARK;
				aParam[2] = EFF_DATE;
				aParam[3] = EXP_DATE;
				aParam[4] = SPECACCNBR_FLAG;
				aParam[5] = DISPLAYNAME;
				ss = cd.commitUpdateDate(sql.toString(),aParam);
			}
			return ss;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	public String addSpecailNo(String cityCode,String SPECACCNBR,String SPECACCNBRREMARK,String EFF_DATE,String EXP_DATE,String SPECACCNBR_FLAG,String DISPLAYNAME) {
		try {
			String ss = "";
				StringBuffer sql = new StringBuffer();
				sql.append("Insert ");
				sql.append("into td_specaccnbr(SPECACCNBRID,CITYCODE,SPECACCNBR,SPECACCNBRREMARK,EFF_DATE,EXP_DATE,CREATE_DATE,SPECACCNBR_FLAG,DISPLAYNAME) ");
				sql.append("values(SEQ_SPECACCNBRID.nextval,?,?,?,to_date(?,'yyyy-mm-dd'),to_date(?,'yyyy-mm-dd'),trunc(sysdate),?,?) ");
				Object[] aParam = new Object[7];
				aParam[0] = cityCode;
				aParam[1] = SPECACCNBR;
				aParam[2] = SPECACCNBRREMARK;
				aParam[3] = EFF_DATE;
				aParam[4] = EXP_DATE;
				aParam[5] = SPECACCNBR_FLAG;
				aParam[6] = DISPLAYNAME;

				System.out.println("*****:"+sql);
				System.out.println("*****:"+aParam[0]);
				System.out.println("*****:"+aParam[1]);
				System.out.println("*****:"+aParam[2]);
				System.out.println("*****:"+aParam[3]);
				System.out.println("*****:"+aParam[4]);
				System.out.println("*****:"+aParam[5]);
				System.out.println("*****:"+aParam[6]);
				
				ss = cd.commitUpdateDate(sql.toString(),aParam);
			return ss;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	
}