content: package com.genersoft.iot.vmp.vmanager.cloudRecord;
  
  import com.alibaba.fastjson2.JSONArray;
  import com.genersoft.iot.vmp.common.StreamInfo;
  import com.genersoft.iot.vmp.conf.UserSetting;
  import com.genersoft.iot.vmp.conf.exception.ControllerException;
  import com.genersoft.iot.vmp.conf.security.JwtUtils;
  import com.genersoft.iot.vmp.media.bean.MediaServer;
  import com.genersoft.iot.vmp.media.service.IMediaServerService;
  import com.genersoft.iot.vmp.service.ICloudRecordService;
  import com.genersoft.iot.vmp.service.bean.CloudRecordItem;
  import com.genersoft.iot.vmp.service.bean.DownloadFileInfo;
  import com.genersoft.iot.vmp.service.bean.ErrorCallback;
  import com.genersoft.iot.vmp.service.bean.InviteErrorCode;
  import com.genersoft.iot.vmp.streamPush.bean.BatchRemoveParam;
  import com.genersoft.iot.vmp.utils.DateUtil;
  import com.genersoft.iot.vmp.vmanager.bean.ErrorCode;
  import com.genersoft.iot.vmp.vmanager.bean.StreamContent;
  import com.genersoft.iot.vmp.vmanager.bean.WVPResult;
  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 lombok.extern.slf4j.Slf4j;
  import org.apache.commons.lang3.ObjectUtils;
  import org.springframework.beans.factory.annotation.Autowired;
  import org.springframework.web.bind.annotation.*;
  import org.springframework.web.context.request.async.DeferredResult;
  
  import javax.servlet.http.HttpServletRequest;
  import javax.servlet.http.HttpServletResponse;
  import java.io.File;
  import java.io.FileInputStream;
  import java.io.IOException;
  import java.net.MalformedURLException;
  import java.net.URL;
  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 = "云端录像接口")
  @Slf4j
  @RestController
  @RequestMapping("/api/cloud/record")
  public class CloudRecordController {
  
  
      @Autowired
      private ICloudRecordService cloudRecordService;
  
      @Autowired
      private IMediaServerService mediaServerService;
  
      @Autowired
      private UserSetting userSetting;
  
  
      @ResponseBody
      @GetMapping("/date/list")
      @Operation(summary = "查询存在云端录像的日期", security = @SecurityRequirement(name = JwtUtils.HEADER))
      @Parameter(name = "app", description = "应用名", required = true)
      @Parameter(name = "stream", description = "流ID", required = true)
      @Parameter(name = "year", description = "年，置空则查询当年", required = false)
      @Parameter(name = "month", description = "月，置空则查询当月", required = false)
      @Parameter(name = "mediaServerId", description = "流媒体ID，置空则查询全部", required = false)
      public List<String> openRtpServer(
              @RequestParam(required = true) String app,
              @RequestParam(required = true) String stream,
              @RequestParam(required = false) Integer year,
              @RequestParam(required = false) Integer month,
              @RequestParam(required = false) String mediaServerId
  
      ) {
          log.info("[云端录像] 查询存在云端录像的日期 app->{}, stream->{}, mediaServerId->{}, year->{}, month->{}", app, stream, mediaServerId, year, month);
          Calendar calendar = Calendar.getInstance();
          if (ObjectUtils.isEmpty(year)) {
              year = calendar.get(Calendar.YEAR);
          }
          if (ObjectUtils.isEmpty(month)) {
              month = calendar.get(Calendar.MONTH) + 1;
          }
          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.getAllOnlineList();
          }
          if (mediaServers.isEmpty()) {
              return new ArrayList<>();
          }
  
          return cloudRecordService.getDateList(app, stream, year, month, mediaServers);
      }
  
      @ResponseBody
      @GetMapping("/list")
      @Operation(summary = "分页查询云端录像", security = @SecurityRequirement(name = JwtUtils.HEADER))
      @Parameter(name = "query", description = "检索内容", required = false)
      @Parameter(name = "app", description = "应用名", required = false)
      @Parameter(name = "stream", description = "流ID", 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 = "流媒体ID，置空则查询全部流媒体", required = false)
      @Parameter(name = "callId", description = "每次录像的唯一标识，置空则查询全部流媒体", required = false)
      @Parameter(name = "ascOrder", description = "是否升序排序， 升序： true， 降序： false", required = false)
      public PageInfo<CloudRecordItem> openRtpServer(@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) Boolean ascOrder
  
      ) {
          log.info("[云端录像] 查询 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 = null;
          }
          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;
          }
          return cloudRecordService.getList(page, count, query, app, stream, startTime, endTime, mediaServers, callId, ascOrder);
      }
  
      @ResponseBody
      @GetMapping("/task/add")
      @Operation(summary = "添加合并任务")
      @Parameter(name = "app", description = "应用名", required = false)
      @Parameter(name = "stream", description = "流ID", required = false)
      @Parameter(name = "mediaServerId", description = "流媒体ID", 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(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) {
          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
      @GetMapping("/task/list")
      @Operation(summary = "查询合并任务")
      @Parameter(name = "taskId", description = "任务Id", required = false)
      @Parameter(name = "mediaServerId", description = "流媒体ID", 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) {
          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 = false)
      @Parameter(name = "stream", description = "流ID", required = false)
      @Parameter(name = "mediaServerId", description = "流媒体ID", 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 = "录像记录的ID，用于精准收藏一个视频文件", required = false)
      public int addCollect(@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) {
          log.info("[云端录像] 添加收藏，app={}，stream={},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 = "流ID", required = false)
      @Parameter(name = "mediaServerId", description = "流媒体ID", 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 = "录像记录的ID，用于精准精准移除一个视频文件的收藏", 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) {
          log.info("[云端录像] 移除收藏，app={}，stream={},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 = "录像记录的ID", required = true)
      public DownloadFileInfo getPlayUrlPath(@RequestParam(required = true) Integer recordId) {
          return cloudRecordService.getPlayUrlPath(recordId);
      }
  
      @ResponseBody
      @GetMapping("/loadRecord")
      @Operation(summary = "加载录像文件形成播放地址")
      @Parameter(name = "app", description = "应用名", required = true)
      @Parameter(name = "stream", description = "流ID", required = true)
      @Parameter(name = "cloudRecordId", description = "云端录像ID", required = true)
      public DeferredResult<WVPResult<StreamContent>> loadRecord(
              HttpServletRequest request,
              @RequestParam(required = true) String app,
              @RequestParam(required = true) String stream,
              @RequestParam(required = true) int cloudRecordId
              ) {
          DeferredResult<WVPResult<StreamContent>> result = new DeferredResult<>();
  
          result.onTimeout(()->{
              log.info("[加载录像文件超时] app={}, stream={}, cloudRecordId={}", app, stream, cloudRecordId);
              WVPResult<StreamContent> wvpResult = new WVPResult<>();
              wvpResult.setCode(ErrorCode.ERROR100.getCode());
              wvpResult.setMsg("加载录像文件超时");
              result.setResult(wvpResult);
          });
  
          ErrorCallback<StreamInfo> callback = (code, msg, streamInfo) -> {
  
              WVPResult<StreamContent> wvpResult = new WVPResult<>();
              if (code == InviteErrorCode.SUCCESS.getCode()) {
                  wvpResult.setCode(ErrorCode.SUCCESS.getCode());
                  wvpResult.setMsg(ErrorCode.SUCCESS.getMsg());
  
                  if (streamInfo != null) {
                      if (userSetting.getUseSourceIpAsStreamIp()) {
                          streamInfo=streamInfo.clone();//深拷贝
                          String host;
                          try {
                              URL url=new URL(request.getRequestURL().toString());
                              host=url.getHost();
                          } catch (MalformedURLException e) {
                              host=request.getLocalAddr();
                          }
                          streamInfo.changeStreamIp(host);
                      }
                      if (!org.springframework.util.ObjectUtils.isEmpty(streamInfo.getMediaServer().getTranscodeSuffix()) && !"null".equalsIgnoreCase(streamInfo.getMediaServer().getTranscodeSuffix())) {
                          streamInfo.setStream(streamInfo.getStream() + "_" + streamInfo.getMediaServer().getTranscodeSuffix());
                      }
                      wvpResult.setData(new StreamContent(streamInfo));
                  }else {
                      wvpResult.setCode(code);
                      wvpResult.setMsg(msg);
                  }
              }else {
                  wvpResult.setCode(code);
                  wvpResult.setMsg(msg);
              }
              result.setResult(wvpResult);
          };
  
          cloudRecordService.loadMP4File(app, stream, cloudRecordId, callback);
          return result;
      }
  
      @ResponseBody
      @GetMapping("/seek")
      @Operation(summary = "定位录像播放到制定位置")
      @Parameter(name = "mediaServerId", description = "使用的节点Id", required = true)
      @Parameter(name = "app", description = "应用名", required = true)
      @Parameter(name = "stream", description = "流ID", required = true)
      @Parameter(name = "seek", description = "要定位的时间位置，从录像开始的时间算起", required = true)
      public void seekRecord(
              @RequestParam(required = true) String mediaServerId,
              @RequestParam(required = true) String app,
              @RequestParam(required = true) String stream,
              @RequestParam(required = true) Double seek,
              @RequestParam(required = false) String schema
              ) {
          if (schema == null) {
              schema = "ts";
          }
          cloudRecordService.seekRecord(mediaServerId, app, stream, seek, schema);
      }
  
      @ResponseBody
      @GetMapping("/speed")
      @Operation(summary = "设置录像播放速度")
      @Parameter(name = "mediaServerId", description = "使用的节点Id", required = true)
      @Parameter(name = "app", description = "应用名", required = true)
      @Parameter(name = "stream", description = "流ID", required = true)
      @Parameter(name = "speed", description = "要设置的录像倍速", required = true)
      public void setRecordSpeed(
              @RequestParam(required = true) String mediaServerId,
              @RequestParam(required = true) String app,
              @RequestParam(required = true) String stream,
              @RequestParam(required = true) Integer speed,
              @RequestParam(required = false) String schema
      ) {
          if (schema == null) {
              schema = "ts";
          }
  
          cloudRecordService.setRecordSpeed(mediaServerId, app, stream, speed, schema);
      }
  
      @ResponseBody
      @DeleteMapping("/delete")
      @Operation(summary = "删除录像文件")
      @Parameter(name = "ids", description = "文件ID集合", required = true)
      public void deleteFileByIds(@RequestBody BatchRemoveParam ids) {
          cloudRecordService.deleteFileByIds(ids.getIds());
      }
  
      /************************* 以下这些接口只适合wvp和zlm部署在同一台服务器的情况，且wvp只有一个zlm节点的情况 ***************************************/
  
      /**
       * 下载指定录像文件的压缩包
       * @param query 检索内容
       * @param app 应用名
       * @param stream 流ID
       * @param startTime 开始时间(yyyy-MM-dd HH:mm:ss)
       * @param endTime 结束时间(yyyy-MM-dd HH:mm:ss)
       * @param mediaServerId 流媒体ID，置空则查询全部流媒体
       * @param callId 每次录像的唯一标识，置空则查询全部流媒体
       * @param ids 指定的Id
       */
      @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
  
      ) {
          log.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((long)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) {
              log.error("[下载指定录像文件的压缩包] 失败： 查询 app->{}, stream->{}, mediaServerId->{}, startTime->{}, endTime->{}, callId->{}", app, stream, mediaServerId, startTime, endTime, callId, e);
          }
      }
  
      /**
       *
       * @param query 检索内容
       * @param app 应用名
       * @param stream 流ID
       * @param startTime 开始时间(yyyy-MM-dd HH:mm:ss)
       * @param endTime 结束时间(yyyy-MM-dd HH:mm:ss)
       * @param mediaServerId 流媒体ID，置空则查询全部流媒体
       * @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 = "流ID", 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 = "流媒体ID，置空则查询全部流媒体", 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
  
      ) {
          log.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 = null;
          }
          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, null);
          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((long)cloudRecordItem.getStartTime()));
                  cloudRecordUrl.setPlayUrl(remoteHost + "/index/api/downloadFile?file_path=" + cloudRecordItem.getFilePath());
                  cloudRecordUrlList.add(cloudRecordUrl);
              }
              cloudRecordUrlPageInfo.setList(cloudRecordUrlList);
          }
          return cloudRecordUrlPageInfo;
      }
  }
  