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

临时提交

pull/1642/head
panlinlin 2024-06-29 23:35:26 +08:00
parent 69e7ab5439
commit e531e497c8
2 changed files with 30 additions and 20 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/genersoft/iot/vmp/streamProxy/dao/StreamProxyMapper.java
View File

@ -92,4 +92,7 @@ public interface StreamProxyMapper {
* 查询设置了自动移除并且没有国标编号的代理 * 查询设置了自动移除并且没有国标编号的代理
*/ */
List<StreamProxy> selectWithAutoRemoveAndWithoutGbDeviceIdByMediaServerId(String mediaServerId); List<StreamProxy> selectWithAutoRemoveAndWithoutGbDeviceIdByMediaServerId(String mediaServerId);
int delete(int id);
} }

47
src/main/java/com/genersoft/iot/vmp/streamProxy/service/impl/StreamProxyServiceImpl.java
View File

@ -191,8 +191,6 @@ public class StreamProxyServiceImpl implements IStreamProxyService {
return null; return null;
} }
/** /**
* 新增代理流 * 新增代理流
*/ */
@ -233,24 +231,22 @@ public class StreamProxyServiceImpl implements IStreamProxyService {
} }
@Override @Override
@Transactional
public void del(String app, String stream) { public void del(String app, String stream) {
StreamProxy streamProxyItem = streamProxyMapper.selectOne(app, stream); StreamProxy streamProxy = streamProxyMapper.selectOne(app, stream);
if (streamProxyItem != null) { if (streamProxy == null) {
gbStreamService.sendCatalogMsg(streamProxyItem, CatalogEvent.DEL); return;
}
// 如果关联了国标那么移除关联 if (streamProxy.getStreamKey() != null) {
platformGbStreamMapper.delByAppAndStream(app, stream); MediaServer mediaServer = mediaServerService.getOne(streamProxy.getMediaServerId());
gbStreamMapper.del(app, stream); if (mediaServer != null) {
streamProxyMapper.del(app, stream); mediaServerService.stopProxy(mediaServer, streamProxy.getStreamKey());
redisCatchStorage.removeStream(streamProxyItem.getMediaServerId(), "PULL", app, stream);
redisCatchStorage.removeStream(streamProxyItem.getMediaServerId(), "PUSH", app, stream);
Boolean result = removeStreamProxyFromZlm(streamProxyItem);
if (result != null && result) {
log.info("[移除代理]： 代理： {}/{}, 从zlm移除成功", app, stream);
}else {
log.info("[移除代理]： 代理： {}/{}, 从zlm移除失败", app, stream);
} }
} }
if (streamProxy.getGbId() > 0) {
gbChannelService.delete(streamProxy.getGbId());
}
streamProxyMapper.delete(streamProxy.getId());
} }
@Override @Override
@ -306,9 +302,20 @@ public class StreamProxyServiceImpl implements IStreamProxyService {
@Override @Override
public void zlmServerOnline(String mediaServerId) { public void zlmServerOnline(String mediaServerId) {
MediaServer mediaServer = mediaServerService.getOne(mediaServerId);
if (mediaServer == null) {
return;
}
// 这里主要是控制数据库/redis缓存/以及zlm中存在的代理流 三者状态一致。以数据库中数据为根本
List<StreamProxy> streamProxies = streamProxyMapper.selectForEnableInMediaServer(mediaServerId, true);
if (streamProxies.isEmpty()){
return;
}
// 移除开启了无人观看自动移除的流 // 移除开启了无人观看自动移除的流
List<StreamProxy> streamProxyItemList = streamProxyMapper.selectWithAutoRemoveAndWithoutGbDeviceIdByMediaServerId(mediaServerId); // List<StreamProxy> streamProxyItemList = streamProxyMapper.selectWithAutoRemoveAndWithoutGbDeviceIdByMediaServerId(mediaServerId);
streamProxyMapper.deleteAutoRemoveItemByMediaServerId(mediaServerId); streamProxyMapper.deleteWithAutoRemoveAndWithoutGbDeviceIdByMediaServerId(mediaServerId);
// 移除拉流代理生成的流信息 // 移除拉流代理生成的流信息
syncPullStream(mediaServerId); syncPullStream(mediaServerId);
@ -318,7 +325,7 @@ public class StreamProxyServiceImpl implements IStreamProxyService {
mediaServerId, true); mediaServerId, true);
for (StreamProxy streamProxyDto : streamProxyListForEnable) { for (StreamProxy streamProxyDto : streamProxyListForEnable) {
log.info("恢复流代理，" + streamProxyDto.getApp() + "/" + streamProxyDto.getStream()); log.info("恢复流代理，" + streamProxyDto.getApp() + "/" + streamProxyDto.getStream());
mediaServerService.startProxy(me) StreamInfo streamInfo = mediaServerService.startProxy(mediaServer, streamProxy);
WVPResult<String> wvpResult = addStreamProxyToZlm(streamProxyDto); WVPResult<String> wvpResult = addStreamProxyToZlm(streamProxyDto);
if (wvpResult == null) { if (wvpResult == null) {
// 设置为离线 // 设置为离线