运管处路单上传BUG修改

zlz
1 parent 895efb67
Showing 1 changed file with 141 additions and 32 deletions
src/main/java/com/bsth/service/impl/TrafficManageServiceImpl.java
@@ -134,12 +134,19 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	 * 上传线路信息
 	 */
 	@Override
-	public String setXL() {
+	public String setXL(Map<String, Object> param) {
 		String result = "failure";
 		StringBuffer sBuffer = new StringBuffer();
 		try {
-			Iterator<Line> lineIterator = lineRepository.findAll().iterator();
+			Map<String,Object> map = new HashMap<String,Object>();
+			map.put("lineCode_eq", param.get("xl.lineCode_like")+"");
+			Iterator<Line> lineIterator;
 			Line line = null;
+			if(param.get("xl.lineCode_like").equals("")){
+				lineIterator = lineRepository.findAll().iterator();
+			}else {
+				line = lineRepository.findOne(new CustomerSpecs<Line>(map));
+			}
 			List<StationRoute> upStationsList = null;// 上行站点路由集
 			List<StationRoute> downStationsList = null;// 下行站点路由集
 			List<LineInformation> lineInformationsList = null;
@@ -147,14 +154,15 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			sBuffer.append("<Data>");
 			sBuffer.append("<RequestOrg>上海巴士拓华科技发展有限公司</RequestOrg>");
 			sBuffer.append("<DataList>");
-			while(lineIterator.hasNext()){
-				line = lineIterator.next();
-				if(!line.getName().equals("浦江4路")){
-					continue;
-				}
-				if(BasicData.lineId2ShangHaiCodeMap.get(line.getId()) == null
+//			while(lineIterator.hasNext()){
+//				line = lineIterator.next();
+//				if(BasicData.lineId2ShangHaiCodeMap.get(line.getId()) == null
+//						|| line.getInUse() == 0){
+//					continue;
+//				}
+			if(BasicData.lineId2ShangHaiCodeMap.get(line.getId()) == null
 						|| line.getInUse() == 0){
-					continue;
+					return result;
 				}
 				sBuffer.append("<LINE_ID>").append(line.getId()).append("</LINE_ID>");
 				sBuffer.append("<LINE_CODE>").append(BasicData.lineId2ShangHaiCodeMap.get(line.getId())).append("</LINE_CODE>");
@@ -176,7 +184,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 				startId = packagStationPointXml(upStationsList, sBuffer, startId);
 				packagStationPointXml(downStationsList, sBuffer, startId);
 				sBuffer.append("</LinePointList>");
-			}
+//			}
 			sBuffer.append("</DataList>");
 			sBuffer.append("</Data>");
 			System.out.println(sBuffer.toString());
@@ -301,6 +309,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			List<ScheduleRealInfo> list = scheduleRealInfoRepository.setLD(date);
 			List<Map<String,Object>> listGroup = scheduleRealInfoRepository.setLDGroup(date);
 			Map<String,Object> map = new HashMap<String,Object>();
+			HashMap<String,String> paramMap;
+			HashMap<String,String> otherMap = new HashMap<String, String>();
 			for(Map<String,Object> schRealInfo:listGroup){
 				if(schRealInfo != null){
 					//根据车辆自编号查询车牌号
@@ -347,16 +357,20 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 							sf.append("<SJGH>"+scheduleRealInfo.getjGh()+"</SJGH>");
 							sf.append("<SXX>"+scheduleRealInfo.getXlDir()+"</SXX>");
 							sf.append("<FCZDMC>"+scheduleRealInfo.getQdzName()+"</FCZDMC>");
-							sf.append("<FCZDXH>" + getYgcStationNumByLineCodeAndDirectionAndStationName(
-									scheduleRealInfo.getXlBm(), scheduleRealInfo.getXlDir(), scheduleRealInfo.getQdzCode()) + "</FCZDXH>");
+							// 起点站的参数
+							otherMap.put("stationMark","B");
+							paramMap = packageYgcStationNumParam(scheduleRealInfo,otherMap);
+							sf.append("<FCZDXH>" + getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap) + "</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>");
-							sf.append("<DDZDXH>"+ getYgcStationNumByLineCodeAndDirectionAndStationName(
-									scheduleRealInfo.getXlBm(), scheduleRealInfo.getXlDir(), scheduleRealInfo.getZdzCode()) +"</DDZDXH>");
+							// 终点站的参数
+							otherMap.put("stationMark","E");
+							paramMap = packageYgcStationNumParam(scheduleRealInfo,otherMap);
+							sf.append("<DDZDXH>"+ getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap) +"</DDZDXH>");
 							sf.append("<DDZDBM>"+scheduleRealInfo.getZdzCode()+"</DDZDBM>");
 							sf.append("<JHDDSJ>"+scheduleRealInfo.getZdsj()+"</JHDDSJ>");
 							sf.append("<SJDDSJ>"+scheduleRealInfo.getZdsjActual()+"</SJDDSJ>");
@@ -650,6 +664,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			List<SchedulePlanInfo> schedulePlanList = schedulePlanInfoRepository.findLineScheduleBc(tomorrow);
 			int j = 0; // 初始化标识
 			if(schedulePlanList != null ){
+				HashMap<String,String> paramMap;
+				HashMap<String,String> otherMap = new HashMap<String, String>();
 				int size = schedulePlanList.size();
 				for (int i = 0; i < size; i++) {
 					schedulePlanInfo = schedulePlanList.get(i);
@@ -676,12 +692,16 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 						sBuffer.append("<SJGH>").append(schedulePlanInfo.getjGh()).append("</SJGH>");
 						sBuffer.append("<SXX>").append(schedulePlanInfo.getXlDir()).append("</SXX>");
 						sBuffer.append("<FCZDMC>").append(schedulePlanInfo.getQdzName()).append("</FCZDMC>");
-						sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
-								schedulePlanInfo.getXlBm(), schedulePlanInfo.getXlDir(), schedulePlanInfo.getQdzCode())).append("</ZDXH>");
+						// 起点站的参数
+						otherMap.put("stationMark","B");
+						paramMap = packageYgcStationNumParam(schedulePlanInfo,otherMap);
+						sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap)).append("</ZDXH>");
 						sBuffer.append("<JHFCSJ>").append(schedulePlanInfo.getFcsj()).append("</JHFCSJ>");
 						sBuffer.append("<DDZDMC>").append(schedulePlanInfo.getZdzName()).append("</DDZDMC>");
-						sBuffer.append("<DDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
-								schedulePlanInfo.getXlBm(), schedulePlanInfo.getXlDir(), schedulePlanInfo.getZdzCode())).append("</DDXH>");
+						// 起点站的参数
+						otherMap.put("stationMark","E");
+						paramMap = packageYgcStationNumParam(schedulePlanInfo,otherMap);
+						sBuffer.append("<DDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap)).append("</DDXH>");
 						sBuffer.append("<JHDDSJ>").append(calcDdsj(schedulePlanInfo.getFcsj(),schedulePlanInfo.getBcsj()))
 								.append("</JHDDSJ>");
 						sBuffer.append("</BC>");
@@ -743,6 +763,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			HashMap<String,Object> param = new HashMap<String, Object>();
 			String lineCode ;
 			sBuffer.append("<SKBs>");
+			HashMap<String,String> paramMap;
+			HashMap<String,String> otherMap = new HashMap<String, String>();
 			for (int i = 0; i < idArray.length; i++) {
 				ttInfo = ttInfoRepository.findOne(Long.valueOf(idArray[i]));
 				if(ttInfo == null)
@@ -783,12 +805,16 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 						sBuffer.append("<LPBH>").append(ttInfoDetail.getLp().getLpNo()).append("</LPBH>");
 						sBuffer.append("<SXX>").append(ttInfoDetail.getXlDir()).append("</SXX>");
 						sBuffer.append("<FCZDMC>").append(ttInfoDetail.getQdz().getStationName()).append("</FCZDMC>");
-						sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
-								lineCode, ttInfoDetail.getXlDir(), ttInfoDetail.getQdz().getStationCod())).append("</ZDXH>");
+						// 起点站的参数
+						otherMap.put("stationMark","B");
+						paramMap = packageYgcStationNumParam(ttInfoDetail,otherMap);
+						sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap)).append("</ZDXH>");
 						sBuffer.append("<JHFCSJ>").append(changeTimeFormat(ttInfoDetail)).append("</JHFCSJ>");
 						sBuffer.append("<DDZDMC>").append(ttInfoDetail.getZdz().getStationName()).append("</DDZDMC>");
-						sBuffer.append("<DDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
-								lineCode, ttInfoDetail.getXlDir(), ttInfoDetail.getZdz().getStationCod())).append("</DDXH>");
+						// 起点站的参数
+						otherMap.put("stationMark","E");
+						paramMap = packageYgcStationNumParam(ttInfoDetail,otherMap);
+						sBuffer.append("<DDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paramMap)).append("</DDXH>");
 						sBuffer.append("<JHDDSJ>").append(calcDdsj(ttInfoDetail.getFcsj(),ttInfoDetail.getBcsj())).append("</JHDDSJ>");
 						sBuffer.append("</BC>");
 					}
@@ -1136,6 +1162,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	private int packagStationXml(List<StationRoute> stationsList,StringBuffer sBuffer,int startId){
 		int size = stationsList.size();
 		StationRoute srRoute;
+		HashMap<String,String> paraMap;
 		String zdlx ;// 站点类型：0：起点站、1：终点站、2：中途站
 		for (int i = 0; i < size; i++) {
 			srRoute = stationsList.get(i);
@@ -1147,10 +1174,11 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			}else{
 				zdlx = "2";
 			}
+			paraMap = packageYgcStationNumParam(srRoute,null);
 			sBuffer.append("<Station>");
-			sBuffer.append("<STATION_ID>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(srRoute.getLineCode(),srRoute.getDirections()+"",srRoute.getStationCode())).append("</STATION_ID>");
+			sBuffer.append("<STATION_ID>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paraMap)).append("</STATION_ID>");
 			sBuffer.append("<UPDDOWN>").append(srRoute.getDirections()).append("</UPDDOWN>");
-			sBuffer.append("<STATION_NO>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(srRoute.getLineCode(),srRoute.getDirections()+"",srRoute.getStationCode())).append("</STATION_NO>");
+			sBuffer.append("<STATION_NO>").append(i).append("</STATION_NO>");
 			sBuffer.append("<STATION_CODE>").append(srRoute.getStationCode()).append("</STATION_CODE>");
 			sBuffer.append("<STATION_NAME>").append(srRoute.getStationName()).append("</STATION_NAME>");
 			sBuffer.append("<STATION_LON>").append(srRoute.getStation().getgLonx()).append("</STATION_LON>");
@@ -1173,6 +1201,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	private int packagStationPointXml(List<StationRoute> stationsList,StringBuffer sBuffer,int startId){
 		int size = stationsList.size();
 		StationRoute srRoute;
+		HashMap<String,String> paraMap;
 		String zdlx ;// 站点类型：0：起点站、1：终点站、2：中途站
 		for (int i = 0; i < size; i++) {
 			srRoute = stationsList.get(i);
@@ -1184,8 +1213,9 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			}else{
 				zdlx = "2";
 			}
+			paraMap = packageYgcStationNumParam(srRoute,null);
 			sBuffer.append("<Point>");
-			sBuffer.append("<POINT_ID>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(srRoute.getLineCode(),srRoute.getDirections()+"",srRoute.getStationCode())).append("</POINT_ID>");
+			sBuffer.append("<POINT_ID>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(paraMap)).append("</POINT_ID>");
 			sBuffer.append("<UPDDOWN>").append(srRoute.getDirections()).append("</UPDDOWN>");
 			sBuffer.append("<POINTLON>").append(srRoute.getStation().getgLonx()).append("</POINTLON>");
 			sBuffer.append("<POINTLAT>").append(srRoute.getStation().getgLaty()).append("</POINTLAT>");
@@ -1196,15 +1226,94 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	}
 	/**
-	 *
-	 * @param lineCode 线路编码
-	 * @param direction 线路方向
-	 * @param stationCode 让点名称
+	 *  获取运管处站点序号
+	 * @param map
 	 * @return 运管处站点序号
 	 */
-	private Integer getYgcStationNumByLineCodeAndDirectionAndStationName(String lineCode,String direction,String stationCode){
-		Integer number = 0;
-		number = BasicData.stationName2YgcNumber.get(lineCode+"_"+direction+"_"+stationCode);
+	private Integer getYgcStationNumByLineCodeAndDirectionAndStationName(HashMap<String,String> map){
+		// 线路编码
+		String lineCode = map.get("lineCode");
+		// 线路走向 0：上行  1：下行
+		String direction = map.get("direction");
+		// 站点编码
+		String stationCode = map.get("stationCode");
+		// 站点类型：B：起点站 Z：中途站 E：终点站 T：停车场
+		String stationMark = map.get("stationMark");
+		String[] marks = null;
+		// 起点站，先从起点找，找不到再从中途站找，最后从终点找
+		if(stationMark.equals("B")){
+			marks= new String[]{"B","Z","E"};
+		}else if(stationMark.equals("E")){// 终点站相反
+			marks= new String[]{"E","Z","B"};
+		}else if(stationMark.equals("Z")){
+			marks= new String[]{"Z"};
+		}
+		Integer number = null;
+		for (int i = 0 ;i < marks.length ; i ++){
+			number = BasicData.stationName2YgcNumber.get(lineCode+"_"+direction+"_"+stationCode+"_"+marks[i]);
+			if(number != null){
+				break;
+			}
+		}
 		return number == null ? 0 : number;
 	}
+
+	/**
+	 * 封装查询站序条件
+	 * @param obj
+	 * @return
+	 */
+	private HashMap packageYgcStationNumParam(Object obj,HashMap<String,String> otherParam){
+		HashMap<String,String> map = new HashMap<String,String>();
+		String lineCode = "",direction = "",stationCode = "",stationMark = "";
+		// 站点路由
+		if(obj instanceof StationRoute){
+			StationRoute sr = (StationRoute)obj;
+			lineCode = sr.getLineCode();
+			direction = String.valueOf(sr.getDirections());
+			stationCode = sr.getStationCode();
+			stationMark = sr.getStationMark();
+		}else if(obj instanceof ScheduleRealInfo){ //实际排班计划明细。
+			ScheduleRealInfo sri = (ScheduleRealInfo)obj;
+			lineCode = sri.getXlBm();
+			direction = sri.getXlDir();
+			if(otherParam != null && otherParam.get("stationMark") != null){
+				stationMark = otherParam.get("stationMark");
+				if(stationMark.equals("B")){ // 起点站
+					stationCode = sri.getQdzCode();
+				}else if(stationMark.equals("E")){ // 终点站
+					stationCode = sri.getZdzCode();
+				}
+			}
+		}else if(obj instanceof SchedulePlanInfo){ //排班计划明细
+			SchedulePlanInfo spi = (SchedulePlanInfo)obj;
+			lineCode = spi.getXlBm();
+			direction = spi.getXlDir();
+			if(otherParam != null && otherParam.get("stationMark") != null){
+				stationMark = otherParam.get("stationMark");
+				if(stationMark.equals("B")){ // 起点站
+					stationCode = spi.getQdzCode();
+				}else if(stationMark.equals("E")){ // 终点站
+					stationCode = spi.getZdzCode();
+				}
+			}
+		}else if(obj instanceof TTInfoDetail){ //时刻表明细
+			TTInfoDetail ttid = (TTInfoDetail)obj;
+			lineCode = ttid.getXl().getLineCode();
+			direction = ttid.getXlDir();
+			if(otherParam != null && otherParam.get("stationMark") != null){
+				stationMark = otherParam.get("stationMark");
+				if(stationMark.equals("B")){ // 起点站
+					stationCode = ttid.getQdz().getStationCod();
+				}else if(stationMark.equals("E")){ // 终点站
+					stationCode = ttid.getZdz().getStationCod();
+				}
+			}
+		}
+		map.put("lineCode",lineCode);// 站点编码
+		map.put("direction",direction); // 上下行
+		map.put("stationCode",stationCode); // 站点编号
+		map.put("stationMark",stationMark); // 站点类型
+		return map;
+	}
 }