From 9fcf4e39a4c638d760fbda298eec42f18ba9d644 Mon Sep 17 00:00:00 2001 From: caozehui <2427765068@qq.com> Date: Sat, 8 Mar 2025 17:45:02 +0800 Subject: [PATCH] =?UTF-8?q?=E5=BE=AE=E8=B0=83?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../service/impl/PreDetectionServiceImpl.java | 16 ++++++++-------- 1 file changed, 8 insertions(+), 8 deletions(-) diff --git a/detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java b/detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java index 8af457f7..0f97f6c6 100644 --- a/detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java +++ b/detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java @@ -246,14 +246,14 @@ public class PreDetectionServiceImpl implements PreDetectionService { @Override public void sendScript(SimulateDetectionParam param) { Channel channel = SocketManager.getChannelByUserId(param.getUserPageId() + source); -// if (Objects.isNull(channel) || !channel.isActive()) { -// // 进行源通信连接 -// PreDetectionParam preDetectionParam = new PreDetectionParam(); -// preDetectionParam.setSourceId(param.getSourceId()); -// preDetectionParam.setUserPageId(param.getUserPageId()); -// preDetectionParam.setSendWebMsg(false); -// this.sendYtxSocketSimulate(preDetectionParam); -// } + if (Objects.isNull(channel) || !channel.isActive()) { + // 进行源通信连接 + PreDetectionParam preDetectionParam = new PreDetectionParam(); + preDetectionParam.setSourceId(param.getSourceId()); + preDetectionParam.setUserPageId(param.getUserPageId()); + preDetectionParam.setSendWebMsg(false); + this.sendYtxSocketSimulate(preDetectionParam); + } //组装源控制脚本 PqScriptIssueParam issueParam = new PqScriptIssueParam(); //issueParam.setPlanId(param.getPlanId());