gas-injection/src/hooks/system/useCamera.ts

import { defHttp } from '/@/utils/http/axios';
// import { render, h, nextTick } from 'vue';
// import LivePlayer from '@liveqing/liveplayer-v3';
import { useDrag } from '../event/useDrag';
import Player from 'xgplayer';
import HlsPlugin from 'xgplayer-hls';
import FlvPlugin from 'xgplayer-flv';
import 'xgplayer/dist/index.min.css';

export function useCamera() {
  const cameraList = (params) => defHttp.get({ url: '/safety/ventanalyCamera/list', params });
  const cameraAddrList = (params) => defHttp.post({ url: '/ventanaly-device/camera/info', params });
  const cameraAddr = (params) => defHttp.get({ url: '/ventanaly-device/camera/queryByCameraCode', params });

  let webRtcServer = <any[]>[];
  const playerList = <any[]>[];
  const playerDoms = <(HTMLVideoElement | undefined | null)[]>[];
  const videoParentDomList: (HTMLElement | [string, { name: string; addr: string }])[] = [];

  async function getCamera(deviceid, parentPlayerDom?) {
    removeCamera();
    if (!parentPlayerDom) {
      parentPlayerDom = document.createElement('div');
      parentPlayerDom.setAttribute('style', `top:0px; left: 0px; width: 100%; height: 100%; position: fixed; z-index: 999;`);
    }
    const res = await cameraList({ deviceid });
    const cameras: [] = res.records || [];
    // const cameras: [] = [
    //   {
    //     name: '1111',
    //     devicekind: 'toHKRtsp',
    //   },
    //   {
    //     name: '2222',
    //     devicekind: 'toHKRtsp',
    //   },
    //   // {
    //   //   name: '3333',
    //   //   devicekind: 'toHKRtsp',
    //   // },
    //   // {
    //   //   name: '4444',
    //   //   devicekind: 'toHKRtsp',
    //   // },
    // ];
    const cameraAddrs: any[] = [],
      cameraNames: string[] = [];
    if (cameras.length > 0) {
      for (let i = 0; i < cameras.length; i++) {
        const item = cameras[i];
        if (item['devicekind'] === 'toHKRtsp') {
          // 从海康平台接口获取视频流
          const data = await cameraAddr({ cameraCode: item['addr'] });
          if (data && data['url']) {
            cameraAddrs.push({ name: item['name'], addr: data['url'] });
          }
          // // 从海康平台接口获取视频流测试
          // cameraAddrs.push({
          //   name: item['name'],
          //   addr: 'https://demo.unified-streaming.com/k8s/features/stable/video/tears-of-steel/tears-of-steel.mp4/.m3u8',
          // });
        } else if (item['devicekind'] == 'toHKR') {
          cameraNames.push(item['name']);
        } else {
          cameraAddrs.push({ name: item['name'], addr: item['addr'] });
        }
      }
    }
    if (cameraNames.length > 0) {
      // 请求接口从装备院拿数据
      const addrs: string[] = await cameraAddrList({ cameraNameList: cameraNames });
      for (let i = 0; i < addrs.length; i++) {
        cameraAddrs.push({ name: '摄像头' + i, addr: addrs[i] });
      }
    }
    await deviceCameraInit(cameraAddrs, parentPlayerDom);
  }

  function deviceCameraInit(cameraAddrs, player: HTMLElement) {
    const newWebRtcServer = [];
    let livePlayerDiv: HTMLElement | null = document.getElementById('LivePlayerBox');
    if (livePlayerDiv) {
      livePlayerDiv.remove();
      livePlayerDiv = null;
    }
    if (!livePlayerDiv) {
      const dom = document.createElement('div');
      dom.setAttribute('id', 'LivePlayerBox');
      livePlayerDiv = dom;
      player.appendChild(livePlayerDiv);
    }

    return new Promise((resolve) => {
      const playCamrea = () => {
        if (cameraAddrs.length > 0) {
          const promiseList: Promise<any>[] = [];
          cameraAddrs.forEach(async (cameraUrl: { name: string; addr: string }, index) => {
            const promise = new Promise(async (childResolve) => {
              let cameraNameDom: null | HTMLElement = null;
              console.log('摄像头地址--------->', cameraUrl, cameraUrl.addr.startsWith('rtsp://'), livePlayerDiv);
              if (cameraUrl.addr.includes('0.0.0.0')) {
                cameraUrl.addr = cameraUrl.addr.replace('0.0.0.0', window.location.hostname);
              }
              if (cameraUrl.addr && cameraUrl.addr.startsWith('rtsp://')) {
                const server = webRtcServer?.shift();
                let videoDom: HTMLVideoElement | null = null;
                if (server) {
                  try {
                    videoDom = server.videoElement as HTMLVideoElement;
                    videoDom.volume = 0;
                    const cameraNameDom = videoDom.parentElement?.getElementsByClassName('video-name')[0];
                    if (cameraNameDom) cameraNameDom.innerText = cameraUrl.name;
                    playerDoms.unshift(videoDom);
                    newWebRtcServer.unshift(server);
                    // videoParentDomList.unshift()
                    await server.connect(cameraUrl['addr']);
                    videoDom.play();
                    childResolve(null);
                  } catch (error) {
                    playerDoms.unshift(undefined);
                    childResolve(null);
                  }
                } else {
                  videoDom = document.createElement('video');
                  videoDom.volume = 0;
                  videoDom.setAttribute('class', 'rtspVideo');
                  videoDom.setAttribute('muted', 'muted');
                  videoDom.setAttribute('poster', '/src/assets/images/vent/noSinge.png');
                  videoDom.autoplay = true;

                  try {
                    const server = new window['WebRtcStreamer'](videoDom, location.protocol + VUE_APP_URL.webRtcUrl);
                    newWebRtcServer.unshift(server);
                    await server.connect(cameraUrl.addr);
                    videoDom.play();
                    playerDoms.unshift(videoDom);
                    childResolve(null);
                  } catch (error) {
                    console.log('WebRtcStreamer 抛出异常！！！！！！');
                    playerDoms.unshift(null);
                    childResolve(null);
                  }
                }
                if (videoDom) {
                  const videoParentDom: HTMLElement = document.createElement('div');
                  videoParentDom.setAttribute('class', 'video-parent');
                  videoParentDom.appendChild(videoDom);
                  cameraNameDom = document.createElement('div');
                  cameraNameDom.setAttribute('class', 'video-name');
                  cameraNameDom.innerText = cameraUrl.name;
                  videoParentDom.appendChild(cameraNameDom);
                  videoParentDom.addEventListener('dblclick', () => {
                    if (videoDom?.requestFullscreen) {
                      videoDom.requestFullscreen();
                      videoDom.play();
                    }
                  });

                  videoParentDomList.push(videoParentDom);
                }
              } else {
                // try {
                //   fetch(cameraUrl.addr, {
                //     method: 'get',
                //     mode: 'no-cors',
                //   })
                //     .then(() => {
                //       videoParentDomList.push(['player', cameraUrl]);
                //       childResolve(null);
                //     })
                //     .catch(() => {
                //       videoParentDomList.push(['onPlayer' + index, cameraUrl]);
                //       childResolve(null);
                //     });
                // } catch (error) {
                //   // console.log('可以捕获到异常吗？？？？？');
                //   childResolve(null);
                // }
                videoParentDomList.push(['player' + index, cameraUrl]);
                childResolve(null);
              }
            });
            promiseList.push(promise);
          });
          Promise.all(promiseList).then(() => {
            resolve(null);
          });
        } else {
          resolve(null);
        }
      };
      playCamrea();
    }).then(() => {
      videoParentDomList.forEach((videoParent) => {
        if (typeof videoParent[0] === 'string' && livePlayerDiv) {
          const videoParentDom: HTMLElement = document.createElement('div');
          videoParentDom.setAttribute('class', 'liveVideo');
          livePlayerDiv?.appendChild(videoParentDom);
          useDrag(videoParentDom);
          const videoDom: HTMLElement = document.createElement('div');
          videoDom.setAttribute('id', videoParent[0]);
          videoParentDom.appendChild(videoDom);
          if (videoParent[1] && videoParent[1].addr) {
            const fileExtension = videoParent[1].addr.split('.').pop();
            let player;
            if (fileExtension === 'flv') {
              player = new Player({
                id: videoParent[0],
                url: videoParent[1].addr,
                width: 294,
                height: 188,
                poster: '/src/assets/images/vent/noSinge.png',
                plugins: [FlvPlugin],
                fluid: true,
                autoplay: true,
                isLive: true,
                playsinline: false,
                screenShot: true,
                whitelist: [''],
                ignores: ['time'],
                closeVideoClick: true,
                customConfig: {
                  isClickPlayBack: false,
                },
                flv: {
                  retryCount: 3, // 重试 3 次，默认值
                  retryDelay: 1000, // 每次重试间隔 1 秒，默认值
                  loadTimeout: 10000, // 请求超时时间为 10 秒，默认值
                  fetchOptions: {
                    // 该参数会透传给 fetch，默认值为 undefined
                    mode: 'cors',
                  },
                  targetLatency: 10, // 直播目标延迟，默认 10 秒
                  maxLatency: 20, // 直播允许的最大延迟，默认 20 秒
                  disconnectTime: 10, // 直播断流时间，默认 0 秒，（独立使用时等于 maxLatency）
                  maxJumpDistance: 10,
                },
              });
              playerList.push(player);
            }
            if (fileExtension === 'm3u8') {
              let player;
              if (document.createElement('video').canPlayType('application/vnd.apple.mpegurl')) {
                // 原生支持 hls 播放
                player = new Player({
                  id: videoParent[0],
                  url: videoParent[1].addr,
                  width: 294,
                  height: 188,
                  isLive: true,
                  autoplay: true,
                  autoplayMuted: true,
                  cors: true,
                  poster: '/src/assets/images/vent/noSinge.png',
                  hls: {
                    retryCount: 3, // 重试 3 次，默认值
                    retryDelay: 1000, // 每次重试间隔 1 秒，默认值
                    loadTimeout: 10000, // 请求超时时间为 10 秒，默认值
                    fetchOptions: {
                      // 该参数会透传给 fetch，默认值为 undefined
                      mode: 'cors',
                    },
                    targetLatency: 10, // 直播目标延迟，默认 10 秒
                    maxLatency: 20, // 直播允许的最大延迟，默认 20 秒
                    disconnectTime: 10, // 直播断流时间，默认 0 秒，（独立使用时等于 maxLatency）
                    maxJumpDistance: 10,
                  },
                });
              } else if (HlsPlugin.isSupported()) {
                // 第一步
                player = new Player({
                  id: videoParent[0],
                  url: videoParent[1].addr,
                  width: 294,
                  height: 188,
                  isLive: true,
                  autoplay: true,
                  autoplayMuted: true,
                  plugins: [HlsPlugin], // 第二步
                  poster: '/src/assets/images/vent/noSinge.png',
                  hls: {
                    retryCount: 3, // 重试 3 次，默认值
                    retryDelay: 1000, // 每次重试间隔 1 秒，默认值
                    loadTimeout: 10000, // 请求超时时间为 10 秒，默认值
                    fetchOptions: {
                      // 该参数会透传给 fetch，默认值为 undefined
                      mode: 'cors',
                    },
                    targetLatency: 10, // 直播目标延迟，默认 10 秒
                    maxLatency: 20, // 直播允许的最大延迟，默认 20 秒
                    disconnectTime: 10, // 直播断流时间，默认 0 秒，（独立使用时等于 maxLatency）
                    maxJumpDistance: 10,
                  },
                });
              }
              playerList.push(player);
            }
            playerList.push(player);
          }
        } else {
          useDrag(videoParent as HTMLElement);
          livePlayerDiv?.appendChild(videoParent as Node);
        }
      });

      const players = livePlayerDiv?.getElementsByClassName('player');
      if (players && players.length) {
        for (let i = 0; i < players.length; i++) {
          try {
            const isCanPlayer = !players[i].getAttribute('id')?.startsWith('onPlayer');
            const dom = players[i].getElementsByTagName('video')[0];
            if (dom && isCanPlayer) {
              playerDoms.unshift(dom);
            } else {
              playerDoms.unshift(null);
            }
          } catch (error) {
            console.log('可以捕获到异常吗？？？？？');
            playerDoms.unshift(null);
          }
        }
      }
      if (webRtcServer.length > 0) {
        for (let i = 0; i < webRtcServer.length; i++) {
          webRtcServer[i].videoElement.parentElement.remove();
          webRtcServer[i].disconnect();
          webRtcServer[i] = undefined;
        }
      }
      webRtcServer.length = 0;
      webRtcServer = newWebRtcServer;
    });
  }

  function removeCamera() {
    if (webRtcServer.length > 0) {
      webRtcServer.forEach((item) => {
        item.disconnect();
      });
      webRtcServer = [];
    }
    playerDoms.forEach((dom) => {
      dom?.remove();
    });
    videoParentDomList.length = 0;
    playerDoms.length = 0;
  }

  return {
    getCamera,
    webRtcServer,
    playerDoms,
    deviceCameraInit,
    removeCamera,
  };
}