kubbo/dvcp-node-service
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

更新应用服务

Browse Source
This commit is contained in:
aixianling
2022-05-16 10:08:20 +08:00
parent c7f56d7958
commit a49d799afe
1 changed files with 19 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
src/rest/wechatapps/add.js
View File

@@ -1,11 +1,10 @@
const dbUtils = require("../../utils/dbUitls");
const {v4: uuid} = require('uuid');
const addOrUpdate = form => {
let sql
if (form.id) {//编辑
return dbUtils.query(`select 1 from node_wechat_apps where id=${form.id}`).then(res => {
if (res.length > 0) {//编辑
let arr = Object.keys(form).filter(e => form[e]).map(e => `${e}='${form[e]}'`)
sql = `update node_wechat_apps set ${arr.join(",")} where id='${form.name}'`
return `update node_wechat_apps set ${arr.join(",")} where id='${form.name}'`
} else {//新增
let cols = [], arr = []
Object.keys(form).map(e => {
@@ -14,26 +13,26 @@ const addOrUpdate = form => {
arr.push(`'${form[e]}'`)
}
})
sql = `insert into node_wechat_apps (id,${cols.join(",")}) values('${form.name}',${arr.join(",")})`
return `insert into node_wechat_apps (id,${cols.join(",")}) values('${form.name}',${arr.join(",")})`
}
return sql
})
}
module.exports = {
action: "/node/wechatapps/addOrUpdate",
method: "post",
execute: (request, response) => {
let form = request.body, sql
let form = request.body
if (form.list?.length > 0) {
Promise.all(form.list.map(e => dbUtils.query(addOrUpdate(e)))).then(() => {
Promise.all(form.list.map(e => addOrUpdate(e).then(sql => dbUtils.query(sql)))).then(() => {
response.send({code: 0})
}).catch(err => {
response.send({code: 1, err: err.sqlMessage})
})
} else {
if (form.name) {
sql = addOrUpdate(form)
sql && dbUtils.query(sql).then(() => {
addOrUpdate(form).then(sql => dbUtils.query(sql)).then(() => {
response.send({code: 0})
}).catch(err => {
response.send({code: 1, err: err.sqlMessage})