querybssinfofromdb.java

电信的网厅的整站代码

package com.doone.fj1w.fjmgr.order.list;
/**重数据库获取已经记录的BSS信息
 * 
 * @author Administrator
 *
 */
import com.doone.data.*;
import com.doone.fj1w.fj1w.order.*;
import com.doone.fj1w.fjmgr.order.*;
import com.doone.fj1w.fjmgr.order.Bss_infoEntity.*;
import com.doone.iossp.FormBody;
import com.doone.util.FileLogger;
import com.doone.fj1w.fjmgr.order.saveFlowRecord.*;
import java.util.*;
import com.doone.fj1w.fjmgr.order.adslalter.*;

public class QueryBssInfoFromDB {
	/**已有终端设备名称
	 * 
	 * @param tf_BSSFlowRecord
	 * @return
	 */
	public static Vector queryselectedDeviceNames(TF_BSSFlowRecord tf_BSSFlowRecord) {
		Vector selected_deviceNames = new Vector();
		DataTable device_dt = null;
		DataTable select_device_dt = null;
		try {
			device_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.DEVICE_TABLE);
			select_device_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.SELECT_DEVICE_TABLE);
			if(device_dt != null && select_device_dt != null){
				if(device_dt.getRows().getCount() > 0){
					for(int i=0;i<device_dt.getRows().getCount();i++){
						DataRow dr = device_dt.getRow(i);
						String productName = dr.getString("PRODiPROD_NAME");
						String productId = dr.getString("PRODiPROD_ID");
						//查看已经选择过的设备
						if(select_device_dt.getRows().getCount() > 0){
							for(int j=0;j<select_device_dt.getRows().getCount();j++){
								DataRow dr1 = select_device_dt.getRow(j);
								String reProductId = dr1.getString(BssParameter.DEVICEID);
								if(productId.equals(reProductId)){
									selected_deviceNames.addElement(productName);
								}
							}
						}
					}
				}
			}
			return selected_deviceNames;
		}
		catch(Exception e) {
			FileLogger.getLogger().debug("取已有终端设备名失败",e);
			return null;
		}
	}
	
	/**已有终端设备ID
	 * 
	 * @param tf_BSSFlowRecord
	 * @return
	 */
	public static Vector queryselectedDeviceIds(TF_BSSFlowRecord tf_BSSFlowRecord) {
		Vector selected_deviceIds = new Vector();
		DataTable device_dt = null;
		DataTable select_device_dt = null;
		try {
			device_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.DEVICE_TABLE);
			select_device_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.SELECT_DEVICE_TABLE);
			if(device_dt != null && select_device_dt != null){
				if(device_dt.getRows().getCount() > 0){
					for(int i=0;i<device_dt.getRows().getCount();i++){
						DataRow dr = device_dt.getRow(i);
						String productId = dr.getString("PRODiPROD_ID");
						//查看已经选择过的设备
						if(select_device_dt.getRows().getCount() > 0){
							for(int j=0;j<select_device_dt.getRows().getCount();j++){
								DataRow dr1 = select_device_dt.getRow(j);
								String reProductId = dr1.getString(BssParameter.DEVICEID);
								if(productId.equals(reProductId)){
									selected_deviceIds.addElement(productId);
								}
							}
						}
					}
				}
			}
			return selected_deviceIds;
		}
		catch(Exception e) {
			FileLogger.getLogger().debug("取已有终端设备ID失败",e);
			return null;
		}
	}
	
	/**已选服务性质名称
	 * 
	 * @param tf_BSSFlowRecord
	 * @return
	 */
	public static String queryselectedServerName(TF_BSSFlowRecord tf_BSSFlowRecord,String sType) {
		DataTable server_dt = null;
		DataTable dt = null;
		String servProperty = "";
		String servName = "";
		String adsl_price_id = "";
		try {
			RateProalterDB rateProalterDB = new RateProalterDB();
			adsl_price_id = String.valueOf(tf_BSSFlowRecord.getTf_prodOrder().getAdsl_Price_Id());
			if(adsl_price_id != null) {
				dt = rateProalterDB.QuerySingleAdslPrice(adsl_price_id);
			}
			java.util.Map map = new java.util.HashMap();
			if(sType.equals("ADSL")) {
				map.put("SERVITYPE","00001365");
				map.put("CITYCODE","0595");
				server_dt = AdslFlowService.getAdslServProperty(String.valueOf(tf_BSSFlowRecord.getProdOrderId()),
						map,BssParameter.ADSLSEVER_TABLE);
			}
			else if(sType.equals("LAN")) {
				map.put("SERVITYPE","00001392");
				map.put("CITYCODE","0595");
				server_dt = AdslFlowService.getAdslServProperty(String.valueOf(tf_BSSFlowRecord.getProdOrderId()),
						map,BssParameter.LANSEVER_TABLE);
			}
			
			servProperty = tf_BSSFlowRecord.getRecordIDS("SERVPROPERTY");
			if(servProperty == null || servProperty.equals("")) {
				if(dt != null && dt.getRows().getCount()>0) {
					servProperty = dt.getRow(0).getString("BSS_TYPE_ID");//从我们数据库找出来服务性质ID与BSS匹配
					tf_BSSFlowRecord.setRecordIDS("SERVPROPERTY",servProperty);
					tf_BSSFlowRecord.save();
				}
			}
			if(server_dt != null && servProperty != null){
				if(server_dt.getRows().getCount() > 0){
					for(int i=0;i<server_dt.getRows().getCount();i++){
						DataRow dr = server_dt.getRow(i);
						String serverId = dr.getString("PRODIPROD_ID");
						String serverName = dr.getString("PRODIPROD_NAME");
						if(servProperty.equals(serverId)){
							servName = serverName;
						}
					}
				}
			}
			return servName;
		}
		catch(Exception e) {
			FileLogger.getLogger().debug("取已选服务性质名称失败",e);
			return null;
		}
	}
	
	/**已选地区名称
	 * 
	 * @param tf_BSSFlowRecord
	 * @return
	 */
	public static String queryselectedAreaName(TF_BSSFlowRecord tf_BSSFlowRecord) {
		DataTable areaInfo_dt = null;
		String cityCode = "";
		String areaName = "";
		DataTable custArchives_dt = null;
		CustArchivesBean custArchivesBean = null;
		try {
			custArchives_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.CUST_ARCHIVES_TABLE);
			custArchivesBean = AdslFlow.setfirstflow(custArchives_dt);
			cityCode = tf_BSSFlowRecord.getRecordIDS("CITYCODE"); //城市编号
			areaInfo_dt =  BssInter2.callWebQryAreaInfo("6",cityCode);
			if(areaInfo_dt != null && areaInfo_dt.getRows().getCount()>0){
				for( int i = 0; i < areaInfo_dt.getRows ().getCount (); i++ ) {
					String area_Id = custArchivesBean.getSERVIAREA_ID();//地区编码
					if(area_Id.equals(areaInfo_dt.getRow(i).getString("AREA_INFOiAREA_ID"))){
						areaName = areaInfo_dt.getRow(i).getString("AREA_INFOiNAME");//地区名称
					}
				}
			}
			return areaName;
		}
		catch(Exception e) {
			FileLogger.getLogger().debug("取已选地区名称失败",e);
			return null;
		}
	}
	
	/**获得加装ADSL电话的程控业务
	 * 
	 * @param tf_BSSFlowRecord
	 * @return
	 */
	public static Vector queryProdFunNames(TF_BSSFlowRecord tf_BSSFlowRecord) {
		Vector prodFunNames = new Vector();
		BssReferProductBean productBean = null;
		try {
			DataTable productDt = tf_BSSFlowRecord.getRecordFrom(BssParameter.PRODUCT_ARCHIVES_TABLE);
			if(productDt != null){
				productBean = new BssReferProductBean();
				productBean.parDataTable(productDt);
				String reProdFunId = "";
				if(productBean != null) {
					for(int i=0;i<productBean.getSob().length;i++){
						if(productBean.getSob()[i] != null &&
								productBean.getSob()[i].getSERV_NWKiMODI_DATE() != null &&
								!productBean.getSob()[i].getSERV_NWKiMODI_DATE().equals("")) {
							if(reProdFunId.equals("")) {
								prodFunNames.addElement(productBean.getSob()[i].getSERV_NWKiMODI_DATE());
							}
							else if(!reProdFunId.equals("") && 
									!reProdFunId.equals(productBean.getSob()[i].getSERV_NWKiPROD_ID())) {
								prodFunNames.addElement(productBean.getSob()[i].getSERV_NWKiMODI_DATE());
							}
							reProdFunId = productBean.getSob()[i].getSERV_NWKiPROD_ID();
						}
					}
				}
			}
		}
		catch(Exception e) {
			e.printStackTrace();
			FileLogger.getLogger().debug("获得加装ADSL电话的程控业务失败",e);
			return null;
		}
		return prodFunNames;
	}
	
	/**从数据库获取客户姓名
	 * 
	 * @param tf_BSSFlowRecord
	 * @return
	 */
	public static String queryCustName(TF_BSSFlowRecord tf_BSSFlowRecord) {
		String sCustName = "";
		try {
			Tf_ProdOrder tf_prodOrder = tf_prodOrder = tf_BSSFlowRecord.getTf_prodOrder();
			sCustName 
		    = (String)TF_BSSFlowRecord.format(tf_BSSFlowRecord.getRecordIDS("CUSTICUST_RELATIONNAME"));//联系人名称
		    if (sCustName == null || sCustName.equals("")){
		    	sCustName = tf_prodOrder.getUsername();
		        tf_BSSFlowRecord.setRecordIDS("CUSTICUST_RELATIONNAME",sCustName);
		        tf_BSSFlowRecord.save();
			}
		}
		catch(Exception e) {
			e.printStackTrace();
			FileLogger.getLogger().debug("获得加装ADSL电话的联系人名称失败",e);
		}
		return sCustName;
	}
	
	
	/**获得加装ADSL电话的终端设备
	 * 
	 * @param tf_BSSFlowRecord
	 * @return
	 */
	public static Vector queryDevices(TF_BSSFlowRecord tf_BSSFlowRecord) {
		Vector prodFunNames = new Vector();
		java.util.Map productMap = new java.util.HashMap();
		BssReferProductBean productBean = null;
		try {
			if(tf_BSSFlowRecord.getRecordIDS(BssParameter.QRY_OPER_MODEL) != null &&
					tf_BSSFlowRecord.getRecordIDS(BssParameter.SERVISERV_ID) != null &&
					tf_BSSFlowRecord.getRecordIDS(BssParameter.KEY_WORD) != null &&
					tf_BSSFlowRecord.getRecordIDS(BssParameter.SERVISERV_TYPE_ID) != null ){
				productMap.put("QRY_OPER_MODEL",tf_BSSFlowRecord.getRecordIDS(BssParameter.QRY_OPER_MODEL));
				productMap.put("SERVISERV_ID",tf_BSSFlowRecord.getRecordIDS(BssParameter.SERVISERV_ID));
				productMap.put("KEY_WORD",tf_BSSFlowRecord.getRecordIDS(BssParameter.KEY_WORD));
				productMap.put("SERV_TYPE_ID",tf_BSSFlowRecord.getRecordIDS(BssParameter.SERVISERV_TYPE_ID));
				productMap.put("SO_TYPE_ID",tf_BSSFlowRecord.getRecordIDS(BssParameter.SO_TYPE_ID));
				productMap.put("CITYCODE",tf_BSSFlowRecord.getRecordIDS("CITYCODE"));
				productBean = BssSreachCustImpl.queryProductInfo(productMap);
				String reDeviceId = "";
				if(productBean != null) {
					for(int i=0;i<productBean.getLtb().length;i++){
						if(productBean.getLtb()[i] != null &&
								productBean.getLtb()[i].getSERV_ACC_TERMiSERV_ID() != null &&
								!productBean.getLtb()[i].getSERV_ACC_TERMiSERV_ID().equals("")) {
							if(reDeviceId.equals("")) {
								prodFunNames.addElement(productBean.getLtb()[i].getSERV_ACC_TERMiSERV_ID());
							}
							else if(!reDeviceId.equals("") && 
									!reDeviceId.equals(productBean.getLtb()[i].getSERV_ACC_TERMiPROD_ID())) {
								prodFunNames.addElement(productBean.getLtb()[i].getSERV_ACC_TERMiSERV_ID());
							}
							reDeviceId = productBean.getLtb()[i].getSERV_ACC_TERMiPROD_ID();
						}
					}
				}
			}
		}
		catch(Exception e) {
			e.printStackTrace();
			FileLogger.getLogger().debug("取电话的终端设备失败",e);
			return null;
		}
		return prodFunNames;
	}
	
}