| | |
|---|
| | | } |
|---|
| | | } |
|---|
| | | } |
|---|
| | | SendRtpItem sendRtpItem = redisCatchStorage.querySendRTPServer(device.getDeviceId(), channelId, null, null); |
|---|
| | | if (sendRtpItem != null) { |
|---|
| | | MediaServerItem mediaServer = mediaServerService.getOne(sendRtpItem.getMediaServerId()); |
|---|
| | | Boolean streamReady = zlmServerFactory.isStreamReady(mediaServer, "rtp", sendRtpItem.getReceiveStream()); |
|---|
| | | if (streamReady) { |
|---|
| | | logger.warn("[语音对讲] 进行中： {}", channelId); |
|---|
| | | event.call("语音对讲进行中"); |
|---|
| | | return false; |
|---|
| | | } else { |
|---|
| | | stopTalk(device, channelId); |
|---|
| | | } |
|---|
| | | } |
|---|
| | | // SendRtpItem sendRtpItem = redisCatchStorage.querySendRTPServer(device.getDeviceId(), channelId, null, null); |
|---|
| | | // if (sendRtpItem != null) { |
|---|
| | | // MediaServerItem mediaServer = mediaServerService.getOne(sendRtpItem.getMediaServerId()); |
|---|
| | | // Boolean streamReady = zlmServerFactory.isStreamReady(mediaServer, sendRtpItem.getApp(), sendRtpItem.getStream()); |
|---|
| | | // if (streamReady) { |
|---|
| | | // logger.warn("[语音对讲] 进行中： {}", channelId); |
|---|
| | | // event.call("语音对讲进行中"); |
|---|
| | | // return false; |
|---|
| | | // } else { |
|---|
| | | // stopTalk(device, channelId); |
|---|
| | | // } |
|---|
| | | // } |
|---|
| | | |
|---|
| | | // 发送通知 |
|---|
| | | cmder.audioBroadcastCmd(device, channelId, eventResultForOk -> { |
|---|
