[update] 缓存参数刷新

wj-datacenter-service/src/main/java/net/wanji/datacenter/task/DataCenterTask.java

@@ -6,9 +6,7 @@ import net.wanji.databus.dao.entity.CrossSectionPO;
 import net.wanji.databus.dao.entity.GreenwaveCrossPO;
 import net.wanji.databus.dao.mapper.BaseCrossSchemeMapper;
 import net.wanji.databus.dao.mapper.BaseCrossSectionMapper;
-import net.wanji.datacenter.cache.CrossGreenWaveInfoCache;
-import net.wanji.datacenter.cache.CrossSchemePhaseLightsCache;
-import net.wanji.datacenter.cache.WeekDirFreeFlowSpeedCache;
+import net.wanji.datacenter.cache.*;
 import net.wanji.datacenter.pojo.dto.CrossSchemePhaseDirTurnDTO;
 import org.apache.commons.lang3.StringUtils;
 import org.springframework.scheduling.annotation.Scheduled;
@@ -32,6 +30,12 @@ public class DataCenterTask {
 
     @Resource
     private WeekDirFreeFlowSpeedCache weekDirFreeFlowSpeedCache;
+    @Resource
+    private WeekTurnFreeFlowSpeedCache weekTurnFreeFlowSpeedCache;
+    @Resource
+    private CrossDirWeekAvgFlowCache crossDirWeekAvgFlowCache;
+    @Resource
+    private CrossDirWeekMaxFlowCache crossDirWeekMaxFlowCache;
 
     @Resource
     private BaseCrossSectionMapper baseCrossSectionMapper;
@@ -41,6 +45,9 @@ public class DataCenterTask {
     @Scheduled(cron = "0 0 0 * * ?")
     public void getWeekFreeFlowSpeed() throws Exception {
         weekDirFreeFlowSpeedCache.run();
+        weekTurnFreeFlowSpeedCache.run();
+        crossDirWeekAvgFlowCache.run();
+        crossDirWeekMaxFlowCache.run();
     }
 
     @Scheduled(initialDelay = 1000 * 60, fixedRate = 1000 * 60 * 60)