adslflowservice.java

电信的网厅的整站代码

				else {
					return "";
				}
			}
			return "0";
		} catch (Exception rux) {
			log.warn(rux.getMessage(), rux);
			return "";
		}
	}*/
	
	
	/**判断两个协议是否依赖
	 * 
	 * @param protocolId
	 * @param prodOrderId
	 * @return
	 */
	/*public static String relaBProtoBySelect(String protocolId,String prodOrderId) {
		try {
			if (prodOrderId != null) {
				TF_BSSFlowRecord tf_BSSFlowRecord = TF_BSSFlowRecord.getBSSFlowRecord(new DacClient(),
						Long.parseLong(prodOrderId));
				DataTable select_protocol_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.SELECT_PROTOCOL_TABLE);
				String reProtocolId = "";
				String cityCode = tf_BSSFlowRecord.getRecordIDS("CITYCODE");
				String serviServ_id = tf_BSSFlowRecord.getRecordIDS(BssParameter.SERVISERV_ID);	
				if(select_protocol_dt != null && select_protocol_dt.getRows().getCount() > 0){
					for(int i=0;i<select_protocol_dt.getRows().getCount();i++) {
						String reProtocolId1 = select_protocol_dt.getRow(i).getString(BssParameter.PROTOCOLID);
						reProtocolId = "!"+reProtocolId1+"!";
						DataTable dt = BssInter6.callWebRelaBProto(protocolId,reProtocolId,serviServ_id,cityCode);
						boolean isHaving = false;
						if(dt.getRow(0).getString("SO_DISCT_PROTOCOLiSEQ").equals("1")) {
							for(int j=0;j<select_protocol_dt.getRows().getCount();j++) {
								String reProtocolId2 
								= select_protocol_dt.getRow(j).getString(BssParameter.PROTOCOLID);
								if(reProtocolId1.equals(reProtocolId2)) {
									isHaving = true;
									break;
								}
							}
							if(isHaving == false) {
								return "[" + getInfoByField_value(tf_BSSFlowRecord.getRecordFrom("ADSLPROTOCOL_TABLE"),
										reProtocolId1,"PROT_INFO_SYSiPROTOCOL_ID","PROT_INFO_SYSiPROTOCOL_NAME") + "]";
							}
							else  continue;
						}
					}
				}
				else {
					return "";
				}
			}
			return "0";
		} catch (Exception rux) {
			log.warn(rux.getMessage(), rux);
			return "";
		}
	}*/
	/**判断两个协议是否互斥
	 * 
	 * @param protocolId
	 * @param prodOrderId
	 * @return
	 */
	public static String mutexProto(String protocolId,String prodOrderId) {
		try {
			if (prodOrderId != null) {
				TF_BSSFlowRecord tf_BSSFlowRecord = TF_BSSFlowRecord.getBSSFlowRecord(new DacClient(),
						Long.parseLong(prodOrderId));
				DataTable select_protocol_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.SELECT_PROTOCOL_TABLE);
				String reProtocolId = "";
				String cityCode = tf_BSSFlowRecord.getRecordIDS("CITYCODE");
				if(select_protocol_dt != null && select_protocol_dt.getRows().getCount() > 0){
					for(int i=0;i<select_protocol_dt.getRows().getCount();i++) {
						reProtocolId = select_protocol_dt.getRow(i).getString(BssParameter.PROTOCOLID);
						DataTable dt = BssInter6.callWebMutexProto(protocolId,reProtocolId,cityCode);
						if(dt.getRow(0).getString("SO_DISCT_PROTOCOLiSEQ").equals("1")) {
							return "“" +getInfoByField_value(tf_BSSFlowRecord.getRecordFrom("ADSLPROTOCOL_TABLE"),
									reProtocolId,"PROT_INFO_SYSiPROTOCOL_ID","PROT_INFO_SYSiPROTOCOL_NAME") + "[" +
									reProtocolId + "]”";
						}	
					}
				}
				else {
					return "";
				}
			}
			return "0";
		} catch (Exception rux) {
			log.warn(rux.getMessage(), rux);
			return "";
		}
	}
	
	/**删除一条选中的协议
	 * 
	 * @param request
	 * @param response
	 * @param _map
	 * @return
	 */
	public static String removeSingleProtocol(ServletRequest request, ServletResponse response, Map _map) {
		String info = "";
		try {
			if (_map != null) {
				
				String prodOrderId = (String) _map.get("PRODORDERID");
				String protocolId = (String) _map.get("PROTOCOLID");
				//判断依赖
				String isrelaBProto = relaBProtoBySelect(protocolId,prodOrderId);
				if(!isrelaBProto.equals("0")) {
					return "2"+isrelaBProto;
				}
				DataRow dataRow = null;
				TF_BSSFlowRecord tf_BSSFlowRecord = TF_BSSFlowRecord.getBSSFlowRecord(new DacClient(),
						Long.parseLong(prodOrderId));
				DataTable select_protocol_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.SELECT_PROTOCOL_TABLE);

				String reProtocolId = "";
				for(int i=0;i<select_protocol_dt.getRows().getCount();i++){
					dataRow = select_protocol_dt.getRow(i);
					reProtocolId = dataRow.getString(BssParameter.PROTOCOLID);
					if(protocolId.equals(reProtocolId)){
						dataRow.delete();
					}
				}
				select_protocol_dt.acceptChanges();
				tf_BSSFlowRecord.setRecordFrom(select_protocol_dt,BssParameter.SELECT_PROTOCOL_TABLE);
				tf_BSSFlowRecord.save();
				info = "1";
			}
		} catch (Exception rux) {
			info = "0";
			log.warn(rux.getMessage(), rux);
		}
		
		return info;
	}
	
	/**添加一条选中的协议
	 * 
	 * @param request
	 * @param response
	 * @param _map
	 * @return
	 */
	public static String moveSingleProtocol(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");
				String protocolIds[] = new String[1];
				protocolIds[0] = protocolId;
				DataRow dataRow = null;
				TF_BSSFlowRecord tf_BSSFlowRecord = TF_BSSFlowRecord.getBSSFlowRecord(new DacClient(),
						Long.parseLong(prodOrderId));
				DataTable select_protocol_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.SELECT_PROTOCOL_TABLE);
				
				String level = getInfoByField_value(tf_BSSFlowRecord.getRecordFrom("ADSLPROTOCOL_TABLE"),
						protocolId,"PROT_INFO_SYSiPROTOCOL_ID","PROT_INFO_SYSIPROTOCOL_LEVEL");
				if(level.equals("2")) {
					return "3";
				}
				
				if(select_protocol_dt == null) {
//					判断依赖
					String isrelaBProto = relaBProto(protocolId,prodOrderId);
					if(!isrelaBProto.equals("0")) {
						return "1"+isrelaBProto;
					}
					select_protocol_dt = AdslFlowService.getNewTable(BssParameter.SELECT_PROTOCOL_TABLE,
							BssParameter.PROTOCOLID,protocolIds);
				}
				else if(select_protocol_dt.getRows().getCount() == 0) {
//					判断依赖
					String isrelaBProto = relaBProto(protocolId,prodOrderId);
					if(!isrelaBProto.equals("0")) {
						return "1"+isrelaBProto;
					}
					select_protocol_dt = AdslFlowService.addRows(select_protocol_dt,
							BssParameter.PROTOCOLID,protocolIds);
				}
				else {
					//判断依赖
					String isrelaBProto = relaBProto(protocolId,prodOrderId);
					if(!isrelaBProto.equals("0")) {
						return "1"+isrelaBProto;
					}
//					判断互斥
					String isMutexProto = mutexProto(protocolId,prodOrderId);
					if(!isMutexProto.equals("0")) {
						return "2"+isMutexProto;
					}
					select_protocol_dt = AdslFlowService.addRows(select_protocol_dt,
							BssParameter.PROTOCOLID,protocolIds);
				}
				tf_BSSFlowRecord.setRecordFrom(select_protocol_dt,BssParameter.SELECT_PROTOCOL_TABLE);
				tf_BSSFlowRecord.save();
				DataTable protocol_dt = tf_BSSFlowRecord.getRecordFrom("ADSLPROTOCOL_TABLE");
				String protocoName = "";
				String reProtocolId = "";
				_sb.append("<table>");
				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)){
						protocoName = dataRow.getString("PROT_INFO_SYSiPROTOCOL_NAME");
						_sb.append("<tr key='");
						_sb.append(reProtocolId);
						_sb.append("'>");
						_sb.append("<td class=\"body_td\" align=\"center\" nowrap>");
						_sb.append(protocoName);
						_sb.append("</td>");
						_sb.append("<td class=\"body_td\" align=\"center\" nowrap>");
						_sb.append(dataRow.getString("PROT_INFO_SYSiEXCLUDE"));
						_sb.append("</td>");
						_sb.append("<td class=\"body_td\" align=\"center\" nowrap>");
						_sb.append("&nbsp;");
						_sb.append("</td>");
						_sb.append("<td class=\"body_td\" align=\"center\" nowrap>");
						_sb.append("&nbsp;");
						_sb.append("</td>");
						_sb.append("<td class=\"body_td\" align=\"center\" nowrap>");
						_sb.append("&nbsp;");
						_sb.append("</td>");
						_sb.append("<td class=\"body_td\" align=\"center\" nowrap>");
						_sb.append(dataRow.getString("PROT_INFO_SYSiEFF_DATE"));
						_sb.append("</td>");
						_sb.append("<td class=\"body_td\" align=\"center\" nowrap>");
						_sb.append(dataRow.getString("PROT_INFO_SYSiEXP_DATE"));
						_sb.append("</td></tr>");
					}
				}
				_sb.append("</table>");
			}
		} catch (Exception rux) {
			log.warn(rux.getMessage(), rux);
		}
		
		return _sb.toString();
	}
	
	/**获得协议说明
	 * 
	 * @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("ADSLPROTOCOL_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) {
			log.warn(rux.getMessage(), rux);
		}
		return _sb.toString();
	}
	
	public static String webCheck(TF_BSSFlowRecord tf_BSSFlowRecord,String SOiSO_TYPE_ID) {
		/*判断某服务档案是否允许办理变更业务(对判断条件进行合并)*/
		String info = "";
		try {
			DataTable custArchives_dt = tf_BSSFlowRecord.getRecordFrom(BssParameter.CUST_ARCHIVES_TABLE);
			CustArchivesBean custArchivesBean = AdslFlow.setfirstflow(custArchives_dt);
			String SOiSERV_TYPE_ID = tf_BSSFlowRecord.getRecordIDS("SERVISERV_TYPE_ID");
			String SOiAREA_ID = custArchivesBean.getSERVIAREA_ID();
			String SOiSERV_ID = tf_BSSFlowRecord.getRecordIDS(BssParameter.SERVISERV_ID);
			String cityCode = tf_BSSFlowRecord.getRecordIDS("CITYCODE"); //城市编号
			FormBody fb = BssInter1.callWebCheckSoAlter("00004207",
					SOiSO_TYPE_ID,
					SOiSERV_TYPE_ID,
					SOiAREA_ID,
					SOiSERV_ID,
					cityCode);
			String isPass = (String)fb.get("TEMP_STS_WORDS1");
			if(isPass.equals("0"))
				info = (String)fb.get("ERROR_INFO");   
			else 
				info = "1";
		}catch(Exception e) {
			log.warn(e.getMessage(), e);
		}
		return info;
	}