Commit 5b982efe authored by duanruiming's avatar duanruiming

[update] 测试websocket连接断开

parent 6be106a5
...@@ -123,6 +123,7 @@ public class HkLightsStatusServiceImpl implements HkLightsStatusService { ...@@ -123,6 +123,7 @@ public class HkLightsStatusServiceImpl implements HkLightsStatusService {
} }
infoVo.setRunMode(WJControlType);// 控制模式 infoVo.setRunMode(WJControlType);// 控制模式
infoVo.setPhasePlanId(String.valueOf(patternNo)); // 相位方案号 infoVo.setPhasePlanId(String.valueOf(patternNo)); // 相位方案号
infoVo.setSchemeId(String.valueOf(patternNo));
int cycleLen = resultPO.getCycle(); // 周期时长 int cycleLen = resultPO.getCycle(); // 周期时长
int curRunTime = resultPO.getCurRunTime(); // 当前运行时长 int curRunTime = resultPO.getCurRunTime(); // 当前运行时长
int cycleCountDown = cycleLen - curRunTime; // 周期剩余时长 int cycleCountDown = cycleLen - curRunTime; // 周期剩余时长
......
...@@ -119,7 +119,7 @@ public class SignalStatusTask { ...@@ -119,7 +119,7 @@ public class SignalStatusTask {
} }
Constants.controlModeMap.put(crossId, lightsStatusVO.getRunMode()); Constants.controlModeMap.put(crossId, lightsStatusVO.getRunMode());
try { try {
log.error("{}路口倒计时:{}", lightsStatusVOS.get(0).getCycleCountDown()); log.error("{}路口倒计时:{}", crossId, lightsStatusVOS.get(0).getCycleCountDown());
webSocket.sendInfo(JSONObject.toJSONString(lightsStatusVOS, SerializerFeature.WriteMapNullValue), crossIdStr); webSocket.sendInfo(JSONObject.toJSONString(lightsStatusVOS, SerializerFeature.WriteMapNullValue), crossIdStr);
} catch (Exception e) { } catch (Exception e) {
log.error("RealTimeDataWebSocket发送异常,异常信息:", e); log.error("RealTimeDataWebSocket发送异常,异常信息:", e);
......
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