Shikong/gb28181-docking-platform-mocking
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

新增根据 指定时间范围的 recordInfo 查询, 预下载视频文件到本地指定路径

Browse Source
This commit is contained in:
shikong 2024-02-06 15:56:37 +08:00
parent 92fb1555fd
commit 70019451d2
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gb28181-mocking-service/src/main/java/cn/skcks/docking/gb28181/mocking/core/sip/service/VideoCacheManager.java
View File

@ -75,6 +75,11 @@ public class VideoCacheManager {
@SneakyThrows @SneakyThrows
protected CompletableFuture<JsonResponse<String>> downloadVideo(String deviceCode, Date startTime, Date endTime) { protected CompletableFuture<JsonResponse<String>> downloadVideo(String deviceCode, Date startTime, Date endTime) {
return CompletableFuture.supplyAsync(()->{ return CompletableFuture.supplyAsync(()->{
File realFile = Paths.get(deviceProxyConfig.getPreDownloadForRecordInfo().getCachePath(),fileName(deviceCode, startTime, endTime) + ".mp4").toFile();
if(realFile.exists()){
return JsonResponse.success(realFile.getAbsolutePath());
}
final String url = UrlBuilder.of(deviceProxyConfig.getUrl()) final String url = UrlBuilder.of(deviceProxyConfig.getUrl())
.addPath("video") .addPath("video")
.addQuery("device_id", deviceCode) .addQuery("device_id", deviceCode)
@ -103,7 +108,6 @@ public class VideoCacheManager {
}); });
log.info("视频下载完成 => {}", file.getAbsolutePath()); log.info("视频下载完成 => {}", file.getAbsolutePath());
log.info("文件 {}, 是否存在: {}", file.getAbsolutePath(), file.exists()); log.info("文件 {}, 是否存在: {}", file.getAbsolutePath(), file.exists());
File realFile = Paths.get(deviceProxyConfig.getPreDownloadForRecordInfo().getCachePath(),fileName(deviceCode, startTime, endTime) + ".mp4").toFile();
file.renameTo(realFile); file.renameTo(realFile);
lock.release(); lock.release();
return JsonResponse.success(realFile.getAbsolutePath()); return JsonResponse.success(realFile.getAbsolutePath());