From 2339a006ecc4304ebda82331a435d05825b41468 Mon Sep 17 00:00:00 2001 From: caozehui <2427765068@qq.com> Date: Thu, 6 Nov 2025 08:51:54 +0800 Subject: [PATCH] =?UTF-8?q?=E8=A1=A5=E5=85=85=E6=BA=90=E6=9C=AA=E7=9F=A5?= =?UTF-8?q?=E5=BC=82=E5=B8=B8=E6=8E=A8=E9=80=81=E6=B6=88=E6=81=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../handler/SocketSourceResponseService.java | 12 ++++++++++++ 1 file changed, 12 insertions(+) diff --git a/detection/src/main/java/com/njcn/gather/detection/handler/SocketSourceResponseService.java b/detection/src/main/java/com/njcn/gather/detection/handler/SocketSourceResponseService.java index 973fa775..be88a1aa 100644 --- a/detection/src/main/java/com/njcn/gather/detection/handler/SocketSourceResponseService.java +++ b/detection/src/main/java/com/njcn/gather/detection/handler/SocketSourceResponseService.java @@ -209,6 +209,10 @@ public class SocketSourceResponseService { case UNPROCESSED_BUSINESS: WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg)); break; + case UNKNOWN_ERROR: + CnSocketUtil.quitSendSource(param); + WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg)); + break; default: CnSocketUtil.quitSendSource(param); socketMsg.setRequestId(socketDataMsg.getRequestId()); @@ -327,6 +331,10 @@ public class SocketSourceResponseService { case MESSAGE_PARSING_ERROR: CnSocketUtil.quitSendSource(param); break; + case UNKNOWN_ERROR: + CnSocketUtil.quitSendSource(param); + WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg)); + break; default: CnSocketUtil.quitSendSource(param); socketMsg.setRequestId(socketDataMsg.getRequestId()); @@ -407,6 +415,10 @@ public class SocketSourceResponseService { case UNPROCESSED_BUSINESS: WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg)); break; + case UNKNOWN_ERROR: + CnSocketUtil.quitSendSource(param); + WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg)); + break; default: CnSocketUtil.quitSendSource(param); socketMsg.setRequestId(socketDataMsg.getRequestId());