| | |
|---|
| | | redisCatchStorage.updateStreamAuthorityInfo(param.getApp(), param.getStream(), streamAuthorityInfo);
|
|---|
| | | }
|
|---|
| | | }
|
|---|
| | |
|
|---|
| | | if ("rtsp".equals(param.getSchema())) {
|
|---|
| | | logger.info("流变化：注册->{}, app->{}, stream->{}", param.isRegist(), param.getApp(), param.getStream());
|
|---|
| | | if (param.isRegist()) {
|
|---|
| | |
|---|
| | | }
|
|---|
| | | if (!param.isRegist()) {
|
|---|
| | | List<SendRtpItem> sendRtpItems = redisCatchStorage.querySendRTPServerByStream(param.getStream());
|
|---|
| | | if (sendRtpItems.size() > 0) {
|
|---|
| | | if (!sendRtpItems.isEmpty()) {
|
|---|
| | | for (SendRtpItem sendRtpItem : sendRtpItems) {
|
|---|
| | | if (sendRtpItem != null && sendRtpItem.getApp().equals(param.getApp())) {
|
|---|
| | | String platformId = sendRtpItem.getPlatformId();
|
|---|
| | |
|---|
| | | }
|
|---|
| | | // 收到无人观看说明流也没有在往上级推送
|
|---|
| | | if (redisCatchStorage.isChannelSendingRTP(inviteInfo.getChannelId())) {
|
|---|
| | | List<SendRtpItem> sendRtpItems = redisCatchStorage.querySendRTPServerByChnnelId(
|
|---|
| | | List<SendRtpItem> sendRtpItems = redisCatchStorage.querySendRTPServerByChannelId(
|
|---|
| | | inviteInfo.getChannelId());
|
|---|
| | | if (sendRtpItems.size() > 0) {
|
|---|
| | | if (!sendRtpItems.isEmpty()) {
|
|---|
| | | for (SendRtpItem sendRtpItem : sendRtpItems) {
|
|---|
| | | ParentPlatform parentPlatform = storager.queryParentPlatByServerGBId(sendRtpItem.getPlatformId());
|
|---|
| | | try {
|
|---|
