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());