diff --git a/src/rest/monitorApi/add.js b/src/rest/monitorApi/add.js index 9c76803..57930f6 100644 --- a/src/rest/monitorApi/add.js +++ b/src/rest/monitorApi/add.js @@ -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 || ""}) diff --git a/src/utils/dbUitls.js b/src/utils/dbUitls.js index b38feee..61ee2dd 100644 --- a/src/utils/dbUitls.js +++ b/src/utils/dbUitls.js @@ -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}) => {