[update] 下发刷新缓存

signal-control-service/src/main/java/net/wanji/web/service/impl/PlanSendServiceImpl.java

@@ -815,7 +815,7 @@ public class PlanSendServiceImpl implements PlanSendService {
             return jsonViewObject.fail("下发信号机参数UTC服务调用异常");
         }
         //return JsonViewObject.newInstance().success();
-        return jsonViewObject.success("下发信号机参数成功");
+        return jsonViewObject.success("下发信号机数据到utc数据库成功，并刷新缓存");
     }
 
     private SaveToUtcPO buildSaveToUtcPO(String crossId) throws Exception {

signal-utc-service/src/main/java/net/wanji/utc/service/control/impl/ControlCommandStrategyServiceImpl.java

@@ -10,6 +10,8 @@ import net.wanji.databus.po.CrossInfoPO;
 import net.wanji.databus.po.SaveToUtcPO;
 import net.wanji.databus.vo.*;
 import net.wanji.utc.cache.CrossInfoCache;
+import net.wanji.utc.cache.CrossPhaseDirTurnCache;
+import net.wanji.utc.cache.CrossSchemePhaseTimeCountCache;
 import net.wanji.utc.common.typeenum.BasicEnum;
 import net.wanji.utc.common.typeenum.DateStyle;
 import net.wanji.utc.po.hk.request.DelBaseConfigPO;
@@ -52,6 +54,8 @@ public class ControlCommandStrategyServiceImpl implements ControlCommandStrategy
     private final CrossInfoCache crossInfoCache;
     private final CrossLightsMapper crossLightsMapper;
     private final CrossPhaseLightsMapper crossPhaseLightsMapper;
+    private final CrossPhaseDirTurnCache crossPhaseDirTurnCache;
+    private final CrossSchemePhaseTimeCountCache crossSchemePhaseTimeCountCache;
 
 
     @Override
@@ -420,6 +424,8 @@ public class ControlCommandStrategyServiceImpl implements ControlCommandStrategy
             log.error("下发数据到utc数据库失败：", e);
             throw new Exception(e);
         }
-        return JsonViewObject.newInstance().success("数据下发到Utc数据库成功");
+        crossPhaseDirTurnCache.run();
+        crossSchemePhaseTimeCountCache.run();
+        return JsonViewObject.newInstance().success("数据下发到Utc数据库成功，并刷新缓存");
     }
 }