lanflowservice.java

电信的网厅的整站代码

	public String getWebAccessByAddr(ServletRequest request, ServletResponse response, Map _map) {
		String ret = "2";
		TF_BSSFlowRecord tf_BSSFlowRecord = null;
		try {
			if (_map != null) {
				String cityCode = (String) _map.get("CITYCODE");
				String addrid = (String) _map.get("ADDRID");
				String handyTel = (String) _map.get("HANDYTEL");
				String prodOrderId = (String) _map.get("PRODORDERID");
				tf_BSSFlowRecord = TF_BSSFlowRecord.getBSSFlowRecord(new DacClient(), Long.parseLong(prodOrderId));
				
				//判断此新装IPTV所选地址是否合理
				DataTable dt = BssInter8.callWebCheckIPTV(addrid,cityCode);
				String check = "";
				String info = "";
				if(dt != null && dt.getRows().getCount() > 0) {
					check = dt.getRow(0).getString("TEMP_STS_WORDS1");
				}
				if(check.equals("0")) {
					info = dt.getRow(0).getString("ERROR_INFO");
					return "0"+info;
				}
				
				try {
					DataTable webAccess = BssInter6.callWebAccessBySub(addrid, "", "", cityCode);
					if (webAccess != null && webAccess.getRows().getCount() > 0) {
						// 将局向和接入点信息保存起来。
						if (webAccess != null && webAccess.getRows().getCount() > 0) {
							tf_BSSFlowRecord.setRecordFrom(webAccess, BssParameter.ACCESS_TABLE);
							
							tf_BSSFlowRecord.setRecordIDS(BssParameter.SO_ACCESSiACCESS_ID, 
									webAccess.getRow(0).getString("ACCESS_INTERFACEiACCESS_ID"));
							tf_BSSFlowRecord.setRecordIDS(BssParameter.SO_ACCESSiEXCH_ID,
									webAccess.getRow(0).getString("EXCHiEXCH_ID"));
						}
						
						// 获取局向的接入点信息。
						_map.put("EXCH_EXCH_ID", tf_BSSFlowRecord.getRecordIDS(BssParameter.SO_ACCESSiACCESS_ID));
						getAccNodeByExch(request, response, _map);
						
						ret = "3";
					}
				} catch (Exception e) {
				}
				
				tf_BSSFlowRecord.setRecordIDS(BssParameter.SO_ACCESSiADDR_ID, addrid);
				tf_BSSFlowRecord.setRecordIDS(BssParameter.SO_ACCESSiREF_TEL_NBR, handyTel);
				tf_BSSFlowRecord.save();
			}
		} catch (Exception ex) {
			FileLogger.getLogger().warn(ex.getMessage(), ex);
		}
		
		return ret;
	}
	
	/**
	 *  获取局向的接入点信息。
	 * 
	 * @param request
	 * @param response
	 * @param _map
	 * @return
	 */
	public boolean getAccNodeByExch(ServletRequest request, ServletResponse response, Map _map) {
		boolean ret = false;
		TF_BSSFlowRecord tf_BSSFlowRecord = null;
		try {
			if (_map != null) {
				String exchId = (String) _map.get("EXCH_EXCH_ID");//地址局向
				String prodOrderId = (String) _map.get("PRODORDERID");
				
				tf_BSSFlowRecord = TF_BSSFlowRecord.getBSSFlowRecord(new DacClient(), Long.parseLong(prodOrderId));
				tf_BSSFlowRecord.setRecordIDS(BssParameter.SO_ACCESSiEXCH_ID,exchId);
				
				String cityCode = tf_BSSFlowRecord.getRecordIDS("CITYCODE"); //城市编号

				DataTable webAccess = BssInter6.callWebQryAccNode(exchId, cityCode);
				
				if (webAccess != null && webAccess.getRows().getCount() > 0) {
					ret = true;
				}
				
				if (webAccess != null && webAccess.getRows().getCount() > 0) {
					tf_BSSFlowRecord.setRecordFrom(webAccess, BssParameter.ACCNODE_TABLE);
					tf_BSSFlowRecord.setRecordIDS(BssParameter.SO_ACCESSiACC_NODE_ID, 
							webAccess.getRow(0).getString("SO_ACCESSiACC_NODE_ID"));
				}
				
				tf_BSSFlowRecord.setStepSN(2);
				tf_BSSFlowRecord.save();
			}
		} catch (Exception ex) {
			FileLogger.getLogger().warn(ex.getMessage(), ex);
		}

		return ret;
	}
	
	/**获得协议说明
	 * 
	 * @param request
	 * @param response
	 * @param _map
	 * @return
	 */
	public static String getProtocolDesc(ServletRequest request, ServletResponse response, Map _map) {
		StringBuffer _sb = new StringBuffer();
		try {
			if (_map != null) {
				
				String prodOrderId = (String) _map.get("PRODORDERID");
				String protocolId = (String) _map.get("PROTOCOLID");
				DataRow dataRow = null;
				TF_BSSFlowRecord tf_BSSFlowRecord = new TF_BSSFlowRecord(new DacClient(),
						Long.parseLong(prodOrderId));
				DataTable protocol_dt = tf_BSSFlowRecord.getRecordFrom("LANPROTOCOL_TABLE");
				String protocoDesc = "";
				String reProtocolId = "";
				for(int i=0;i<protocol_dt.getRows().getCount();i++){
					dataRow = protocol_dt.getRow(i);
					reProtocolId = dataRow.getString("PROT_INFO_SYSIPROTOCOL_ID");
					if(protocolId.equals(reProtocolId)){
						protocoDesc = dataRow.getString("PROT_INFO_SYSISUMMARY");
						_sb.append(protocoDesc);
					}
				}
			}
		} catch (Exception rux) {
			FileLogger.getLogger().warn(rux.getMessage(), rux);
		}
		return _sb.toString();
	}
	
	/**是否要撤消
	 * 
	 * @param prodOrderId
	 * @return
	 */
	public static boolean isRecisionApply(String prodOrderId) {
		boolean b =false;
		if(prodOrderId != null){
			TF_BSSFlowRecord tf_BSSFlowRecord = TF_BSSFlowRecord.getBSSFlowRecord(new DacClient(),Long.parseLong(prodOrderId));
			if(tf_BSSFlowRecord.getStepSN() >= 12)  b = true;
			else  b = false;
		}
		return b;
	}
	
	/**记录客户前台传近来的信息
	 * 
	 * @param prodOrderId
	 * @return
	 */
	public static String saveCustInfo(String prodOrderId) {
		String str = "0";
		if(prodOrderId != null){
			TF_BSSFlowRecord tf_BSSFlowRecord = TF_BSSFlowRecord.getBSSFlowRecord(new DacClient(),Long.parseLong(prodOrderId));
			String name = tf_BSSFlowRecord.getRecordIDS("CUSTICUST_RELATIONNAME");
			String pho = tf_BSSFlowRecord.getRecordIDS("CUSTICUST_RELATIONPHO");
			String card = tf_BSSFlowRecord.getRecordIDS("CUSTICUST_CARD");
			String cardNo = tf_BSSFlowRecord.getRecordIDS("CUSTICUST_CARDNO");
			if(name == null)
				tf_BSSFlowRecord.setRecordIDS("CUSTICUST_RELATIONNAME",tf_BSSFlowRecord.getTf_prodOrder().getUsername());
			if(pho == null)
				tf_BSSFlowRecord.setRecordIDS("CUSTICUST_RELATIONPHO",tf_BSSFlowRecord.getTf_prodOrder().getRelationtel());
			if(card == null)
				tf_BSSFlowRecord.setRecordIDS("CUSTICUST_CARD","");
			if(cardNo == null)
				tf_BSSFlowRecord.setRecordIDS("CUSTICUST_CARDNO",tf_BSSFlowRecord.getTf_prodOrder().getCartno());
			tf_BSSFlowRecord.save();
			str = "1";
		}
		return str;
	}
	
	static public String formatString(String s){
		if(s == null || s.equals("null") || s.equals(""))
			s="&nbsp;";
		return s;  
	}
	
	/**调用小江的XML配置文件调用callWebReferSo接口
	 * 
	 * @param tf_BSSFlowRecord
	 * @return
	 */
	public String applyNewLan(TF_BSSFlowRecord tf_BSSFlowRecord) {
		String sResult = "";
		boolean isLock = true;
		AdslFlowService adslFlowService = null;
		try{
			DataTable custArchives_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.CUST_ARCHIVES_TABLE);
			BssReferProductBean productBean = null;
			BssReferCustBean custBean = null;
			CustArchivesBean custArchivesBean = AdslFlow.setfirstflow(custArchives_dt);
			java.util.Map custMap = new java.util.HashMap();
			
			if(tf_BSSFlowRecord.getRecordIDS("CUSTICUST_ID") != null &&
					tf_BSSFlowRecord.getRecordIDS("CITYCODE") != null){
				custMap.put("CUSTiCUST_ID",tf_BSSFlowRecord.getRecordIDS("CUSTICUST_ID"));
				custMap.put("CITYCODE",tf_BSSFlowRecord.getRecordIDS("CITYCODE"));
				custBean = BssSreachCustImpl.queryCustomer(custMap);
			}
			
			if(tf_BSSFlowRecord.getRecordFrom(BssParameter.PRODUCT_ARCHIVES_TABLE) != null){
				productBean = new BssReferProductBean();
				productBean.parDataTable(tf_BSSFlowRecord.getRecordFrom(BssParameter.PRODUCT_ARCHIVES_TABLE));
			}
			
			String cityCode = tf_BSSFlowRecord.getRecordIDS("CITYCODE"); //城市编号
			String SOiAREA_ID = custArchivesBean.getSERVIAREA_ID();//受理地区
			DataTable soId_dt = BssInter6.callWebGetSoIDNbr(SOiAREA_ID,cityCode);//取申请流水号
			
			/*判断某服务档案是否允许办理变更业务(对判断条件进行合并)*/
			sResult = AdslFlowService.webCheck(tf_BSSFlowRecord,"1");
			System.out.println("sResult==>"+sResult);
			if(sResult == null) {
				return null;
			}
			
			if(sResult.equals("1")) {
				//如果不能办理需调用WebServUnLock进行启用服务
				String SOiSERV_ID = tf_BSSFlowRecord.getRecordIDS(BssParameter.SERVISERV_ID);
				DataSet dtSet = BssReferSoBean.getReferSoBean();
				//提交申请信息；
				String SOiSO_ID = soId_dt.getRow(0).getString("SOISO_ID");
				String SOiSO_NBR = soId_dt.getRow(0).getString("SOISO_NBR");
				String SOiSERV_TYPE_ID = "48";
				String SOiSO_TYPE_ID = "1";
				String SOiSERV_AREA_ID = SOiAREA_ID;
				String SOiCUST_ID = custBean.getCUSTiCUST_ID();//客户编码
				String SOiDISCT_TYPE_ID = tf_BSSFlowRecord.getRecordIDS("DISCTTYPE");
				String SOiSTAFF_ID = "QZ02900";
				String SOiPRIORITY = tf_BSSFlowRecord.getRecordIDS("OPERATIONLEVEL");
				String SOiACCEPT_TYPE = "N";
				String SOiSTATE = "N";
				String SOiANN_ACT_TYPE = "C";
				String FLAG1 = "";
				String STAFF_ID="QZ02900";
				String SOiPRI_SERV_ID = "";
				adslFlowService = new AdslFlowService();
//				设置联系人信息；
				String CORR_INFOiCONTACT_TYPE = "";
				String CORR_INFOiCONTACT_NAME = "";
				String CORR_INFOiCONTACT_TEL = "";
				String CORR_INFOiCERT_TYPE = "";
				String CORR_INFOiCERT_NBR = "";
				CORR_INFOiCONTACT_TYPE = "C";//相关人类型C代表受理联系人D代表受理经办人
				CORR_INFOiCONTACT_NAME = tf_BSSFlowRecord.getRecordIDS("CUSTICUST_RELATIONNAME");//相关人名称
				CORR_INFOiCONTACT_TEL = tf_BSSFlowRecord.getRecordIDS("CUSTICUST_RELATIONPHO");//联系电话
				CORR_INFOiCERT_TYPE = tf_BSSFlowRecord.getRecordIDS("CUSTICUST_CARD");//证件类型
				CORR_INFOiCERT_NBR = tf_BSSFlowRecord.getRecordIDS("CUSTICUST_CARDNO");//证件号码
				adslFlowService.setCorrInfo(dtSet.getDataTable(BssReferSoBean.CORR_INFO_TABLE), 
						CORR_INFOiCONTACT_TYPE, 
						CORR_INFOiCONTACT_NAME, 
						CORR_INFOiCONTACT_TEL, 
						CORR_INFOiCERT_TYPE, 
						CORR_INFOiCERT_NBR);
				
				//设置经办人信息；
				if(tf_BSSFlowRecord.getRecordIDS("ACCEPTMEN_NAME") != null && 
						!tf_BSSFlowRecord.getRecordIDS("ACCEPTMEN_NAME").equals("")) {
					CORR_INFOiCONTACT_TYPE = "D";//相关人类型C代表受理联系人D代表受理经办人
					CORR_INFOiCONTACT_NAME = tf_BSSFlowRecord.getRecordIDS("ACCEPTMEN_NAME");//相关人名称
					CORR_INFOiCONTACT_TEL = tf_BSSFlowRecord.getRecordIDS("ACCEPTMEN_PHO");//联系电话
					CORR_INFOiCERT_TYPE = tf_BSSFlowRecord.getRecordIDS("ACCEPTMEN_CARD");//证件类型
					CORR_INFOiCERT_NBR = tf_BSSFlowRecord.getRecordIDS("ACCEPTMEN_CARDNO");//证件号码
					adslFlowService.setCorrInfo(dtSet.getDataTable(BssReferSoBean.CORR_INFO_TABLE),
							CORR_INFOiCONTACT_TYPE, 
							CORR_INFOiCONTACT_NAME, 
							CORR_INFOiCONTACT_TEL, 
							CORR_INFOiCERT_TYPE, 
							CORR_INFOiCERT_NBR);
				}
				
				adslFlowService.setApplyInfo(dtSet.getDataTable(BssReferSoBean.APPLY_INFO_TABLE),
						SOiSO_ID,
						SOiSO_NBR,
						SOiAREA_ID,
						SOiSERV_TYPE_ID,
						SOiSO_TYPE_ID,
						SOiSERV_AREA_ID,
						SOiCUST_ID,
						SOiDISCT_TYPE_ID,
						SOiSTAFF_ID,
						SOiPRIORITY,
						SOiACCEPT_TYPE,
						SOiSERV_ID,
						SOiSTATE,
						SOiANN_ACT_TYPE,
						FLAG1,
						STAFF_ID,
						SOiPRI_SERV_ID
				);		
				
				//提交产品信息
				String SO_PRODiPROD_ID = productBean.getSab().getSERViPROD_ID();//产品编码(服务性质编码)
				String SO_PRODiPROD_NUM = "1";//产品数量