const router = require('koa-router')()
const base = require('../models/base')
const upload = require('../utils/upload')
const recordAnalysis = require('../utils/recordAnalysis')
const path = require('path')
router.prefix('/base')

/*token校验 */
const jwt = require('jsonwebtoken')
const util = require('util')
const verify = util.promisify(jwt.verify) // 解密
let secert = 'FM_Monitor'

router.get('/:func', async function (ctx, next) {
  const token = ctx.header.authorization
  payload = await verify(token.split(' ')[1], secert) // // 解密，获取payload
  if (payload) {
    await next()
  } else {
    ctx.body = {
      code: 50014
    }
    return
  }
})
/*校验结束 */

//导入
router.get('/importExcel', async function (ctx, res, next) {
  let data = ctx.query
  data.logDes = `Excel导入数据。`
  ctx.body = {
    data: await base.importExcel(data),
    code: 20000
  }
})

//编辑
router.get('/updateTable', async function (ctx, res, next) {
  let data = ctx.query
  ctx.body = {
    data: await base.updateTable(data),
    code: 20000
  }
})

//批量更新
router.get('/updateBatch', async function (ctx, res, next) {
  let data = ctx.query
  ctx.body = {
    data: await base.updateBatch(data),
    code: 20000
  }
})

//删除
router.get('/delete', async function (ctx, res, next) {
  let data = ctx.query
  ctx.body = {
    data: await base.delete(data),
    code: 20000
  }
})

//批量删除
router.get('/deleteBatch', async function (ctx, res, next) {
  let data = ctx.query
  //验证该周期任务是否有设备正在运行使用
  let params = JSON.parse(data.id_list)
  let error_ids = [] //不符合删除要求的任务号id。
  let success_ids = [] //正在使用周期任务的设备。
  for (let i = 0; i < params.length; i++) {
    let result = await base.checkTaskId(params[i])
    if (result.length > 0) {
      error_ids.push(params[i])
    } else {
      success_ids.push(params[i])
    }
  }
  if (success_ids.length > 0) {
    data.id_list = JSON.stringify(success_ids)
    await base.deleteBatch(data)
  }
  ctx.body = {
    error_data: error_ids,
    success_data: success_ids,
    code: 20000
  }
})

//新增
router.get('/insertTable', async function (ctx, res, next) {
  let data = ctx.query
  ctx.body = {
    data: await base.insertTable(data),
    code: 20000
  }
})

//上传
router.put('/uploadFile', upload.single('file'), async ctx => {
  let fileparams = ctx.req.file
  let txtparams = ctx.req.body
  let path = fileparams.path.replace(/\\/g, '/')
  if (typeof txtparams.table != 'undefined') {
    //新增
    txtparams.values += `'${path.replace('public/', '')}',`
    ctx.body = {
      data: await base.insertTable(txtparams),
      code: 20000
    }
  } else {
    txtparams.sql += ` '${path.replace('public/', '')}'  WHERE id = '${
      txtparams.sql_id
      }' `
    ctx.body = {
      data: await base.updateTable(txtparams),
      code: 20000
    }
  }
})

//更换头像
router.put('/uploadPic', upload.single('file'), async ctx => {
  let fileparams = ctx.req.file
  let txtparams = ctx.req.body
  txtparams.path = fileparams.path.replace(/\\/g, '/').replace('public/', '')

  ctx.body = {
    data: await base.uploadPic(txtparams),
    path: txtparams.path,
    code: 20000
  }
})

//从文件读取字符串
router.get('/readFile', async function (ctx, next) {
  const fs = require('fs')
  ctx.query.logDes = `从文件(${ctx.query.path})读取字符串`
  let data = fs.readFileSync(ctx.query.path, ctx.query.encoding)

  ctx.body = {
    code: 20000,
    data: data
  }
})

//保存字符串到文件
router.get('/saveFile', async function (ctx, next) {
  const fs = require('fs')
  ctx.query.logDes = `保存字符串到文件(${ctx.query.path})`
  fs.writeFileSync(ctx.query.path, ctx.query.data, ctx.query.encoding)
  ctx.body = {
    code: 20000
  }
})

router.post('/recordUpload', async (ctx, next) => {
  const fs = require('fs')
  // 上传单个文件
  console.log(ctx.request)
  let file = ctx.request.files.recordFile
  // 创建可读流
  const reader = fs.createReadStream(file.path)

  //根据上传设备的物理编号，按要求统一存放设备录音文件
  let filePathByDeviceId =
    path.join(__dirname, '../public/record') + `/${ctx.request.body.deviceId}`
  if (!fs.existsSync(filePathByDeviceId)) {
    fs.mkdirSync(filePathByDeviceId)
  }

  let filePath = filePathByDeviceId + `/${file.name}`
  // 创建可写流
  const upStream = fs.createWriteStream(filePath)
  //可读流通过管道写入可写流
  reader.pipe(upStream)

  ctx.body = {
    data: '上传成功！',
    code: 20000
  }

  // let voice = fs.readFileSync(path.resolve(__dirname,'../public/record/123.wav'));
  // let voiceBuffer = new Buffer(voice);

  // // 识别本地文件，附带参数
  // recordAnalysis.client.recognize(voiceBuffer, 'wav', 8000, {dev_pid: '1537', cuid:"15001307"}).then(function (result) {
  //   console.log('<recognize>: ' + JSON.stringify(result));
  // //  console.log(result);
  // }, function(err) {
  //     console.log(err);
  // });
})

module.exports = router