From 0a928d823102809085e087bf920b911533647e79 Mon Sep 17 00:00:00 2001 From: aixianling Date: Fri, 10 Feb 2023 19:33:57 +0800 Subject: [PATCH] =?UTF-8?q?=E8=B0=83=E6=95=B4=E6=8E=A5=E5=8F=A3?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- src/rest/monitorApi/add.js | 17 ++++++++++++++++- src/utils/dbUitls.js | 13 ++++++++++--- 2 files changed, 26 insertions(+), 4 deletions(-) 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}) => {