const mysql = require('../utils/mysql_db')
const dbhandle = require('../utils/handle_db')
const uuid = require('node-uuid')

module.exports = {
  /**
   * 导入
   * @param {*} params
   * @param staff
   * @param table
   */
  async importExcel(data) {
    let params = JSON.parse(data.params)
    let newData = []
    let insertField = []
    insertField[0] = 'id'
    for (let item in params) {
      let arr = []
      arr[0] = uuid.v4()
      //params[item] = JSON.parse(params[item])
      for (let key in params[item]) {
        if (key != 'tag') {
          if (item == 0) {
            insertField.push(key)
          }
          arr.push(params[item][key])
        }
      }
      newData.push(arr)
    }
    let str = dbhandle.array_connect(insertField, ',').replace(/\'/g, '')
    let sql = `INSERT INTO ${data.table} (${str}) VALUES ?;`
    return await mysql.query(sql, [newData])
  },
  /**
   * 编辑
   */
  async updateTable(data) {
    return await mysql.query(data.sql)
  },
  /**
   * 批量更新
   */
  async updateBatch(params) {
    await mysql.query(
      `REPLACE INTO ${params.table} (${params.fields}) VALUES ?;`,
      [JSON.parse(params.values)]
    )
  },

  /**
   * 根据周期任务id验证是否有设备正在使用
   */
  async checkTaskId(data) {
    let sql = `SELECT log_id FROM fm_t_device WHERE task_id = '${data}'`
    return await mysql.query(sql)
  },

  /**
   * 删除
   */
  async delete(data) {
    let sql = `DELETE FROM ${data.table} WHERE id = '${data.id}'`
    return await mysql.query(sql)
  },
  /**
   * 批量删除
   */
  async deleteBatch(data) {
    let sql = `update ${
      data.table
    } set status = '已删除' WHERE id IN (${dbhandle.array_connect(
      JSON.parse(data.id_list),
      ','
    )});`
    return await mysql.query(sql)
  },
  /**
   * 新增
   */
  async insertTable(data) {
    
    data.colName = data.colName.slice(0,data.colName.length - 1);
    data.values = data.values.slice(0,data.values.length - 1);
    // data.colName += `id`
    // data.values += `'${uuid.v4()}'`
    console.log(data);
    let sql = `INSERT INTO ${data.table} (${data.colName}) VALUES(${data.values})`
    console.log(sql);
    return await mysql.query(sql)
  },

  /**
   * 更新图像
   */
  async uploadPic(param) {
    let sql = `UPDATE ${param.table} SET ${param.field} = '${param.path}' WHERE id = '${param.id}'`
    return await mysql.query(sql)
  }
}