From a74fb6ecd666ca479c7b5d9b6ace8103333610f7 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期一, 08 一月 2024 15:03:07 +0800
Subject: [PATCH] 优化目录订阅处理，保证存储异常时不影响后续操作
---
src/main/java/com/genersoft/iot/vmp/media/zlm/AssistRESTfulUtils.java | 21 ++++++++++-----------
1 files changed, 10 insertions(+), 11 deletions(-)
diff --git a/src/main/java/com/genersoft/iot/vmp/media/zlm/AssistRESTfulUtils.java b/src/main/java/com/genersoft/iot/vmp/media/zlm/AssistRESTfulUtils.java
index fd63ce6..9fda53e 100644
--- a/src/main/java/com/genersoft/iot/vmp/media/zlm/AssistRESTfulUtils.java
+++ b/src/main/java/com/genersoft/iot/vmp/media/zlm/AssistRESTfulUtils.java
@@ -257,8 +257,17 @@
return sendPost(mediaServerItem, "api/record/file/download/task/add", videoTaskInfoJSON, null, 30);
}
- public JSONObject queryTaskList(MediaServerItem mediaServerItem, String taskId, Boolean isEnd) {
+ public JSONObject queryTaskList(MediaServerItem mediaServerItem, String app, String stream, String callId, String taskId, Boolean isEnd) {
Map<String, Object> param = new HashMap<>();
+ if (!ObjectUtils.isEmpty(app)) {
+ param.put("app", app);
+ }
+ if (!ObjectUtils.isEmpty(stream)) {
+ param.put("stream", stream);
+ }
+ if (!ObjectUtils.isEmpty(callId)) {
+ param.put("callId", callId);
+ }
if (!ObjectUtils.isEmpty(taskId)) {
param.put("taskId", taskId);
}
@@ -267,15 +276,5 @@
}
return sendGet(mediaServerItem, "api/record/file/download/task/list", param, null);
- }
-
- public JSONObject addCollect(MediaServerItem mediaServerItem, JSONObject jsonObject) {
- return sendPost(mediaServerItem, "api/record/file/collection/add", jsonObject, null, 30);
- }
-
- public JSONObject deleteFiles(MediaServerItem mediaServerItem, List<String> filePathList) {
- JSONObject jsonObject = new JSONObject();
- jsonObject.put("filePathList", filePathList);
- return sendPost(mediaServerItem, "api/record/file/delete", jsonObject, null, 15*60);
}
}
--
Gitblit v1.8.0