update...

潘钊
1 parent aa5cc34b
Showing 3 changed files with 44 additions and 39 deletions
src/main/java/com/bsth/data/gpsdata/arrival/handlers/InOutStationSignalHandle.java
src/main/java/com/bsth/websocket/handler/SendUtils.java
src/main/resources/static/real_control_v2/css/main.css
@@ -164,6 +164,9 @@ public class InOutStationSignalHandle extends SignalHandle{
             //实发时间
             sch.setFcsjActualAll(rsT);
             sch.setSiginCompate(1);
+
+            //出站既出场
+            outStationAndOutPark(sch);
             //通知客户端
             sendUtils.sendFcsj(sch);
             //持久化
@@ -172,12 +175,11 @@ public class InOutStationSignalHandle extends SignalHandle{
             //清理应发未发标记
             LateAdjustHandle.remove(sch);
-            if(!gps.isService()){
+            if(!gps.isService() && !dayOfSchedule.emptyService(sch)){
                 //切换成营运状态
                 gpsStatusManager.changeServiceState(sch.getClZbh(), sch.getXlDir(), 0, "发车@系统");
             }
-            //出站既出场
-            outStationAndOutPark(sch);
+
             logger.info("车辆：" + sch.getClZbh() + " 班次：" + sch.getDfsj() + "发车， 时间：" + sch.getFcsjActual());
         }
         else if(isOutSch(sch)){
@@ -252,31 +254,29 @@ public class InOutStationSignalHandle extends SignalHandle{
     private void outStationAndOutPark(ScheduleRealInfo sch){
-        LineConfig config = lineConfigData.get(sch.getXlBm());
-        //限定出站既出场的停车场
-        String park = config.getTwinsPark();
-        boolean limitPark = StringUtils.isNotEmpty(park);
-
-        if (config != null && config.getOutConfig() == 2) {
-            //出站既出场
-            ScheduleRealInfo schPrev = dayOfSchedule.prev(sch);
-            if (schPrev != null && schPrev.getBcType().equals("out") && (schPrev.getBcsj()==0 || schPrev.getJhlcOrig().intValue()==0)
-                    && (!limitPark || park.equals(schPrev.getQdzCode()))) {
-
-                schPrev.setFcsjActualAll(sch.getFcsjActualTime());
-                schPrev.setZdsjActualAll(sch.getFcsjActualTime());
-
-                sendUtils.refreshSch(schPrev);
-                dayOfSchedule.save(schPrev);
-
-                /*if(schPrev.getBcType().equals("out")){
-                    //出场时，切换成营运状态
-                    String deviceId = BasicData.deviceId2NbbmMap.inverse().get(sch.getClZbh());
-                    gpsStatusManager.changeServiceState(deviceId, schPrev.getXlDir(), 0, "出场@系统");
-                    //DirectivePushQueue.put6003(schPrev.getClZbh(), 0, Integer.parseInt(schPrev.getXlDir()), "出场@系统");
-                    //directiveService.send60Operation(schPrev.getClZbh(), 0, Integer.parseInt(schPrev.getXlDir()), null, "出场@系统");
-                }*/
+        try{
+            LineConfig config = lineConfigData.get(sch.getXlBm());
+            //限定出站既出场的停车场
+            String park = config.getTwinsPark();
+            boolean limitPark = StringUtils.isNotEmpty(park);
+
+            if (config != null && config.getOutConfig() == 2) {
+                //出站既出场
+                ScheduleRealInfo schPrev = dayOfSchedule.prev(sch);
+                if (schPrev != null && schPrev.getBcType().equals("out") && (schPrev.getBcsj()==0 || schPrev.getJhlcOrig().intValue()==0)
+                        && (!limitPark || park.equals(schPrev.getQdzCode()))) {
+
+                    schPrev.setFcsjActualAll(sch.getFcsjActualTime());
+                    schPrev.setZdsjActualAll(sch.getFcsjActualTime());
+                    //起点实到
+                    sch.setQdzArrDatesj(schPrev.getZdsjActual());
+
+                    sendUtils.refreshSch(schPrev);
+                    dayOfSchedule.save(schPrev);
+                }
             }
+        }catch (Exception e){
+            logger.error("", e);
         }
     }
@@ -343,9 +343,6 @@ public class InOutStationSignalHandle extends SignalHandle{
             if(lpNext != null){
                 lpNext.setQdzArrDatesj(sch.getZdsjActual());
             }
-            else{
-                logger.info(sch.getClZbh() + " 到终点，无下一班");
-            }
             //通知客户端
             sendUtils.sendZdsj(sch, lpNext, doneSum);
@@ -361,11 +358,12 @@ public class InOutStationSignalHandle extends SignalHandle{
                 if(!next.getXlBm().equals(sch.getXlBm())){
                     gpsStatusManager.changeLine(next.getClZbh(), next.getXlBm(), "套跑@系统");
                 }
-            }
-            else if(sch.getBcType().equals("in")){
-                //进场，切换成非营运状态
-                gpsStatusManager.changeServiceState(sch.getClZbh(), sch.getXlDir(), 1, "进场@系统");
-            }
+
+                //下一个班次是空驶班次
+                if(dayOfSchedule.emptyService(next))
+                    nonService(sch, "空驶@系统");
+            } else
+                nonService(sch, "结束@系统");
         }
         else {
             /*if(sch.getFcsjActual() == null){
@@ -466,7 +464,7 @@ public class InOutStationSignalHandle extends SignalHandle{
                 dayOfSchedule.addExecPlan(next);
             //进场，切换成非营运状态
-            gpsStatusManager.changeServiceState(sch.getClZbh(), sch.getXlDir(), 1, "进场@系统");
+            nonService(sch, "进场@系统");
         }
     }
@@ -522,4 +520,13 @@ public class InOutStationSignalHandle extends SignalHandle{
     private boolean isInSch(ScheduleRealInfo sch){
         return sch.getBcType().equals("in") || GeoCacheData.tccMap.keySet().contains(sch.getZdzCode());
     }
+
+    /**
+     * 切换为非营运状态
+     * @param sch
+     * @param sender
+     */
+    private void nonService(ScheduleRealInfo sch, String sender){
+        gpsStatusManager.changeServiceState(sch.getClZbh(), sch.getXlDir(), 1, sender);
+    }
 }
 \ No newline at end of file
@@ -36,8 +36,6 @@ public class SendUtils{
 	 *             TODO(推送发车信息)
 	 */
 	public void sendFcsj(ScheduleRealInfo sch) {
-		//处理出站即出场的班次
-		//connectOutSchTime(sch);
 		Map<String, Object> map = new HashMap<>();
 		map.put("fn", "faChe");
@@ -271,7 +271,7 @@ svg.line-chart g.merge-item text {
 }
 .qtip-multi-gps {
-    max-width: 716px !important;
+    max-width: 720px !important;
 }
 .qtip-bootstrap.qtip-multi-gps .qtip-content {