From 2127cbeca3c2f2de31b7f70b2841cdb2ee259e1a Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期三, 05 六月 2024 22:45:13 +0800
Subject: [PATCH] 调整收到移动位置订阅后开启定时任务

---
 src/main/java/com/genersoft/iot/vmp/service/bean/CloudRecordItem.java |   49 +++++++++++++++++++++++++++++++++++++++++++------
 1 files changed, 43 insertions(+), 6 deletions(-)

diff --git a/src/main/java/com/genersoft/iot/vmp/service/bean/CloudRecordItem.java b/src/main/java/com/genersoft/iot/vmp/service/bean/CloudRecordItem.java
index b374c13..c6e84de 100644
--- a/src/main/java/com/genersoft/iot/vmp/service/bean/CloudRecordItem.java
+++ b/src/main/java/com/genersoft/iot/vmp/service/bean/CloudRecordItem.java
@@ -1,5 +1,10 @@
 package com.genersoft.iot.vmp.service.bean;
 
+import com.genersoft.iot.vmp.media.zlm.dto.hook.OnRecordMp4HookParam;
+import com.genersoft.iot.vmp.utils.MediaServerUtils;
+
+import java.util.Map;
+
 /**
  * 浜戠褰曞儚鏁版嵁
  */
@@ -55,9 +60,14 @@
     private String folder;
     
     /**
-     * 鏀惰棌绫诲瀷锛屾敹钘忕殑鏂囦欢涓嶇Щ闄�
+     * 鏀惰棌锛屾敹钘忕殑鏂囦欢涓嶇Щ闄�
      */
-    private String collectType;
+    private Boolean collect;
+
+    /**
+     * 淇濈暀锛屾敹钘忕殑鏂囦欢涓嶇Щ闄�
+     */
+    private Boolean reserve;
     
     /**
      * 鏂囦欢澶у皬
@@ -68,6 +78,25 @@
      * 鏂囦欢鏃堕暱
      */
     private long timeLen;
+
+    public static CloudRecordItem getInstance(OnRecordMp4HookParam param) {
+        CloudRecordItem cloudRecordItem = new CloudRecordItem();
+        cloudRecordItem.setApp(param.getApp());
+        cloudRecordItem.setStream(param.getStream());
+        cloudRecordItem.setStartTime(param.getStart_time()*1000);
+        cloudRecordItem.setFileName(param.getFile_name());
+        cloudRecordItem.setFolder(param.getFolder());
+        cloudRecordItem.setFileSize(param.getFile_size());
+        cloudRecordItem.setFilePath(param.getFile_path());
+        cloudRecordItem.setMediaServerId(param.getMediaServerId());
+        cloudRecordItem.setTimeLen((long) param.getTime_len() * 1000);
+        cloudRecordItem.setEndTime((param.getStart_time() + (long)param.getTime_len()) * 1000);
+        Map<String, String> paramsMap = MediaServerUtils.urlParamToMap(param.getParams());
+        if (paramsMap.get("callId") != null) {
+            cloudRecordItem.setCallId(paramsMap.get("callId"));
+        }
+        return cloudRecordItem;
+    }
 
     public int getId() {
         return id;
@@ -165,11 +194,19 @@
         this.timeLen = timeLen;
     }
 
-    public String getCollectType() {
-        return collectType;
+    public Boolean getCollect() {
+        return collect;
     }
 
-    public void setCollectType(String collectType) {
-        this.collectType = collectType;
+    public void setCollect(Boolean collect) {
+        this.collect = collect;
+    }
+
+    public Boolean getReserve() {
+        return reserve;
+    }
+
+    public void setReserve(Boolean reserve) {
+        this.reserve = reserve;
     }
 }

--
Gitblit v1.8.0