import ajax from 'ajax'
import { ElMessage } from 'element-plus'
import {playback} from "@/api/ycjg/hik";
// import { BrowserType, PlayerControl, RPC, _getSession, pubsub } from './module/PlayerControl'

// id：dom的id
export function loginDH(ip, port, username, password, channel, id, isPlayback = false, StartTime = '', EndTime = '') {
  return new Promise((resolve, reject) => {
    setIP(`${ip}:${port}`)
    RPC.login(username, password, false).then((res: any) => {
      console.info('登录成功', res)
      setCookie('DWebClientSessionID', '', -1)
      setCookie('DhWebClientSessionID', '', -1)
      /**
       * RPC.keepAlive 保活
       */
      RPC.keepAlive(300, 60000, _getSession(), `${ip}:${port}`)
      const browser = BrowserType()
      if (browser.includes('ie')) {
        window.onunload = () => {
          ajax({
            url: 'global.logout',
          })
        }
      }
      else if (browser.includes('chrome')) {
        const params = {
          method: 'global.logout',
          params: null,
          id: 10000,
          session: _getSession(),
        }
        pubsub.subscribe('onbeforeunload', () => {
          navigator.sendBeacon('/RPC2', JSON.stringify(params))
        })
      }
      else {
        pubsub.subscribe('onbeforeunload', () => {
          ajax({
            url: 'global.logout',
          })
        })
      }
      if (!isPlayback) {
        const player = onPreview(ip, port, username, password, channel, id, isPlayback)
        window.player = player
        resolve(player)
      }
      else {
        playBackDH(ip, port, username, password, channel, id, StartTime, EndTime)
        resolve(null)
      }
    }).catch((err: any) => {
      console.log(err)
      reject(err)
    })
  })
}

export function onPreview(ip, port, username, password, channel, id, isPlayback, list = [], playIndex = 0, StartTime = 0, EndTime = 0) {
  let url
  if (isPlayback) {
    url = list[playIndex].FilePath
  }
  const options = {
    wsURL: `ws://${ip}:${port}/rtspoverwebsocket`,
    rtspURL: !isPlayback
      ? `rtsp://${ip}:${port}/cam/realmonitor?channel=${Number(channel) + 1}&subtype=0&proto=Private3`
      : `rtsp://${ip}:${port}/${url}`,
    username,
    password,
    lessRateCanvas: true,
    playback: isPlayback,
    isPrivateProtocol: false,
    realm: RPC.realm, // 设备登录返回的realm
    // playbackIndex: 0,
    range: !isPlayback ? 0 : playIndex === 0 ? (new Date(StartTime).getTime() / 1000) - (new Date(list[0].StartTime).getTime() / 1000) : 0,
    h265AccelerationEnabled: true, // 硬解码是否开启，默认不开启
  }

  const videoplayerObj = document.getElementById(`dhVideo${id}`)
  const canvasplayerObj = document.getElementById(`dhCanvas${id}`)
  const player = new PlayerControl(options)

  player.on('PlayStart', (e: any) => {
    // console.log(e)
  })
  player.on('WorkerReady', () => {
    player.connect()
  })
  player.on('Error', (rs: any) => {
    console.log(rs)
  })
  if (isPlayback) {
    player.on('FileOver', () => {
      // 播下个录像
      onPreview(ip, port, username, password, channel, id, true, list, playIndex + 1, StartTime, EndTime)
    })
    player.on('UpdateTimeStamp', (e: any) => {
      // const s = new Date(StartTime).getTime() / 1000
      const end = new Date(EndTime).getTime() / 1000
      if (e.timestamp > end) {
        player.stop()
        player.close()
      }
    })
  }

  player.init(canvasplayerObj, videoplayerObj)
  return player
}

export function playBackDH(ip, port, username, password, channel, id, StartTime, EndTime) {
  onSearchRecord(channel, StartTime, EndTime).then((result: any) => {
    if (result.recordNums !== 0) {
      onPreview(ip, port, username, password, channel, id, true, result.allRecords, 0, StartTime, EndTime)
    }
  }).catch((err: any) => {
    console.log(err, 'playBackDH')
  })
}
export async function onSearchRecord(Channel: any, StartTime: any, EndTime: any) {
  let tmpDir = []
  try {
    /**
     * RPC.getDeviceAllInfo 获取存储信息
     * @param {string} 'getDeviceAllInfo' 方法名
     * @return {Promise}
     */
    tmpDir = await RPC.getDeviceAllInfo('getDeviceAllInfo')
  }
  catch (e) {
    console.log(e)
  }
  let dirs = null
  if (tmpDir.info && tmpDir.info.length > 1) {
    dirs = 'All'
  }
  else {
    dirs = tmpDir.info && tmpDir.info[0] && tmpDir.info[0].Detail && tmpDir.info[0].Detail[0] && tmpDir.info[0].Detail[0].Path || '/mnt/sd'
  }
  const params = {
    condition: {
      Channel: Number(Channel),
      Dirs: [dirs],
      StartTime,
      EndTime,
      Flags: null,
      Events: ['*'],
      Types: ['dav'],
    },
  }
  return new Promise((resolve, reject) => {
    getMediaFile(params).then((result: any) => {
      resolve(result)
    }).catch((err: any) => {
      if (err && err.error && err.error.code === 285409409) {
        ElMessage.warning('回放功能需要确保SD卡经过设备认证')
      }
      else {
        ElMessage.warning('无数据')
      }
      reject(err)
    })
  })
}

export function getMediaFile(params: any) {
  return new Promise((resolve, reject) => {
    /**
     * RPC.MediaFileFind.instance 创建媒体文件查找实例
     * @returns {Promise}
     */
    RPC.MediaFileFind.instance().then((json: any) => {
      const queryId = json.result
      /**
       * RPC.MediaFileFind.findFile 设置查找条件，并判断是否存在文件
       * @param {number} queryId 实例id
       * @param {object} params condition参数
       * @returns {Promise}
       */
      RPC.MediaFileFind.findFile(queryId, params).then(() => {
        findNextFile(queryId).then((result: any) => {
          resolve(result)
        }).catch((err: any) => {
          reject(err)
        })
      }).catch((err: any) => {
        reject(err)
      })
    }).catch((err: any) => {
      reject(err)
    })
  })
}

export function findNextFile(queryId: any) {
  return new Promise((resolve, reject) => {
    /**
     * RPC.MediaFileFind.findNextFile 在指定条件基础上查询文件信息
     * @param {number} queryId 实例
     * @param {object} 需要查找的数目
     * @returns {Promise}
     */
    RPC.MediaFileFind.findNextFile(queryId, { count: 100 }).then((data: any) => {
      if (Number.isInteger(data.found)) {
        const recordNums = data.found
        const allRecords = [...data.infos]
        stopFind(queryId).then(() => {})
        resolve({
          recordNums,
          allRecords,
        })
      }
      else {
        stopFind(queryId).then(() => {})
        resolve({
          recordNums: 0,
          allRecords: [],
        })
      }
    }).catch((err: any) => {
      reject(err)
      stopFind(queryId).then(() => {})
    })
  })
}

export function stopFind(object: any) {
  return new Promise((resolve, reject) => {
    /**
     * PC.MediaFileFind.close 结束查询
     * @param {number} object 媒体文件查找实例ID
     * @returns {Promise}
     */
    RPC.MediaFileFind.close(object).then(() => {
      /**
       * PC.MediaFileFind.destroy 销毁媒体文件查找实例
       * @param {number} object 媒体文件查找实例ID
       */
      RPC.MediaFileFind.destroy(object)
      resolve(true)
    }).catch((err: any) => {
      reject(err)
    }).finally(() => {
    })
  })
}

export function onStartCut(ip, port, username, password, channel, startTime, endTime) {
  let isCuting = false
  let isCuting1 = false
  const videoplayerObj = document.getElementById('dhVideo0')
  const canvasplayerObj = document.getElementById('dhCanvas0')
  onSearchRecord(channel, startTime, endTime).then((result: any) => {
    if (result.recordNums !== 0) {
      const optionsRecord = {
        wsURL: `ws://${ip}:${port}/rtspoverwebsocket`,
        rtspURL: `rtsp://${ip}:${port}/${result.allRecords[0].FilePath}`,
        username,
        password,
        isPrivateProtocol: false, // 是否私有协议，默认false
        realm: RPC.realm, // 登录返回的设备Realm值
        speed: 16, // 倍速拉流，16倍速
        playback: true, // 是都回放
        isDownLoad: true,
        range: (new Date(startTime).getTime() / 1000) - (new Date(result.allRecords[0].StartTime).getTime() / 1000), // 视频裁剪时间与视频的StartTime时间差值
      }
      const cutPlayer = new PlayerControl(optionsRecord)
      cutPlayer.on('FileOver', () => {
        console.log('File Over')
        cutPlayer.startCut(false)
        isCuting = false
        if (result.recordNums > 1) {
          // 录制第二个文件
          const optionsRecord1 = {
            wsURL: `ws://${ip}:${port}/rtspoverwebsocket`,
            rtspURL: `rtsp://${ip}:${port}/${result.allRecords[1].FilePath}`,
            username,
            password,
            isPrivateProtocol: false, // 是否私有协议，默认false
            realm: RPC.realm, // 登录返回的设备Realm值
            speed: 16, // 倍速拉流，16倍速
            playback: true, // 是都回放
            isDownLoad: true,
            range: 0, // 视频裁剪时间与视频的StartTime时间差值
          }
          const cutPlayer1 = new PlayerControl(optionsRecord1)
          cutPlayer1.on('FileOver', () => {
            console.log('File Over')
            cutPlayer1.startCut(false)
            isCuting1 = false
          })
          cutPlayer1.on('UpdateTimeStamp', (e: any) => {
            const s1 = new Date(startTime).getTime() / 1000
            const e1 = new Date(endTime).getTime() / 1000
            if ((e.timestamp >= s1) && !isCuting1) {
              cutPlayer1.startCut(true)
              isCuting1 = true
            }
            if ((e.timestamp >= e1) && isCuting1) {
              cutPlayer1.startCut(false)
              isCuting1 = false
            }
          })
          cutPlayer1.init(canvasplayerObj, videoplayerObj)
          cutPlayer1.connect(true)
        }
      })
      cutPlayer.on('UpdateTimeStamp', (e: any) => {
        const s1 = new Date(startTime).getTime() / 1000
        const e1 = new Date(endTime).getTime() / 1000
        if ((e.timestamp >= s1) && !isCuting) {
          cutPlayer.startCut(true)
          isCuting = true
        }
        if ((e.timestamp >= e1) && isCuting) {
          cutPlayer.startCut(false)
          isCuting = false
        }
      })
      cutPlayer.init(canvasplayerObj, videoplayerObj)
      cutPlayer.connect(true)
    }
  }).catch((err: any) => {
    console.log(err)
  })
}