预检测在相序校验不合格时没有关闭源bug

This commit is contained in:
caozehui
2025-05-12 14:36:27 +08:00
parent 40b0e535cb
commit e235c3ef66
2 changed files with 3 additions and 0 deletions

View File

@@ -1026,6 +1026,8 @@ public class SocketDevResponseService {
webSocketVO.setCode(SourceResponseCodeEnum.PHASE_CHECK_FAIL.getCode()); webSocketVO.setCode(SourceResponseCodeEnum.PHASE_CHECK_FAIL.getCode());
webSocketVO.setData(SourceResponseCodeEnum.PHASE_CHECK_FAIL.getMessage()); webSocketVO.setData(SourceResponseCodeEnum.PHASE_CHECK_FAIL.getMessage());
WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(webSocketVO)); WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(webSocketVO));
CnSocketUtil.quitSend(param);
return; return;
} }

View File

@@ -146,6 +146,7 @@ public class NettyDevClientHandler extends SimpleChannelInboundHandler<String> {
fly = true; fly = true;
//为空则认为是常规步骤,设定一分钟超时 //为空则认为是常规步骤,设定一分钟超时
CnSocketUtil.quitSend(param); CnSocketUtil.quitSend(param);
CnSocketUtil.sendToWebSocket(param.getUserPageId(), SourceOperateCodeEnum.SOCKET_TIMEOUT.getValue(), SourceOperateCodeEnum.SOCKET_TIMEOUT.getValue(), SourceOperateCodeEnum.SOCKET_TIMEOUT.getMsg(), null);
} }
if (fly) { if (fly) {
socketResponseService.backCheckState(param); socketResponseService.backCheckState(param);