潘钊 / bsth_control · Commits

Commit d1c07f52efac8879b68ebeeb13df3b7da85e9363

Authored by 潘钊
1 parent 89431cf9

update...

Inline Side-by-side
Showing 1 changed file with 9 additions and 1 deletions
src/main/java/com/bsth/XDApplication.java
  View file @d1c07f5
@@ -13,6 +13,7 @@ import com.bsth.data.msg_queue.WebSocketPushQueue; @@ -13,6 +13,7 @@ import com.bsth.data.msg_queue.WebSocketPushQueue;
13 import com.bsth.data.safe_driv.SafeDrivDataLoadThread; 13 import com.bsth.data.safe_driv.SafeDrivDataLoadThread;
14 import com.bsth.data.schedule.DayOfSchedule; 14 import com.bsth.data.schedule.DayOfSchedule;
15 import com.bsth.data.schedule.auto_exec.AutoExecScanThread; 15 import com.bsth.data.schedule.auto_exec.AutoExecScanThread;
  16 +import com.bsth.data.schedule.e_state_check.thread.FixedCheckStationCodeThread;
16 import com.bsth.data.schedule.edit_logs.SeiPstThread; 17 import com.bsth.data.schedule.edit_logs.SeiPstThread;
17 import com.bsth.data.schedule.late_adjust.ScheduleLateThread; 18 import com.bsth.data.schedule.late_adjust.ScheduleLateThread;
18 import com.bsth.data.schedule.signal.SchSiginUpdateDBThread; 19 import com.bsth.data.schedule.signal.SchSiginUpdateDBThread;
@@ -82,6 +83,9 @@ public class XDApplication implements CommandLineRunner { @@ -82,6 +83,9 @@ public class XDApplication implements CommandLineRunner {
82 @Autowired 83 @Autowired
83 SafeDrivDataLoadThread safeDrivDataLoadThread; 84 SafeDrivDataLoadThread safeDrivDataLoadThread;
84 85
  86 + @Autowired
  87 + FixedCheckStationCodeThread fixedCheckStationCodeThread;
  88 +
85 private static long timeDiff; 89 private static long timeDiff;
86 private static long timeDiffTraffic; 90 private static long timeDiffTraffic;
87 91
@@ -128,8 +132,11 @@ public class XDApplication implements CommandLineRunner { @@ -128,8 +132,11 @@ public class XDApplication implements CommandLineRunner {
128 //sexec.scheduleWithFixedDelay(gpsDataLoader, 60, 4, TimeUnit.SECONDS); 132 //sexec.scheduleWithFixedDelay(gpsDataLoader, 60, 4, TimeUnit.SECONDS);
129 //实际排班更新线程 133 //实际排班更新线程
130 //sexec.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS); 134 //sexec.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS);
  135 + //sexec.scheduleWithFixedDelay(scheduleLateThread, 140, 30, TimeUnit.SECONDS);//检查班次误点
131 //sexec.scheduleWithFixedDelay(autoExecScanThread, 100, 50, TimeUnit.SECONDS);//班次自动执行 136 //sexec.scheduleWithFixedDelay(autoExecScanThread, 100, 50, TimeUnit.SECONDS);//班次自动执行
132 //WebSocketPushQueue.start();//消息队列 -webSocket ，推送至线调web页面的 137 //WebSocketPushQueue.start();//消息队列 -webSocket ，推送至线调web页面的
  138 +
  139 + //sexec.scheduleWithFixedDelay(fixedCheckStationCodeThread, 50, 60 * 5, TimeUnit.SECONDS);//检查班次站点编码
133 //实际排班延迟入库线程 140 //实际排班延迟入库线程
134 //sexec.scheduleWithFixedDelay(schedulePstThread, 60, 15, TimeUnit.SECONDS); 141 //sexec.scheduleWithFixedDelay(schedulePstThread, 60, 15, TimeUnit.SECONDS);
135 //班次修正日志延迟入库 142 //班次修正日志延迟入库
@@ -155,6 +162,7 @@ public class XDApplication implements CommandLineRunner { @@ -155,6 +162,7 @@ public class XDApplication implements CommandLineRunner {
155 sexec.scheduleWithFixedDelay(scheduleRefreshThread, 10, 120, TimeUnit.SECONDS);//班次更新线程 162 sexec.scheduleWithFixedDelay(scheduleRefreshThread, 10, 120, TimeUnit.SECONDS);//班次更新线程
156 sexec.scheduleWithFixedDelay(scheduleLateThread, 140, 30, TimeUnit.SECONDS);//检查班次误点 163 sexec.scheduleWithFixedDelay(scheduleLateThread, 140, 30, TimeUnit.SECONDS);//检查班次误点
157 sexec.scheduleWithFixedDelay(gpsDataLoader, 100, 2, TimeUnit.SECONDS);//抓取GPS数据 164 sexec.scheduleWithFixedDelay(gpsDataLoader, 100, 2, TimeUnit.SECONDS);//抓取GPS数据
  165 + sexec.scheduleWithFixedDelay(fixedCheckStationCodeThread, 60, 60 * 5, TimeUnit.SECONDS);//检查班次站点编码
158 166
159 sexec.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS);//GPS设备掉离线 167 sexec.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS);//GPS设备掉离线
160 sexec.scheduleWithFixedDelay(schedulePstThread, 180, 10, TimeUnit.SECONDS);//班次延迟入库线程 168 sexec.scheduleWithFixedDelay(schedulePstThread, 180, 10, TimeUnit.SECONDS);//班次延迟入库线程
@@ -162,7 +170,7 @@ public class XDApplication implements CommandLineRunner { @@ -162,7 +170,7 @@ public class XDApplication implements CommandLineRunner {
162 sexec.scheduleWithFixedDelay(directivesPstThread, 120, 60, TimeUnit.SECONDS);//调度指令延迟入库 170 sexec.scheduleWithFixedDelay(directivesPstThread, 120, 60, TimeUnit.SECONDS);//调度指令延迟入库
163 sexec.scheduleWithFixedDelay(threadMonotor, 240, 60, TimeUnit.SECONDS);//线程监听（防止重要的线程阻塞、异常结束。以及部分主备切换工作） 171 sexec.scheduleWithFixedDelay(threadMonotor, 240, 60, TimeUnit.SECONDS);//线程监听（防止重要的线程阻塞、异常结束。以及部分主备切换工作）
164 sexec.scheduleWithFixedDelay(sampleTimeDataLoader, 140, 120 * 60, TimeUnit.SECONDS);//到离站预测需要的站点间耗时数据 172 sexec.scheduleWithFixedDelay(sampleTimeDataLoader, 140, 120 * 60, TimeUnit.SECONDS);//到离站预测需要的站点间耗时数据
165 - sexec.scheduleWithFixedDelay(basicDataLoader, 2, 2, TimeUnit.HOURS);//基础数据更新 173 + sexec.scheduleWithFixedDelay(basicDataLoader, 1, 1, TimeUnit.HOURS);//基础数据更新
166 sexec.scheduleWithFixedDelay(autoExecScanThread, 180, 50, TimeUnit.SECONDS);//班次自动执行 174 sexec.scheduleWithFixedDelay(autoExecScanThread, 180, 50, TimeUnit.SECONDS);//班次自动执行
167 DirectivePushQueue.start();//消息队列 -指令，系统下发的 175 DirectivePushQueue.start();//消息队列 -指令，系统下发的
168 WebSocketPushQueue.start();//消息队列 -webSocket ，推送至线调web页面的 176 WebSocketPushQueue.start();//消息队列 -webSocket ，推送至线调web页面的