| | |
| | | import com.genersoft.iot.vmp.gb28181.event.EventPublisher; |
| | | import com.genersoft.iot.vmp.gb28181.event.subscribe.catalog.CatalogEvent; |
| | | import com.genersoft.iot.vmp.media.bean.MediaInfo; |
| | | import com.genersoft.iot.vmp.media.event.MediaArrivalEvent; |
| | | import com.genersoft.iot.vmp.media.event.MediaDepartureEvent; |
| | | import com.genersoft.iot.vmp.media.event.media.MediaArrivalEvent; |
| | | import com.genersoft.iot.vmp.media.event.media.MediaDepartureEvent; |
| | | import com.genersoft.iot.vmp.media.service.IMediaServerService; |
| | | import com.genersoft.iot.vmp.media.zlm.dto.MediaServer; |
| | | import com.genersoft.iot.vmp.media.zlm.dto.StreamAuthorityInfo; |
| | |
| | | redisCatchStorage.sendStreamChangeMsg(type, jsonObject); |
| | | } |
| | | } |
| | | GbStream gbStream = storager.getGbStream(event.getApp(), event.getStream()); |
| | | GbStream gbStream = gbStreamMapper.selectOne(event.getApp(), event.getStream()); |
| | | if (gbStream != null) { |
| | | if (userSetting.isUsePushingAsStatus()) { |
| | | storager.mediaOffline(event.getApp(), event.getStream()); |
| | | streamPushMapper.updatePushStatus(event.getApp(), event.getStream(), false); |
| | | eventPublisher.catalogEventPublishForStream(null, gbStream, CatalogEvent.OFF); |
| | | } |
| | | }else { |
| | | storager.removeMedia(event.getApp(), event.getStream()); |
| | | streamPushMapper.del(event.getApp(), event.getStream()); |
| | | } |
| | | } |
| | | |