From e235c3ef667f70ede789000b4e7da289a926288e Mon Sep 17 00:00:00 2001
From: caozehui <2427765068@qq.com>
Date: Mon, 12 May 2025 14:36:27 +0800
Subject: [PATCH] =?UTF-8?q?=E9=A2=84=E6=A3=80=E6=B5=8B=E5=9C=A8=E7=9B=B8?=
 =?UTF-8?q?=E5=BA=8F=E6=A0=A1=E9=AA=8C=E4=B8=8D=E5=90=88=E6=A0=BC=E6=97=B6?=
 =?UTF-8?q?=E6=B2=A1=E6=9C=89=E5=85=B3=E9=97=AD=E6=BA=90bug?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../njcn/gather/detection/handler/SocketDevResponseService.java | 2 ++
 .../detection/util/socket/cilent/NettyDevClientHandler.java     | 1 +
 2 files changed, 3 insertions(+)

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<String> {
                         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);