update...

潘钊
1 parent 2248fc4a
Showing 1 changed file with 12 additions and 4 deletions
src/main/java/com/bsth/XDApplication.java
 package com.bsth;
 import com.bsth.data.BasicData;
-import com.bsth.data.LineVersionsData;
 import com.bsth.data.ThreadMonotor;
 import com.bsth.data.car_out_info.UpdateDBThread;
 import com.bsth.data.directive.DirectivesPstThread;
 import com.bsth.data.forecast.SampleTimeDataLoader;
 import com.bsth.data.gpsdata_v2.thread.GpsDataLoaderThread;
 import com.bsth.data.gpsdata_v2.thread.OfflineMonitorThread;
+import com.bsth.data.line_version.thread.FixedEnableVerionsThread;
 import com.bsth.data.msg_queue.DirectivePushQueue;
 import com.bsth.data.msg_queue.WebSocketPushQueue;
 import com.bsth.data.safe_driv.SafeDrivDataLoadThread;
@@ -73,8 +73,11 @@ public class XDApplication implements CommandLineRunner {
     @Autowired
     OfflineMonitorThread offlineMonitorThread;
+    //@Autowired
+    //LineVersionsData lineVersionsData;
+
     @Autowired
-    LineVersionsData lineVersionsData;
+    FixedEnableVerionsThread fixedEnableVerionsThread;
     @Autowired
     SafeDrivDataLoadThread safeDrivDataLoadThread;
@@ -126,7 +129,7 @@ public class XDApplication implements CommandLineRunner {
         //实际排班更新线程
         //sexec.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS);
         //sexec.scheduleWithFixedDelay(autoExecScanThread, 100, 50, TimeUnit.SECONDS);//班次自动执行
-        WebSocketPushQueue.start();//消息队列 -webSocket ，推送至线调web页面的
+        //WebSocketPushQueue.start();//消息队列 -webSocket ，推送至线调web页面的
         //实际排班延迟入库线程
         //sexec.scheduleWithFixedDelay(schedulePstThread, 60, 15, TimeUnit.SECONDS);
         //班次修正日志延迟入库
@@ -138,6 +141,8 @@ public class XDApplication implements CommandLineRunner {
         //安全驾驶
         //sexec.scheduleWithFixedDelay(safeDrivDataLoadThread, 40, 30, TimeUnit.SECONDS);
+
+        //sexec.scheduleWithFixedDelay(fixedEnableVerionsThread, 20, 60 * 2 , TimeUnit.SECONDS);
     }
     public void prodInit(){
@@ -175,6 +180,9 @@ public class XDApplication implements CommandLineRunner {
         sexec.scheduleAtFixedRate(calcOilThread, timeDiff / 1000, 60 * 60 * 24, TimeUnit.SECONDS);
         //线路版本更新
-        sexec.scheduleWithFixedDelay(lineVersionsData, 60 * 5, 60 * 15, TimeUnit.SECONDS);
+        //sexec.scheduleWithFixedDelay(lineVersionsData, 60 * 5, 60 * 15, TimeUnit.SECONDS);
+
+        //线路版本更新
+        sexec.scheduleWithFixedDelay(fixedEnableVerionsThread, 60 * 4, 60 * 2 , TimeUnit.SECONDS);
     }
 }