feat: 增加订阅brcb

dev
huangfeng 8 months ago
parent 07e861c3ea
commit 5ecb8193ee

@ -67,6 +67,11 @@ public class IecClient implements ClientEventListener {
clientAssociation.enableReporting(urcb); clientAssociation.enableReporting(urcb);
} }
} }
if (!CollectionUtils.isEmpty(serverModel.getBrcbs())) {
for (Brcb brcb : serverModel.getBrcbs()) {
clientAssociation.enableReporting(brcb);
}
}
} }
public void disableReporting() { public void disableReporting() {
@ -78,6 +83,14 @@ public class IecClient implements ClientEventListener {
} catch (Exception ignore) { } catch (Exception ignore) {
} }
} }
if (!CollectionUtils.isEmpty(serverModel.getBrcbs())) {
try {
for (Brcb brcb : serverModel.getBrcbs()) {
clientAssociation.disableReporting(brcb);
}
} catch (Exception ignore) {
}
}
} }
@Override @Override

@ -24,10 +24,11 @@ public class IecServerService {
@Resource @Resource
IcdTransformService transformService; IcdTransformService transformService;
IecServer iecServer = new IecServer(transformService); IecServer iecServer = null;
@PostConstruct @PostConstruct
private void init() { private void init() {
iecServer = new IecServer(transformService);
List<IcdFile> list = fileRepository.findBySrvAndStart(Constants.Server, Constants.TRUE); List<IcdFile> list = fileRepository.findBySrvAndStart(Constants.Server, Constants.TRUE);
if (!CollectionUtils.isEmpty(list)) { if (!CollectionUtils.isEmpty(list)) {
IcdFile icdFile = list.get(0); IcdFile icdFile = list.get(0);

Loading…
Cancel
Save