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-06-08 16:17:13 +08:00
parent 7afb62b16a
commit ac883222ca
1 changed files with 22 additions and 20 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -1,7 +1,6 @@
const dbUtils = require("../../utils/dbUitls"); const dbUtils = require("../../utils/dbUitls");
const addOrUpdate = form => { const addOrUpdate = form => {
return dbUtils.query(`delete from node_wechat_apps where type='${form.type}'`).then(() => {
let cols = [], arr = [] let cols = [], arr = []
Object.keys(form).map(e => { Object.keys(form).map(e => {
if (form[e]) { if (form[e]) {
@@ -9,8 +8,7 @@ const addOrUpdate = form => {
arr.push(`'${form[e]}'`) arr.push(`'${form[e]}'`)
} }
}) })
return `insert into node_wechat_apps (${cols.join(",")}) values(${arr.join(",")})` return Promise.resolve(`insert into node_wechat_apps (${cols.join(",")}) values(${arr.join(",")})`)
})
} }
module.exports = { module.exports = {
@@ -18,6 +16,7 @@ module.exports = {
method: "post", method: "post",
execute: (request, response) => { execute: (request, response) => {
let form = request.body let form = request.body
dbUtils.query(`delete from node_wechat_apps where type='${form.type}'`).then(() => {
if (form.list?.length > 0) { if (form.list?.length > 0) {
Promise.all(form.list.map(e => addOrUpdate(e).then(sql => dbUtils.query(sql)))).then(() => { Promise.all(form.list.map(e => addOrUpdate(e).then(sql => dbUtils.query(sql)))).then(() => {
response.send({code: 0}) response.send({code: 0})
@@ -33,5 +32,8 @@ module.exports = {
}) })
} else response.send({code: 1, err: "name必填"}) } else response.send({code: 1, err: "name必填"})
} }
}).catch(err => {
response.send({code: 1, err: err.sqlMessage})
})
} }
} }