Thirdparty
/
wvp-GB28181-pro
mirror of https://github.com/648540858/wvp-GB28181-pro
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

[集群] 修复catalog 递归循环BUG

dev/数据库统合
648540858 2025-01-03 17:34:30 +08:00
parent 85427497bf
commit a2e7cd0323
1 changed files with 4 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/main/java/com/genersoft/iot/vmp/gb28181/event/EventPublisher.java
View File

@ -76,6 +76,9 @@ public class EventPublisher {
} }
public void catalogEventPublish(Platform platform, List<CommonGBChannel> deviceChannels, String type) { public void catalogEventPublish(Platform platform, List<CommonGBChannel> deviceChannels, String type) {
catalogEventPublish(platform, deviceChannels, type, true);
}
public void catalogEventPublish(Platform platform, List<CommonGBChannel> deviceChannels, String type, boolean share) {
if (platform != null && !userSetting.getServerId().equals(platform.getServerId())) { if (platform != null && !userSetting.getServerId().equals(platform.getServerId())) {
// 指定了上级平台的推送，则发送到指定的设备，未指定的则全部发送， 接收后各自处理自己的 // 指定了上级平台的推送，则发送到指定的设备，未指定的则全部发送， 接收后各自处理自己的
CatalogEvent outEvent = new CatalogEvent(this); CatalogEvent outEvent = new CatalogEvent(this);
@ -103,7 +106,7 @@ public class EventPublisher {
outEvent.setType(type); outEvent.setType(type);
outEvent.setPlatform(platform); outEvent.setPlatform(platform);
applicationEventPublisher.publishEvent(outEvent); applicationEventPublisher.publishEvent(outEvent);
if (platform == null) { if (platform == null && share) {
// 如果没指定上级平台，则推送消息到所有在线的wvp处理自己含有的平台的目录更新 // 如果没指定上级平台，则推送消息到所有在线的wvp处理自己含有的平台的目录更新
redisRpcService.catalogEventPublish(null, outEvent); redisRpcService.catalogEventPublish(null, outEvent);
} }