1.加入获取不在岗的出场班次接口

王通
1 parent c3956eea
Showing 2 changed files with 104 additions and 74 deletions
src/main/java/com/bsth/server_rs/schedule/real/SchRealDataBuffer.java
src/main/java/com/bsth/server_rs/schedule/real/ScheduleRealService.java
-package com.bsth.server_rs.schedule.real;
-
-import com.alibaba.fastjson.JSONObject;
-import com.bsth.entity.ScheduleRealInfo;
-import com.google.common.collect.ArrayListMultimap;
-import org.apache.commons.lang3.StringUtils;
-import org.springframework.stereotype.Component;
-
-import java.util.Collection;
-import java.util.List;
-import java.util.Map;
-
-/**
- * 实际排班缓存
- * Created by panzhao on 2017/9/27.
- */
-@Component
-public class SchRealDataBuffer {
-
-    /**
-     * 进出场班次数据，定时从调度系统获取。 对各场站输出
-     */
-    private static ArrayListMultimap<String, ScheduleRealInfo> inOutMap;
-
-    /**
-     * 车辆 和 当前正在执行班次对照
-     */
-    private static Map<String, JSONObject> execMap;
-
-    public void putInOutData(List<ScheduleRealInfo> list) {
-        ArrayListMultimap<String, ScheduleRealInfo> inOutMapCopy = ArrayListMultimap.create();
-
-        String type;
-        for (ScheduleRealInfo sch : list) {
-            type = sch.getBcType();
-            if (StringUtils.isEmpty(type))
-                continue;
-
-            if (type.equals("in"))
-                inOutMapCopy.put(sch.getZdzCode(), sch);
-            else if (type.equals("out"))
-                inOutMapCopy.put(sch.getQdzCode(), sch);
-        }
-
-        inOutMap = inOutMapCopy;
-    }
-
-
-    public void setExecMap(Map<String, JSONObject> map) {
-        if (map.size() > 0)
-            execMap = map;
-    }
-
-    public List<ScheduleRealInfo> findByParkCode(String parkCode) {
-        return inOutMap.get(parkCode);
-    }
-
- /*   public List<JSONObject> findExec(List<String> cars){
-        List<JSONObject> rs = new ArrayList<>(cars.size());
-
-        for(String nbbm : cars){
-            rs.add(execMap.get(nbbm));
-        }
-        return rs;
-    }*/
-
-    public JSONObject getExecPlan(String nbbm) {
-        return execMap.get(nbbm);
-    }
-
-    public Collection<JSONObject> execs() {
-        return execMap.values();
-    }
-}
+package com.bsth.server_rs.schedule.real;
+
+import com.alibaba.fastjson.JSONObject;
+import com.bsth.entity.ScheduleRealInfo;
+import com.google.common.collect.ArrayListMultimap;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Component;
+
+import java.util.Collection;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 实际排班缓存
+ * Created by panzhao on 2017/9/27.
+ */
+@Component
+public class SchRealDataBuffer {
+
+    /**
+     * 进出场班次数据，定时从调度系统获取。 对各场站输出
+     */
+    private static ArrayListMultimap<String, ScheduleRealInfo> inOutMap;
+
+    /**
+     * 车辆 和 当前正在执行班次对照
+     */
+    private static Map<String, JSONObject> execMap;
+
+    public void putInOutData(List<ScheduleRealInfo> list) {
+        ArrayListMultimap<String, ScheduleRealInfo> inOutMapCopy = ArrayListMultimap.create();
+
+        String type;
+        for (ScheduleRealInfo sch : list) {
+            type = sch.getBcType();
+            if (StringUtils.isEmpty(type))
+                continue;
+
+            if (type.equals("in"))
+                inOutMapCopy.put(sch.getZdzCode(), sch);
+            else if (type.equals("out"))
+                inOutMapCopy.put(sch.getQdzCode(), sch);
+        }
+
+        inOutMap = inOutMapCopy;
+    }
+
+    public Collection<ScheduleRealInfo> getInOutData() {
+        return inOutMap.values();
+    }
+
+    public void setExecMap(Map<String, JSONObject> map) {
+        if (map.size() > 0)
+            execMap = map;
+    }
+
+    public List<ScheduleRealInfo> findByParkCode(String parkCode) {
+        return inOutMap.get(parkCode);
+    }
+
+ /*   public List<JSONObject> findExec(List<String> cars){
+        List<JSONObject> rs = new ArrayList<>(cars.size());
+
+        for(String nbbm : cars){
+            rs.add(execMap.get(nbbm));
+        }
+        return rs;
+    }*/
+
+    public JSONObject getExecPlan(String nbbm) {
+        return execMap.get(nbbm);
+    }
+
+    public Collection<JSONObject> execs() {
+        return execMap.values();
+    }
+}
@@ -14,6 +14,8 @@ import com.bsth.server_rs.base_info.car.Car;
 import com.bsth.server_rs.base_info.car.buffer.CarBufferData;
 import com.bsth.server_rs.base_info.line.Line;
 import com.bsth.server_rs.base_info.line.buffer.LineBufferData;
+import com.bsth.server_rs.gps.buffer.GpsRealDataBuffer;
+import com.bsth.server_rs.gps.entity.GpsEntity;
 import com.bsth.server_rs.schedule.dto.ScheduleCcInfoConfig;
 import com.bsth.server_rs.schedule.dto.ScheduleInOut;
 import com.bsth.server_rs.schedule.dto.ScheduleRealInfoDTO_JK;
@@ -303,6 +305,31 @@ public class ScheduleRealService implements InitializingBean {
         return rs;
     }
+    /**
+     * 获取不在岗的班次信息
+     */
+    @GET
+    @Path("/notOnDuty")
+    public List<ScheduleRealInfo> notOnDuty() {
+        List<ScheduleRealInfo> result = new ArrayList<>();
+        Collection<ScheduleRealInfo> collection = schRealDataBuffer.getInOutData();
+        long now = System.currentTimeMillis();
+        for (ScheduleRealInfo sch : collection) {
+            if ("in".equals(sch.getBcType())) {
+                continue;
+            }
+            GpsEntity gpsEntity = GpsRealDataBuffer.get(CarBufferData.findOne(sch.getClZbh()).getEquipmentCode());
+            long schIntervalMillis = sch.getDfsjT() - now, gpsIntervalMillis =  sch.getDfsjT() - (gpsEntity == null ? 0 : gpsEntity.getTimestamp());
+            boolean isSchMatch = schIntervalMillis > 0 && schIntervalMillis < 1200000, isGpsMatch = gpsIntervalMillis > 1200000;
+            // 当前时间往后20分钟内的出场班次 且相应车辆在待发时间20分钟内无GPS数据
+            if (isSchMatch && isGpsMatch) {
+                result.add(sch);
+            }
+        }
+
+        return result;
+    }
+
     @Override
     public void afterPropertiesSet() throws Exception {
         /*Application.mainServices.scheduleWithFixedDelay(new Runnable() {