| | |
| | | deviceChannel.setSecrecy("0"); |
| | | cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size); |
| | | // 防止发送过快 |
| | | Thread.sleep(10); |
| | | Thread.sleep(50); |
| | | } |
| | | } |
| | | // 回复级联的通道 |
| | | if (channelReduces.size() > 0) { |
| | | for (ChannelReduce channelReduce : channelReduces) { |
| | | DeviceChannel deviceChannel = storager.queryChannel(channelReduce.getDeviceId(), channelReduce.getChannelId()); |
| | | // TODO 目前暂时认为这里只用通道没有目录 |
| | | deviceChannel.setParental(0); |
| | | deviceChannel.setParentId(channelReduce.getCatalogId()); |
| | | |
| | | cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size); |
| | | // 防止发送过快 |
| | | Thread.sleep(10); |
| | | Thread.sleep(50); |
| | | } |
| | | } |
| | | // 回复直播的通道 |
| | |
| | | deviceChannel.setSecrecy("0"); |
| | | cmderFroPlatform.catalogQuery(deviceChannel, parentPlatform, sn, fromHeader.getTag(), size); |
| | | // 防止发送过快 |
| | | Thread.sleep(10); |
| | | Thread.sleep(50); |
| | | } |
| | | } |
| | | if (size == 0) { |