From bec35ebf940f5cb1f0e2b9052d6dfb4da3ab7391 Mon Sep 17 00:00:00 2001
From: 648540858 <648540858@qq.com>
Date: 星期二, 28 五月 2024 16:06:08 +0800
Subject: [PATCH] 调整录像进度获取流程
---
src/main/java/com/genersoft/iot/vmp/vmanager/cloudRecord/CloudRecordController.java | 393 +++++++++++++++++++++++++++++++++++++++++++++++--------
1 files changed, 332 insertions(+), 61 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 cb731cd..ecf3a8d 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,33 +1,37 @@
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;
-import com.genersoft.iot.vmp.media.zlm.SendRtpPortManager;
-import com.genersoft.iot.vmp.media.zlm.ZLMServerFactory;
-import com.genersoft.iot.vmp.media.zlm.ZlmHttpHookSubscribe;
-import com.genersoft.iot.vmp.media.zlm.dto.MediaServerItem;
+import com.genersoft.iot.vmp.conf.security.JwtUtils;
+import com.genersoft.iot.vmp.media.bean.MediaServer;
import com.genersoft.iot.vmp.service.ICloudRecordService;
-import com.genersoft.iot.vmp.service.IMediaServerService;
+import com.genersoft.iot.vmp.media.service.IMediaServerService;
import com.genersoft.iot.vmp.service.bean.CloudRecordItem;
+import com.genersoft.iot.vmp.service.bean.DownloadFileInfo;
+import com.genersoft.iot.vmp.utils.DateUtil;
import com.genersoft.iot.vmp.vmanager.bean.ErrorCode;
-import com.genersoft.iot.vmp.vmanager.bean.RecordFile;
+import com.genersoft.iot.vmp.vmanager.cloudRecord.bean.CloudRecordUrl;
import com.github.pagehelper.PageInfo;
import io.swagger.v3.oas.annotations.Operation;
import io.swagger.v3.oas.annotations.Parameter;
+import io.swagger.v3.oas.annotations.security.SecurityRequirement;
import io.swagger.v3.oas.annotations.tags.Tag;
import org.apache.commons.lang3.ObjectUtils;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
-import org.springframework.data.redis.core.RedisTemplate;
import org.springframework.web.bind.annotation.*;
+import javax.servlet.http.HttpServletRequest;
+import javax.servlet.http.HttpServletResponse;
+import java.io.File;
+import java.io.FileInputStream;
+import java.io.IOException;
import java.util.ArrayList;
import java.util.Calendar;
import java.util.List;
+import java.util.zip.ZipEntry;
+import java.util.zip.ZipOutputStream;
@SuppressWarnings("rawtypes")
@Tag(name = "浜戠褰曞儚鎺ュ彛")
@@ -36,11 +40,6 @@
@RequestMapping("/api/cloud/record")
public class CloudRecordController {
- @Autowired
- private ZLMServerFactory zlmServerFactory;
-
- @Autowired
- private SendRtpPortManager sendRtpPortManager;
private final static Logger logger = LoggerFactory.getLogger(CloudRecordController.class);
@@ -50,26 +49,18 @@
@Autowired
private IMediaServerService mediaServerService;
- @Autowired
- private UserSetting userSetting;
-
- @Autowired
- private DynamicTask dynamicTask;
-
- @Autowired
- private RedisTemplate<Object, Object> redisTemplate;
@ResponseBody
@GetMapping("/date/list")
- @Operation(summary = "鏌ヨ瀛樺湪浜戠褰曞儚鐨勬棩鏈�")
+ @Operation(summary = "鏌ヨ瀛樺湪浜戠褰曞儚鐨勬棩鏈�", security = @SecurityRequirement(name = JwtUtils.HEADER))
@Parameter(name = "app", description = "搴旂敤鍚�", required = true)
@Parameter(name = "stream", description = "娴両D", required = true)
@Parameter(name = "year", description = "骞达紝缃┖鍒欐煡璇㈠綋骞�", required = false)
@Parameter(name = "month", description = "鏈堬紝缃┖鍒欐煡璇㈠綋鏈�", required = false)
@Parameter(name = "mediaServerId", description = "娴佸獟浣揑D锛岀疆绌哄垯鏌ヨ鍏ㄩ儴", required = false)
public List<String> openRtpServer(
- @RequestParam String app,
- @RequestParam String stream,
+ @RequestParam(required = true) String app,
+ @RequestParam(required = true) String stream,
@RequestParam(required = false) int year,
@RequestParam(required = false) int month,
@RequestParam(required = false) String mediaServerId
@@ -84,35 +75,36 @@
if (ObjectUtils.isEmpty(month)) {
month = calendar.get(Calendar.MONTH) + 1;
}
- List<MediaServerItem> mediaServerItems;
+ List<MediaServer> mediaServers;
if (!ObjectUtils.isEmpty(mediaServerId)) {
- mediaServerItems = new ArrayList<>();
- MediaServerItem mediaServerItem = mediaServerService.getOne(mediaServerId);
- if (mediaServerItem == null) {
+ mediaServers = new ArrayList<>();
+ MediaServer mediaServer = mediaServerService.getOne(mediaServerId);
+ if (mediaServer == null) {
throw new ControllerException(ErrorCode.ERROR100.getCode(), "鏈壘鍒版祦濯掍綋: " + mediaServerId);
}
- mediaServerItems.add(mediaServerItem);
+ mediaServers.add(mediaServer);
} else {
- mediaServerItems = mediaServerService.getAll();
+ mediaServers = mediaServerService.getAllOnlineList();
}
- if (mediaServerItems.isEmpty()) {
+ if (mediaServers.isEmpty()) {
return new ArrayList<>();
}
- return cloudRecordService.getDateList(app, stream, year, month, mediaServerItems);
+ return cloudRecordService.getDateList(app, stream, year, month, mediaServers);
}
@ResponseBody
@GetMapping("/list")
- @Operation(summary = "鍒嗛〉鏌ヨ浜戠褰曞儚")
+ @Operation(summary = "鍒嗛〉鏌ヨ浜戠褰曞儚", security = @SecurityRequirement(name = JwtUtils.HEADER))
@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 = "page", description = "褰撳墠椤�", required = true)
+ @Parameter(name = "count", description = "姣忛〉鏌ヨ鏁伴噺", 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)
+ @Parameter(name = "callId", description = "姣忔褰曞儚鐨勫敮涓�鏍囪瘑锛岀疆绌哄垯鏌ヨ鍏ㄩ儴娴佸獟浣�", required = false)
public PageInfo<CloudRecordItem> openRtpServer(
@RequestParam(required = false) String query,
@RequestParam(required = false) String app,
@@ -121,24 +113,25 @@
@RequestParam int count,
@RequestParam(required = false) String startTime,
@RequestParam(required = false) String endTime,
- @RequestParam(required = false) String mediaServerId
+ @RequestParam(required = false) String mediaServerId,
+ @RequestParam(required = false) String callId
) {
- logger.info("[浜戠褰曞儚] 鏌ヨ app->{}, stream->{}, mediaServerId->{}, page->{}, count->{}, startTime->{}, endTime->{}",
- app, stream, mediaServerId, page, count, startTime, endTime);
+ logger.info("[浜戠褰曞儚] 鏌ヨ app->{}, stream->{}, mediaServerId->{}, page->{}, count->{}, startTime->{}, endTime->{}, callId->{}",
+ app, stream, mediaServerId, page, count, startTime, endTime, callId);
- List<MediaServerItem> mediaServerItems;
+ List<MediaServer> mediaServers;
if (!ObjectUtils.isEmpty(mediaServerId)) {
- mediaServerItems = new ArrayList<>();
- MediaServerItem mediaServerItem = mediaServerService.getOne(mediaServerId);
- if (mediaServerItem == null) {
+ mediaServers = new ArrayList<>();
+ MediaServer mediaServer = mediaServerService.getOne(mediaServerId);
+ if (mediaServer == null) {
throw new ControllerException(ErrorCode.ERROR100.getCode(), "鏈壘鍒版祦濯掍綋: " + mediaServerId);
}
- mediaServerItems.add(mediaServerItem);
+ mediaServers.add(mediaServer);
} else {
- mediaServerItems = mediaServerService.getAll();
+ mediaServers = mediaServerService.getAllOnlineList();
}
- if (mediaServerItems.isEmpty()) {
+ if (mediaServers.isEmpty()) {
throw new ControllerException(ErrorCode.ERROR100.getCode(), "褰撳墠鏃犳祦濯掍綋");
}
if (query != null && ObjectUtils.isEmpty(query.trim())) {
@@ -156,29 +149,46 @@
if (endTime != null && ObjectUtils.isEmpty(endTime.trim())) {
endTime = null;
}
- return cloudRecordService.getList(page, count, query, app, stream, startTime, endTime, mediaServerItems);
+ if (callId != null && ObjectUtils.isEmpty(callId.trim())) {
+ callId = null;
+ }
+ return cloudRecordService.getList(page, count, query, app, stream, startTime, endTime, mediaServers, callId);
}
@ResponseBody
@GetMapping("/task/add")
@Operation(summary = "娣诲姞鍚堝苟浠诲姟")
- @Parameter(name = "app", description = "搴旂敤鍚�", required = true)
- @Parameter(name = "stream", description = "娴両D", required = true)
+ @Parameter(name = "app", description = "搴旂敤鍚�", required = false)
+ @Parameter(name = "stream", description = "娴両D", required = false)
@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(required = true) String app,
- @RequestParam(required = true) String stream,
+ HttpServletRequest request,
+ @RequestParam(required = false) String app,
+ @RequestParam(required = false) 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, mediaServerId, startTime, endTime, callId, remoteHost);
+ MediaServer mediaServer;
+ if (mediaServerId == null) {
+ mediaServer = mediaServerService.getDefaultMediaServer();
+ }else {
+ mediaServer = mediaServerService.getOne(mediaServerId);
+ }
+ if (mediaServer == null) {
+ throw new ControllerException(ErrorCode.ERROR100.getCode(), "鏈壘鍒板彲鐢ㄧ殑娴佸獟浣�");
+ }else {
+ if (remoteHost == null) {
+ remoteHost = request.getScheme() + "://" + mediaServer.getIp() + ":" + mediaServer.getRecordAssistPort();
+ }
+ }
+ return cloudRecordService.addTask(app, stream, mediaServer, startTime, endTime, callId, remoteHost, mediaServerId != null);
}
@ResponseBody
@@ -188,31 +198,292 @@
@Parameter(name = "mediaServerId", description = "娴佸獟浣揑D", required = false)
@Parameter(name = "isEnd", description = "鏄惁缁撴潫", required = false)
public JSONArray queryTaskList(
+ HttpServletRequest request,
+ @RequestParam(required = false) String app,
+ @RequestParam(required = false) String stream,
+ @RequestParam(required = false) String callId,
@RequestParam(required = false) String taskId,
@RequestParam(required = false) String mediaServerId,
@RequestParam(required = false) Boolean isEnd
){
- return cloudRecordService.queryTask(taskId, mediaServerId, isEnd);
+ if (ObjectUtils.isEmpty(mediaServerId)) {
+ mediaServerId = null;
+ }
+
+ return cloudRecordService.queryTask(app, stream, callId, taskId, mediaServerId, isEnd, request.getScheme());
}
@ResponseBody
@GetMapping("/collect/add")
@Operation(summary = "娣诲姞鏀惰棌")
- @Parameter(name = "app", description = "搴旂敤鍚�", required = true)
- @Parameter(name = "stream", description = "娴両D", required = true)
+ @Parameter(name = "app", description = "搴旂敤鍚�", required = false)
+ @Parameter(name = "stream", description = "娴両D", required = false)
@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,
+ @Parameter(name = "recordId", description = "褰曞儚璁板綍鐨処D锛岀敤浜庣簿鍑嗘敹钘忎竴涓棰戞枃浠�", required = false)
+ public int addCollect(
+ @RequestParam(required = false) String app,
+ @RequestParam(required = false) String stream,
@RequestParam(required = false) String mediaServerId,
- @RequestParam(required = false) Boolean isEnd
+ @RequestParam(required = false) String startTime,
+ @RequestParam(required = false) String endTime,
+ @RequestParam(required = false) String callId,
+ @RequestParam(required = false) Integer recordId
){
- return cloudRecordService.queryTask(taskId, mediaServerId, isEnd);
+ logger.info("[浜戠褰曞儚] 娣诲姞鏀惰棌锛宎pp={}锛宻tream={},mediaServerId={},startTime={},endTime={},callId={},recordId={}",
+ app, stream, mediaServerId, startTime, endTime, callId, recordId);
+ if (recordId != null) {
+ return cloudRecordService.changeCollectById(recordId, true);
+ }else {
+ return cloudRecordService.changeCollect(true, app, stream, mediaServerId, startTime, endTime, callId);
+ }
}
+ @ResponseBody
+ @GetMapping("/collect/delete")
+ @Operation(summary = "绉婚櫎鏀惰棌")
+ @Parameter(name = "app", description = "搴旂敤鍚�", required = false)
+ @Parameter(name = "stream", description = "娴両D", required = false)
+ @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 = "recordId", description = "褰曞儚璁板綍鐨処D锛岀敤浜庣簿鍑嗙簿鍑嗙Щ闄や竴涓棰戞枃浠剁殑鏀惰棌", required = false)
+ public int deleteCollect(
+ @RequestParam(required = false) String app,
+ @RequestParam(required = false) 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) Integer recordId
+ ){
+ logger.info("[浜戠褰曞儚] 绉婚櫎鏀惰棌锛宎pp={}锛宻tream={},mediaServerId={},startTime={},endTime={},callId={},recordId={}",
+ app, stream, mediaServerId, startTime, endTime, callId, recordId);
+ if (recordId != null) {
+ return cloudRecordService.changeCollectById(recordId, false);
+ }else {
+ return cloudRecordService.changeCollect(false, app, stream, mediaServerId, startTime, endTime, callId);
+ }
+ }
+ @ResponseBody
+ @GetMapping("/play/path")
+ @Operation(summary = "鑾峰彇鎾斁鍦板潃")
+ @Parameter(name = "recordId", description = "褰曞儚璁板綍鐨処D", required = true)
+ public DownloadFileInfo getPlayUrlPath(
+ @RequestParam(required = true) Integer recordId
+ ){
+ return cloudRecordService.getPlayUrlPath(recordId);
+ }
+ /************************* 浠ヤ笅杩欎簺鎺ュ彛鍙�傚悎wvp鍜寊lm閮ㄧ讲鍦ㄥ悓涓�鍙版湇鍔″櫒鐨勬儏鍐碉紝涓攚vp鍙湁涓�涓獄lm鑺傜偣鐨勬儏鍐� ***************************************/
+
+ /**
+ * 涓嬭浇鎸囧畾褰曞儚鏂囦欢鐨勫帇缂╁寘
+ * @param query 妫�绱㈠唴瀹�
+ * @param app 搴旂敤鍚�
+ * @param stream 娴両D
+ * @param startTime 寮�濮嬫椂闂�(yyyy-MM-dd HH:mm:ss)
+ * @param endTime 缁撴潫鏃堕棿(yyyy-MM-dd HH:mm:ss)
+ * @param mediaServerId 娴佸獟浣揑D锛岀疆绌哄垯鏌ヨ鍏ㄩ儴娴佸獟浣�
+ * @param callId 姣忔褰曞儚鐨勫敮涓�鏍囪瘑锛岀疆绌哄垯鏌ヨ鍏ㄩ儴娴佸獟浣�
+ * @param ids 鎸囧畾鐨処d
+ */
+ @ResponseBody
+ @GetMapping("/zip")
+ public void downloadZipFile(
+ HttpServletResponse response,
+ @RequestParam(required = false) String query,
+ @RequestParam(required = false) String app,
+ @RequestParam(required = false) String stream,
+ @RequestParam(required = false) String startTime,
+ @RequestParam(required = false) String endTime,
+ @RequestParam(required = false) String mediaServerId,
+ @RequestParam(required = false) String callId,
+ @RequestParam(required = false) List<Integer> ids
+
+ ) {
+ logger.info("[涓嬭浇鎸囧畾褰曞儚鏂囦欢鐨勫帇缂╁寘] 鏌ヨ app->{}, stream->{}, mediaServerId->{}, startTime->{}, endTime->{}, callId->{}",
+ app, stream, mediaServerId, startTime, endTime, callId);
+
+ List<MediaServer> mediaServers;
+ if (!ObjectUtils.isEmpty(mediaServerId)) {
+ mediaServers = new ArrayList<>();
+ MediaServer mediaServer = mediaServerService.getOne(mediaServerId);
+ if (mediaServer == null) {
+ throw new ControllerException(ErrorCode.ERROR100.getCode(), "鏈壘鍒版祦濯掍綋: " + mediaServerId);
+ }
+ mediaServers.add(mediaServer);
+ } else {
+ mediaServers = mediaServerService.getAll();
+ }
+ if (mediaServers.isEmpty()) {
+ throw new ControllerException(ErrorCode.ERROR100.getCode(), "褰撳墠鏃犳祦濯掍綋");
+ }
+ 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;
+ }
+ if (callId != null && ObjectUtils.isEmpty(callId.trim())) {
+ callId = null;
+ }
+ if (stream != null && callId != null) {
+ response.addHeader( "Content-Disposition", "attachment;filename=" + stream + "_" + callId + ".zip" );
+ }
+ List<CloudRecordItem> cloudRecordItemList = cloudRecordService.getAllList(query, app, stream, startTime, endTime, mediaServers, callId, ids);
+ if (ObjectUtils.isEmpty(cloudRecordItemList)) {
+ return;
+ }
+ try {
+ ZipOutputStream zos = new ZipOutputStream(response.getOutputStream());
+ for (CloudRecordItem cloudRecordItem : cloudRecordItemList) {
+ zos.putNextEntry(new ZipEntry(DateUtil.timestampMsToUrlToyyyy_MM_dd_HH_mm_ss(cloudRecordItem.getStartTime()) + ".mp4"));
+ File file = new File(cloudRecordItem.getFilePath());
+ if (!file.exists() || file.isDirectory()) {
+ continue;
+ }
+ FileInputStream fis = new FileInputStream(cloudRecordItem.getFilePath());
+ byte[] buf = new byte[2*1024];
+ int len;
+ while ((len = fis.read(buf)) != -1){
+ zos.write(buf, 0, len);
+ }
+ zos.closeEntry();
+ fis.close();
+ }
+ zos.close();
+ } catch (IOException e) {
+ logger.error("[涓嬭浇鎸囧畾褰曞儚鏂囦欢鐨勫帇缂╁寘] 澶辫触锛� 鏌ヨ app->{}, stream->{}, mediaServerId->{}, startTime->{}, endTime->{}, callId->{}",
+ app, stream, mediaServerId, startTime, endTime, callId, e);
+ }
+ }
+
+ /**
+ *
+ * @param query 妫�绱㈠唴瀹�
+ * @param app 搴旂敤鍚�
+ * @param stream 娴両D
+ * @param startTime 寮�濮嬫椂闂�(yyyy-MM-dd HH:mm:ss)
+ * @param endTime 缁撴潫鏃堕棿(yyyy-MM-dd HH:mm:ss)
+ * @param mediaServerId 娴佸獟浣揑D锛岀疆绌哄垯鏌ヨ鍏ㄩ儴娴佸獟浣�
+ * @param callId 姣忔褰曞儚鐨勫敮涓�鏍囪瘑锛岀疆绌哄垯鏌ヨ鍏ㄩ儴娴佸獟浣�
+ * @param remoteHost 鎷兼帴鎾斁鍦板潃鏃朵娇鐢ㄧ殑杩滅▼鍦板潃
+ */
+ @ResponseBody
+ @GetMapping("/list-url")
+ @Operation(summary = "鍒嗛〉鏌ヨ浜戠褰曞儚", security = @SecurityRequirement(name = JwtUtils.HEADER))
+ @Parameter(name = "query", description = "妫�绱㈠唴瀹�", required = false)
+ @Parameter(name = "app", description = "搴旂敤鍚�", required = false)
+ @Parameter(name = "stream", description = "娴両D", required = false)
+ @Parameter(name = "page", description = "褰撳墠椤�", required = true)
+ @Parameter(name = "count", description = "姣忛〉鏌ヨ鏁伴噺", 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)
+ @Parameter(name = "callId", description = "姣忔褰曞儚鐨勫敮涓�鏍囪瘑锛岀疆绌哄垯鏌ヨ鍏ㄩ儴娴佸獟浣�", required = false)
+ public PageInfo<CloudRecordUrl> getListWithUrl(
+ HttpServletRequest request,
+ @RequestParam(required = false) String query,
+ @RequestParam(required = false) String app,
+ @RequestParam(required = false) String stream,
+ @RequestParam int page,
+ @RequestParam int count,
+ @RequestParam(required = false) String startTime,
+ @RequestParam(required = false) String endTime,
+ @RequestParam(required = false) String mediaServerId,
+ @RequestParam(required = false) String callId,
+ @RequestParam(required = false) String remoteHost
+
+ ) {
+ logger.info("[浜戠褰曞儚] 鏌ヨURL app->{}, stream->{}, mediaServerId->{}, page->{}, count->{}, startTime->{}, endTime->{}, callId->{}",
+ app, stream, mediaServerId, page, count, startTime, endTime, callId);
+
+ List<MediaServer> mediaServers;
+ if (!ObjectUtils.isEmpty(mediaServerId)) {
+ mediaServers = new ArrayList<>();
+ MediaServer mediaServer = mediaServerService.getOne(mediaServerId);
+ if (mediaServer == null) {
+ throw new ControllerException(ErrorCode.ERROR100.getCode(), "鏈壘鍒版祦濯掍綋: " + mediaServerId);
+ }
+ mediaServers.add(mediaServer);
+ } else {
+ mediaServers = mediaServerService.getAll();
+ }
+ if (mediaServers.isEmpty()) {
+ throw new ControllerException(ErrorCode.ERROR100.getCode(), "褰撳墠鏃犳祦濯掍綋");
+ }
+ 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;
+ }
+ if (callId != null && ObjectUtils.isEmpty(callId.trim())) {
+ callId = null;
+ }
+ MediaServer mediaServer = mediaServerService.getDefaultMediaServer();
+ if (mediaServer == null) {
+ throw new ControllerException(ErrorCode.ERROR100.getCode(), "鏈壘鍒版祦濯掍綋鑺傜偣");
+ }
+ if (remoteHost == null) {
+ remoteHost = request.getScheme() + "://" + request.getLocalAddr() + ":" +
+ (request.getScheme().equals("https")? mediaServer.getHttpSSlPort() : mediaServer.getHttpPort());
+ }
+ PageInfo<CloudRecordItem> cloudRecordItemPageInfo = cloudRecordService.getList(page, count, query, app, stream, startTime, endTime, mediaServers, callId);
+ PageInfo<CloudRecordUrl> cloudRecordUrlPageInfo = new PageInfo<>();
+ if (!ObjectUtils.isEmpty(cloudRecordItemPageInfo)) {
+ cloudRecordUrlPageInfo.setPageNum(cloudRecordItemPageInfo.getPageNum());
+ cloudRecordUrlPageInfo.setPageSize(cloudRecordItemPageInfo.getPageSize());
+ cloudRecordUrlPageInfo.setSize(cloudRecordItemPageInfo.getSize());
+ cloudRecordUrlPageInfo.setEndRow(cloudRecordItemPageInfo.getEndRow());
+ cloudRecordUrlPageInfo.setStartRow(cloudRecordItemPageInfo.getStartRow());
+ cloudRecordUrlPageInfo.setPages(cloudRecordItemPageInfo.getPages());
+ cloudRecordUrlPageInfo.setPrePage(cloudRecordItemPageInfo.getPrePage());
+ cloudRecordUrlPageInfo.setNextPage(cloudRecordItemPageInfo.getNextPage());
+ cloudRecordUrlPageInfo.setIsFirstPage(cloudRecordItemPageInfo.isIsFirstPage());
+ cloudRecordUrlPageInfo.setIsLastPage(cloudRecordItemPageInfo.isIsLastPage());
+ cloudRecordUrlPageInfo.setHasPreviousPage(cloudRecordItemPageInfo.isHasPreviousPage());
+ cloudRecordUrlPageInfo.setHasNextPage(cloudRecordItemPageInfo.isHasNextPage());
+ cloudRecordUrlPageInfo.setNavigatePages(cloudRecordItemPageInfo.getNavigatePages());
+ cloudRecordUrlPageInfo.setNavigateFirstPage(cloudRecordItemPageInfo.getNavigateFirstPage());
+ cloudRecordUrlPageInfo.setNavigateLastPage(cloudRecordItemPageInfo.getNavigateLastPage());
+ cloudRecordUrlPageInfo.setNavigatepageNums(cloudRecordItemPageInfo.getNavigatepageNums());
+ cloudRecordUrlPageInfo.setTotal(cloudRecordItemPageInfo.getTotal());
+ List<CloudRecordUrl> cloudRecordUrlList = new ArrayList<>(cloudRecordItemPageInfo.getList().size());
+ List<CloudRecordItem> cloudRecordItemList = cloudRecordItemPageInfo.getList();
+ for (CloudRecordItem cloudRecordItem : cloudRecordItemList) {
+ CloudRecordUrl cloudRecordUrl = new CloudRecordUrl();
+ cloudRecordUrl.setId(cloudRecordItem.getId());
+ cloudRecordUrl.setDownloadUrl(remoteHost + "/index/api/downloadFile?file_path=" + cloudRecordItem.getFilePath()
+ + "&save_name=" + cloudRecordItem.getStream() + "_" + cloudRecordItem.getCallId() + "_" + DateUtil.timestampMsToUrlToyyyy_MM_dd_HH_mm_ss(cloudRecordItem.getStartTime()) );
+ cloudRecordUrl.setPlayUrl(remoteHost + "/index/api/downloadFile?file_path=" + cloudRecordItem.getFilePath());
+ cloudRecordUrlList.add(cloudRecordUrl);
+ }
+ cloudRecordUrlPageInfo.setList(cloudRecordUrlList);
+ }
+ return cloudRecordUrlPageInfo;
+ }
}
--
Gitblit v1.8.0