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

修复导入通道时无平台关联时的bug

pull/379/head^2
648540858 2022-03-07 10:47:06 +08:00
parent a45bb7d9df
commit 41616f726d
2 changed files with 11 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
src/main/java/com/genersoft/iot/vmp/gb28181/transmit/cmd/impl/SIPCommanderFroPlatform.java
View File

@ -563,6 +563,9 @@ public class SIPCommanderFroPlatform implements ISIPCommanderForPlatform {
@Override @Override
public void streamByeCmd(ParentPlatform platform, String callId) { public void streamByeCmd(ParentPlatform platform, String callId) {
if (platform == null) {
return;
}
SendRtpItem sendRtpItem = redisCatchStorage.querySendRTPServer(platform.getServerGBId(), null, null, callId); SendRtpItem sendRtpItem = redisCatchStorage.querySendRTPServer(platform.getServerGBId(), null, null, callId);
if (sendRtpItem != null) { if (sendRtpItem != null) {
String mediaServerId = sendRtpItem.getMediaServerId(); String mediaServerId = sendRtpItem.getMediaServerId();

13
src/main/java/com/genersoft/iot/vmp/service/impl/StreamPushServiceImpl.java
View File

@ -413,12 +413,15 @@ public class StreamPushServiceImpl implements IStreamPushService {
} }
} }
platformGbStreamMapper.batchAdd(streamPushItemListFroPlatform); if (streamPushItemListFroPlatform.size() > 0) {
// 发送通知 platformGbStreamMapper.batchAdd(streamPushItemListFroPlatform);
for (String platformId : platformForEvent.keySet()) { // 发送通知
eventPublisher.catalogEventPublishForStream( for (String platformId : platformForEvent.keySet()) {
platformId, platformForEvent.get(platformId), CatalogEvent.ADD); eventPublisher.catalogEventPublishForStream(
platformId, platformForEvent.get(platformId), CatalogEvent.ADD);
}
} }
} }
} }