调整接口
This commit is contained in:
@@ -8,7 +8,22 @@ module.exports = {
|
||||
action: "/node/monitorApi/addOrUpdate",
|
||||
method: "post",
|
||||
execute: (request, response) => {
|
||||
Promise.all([request.body].flat().map(e => addLog(e))).then(data => {
|
||||
dbUtils.batchInsert({
|
||||
table: 'node_api_logs',
|
||||
list: [request.body].flat().map(({id, status, path, device, url, createTime, nodeProcess, method, code, userName, error}) => ({
|
||||
id,
|
||||
status,
|
||||
path,
|
||||
device,
|
||||
url,
|
||||
createTime,
|
||||
nodeProcess,
|
||||
method,
|
||||
code,
|
||||
userName,
|
||||
error
|
||||
}))
|
||||
}).then(data => {
|
||||
response.send({code: 0, data})
|
||||
}).catch(err => {
|
||||
response.send({code: 1, err: err?.sqlMessage || err || ""})
|
||||
|
||||
@@ -48,8 +48,7 @@ module.exports = {
|
||||
})
|
||||
}
|
||||
},
|
||||
addOrUpdate: ({table, form}) => {
|
||||
//新增和更新
|
||||
insert: ({table, form}) => {
|
||||
let sql
|
||||
if (form.id) {//编辑
|
||||
let arr = Object.keys(form).filter(e => form[e]).map(e => {
|
||||
@@ -66,8 +65,16 @@ module.exports = {
|
||||
arr.push(`'${form[e]}'`)
|
||||
}
|
||||
})
|
||||
sql = `insert into ${table} (id,createTime,${cols.join(",")}) values('${uuid()}','${dayjs().format("YYYY-MM-DD hh:mm:ss")}',${arr.join(",")})`
|
||||
sql = `insert into ${table} (id,createTime,${cols.join(",")}) values('${uuid()}','${dayjs().format("YYYY-MM-DD HH:mm:ss")}',${arr.join(",")})`
|
||||
}
|
||||
return sql
|
||||
},
|
||||
batchInsert({table, list}) {
|
||||
return query(list.map(e => this.insert({table, e})).join(";"))
|
||||
},
|
||||
addOrUpdate: ({table, form}) => {
|
||||
//新增和更新
|
||||
const sql = this.insert({table, form})
|
||||
return query(sql)
|
||||
},
|
||||
delete: ({table, ids}) => {
|
||||
|
||||
Reference in New Issue
Block a user