var express = require('express');
var router = express.Router();
const { spawn } = require('child_process');
const fs = require("fs");

const method = require("../config/method")
const config = require("../config/config")

// const { GETCLASSURL, GETCLASSURLPARAMETER, PROJECTCATALOG, PROJECTWINCATALOG, BACKMEDIACONFIG } = config
const { YesterdayTime, getRequestClassIds,dayTimeYMD } = method

const { startTime, endTime, ymd } = YesterdayTime()
let siteIds = []

let classid = []
let parentData = {}
var classobj = {};
let className = ""
/**
 * 
 * @param {*} id 课堂id
 */
class MediaCreat {
  constructor() { }
  // 取出所有数据
  async allData() {
    let fileConfig = await new MediaCreat().getConfigFileJson()
    if(!fileConfig) return false
    className = siteIds.shift()
    const { GETCLASSURL,GETCLASSURLPARAMETER } = JSON.parse(fileConfig)
    let page = 1
    if (className) {
      let result = await getRequestClassIds(GETCLASSURL, className, GETCLASSURLPARAMETER.key, startTime, endTime, page)
      parentData[result.data.data.siteId] = new Set()
      for (let j = 0; j < result.data.data.list.length; j++) {
        classid.push(result.data.data.list[j])
        parentData[result.data.data.siteId].add(result.data.data.list[j]['classId'])
      }
      const { siteId, list, totalPage } = result.data.data
      for (let i = page += 1; i <= totalPage; i++) {
        let result = await getRequestClassIds(GETCLASSURL, className, GETCLASSURLPARAMETER.key, startTime, endTime, i)
        for (let j = 0; j < result.data.data.list.length; j++) {
          classid.push(result.data.data.list[j])
          parentData[result.data.data.siteId].add(result.data.data.list[j]['classId'])
        }
      }
      parentData[result.data.data.siteId] = Array.from(parentData[result.data.data.siteId])
      if (siteIds.length) {
        return await new MediaCreat().allData()
      }
      return true
    } else {
      return false
    }
  }
  async mediaCreat(id, siteId) {
    let fileConfig = await new MediaCreat().getConfigFileJson()
    if(!fileConfig) return false
    const { BACKMEDIACONFIG,PROJECTWINCATALOG,PROJECTCATALOG } = JSON.parse(fileConfig)

    let mediaDir = PROJECTCATALOG + "/media/"
    let classDir = PROJECTCATALOG + "/media/" + siteId
    let ymdDir = PROJECTCATALOG + "/media/" + siteId + "/" + ymd
    if (!fs.existsSync(mediaDir)) {
      fs.mkdirSync(mediaDir);
    }
    if (!fs.existsSync(classDir)) {
      fs.mkdirSync(classDir);
    }
    if (!fs.existsSync(ymdDir)) {
      fs.mkdirSync(ymdDir);
    }
    let url = `web_capture_c -o=../media/${siteId}/${ymd}/${id}.mp4 -u="${BACKMEDIACONFIG.url}?classId=${id}&userId=${BACKMEDIACONFIG.userId}&userName=${BACKMEDIACONFIG.userName}&userRole=${BACKMEDIACONFIG.userRole}&portalIP=${BACKMEDIACONFIG.portalIP}&portalPort=${BACKMEDIACONFIG.portalPort}&channels=${BACKMEDIACONFIG.channels}&playRecord=${BACKMEDIACONFIG.playRecord}" -d=${BACKMEDIACONFIG.d} -s=${BACKMEDIACONFIG.s} -fa=${BACKMEDIACONFIG.fa} -k=${BACKMEDIACONFIG.k} -w=${BACKMEDIACONFIG.w} -h=${BACKMEDIACONFIG.h}`
    var workerProcess = spawn(url, { cwd: PROJECTWINCATALOG, shell: true })
    // workerProcess.stdout.on('data', async function (data) {

    // });

    workerProcess.on('close', async function (code) {
      let files = fs.readdirSync(ymdDir);
      if (files.indexOf(id + ".mp4") == -1) {
        //当前课堂没有写入到文件夹，进入重录
        new MediaCreat().mediaCreat(id, siteId)
        return false
      } else {
        if (parentData[siteId].indexOf(id.toString()) != -1) {
          parentData[siteId].splice(parentData[siteId].indexOf(id.toString()), 1)
        }
        if (parentData[siteId].length == 0) {
          //   //全部录制完毕
          fs.writeFile(ymdDir + "/download.json", `{ "code": "0", "success": "ok"}`, function (err) {
            if (err) {
              console.log(err);
            }
          });
        }
        if (classid.length) {
          let shiftData = classid.shift()
          new MediaCreat().mediaCreat(shiftData['classId'], shiftData['siteId'])
        }
      }
    });
  }
  async recordingCreat(id, siteId) {
    let fileConfig = await new MediaCreat().getConfigFileJson()
    if(!fileConfig) return false
    const { BACKMEDIACONFIG,PROJECTWINCATALOG,PROJECTCATALOG } = JSON.parse(fileConfig)
    let mediaDir = PROJECTCATALOG + "/media/"
    let recordingDir = mediaDir + "recording/"
    let classDir = recordingDir + siteId +"/"
    let dateDir = classDir + dayTimeYMD().ymd
    if (!fs.existsSync(mediaDir)) {
      fs.mkdirSync(mediaDir);
    }
    if (!fs.existsSync(recordingDir)) {
      fs.mkdirSync(recordingDir);
    }
    if (!fs.existsSync(classDir)) {
      fs.mkdirSync(classDir);
    }
    if (!fs.existsSync(dateDir)) {
      fs.mkdirSync(dateDir);
    }
    let url = `web_capture_c -o=../media/recording/${siteId}/${dayTimeYMD().ymd}/${id}.mp4 -u="${BACKMEDIACONFIG.url}?classId=${id}&userId=${BACKMEDIACONFIG.userId}&userName=${BACKMEDIACONFIG.userName}&userRole=${BACKMEDIACONFIG.userRole}&portalIP=${BACKMEDIACONFIG.portalIP}&portalPort=${BACKMEDIACONFIG.portalPort}&channels=${BACKMEDIACONFIG.channels}&playRecord=${BACKMEDIACONFIG.playRecord}" -d=${BACKMEDIACONFIG.d} -s=${BACKMEDIACONFIG.s} -fa=${BACKMEDIACONFIG.fa} -k=${BACKMEDIACONFIG.k} -w=${BACKMEDIACONFIG.w} -h=${BACKMEDIACONFIG.h}`
    var workerProcess = spawn(url, { cwd: PROJECTWINCATALOG, shell: true })
    // workerProcess.stdout.on('data', async function (data) {
  
    // });
  
    workerProcess.on('close', async function (code) {
      let files = fs.readdirSync(dateDir);
      if (files.indexOf(id + ".mp4") == -1) {
        //当前课堂没有写入到文件夹，进入重录
        new MediaCreat().recordingCreat(id, siteId)
        return false
      } else {
        if (parentData[siteId].indexOf(id.toString()) != -1) {
          parentData[siteId].splice(parentData[siteId].indexOf(id.toString()), 1)
        }
        if (parentData[siteId].length == 0) {
          //   //全部录制完毕
          fs.writeFile(dateDir + "/download.json", `{ "code": "0", "success": "ok"}`, function (err) {
            if (err) {
              console.log(err);
            }
          });
        }
        if (classid.length) {
          let shiftData = classid.shift()
          new MediaCreat().recordingCreat(shiftData['classId'], shiftData['siteId'])
        }
      }
    });
  }

  async getConfigFileJson(){
    const buffer= fs.readFileSync(process.cwd()+"/config/config.json")
    return String(buffer)
  }
}


router.get('/', async function (req, res, next) {
  let fileConfig = await new MediaCreat().getConfigFileJson()
  if(!fileConfig) return false
  
  const {GETCLASSURLPARAMETER} = JSON.parse(fileConfig)
  siteIds = GETCLASSURLPARAMETER.siteId

  let result = await new MediaCreat().allData()
  if (result) {
    // 去重
    classid = classid.reduce(function (item, next) {
      classobj[next.classId] ? '' : classobj[next.classId] = true && item.push(next);
      return item;
    }, []);
    if (classid.length) {
      for (let i = 0; i < GETCLASSURLPARAMETER.maxMedia; i++) {
        let shiftData = classid.shift()
        if (shiftData) {
          new MediaCreat().mediaCreat(shiftData['classId'], shiftData['siteId'])
        } else {
          return false
        }
      }
    }
    res.send({ code: "0" });
  }
});

/**
 * {
 * "classId":[{ classId: '389675110', siteId: 'kuaikuenglish' }]
 * }
 */
router.post('/recording', async function (req, res, next) {
  let fileConfig = await new MediaCreat().getConfigFileJson()
  if(!fileConfig) return false
  const { classId } = req.body
  if(classId && classId.length){
    classid = classId
    const { PROJECTCATALOG,GETCLASSURLPARAMETER } = JSON.parse(fileConfig)
    for(let i=0;i<classId.length;i++){
      if(!Array.isArray(parentData[classId[i].siteId])){
        parentData[classId[i].siteId] = []
      }
      parentData[classId[i].siteId].push(classId[i].classId)
    }
    for(let i=0;i<GETCLASSURLPARAMETER.maxMedia;i++){
      let shiftData = classid.shift()
      if (shiftData) {
        new MediaCreat().recordingCreat(shiftData['classId'], shiftData['siteId'])
      } else {
        return false
      }
    }
  }
  res.send({ code: "0" });
})


module.exports = router;