| | |
|---|
| | | List<SendRtpItem> sendRtpItems = redisCatchStorage.querySendRTPServerByStream(param.getStream());
|
|---|
| | | if (!sendRtpItems.isEmpty()) {
|
|---|
| | | for (SendRtpItem sendRtpItem : sendRtpItems) {
|
|---|
| | | if (sendRtpItem != null && sendRtpItem.getApp().equals(param.getApp())) {
|
|---|
| | | if (sendRtpItem == null) {
|
|---|
| | | continue;
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | if (sendRtpItem.getApp().equals(param.getApp())) {
|
|---|
| | | logger.info(sendRtpItem.toString());
|
|---|
| | | if (userSetting.getServerId().equals(sendRtpItem.getServerId())) {
|
|---|
| | | // 通知其他wvp停止发流
|
|---|
| | | // redisCatchStorage.sendRtp
|
|---|
| | | }else {
|
|---|
| | | String platformId = sendRtpItem.getPlatformId();
|
|---|
| | | ParentPlatform platform = storager.queryParentPlatByServerGBId(platformId);
|
|---|
| | | Device device = deviceService.getDevice(platformId);
|
|---|
| | |
|---|
| | | logger.error("[命令发送失败] 发送BYE: {}", e.getMessage());
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | | }
|
|---|
