2024-06-14

src/main/java/com/spring/modules/cdc/task/GatherDataTask.java

@@ -101,6 +101,7 @@ public class GatherDataTask {
                         collectRecordService.insertCollectRecord(collectRecord);
                         collectRecordService.updateCollectCurrentValue(collectRecord);
                     }
+                    siemensS7Net.ConnectClose();
                 }else {
                     log.info("IP:{} 连接失败",ip);
                     for (Device device : deviceList) {
@@ -126,6 +127,7 @@ public class GatherDataTask {
                         collectRecordService.insertCollectRecord(collectRecord);
                         collectRecordService.updateCollectCurrentValue(collectRecord);
                     }
+                    melsecMcNet.ConnectClose();
                 }else {
                     log.info("IP:{} 连接失败",ip);
                     for (Device device : deviceList) {