搭配zgyw，实现gb28181
blame | 历史 | 补丁 | 提交 | 提交对比 | ignore whitespace
648540858
2023-07-31 3cada227435934da8a2db49939695f870b7f477e 
 src/main/java/com/genersoft/iot/vmp/service/redisMsg/RedisPushStreamCloseResponseListener.java


@@ -58,7 +58,7 @@


    private IMediaServerService mediaServerService;




    @Autowired


    private ZLMServerFactory ZLMServerFactory;


    private ZLMServerFactory zlmServerFactory;






    private Map<String, PushStreamResponseEvent> responseEvents = new ConcurrentHashMap<>();


@@ -80,7 +80,7 @@


                    for (SendRtpItem sendRtpItem : sendRtpItems) {


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


                        // 停止向上级推流


                        String streamId = sendRtpItem.getStreamId();


                        String streamId = sendRtpItem.getStream();


                        Map<String, Object> param = new HashMap<>();


                        param.put("vhost","__defaultVhost__");


                        param.put("app",sendRtpItem.getApp());


@@ -88,8 +88,8 @@


                        param.put("ssrc",sendRtpItem.getSsrc());


                        logger.info("[REDIS消息-推流结束] 停止向上级推流：{}", streamId);


                        MediaServerItem mediaInfo = mediaServerService.getOne(sendRtpItem.getMediaServerId());


                        redisCatchStorage.deleteSendRTPServer(sendRtpItem.getPlatformId(), sendRtpItem.getChannelId(), sendRtpItem.getCallId(), sendRtpItem.getStreamId());


                        ZLMServerFactory.stopSendRtpStream(mediaInfo, param);


                        redisCatchStorage.deleteSendRTPServer(sendRtpItem.getPlatformId(), sendRtpItem.getChannelId(), sendRtpItem.getCallId(), sendRtpItem.getStream());


                        zlmServerFactory.stopSendRtpStream(mediaInfo, param);




                        try {


                            commanderFroPlatform.streamByeCmd(parentPlatform, sendRtpItem);


@@ -98,7 +98,7 @@


                        }


                        if (InviteStreamType.PUSH == sendRtpItem.getPlayType()) {


                            MessageForPushChannel messageForPushChannel = MessageForPushChannel.getInstance(0,


                                    sendRtpItem.getApp(), sendRtpItem.getStreamId(), sendRtpItem.getChannelId(),


                                    sendRtpItem.getApp(), sendRtpItem.getStream(), sendRtpItem.getChannelId(),


                                    sendRtpItem.getPlatformId(), parentPlatform.getName(), userSetting.getServerId(), sendRtpItem.getMediaServerId());


                            messageForPushChannel.setPlatFormIndex(parentPlatform.getId());


                            redisCatchStorage.sendPlatformStopPlayMsg(messageForPushChannel);