1.青浦上传至运管所的电子路单需按线路分割上传，同一条线路被分割会只认一条数据

王通
1 parent b6838416
Showing 1 changed file with 42 additions and 37 deletions
src/main/java/com/bsth/service/impl/TrafficManageServiceImpl.java
@@ -445,10 +445,11 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			Map<String,Object> map = new HashMap();
 			HashMap<String,String> paramMap;
 			HashMap<String,String> otherMap = new HashMap();
-			String oldXlbm = "";
-			StringBuilder ygsXml = new StringBuilder();
+			String oldXlbm = null;
+			StringBuilder ygsXml = new StringBuilder(), lineXml = new StringBuilder();
 			for(Map<String,Object> schRealInfo:listGroup){
 				if(schRealInfo != null){
+					StringBuilder sri = new StringBuilder();
 					//根据车辆自编号查询车牌号
 					map.put("insideCode_eq", schRealInfo.get("clZbh")+"");
 					Cars car = carsRepository.findOne(new CustomerSpecs<Cars>(map));
@@ -467,13 +468,13 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					if(logXlbmMap.get(xlbm) == null){
 						logXlbmMap.put(xlbm,xlbm);
 					}
-					sf.append("<DLD>");
-					sf.append("<RQ>"+date+"</RQ>");
-					sf.append("<XLBM>"+xlbm+"</XLBM>");
-					sf.append("<LPBH>"+schRealInfo.get("lpName")+"</LPBH>");
-					sf.append("<CPH>"+car.getCarPlate()+"</CPH>");
-					sf.append("<UPDT>"+sdfnyrsfm.format(new Date())+"</UPDT>");
-					sf.append("<LDList>");
+					sri.append("<DLD>");
+					sri.append("<RQ>"+date+"</RQ>");
+					sri.append("<XLBM>"+xlbm+"</XLBM>");
+					sri.append("<LPBH>"+schRealInfo.get("lpName")+"</LPBH>");
+					sri.append("<CPH>"+car.getCarPlate()+"</CPH>");
+					sri.append("<UPDT>"+sdfnyrsfm.format(new Date())+"</UPDT>");
+					sri.append("<LDList>");
 					for(ScheduleRealInfo scheduleRealInfo:list){
 						if((schRealInfo.get("xlBm")+"").equals(scheduleRealInfo.getXlBm()) && (schRealInfo.get("lpName")+"")
@@ -494,43 +495,45 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 								continue;
 							}
-							sf.append("<LD>");
-							sf.append("<SJGH>"+scheduleRealInfo.getjGh()+"</SJGH>");
-							sf.append("<SXX>"+scheduleRealInfo.getXlDir()+"</SXX>");
-							sf.append("<FCZDMC>"+scheduleRealInfo.getQdzName()+"</FCZDMC>");
+							sri.append("<LD>");
+							sri.append("<SJGH>"+scheduleRealInfo.getjGh()+"</SJGH>");
+							sri.append("<SXX>"+scheduleRealInfo.getXlDir()+"</SXX>");
+							sri.append("<FCZDMC>"+scheduleRealInfo.getQdzName()+"</FCZDMC>");
 							// 起点站的参数
 							otherMap.put("stationMark","B");
 							paramMap = packageYgcStationNumParam(scheduleRealInfo,otherMap);
-							sf.append("<FCZDXH>" + getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,null) + "</FCZDXH>");
-							sf.append("<FCZDBM>"+scheduleRealInfo.getQdzCode()+"</FCZDBM>");
-							sf.append("<JHFCSJ>"+scheduleRealInfo.getFcsj()+"</JHFCSJ>");
-							sf.append("<DFSJ>"+scheduleRealInfo.getDfsj()+"</DFSJ>");
-							sf.append("<SJFCSJ>"+scheduleRealInfo.getFcsjActual()+"</SJFCSJ>");
-							sf.append("<FCZDLX>"+""+"</FCZDLX>");
-							sf.append("<DDZDMC>"+scheduleRealInfo.getZdzName()+"</DDZDMC>");
+							sri.append("<FCZDXH>" + getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,null) + "</FCZDXH>");
+							sri.append("<FCZDBM>"+scheduleRealInfo.getQdzCode()+"</FCZDBM>");
+							sri.append("<JHFCSJ>"+scheduleRealInfo.getFcsj()+"</JHFCSJ>");
+							sri.append("<DFSJ>"+scheduleRealInfo.getDfsj()+"</DFSJ>");
+							sri.append("<SJFCSJ>"+scheduleRealInfo.getFcsjActual()+"</SJFCSJ>");
+							sri.append("<FCZDLX>"+""+"</FCZDLX>");
+							sri.append("<DDZDMC>"+scheduleRealInfo.getZdzName()+"</DDZDMC>");
 							// 终点站的参数
 							otherMap.put("stationMark","E");
 							paramMap = packageYgcStationNumParam(scheduleRealInfo,otherMap);
-							sf.append("<DDZDXH>"+ getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,null) +"</DDZDXH>");
-							sf.append("<DDZDBM>"+scheduleRealInfo.getZdzCode()+"</DDZDBM>");
-							sf.append("<JHDDSJ>"+scheduleRealInfo.getZdsj()+"</JHDDSJ>");
-							sf.append("<SJDDSJ>"+scheduleRealInfo.getZdsjActual()+"</SJDDSJ>");
-							sf.append("<DDZDLX>"+""+"</DDZDLX>");
-							sf.append("<LDSCBZ>"+0+"</LDSCBZ>");
-							sf.append("<DDBZ>").append(scheduleRealInfo.getRemarks() == null ? "" : scheduleRealInfo.getRemarks()).append("</DDBZ>");
-							sf.append("</LD>");
+							sri.append("<DDZDXH>"+ getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,null) +"</DDZDXH>");
+							sri.append("<DDZDBM>"+scheduleRealInfo.getZdzCode()+"</DDZDBM>");
+							sri.append("<JHDDSJ>"+scheduleRealInfo.getZdsj()+"</JHDDSJ>");
+							sri.append("<SJDDSJ>"+scheduleRealInfo.getZdsjActual()+"</SJDDSJ>");
+							sri.append("<DDZDLX>"+""+"</DDZDLX>");
+							sri.append("<LDSCBZ>"+0+"</LDSCBZ>");
+							sri.append("<DDBZ>").append(scheduleRealInfo.getRemarks() == null ? "" : scheduleRealInfo.getRemarks()).append("</DDBZ>");
+							sri.append("</LD>");
 						}
 					}
-					sf.append("</LDList>");
-					sf.append("</DLD>");
+					sri.append("</LDList>");
+					sri.append("</DLD>");
+					sf.append(sri);
+					lineXml.append(sri);
 				}
 				if(counter % per == per - 1){
 					counter = 0;
 					sf.append("</DLDS>");
 					str = sf.toString().replace("'","");// 去掉'号
-					results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
+					//results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
 					// 记录日志
-					result = logRecord(results,logXlbmMap,logXlbmSuccessMap,logXlbmFailureMap,logSuccess,logFailure,str);
+					//result = logRecord(results,logXlbmMap,logXlbmSuccessMap,logXlbmFailureMap,logSuccess,logFailure,str);
 					// 发送到青浦运管处
 					/*try {
 						logger.info("xml："+StringEscapeUtils.unescapeHtml(str));
@@ -548,7 +551,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					if (oldXlbm != null) {
 						ygsXml.append("</DLDS>");
 						try {
-							logger.info("xml："+StringEscapeUtils.unescapeHtml(ygsXml.toString()));
+							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("'","")));
 							logger.info("青浦路单是否上传成功："+res.isSuccess());
@@ -558,8 +561,10 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 						}
 					}
 					ygsXml = new StringBuilder("<DLDS>");
+					lineXml = new StringBuilder();
+					oldXlbm = String.valueOf(schRealInfo.get("xlBm"));
 				} else {
-					ygsXml.append(sf.toString().replace("<DLDS>", "").replace("</DLDS>", ""));
+					ygsXml.append(lineXml);
 				}
 			}
 			// 每per条线路上传后剩下的数据再上传
@@ -567,10 +572,10 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 				ygsXml.append("</DLDS>");
 				sf.append("</DLDS>");
 				str = sf.toString().replace("'","");// 去掉'号
-				results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
+				//results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
 				// 发送到青浦运管处
 				try {
-					logger.info("xml："+StringEscapeUtils.unescapeHtml(str));
+					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("'","")));
 					logger.info("青浦路单是否上传成功："+res.isSuccess());
@@ -579,7 +584,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 				}
 			}
 			// 记录日志
-			result = logRecord(results,logXlbmMap,logXlbmSuccessMap,logXlbmFailureMap,logSuccess,logFailure,str);
+			//result = logRecord(results,logXlbmMap,logXlbmSuccessMap,logXlbmFailureMap,logSuccess,logFailure,str);
 		} catch (Exception e) {
 			logger.error("setLD:",e);
 			logFailure.append(e).append("<br/>");