| | |
|---|
| | | }
|
|---|
| | |
|
|---|
| | | // 查询请求方是否上级平台
|
|---|
| | | ParentPlatform platform = storager.queryParentPlatById(requesterId);
|
|---|
| | | ParentPlatform platform = storager.queryParentPlatByServerGBId(requesterId);
|
|---|
| | | if (platform != null) {
|
|---|
| | | // 查询平台下是否有该通道
|
|---|
| | | DeviceChannel channel = storager.queryChannelInParentPlatform(requesterId, channelId);
|
|---|
| | |
|---|
| | | // 通知下级推流，
|
|---|
| | | PlayResult playResult = playService.play(device.getDeviceId(), channelId, (responseJSON)->{
|
|---|
| | | // 收到推流， 回复200OK, 等待ack
|
|---|
| | | if (sendRtpItem == null) return;
|
|---|
| | | // if (sendRtpItem == null) return;
|
|---|
| | | sendRtpItem.setStatus(1);
|
|---|
| | | redisCatchStorage.updateSendRTPSever(sendRtpItem);
|
|---|
| | | // TODO 添加对tcp的支持
|
|---|
