Commit 3c70808649f233f38e3e9f0c50eb41924ffb589d

Authored by 王通
1 parent 56c2779e

1.pudong_test分支加入rfid处理逻辑

src/main/java/com/bsth/XDApplication.java
... ... @@ -8,6 +8,7 @@ import com.bsth.data.directive.DirectivesPstThread;
8 8 import com.bsth.data.forecast.SampleTimeDataLoader;
9 9 import com.bsth.data.gpsdata_v2.thread.GpsDataLoaderThread;
10 10 import com.bsth.data.gpsdata_v2.thread.OfflineMonitorThread;
  11 +import com.bsth.data.gpsdata_v2.thread.RfidDataLoaderThread;
11 12 import com.bsth.data.msg_queue.DirectivePushQueue;
12 13 import com.bsth.data.msg_queue.WebSocketPushQueue;
13 14 import com.bsth.data.safe_driv.SafeDrivDataLoadThread;
... ... @@ -72,6 +73,9 @@ public class XDApplication implements CommandLineRunner {
72 73 GpsDataLoaderThread gpsDataLoader;
73 74  
74 75 @Autowired
  76 + RfidDataLoaderThread rfidDataLoaderThread;
  77 +
  78 + @Autowired
75 79 OfflineMonitorThread offlineMonitorThread;
76 80  
77 81 @Autowired
... ... @@ -162,6 +166,7 @@ public class XDApplication implements CommandLineRunner {
162 166 sexec.scheduleWithFixedDelay(scheduleRefreshThread, 10, 120, TimeUnit.SECONDS);//班次更新线程
163 167 sexec.scheduleWithFixedDelay(scheduleLateThread, 140, 20, TimeUnit.SECONDS);//检查班次误点
164 168 sexec.scheduleWithFixedDelay(gpsDataLoader, 100, 2, TimeUnit.SECONDS);//抓取GPS数据
  169 + sexec.scheduleWithFixedDelay(rfidDataLoaderThread, 10, 20, TimeUnit.SECONDS);//抓取GPS数据
165 170 sexec.scheduleWithFixedDelay(fixedCheckStationCodeThread, 60, 60 * 5, TimeUnit.SECONDS);//检查班次站点编码
166 171  
167 172 sexec.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS);//GPS设备掉离线
... ...