Commit f11b9761cb1d0b41816a2442ad38895d94c41b7d
1 parent
9ef1749d
update
Showing
3 changed files
with
6 additions
and
6 deletions
src/main/java/com/bsth/data/arrival/ArrivalData_GPS.java
| @@ -51,7 +51,7 @@ public class ArrivalData_GPS implements CommandLineRunner{ | @@ -51,7 +51,7 @@ public class ArrivalData_GPS implements CommandLineRunner{ | ||
| 51 | @Override | 51 | @Override |
| 52 | public void run(String... arg0) throws Exception { | 52 | public void run(String... arg0) throws Exception { |
| 53 | logger.info("ArrivalData_GPS,100,10 @11-10"); | 53 | logger.info("ArrivalData_GPS,100,10 @11-10"); |
| 54 | - Application.mainServices.scheduleWithFixedDelay(dataLoaderThread, 100, 10, TimeUnit.SECONDS); | 54 | + //Application.mainServices.scheduleWithFixedDelay(dataLoaderThread, 100, 10, TimeUnit.SECONDS); |
| 55 | } | 55 | } |
| 56 | 56 | ||
| 57 | @Component | 57 | @Component |
src/main/java/com/bsth/data/gpsdata/GpsRealData.java
| @@ -68,7 +68,7 @@ public class GpsRealData implements CommandLineRunner{ | @@ -68,7 +68,7 @@ public class GpsRealData implements CommandLineRunner{ | ||
| 68 | @Override | 68 | @Override |
| 69 | public void run(String... arg0) throws Exception { | 69 | public void run(String... arg0) throws Exception { |
| 70 | logger.info("gpsDataLoader,20,6"); | 70 | logger.info("gpsDataLoader,20,6"); |
| 71 | - Application.mainServices.scheduleWithFixedDelay(gpsDataLoader, 20, 6, TimeUnit.SECONDS); | 71 | + //Application.mainServices.scheduleWithFixedDelay(gpsDataLoader, 20, 6, TimeUnit.SECONDS); |
| 72 | } | 72 | } |
| 73 | 73 | ||
| 74 | public GpsEntity add(GpsEntity gps) { | 74 | public GpsEntity add(GpsEntity gps) { |
src/main/java/com/bsth/data/schedule/DayOfSchedule.java
| @@ -130,11 +130,11 @@ public class DayOfSchedule implements CommandLineRunner { | @@ -130,11 +130,11 @@ public class DayOfSchedule implements CommandLineRunner { | ||
| 130 | //翻班线程 | 130 | //翻班线程 |
| 131 | Application.mainServices.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS); | 131 | Application.mainServices.scheduleWithFixedDelay(scheduleRefreshThread, 15, 240, TimeUnit.SECONDS); |
| 132 | //入库 | 132 | //入库 |
| 133 | - Application.mainServices.scheduleWithFixedDelay(schedulePstThread, 60, 60, TimeUnit.SECONDS); | 133 | + //Application.mainServices.scheduleWithFixedDelay(schedulePstThread, 60, 60, TimeUnit.SECONDS); |
| 134 | //首班出场指令补发器 | 134 | //首班出场指令补发器 |
| 135 | - Application.mainServices.scheduleWithFixedDelay(firstScheduleCheckThread, 30, 240, TimeUnit.SECONDS); | 135 | + //Application.mainServices.scheduleWithFixedDelay(firstScheduleCheckThread, 30, 240, TimeUnit.SECONDS); |
| 136 | //班次误点扫描 | 136 | //班次误点扫描 |
| 137 | - Application.mainServices.scheduleWithFixedDelay(scheduleLateThread, 60, 60, TimeUnit.SECONDS); | 137 | + //Application.mainServices.scheduleWithFixedDelay(scheduleLateThread, 60, 60, TimeUnit.SECONDS); |
| 138 | 138 | ||
| 139 | //每天凌晨2点20提交数据到运管处 | 139 | //每天凌晨2点20提交数据到运管处 |
| 140 | long diff = (DateUtils.getTimestamp() + 1000*60*140) - System.currentTimeMillis(); | 140 | long diff = (DateUtils.getTimestamp() + 1000*60*140) - System.currentTimeMillis(); |
| @@ -142,7 +142,7 @@ public class DayOfSchedule implements CommandLineRunner { | @@ -142,7 +142,7 @@ public class DayOfSchedule implements CommandLineRunner { | ||
| 142 | diff+=(1000*60*60*24); | 142 | diff+=(1000*60*60*24); |
| 143 | 143 | ||
| 144 | logger.info(diff/1000/60 + "分钟之后提交到运管处"); | 144 | logger.info(diff/1000/60 + "分钟之后提交到运管处"); |
| 145 | - Application.mainServices.scheduleWithFixedDelay(submitToTrafficManage, diff / 1000, 60 * 60 * 24, TimeUnit.SECONDS); | 145 | + //Application.mainServices.scheduleWithFixedDelay(submitToTrafficManage, diff / 1000, 60 * 60 * 24, TimeUnit.SECONDS); |
| 146 | } | 146 | } |
| 147 | 147 | ||
| 148 | public Map<String, String> getCurrSchDate() { | 148 | public Map<String, String> getCurrSchDate() { |