package com.genersoft.iot.vmp.gb28181.event.subscribe.catalog;
|
|
import com.genersoft.iot.vmp.common.VideoManagerConstants;
|
import com.genersoft.iot.vmp.conf.SipConfig;
|
import com.genersoft.iot.vmp.conf.UserSetting;
|
import com.genersoft.iot.vmp.gb28181.bean.*;
|
import com.genersoft.iot.vmp.gb28181.transmit.cmd.impl.SIPCommanderFroPlatform;
|
import com.genersoft.iot.vmp.media.zlm.ZLMRTPServerFactory;
|
import com.genersoft.iot.vmp.service.IGbStreamService;
|
import com.genersoft.iot.vmp.service.IMediaServerService;
|
import com.genersoft.iot.vmp.storager.IRedisCatchStorage;
|
import com.genersoft.iot.vmp.storager.IVideoManagerStorage;
|
import org.slf4j.Logger;
|
import org.slf4j.LoggerFactory;
|
import org.springframework.beans.factory.annotation.Autowired;
|
import org.springframework.context.ApplicationListener;
|
import org.springframework.stereotype.Component;
|
import org.springframework.util.StringUtils;
|
|
import java.util.*;
|
|
/**
|
* catalog事件
|
*/
|
@Component
|
public class CatalogEventLister implements ApplicationListener<CatalogEvent> {
|
|
private final static Logger logger = LoggerFactory.getLogger(CatalogEventLister.class);
|
|
@Autowired
|
private IVideoManagerStorage storager;
|
@Autowired
|
private IRedisCatchStorage redisCatchStorage;
|
@Autowired
|
private IMediaServerService mediaServerService;
|
|
@Autowired
|
private SIPCommanderFroPlatform sipCommanderFroPlatform;
|
|
@Autowired
|
private ZLMRTPServerFactory zlmrtpServerFactory;
|
|
@Autowired
|
private SipConfig config;
|
|
@Autowired
|
private UserSetting userSetting;
|
|
@Autowired
|
private IGbStreamService gbStreamService;
|
|
@Autowired
|
private SubscribeHolder subscribeHolder;
|
|
@Override
|
public void onApplicationEvent(CatalogEvent event) {
|
SubscribeInfo subscribe = null;
|
ParentPlatform parentPlatform = null;
|
|
Map<String, List<ParentPlatform>> parentPlatformMap = new HashMap<>();
|
if (event.getPlatformId() != null) {
|
parentPlatform = storager.queryParentPlatByServerGBId(event.getPlatformId());
|
if (parentPlatform != null && !parentPlatform.isStatus()) {
|
return;
|
}
|
subscribe = subscribeHolder.getCatalogSubscribe(event.getPlatformId());
|
|
if (subscribe == null) {
|
logger.info("发送订阅消息时发现订阅信息已经不存在");
|
return;
|
}
|
}else {
|
// 获取所用订阅
|
List<String> platforms = subscribeHolder.getAllCatalogSubscribePlatform();
|
if (event.getDeviceChannels() != null) {
|
if (platforms.size() > 0) {
|
for (DeviceChannel deviceChannel : event.getDeviceChannels()) {
|
List<ParentPlatform> parentPlatformsForGB = storager.queryPlatFormListForGBWithGBId(deviceChannel.getChannelId(), platforms);
|
parentPlatformMap.put(deviceChannel.getChannelId(), parentPlatformsForGB);
|
}
|
}
|
}else if (event.getGbStreams() != null) {
|
if (platforms.size() > 0) {
|
for (GbStream gbStream : event.getGbStreams()) {
|
if (gbStream == null || StringUtils.isEmpty(gbStream.getGbId())) {
|
continue;
|
}
|
List<ParentPlatform> parentPlatformsForGB = storager.queryPlatFormListForStreamWithGBId(gbStream.getApp(),gbStream.getStream(), platforms);
|
parentPlatformMap.put(gbStream.getGbId(), parentPlatformsForGB);
|
}
|
}
|
}
|
}
|
switch (event.getType()) {
|
case CatalogEvent.ON:
|
case CatalogEvent.OFF:
|
case CatalogEvent.DEL:
|
|
if (parentPlatform != null || subscribe != null) {
|
List<DeviceChannel> deviceChannelList = new ArrayList<>();
|
if (event.getDeviceChannels() != null) {
|
deviceChannelList.addAll(event.getDeviceChannels());
|
}
|
if (event.getGbStreams() != null && event.getGbStreams().size() > 0){
|
for (GbStream gbStream : event.getGbStreams()) {
|
DeviceChannel deviceChannelByStream = gbStreamService.getDeviceChannelListByStream(gbStream, gbStream.getCatalogId(), parentPlatform);
|
deviceChannelList.add(deviceChannelByStream);
|
}
|
}
|
if (deviceChannelList.size() > 0) {
|
logger.info("[Catalog事件: {}]平台：{}，影响通道{}个", event.getType(), event.getPlatformId(), deviceChannelList.size());
|
sipCommanderFroPlatform.sendNotifyForCatalogOther(event.getType(), parentPlatform, deviceChannelList, subscribe, null);
|
}
|
}else if (parentPlatformMap.keySet().size() > 0) {
|
for (String gbId : parentPlatformMap.keySet()) {
|
List<ParentPlatform> parentPlatforms = parentPlatformMap.get(gbId);
|
if (parentPlatforms != null && parentPlatforms.size() > 0) {
|
for (ParentPlatform platform : parentPlatforms) {
|
SubscribeInfo subscribeInfo = subscribeHolder.getCatalogSubscribe(platform.getServerGBId());
|
if (subscribeInfo == null) {
|
continue;
|
}
|
logger.info("[Catalog事件: {}]平台：{}，影响通道{}", event.getType(), platform.getServerGBId(), gbId);
|
List<DeviceChannel> deviceChannelList = new ArrayList<>();
|
DeviceChannel deviceChannel = new DeviceChannel();
|
deviceChannel.setChannelId(gbId);
|
deviceChannelList.add(deviceChannel);
|
sipCommanderFroPlatform.sendNotifyForCatalogOther(event.getType(), platform, deviceChannelList, subscribeInfo, null);
|
}
|
}
|
}
|
}
|
break;
|
case CatalogEvent.VLOST:
|
break;
|
case CatalogEvent.DEFECT:
|
break;
|
case CatalogEvent.ADD:
|
case CatalogEvent.UPDATE:
|
if (parentPlatform != null || subscribe != null) {
|
List<DeviceChannel> deviceChannelList = new ArrayList<>();
|
if (event.getDeviceChannels() != null) {
|
deviceChannelList.addAll(event.getDeviceChannels());
|
}
|
if (event.getGbStreams() != null && event.getGbStreams().size() > 0){
|
for (GbStream gbStream : event.getGbStreams()) {
|
DeviceChannel deviceChannelByStream = gbStreamService.getDeviceChannelListByStream(gbStream, gbStream.getCatalogId(), parentPlatform);
|
if (deviceChannelByStream.getParentId().length() <= 10) { // 父节点是行政区划,则设置CivilCode使用此行政区划
|
deviceChannelByStream.setCivilCode(deviceChannelByStream.getParentId());
|
}
|
deviceChannelList.add(deviceChannelByStream);
|
}
|
}
|
if (deviceChannelList.size() > 0) {
|
logger.info("[Catalog事件: {}]平台：{}，影响通道{}个", event.getType(), event.getPlatformId(), deviceChannelList.size());
|
sipCommanderFroPlatform.sendNotifyForCatalogAddOrUpdate(event.getType(), parentPlatform, deviceChannelList, subscribe, null);
|
}
|
}else if (parentPlatformMap.keySet().size() > 0) {
|
for (String gbId : parentPlatformMap.keySet()) {
|
List<ParentPlatform> parentPlatforms = parentPlatformMap.get(gbId);
|
if (parentPlatforms != null && parentPlatforms.size() > 0) {
|
for (ParentPlatform platform : parentPlatforms) {
|
SubscribeInfo subscribeInfo = subscribeHolder.getCatalogSubscribe(platform.getServerGBId());
|
if (subscribeInfo == null) {
|
continue;
|
}
|
logger.info("[Catalog事件: {}]平台：{}，影响通道{}", event.getType(), platform.getServerGBId(), gbId);
|
List<DeviceChannel> deviceChannelList = new ArrayList<>();
|
DeviceChannel deviceChannel = storager.queryChannelInParentPlatform(platform.getServerGBId(), gbId);
|
deviceChannelList.add(deviceChannel);
|
GbStream gbStream = storager.queryStreamInParentPlatform(platform.getServerGBId(), gbId);
|
if(gbStream != null){
|
DeviceChannel deviceChannelByStream = gbStreamService.getDeviceChannelListByStream(gbStream, gbStream.getCatalogId(), platform);
|
deviceChannelList.add(deviceChannelByStream);
|
}
|
sipCommanderFroPlatform.sendNotifyForCatalogAddOrUpdate(event.getType(), platform, deviceChannelList, subscribeInfo, null);
|
}
|
}
|
}
|
}
|
break;
|
default:
|
break;
|
}
|
}
|
}
|
|
