diff --git a/src/rest/wechatapps/add.js b/src/rest/wechatapps/add.js index fb327d7..a3192f2 100644 --- a/src/rest/wechatapps/add.js +++ b/src/rest/wechatapps/add.js @@ -1,16 +1,14 @@ const dbUtils = require("../../utils/dbUitls"); const addOrUpdate = form => { - return dbUtils.query(`delete from node_wechat_apps where type='${form.type}'`).then(() => { - let cols = [], arr = [] - Object.keys(form).map(e => { - if (form[e]) { - cols.push(e) - arr.push(`'${form[e]}'`) - } - }) - return `insert into node_wechat_apps (${cols.join(",")}) values(${arr.join(",")})` + let cols = [], arr = [] + Object.keys(form).map(e => { + if (form[e]) { + cols.push(e) + arr.push(`'${form[e]}'`) + } }) + return Promise.resolve(`insert into node_wechat_apps (${cols.join(",")}) values(${arr.join(",")})`) } module.exports = { @@ -18,20 +16,24 @@ module.exports = { method: "post", execute: (request, response) => { let form = request.body - if (form.list?.length > 0) { - 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) { - addOrUpdate(form).then(sql => dbUtils.query(sql)).then(() => { + dbUtils.query(`delete from node_wechat_apps where type='${form.type}'`).then(() => { + if (form.list?.length > 0) { + 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 response.send({code: 1, err: "name必填"}) - } + } else { + if (form.name) { + addOrUpdate(form).then(sql => dbUtils.query(sql)).then(() => { + response.send({code: 0}) + }).catch(err => { + response.send({code: 1, err: err.sqlMessage}) + }) + } else response.send({code: 1, err: "name必填"}) + } + }).catch(err => { + response.send({code: 1, err: err.sqlMessage}) + }) } }