1.路单、基础信息上传接口加入备用链路

王通
1 parent 2e50893e
Showing 4 changed files with 325 additions and 210 deletions
src/main/java/com/bsth/common/SystemParamKeys.java
src/main/java/com/bsth/data/SystemParamCache.java
src/main/java/com/bsth/service/impl/TrafficManageServiceImpl.java
src/main/resources/static/pages/trafficManage/js/lineStationUpload.js
@@ -52,4 +52,26 @@ public class SystemParamKeys {
     public static final String URL_HTTP_DVR = "url.http.dvr";
     public static final String URL_HTTP_DVR_PWD = "url.http.dvr.pwd";
+
+    public static final String DR_SYS_CITY_INTERFACE_URL = "dr.sys.city.interface.url";
+
+    public static final String DR_SYS_CITY_INTERFACE_URL1 = "dr.sys.city.interface.url1";
+
+    public static final String DR_SYS_CITY_INTERFACE_USER = "dr.sys.city.interface.user";
+
+    public static final String DR_SYS_CITY_INTERFACE_PASSWORD = "dr.sys.city.interface.password";
+
+    public static final String DR_SYS_AREA_INTERFACE_URL = "dr.sys.area.interface.url";
+
+    public static final String DR_SYS_AREA_INTERFACE_USER = "dr.sys.area.interface.user";
+
+    public static final String DR_SYS_AREA_INTERFACE_PASSWORD = "dr.sys.area.interface.password";
+
+    public static final String DR_SYS_CITY_INTERFACE_BAK_URL = "dr.sys.city.interface.bak.url";
+
+    public static final String DR_SYS_CITY_INTERFACE_BAK_URL1 = "dr.sys.city.interface.bak.url1";
+
+    public static final String DR_SYS_CITY_INTERFACE_BAK_USER = "dr.sys.city.interface.bak.user";
+
+    public static final String DR_SYS_CITY_INTERFACE_BAK_PASSWORD = "dr.sys.city.interface.bak.password";
 }
 \ No newline at end of file
@@ -113,6 +113,50 @@ public class SystemParamCache implements InitializingBean {
         return systemParamService1.getValue(SystemParamKeys.URL_HTTP_DVR_PWD);
     }
+    public static String getDrSysCityInterfaceUrl() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_CITY_INTERFACE_URL);
+    }
+
+    public static String getDrSysCityInterfaceUrl1() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_CITY_INTERFACE_URL1);
+    }
+
+    public static String getDrSysCityInterfaceUser() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_CITY_INTERFACE_USER);
+    }
+
+    public static String getDrSysCityInterfacePassword() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_CITY_INTERFACE_PASSWORD);
+    }
+
+    public static String getDrSysAreaInterfaceUrl() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_AREA_INTERFACE_URL);
+    }
+
+    public static String getDrSysAreaInterfaceUser() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_AREA_INTERFACE_USER);
+    }
+
+    public static String getDrSysAreaInterfacePassword() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_AREA_INTERFACE_PASSWORD);
+    }
+
+    public static String getDrSysCityInterfaceBakUrl() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_CITY_INTERFACE_BAK_URL);
+    }
+
+    public static String getDrSysCityInterfaceBakUrl1() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_CITY_INTERFACE_BAK_URL1);
+    }
+
+    public static String getDrSysCityInterfaceBakUser() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_CITY_INTERFACE_BAK_USER);
+    }
+
+    public static String getDrSysCityInterfaceBakPassword() {
+        return systemParamService1.getValue(SystemParamKeys.DR_SYS_CITY_INTERFACE_BAK_PASSWORD);
+    }
+
     @Override
     public void afterPropertiesSet() throws Exception {
         systemParamService1 = systemParamService;
 package com.bsth.service.impl;
 import com.bsth.data.BasicData;
+import com.bsth.data.SystemParamCache;
 import com.bsth.email.SendEmailController;
 import com.bsth.email.entity.EmailBean;
 import com.bsth.entity.*;
@@ -22,10 +23,9 @@ import com.bsth.service.traffic.YgcBasicDataService;
 import com.bsth.util.IpUtils;
 import com.bsth.util.TimeUtils;
 import com.bsth.util.db.DBUtils_MS;
-import com.bsth.webService.trafficManage.org.tempuri.Results;
-import com.bsth.webService.trafficManage.org.tempuri.WebServiceLocator;
-import com.bsth.webService.trafficManage.org.tempuri.WebServiceSoap;
-import com.bsth.webService.trafficManage.qp.WebServiceSoap_PortType;
+import com.bsth.webService.trafficManage.up.org.tempuri.Results;
+import com.bsth.webService.trafficManage.up.org.tempuri.WebServiceLocator;
+import com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap;
 import org.apache.commons.lang.StringEscapeUtils;
 import org.apache.commons.lang.StringUtils;
 import org.apache.commons.lang.time.DateUtils;
@@ -134,20 +134,38 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	private LineVersionsRepository lineVersionsRepository;
 	// 运管处上传接口
-	private com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap webServiceSoapUp;
-	private WebServiceSoap ssop ;
-	{
-		try {
-			ssop = new WebServiceLocator().getWebServiceSoap();
-		} catch (Exception e) {
-			e.printStackTrace();
-		}
-	}
+	private WebServiceSoap ssop,ssop1;
+	private WebServiceSoap ssopBak,ssopBak1;
 	// 青浦接口
-	private WebServiceSoap_PortType qp_ssop;
+	private WebServiceSoap qp_ssop;
 	{
 		try {
-			qp_ssop = new com.bsth.webService.trafficManage.qp.WebServiceLocator().getWebServiceSoap();
+			WebServiceLocator locator = new WebServiceLocator();
+			String url = SystemParamCache.getDrSysCityInterfaceUrl();
+			if (StringUtils.isNotEmpty(url)) {
+				locator.setWebServiceSoapEndpointAddress(url);
+				ssop = locator.getWebServiceSoap();
+			}
+			url = SystemParamCache.getDrSysCityInterfaceUrl1();
+			if (StringUtils.isNotEmpty(url)) {
+				locator.setWebServiceSoapEndpointAddress(url);
+				ssop1 = locator.getWebServiceSoap();
+			}
+			url = SystemParamCache.getDrSysCityInterfaceBakUrl();
+			if (StringUtils.isNotEmpty(url)) {
+				locator.setWebServiceSoapEndpointAddress(url);
+				ssopBak = locator.getWebServiceSoap();
+			}
+			url = SystemParamCache.getDrSysCityInterfaceBakUrl1();
+			if (StringUtils.isNotEmpty(url)) {
+				locator.setWebServiceSoapEndpointAddress(url);
+				ssopBak1 = locator.getWebServiceSoap();
+			}
+			url = SystemParamCache.getDrSysAreaInterfaceUrl();
+			if (StringUtils.isNotEmpty(url)) {
+				locator.setWebServiceSoapEndpointAddress(url);
+				qp_ssop = locator.getWebServiceSoap();
+			}
 		} catch (Exception e) {
 			e.printStackTrace();
 		}
@@ -161,19 +179,19 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	// 数字格式化
 	DecimalFormat format = new DecimalFormat("0.00");
-	// 用户名
-	private final String userNameOther = "user";
-	// 密码
-	private final String passwordOther = "user";
+	private final String userNameOther = SystemParamCache.getDrSysCityInterfaceUser();
+
+	private final String passwordOther = SystemParamCache.getDrSysCityInterfacePassword();
+
+	private final String userNameUp = SystemParamCache.getDrSysCityInterfaceBakUser();
+
+	private final String passwordUp = SystemParamCache.getDrSysCityInterfaceBakPassword();
-	private final String userNameOther_qp = "china317";
+	private final String userNameOther_qp = SystemParamCache.getDrSysAreaInterfaceUser();
+
+	private final String passwordOther_qp = SystemParamCache.getDrSysAreaInterfacePassword();
-	private final String passwordOther_qp = "china317";
-	// 用户名
-	private final String userNameUp = "user";
-	// 密码
-	private final String passwordUp = "user";
 	// 接收邮件人
 	@Value("${waybill.emails}")
@@ -182,17 +200,6 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	// 记录路单上线的成功、失败线路数
 	private Integer countSuccess,countFailure;
-	private synchronized com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap  getWebServiceSoapUp(){
-		try {
-			if(webServiceSoapUp == null){
-				webServiceSoapUp = new com.bsth.webService.trafficManage.up.org.tempuri.WebServiceLocator().getWebServiceSoap();
-			}
-		}catch (Exception e){
-			e.printStackTrace();
-		}finally {
-			return webServiceSoapUp;
-		}
-	}
 	/**
 	 * 上传线路信息
 	 */
@@ -272,11 +279,16 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					return "0";
 				}
 				// 调用上传方法
-				if(getWebServiceSoapUp().setXL(userNameUp,passwordUp,sBuffer.toString()).isSuccess()){
+				if(ssop1.setXL(userNameOther,passwordOther,sBuffer.toString()).isSuccess()){
 					result = "success";
 				}else{
 					result = "failure";
 				}
+				if (ssopBak1.setXL(userNameOther,passwordOther,sBuffer.toString()).isSuccess()) {
+					result += ",success";
+				} else {
+					result += ",failure";
+				}
 				logger.info("setXL:"+sBuffer.toString());
 				logger.info("setXL:"+result);
 			}
@@ -369,6 +381,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			if(ssop.setCL(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
 				result = "success";
 			}
+			if (ssopBak != null && ssopBak.setCL(userNameOther, passwordOther, sBuffer.toString()).isSuccess()) {
+				result += ",success";
+			}
 		} catch (Exception e) {
 			logger.error("setCL:",e);
 			e.printStackTrace();
@@ -406,7 +421,10 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			sBuffer.append("</SJs>");
 			if(ssop.setSJ(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
 				result = "success";
-			};
+			}
+			if (ssopBak != null && ssopBak.setSJ(userNameOther, passwordOther, sBuffer.toString()).isSuccess()) {
+				result += ",success";
+			}
 		} catch (Exception e) {
 			logger.error("setSJ:",e);
 			e.printStackTrace();
@@ -448,6 +466,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 		String str = "", xlbm = null, oldXlbm = null;
 		List<Map<String,Object>> listGroup = null;
 		int scount = 0, ccount = 0;
+		int scount1 = 0, ccount1 = 0;
 		long start = System.currentTimeMillis();
 		try {
 			// 计数器
@@ -489,6 +508,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					Line line = code2line.get(lineCode);
 					if(line == null || line.getInUse() == null || line.getInUse() == 0){
 						ccount++;
+						ccount1++;
 						continue;
 					}
 					if(counter % per == 0){
@@ -567,7 +587,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					sf.append("</DLDS>");
 					// 去掉'号
 					str = sf.toString().replace("'","");
-					scount += invokeSetLD(str, counter);
+					scount += invokeSetLD(ssop, str, counter, "master");
+					scount1 += invokeSetLD(ssopBak, str, counter, "slave");
 					counter = 0;
 				}
 			}
@@ -576,7 +597,10 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 				sf.append("</DLDS>");
 				// 去掉'号
 				str = sf.toString().replace("'","");
-				scount += invokeSetLD(str, counter);
+				scount += invokeSetLD(ssop, str, counter, "master");
+				if (ssopBak != null) {
+					scount1 += invokeSetLD(ssopBak, str, counter, "slave");
+				}
 			}
 		} catch (Exception e) {
 			e.printStackTrace();
@@ -587,7 +611,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					//发送邮件
 					EmailBean mail = new EmailBean();
 					mail.setSubject(IpUtils.getLocalIpAddress() +":路单日志数据"+date);
-					mail.setContent("总数：" + (listGroup == null ? 0 : listGroup.size()) + "<br/>成功数：" + scount + "<br/>跳过数：" + ccount + "<br/>耗时：" + (System.currentTimeMillis() - start));
+					mail.setContent("总数：" + (listGroup == null ? 0 : listGroup.size()) + "<br/>成功数：" + scount + "," + scount1 + "<br/>跳过数：" + ccount + "," + ccount1 + "<br/>耗时：" + (System.currentTimeMillis() - start));
 					sendEmailController.sendMail(email, mail);
 				}
 				logger.info("setLD-sendMail:邮件发送成功！");
@@ -605,21 +629,24 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	 * @param counter 分组数
 	 * @return 成功返回counter 失败返回0
 	 */
-	private int invokeSetLD(String xml, int counter) {
+	private int invokeSetLD(WebServiceSoap ssop, String xml, int counter, String flag) {
+		if ("slave".equals(flag)) {
+			System.out.println("slave");
+		}
 		for (int i = 0;i < 10;i++) {
 			try {
 				Results results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(xml));
 				if (results.isSuccess()) {
-					logger.info("setLD: " + xml);
+					logger.info("{} setLD: {}", flag, xml);
 					logger.info("setLD: 成功");
 					return counter;
 				} else if (i == 9) {
-					logger.error("setLD: " + xml);
+					logger.error("{} setLD: {}", flag, xml);
 					logger.error("setLD: 失败，" + results.getMessage());
 				}
 				Thread.sleep(2000);
 			} catch (Exception e) {
-				logger.error("运管处接口调用异常", e);
+				logger.error("{} 运管处接口调用异常", flag, e);
 				try {
 					Thread.sleep(2000);
 				} catch (InterruptedException ex) {
@@ -666,8 +693,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 						ygsXml.append("</DLDS>");
 						try {
 							logger.info("xml："+StringEscapeUtils.unescapeHtml(ygsXml.toString().replace("'","")));
-							com.bsth.webService.trafficManage.qp.Results res
-									= qp_ssop.setLD(userNameOther_qp,passwordOther_qp,StringEscapeUtils.unescapeHtml(ygsXml.toString().replace("'","")));
+							Results res = qp_ssop.setLD(userNameOther_qp,passwordOther_qp,StringEscapeUtils.unescapeHtml(ygsXml.toString().replace("'","")));
 							logger.info("青浦路单是否上传成功："+res.isSuccess());
 						}catch (Exception e){
 							logger.error("青浦路单上传异常", e);
@@ -758,8 +784,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			// 发送到青浦运管所
 			try {
 				logger.info("xml："+StringEscapeUtils.unescapeHtml(ygsXml.toString().replace("'","")));
-				com.bsth.webService.trafficManage.qp.Results res
-						= qp_ssop.setLD(userNameOther_qp,passwordOther_qp,StringEscapeUtils.unescapeHtml(ygsXml.toString().replace("'","")));
+				Results res = qp_ssop.setLD(userNameOther_qp,passwordOther_qp,StringEscapeUtils.unescapeHtml(ygsXml.toString().replace("'","")));
 				logger.info("青浦路单是否上传成功1："+res.isSuccess());
 			}catch (Exception e){
 				logger.error("青浦路单上传异常1", e);
@@ -772,7 +797,6 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			for (StackTraceElement traceElement : e.getStackTrace()){
 				logFailure.append("\r\t").append(traceElement);
 			}
-			e.printStackTrace();
 		}
 		return result;
@@ -838,6 +862,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			if(rss.isSuccess()){
 				result = "success";
 			}
+			if (ssopBak != null && ssopBak.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(tmp)).isSuccess()) {
+				result += ",success";
+			}
 		} catch (Exception e) {
 			logger.error("setLD:",e);
 			e.printStackTrace();
@@ -939,6 +966,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			if(ssop.setLCYH(userNameOther, passwordOther, sf.toString()).isSuccess()){
 				result = "success";
 			}
+			if (ssopBak != null && ssopBak.setLCYH(userNameOther, passwordOther, sf.toString()).isSuccess()) {
+				result += ",success";
+			}
 		} catch (Exception e) {
 			logger.error("setLCYH:",e);
 			e.printStackTrace();
@@ -1043,6 +1073,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			if(ssop.setDDRB(userNameOther, passwordOther, sf.toString()).isSuccess()){
 				result = "success";
 			}
+			if (ssopBak != null && ssopBak.setDDRB(userNameOther, passwordOther, sf.toString()).isSuccess()) {
+				result += ",success";
+			}
 		} catch (Exception e) {
 			logger.error("setDDRB:",e);
 			e.printStackTrace();
@@ -1161,6 +1194,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			if(ssop.setJHBC(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
 				result = "success";
 			}
+			if (ssopBak != null && ssopBak.setJHBC(userNameOther, passwordOther, sBuffer.toString()).isSuccess()) {
+				result += ",success";
+			}
 		} catch (Exception e) {
 			logger.error("setJHBC:",e);
 			e.printStackTrace();
@@ -1351,6 +1387,13 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 				result = "上传失败";
 				state = "0";
 			}
+			if (ssopBak != null) {
+				if (ssopBak.setSKB(userNameOther, passwordOther, sBuffer.toString()).isSuccess()) {
+					result += ",上传成功";
+				} else {
+					result += ",上传失败";
+				}
+			}
 			logger.info("xml:" + sBuffer.toString());
 			logger.info("上传结果:" + result);
 			// 保存运管处上传记录
@@ -1497,6 +1540,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			if(ssop.setXLPC(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
 				result = "success";
 			}
+			if (ssopBak != null && ssopBak.setXLPC(userNameOther, passwordOther, sBuffer.toString()).isSuccess()) {
+				result += ",success";
+			}
 		} catch (Exception e) {
 			logger.error("setXLPC:",e);
 			e.printStackTrace();
@@ -1557,6 +1603,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			if(ssop.setCS(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
 				result = "success";
 			}
+			if (ssopBak != null && ssopBak.setCS(userNameOther, passwordOther, sBuffer.toString()).isSuccess()) {
+				result += ",success";
+			}
 		} catch (Exception e) {
 			logger.error("setCS:",e);
 			e.printStackTrace();
-/**
- * 
- * @JSName : common.js(运管功能公共js)
- * 
- * @Author : bsth@lq
- * 
- * @Description : TODO(运管功能公共js)
- * 
- * @Data : 2016年6月29日 上午9:21:17
- *
- * @Version 公交调度系统BS版 0.1
- * 
- */
-
-(function(){
-    function getComp(cb) {
-        $.get('/user/companyData',null,function(rs) {
-            return cb && cb(rs);
-        });
-    }
-
-    initLineSelect2();
-
-    function initLineSelect2(compD) {
-        getComp(function(rs) {
-            var params = {};
-            if(rs.length>0) {
-                var compA = new Array();
-                for(var c = 0 ; c<rs.length;c++) {
-                    var comC = rs[c].companyCode;
-                    var child = rs[c].children;
-                    if(child.length>0) {
-                        for(var d = 0 ;d< child.length;d++) {
-                            compA.push(comC + '_' + child[d].code);
-                        }
-                    }else {
-                        compA.push(comC);
-                    }
-                }
-                params.cgsbm_in  = compA.toString();
-            }
-            params["remove_ne"] = 1;
-            // 填充线路拉框选择值
-            $get('/line/all', params, function(array){
-                var len_ = array.length,paramsD = new Array();
-                if(len_>0) {
-                    $.each(array, function(i, g){
-                        if(g.name!='' || g.name != null) {
-                            paramsD.push({'id':g.id ,'text':g.name});
-                        }
-                    });
-                    initPinYinSelect2($('#line'),paramsD,function(selector) {
-                        selector.select2("val", storage.xlName_AgursData);
-                    });
-                }
-            });
-        });
-    }
-
-	// 绑定查询事件
-	$("#search").click(searchM);
-	// 绑定上传事件
-	$("#upload").click(uploadM);
-	// 绑定全部移到右边事件
-	$("#to_right").click(function(){
-		$("#left_div tbody tr:not(.muted)").click();
-	});
-	// 绑定全部移到左边事件
-	$("#to_left").click(function(){
-		$("#right_div tbody tr:not(.muted)").click();
-	});
-	// 查询方法
-	function searchM() {
-		// 清空已选定列表
-		$("#right_div table tbody").empty();
-		var params = {};
-		// 取得输入框的值
-        var inputs = $(".param input,select");
-		// 遍历数组
-		$.each(inputs, function(i, element) {
-			params[$(element).attr("name")] = $(element).val();
-		});
-		var i = layer.load(2);
-		$get('/line', params, function(data) {
-			var bodyHtm = template('lineStation_list_temp', {
-				list : data.content
-			});
-			$("#left_div table tbody").empty();
-			$("#left_div table tbody").append(bodyHtm);
-			$("#left_div tbody tr:not(.muted)").click(_click);
-			layer.close(i);
-		});
-	}
-
-	// 上传方法
-	function uploadM() {
-        // 取得输入框的值
-        var trs = $("#right_div tbody tr input");
-        if (trs.length == 0) {
-            alert("请选择线路");
-            return;
-        }else if(trs.length > 1){
-            alert("一次只能上传一条线路");
-            return;
-        }
-        var ids ="0,";
-        // 遍历数组
-        $.each(trs, function(i, element) {
-            ids +=$(element).val()+",";
-        });
-        var params = {"ids":ids};
-        $.ajax({
-            type: 'get',url: '/trmg/setXL',
-            data: params ,dataType:'text',
-            success:function(data) {
-                if(data == 'success'){
-                    alert("上传成功");
-                }else if(data == '0'){
-                    alert("上传失败，线路编号有0");
-                }else{
-                    alert("上传失败");
-                }
-
-            }, error : function() {
-                alert("操作失败");
-            }
-
-        });
-	}
-
-	// 表格行的单击事件
-	function _click() {
-		var tmpTr = $(this).clone();
-		tmpTr.unbind("click").click(_click);
-		// 判断父DIV的ID
-		if ($(this).closest(".table-container").attr("id") == "left_div") {
-			// 把要移动行的class=".seq"的HTML的内容设成另一分类的最后一个序号
-			$(".seq",tmpTr).html($("#right_div tbody tr:not(.muted)").length + 1);
-			$("#right_div tbody").append(tmpTr);
-			nextAllChildSeqMinusOne($(this));
-		} else {
-			// 把要移动行的class=".seq"的HTML的内容设成另一分类的最后一个序号
-			$(".seq",tmpTr).html($("#left_div tbody tr:not(.muted)").length + 1);
-			$("#left_div tbody").append(tmpTr);
-			nextAllChildSeqMinusOne($(this));
-		}
-		$(this).remove();
-	}
-
-	// 后面所有兄弟节点的中class=".seq"的HTML的内容自减 1
-	function nextAllChildSeqMinusOne(theElement){
-		$.each(theElement.nextAll(),function(i,e){
-			$(".seq",e).html($(".seq",e).html() - 1);
-		});
-	}
-	// 保存左边空表格
-	var leftDivTemplate = $("#left_div table").clone(true);
-	// 把左边表格的格式复制到右边
-	$("#right_div").append(leftDivTemplate);
-
+/**
+ * 
+ * @JSName : common.js(运管功能公共js)
+ * 
+ * @Author : bsth@lq
+ * 
+ * @Description : TODO(运管功能公共js)
+ * 
+ * @Data : 2016年6月29日 上午9:21:17
+ *
+ * @Version 公交调度系统BS版 0.1
+ * 
+ */
+
+(function(){
+    function getComp(cb) {
+        $.get('/user/companyData',null,function(rs) {
+            return cb && cb(rs);
+        });
+    }
+
+    initLineSelect2();
+
+    function initLineSelect2(compD) {
+        getComp(function(rs) {
+            var params = {};
+            if(rs.length>0) {
+                var compA = new Array();
+                for(var c = 0 ; c<rs.length;c++) {
+                    var comC = rs[c].companyCode;
+                    var child = rs[c].children;
+                    if(child.length>0) {
+                        for(var d = 0 ;d< child.length;d++) {
+                            compA.push(comC + '_' + child[d].code);
+                        }
+                    }else {
+                        compA.push(comC);
+                    }
+                }
+                params.cgsbm_in  = compA.toString();
+            }
+            params["remove_ne"] = 1;
+            // 填充线路拉框选择值
+            $get('/line/all', params, function(array){
+                var len_ = array.length,paramsD = new Array();
+                if(len_>0) {
+                    $.each(array, function(i, g){
+                        if(g.name!='' || g.name != null) {
+                            paramsD.push({'id':g.id ,'text':g.name});
+                        }
+                    });
+                    initPinYinSelect2($('#line'),paramsD,function(selector) {
+                        selector.select2("val", storage.xlName_AgursData);
+                    });
+                }
+            });
+        });
+    }
+
+	// 绑定查询事件
+	$("#search").click(searchM);
+	// 绑定上传事件
+	$("#upload").click(uploadM);
+	// 绑定全部移到右边事件
+	$("#to_right").click(function(){
+		$("#left_div tbody tr:not(.muted)").click();
+	});
+	// 绑定全部移到左边事件
+	$("#to_left").click(function(){
+		$("#right_div tbody tr:not(.muted)").click();
+	});
+	// 查询方法
+	function searchM() {
+		// 清空已选定列表
+		$("#right_div table tbody").empty();
+		var params = {};
+		// 取得输入框的值
+        var inputs = $(".param input,select");
+		// 遍历数组
+		$.each(inputs, function(i, element) {
+			params[$(element).attr("name")] = $(element).val();
+		});
+		var i = layer.load(2);
+		$get('/line', params, function(data) {
+			var bodyHtm = template('lineStation_list_temp', {
+				list : data.content
+			});
+			$("#left_div table tbody").empty();
+			$("#left_div table tbody").append(bodyHtm);
+			$("#left_div tbody tr:not(.muted)").click(_click);
+			layer.close(i);
+		});
+	}
+
+	// 上传方法
+	function uploadM() {
+        // 取得输入框的值
+        var trs = $("#right_div tbody tr input");
+        if (trs.length == 0) {
+            alert("请选择线路");
+            return;
+        }else if(trs.length > 1){
+            alert("一次只能上传一条线路");
+            return;
+        }
+        var ids ="0,";
+        // 遍历数组
+        $.each(trs, function(i, element) {
+            ids +=$(element).val()+",";
+        });
+        var params = {"ids":ids};
+        $.ajax({
+            type: 'get',url: '/trmg/setXL',
+            data: params ,dataType:'text',
+            success:function(data) {
+                if(data.indexOf('success,') > -1){
+                    alert("上传成功");
+                }else if(data == '0'){
+                    alert("上传失败，线路编号有0");
+                }else{
+                    alert("上传失败");
+                }
+
+            }, error : function() {
+                alert("操作失败");
+            }
+
+        });
+	}
+
+	// 表格行的单击事件
+	function _click() {
+		var tmpTr = $(this).clone();
+		tmpTr.unbind("click").click(_click);
+		// 判断父DIV的ID
+		if ($(this).closest(".table-container").attr("id") == "left_div") {
+			// 把要移动行的class=".seq"的HTML的内容设成另一分类的最后一个序号
+			$(".seq",tmpTr).html($("#right_div tbody tr:not(.muted)").length + 1);
+			$("#right_div tbody").append(tmpTr);
+			nextAllChildSeqMinusOne($(this));
+		} else {
+			// 把要移动行的class=".seq"的HTML的内容设成另一分类的最后一个序号
+			$(".seq",tmpTr).html($("#left_div tbody tr:not(.muted)").length + 1);
+			$("#left_div tbody").append(tmpTr);
+			nextAllChildSeqMinusOne($(this));
+		}
+		$(this).remove();
+	}
+
+	// 后面所有兄弟节点的中class=".seq"的HTML的内容自减 1
+	function nextAllChildSeqMinusOne(theElement){
+		$.each(theElement.nextAll(),function(i,e){
+			$(".seq",e).html($(".seq",e).html() - 1);
+		});
+	}
+	// 保存左边空表格
+	var leftDivTemplate = $("#left_div table").clone(true);
+	// 把左边表格的格式复制到右边
+	$("#right_div").append(leftDivTemplate);
+
 })();
 \ No newline at end of file