update...

潘钊
1 parent cb9e67ff
Showing 2 changed files with 13 additions and 1 deletions
src/main/java/com/bsth/data/gpsdata_v2/cache/GpsCacheData.java
src/main/java/com/bsth/data/schedule/thread/ScheduleRefreshThread.java
@@ -33,6 +33,15 @@ public class GpsCacheData {
         return gpsCacheMap.get(device);
     }
+    /**
+     * 清除车辆的轨迹数据
+     * @param nbbm
+     */
+    public static void remove(String nbbm){
+        logger.info("清除车辆到离站轨迹, " + nbbm);
+        trailListMultimap.removeAll(nbbm);
+    }
+
     public static GpsExecTrail gpsExecTrail(String nbbm){
         List<GpsExecTrail> list = trailListMultimap.get(nbbm);
@@ -3,6 +3,7 @@ package com.bsth.data.schedule.thread;
 import com.bsth.data.BasicData;
 import com.bsth.data.LineConfigData;
 import com.bsth.data.directive.DayOfDirectives;
+import com.bsth.data.gpsdata_v2.cache.GpsCacheData;
 import com.bsth.data.pilot80.PilotReport;
 import com.bsth.data.schedule.DayOfSchedule;
 import com.bsth.data.schedule.f_a_l.FirstAndLastHandler;
@@ -60,8 +61,10 @@ public class ScheduleRefreshThread extends Thread{
 						try{
 							//清除指令数据
 							Set<String> cars = dayOfSchedule.findCarByLineCode(lineCode);
-							for(String car : cars)
+							for(String car : cars){
 								dayOfDirectives.clear(BasicData.deviceId2NbbmMap.inverse().get(car));
+								GpsCacheData.remove(car);
+							}
 							//清除驾驶员上报数据
 							pilotReport.clear(lineCode);
 						}catch (Exception e){