微调

detection/src/main/java/com/njcn/gather/detection/handler/SocketSourceResponseService.java

@@ -100,7 +100,9 @@ public class SocketSourceResponseService {
         if (ObjectUtil.isNotNull(dictDataEnumByCode)) {
             switch (dictDataEnumByCode) {
                 case SUCCESS:
+                    if(param.getSendWebMsg()){
                         WebServiceManager.sendMsg(param.getUserPageId(), JSON.toJSONString(socketDataMsg));
+                    }
                     System.out.println("模拟检测-源初始化成功");
                     break;
                 case UNPROCESSED_BUSINESS:

detection/src/main/java/com/njcn/gather/detection/pojo/param/PreDetectionParam.java

@@ -62,4 +62,5 @@ public class PreDetectionParam {
      */
     private String code;
 
+    private Boolean sendWebMsg;
 }

detection/src/main/java/com/njcn/gather/detection/service/impl/PreDetectionServiceImpl.java

@@ -224,6 +224,7 @@ public class PreDetectionServiceImpl implements PreDetectionService {
         PreDetectionParam preDetectionParam = new PreDetectionParam();
         preDetectionParam.setSourceId(param.getSourceId());
         preDetectionParam.setUserPageId(param.getUserPageId());
+        preDetectionParam.setSendWebMsg(true);
 
         specialDealSimulate(preDetectionParam);
 
@@ -250,6 +251,7 @@ public class PreDetectionServiceImpl implements PreDetectionService {
             PreDetectionParam preDetectionParam = new PreDetectionParam();
             preDetectionParam.setSourceId(param.getSourceId());
             preDetectionParam.setUserPageId(param.getUserPageId());
+            preDetectionParam.setSendWebMsg(false);
             this.sendYtxSocketSimulate(preDetectionParam);
         }
         //组装源控制脚本