| | |
| | | if (needUpdate) { |
| | | ardFlightTaskMapper.updateArdFlightTask(local); |
| | | } |
| | | |
| | | // 其它媒体增量更新 |
| | | updateVideoToDatabase(local, remote.getVideoPathList()); |
| | | updatePhotoToDatabase(local, local.getServerId(), remote.getBoxSn()); |
| | | } |
| | | |
| | | |
| | |
| | | if (videoPathList == null) { |
| | | return; |
| | | } |
| | | Integer count = flightTask.getVideoCount();//获取本地库视频数量 |
| | | // 需要插入新的视频 |
| | | List<ArdMedia> existingVideos = ardMediaMapper.selectArdMediaByTaskIdAndType(flightTask.getTaskId(), 1); |
| | | Integer count = existingVideos.size();//获取本地库视频数量 |
| | | int size = videoPathList.size();//获取接口返回的视频数量 |
| | | if (count != null && size > count) { |
| | | log.info("任务【{}】录像数量不一致,需要更新数据库", flightTask.getTaskId()); |
| | | // 需要插入新的视频 |
| | | List<ArdMedia> existingVideos = ardMediaMapper.selectArdMediaByTaskIdAndType(flightTask.getTaskId(), 1); |
| | | |
| | | // 提取现有的视频路径 |
| | | List<String> existingVideoPaths = existingVideos.stream() |
| | | .map(ArdMedia::getSourceUrl) // 获取每个视频的 URL |
| | |
| | | } |
| | | |
| | | private void updatePhotoToDatabase(ArdFlightTask flightTask, String serverId, String boxSn) { |
| | | int count = flightTask.getPhotoCount(); //获取本地库图片数量 |
| | | |
| | | // 获取本地数据库中已存在的图片记录(类型为 0 表示图片) |
| | | List<ArdMedia> existingPhotos = ardMediaMapper.selectArdMediaByTaskIdAndType(flightTask.getTaskId(), 0); |
| | | int count = existingPhotos.size(); //获取本地库图片数量 |
| | | // 查询图片 |
| | | BoxPhotosDTO boxPhotosDTO = BoxPhotosDTO.builder() |
| | | .taskId(flightTask.getTaskId()) |
| | |
| | | |
| | | if (size > count) { |
| | | log.info("任务【{}】图片数量不一致,需要更新数据库", flightTask.getTaskId()); |
| | | // 获取本地数据库中已存在的图片记录(类型为 0 表示图片) |
| | | List<ArdMedia> existingPhotos = ardMediaMapper.selectArdMediaByTaskIdAndType(flightTask.getTaskId(), 0); |
| | | // 需要插入新的视频 |
| | | // 提取现有的图片路径(根据 imgUrl 来判断是否重复) |
| | | List<String> existingPhotoUrls = existingPhotos.stream() |