[add] 海信灯态优化

signal-utc-hisense-service/src/main/java/net/wanji/utc/hisense/cache/SignalDataCache.java

@@ -24,6 +24,7 @@ public class SignalDataCache {
     // 海信推送灯态数据
     public static final Map<String, RunningLightsStatusPojo> runningStateInfoCacheUdp = new HashMap<>();
     public static final Map<String, LightsStatusVO> runningStateInfoCache = new ConcurrentHashMap<>();
+    // 海信推送方案相位信息，未计算灯态缓存
     public static final Map<String, LightsStatusVO> runningStateInfoCacheNoLamp = new ConcurrentHashMap<>();
     public static final Map<String, Long> runningStatusStampMap = new HashMap<>();
 }

signal-utc-hisense-service/src/main/java/net/wanji/utc/hisense/task/HisensePhaseCountDownTask.java

@@ -15,6 +15,7 @@ import net.wanji.utc.hisense.cache.SignalDataCache;
 import net.wanji.utc.hisense.pojo.CrossPhaseDirTurnPojo;
 import net.wanji.utc.hisense.pojo.dto.CrossSchemePhaseCountDownDTO;
 import net.wanji.utc.hisense.pojo.dto.PhaseCountDownDTO;
+import org.apache.commons.lang3.time.DateUtils;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 import org.springframework.util.CollectionUtils;
@@ -50,8 +51,10 @@ public class HisensePhaseCountDownTask {
 
                     // 通过时段表，切换方案 凌晨00：00 如果切换下一个日期方案，可能RefreshCacheTask还没执行
                     String nextSectionSchemeNo = CrossRunSchemeCache.currentRunSchemeNoCache.get(crossId);
-                    String currentTime = String.valueOf(new Date().getTime());
-                    if (StringUtils.equalsIgnoreCase(schemeStartTime, currentTime)) {
+                    Date currentDate = new Date();
+                    String currentTime = String.valueOf(currentDate.getTime());
+                    Date date2HoursAgo = DateUtils.addHours(currentDate, -1);
+                    if (StringUtils.equalsIgnoreCase(schemeStartTime, currentTime) || Long.parseLong(schemeStartTime) < date2HoursAgo.getTime()) {
                         crossSchemePO = crossSchemeMapper.selectByCrossIdAndSchemeNo(crossId, Integer.valueOf(nextSectionSchemeNo));
                         executeNextSectionScheme(crossId, lightsStatusVO, crossSchemePO);
                         lightsStatusVO.setCycleLen(crossSchemePO.getCycle());
@@ -61,6 +64,18 @@ public class HisensePhaseCountDownTask {
                     // 当前方案下一周期
                     setDirLampGroupMap(lightsStatusVO);
                     if (Objects.nonNull(lightsStatusVO.getDirLampGroupMap())) {
+                        if (Objects.equals(crossId, "13NI00B5RM0")) {
+                            List<String> dirList = Arrays.asList("1", "3", "7");
+                            Map<String, Object> dirLampGroupMap = lightsStatusVO.getDirLampGroupMap();
+                            for (String dir : dirList) {
+                                if (!dirLampGroupMap.containsKey(dir)) {
+                                    Map<String, String> value = new HashMap<>();
+                                    setAllTurnColorRed(value, null, null);
+                                    dirLampGroupMap.put(dir, value);
+                                }
+                            }
+                            lightsStatusVO.setDirLampGroupMap(dirLampGroupMap);
+                        }
                         SignalDataCache.runningStateInfoCache.put(crossId, lightsStatusVO);
                     }
                 }
@@ -213,6 +228,7 @@ public class HisensePhaseCountDownTask {
 
     /**
      * 两秒倒计时，全场红
+     *
      * @param turnColor
      * @param type
      * @param color
@@ -231,6 +247,7 @@ public class HisensePhaseCountDownTask {
 
     /**
      * 设置所有转向灯色
+     *
      * @param turnColor
      * @param type
      * @param color