update...

潘钊
1 parent 48d55e8d
Showing 4 changed files with 67 additions and 6 deletions
src/main/java/com/bsth/data/gpsdata/arrival/GpsRealAnalyse.java
src/main/java/com/bsth/entity/realcontrol/ChildTaskPlan.java
src/main/java/com/bsth/entity/realcontrol/ScheduleRealInfo.java
src/main/java/com/bsth/service/realcontrol/impl/ChildTaskPlanServiceImpl.java
@@ -41,7 +41,7 @@ public class GpsRealAnalyse {
     @Autowired
     GpsRealData gpsRealData;
-    final static int POOL_SIZE = 25;
+    final static int POOL_SIZE = 30;
     static ExecutorService threadPool = Executors.newFixedThreadPool(POOL_SIZE + 1);
     public static long st;
@@ -35,6 +35,7 @@ public class ChildTaskPlan {
 	/**
 	 * 任务类型2
+	 * 1 正常 2 进场 3 出场
 	 */
 	private String type2;
@@ -99,6 +100,11 @@ public class ChildTaskPlan {
 	private String nbbm;
 	/**
+	 * 中途换车营运， 新车关联的主任务ID，子任务删除时，主任务ID将级联
+	 */
+	private Long ccId;
+
+	/**
 	 * 为true 则无售票员， 否则继承主任务
 	 */
 	private boolean noClerk;
@@ -277,4 +283,12 @@ public class ChildTaskPlan {
 	public void setNoClerk(boolean noClerk) {
 		this.noClerk = noClerk;
 	}
+
+	public Long getCcId() {
+		return ccId;
+	}
+
+	public void setCcId(Long ccId) {
+		this.ccId = ccId;
+	}
 }
@@ -225,6 +225,11 @@ public class ScheduleRealInfo {
 	 */
 	private Integer driftStatus = 0;
+	/**
+	 * 换车营运标记 true 表示该主任务由 【中途换车子任务】 级联生成
+	 */
+	private boolean ccService;
+
 	public boolean isDfAuto() {
 		return dfAuto;
 	}
@@ -958,4 +963,12 @@ public class ScheduleRealInfo {
 	public void setDriftStatus(Integer driftStatus) {
 		this.driftStatus = driftStatus;
 	}
+
+	public boolean isCcService() {
+		return ccService;
+	}
+
+	public void setCcService(boolean ccService) {
+		this.ccService = ccService;
+	}
 }
 package com.bsth.service.realcontrol.impl;
+import com.alibaba.fastjson.JSON;
 import com.bsth.common.ResponseCode;
 import com.bsth.data.BasicData;
 import com.bsth.data.Station2ParkBuffer;
@@ -46,14 +47,11 @@ public class ChildTaskPlanServiceImpl extends BaseServiceImpl&lt;ChildTaskPlan, Lon
         try {
             ScheduleRealInfo sch = dayOfSchedule.get(t.getSchedule().getId());
             //保存起终点名称
-            //String prefix = sch.getXlBm() + "_" + sch.getXlDir() + "_";
             if(StringUtils.isEmpty(t.getStartStationName()))
                 t.setStartStationName(getStationName(sch.getXlBm(), t.getStartStation()));
-                //t.setStartStationName(BasicData.getStationNameByCode(t.getStartStation(), prefix));
             if(StringUtils.isEmpty(t.getEndStationName()))
                 t.setEndStationName(getStationName(sch.getXlBm(), t.getEndStation()));
-                //t.setEndStationName(BasicData.getStationNameByCode(t.getEndStation(), prefix));
             if(t.getDestroyReason() == null)
                 t.setDestroyReason("");
@@ -61,13 +59,44 @@ public class ChildTaskPlanServiceImpl extends BaseServiceImpl&lt;ChildTaskPlan, Lon
             if(t.isDestroy() && StringUtils.isEmpty(t.getDestroyReason()))
                 t.setDestroyReason(t.getReason());
+            //中途换车出场子任务，级联生成一个主任务，供报表和对外接口计算用
+            if(StringUtils.isNotEmpty(t.getNbbm())){
+                ScheduleRealInfo ccServiceSch = JSON.parseObject(JSON.toJSONString(sch), ScheduleRealInfo.class);
+                ccServiceSch.setId(null);
+                ccServiceSch.setSpId(null);
+                ccServiceSch.setClZbh(t.getNbbm());
+                ccServiceSch.setCcService(true);
+                ccServiceSch.setFcsj(t.getStartDate());
+                ccServiceSch.setDfsj(t.getStartDate());
+                ccServiceSch.setZdsj(t.getEndDate());
+                ccServiceSch.setBcsj(0);
+                ccServiceSch.setJhlcOrig(Double.parseDouble(String.valueOf(t.getMileage())));
+                ccServiceSch.setJhlc(ccServiceSch.getJhlcOrig());
+                ccServiceSch.setQdzCode(t.getStartStation());
+                ccServiceSch.setZdzCode(t.getEndStation());
+                ccServiceSch.setQdzName(t.getStartStationName());
+                ccServiceSch.setZdzName(t.getEndStationName());
+                ccServiceSch.setFcsjActual(ccServiceSch.getDfsj());
+                ccServiceSch.setZdsjActual(ccServiceSch.getZdsj());
+                if("1".equals(t.getType2())){
+                    ccServiceSch.setBcType("normal");
+                }
+                else {
+                    if("2".equals(t.getType2()))
+                        ccServiceSch.setBcType("in");
+                    else if("3".equals(t.getType2()))
+                        ccServiceSch.setBcType("out");
+                }
+                //实时入库
+                ccServiceSch = scheduleRealInfoRepository.save(ccServiceSch);
+                t.setCcId(ccServiceSch.getId());
+            }
+
             //先持久化子任务
             rs = super.save(t);
             //关联主任务
             sch.getcTasks().add(t);
             dayOfSchedule.save(sch);
-            //直接持久化
-            //scheduleRealInfoRepository.save(sch);
             //站到场对照
             t.setSchedule(sch);
             Station2ParkBuffer.put(t);
@@ -101,6 +130,11 @@ public class ChildTaskPlanServiceImpl extends BaseServiceImpl&lt;ChildTaskPlan, Lon
         //删除子任务
         rs = super.delete(id);
+
+        //删除级联生成的换车主任务
+        if(null != cPlan.getCcId()){
+            scheduleRealInfoRepository.delete(cPlan.getCcId());
+        }
         //dayOfSchedule.save(sch);
         //解除和主任务关联
         ScheduleRealInfo sch = dayOfSchedule.get(cPlan.getSchedule().getId());