1.路单上传道运局和道运中心上传分开，先传道运局后传道运中心，道运局有10次重传

王通
1 parent 65a3b3b6
Showing 1 changed file with 220 additions and 51 deletions
src/main/java/com/bsth/service/impl/TrafficManageServiceImpl.java
@@ -19,6 +19,7 @@ import com.bsth.repository.traffic.SKBUploadLoggerRepository;
 import com.bsth.security.util.SecurityUtils;
 import com.bsth.service.TrafficManageService;
 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;
@@ -28,9 +29,11 @@ import com.bsth.webService.trafficManage.qp.WebServiceSoap_PortType;
 import org.apache.commons.lang.StringEscapeUtils;
 import org.apache.commons.lang.StringUtils;
 import org.apache.commons.lang.time.DateUtils;
+import org.joda.time.DateTime;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.domain.Sort.Direction;
 import org.springframework.security.core.context.SecurityContextHolder;
@@ -127,6 +130,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	@Autowired
 	private SendEmailController sendEmailController;
+	@Autowired
+	private LineVersionsRepository lineVersionsRepository;
+
 	// 运管处上传接口
 	private com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap webServiceSoapUp;
 	private WebServiceSoap ssop ;
@@ -168,8 +174,11 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	private final String userNameUp = "user";
 	// 密码
 	private final String passwordUp = "user";
+
 	// 接收邮件人
-	private final String emailSendToAddress = "175912183@qq.com";
+	@Value("${waybill.emails}")
+	private String[] emails;
+
 	// 记录路单上线的成功、失败线路数
 	private Integer countSuccess,countFailure;
@@ -414,7 +423,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	 * @return
 	 */
 	public String setLD(String theDate){
-		return uploadLD(theDate);
+		uploadLD(theDate);
+		return uploadLD1(theDate);
 	}
 	/**
@@ -422,19 +432,213 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	 * @return
 	 */
 	public String setLD(){
-		return uploadLD(null);
+		uploadLD(null);
+		return uploadLD1(null);
 	}
+
 	/**
 	 * 上传路单
 	 * @return 上传成功标识
 	 */
 	private String uploadLD(String theDate){
+		// 取昨天 的日期
+		String date = theDate == null ?sdfnyr.format(DateUtils.addDays(new Date(), -1)) : theDate;
+		StringBuffer sf = new StringBuffer();
+		Results results = null;
+		String str = "", xlbm = null, oldXlbm = null;
+		List<Map<String,Object>> listGroup = null;
+		int scount = 0, ccount = 0;
+		long start = System.currentTimeMillis();
+		try {
+			// 计数器
+			int counter = 0;
+			// 每几条线路上传一次路单
+			int per = 10;
+			List<ScheduleRealInfo> list = scheduleRealInfoRepository.setLD(date);
+			listGroup = scheduleRealInfoRepository.setLDGroup(date);
+			Map<String,Object> map = new HashMap();
+			HashMap<String,String> paramMap;
+			HashMap<String,String> otherMap = new HashMap();
+
+			// 车辆内部编码和车牌做映射
+			Map<String, String> inside2plate = new HashMap<>();
+			Iterable<Cars> cars = carsRepository.findAll();
+			for (Cars car : cars)  {
+				inside2plate.put(car.getInsideCode(), car.getCarPlate());
+			}
+
+			// 线路编码和线路信息映射
+			Map<String, Line> code2line = new HashMap<>();
+			Iterable<Line> lines = lineRepository.findAll();
+			for (Line line : lines) {
+				code2line.put(line.getLineCode(), line);
+			}
+
+			// 线路编码和线路版本映射(电子路单日期)
+			Map<String, Integer> code2version = new HashMap<>();
+			Iterable<LineVersions> versions = lineVersionsRepository.findLineVersionsByDate((int)(DateTime.parse(date).getMillis() / 1000));
+			for (LineVersions version : versions) {
+				code2version.put(version.getLineCode(), version.getVersions());
+			}
+
+			Map<String, Integer> stationNumMap = null;
+			for(Map<String,Object> schRealInfo:listGroup){
+				if(schRealInfo != null){
+					// 获取线路是否使用标识，如果未使用，则不查该线路数据
+					String lineCode = schRealInfo.get("xlBm")+"";
+					Line line = code2line.get(lineCode);
+					if(line == null || line.getInUse() == null || line.getInUse() == 0){
+						ccount++;
+						continue;
+					}
+					if(counter % per == 0){
+						sf = new StringBuffer();
+						sf.append("<DLDS>");
+					}
+					counter ++;
+					xlbm = BasicData.lineCode2ShangHaiCodeMap.get(lineCode);
+					if (!xlbm.equals(oldXlbm)) {
+						oldXlbm = xlbm;
+						Integer ver = code2version.get(lineCode);
+						if (ver != null) {
+							stationNumMap = getLsStationRoute(lineCode, ver);
+						}
+					}
+
+					sf.append("<DLD>");
+					sf.append("<RQ>").append(date).append("</RQ>");
+					sf.append("<XLBM>").append(xlbm).append("</XLBM>");
+					sf.append("<LPBH>").append(schRealInfo.get("lpName")).append("</LPBH>");
+					sf.append("<CPH>").append(inside2plate.get(schRealInfo.get("clZbh"))).append("</CPH>");
+					sf.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
+					sf.append("<LDList>");
+					for(ScheduleRealInfo scheduleRealInfo:list){
+						if((schRealInfo.get("xlBm")+"").equals(scheduleRealInfo.getXlBm()) && (schRealInfo.get("lpName")+"")
+								.equals(scheduleRealInfo.getLpName())
+								&& (schRealInfo.get("clZbh")+"").equals(scheduleRealInfo.getClZbh())){
+
+							if(scheduleRealInfo.isDestroy()){
+								if(scheduleRealInfo.isReissue()){
+									scheduleRealInfo.setFcsjActualAll(scheduleRealInfo.getDfsj());
+									scheduleRealInfo.setZdsjActualAll(scheduleRealInfo.getZdsj());
+								}
+								else
+									continue;
+							}
+
+							if(scheduleRealInfo.getBcType().equals("in")
+									|| scheduleRealInfo.getBcType().equals("out")){
+								continue;
+							}
+
+							sf.append("<LD>");
+							sf.append("<SJGH>").append(scheduleRealInfo.getjGh()).append("</SJGH>");
+							sf.append("<SXX>").append(scheduleRealInfo.getXlDir()).append("</SXX>");
+							sf.append("<FCZDMC>").append(scheduleRealInfo.getQdzName()).append("</FCZDMC>");
+							// 起点站的参数
+							otherMap.put("stationMark","B");
+							paramMap = packageYgcStationNumParam(scheduleRealInfo,otherMap);
+							sf.append("<FCZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,stationNumMap)).append("</FCZDXH>");
+							sf.append("<FCZDBM>").append(scheduleRealInfo.getQdzCode()).append("</FCZDBM>");
+							sf.append("<JHFCSJ>").append(scheduleRealInfo.getFcsj()).append("</JHFCSJ>");
+							sf.append("<DFSJ>").append(scheduleRealInfo.getDfsj()).append("</DFSJ>");
+							sf.append("<SJFCSJ>").append(scheduleRealInfo.getFcsjActual()).append("</SJFCSJ>");
+							sf.append("<FCZDLX></FCZDLX>");
+							sf.append("<DDZDMC>").append(scheduleRealInfo.getZdzName()).append("</DDZDMC>");
+							// 终点站的参数
+							otherMap.put("stationMark","E");
+							paramMap = packageYgcStationNumParam(scheduleRealInfo,otherMap);
+							sf.append("<DDZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,stationNumMap)).append("</DDZDXH>");
+							sf.append("<DDZDBM>").append(scheduleRealInfo.getZdzCode()).append("</DDZDBM>");
+							sf.append("<JHDDSJ>").append(scheduleRealInfo.getZdsj()).append("</JHDDSJ>");
+							sf.append("<SJDDSJ>").append(scheduleRealInfo.getZdsjActual()).append("</SJDDSJ>");
+							sf.append("<DDZDLX></DDZDLX>");
+							sf.append("<LDSCBZ>0</LDSCBZ>");
+							sf.append("<DDBZ></DDBZ>");
+							sf.append("</LD>");
+						}
+					}
+					sf.append("</LDList>");
+					sf.append("</DLD>");
+				}
+				if(counter % per == per - 1){
+					sf.append("</DLDS>");
+					// 去掉'号
+					str = sf.toString().replace("'","");
+					scount += invokeSetLD(str, counter);
+					counter = 0;
+				}
+			}
+			// 每per条线路上传后剩下的数据再上传
+			if(counter > 0){
+				sf.append("</DLDS>");
+				// 去掉'号
+				str = sf.toString().replace("'","");
+				scount += invokeSetLD(str, counter);
+			}
+		} catch (Exception e) {
+			e.printStackTrace();
+			logger.error("setLD:", e);
+		} finally {
+			try {
+				for (String email : emails) {
+					//发送邮件
+					EmailBean mail = new EmailBean();
+					mail.setSubject(IpUtils.getLocalIpAddress() +":路单日志数据"+date);
+					mail.setContent("总数：" + (listGroup == null ? 0 : listGroup.size()) + "<br/>成功数：" + scount + "<br/>跳过数：" + ccount + "<br/>耗时：" + (System.currentTimeMillis() - start));
+					sendEmailController.sendMail(email, mail);
+				}
+				logger.info("setLD-sendMail:邮件发送成功！");
+			} catch (Exception e) {
+				e.printStackTrace();
+				logger.error("setLD-sendMail:",e);
+			}
+		}
+		return "success";
+	}
+
+	/**
+	 * 调用运管处电子路单接口，如果上传失败或有网络问题，最多执行10次
+	 * @param xml 拼接的xml字符串
+	 * @param counter 分组数
+	 * @return 成功返回counter 失败返回0
+	 */
+	private int invokeSetLD(String xml, int counter) {
+		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: 成功");
+					return counter;
+				} else if (i == 9) {
+					logger.error("setLD: " + xml);
+					logger.error("setLD: 失败，" + results.getMessage());
+				}
+				Thread.sleep(2000);
+			} catch (Exception e) {
+				logger.error("运管处接口调用异常", e);
+				try {
+					Thread.sleep(2000);
+				} catch (InterruptedException ex) {
+					ex.printStackTrace();
+				}
+			}
+		}
+
+		return 0;
+	}
+
+	/**
+	 * 上传路单
+	 * @return 上传成功标识
+	 */
+	private String uploadLD1(String theDate){
 		String result = "failure";
 		countSuccess = 0 ;countFailure = 0;
 		Line line;
 		// 取昨天 的日期
 		String date = theDate == null ?sdfnyr.format(DateUtils.addDays(new Date(), -1)) : theDate;
-		StringBuffer sf = new StringBuffer();
 		StringBuffer logSuccess = new StringBuffer("成功：");
 		StringBuffer logFailure = new StringBuffer("失败：");
 		HashMap logXlbmSuccessMap = new HashMap();
@@ -443,9 +647,6 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 		Results results = null;
 		String str = "",xlbm;
 		try {
-			int counter = 0; // 计数器
-			int per = 10; // 每几条线路上传一次路单
-
 			List<ScheduleRealInfo> list = scheduleRealInfoRepository.setLD(date);
 			List<Map<String,Object>> listGroup = scheduleRealInfoRepository.setLDGroup(date);
 			Map<String,Object> map = new HashMap();
@@ -467,8 +668,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 									= qp_ssop.setLD(userNameOther_qp,passwordOther_qp,StringEscapeUtils.unescapeHtml(ygsXml.toString().replace("'","")));
 							logger.info("青浦路单是否上传成功："+res.isSuccess());
 						}catch (Exception e){
-							e.printStackTrace();
-							continue;
+							logger.error("青浦路单上传异常", e);
 						}
 					}
 					// 新起xml标签
@@ -486,11 +686,6 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					if(line == null || line.getInUse() == null || line.getInUse() == 0){
 						continue;
 					}
-					if(counter % per == 0){
-						sf = new StringBuffer();
-						sf.append("<DLDS>");
-					}
-					counter ++;
 					xlbm = BasicData.lineCode2ShangHaiCodeMap.get(schRealInfo.get("xlBm")+"");
 					// 保存一次路单的线路编码，用于发送邮箱
 					if(logXlbmMap.get(xlbm) == null){
@@ -552,35 +747,20 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					}
 					sri.append("</LDList>");
 					sri.append("</DLD>");
-					sf.append(sri);
 					// 运管所xml加入路单信息
 					ygsXml.append(sri);
 				}
-				if(counter % per == per - 1){
-					counter = 0;
-					sf.append("</DLDS>");
-					str = sf.toString().replace("'","");// 去掉'号
-					results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
-					// 记录日志
-					result = logRecord(results,logXlbmMap,logXlbmSuccessMap,logXlbmFailureMap,logSuccess,logFailure,str);
-				}
 			}
-			// 每per条线路上传后剩下的数据再上传
-			if(counter > 0){
-				// 最后的路单一次上传
-				ygsXml.append("</DLDS>");
-				sf.append("</DLDS>");
-				str = sf.toString().replace("'","");// 去掉'号
-				results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
-				// 发送到青浦运管所
-				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("'","")));
-					logger.info("青浦路单是否上传成功："+res.isSuccess());
-				}catch (Exception e){
-					e.printStackTrace();
-				}
+			// 最后的路单一次上传
+			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("'","")));
+				logger.info("青浦路单是否上传成功1："+res.isSuccess());
+			}catch (Exception e){
+				logger.error("青浦路单上传异常1", e);
 			}
 			// 记录日志
 			result = logRecord(results,logXlbmMap,logXlbmSuccessMap,logXlbmFailureMap,logSuccess,logFailure,str);
@@ -591,19 +771,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 				logFailure.append("\r\t").append(traceElement);
 			}
 			e.printStackTrace();
-		}finally{
-			try {
-				//发送邮件
-				EmailBean mail = new EmailBean();
-				mail.setSubject(InetAddress.getLocalHost().getHostAddress()+":路单日志数据"+date);
-				mail.setContent("成功数："+countSuccess+"<br/>失败数："+countFailure+"<br/>" +logSuccess + "<br/>"+logFailure);
-				sendEmailController.sendMail(emailSendToAddress, mail);
-				logger.info("setLD-sendMail:邮件发送成功！");
-			}catch (Exception e){
-				e.printStackTrace();
-				logger.error("setLD-sendMail:",e);
-			}
 		}
+
 		return result;
 	}