增加部署发布模块

config/db.js

@@ -3,6 +3,6 @@ module.exports = {
   user: "root",
   port: 3306,
   password: "Cwy@2019",
-  database: "dvcp_v2_dev",
+  database: "dvcp_oms_dev",
   multipleStatements: true
 }

index.js

@@ -8,6 +8,8 @@ app.listen(port, () => {
   console.log('启动数据库连接池...')
   db.init()
   console.log('启动接口...')
+  app.use(express.json()) // for parsing application/json
+  app.use(express.urlencoded({ extended: true })) // for parsing application/x-www-form-urlencoded
   rest.init(app).then(()=>{
     console.log(`serve is listening on ${port}`)
   })

package.json

@@ -21,6 +21,7 @@
   "dependencies": {
     "express": "^4.17.3",
     "helmet": "^5.0.2",
-    "mysql": "^2.18.1"
+    "mysql": "^2.18.1",
+    "uuid": "^8.3.2"
   }
 }

rest/autodeploy/add.js

@@ -0,0 +1,28 @@
+const dbUtils = require("../../utils/dbUitls");
+const {v4: uuid} = require('uuid');
+module.exports = {
+  action: "/node/autodeploy/addOrUpdate",
+  method: "post",
+  execute: (request, response) => {
+    let form = request.body, sql
+    if (form.id) {//编辑
+      let arr = Object.keys(form).filter(e => form[e]).map(e => `${e}=${form[e]}`)
+      sql = `update node_autodeploy set ${arr.join(",")} where id=${form.id}`
+    } else {//新增
+      let cols = [], arr = []
+      Object.keys(form).map(e => {
+        if (form[e]) {
+          cols.push(e)
+          arr.push(`'${form[e]}'`)
+        }
+      })
+      sql = `insert into node_autodeploy (id,${cols.join(",")}) values('${uuid()}',${arr.join(",")})`
+    }
+    console.log(sql)
+    dbUtils.query(sql).then(() => {
+      response.send({code: 0})
+    }).catch(err => {
+      response.send({code: 1, err: err.sqlMessage})
+    })
+  }
+}

rest/autodeploy/delete.js

@@ -0,0 +1,14 @@
+const dbUtils = require("../../utils/dbUitls");
+module.exports = {
+  action: "/node/autodeploy/delete",
+  method: "post",
+  execute: (request, response) => {
+    let {query: {ids}} = request
+    ids = ids?.split(",")?.map(e => `'${e}'`)?.toString()
+    dbUtils.query(`delete from node_autodeploy where id in (${ids})`).then(() => {
+      response.send({code: 0})
+    }).catch(err => {
+      response.send({code: 1, err: err.sqlMessage})
+    })
+  }
+}

rest/autodeploy/list.js

@@ -0,0 +1,28 @@
+const dbUtils = require("../../utils/dbUitls");
+module.exports = {
+  action: "/node/autodeploy/list",
+  method: "post",
+  execute: (request, response) => {
+    let total = 0, records = []
+    Promise.all([
+      dbUtils.query(`select 1 from node_autodeploy`).then(res => {
+        return total = res.length
+      }),
+      new Promise(resolve => {
+        let sql = `select * from node_autodeploy`
+        dbUtils.query(sql).then(res => {
+          records = res
+          resolve()
+        })
+      })
+
+    ]).then(() => {
+      response.send({
+        code: 0,
+        data: {records, total}
+      })
+    })
+
+
+  }
+}

utils/dbUitls.js

@@ -5,7 +5,7 @@ module.exports = {
   init: () => {
     this.pool = mysql.createPool(dbConfig)
   },
-  query: sql => new Promise(resolve => {
+  query: sql => new Promise((resolve, reject) => {
     this.pool?.getConnection((err, conn) => {
       if (err) {
         console.log(err)
@@ -13,6 +13,7 @@ module.exports = {
         conn.query(sql, (err, result) => {
           if (err) {
             console.log(err)
+            reject(err)
           } else {
             conn.release()
             resolve(result)