| | |
|---|
| | | if (parentPlatform != null && !parentPlatform.isStatus())return; |
|---|
| | | String key = VideoManagerConstants.SIP_SUBSCRIBE_PREFIX + userSetup.getServerId() + "_Catalog_" + event.getPlatformId(); |
|---|
| | | subscribe = redisCatchStorage.getSubscribe(key); |
|---|
| | | if (subscribe == null) return; |
|---|
| | | |
|---|
| | | if (subscribe == null) { |
|---|
| | | logger.debug("发送订阅消息时发现订阅信息已经不存在"); |
|---|
| | | return; |
|---|
| | | } |
|---|
| | | }else { |
|---|
| | | // 获取所用订阅 |
|---|
| | | List<String> platforms = redisCatchStorage.getAllSubscribePlatform(); |
|---|
| | |
|---|
| | | if (event.getDeviceChannels() != null) { |
|---|
| | | deviceChannelList.addAll(event.getDeviceChannels()); |
|---|
| | | } |
|---|
| | | if (event.getGbStreams() != null && event.getGbStreams().length > 0){ |
|---|
| | | if (event.getGbStreams() != null && event.getGbStreams().size() > 0){ |
|---|
| | | for (GbStream gbStream : event.getGbStreams()) { |
|---|
| | | DeviceChannel deviceChannelByStream = gbStreamService.getDeviceChannelListByStream(gbStream, gbStream.getCatalogId(), parentPlatform.getDeviceGBId()); |
|---|
| | | deviceChannelList.add(deviceChannelByStream); |
|---|
| | |
|---|
| | | if (event.getDeviceChannels() != null) { |
|---|
| | | deviceChannelList.addAll(event.getDeviceChannels()); |
|---|
| | | } |
|---|
| | | if (event.getGbStreams() != null && event.getGbStreams().length > 0){ |
|---|
| | | if (event.getGbStreams() != null && event.getGbStreams().size() > 0){ |
|---|
| | | for (GbStream gbStream : event.getGbStreams()) { |
|---|
| | | DeviceChannel deviceChannelByStream = gbStreamService.getDeviceChannelListByStream(gbStream, gbStream.getCatalogId(), parentPlatform.getDeviceGBId()); |
|---|
| | | deviceChannelList.add(deviceChannelByStream); |
|---|
| | |
|---|
| | | } |
|---|
| | | if (deviceChannelList.size() > 0) { |
|---|
| | | logger.info("[Catalog事件: {}]平台：{}，影响通道{}个", event.getType(), event.getPlatformId(), deviceChannelList.size()); |
|---|
| | | sipCommanderFroPlatform.sendNotifyForCatalogAddOrUpdate(event.getType(), parentPlatform, deviceChannelList, subscribe); |
|---|
| | | sipCommanderFroPlatform.sendNotifyForCatalogAddOrUpdate(event.getType(), parentPlatform, deviceChannelList, subscribe, null); |
|---|
| | | } |
|---|
| | | }else if (parentPlatformMap.keySet().size() > 0) { |
|---|
| | | for (String gbId : parentPlatformMap.keySet()) { |
|---|
