| | |
| | | log.debug("定时同步Vtdu任务"); |
| | | List<ArdChannel> channels = this.selectArdChannelList(new ArdChannel()); |
| | | if (channels == null || channels.isEmpty()) { |
| | | log.warn("没有获取到通道数据,退出同步"); |
| | | // log.warn("没有获取到通道数据,退出同步"); |
| | | return; |
| | | } |
| | | List<ArdVtdu> ardVtduList = ardVtduService.selectArdVtduList(new ArdVtdu()); |
| | |
| | | // 3. 删除操作:删除媒体表中多余的记录 |
| | | List<String> invalidNames = ardVtduList.stream() |
| | | .filter(vtdu -> !validNames.contains(vtdu.getName())) |
| | | .filter(vtdu -> !"publisher".equalsIgnoreCase(vtdu.getRtspSource())) // 不是机场流 |
| | | .map(ArdVtdu::getName) |
| | | .collect(Collectors.toList()); |
| | | |