修正上传至运管处的时刻表的总里程、营运里程

zlz
1 parent 16a6e003
Showing 1 changed file with 47 additions and 25 deletions
src/main/java/com/bsth/service/impl/TrafficManageServiceImpl.java
@@ -942,32 +942,42 @@ 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 = null,sBufferC = null;
+			double zlc = 0.0f,yylc = 0.0f,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); // 保存时刻表
+				// 获得时刻表
+				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>");
@@ -975,46 +985,58 @@ 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>");
 				}
 			}
-			sBuffer.append("</SKBs>");
+
+			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).append("</SKBs>");
 			if(ssop.setSKB(userNameOther, passwordOther, sBuffer.toString()).isSuccess()){
 				result = "success";
 				SKBUploadLogger skbUploadLogger ;