录像播放及下载接口如何返回在线m3u8格式视频流？

随着视频智能安防监控系统的不断普及，安防监控平台在各行各业的项目中也得到了充分利用。未来AI智能将会成为安防监控的主导方向，TSINGSEE青犀视频根据行业需求，不断提升现有产品的适应能力，将进一步推动智能安防监控系统的发展。

目前EasyNVR作为TSINGSEE青犀视频开发的稳定可靠的智能安防监控平台，具备视频采集、直播、转码、分发等能力，其中在录像功能方面，不仅可以调取录像视频直接回放，还可以将录像文件通过接口调用下载，但目前下载和播放的都是mp4格式的视频文件。

部分项目团队对EasyNVR的录像接口调用功能提出了新的需求，即需要在指定时间段录像播放及下载接口返回在线的m3u8格式的视频，在线观看。

EasyNVR的录像文件就是m3u8格式的文件，存储在服务器中，调用指定时间段录像播放及下载接口时，EasyNVR将录像文件利用了ffmpeg转成了mp4，所以下载和播放的都是mp4格式的视频。

实现该项目的需求，我们可以定位到EasyNVR接口中找到指定时间段录像播放及下载接口具体逻辑处。首先将接口改变下，需要添加个字段判断获取m3u8格式的视频还是mp4的视频，这个字段为file，这个新接口的file字段不能为空。参考代码如下：

/**
 * @api {get} /api/v2/record/video/:operate/:file/:id/:starttime/:endtime 指定时间段录像播放及下载
 * @apiGroup record
 * @apiParam {String=play,download} operate 调用操作 play:播放 download下载
 * @apiParam {String=mp4,m3u8} file 文件类别 m3u8:(只提供在线地址) mp4:支持
 * @apiParam {String} id 通道号
 * @apiParam {String} starttime 开始时间, YYYYMMDDHHmmss
 * @apiParam {String} endtime 结束时间, YYYYMMDDHHmmss
 * @apiSuccessExample 播放示例
 * 播放mp4
 * http://localhost:10800/api/v2/record/video/play/mp4/1/20180911101139/20180911101248
 * 播放m3u8
 * http://localhost:10800/api/v2/record/video/play/m3u8/1/20180911101139/20180911101248
 * @apiErrorExample 下载示例 (不支持下载m3u8)
 * 下载mp4
 * http://localhost:10800/api/v2/record/video/download/mp4/1/20180911101139/20180911101248
 */
func (h *APIHandler) VideoFileMP4(c *gin.Context) {
   operate := c.Param("operate")
   fileType := strings.ToLower(c.Param("file"))
   if fileType == "" {
      c.AbortWithStatusJSON(http.StatusBadRequest, "文件类别不能为空")
      return
   }
   var err error
   id := c.Param("id")
   if id == "" {
      c.AbortWithStatusJSON(http.StatusBadRequest, "未指定通道号")
      return
   }
   streamID := channels.StreamIDString(id)
   starttime := c.Param("starttime")
   endtime := c.Param("endtime")
   if matched, err := regexp.MatchString(`^\d{14}$`, starttime); !matched || err != nil {
      c.AbortWithStatusJSON(http.StatusBadRequest, "开始时间格式不合法,正确格式：YYYYMMDDHHmmss")
      return
   }
   if matched, err := regexp.MatchString(`^\d{14}$`, endtime); !matched || err != nil {
      c.AbortWithStatusJSON(http.StatusBadRequest, "结束时间格式不合法,正确格式：YYYYMMDDHHmmss")
      return
   }
   start := ff.StrYYYYMMDDHHmmssToTime(starttime)
   end := ff.StrYYYYMMDDHHmmssToTime(endtime)
   if start.After(end) {
      c.AbortWithStatusJSON(http.StatusBadRequest, "开始时间要小于结束时间")
      return
   }
   if end.Unix()-start.Unix() > 10800 {
      c.AbortWithStatusJSON(http.StatusBadRequest, "最大播放/下载录像间隔是3小时！")
      return
   }
   videoID := fmt.Sprintf(`%s_%s_%s`, id, starttime, endtime)
   recordCachePath := dss.RecordDir()

   if operate == "play" && fileType == "m3u8" {
      resPath, ok, _ := ff.GetRecordM3U8File(id, start, end, videoID, false)
      if ok != "Complete" {
         c.AbortWithStatusJSON(http.StatusBadRequest, "获取录像错误！")
         return
      }
      c.JSON(http.StatusOK, resPath)
      return
   }

   mp4Path := filepath.Join(recordCachePath, fmt.Sprintf(`Stream_%s.mp4`, videoID))
   if utils.Exist(mp4Path) {
      //存在直接返回
      ff.RecordCacheTime[videoID] = ff.RecordCacheTimeStruct{
         Time: time.Now(),
         Path: mp4Path}
      ff.OperFile(c, operate, mp4Path, videoID)
      return
   }
   //判断任务是否在处理
   if _, OK := ff.RecordCacheTime[videoID]; OK { //存在任务
      c.AbortWithStatusJSON(http.StatusBadRequest, "合成中")
      return
   }