Commit 93adae10 authored by zhoushiguang's avatar zhoushiguang

Merge remote-tracking branch 'origin/master'

parents 1946b6d7 0daa0f65
...@@ -29,7 +29,7 @@ import java.util.stream.Collectors; ...@@ -29,7 +29,7 @@ import java.util.stream.Collectors;
* @description 从信号机方案模拟信号机灯态 * @description 从信号机方案模拟信号机灯态
* @date 2023/12/01 10:28 * @date 2023/12/01 10:28
*/ */
@Component //@Component
@Slf4j @Slf4j
@SuppressWarnings("unused") @SuppressWarnings("unused")
public class SignalStatus4StaticSchemeTask { public class SignalStatus4StaticSchemeTask {
...@@ -48,7 +48,7 @@ public class SignalStatus4StaticSchemeTask { ...@@ -48,7 +48,7 @@ public class SignalStatus4StaticSchemeTask {
@Resource @Resource
private CrossLightsMapper crossLightsMapper; private CrossLightsMapper crossLightsMapper;
@Scheduled(fixedRate = 1000) //@Scheduled(fixedRate = 1000)
public void signalStatusCountDown() throws Exception { public void signalStatusCountDown() throws Exception {
try { try {
if (!currentCrossLightStatusCache.isEmpty()) { if (!currentCrossLightStatusCache.isEmpty()) {
......
...@@ -138,10 +138,12 @@ public class SignalStatusTask { ...@@ -138,10 +138,12 @@ public class SignalStatusTask {
if (Objects.nonNull(lightsStatusVO)) { if (Objects.nonNull(lightsStatusVO)) {
machineTimestamp = lightsStatusVO.getTimeStamp(); machineTimestamp = lightsStatusVO.getTimeStamp();
long offsetTime = start - Long.valueOf(machineTimestamp); long offsetTime = start - Long.valueOf(machineTimestamp);
if (offsetTime < 1000 * 10) { if (offsetTime < 1000 * 12) {
status = 1; status = 1;
} }
runMode = lightsStatusVO.getRunMode(); runMode = lightsStatusVO.getRunMode();
log.error("当前路口:{},当前信号机状态时间差:{}, 当前控制模式:{}, 当前在线离线状态:{}",
crossId, offsetTime, runMode, status);
} }
} }
} }
......
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