临时提交

648540858

2024-04-18 73559cc6b3ac8fc0fa71783ccf8cfec5c9d20d77

临时提交

 src/main/java/com/genersoft/iot/vmp/media/zlm/ZLMHttpHookListener.java

@@ -518,13 +518,13 @@
                            }

                            if (sendRtpItem.getApp().equals(param.getApp())) {

                                // 在hook收到这个消息，说明发流一定是本级完成的。

                                redisCatchStorage.deleteSendRTPServer(sendRtpItem);

                                ssrcFactory.releaseSsrc(sendRtpItem.getMediaServerId(), sendRtpItem.getSsrc());

                                ParentPlatform platform = storager.queryParentPlatByServerGBId(sendRtpItem.getPlatformId());

                                Device device = deviceService.getDevice(sendRtpItem.getPlatformId());

                                try {

                                    if (platform != null) {

                                        commanderFroPlatform.streamByeCmd(platform, sendRtpItem);

                                        redisCatchStorage.deleteSendRTPServer(sendRtpItem);

                                        redisCatchStorage.sendPlatformStopPlayMsg(sendRtpItem, platform);

                                    } else if (device != null) {

                                        cmder.streamByeCmd(device, sendRtpItem.getChannelId(), param.getStream(), sendRtpItem.getCallId());


 src/main/java/com/genersoft/iot/vmp/storager/impl/RedisCatchStorageImpl.java

@@ -271,10 +271,10 @@
                + channelId + "_"
                + streamId + "_"
                + callId;
        logger.info("[删除 redis的SendRTP]： {}", key);
        List<Object> scan = RedisUtil.scan(redisTemplate, key);
        if (scan.size() > 0) {
            for (Object keyStr : scan) {
                logger.info("[删除 redis的SendRTP]： {}", keyStr.toString());
                redisTemplate.delete(keyStr);
            }
        }