From 9b036fb71de123a9c150b46621e3d51f6feef384 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期三, 18 十月 2023 15:33:31 +0800
Subject: [PATCH] 优化云端录像页面

---
 src/main/java/com/genersoft/iot/vmp/vmanager/cloudRecord/CloudRecordController.java |   85 ++++++++++++++++++++++++++++++++++--------
 1 files changed, 69 insertions(+), 16 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/vmanager/cloudRecord/CloudRecordController.java b/src/main/java/com/genersoft/iot/vmp/vmanager/cloudRecord/CloudRecordController.java
index 0d79675..cb731cd 100755
--- a/src/main/java/com/genersoft/iot/vmp/vmanager/cloudRecord/CloudRecordController.java
+++ b/src/main/java/com/genersoft/iot/vmp/vmanager/cloudRecord/CloudRecordController.java
@@ -1,5 +1,7 @@
 package com.genersoft.iot.vmp.vmanager.cloudRecord;
 
+import com.alibaba.fastjson2.JSONArray;
+import com.alibaba.fastjson2.JSONObject;
 import com.genersoft.iot.vmp.conf.DynamicTask;
 import com.genersoft.iot.vmp.conf.UserSetting;
 import com.genersoft.iot.vmp.conf.exception.ControllerException;
@@ -103,20 +105,22 @@
     @ResponseBody
     @GetMapping("/list")
     @Operation(summary = "鍒嗛〉鏌ヨ浜戠褰曞儚")
-    @Parameter(name = "app", description = "搴旂敤鍚�", required = true)
-    @Parameter(name = "stream", description = "娴両D", required = true)
+    @Parameter(name = "query", description = "妫�绱㈠唴瀹�", required = false)
+    @Parameter(name = "app", description = "搴旂敤鍚�", required = false)
+    @Parameter(name = "stream", description = "娴両D", required = false)
     @Parameter(name = "page", description = "褰撳墠椤�", required = false)
     @Parameter(name = "count", description = "姣忛〉鏌ヨ鏁伴噺", required = false)
-    @Parameter(name = "startTime", description = "寮�濮嬫椂闂�(yyyy-MM-dd HH:mm:ss)", required = true)
-    @Parameter(name = "endTime", description = "缁撴潫鏃堕棿(yyyy-MM-dd HH:mm:ss)", required = true)
+    @Parameter(name = "startTime", description = "寮�濮嬫椂闂�(yyyy-MM-dd HH:mm:ss)", required = false)
+    @Parameter(name = "endTime", description = "缁撴潫鏃堕棿(yyyy-MM-dd HH:mm:ss)", required = false)
     @Parameter(name = "mediaServerId", description = "娴佸獟浣揑D锛岀疆绌哄垯鏌ヨ鍏ㄩ儴娴佸獟浣�", required = false)
     public PageInfo<CloudRecordItem> openRtpServer(
-            @RequestParam String app,
-            @RequestParam String stream,
+            @RequestParam(required = false)  String query,
+            @RequestParam(required = false)  String app,
+            @RequestParam(required = false)  String stream,
             @RequestParam int page,
             @RequestParam int count,
-            @RequestParam String startTime,
-            @RequestParam String endTime,
+            @RequestParam(required = false)  String startTime,
+            @RequestParam(required = false)  String endTime,
             @RequestParam(required = false) String mediaServerId
 
     ) {
@@ -137,7 +141,22 @@
         if (mediaServerItems.isEmpty()) {
             throw new ControllerException(ErrorCode.ERROR100.getCode(), "褰撳墠鏃犳祦濯掍綋");
         }
-        return cloudRecordService.getList(page, count, app, stream, startTime, endTime, mediaServerItems);
+        if (query != null && ObjectUtils.isEmpty(query.trim())) {
+            query = null;
+        }
+        if (app != null && ObjectUtils.isEmpty(app.trim())) {
+            app = null;
+        }
+        if (stream != null && ObjectUtils.isEmpty(stream.trim())) {
+            stream = null;
+        }
+        if (startTime != null && ObjectUtils.isEmpty(startTime.trim())) {
+            startTime = null;
+        }
+        if (endTime != null && ObjectUtils.isEmpty(endTime.trim())) {
+            endTime = null;
+        }
+        return cloudRecordService.getList(page, count, query, app, stream, startTime, endTime, mediaServerItems);
     }
 
     @ResponseBody
@@ -145,19 +164,53 @@
     @Operation(summary = "娣诲姞鍚堝苟浠诲姟")
     @Parameter(name = "app", description = "搴旂敤鍚�", required = true)
     @Parameter(name = "stream", description = "娴両D", required = true)
+    @Parameter(name = "mediaServerId", description = "娴佸獟浣揑D", required = false)
     @Parameter(name = "startTime", description = "閴存潈ID", required = false)
     @Parameter(name = "endTime", description = "閴存潈ID", required = false)
     @Parameter(name = "callId", description = "閴存潈ID", required = false)
     @Parameter(name = "remoteHost", description = "杩斿洖鍦板潃鏃剁殑杩滅▼鍦板潃", required = false)
     public String addTask(
-            @RequestParam String app,
-            @RequestParam String stream,
-            @RequestParam String startTime,
-            @RequestParam String endTime,
-            @RequestParam String callId,
-            @RequestParam String remoteHost
+            @RequestParam(required = true) String app,
+            @RequestParam(required = true) String stream,
+            @RequestParam(required = false) String mediaServerId,
+            @RequestParam(required = false) String startTime,
+            @RequestParam(required = false) String endTime,
+            @RequestParam(required = false) String callId,
+            @RequestParam(required = false) String remoteHost
     ){
-        return cloudRecordService.addTask(app, stream, startTime, endTime, callId, remoteHost);
+        return cloudRecordService.addTask(app, stream, mediaServerId, startTime, endTime, callId, remoteHost);
+    }
+
+    @ResponseBody
+    @GetMapping("/task/list")
+    @Operation(summary = "鏌ヨ鍚堝苟浠诲姟")
+    @Parameter(name = "taskId", description = "浠诲姟Id", required = false)
+    @Parameter(name = "mediaServerId", description = "娴佸獟浣揑D", required = false)
+    @Parameter(name = "isEnd", description = "鏄惁缁撴潫", required = false)
+    public JSONArray queryTaskList(
+            @RequestParam(required = false) String taskId,
+            @RequestParam(required = false) String mediaServerId,
+            @RequestParam(required = false) Boolean isEnd
+    ){
+        return cloudRecordService.queryTask(taskId, mediaServerId, isEnd);
+    }
+
+    @ResponseBody
+    @GetMapping("/collect/add")
+    @Operation(summary = "娣诲姞鏀惰棌")
+    @Parameter(name = "app", description = "搴旂敤鍚�", required = true)
+    @Parameter(name = "stream", description = "娴両D", required = true)
+    @Parameter(name = "mediaServerId", description = "娴佸獟浣揑D", required = false)
+    @Parameter(name = "startTime", description = "閴存潈ID", required = false)
+    @Parameter(name = "endTime", description = "閴存潈ID", required = false)
+    @Parameter(name = "callId", description = "閴存潈ID", required = false)
+    @Parameter(name = "collectType", description = "鏀惰棌绫诲瀷", required = false)
+    public JSONArray addCollect(
+            @RequestParam(required = false) String taskId,
+            @RequestParam(required = false) String mediaServerId,
+            @RequestParam(required = false) Boolean isEnd
+    ){
+        return cloudRecordService.queryTask(taskId, mediaServerId, isEnd);
     }
 
 

--
Gitblit v1.8.0