前端接口监控统计完成

src/rest/monitorApi/add.js

@@ -1,13 +1,14 @@
 const dbUtils = require("../../utils/dbUitls");
+const addLog = ({id, status, path, device, url, createTime, nodeProcess, method, code, userName, error}) => dbUtils.addOrUpdate({
+  table: 'node_api_logs',
+  form: {id, status, path, device, url, createTime, nodeProcess, method, code, userName, error}
+})
+
 module.exports = {
   action: "/node/monitorApi/addOrUpdate",
   method: "post",
   execute: (request, response) => {
-    let {id, status, path, device, url, createTime, nodeProcess, userId, userName, error} = request.body
-    dbUtils.addOrUpdate({
-      table: 'node_api_logs',
-      form: {id, status, path, device, url, createTime, nodeProcess, userId, userName, error}
-    }).then(data => {
+    Promise.all([request.body].flat().map(e => addLog(e))).then(data => {
       response.send({code: 0, data})
     }).catch(err => {
       response.send({code: 1, err: err?.sqlMessage || err || ""})

src/rest/monitorApi/sta.js

@@ -0,0 +1,17 @@
+const dbUtils = require("../../utils/dbUitls");
+module.exports = {
+  action: "/node/monitorApi/sta",
+  method: "post",
+  execute: (request, response) => {
+    const data = {}
+    Promise.all([
+      dbUtils.query(`select path,method,SUM(1) as total,createTime FROM node_api_logs where status not like '200' GROUP BY path ORDER BY total DESC limit 0,10`).then(res => data.top10 = res),
+      dbUtils.query(`select status as name,SUM(1) as value FROM node_api_logs where status not like '200' GROUP BY status`).then(res => data.distribution = res)
+    ]).then(() => {
+      response.send({code: 0, data})
+    }).catch(err => {
+      response.send({code: 1, err: err?.sqlMessage || err || ""})
+    })
+
+  }
+}

src/utils/dbUitls.js

@@ -31,7 +31,7 @@ module.exports = {
     let total = 0, records = []
     if (table) {
       const {current, size = 10} = search, params = JSON.parse(JSON.stringify(search))
-      const conValue = params[con]
+      const conValue = params[con] || ""
       delete params.current
       delete params.size
       delete params[con]