| | |
|---|
| | | ParentPlatform parentPlatform = null; |
|---|
| | | |
|---|
| | | Map<String, List<ParentPlatform>> parentPlatformMap = new HashMap<>(); |
|---|
| | | Map<String, DeviceChannel> channelMap = new HashMap<>(); |
|---|
| | | if (!ObjectUtils.isEmpty(event.getPlatformId())) { |
|---|
| | | subscribe = subscribeHolder.getCatalogSubscribe(event.getPlatformId()); |
|---|
| | | if (subscribe == null) { |
|---|
| | |
|---|
| | | for (DeviceChannel deviceChannel : event.getDeviceChannels()) { |
|---|
| | | List<ParentPlatform> parentPlatformsForGB = storager.queryPlatFormListForGBWithGBId(deviceChannel.getChannelId(), platforms); |
|---|
| | | parentPlatformMap.put(deviceChannel.getChannelId(), parentPlatformsForGB); |
|---|
| | | channelMap.put(deviceChannel.getChannelId(), deviceChannel); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | }else if (event.getGbStreams() != null) { |
|---|
| | |
|---|
| | | } |
|---|
| | | logger.info("[Catalog事件: {}]平台：{}，影响通道{}", event.getType(), platform.getServerGBId(), gbId); |
|---|
| | | List<DeviceChannel> deviceChannelList = new ArrayList<>(); |
|---|
| | | DeviceChannel deviceChannel = storager.queryChannelInParentPlatform(platform.getServerGBId(), gbId); |
|---|
| | | DeviceChannel deviceChannel = channelMap.get(gbId); |
|---|
| | | deviceChannelList.add(deviceChannel); |
|---|
| | | GbStream gbStream = storager.queryStreamInParentPlatform(platform.getServerGBId(), gbId); |
|---|
| | | if(gbStream != null){ |
|---|
