Commit dd60bb258367fa30eb6137dde9701947839eb998
1 parent
1010b250
update...
Showing
1 changed file
with
3 additions
and
15 deletions
src/main/java/com/bsth/data/gpsdata/GpsRealData.java
| 1 | 1 | package com.bsth.data.gpsdata; |
| 2 | 2 | |
| 3 | -import com.bsth.Application; | |
| 4 | 3 | import com.bsth.data.BasicData; |
| 5 | 4 | import com.bsth.data.forecast.ForecastRealServer; |
| 6 | -import com.bsth.data.gpsdata.client.ClientApp; | |
| 7 | -import com.bsth.data.gpsdata.client.GpsBeforeBuffer; | |
| 8 | 5 | import com.bsth.data.gpsdata.thread.GpsDataLoaderThread; |
| 9 | 6 | import com.bsth.data.gpsdata.thread.OfflineMonitorThread; |
| 10 | 7 | import com.bsth.data.schedule.DayOfSchedule; |
| ... | ... | @@ -20,7 +17,6 @@ import org.springframework.stereotype.Component; |
| 20 | 17 | import java.util.*; |
| 21 | 18 | import java.util.concurrent.ConcurrentHashMap; |
| 22 | 19 | import java.util.concurrent.ConcurrentMap; |
| 23 | -import java.util.concurrent.TimeUnit; | |
| 24 | 20 | |
| 25 | 21 | /** |
| 26 | 22 | * @author PanZhao |
| ... | ... | @@ -58,21 +54,13 @@ public class GpsRealData implements CommandLineRunner { |
| 58 | 54 | lineCode2Devices = TreeMultimap.create(); |
| 59 | 55 | } |
| 60 | 56 | |
| 61 | - @Autowired | |
| 62 | - ClientApp clientApp; | |
| 63 | - @Autowired | |
| 64 | - GpsBeforeBuffer gpsBeforeBuffer; | |
| 65 | 57 | @Override |
| 66 | 58 | public void run(String... arg0) throws Exception { |
| 67 | 59 | logger.info("gpsDataLoader,20,3"); |
| 68 | - //定时从网关http形式获取GPS数据 --- 已弃用,现socket客户端接入数据 | |
| 69 | - //Application.mainServices.scheduleWithFixedDelay(gpsDataLoader, 20, 3, TimeUnit.SECONDS); | |
| 60 | + //http形式获取GPS数据 | |
| 61 | + //Application.mainServices.scheduleWithFixedDelay(gpsDataLoader, 20, 2, TimeUnit.SECONDS); | |
| 70 | 62 | //定时扫描掉离线 |
| 71 | - Application.mainServices.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS); | |
| 72 | - | |
| 73 | - //gps 客户端 | |
| 74 | - //clientApp.init(); | |
| 75 | - //gpsBeforeBuffer.init(); | |
| 63 | + //Application.mainServices.scheduleWithFixedDelay(offlineMonitorThread, 120, 60, TimeUnit.SECONDS); | |
| 76 | 64 | } |
| 77 | 65 | |
| 78 | 66 | ... | ... |