lanflowservice.java

电信的网厅的整站代码

				String SO_PRODiACTION_TYPE = SOiSO_TYPE_ID;//动作类型
				adslFlowService.setProd(dtSet.getDataTable(BssReferSoBean.PROD_TABLE),
						SO_PRODiPROD_ID,
						SO_PRODiPROD_NUM,
						SO_PRODiACTION_TYPE);
				
				//提交程控信息。
				adslFlowService.setProdFun(dtSet.getDataTable(BssReferSoBean.PROD_TABLE),productBean.getSob());
				
				//提交终端设备。
				adslFlowService.setDevice(dtSet.getDataTable(BssReferSoBean.PROD_TABLE),productBean.getLtb());
				
				//提交新装终端设备
				Vector selected_deviceIds = new Vector();
				selected_deviceIds = QueryBssInfoFromDB.queryselectedDeviceIds(tf_BSSFlowRecord);//取新装终端设备
				adslFlowService.setSelectDevice(dtSet.getDataTable(BssReferSoBean.PROD_TABLE),selected_deviceIds);
				
				// 提交付费信息
				/*根据业务号码查询客户档案*/
				String qry_oper_model = "7";
				custArchives_dt = BssInter5.callWebQryServFor(qry_oper_model,
						"2",
						"","","","","","",
						custArchivesBean.getSERV_ACC_NBRISERV_ACC_NBR(),"","","","","",
						"1",custArchivesBean.getSERVIAREA_ID(),"",cityCode);
				String SO_SERV_ACCTiACCT_ID = custArchives_dt.getRow(0).getString("ACCTiACCT_NBR");
				String SO_SERV_ACCTiACCT_ITEM_TYPE_ID = CommonMethod.formatString(tf_BSSFlowRecord.getRecordIDS("PAYTYPE"));//帐目类型编码;
				String SO_SERV_ACCTiACTION_TYPE = "A";
				String SO_SERV_ACCTiBILLING_TYPE_ID = CommonMethod.formatString(tf_BSSFlowRecord.getRecordIDS("PAYMODE"));//计费方式编码;
				String SERV_ACCTiPAY_RATING = CommonMethod.formatString(tf_BSSFlowRecord.getRecordIDS("PERCENT"));//付费额度：付费金额（元）或付费的百分比（含百分号）;
				adslFlowService.setServAcct(dtSet.getDataTable(BssReferSoBean.SERV_ACCT_TABLE),
						SO_SERV_ACCTiACCT_ID,
						SO_SERV_ACCTiACCT_ITEM_TYPE_ID,
						SO_SERV_ACCTiACTION_TYPE,
						SO_SERV_ACCTiBILLING_TYPE_ID,
						SERV_ACCTiPAY_RATING);
				
//				提交受理业务信息
				String SO_BUSINESSiSECRE_GRADE_ID = "";//保密级别编码
				String SO_BUSINESSiLIMIT_DATE = "";//服务期限
				String SO_BUSINESSiBESP_DATE = CommonMethod.formatString(tf_BSSFlowRecord.getRecordIDS("BESPEAKTIME"));//预约装机日期
				String SO_BUSINESSiPROD_ID = tf_BSSFlowRecord.getRecordIDS("SERVPROPERTY");//服务性质编码
				String CORP_CUSTiCUST_ID = "";//客户编码
				String SO_BUSINESSiACTION_TYPE = "A";//动作类型
				adslFlowService.setBusiness(dtSet.getDataTable(BssReferSoBean.BUSINESS_TABLE),
						SO_BUSINESSiSECRE_GRADE_ID,
						SO_BUSINESSiLIMIT_DATE,
						SO_BUSINESSiBESP_DATE,
						SO_BUSINESSiPROD_ID, 
						CORP_CUSTiCUST_ID,
						SO_BUSINESSiACTION_TYPE);
				
//				受理受理产品的附加属性
				adslFlowService.setProdAddInfo(dtSet.getDataTable(BssReferSoBean.PROD_ADDINFO_TABLE), selected_deviceIds);
				
//				设置资源接入信息
				String SO_ACCESSiACCESS_ID = productBean.getLnb().getSERV_ACCESSiACCESS_ID();//业务接入编码
				String SO_ACCESSiACC_NODE_ID = productBean.getLnb().getSERV_ACCESSiACC_NODE_ID();//接入点编码
				String SO_ACCESSiEXCH_ID = productBean.getLnb().getSERV_ACCESSiEXCH_ID();//地址局向
				String SO_ACCESSiADDR_ID = productBean.getLnb().getSERV_ACCESSiADDR_ID();//地址编码
				String SO_ACCESSiREF_TEL_NBR = productBean.getLnb().getSO_ACCESSiREF_TEL_NBR();//就近电话
				String SO_ACCESSiREF_ADDR_ID = productBean.getLnb().getSO_ACCESSiREF_ADDR_ID();//就近地址
				String SO_ACCESSiACTION_TYPE = "A";//动作类型
				adslFlowService.setAccess(dtSet.getDataTable(BssReferSoBean.ACCESS_TABLE), 
						SO_ACCESSiACCESS_ID,
						SO_ACCESSiACC_NODE_ID, 
						SO_ACCESSiEXCH_ID,
						SO_ACCESSiADDR_ID, 
						SO_ACCESSiREF_TEL_NBR,
						SO_ACCESSiREF_ADDR_ID,
						SO_ACCESSiACTION_TYPE);
				
				//设置号码信息。
				String SO_ACC_NBRiNBR_SEQ = "1";
				String SO_ACC_NBRiSEQ = "1";
				String SO_ACC_NBRiACC_NBR = tf_BSSFlowRecord.getRecordIDS("DATANbr");
				String SO_ACC_NBRiIS_CHOSEN = "Y";
				String SO_ACC_NBRiACC_NBR_AB = "";
				String SO_ACC_NBRiEXCH_ID = productBean.getLnb().getSERV_ACCESSiEXCH_ID();
				String SO_ACC_NBRiIS_SECRET = "";
				String SERV_ACCESSiACCESS_ID = "";
				String SO_ACC_NBRiMAINTAIN_LEVEL = "C";//(需要获取)
				String SO_ACC_NBRiINSTALL_LEVEL = "";
				String TEMP_STS_WORDS2 = "";
				String SERV_NBRiAREA_ID = SOiAREA_ID;
				String SERV_NBRiSERV_NBR_ID = "";
				String SO_ACC_NBRiACTION_TYPE = "A";
				
				adslFlowService.setAcc_Nbr(dtSet.getDataTable(BssReferSoBean.ACC_NBR_TABLE),
						SOiSO_TYPE_ID,
						SO_ACC_NBRiNBR_SEQ,
						SO_ACC_NBRiSEQ,
						SO_ACC_NBRiACC_NBR,
						SO_ACC_NBRiIS_CHOSEN,
						SO_ACC_NBRiACC_NBR_AB,
						SO_ACC_NBRiEXCH_ID,
						SO_ACC_NBRiIS_SECRET,
						SERV_ACCESSiACCESS_ID,
						SO_ACC_NBRiMAINTAIN_LEVEL,
						SO_ACC_NBRiINSTALL_LEVEL,
						TEMP_STS_WORDS2,
						SERV_NBRiAREA_ID,
						SERV_NBRiSERV_NBR_ID,
						SO_ACC_NBRiACTION_TYPE);
				
//				特殊号码的提交  拨号帐号电话
				String SO_SPECIAL_NBRSiNBR = "";
				String SO_SPECIAL_NBRSiNBR_TYPE = "";
				String SO_SPECIAL_NBRSiACTION_TYPE = "";
				TEMP_STS_WORDS2 = "";
				SERV_NBRiAREA_ID = SOiAREA_ID;
				SERV_NBRiSERV_NBR_ID = "";//接入点编码
				String SO_SPECIAL_NBRSiNBR_ID = "";
				
//				是否开通阳光帐号
				String ifOpen = tf_BSSFlowRecord.getRecordIDS("ISOPEN");
				if(ifOpen.equals("0")) {
					SO_SPECIAL_NBRSiNBR = tf_BSSFlowRecord.getRecordIDS("DIALUPACC");
					SO_SPECIAL_NBRSiNBR_TYPE = "A";
					SO_SPECIAL_NBRSiACTION_TYPE = "A";
					adslFlowService.setSpecialNbr(dtSet.getDataTable(BssReferSoBean.SPECIAL_NBRS_TABLE),
							SO_SPECIAL_NBRSiNBR,
							SO_SPECIAL_NBRSiNBR_TYPE,
							SO_SPECIAL_NBRSiACTION_TYPE,
							TEMP_STS_WORDS2,
							SERV_NBRiAREA_ID,
							SERV_NBRiSERV_NBR_ID,
							SO_SPECIAL_NBRSiNBR_ID);
				}
				else if(ifOpen.equals("1")) {
					SO_SPECIAL_NBRSiNBR = tf_BSSFlowRecord.getRecordIDS("DIALUPACC");
					SO_SPECIAL_NBRSiNBR_TYPE = "A";
					SO_SPECIAL_NBRSiACTION_TYPE = "A";
					adslFlowService.setSpecialNbr(dtSet.getDataTable(BssReferSoBean.SPECIAL_NBRS_TABLE),
							SO_SPECIAL_NBRSiNBR,
							SO_SPECIAL_NBRSiNBR_TYPE,
							SO_SPECIAL_NBRSiACTION_TYPE,
							TEMP_STS_WORDS2,
							SERV_NBRiAREA_ID,
							SERV_NBRiSERV_NBR_ID,
							SO_SPECIAL_NBRSiNBR_ID);
					SO_SPECIAL_NBRSiNBR = tf_BSSFlowRecord.getRecordIDS("SHINEACCOUNT");
					SO_SPECIAL_NBRSiNBR_TYPE = "O";
					SO_SPECIAL_NBRSiACTION_TYPE = "O";
					adslFlowService.setSpecialNbr(dtSet.getDataTable(BssReferSoBean.SPECIAL_NBRS_TABLE),
							SO_SPECIAL_NBRSiNBR,
							SO_SPECIAL_NBRSiNBR_TYPE,
							SO_SPECIAL_NBRSiACTION_TYPE,
							TEMP_STS_WORDS2,
							SERV_NBRiAREA_ID,
							SERV_NBRiSERV_NBR_ID,
							SO_SPECIAL_NBRSiNBR_ID);
				}				
				
				//受理接入终端
				if(selected_deviceIds != null && selected_deviceIds.size() > 0) {
					adslFlowService.setInfoForDervice(selected_deviceIds,tf_BSSFlowRecord,dtSet);
				}
				
				//数据接入信息
				String SO_DATA_ACCESS_INFOiTERM_ACC_ID = "";
				String SO_DATA_ACCESS_IiACC_PURPOSE_ID = "";
				String SO_DATA_ACCESS_INFOiACC_SERV_ID = tf_BSSFlowRecord.getRecordIDS(BssParameter.SERVISERV_ID);
				String SO_DATA_ACCESS_INFOiBILL_SERV_ID = tf_BSSFlowRecord.getRecordIDS(BssParameter.SERVISERV_ID);
				String SERV_DATA_ACCESS_INFOiACCT_ITEM_TYPE_ID = CommonMethod.formatString(tf_BSSFlowRecord.getRecordIDS("PAYTYPE"));
				String SERV_DATA_ACCESS_INFOiPAY_RATING = CommonMethod.formatString(tf_BSSFlowRecord.getRecordIDS("PERCENT"));
				String SO_DATA_ACCESS_INFOiSEQ = "1";
				String SO_DATA_ACCESS_INFOiACT_TYPE = "A";
				adslFlowService.setData_access_info(dtSet.getDataTable(BssReferSoBean.DATA_ACCESS_INFO_TABLE),
						SO_DATA_ACCESS_INFOiTERM_ACC_ID,
						SO_DATA_ACCESS_IiACC_PURPOSE_ID,
						SO_DATA_ACCESS_INFOiACC_SERV_ID,
						SO_DATA_ACCESS_INFOiBILL_SERV_ID,
						SERV_DATA_ACCESS_INFOiACCT_ITEM_TYPE_ID,
						SERV_DATA_ACCESS_INFOiPAY_RATING,
						SO_DATA_ACCESS_INFOiSEQ,
						SO_DATA_ACCESS_INFOiACT_TYPE);
				
				//提交协议受理信息表
				DataTable protocol_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.SELECT_PROTOCOL_TABLE);
				adslFlowService.setProtocol_Info(dtSet.getDataTable(BssReferSoBean.PROTOCOL_INFO_TABLE),protocol_dt,productBean);
				
				dtSet.acceptChanges();
				
				Map _map = BssReferSoBean.call(dtSet, cityCode);
				String so_id = (String) _map.get(BssReferSoBean.OUTPUT_SO_ID);
				
				if(_map == null || _map.get(BssReferSoBean.OUTPUT_SO_ID) == null || so_id.equals("") ) 
					isLock = false;
				else {
					tf_BSSFlowRecord.setRecordIDS("SOISO_SEQ",(String) _map.get(BssReferSoBean.OUTPUT_SO_SEQ));//申请序列号
					tf_BSSFlowRecord.setRecordIDS("SOISO_ID",(String) _map.get(BssReferSoBean.OUTPUT_SO_ID));//申请流水号
					tf_BSSFlowRecord.setRecordIDS("SOISO_NBR",(String) _map.get(BssReferSoBean.OUTPUT_SO_NBR));//申请单号
					tf_BSSFlowRecord.setRecordIDS("SOIAPPL_DATE",(String) _map.get(BssReferSoBean.OUTPUT_APPL_DATE));//申请时间
					log.info("申请序列号==>"+(String) _map.get(BssReferSoBean.OUTPUT_SO_SEQ));
					log.info("申请流水号==>"+(String) _map.get(BssReferSoBean.OUTPUT_SO_ID));
					log.info("申请单号==>"+(String) _map.get(BssReferSoBean.OUTPUT_SO_NBR));
					log.info("申请时间==>"+(String) _map.get(BssReferSoBean.OUTPUT_APPL_DATE));
					tf_BSSFlowRecord.setStepSN(12);
					tf_BSSFlowRecord.save();
					
					sResult = "1";
				}
			}else return sResult;
		}
		catch(Exception e) {
			isLock = false;
			sResult = null;
			FileLogger.getLogger().warn("提交LAN新装申请信息失败：" + e);
		}
		
		String lockInfo = adslFlowService.isLock(isLock,tf_BSSFlowRecord);
		if(lockInfo != null && lockInfo.equals("1"))
			return sResult;
		else
			sResult = lockInfo;
			return sResult;
	}
	
	/**产生申请记录
	 * 
	 * @param tf_BSSFlowRecord
	 * @return
	 */
	public static String webApply(TF_BSSFlowRecord tf_BSSFlowRecord) {
		String info = "";
		try {
			DataTable custArchives_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.CUST_ARCHIVES_TABLE);
			String cityCode = "";
			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));
			}
			cityCode = tf_BSSFlowRecord.getRecordIDS("CITYCODE"); //城市编号
			String SOiAREA_ID = custArchivesBean.getSERVIAREA_ID();//受理地区
			String SOiSERV_ID = tf_BSSFlowRecord.getRecordIDS(BssParameter.SERVISERV_ID);//服务编码(必须传,可为空)
			
			
			/*判断某服务档案是否允许办理变更业务(对判断条件进行合并)*/
			info = AdslFlowService.webCheck(tf_BSSFlowRecord,"1");
			info = "1";
			System.out.println("info==>"+info);
			if(info == null) {
				return null;
			}
			else if(info.equals("1")){
				//如果不能办理需调用WebServUnLock进行启用服务
				BssInter1.callWebServUnLock(SOiSERV_ID,"",cityCode);
				
				DataTable soType_dt = BssInter2.callWebQrySoType(cityCode);//查询申请类型信息
				tf_BSSFlowRecord.setRecordIDS("SO_TYPEISO_TYPE_ID",soType_dt.getRow(0).getString("SO_TYPEISO_TYPE_ID"));
				tf_BSSFlowRecord.setRecordIDS("SO_TYPEISO_TYPE_NAME",soType_dt.getRow(0).getString("SO_TYPEISO_TYPE_NAME"));
				DataTable soId_dt = BssInter6.callWebGetSoIDNbr(SOiAREA_ID,cityCode);//取申请流水号
				String SOiSO_ID = soId_dt.getRow(0).getString("SOISO_ID");
				String SOiSO_NBR = soId_dt.getRow(0).getString("SOISO_NBR");
				tf_BSSFlowRecord.setRecordFrom(soId_dt,BssParameter.SO_TABLE);
				tf_BSSFlowRecord.setRecordIDS("SOISO_ID",SOiSO_ID);//申请流水号
				tf_BSSFlowRecord.setRecordIDS("SOISO_NBR",SOiSO_NBR);//申请单号
				
				String SOiSO_TYPE_ID = "1";//申请类型编码(新装)
				String SOiSERV_TYPE_ID = "48";//LAN服务类型编码
				String SOiSERV_AREA_ID = SOiAREA_ID;//服务地区编码
				String SOiSERV_SO_ID = "";//服务申请流水号
				String SOiSERV_SO_SEQ = "";//服务申请流水序号
				String SOiSERV_SO_NBR = "";//服务地申请单号
				String SOiCUST_ID = custBean.getCUSTiCUST_ID();//客户编码
				String SOiSUBS_CODE = "";//用户代码
				String SOiDISCT_TYPE_ID = tf_BSSFlowRecord.getRecordIDS("DISCTTYPE");//优惠类型编码(需要获取)
				String SOiSTAFF_ID = "QZ02900";//CommonMethod.formatString(tf_BSSFlowRecord.getRecordIDS("DEVELOPMEN"));//发展员工编码QZ02900
				String SOiPRIORITY = tf_BSSFlowRecord.getRecordIDS("OPERATIONLEVEL");//处理级别
				String SOiACCEPT_TYPE = "N";//tf_BSSFlowRecord.getRecordIDS("ACCEPTSOURCE");//受理来源
				/*获取受理日期*/
				Date date = new Date();
				String SOiACCEPT_DATE = date.toLocaleString();//受理日期
				String SOiSTATE = "N";//状态
				String SOiANN_ACT_TYPE = "C";//附加动作类型
				String FLAG1 = "";//提交标志
				String STAFF_ID="QZ02900";
				String SOiPRI_SERV_ID = "";//主的serv_id(中继专用)
				
				//提交受理经办人，受理联系人
				String CORR_INFOiCONTACT_TYPE = "";
				String CORR_INFOiCONTACT_NAME = "";
				String CORR_INFOiCONTACT_TEL = "";
				String CORR_INFOiCERT_TYPE = "";
				String CORR_INFOiCERT_NBR = "";