mutexleanfunbean.java

电信的网厅的整站代码

package com.doone.fj1w.fjmgr.config;


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

import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;

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

public class MutexleanFunBean  {
	DataRow repositoryInfo;
//	private DacClient _dbClient;
	
	
	public MutexleanFunBean() {
	}
	
	/**查询程控功能的互斥或依赖关系
	 * 标准资费表
	 * @param dbClient
	 * @return
	 */
	public DataTable getMutexleanFunById(DacClient dbClient,String sProdfunId,String mutexleanType,String sFunType) {
		try {
			StringBuffer sql = new StringBuffer();
			sql.append("select ");
			sql.append("a.prodfunmutexleanid,");
			sql.append("a.MutexLeanType,");
			sql.append("a.CorrProdFunId,");
			sql.append("a.State ");
			sql.append("from ");
			sql.append("Td_ProdFunMutexLean a,td_prodfun b ");
			sql.append("where a.ProdFunId=? ");
			sql.append("and a.mutexleanType=? ");
			sql.append("and a.corrprodfunid = b.prodfunid and b.funtype = ? ");
			Object[] aParam = new Object[3];
			aParam[0] = sProdfunId;
			aParam[1] = mutexleanType;
			aParam[2] = sFunType;
			DataTable dt = dbClient.executeQuery(sql.toString(),aParam);
			return dt;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	/**查询程控功能的依赖关系
	 * 标准资费表
	 * @param dbClient
	 * @return
	 */
	public DataTable getMutexleanFunById(DacClient dbClient,String sCorrProdFunId,String sFunType) {
		try {
			StringBuffer sql = new StringBuffer();
			sql.append("select ");
			sql.append("a.prodfunmutexleanid,");
			sql.append("a.MutexLeanType,");
			sql.append("a.ProdfunId,");
			sql.append("a.CorrProdFunId,");
			sql.append("a.State ");
			sql.append("from ");
			sql.append("Td_ProdFunMutexLean a,td_prodfun b ");
			sql.append("where a.CorrProdFunId = ? ");
			sql.append("and a.mutexleanType='2' ");
			sql.append("and a.ProdfunId = b.prodfunid and b.funtype = ? ");
			Object[] aParam = new Object[2];
			aParam[0] = sCorrProdFunId;
			aParam[1] = sFunType;
			DataTable dt = dbClient.executeQuery(sql.toString(),aParam);
			return dt;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	public DataTable getSingleList(DacClient dbClient,String sProdfunmutexleanId) {
		try {
			StringBuffer sql = new StringBuffer();
			Object[] aParam = null;
			sql.append("select ");
			sql.append("a.prodfunmutexleanid,");
			sql.append("a.prodfunid,");
			sql.append("b.funname \"funname\",");
			sql.append("decode(a.mutexleantype,'1','互斥','2','依赖') \"mutexleantype\",");
			sql.append("a.corrProdFunId,");
			sql.append("c.funname \"corrfunname\",");
			sql.append("a.state ");
			sql.append("from ");
			sql.append("Td_ProdFunMutexLean a,td_prodfun b,td_prodfun c ");
			sql.append("where a.prodfunmutexleanid=? ");
			sql.append("and a.ProdFunId = b.prodfunid and a.corrProdFunId = c.prodfunid ");
			aParam = new Object[1];
			aParam[0] = sProdfunmutexleanId;

			DataTable dt = dbClient.executeQuery(sql.toString(),aParam);
			return dt;
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
	}
	
	public String addConnection(ServletRequest request, ServletResponse response, Map _map) {
		String result = "";
		try {
			DacClient db = new DacClient();
			String sMutexleanType = (String) _map.get("MUTEXLEANTYPE");
			//String sFunType = (String) _map.get("FUNTYPE");
			String sProdfunId = (String) _map.get("PRODFUNID");
			String sCorrprodfunId = (String) _map.get("CORRPRODFUNID");
			List oParam = new ArrayList();
			StringBuffer sql = new StringBuffer();
			if(sMutexleanType.equals("1")) {
				sql.append("insert into Td_ProdFunMutexLean values(seq_prodfunmutexleanid.nextval,?,?,?,?)");
				oParam.add(sProdfunId);
				oParam.add("1");
				oParam.add(sCorrprodfunId);
				oParam.add("E");
			}
			else if(sMutexleanType.equals("2")) {
				sql.append("insert into Td_ProdFunMutexLean values(seq_prodfunmutexleanid.nextval,?,?,?,?)");
				oParam.add(sCorrprodfunId);
				oParam.add("2");
				oParam.add(sProdfunId);
				oParam.add("E");
			}
			/*else if(sMutexleanType.equals("3")) {
				sql.append("insert into Td_ProdFunMutexLean values(seq_prodfunmutexleanid.nextval,?,?,?,?)");
				oParam.add(sProdfunId);
				oParam.add("2");
				oParam.add(sCorrprodfunId);
				oParam.add("E");
			}*/
			Object ap[] = new Object[oParam.size()];
			
			for (int i = 0; i < ap.length; i++) {
				ap[i] = oParam.get(i);
			}

			result = String.valueOf(db.executeUpdate(sql.toString(), 1000, ap));
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
		
		return result;
	}
	
	public String editConnection(ServletRequest request, ServletResponse response, Map _map) {
		String result = "";
		try {
			DacClient db = new DacClient();
			String sProdfunmutexleanId = (String) _map.get("PRODFUNMUTEXLEANID");
			String sState = (String) _map.get("STATE");
			List oParam = new ArrayList();
			StringBuffer sql = new StringBuffer();
			sql.append("update Td_ProdFunMutexLean set state = ? where prodfunmutexleanid = ?");
			
			oParam.add(sState);
			oParam.add(sProdfunmutexleanId);
			
			Object ap[] = new Object[oParam.size()];
			
			for (int i = 0; i < ap.length; i++) {
				ap[i] = oParam.get(i);
			}

			result = String.valueOf(db.executeUpdate(sql.toString(), 1000, ap));
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
		
		return result;
	}
	
	public String delConnection(ServletRequest request, ServletResponse response, Map _map) {
		String result = "";
		try {
			DacClient db = new DacClient();
			String sProdfunmutexleanId = (String) _map.get("PRODFUNMUTEXLEANID");
			List oParam = new ArrayList();
			StringBuffer sql = new StringBuffer();
			sql.append("delete from Td_ProdFunMutexLean where prodfunmutexleanid = ? ");
			
			oParam.add(sProdfunmutexleanId);
			
			Object ap[] = new Object[oParam.size()];
			
			for (int i = 0; i < ap.length; i++) {
				ap[i] = oParam.get(i);
			}

			result = String.valueOf(db.executeUpdate(sql.toString(), 1000, ap));
		}
		catch (Exception ex) {
			FileLogger.getLogger().warn(ex);
			ex.printStackTrace();
			throw new RuntimeException(ex);
		}
		
		return result;
	}
}