diff --git a/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java b/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java index c1800d5d..c0f52855 100644 --- a/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java +++ b/detection/src/main/java/com/njcn/gather/detection/handler/SocketDevResponseService.java @@ -1026,6 +1026,8 @@ public class SocketDevResponseService { webSocketVO.setCode(SourceResponseCodeEnum.PHASE_CHECK_FAIL.getCode()); webSocketVO.setData(SourceResponseCodeEnum.PHASE_CHECK_FAIL.getMessage()); WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(webSocketVO)); + + CnSocketUtil.quitSend(param); return; } diff --git a/detection/src/main/java/com/njcn/gather/detection/util/socket/cilent/NettyDevClientHandler.java b/detection/src/main/java/com/njcn/gather/detection/util/socket/cilent/NettyDevClientHandler.java index 046b79b5..c5c90755 100644 --- a/detection/src/main/java/com/njcn/gather/detection/util/socket/cilent/NettyDevClientHandler.java +++ b/detection/src/main/java/com/njcn/gather/detection/util/socket/cilent/NettyDevClientHandler.java @@ -146,6 +146,7 @@ public class NettyDevClientHandler extends SimpleChannelInboundHandler { fly = true; //为空则认为是常规步骤,设定一分钟超时 CnSocketUtil.quitSend(param); + CnSocketUtil.sendToWebSocket(param.getUserPageId(), SourceOperateCodeEnum.SOCKET_TIMEOUT.getValue(), SourceOperateCodeEnum.SOCKET_TIMEOUT.getValue(), SourceOperateCodeEnum.SOCKET_TIMEOUT.getMsg(), null); } if (fly) { socketResponseService.backCheckState(param);