From c8b38c0d614a5fbc308ec740a9c6914668230e9e Mon Sep 17 00:00:00 2001
From: huangfeng <huangfeng@xinyingpower.com>
Date: Thu, 31 Oct 2024 15:03:44 +0800
Subject: [PATCH] =?UTF-8?q?fix:=20=E8=B0=83=E6=95=B4=E5=81=9C=E6=AD=A2?=
 =?UTF-8?q?=E9=87=87=E9=9B=86?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 src/main/java/com/xydl/cac/iec/RealTimeDataService.java | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/src/main/java/com/xydl/cac/iec/RealTimeDataService.java b/src/main/java/com/xydl/cac/iec/RealTimeDataService.java
index 31b4898..54a5715 100644
--- a/src/main/java/com/xydl/cac/iec/RealTimeDataService.java
+++ b/src/main/java/com/xydl/cac/iec/RealTimeDataService.java
@@ -83,6 +83,9 @@ public class RealTimeDataService {
     public void stopCollect(Integer iedId) {
         IecClient iecClient = clientMap.get(iedId);
         if (iecClient != null) {
+            iecClient.keep = false;
+            iecClient.realTimeDataService = null;
+            iecClient.webSocketServer = null;
             iecClient.disableReporting();
             iecClient.disconnect();
             clientMap.remove(iedId);
@@ -92,7 +95,7 @@ public class RealTimeDataService {
             IcdIed ied = optional.get();
             ied.setStart(Constants.FALSE);
             iedRepository.save(ied);
-            log.info("61850停止订阅, ied=" + ied.getName() + ", ip=" + ied.getIp());
+            log.info("61850停止订阅, ied=" + ied.getName() + ", ip=" + ied.getIp() + ", port=" + ied.getPort());
         }
     }