帮周勤提交一下代码

潘钊
1 parent 40d6caca
Showing 3 changed files with 151 additions and 70 deletions
src/main/java/com/bsth/data/BasicData.java
src/main/java/com/bsth/service/TrafficManageService.java
src/main/java/com/bsth/service/impl/TrafficManageServiceImpl.java
 package com.bsth.data;
-import java.util.ArrayList;
-import java.util.HashMap;
-import java.util.Iterator;
-import java.util.List;
-import java.util.Map;
-import java.util.concurrent.TimeUnit;
-
+import com.bsth.Application;
+import com.bsth.entity.*;
+import com.bsth.entity.schedule.CarConfigInfo;
+import com.bsth.repository.*;
+import com.bsth.repository.schedule.CarConfigInfoRepository;
+import com.google.common.collect.BiMap;
+import com.google.common.collect.HashBiMap;
 import org.apache.commons.lang3.StringUtils;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
@@ -14,24 +14,8 @@ import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.CommandLineRunner;
 import org.springframework.stereotype.Component;
-import com.bsth.Application;
-import com.bsth.entity.CarPark;
-import com.bsth.entity.Cars;
-import com.bsth.entity.Line;
-import com.bsth.entity.Personnel;
-import com.bsth.entity.Station;
-import com.bsth.entity.StationRoute;
-import com.bsth.entity.schedule.CarConfigInfo;
-import com.bsth.repository.CarParkRepository;
-import com.bsth.repository.CarsRepository;
-import com.bsth.repository.LineRepository;
-import com.bsth.repository.PersonnelRepository;
-import com.bsth.repository.StationRepository;
-import com.bsth.repository.StationRouteRepository;
-import com.bsth.repository.schedule.CarConfigInfoRepository;
-import com.google.common.collect.BiMap;
-import com.google.common.collect.HashBiMap;
-import com.google.common.collect.TreeMultimap;
+import java.util.*;
+import java.util.concurrent.TimeUnit;
 /**
  * @author PanZhao
@@ -85,6 +69,9 @@ public class BasicData implements CommandLineRunner {
     //全量员工 工号和姓名对照
     public static Map<String, String> allPerson;
+    //站点名和运管处编号 对照
+    public static Map<String, Map<String, Map>> stationName2YgcNumber;
+
     static Logger logger = LoggerFactory.getLogger(BasicData.class);
@@ -245,7 +232,14 @@ public class BasicData implements CommandLineRunner {
          * @Title: loadLineInfo
          * @Description: TODO(加载线路相关信息)
          */
-        public void loadLineInfo() {
+        public void loadLineInfo(){
+            List<StationRoute> stationsList = null;// 站点路由集
+            StationRoute stationRoute = null;
+            int size = 0;
+            Map<String, Integer> station2Number ;
+            Map<String, Map> dirs2Statioin ;
+            int[] dirs = {0,1};// 运行方向  上下行
+            int num = 1;
             Iterator<Line> iterator = lineRepository.findAll().iterator();
             Line line;
@@ -253,19 +247,46 @@ public class BasicData implements CommandLineRunner {
             Map<String, String> code2name = new HashMap<>();
             Map<Integer, String> id2SHcode = new HashMap<Integer, String>();
             Map<String, String> code2SHcode = new HashMap<String, String>();
+            Map<String, Map<String, Map>> tempStationName2YgcNumber = new HashMap<String, Map<String, Map>>();
-            while (iterator.hasNext()) {
+            while(iterator.hasNext()){
                 line = iterator.next();
                 biMap.put(line.getId(), line.getLineCode());
                 code2name.put(line.getLineCode(), line.getName());
-                id2SHcode.put(line.getId(), line.getShanghaiLinecode());
+                id2SHcode.put(line.getId(),line.getShanghaiLinecode());
                 code2SHcode.put(line.getLineCode(), line.getShanghaiLinecode());
+
+                /**
+                 * 加载运管处的站点及序号
+                 * 上行从1开始，下行顺序续编
+
+                num = 1;
+                dirs2Statioin = new HashMap<String, Map>();
+                for (int i = 0; i < dirs.length; i++) {
+                    // 分别取得上下行的站点
+                    stationsList = stationRouteRepository.findByLine(line.getLineCode(), dirs[i]);
+                    size = stationsList == null ? 0 :stationsList.size();
+                    if(size > 0 ){
+                        station2Number = new HashMap<String, Integer>();
+                        for (int j = 0; j < size; j++) {
+                            stationRoute = stationsList.get(j);
+                            // map保存为（站点名称 -->序号）
+                            station2Number.put(stationRoute.getStationName(), num++);
+                        }
+                        // 保存两个数据，（0 --> station2Number）（1 --> station2Number） 0上行 1 下行
+                        dirs2Statioin.put(dirs[i]+"", station2Number);
+                    }
+                }
+                // 保存(站点编码 --> dirs2Statioin)
+                tempStationName2YgcNumber.put(line.getLineCode(), dirs2Statioin);
+                 */
             }
             lineId2CodeMap = biMap;
             lineCode2NameMap = code2name;
             lineId2ShangHaiCodeMap = id2SHcode;
             lineCode2ShangHaiCodeMap = code2SHcode;
+            stationName2YgcNumber = tempStationName2YgcNumber;
         }
         /**
 package com.bsth.service;
-import com.bsth.entity.Line;
-
 /**
- * 
+ *
  * @Interface: LineService(线路service业务层实现接口)
- * 
+ *
  * @extends : BaseService
- * 
+ *
  * @Description: TODO(线路service业务层实现接口)
- * 
+ *
  * @Author bsth@lq
- * 
+ *
  * @Date 2016年4月28日 上午9:21:17
  *
  * @Version 公交调度系统BS版 0.1
- * 
+ *
  */
 public interface TrafficManageService {
-	
+
 	/**
 	 * 上传线路信息
-	 * 
+	 *
 	 * @return 调用接口返回信息
 	 */
 	String setXL();
-	
+
 	/**
 	 * 上传车辆信息
-	 * 
+	 *
 	 * @return 调用接口返回信息
 	 */
 	String setCL();
-	
+
 	/**
 	 * 上传司机信息
 	 * @return 调用接口返回信息
 	 */
 	String setSJ();
-	
+
 	/**
 	 * 上传超速数据
-	 * 
+	 *
 	 * @return 调用接口返回信息
 	 */
 	String setCS();
-	
+
 	/**
 	 * 上传线路班次时刻表数据
-	 * 
+	 *
 	 * @return 调用接口返回信息
 	 */
 	String setSKB(String ids);
-	
+
 	/**
 	 * 线路人员车辆配置信息
 	 * @return 调用接口返回信息
 	 */
 	String setXLPC();
-	
+
 	/**
 	 * 线路计划班次表
 	 * @return 调用接口返回信息
 	 */
 	String setJHBC();
-	
+
 	String setLD();
-	
+
 	String setLCYH();
-	
-	String setDDRB();	
+
+	String setDDRB();
+
+	/**
+	 * 下载全量的公交基础数据
+	 * @return
+	 */
+	String getDownLoadAllDataFile();
+
+	/**
+	 * 下载增量的公交基础数据
+	 * @return
+	 */
+	String getDownLoadIncreaseDataFile();
+
+	/**
+	 * 指定线路查询方式公交基础数据下载
+	 * @return
+	 */
+	String getDownLoadWarrantsBusLineStation();
 }
@@ -22,6 +22,7 @@ import org.slf4j.LoggerFactory;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.data.domain.Sort;
 import org.springframework.data.domain.Sort.Direction;
+import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate;
 import org.springframework.stereotype.Service;
 import com.bsth.data.BasicData;
@@ -119,6 +120,10 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 	@Autowired
 	private ScheduleRealInfoRepository scheduleRealInfoRepository;
+	@Autowired
+	NamedParameterJdbcTemplate jdbcTemplate;
+
+
 	// 运管处接口
 	private InternalPortType portType = new Internal().getInternalHttpSoap11Endpoint();
 	private WebServiceSoap ssop ;
@@ -163,9 +168,6 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			sBuffer.append("<XLs>");
 			while(lineIterator.hasNext()){
 				line = lineIterator.next();
-				if(line.getLinePlayType() == null){
-					continue;
-				}
 				if(BasicData.lineId2ShangHaiCodeMap.get(line.getId()) == null){
 					continue;
 				}
@@ -189,7 +191,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					sBuffer.append("<QZLC>").append(upMileage).append("</QZLC>");
 					sBuffer.append("<ZQLC>").append(downMileage).append("</ZQLC>");
 				}
-				sBuffer.append("<XLGH>").append(line.getLinePlayType()).append("</XLGH>");
+				sBuffer.append("<XLGH>").append(line.getLinePlayType() == null ?"0":line.getLinePlayType())
+						.append("</XLGH>");
 				// 循环添加站点信息
 				sBuffer.append("<StationList>");
 				// 先查上行
@@ -334,21 +337,28 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					int seqNumber = 0;
 					for(ScheduleRealInfo scheduleRealInfo:list){
-						if(schRealInfo.getXlBm().equals(scheduleRealInfo.getXlBm()) && schRealInfo.getLpName().equals(scheduleRealInfo.getLpName())
+						if(schRealInfo.getXlBm().equals(scheduleRealInfo.getXlBm()) && schRealInfo.getLpName()
+								.equals(scheduleRealInfo.getLpName())
 								&& schRealInfo.getClZbh().equals(scheduleRealInfo.getClZbh())){
+							if(scheduleRealInfo.getFcsjActual() == null ||scheduleRealInfo.getBcType().equals("in")
+									|| scheduleRealInfo.getBcType().equals("out")){
+								continue;
+							}
 							scheduleRealInfo.getQdzCode();
 							sf.append("<LD>");
 							sf.append("<SJGH>"+scheduleRealInfo.getjGh()+"</SJGH>");
 							sf.append("<SXX>"+scheduleRealInfo.getXlDir()+"</SXX>");
 							sf.append("<FCZDMC>"+scheduleRealInfo.getQdzName()+"</FCZDMC>");
-							sf.append("<FCZDXH>" + ++seqNumber + "</FCZDXH>");
+							sf.append("<FCZDXH>" + getYgcStationNumByLineCodeAndDirectionAndStationName(
+									scheduleRealInfo.getXlBm(), scheduleRealInfo.getXlDir(), scheduleRealInfo.getQdzName()) + "</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>"+ seqNumber +"</DDZDXH>");
+							sf.append("<DDZDXH>"+ getYgcStationNumByLineCodeAndDirectionAndStationName(
+									scheduleRealInfo.getXlBm(), scheduleRealInfo.getXlDir(), scheduleRealInfo.getZdzName()) +"</DDZDXH>");
 							sf.append("<DDZDBM>"+scheduleRealInfo.getZdzCode()+"</DDZDBM>");
 							sf.append("<JHDDSJ>"+scheduleRealInfo.getZdsj()+"</JHDDSJ>");
 							sf.append("<SJDDSJ>"+scheduleRealInfo.getZdsjActual()+"</SJDDSJ>");
@@ -404,7 +414,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					sf.append("<XLBM>"+BasicData.lineCode2ShangHaiCodeMap.get(schRealInfo.getXlBm())+"</XLBM>");
 					sf.append("<CPH>"+car.getCarPlate()+"</CPH>");
 					for(ScheduleRealInfo scheduleRealInfo:list){
-						if(schRealInfo.getXlBm().equals(scheduleRealInfo.getXlBm()) && schRealInfo.getClZbh().equals(scheduleRealInfo.getClZbh())){
+						if(schRealInfo.getXlBm().equals(scheduleRealInfo.getXlBm()) && schRealInfo.getClZbh()
+								.equals(scheduleRealInfo.getClZbh())){
 							Set<ChildTaskPlan> childTaskPlans = scheduleRealInfo.getcTasks();
 							//如果没有子任务，里程就是已执行（Status=2）;有子任务的，忽略主任务，子任务的烂班
 							if(childTaskPlans.isEmpty()){
@@ -412,7 +423,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 									totalKilometers += scheduleRealInfo.getJhlc()==null?0.0:scheduleRealInfo.getJhlc();
 									if(scheduleRealInfo.getBcType().equals("in") || scheduleRealInfo.getBcType().equals("out")
 											|| scheduleRealInfo.getBcType().equals("venting")){
-										emptyKilometers += scheduleRealInfo.getJhlc()==null?0.0:scheduleRealInfo.getJhlc();;
+										emptyKilometers += scheduleRealInfo.getJhlc()==null?0.0:scheduleRealInfo.getJhlc();
 									}
 								}
 							}else{
@@ -588,14 +599,19 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 					if(xlbm.equals(schedulePlanInfo.getXlBm())
 							&& zbh.equals(schedulePlanInfo.getClZbh())
 							&& lp == schedulePlanInfo.getLp()){
+						if(schedulePlanInfo.getBcType().equals("in") || schedulePlanInfo.getBcType().equals("out")){
+							continue;
+						}
 						sBuffer.append("<BC>");
 						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(++startSerialNum).append("</ZDXH>");
+						sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
+								schedulePlanInfo.getXlBm(), schedulePlanInfo.getXlDir(), schedulePlanInfo.getQdzName())).append("</ZDXH>");
 						sBuffer.append("<JHFCSJ>").append(schedulePlanInfo.getFcsj()).append("</JHFCSJ>");
 						sBuffer.append("<DDZDMC>").append(schedulePlanInfo.getZdzName()).append("</DDZDMC>");
-						sBuffer.append("<ZDXH>").append(++endSerialNum).append("</ZDXH>");
+						sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
+								schedulePlanInfo.getXlBm(), schedulePlanInfo.getXlDir(), schedulePlanInfo.getZdzName())).append("</ZDXH>");
 						sBuffer.append("<JHDDSJ>").append(calcDdsj(schedulePlanInfo.getFcsj(),schedulePlanInfo.getBcsj()))
 								.append("</JHDDSJ>");
 						sBuffer.append("</BC>");
@@ -643,6 +659,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 			Iterator<TTInfoDetail> ttInfoDetailIterator;
 			HashMap<String,Object> param = new HashMap<String, Object>();
 			String ttinfoJhlc = null;//计划总里程
+			String lineCode ;
 			sBuffer.append("<SKBs>");
 			for (int i = 0; i < idArray.length; i++) {
 				ttInfo = ttInfoRepository.findOne(Long.valueOf(idArray[i]));
@@ -652,7 +669,8 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 				ttInfoDetailIterator = ttInfoDetailRepository.findAll(new CustomerSpecs<TTInfoDetail>(param),
 						new Sort(Direction.ASC, "xlDir")).iterator();
 				sBuffer.append("<SKB>");
-				sBuffer.append("<XLBM>").append(BasicData.lineId2ShangHaiCodeMap.get(ttInfo.getXl())).append("</XLBM>");
+				sBuffer.append("<XLBM>").append(BasicData.lineId2ShangHaiCodeMap.get(ttInfo.getXl().getId()))
+						.append("</XLBM>");
 				ttinfoJhlc = new String();
 				sBuffer.append("<JHZLC>").append(ttinfoJhlc).append("</JHZLC>");
 				sBuffer.append("<JHYYLC>").append(ttinfoJhlc).append("</JHYYLC>");
@@ -662,23 +680,35 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 				sBuffer.append("<TBYY>").append("").append("</TBYY>");
 				sBuffer.append("<UPDT>").append(sdfnyrsfm.format(new Date())).append("</UPDT>");
 				int num = 1;
+				// 加上<BCList>
+				if(ttInfoDetailIterator.hasNext()){
+					sBuffer.append("<BCList>");
+				}
 				while (ttInfoDetailIterator.hasNext()) {
 					ttInfoDetail = ttInfoDetailIterator.next();
+					if(ttInfoDetail.getBcType().equals("in") || ttInfoDetail.getBcType().equals("out")){
+						continue;
+					}
 					ttinfoJhlc = ttInfoDetail.getJhlc()+"";// 设置计划总里程
-					sBuffer.append("<BCList>");
+					lineCode = ttInfoDetail.getXl().getLineCode();
 					sBuffer.append("<BC>");
 					sBuffer.append("<LPBH>").append(ttInfoDetail.getLp().getLpNo()).append("</LPBH>");
 					sBuffer.append("<SXX>").append(ttInfoDetail.getXlDir()).append("</SXX>");
-					sBuffer.append("<FCZDMC>").append(ttInfoDetail.getQdz()).append("</FCZDMC>");
-					sBuffer.append("<ZDXH>").append(num).append("</ZDXH>");
+					sBuffer.append("<FCZDMC>").append(ttInfoDetail.getQdz().getStationName()).append("</FCZDMC>");
+					sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
+							lineCode, ttInfoDetail.getXlDir(), ttInfoDetail.getQdz().getStationName())).append("</ZDXH>");
 					sBuffer.append("<JHFCSJ>").append(ttInfoDetail.getFcsj()).append("</JHFCSJ>");
-					sBuffer.append("<DDZDMC>").append(ttInfoDetail.getZdz()).append("</DDZDMC>");
-					sBuffer.append("<ZDXH>").append(num).append("</ZDXH>");
+					sBuffer.append("<DDZDMC>").append(ttInfoDetail.getZdz().getStationName()).append("</DDZDMC>");
+					sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(
+							lineCode, ttInfoDetail.getXlDir(), ttInfoDetail.getZdz().getStationName())).append("</ZDXH>");
 					sBuffer.append("<JHDDSJ>").append(calcDdsj(ttInfoDetail.getFcsj(),ttInfoDetail.getBcsj())).append("</JHDDSJ>");
 					sBuffer.append("</BC>");
-					sBuffer.append("</BCList>");
+
 					num++;
 				}
+				if(sBuffer.indexOf("<BCList>") != -1){
+					sBuffer.append("</BCList>");
+				}
 				sBuffer.append("</SKB>");
 			}
 			sBuffer.append("</SKBs>");
@@ -1008,7 +1038,7 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 				zdlx = "2";
 			}
 			sBuffer.append("<Station>");
-			sBuffer.append("<ZDXH>").append(startId).append("</ZDXH>");
+			sBuffer.append("<ZDXH>").append(getYgcStationNumByLineCodeAndDirectionAndStationName(srRoute.getLineCode(),srRoute.getDirections()+"",srRoute.getStationName())).append("</ZDXH>");
 			sBuffer.append("<SXX>").append(srRoute.getDirections()).append("</SXX>");
 			sBuffer.append("<ZDMC>").append(srRoute.getStationName()).append("</ZDMC>");
 			sBuffer.append("<ZDBM>").append(srRoute.getStationCode()).append("</ZDBM>");
@@ -1023,4 +1053,18 @@ public class TrafficManageServiceImpl  implements TrafficManageService{
 		return startId;
 	}
+	/**
+	 *
+	 * @param lineCode 线路编码
+	 * @param direction 线路方向
+	 * @param stationName 让点名称
+	 * @return 运管处站点序号
+	 */
+	private Integer getYgcStationNumByLineCodeAndDirectionAndStationName(String lineCode,String direction,String stationName){
+		Integer number = 0;
+		Map<String, Map> dirs2Statioin = BasicData.stationName2YgcNumber.get(lineCode);
+		Map<String, Integer> station2Number = dirs2Statioin.get(direction);
+		number = station2Number.get(stationName);
+		return number;
+	}
 }