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)
|
}
|
}
|
