青浦时刻表上传代码依赖

zq
1 parent 2530b841
Showing 1 changed file with 164 additions and 50 deletions
src/main/java/com/bsth/service/impl/TrafficManageServiceImpl.java
 package com.bsth.service.impl;
 import com.bsth.data.BasicData;
+import com.bsth.email.SendEmailController;
+import com.bsth.email.entity.EmailBean;
 import com.bsth.entity.*;
 import com.bsth.entity.realcontrol.ChildTaskPlan;
 import com.bsth.entity.realcontrol.ScheduleRealInfo;
@@ -33,6 +35,7 @@ import org.springframework.data.domain.Sort.Direction;
 import org.springframework.stereotype.Service;
 import java.io.*;
+import java.net.InetAddress;
 import java.sql.Connection;
 import java.sql.PreparedStatement;
 import java.sql.ResultSet;
@@ -109,6 +112,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	@Autowired
 	private YgcBasicDataService ygcBasicDataService;
+	// 发送邮件
+	@Autowired
+	private SendEmailController sendEmailController;
 	// 运管处上传接口
 	private com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap webServiceSoapUp;
@@ -138,6 +144,10 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	private final String userNameUp = "user";
 	// 密码
 	private final String passwordUp = "user";
+	// 接收邮件人
+	private final String emailSendToAddress = "175912183@qq.com";
+	// 记录路单上线的成功、失败线路数
+	private Integer countSuccess,countFailure;
 	private synchronized com.bsth.webService.trafficManage.up.org.tempuri.WebServiceSoap  getWebServiceSoapUp(){
 		try {
@@ -396,20 +406,27 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	 */
 	private String uploadLD(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();
-		String str;
+		StringBuffer logSuccess = new StringBuffer("成功：");
+		StringBuffer logFailure = new StringBuffer("失败：");
+		HashMap logXlbmSuccessMap = new HashMap();
+		HashMap logXlbmFailureMap = new HashMap();
+		HashMap logXlbmMap = new HashMap();
+		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<String,Object>();
+			Map<String,Object> map = new HashMap();
 			HashMap<String,String> paramMap;
-			HashMap<String,String> otherMap = new HashMap<String, String>();
+			HashMap<String,String> otherMap = new HashMap();
 			for(Map<String,Object> schRealInfo:listGroup){
 				if(schRealInfo != null){
 					//根据车辆自编号查询车牌号
@@ -425,9 +442,14 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 						sf.append("<DLDS>");
 					}
 					counter ++;
+					xlbm = BasicData.lineCode2ShangHaiCodeMap.get(schRealInfo.get("xlBm")+"");
+					// 保存一次路单的线路编码，用于发送邮箱
+					if(logXlbmMap.get(xlbm) == null){
+						logXlbmMap.put(xlbm,xlbm);
+					}
 					sf.append("<DLD>");
 					sf.append("<RQ>"+date+"</RQ>");
-					sf.append("<XLBM>"+BasicData.lineCode2ShangHaiCodeMap.get(schRealInfo.get("xlBm")+"")+"</XLBM>");
+					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>");
@@ -485,39 +507,91 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					counter = 0;
 					sf.append("</DLDS>");
 					str = sf.toString().replace("'","");// 去掉'号
-					Results results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
-					if(results.isSuccess()){
-						result = "success";
-					}else{
-						result = "failure";
-					}
-					logger.info("setLD:"+str);
-					logger.info("setLD:"+result);
+					results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
+					// 记录日志
+					result = logRecord(results,logXlbmMap,logXlbmSuccessMap,logXlbmFailureMap,logSuccess,logFailure,str);
 				}
 			}
 			// 每per条线路上传后剩下的数据再上传
 			if(counter > 0){
 				sf.append("</DLDS>");
 				str = sf.toString().replace("'","");// 去掉'号
-				Results results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
-				if(results.isSuccess()){
-					result = "success";
-				}else{
-					result = "failure";
-				}
-				logger.info("setLD:"+str);
-				logger.info("setLD:"+result);
+				results = ssop.setLD(userNameOther, passwordOther, StringEscapeUtils.unescapeHtml(str));
 			}
+			// 记录日志
+			result = logRecord(results,logXlbmMap,logXlbmSuccessMap,logXlbmFailureMap,logSuccess,logFailure,str);
 		} catch (Exception e) {
 			logger.error("setLD:",e);
+			logFailure.append(e).append("<br/>");
+			for (StackTraceElement traceElement : e.getStackTrace()){
+				logFailure.append("\r\t").append(traceElement);
+			}
 			e.printStackTrace();
 		}finally{
-
+			try {
+				//发送邮件
+				EmailBean mail = new EmailBean();
+				mail.setSubject(InetAddress.getLocalHost().getHostAddress()+":路单日志数据"+date);
+				mail.setContent(logSuccess+"<br/>成功数："+countSuccess+"<br/>" +logFailure+"<br/>失败数："+countFailure);
+				sendEmailController.sendMail(emailSendToAddress, mail);
+				logger.info("setLD-sendMail:邮件发送成功！");
+			}catch (Exception e){
+				e.printStackTrace();
+				logger.error("setLD-sendMail:",e);
+			}
 		}
 		return result;
 	}
 	/**
+	 * 记录日志
+	 * @param results
+	 * @param logXlbmMap
+	 * @param logXlbmSuccessMap
+	 * @param logXlbmFailureMap
+	 * @param logSuccess
+	 * @param logFailure
+	 * @param str
+	 */
+	private String logRecord(Results results,HashMap logXlbmMap,HashMap logXlbmSuccessMap,HashMap logXlbmFailureMap,StringBuffer logSuccess,
+							 StringBuffer logFailure,String str){
+		String result = "failure";
+		// 记录日志
+		if(results != null){
+			if(results.isSuccess()){// 上传成功
+				// 把上线成功的线路编码放入 logXlbmSuccessMap，并记录logSuccess
+				countSuccess += fillMailXlbmMap(logXlbmMap,logXlbmSuccessMap,logSuccess);
+				result = "success";
+			}else{// 上传失败
+				// 把上线失败的线路编码放入 logXlbmFailureMap，并记录logFailure
+				countFailure += fillMailXlbmMap(logXlbmMap,logXlbmFailureMap,logFailure);
+				result = "failure";
+			}
+			logger.info("setLD:"+str);
+			logger.info("setLD:"+result);
+			results = null;
+			logXlbmMap = new HashMap();
+		}
+		return result;
+	}
+	/**
+	 * 填充线路编码到相应的map
+	 * @param fromMap
+	 * @param toMap
+	 */
+	private int fillMailXlbmMap(HashMap fromMap,HashMap toMap,StringBuffer logStr){
+		int tmpCount = 0;
+		for (Object key : fromMap.keySet()) {
+			if(toMap.get(key) == null){
+				toMap.put(key,fromMap.get(key));
+				logStr.append(key).append(",");
+				tmpCount ++;
+			}
+		}
+		fromMap = new HashMap();
+		return tmpCount;
+	}
+	/**
 	 * 上传路单 xml来自文件
 	 * @return 上传成功标识
 	 */
@@ -577,7 +651,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					/**
 					 * 如果car==null，则说明该车辆是从线调中换车功能中加进去的，
 					 * 在cars基础信息中查不到车辆的信息，所以忽略该车辆
- 					 */
+					 */
 					if(car == null){
 						continue;
 					}
@@ -745,10 +819,26 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	}
 	/**
+	 * 上传计划班次 指定日期 yyyy-MM-dd
+	 * @param theDate
+	 * @return
+	 */
+	public String setJHBC(String theDate){
+		return uploadJHBC(theDate);
+	}
+
+	/**
+	 * 上传计划班次
+	 * @return
+	 */
+	public String setJHBC(){
+		return uploadJHBC(null);
+	}
+	/**
 	 * 上传线路计划班次表
 	 */
-	@Override
-	public String setJHBC() {
+
+	private String uploadJHBC(String theDate) {
 		String result = "failure";
 		Line line;
 		StringBuffer sBuffer =new StringBuffer();
@@ -758,8 +848,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			SchedulePlanInfo schedulePlanInfo;
 			String xlbm,zbh = "";
 			Long lp = 0L;
-			// 取明天的日期
-			String tomorrow = sdfnyr.format(DateUtils.addDays(new Date(), +1));
+			// 取得计划班次时间
+			String tomorrow = theDate == null ? sdfnyr.format(DateUtils.addDays(new Date(), +1)) : theDate;
 			// 查询所有班次
 			List<SchedulePlanInfo> schedulePlanList = schedulePlanInfoRepository.findLineScheduleBc(tomorrow);
 			int j = 0; // 初始化标识
@@ -853,32 +943,44 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	public String setSKB(String ids) {
 		String result = "failure";
 		StringBuffer sBuffer = new StringBuffer();
+		DecimalFormat df = new DecimalFormat("######0.000");
 		try {
 			String[] idArray = ids.split(",");
-			StringBuffer sBufferA;
-			StringBuffer sBufferB;
+			StringBuffer sBufferA ,sBufferB ,sBufferC ;
+			double zlc,yylc,singleLc,emptyLc;// 总里程、营运里程、单程、空放里程
+			String bcType,sxx;// 班次类型、上下行
 			// 上传的时刻表集合
 			List<TTInfo> ttinfoList = new ArrayList<>();
 			TTInfo ttInfo;
 			TTInfoDetail ttInfoDetail;
+			LineInformation lineInformation;
 			Iterator<TTInfoDetail> ttInfoDetailIterator;
-			HashMap<String,Object> param = new HashMap<String, Object>();
+			HashMap<String,Object> param ;
 			sBuffer.append("<SKBs>");
 			HashMap<String,String> paramMap;
-			HashMap<String,String> otherMap = new HashMap<String, String>();
+			HashMap<String,String> otherMap = new HashMap<>();
 			for (int i = 0; i < idArray.length; i++) {
 				ttInfo = ttInfoRepository.findOne(Long.valueOf(idArray[i]));
 				if(ttInfo == null)
 					continue;
 				ttinfoList.add(ttInfo); // 保存时刻表
+				zlc = 0.0f;
+				yylc = 0.0f;
+				// 获得时刻表
+				param = new HashMap();
 				param.put("ttinfo.id_eq", ttInfo.getId());
 				ttInfoDetailIterator = ttInfoDetailRepository.findAll(new CustomerSpecs<TTInfoDetail>(param),
 						new Sort(Direction.ASC, "xlDir")).iterator();
+				// 获得lineInformation
+				param = new HashMap();
+				param.put("line.id_eq", ttInfo.getXl().getId());
+				lineInformation = lineInformationRepository.findOne(new CustomerSpecs<LineInformation>(param));
 				if(ttInfoDetailIterator.hasNext()){
 					sBuffer.append("<SKB>");
 					sBuffer.append("<XLBM>").append(BasicData.lineId2ShangHaiCodeMap.get(ttInfo.getXl().getId()))
 							.append("</XLBM>");
 					sBufferB = new StringBuffer();
+					sBufferC = new StringBuffer();
 					sBufferB.append("<KSRQ>").append(sdfnyr.format(ttInfo.getQyrq())).append("</KSRQ>");
 					// 结束日期暂时不要，节假日的班次表才需要，如春节的班次表
 					sBufferB.append("<JSRQ>").append("").append("</JSRQ>");
@@ -886,43 +988,55 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					sBufferB.append("<TBYY>").append("").append("</TBYY>");
 					sBufferB.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
 					sBufferB.append("<BCList>");
-					int num = 1;
 					while (ttInfoDetailIterator.hasNext()) {
 						ttInfoDetail = ttInfoDetailIterator.next();
-						if(ttInfoDetail.getBcType().equals("in") || ttInfoDetail.getBcType().equals("out")){
+						bcType = ttInfoDetail.getBcType();
+						sxx = ttInfoDetail.getXlDir();
+						// 进出场班次
+						if(bcType.equals("in") || bcType.equals("out")){
+							// 进出班次的计划里程，算空驶里程
+							emptyLc = ttInfoDetail.getJhlc();
+							// 总里程需要加上空驶里程
+							zlc += emptyLc;
 							continue;
 						}
-						if(num++ == 1){
-							sBufferA = new StringBuffer();
-							sBufferA.append("<JHZLC>").append(ttInfoDetail.getJhlc()).append("</JHZLC>");
-							sBufferA.append("<JHYYLC>").append(ttInfoDetail.getJhlc()).append("</JHYYLC>");
-							sBuffer.append(sBufferA).append(sBufferB);
-						}
 						// 如果发车时间格式错误，忽略此条
 						if(changeTimeFormat(ttInfoDetail) == null){
 							continue;
 						}
-						sBuffer.append("<BC>");
-						sBuffer.append("<LPBH>").append(ttInfoDetail.getLp().getLpNo()).append("</LPBH>");
-						sBuffer.append("<SXX>").append(ttInfoDetail.getXlDir()).append("</SXX>");
-						sBuffer.append("<FCZDMC>").append(BasicData.stationCode2NameMap.get(ttInfoDetail.getXl().getLineCode()+"_"+ttInfoDetail.getXlDir()
+						sBufferC.append("<BC>");
+						sBufferC.append("<LPBH>").append(ttInfoDetail.getLp().getLpNo()).append("</LPBH>");
+						sBufferC.append("<SXX>").append(sxx).append("</SXX>");
+						sBufferC.append("<FCZDMC>").append(BasicData.stationCode2NameMap.get(ttInfoDetail.getXl().getLineCode()+"_"+ttInfoDetail.getXlDir()
 								+"_"+ttInfoDetail.getQdzCode())).append("</FCZDMC>");
 						// 起点站的参数
 						otherMap.put("stationMark","B");
 						paramMap = packageYgcStationNumParam(ttInfoDetail,otherMap);
-						sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,null)).append("</ZDXH>");
-						sBuffer.append("<JHFCSJ>").append(changeTimeFormat(ttInfoDetail)).append("</JHFCSJ>");
-						sBuffer.append("<DDZDMC>").append(BasicData.stationCode2NameMap.get(ttInfoDetail.getXl().getLineCode()+"_"+ttInfoDetail.getXlDir()
+						sBufferC.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,null)).append("</ZDXH>");
+						sBufferC.append("<JHFCSJ>").append(changeTimeFormat(ttInfoDetail)).append("</JHFCSJ>");
+						sBufferC.append("<DDZDMC>").append(BasicData.stationCode2NameMap.get(ttInfoDetail.getXl().getLineCode()+"_"+ttInfoDetail.getXlDir()
 								+"_"+ttInfoDetail.getZdzCode())).append("</DDZDMC>");
 						// 起点站的参数
 						otherMap.put("stationMark","E");
 						paramMap = packageYgcStationNumParam(ttInfoDetail,otherMap);
-						sBuffer.append("<DDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,null)).append("</DDXH>");
-						sBuffer.append("<JHDDSJ>").append(calcDdsj(ttInfoDetail.getFcsj(),ttInfoDetail.getBcsj())).append("</JHDDSJ>");
-						sBuffer.append("</BC>");
+						sBufferC.append("<DDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap,null)).append("</DDXH>");
+						sBufferC.append("<JHDDSJ>").append(calcDdsj(ttInfoDetail.getFcsj(),ttInfoDetail.getBcsj())).append("</JHDDSJ>");
+						sBufferC.append("</BC>");
+						// 0：上行；1：下行
+						if("0".equals(sxx)){
+							singleLc = lineInformation.getUpMileage();
+						}else{
+							singleLc = lineInformation.getDownMileage();
+						}
+						zlc += singleLc ;
+						yylc += singleLc;
 					}
-					sBuffer.append("</BCList>");
-					sBuffer.append("</SKB>");
+					sBufferC.append("</BCList>");
+					sBufferC.append("</SKB>");
+					sBufferA = new StringBuffer();
+					sBufferA.append("<JHZLC>").append(df.format(zlc)).append("</JHZLC>");
+					sBufferA.append("<JHYYLC>").append(df.format(yylc)).append("</JHYYLC>");
+					sBuffer.append(sBufferA).append(sBufferB).append(sBufferC);
 				}
 			}
 			sBuffer.append("</SKBs>");