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