|
@@ -1110,17 +1110,24 @@ ffmpeg -i "concat:1.ts|2.ts" -c copy output.mp4
|
|
|
}
|
|
|
// 计算查询的时间范围(前五分钟)
|
|
|
long startTime = currentTimestamp - timeInterval;
|
|
|
+ log.info("当前时间戳:{},时间间隔:{}", currentTimestamp, timeInterval);
|
|
|
+ log.info("查询时间范围:{}", new Date(startTime) + "--" + new Date(currentTimestamp));
|
|
|
// 查询 MQ 日志
|
|
|
LambdaQueryWrapper<MqLog> mqLogQuery = new LambdaQueryWrapper<>();
|
|
|
mqLogQuery.between(MqLog::getCreateTime, new Date(startTime), new Date(currentTimestamp));
|
|
|
List<MqLog> mqLogs = mqLogService.list(mqLogQuery);
|
|
|
+ log.info("查询结果:{}", mqLogs);
|
|
|
Set<String> loggedCameraCodes = mqLogs.stream().map(MqLog::getCameraCode).collect(Collectors.toSet());
|
|
|
+ log.info("已记录日志的设备:{}", loggedCameraCodes);
|
|
|
// 获取所有设备
|
|
|
List<BaseDeviceDynamicManagement> devices = baseDeviceDynamicManagementService.list();
|
|
|
Set<String> allCameraCodes = devices.stream().map(BaseDeviceDynamicManagement::getCameraCode).collect(Collectors.toSet());
|
|
|
+ log.info("所有设备:{}", allCameraCodes);
|
|
|
// 找出未记录日志的设备
|
|
|
Set<String> inactiveCameraCodes = new HashSet<>(allCameraCodes);
|
|
|
+ log.info("set集合中的设备:{}", inactiveCameraCodes);
|
|
|
inactiveCameraCodes.removeAll(loggedCameraCodes);
|
|
|
+ log.info("未记录日志的设备:{}", inactiveCameraCodes);
|
|
|
// 保存设备状态变更记录
|
|
|
saveDeviceResume(loggedCameraCodes, 1);
|
|
|
saveDeviceResume(inactiveCameraCodes, 2);
|