Commit c5eaaa4e authored by duanruiming's avatar duanruiming

[update] 周期倒计时优化

parent 9e5213a0
...@@ -73,13 +73,14 @@ public class SignalStatusTask { ...@@ -73,13 +73,14 @@ public class SignalStatusTask {
if (Objects.equals(lightsStatusVO.getCrossId(), crossIdStr.split(",")[0])) { if (Objects.equals(lightsStatusVO.getCrossId(), crossIdStr.split(",")[0])) {
Integer coutTime = 0; Integer coutTime = 0;
if (Arrays.asList(2, 3, 4, 9).contains(Integer.valueOf(lightsStatusVO.getRunMode()))) { if (Arrays.asList(2, 3, 4, 9).contains(Integer.valueOf(lightsStatusVO.getRunMode()))) {
if (runModeTimeMap.isEmpty() || Objects.isNull(runModeTimeMap.get(crossId))) { if (runModeTimeMap.isEmpty() || Objects.isNull(runModeTimeMap.get(crossIdStr))) {
runModeTimeMap.put(crossIdStr, coutTime); runModeTimeMap.put(crossIdStr, coutTime);
} else { } else {
Integer countTimeCahce = runModeTimeMap.get(crossId); Integer countTimeCahce = runModeTimeMap.get(crossIdStr);
runModeTimeMap.put(crossIdStr, ++countTimeCahce); runModeTimeMap.put(crossIdStr, ++countTimeCahce);
} }
lightsStatusVO.setCycleCountDown(runModeTimeMap.get(crossIdStr)); lightsStatusVO.setCycleCountDown(runModeTimeMap.get(crossIdStr));
log.info("路口编号:{},控制剩余时长:{}", crossIdStr, runModeTimeMap.get(crossIdStr));
} else if (StringUtils.equals(lightsStatusVO.getRunMode(), "11")){ } else if (StringUtils.equals(lightsStatusVO.getRunMode(), "11")){
runModeTimeMap.remove(crossIdStr); runModeTimeMap.remove(crossIdStr);
} }
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment