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
2023-03-02 10:08:20 +08:00
parent c221ce8965
commit 6b9a777653
1 changed files with 11 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
src/utils/dbUitls.js
View File

@@ -3,7 +3,6 @@ const dbConfig = require("../config/db");
const {v4: uuid} = require("uuid"); const {v4: uuid} = require("uuid");
const dayjs = require("dayjs"); const dayjs = require("dayjs");
const chalk = require("chalk"); const chalk = require("chalk");
const {checkJson} = require("../tools");
const query = sql => new Promise((resolve, reject) => { const query = sql => new Promise((resolve, reject) => {
this.pool?.getConnection((err, conn) => { this.pool?.getConnection((err, conn) => {
if (err) { if (err) {
@@ -23,26 +22,24 @@ const query = sql => new Promise((resolve, reject) => {
const insert = ({table, form}) => { const insert = ({table, form}) => {
let sql let sql
if (form.id) {//编辑 if (form.id) {//编辑
let arr = Object.keys(form).filter(e => form[e]).map(e => { let arr = Object.entries(form).map(([e, v]) => {
if (typeof form[e] == "object") { if (v) {
if (checkJson(form[e])) { if (typeof v == "object") {
form[e] = JSON.stringify(form[e]).replace(/["']/g, "\\'") v = JSON.stringify(v)
console.log(form[e]) }
} else form[e] = JSON.stringify(form[e])
} }
return `${e}='${form[e]}'` return `${e}='${v}'`
}) })
sql = `update ${table} set ${arr.join(",")} where id='${form.id}'` sql = `update ${table} set ${arr.join(",")} where id='${form.id}'`
} else {//新增 } else {//新增
let cols = [], arr = [] let cols = [], arr = []
Object.keys(form).map(e => { Object.entries(form).map(([e, v]) => {
if (form[e]) { if (v) {
cols.push(e) cols.push(e)
if (typeof form[e] == "object") { if (typeof v == "object") {
if (checkJson(form[e])) form[e] = JSON.stringify(form[e]).replace(/["']/g, "\\'") v = JSON.stringify(v)
else form[e] = JSON.stringify(form[e])
} }
arr.push(`'${form[e]}'`) arr.push(`'${v}'`)
} }
}) })
sql = `insert into ${table} (id,createTime,${cols.join(",")}) values('${uuid()}','${dayjs().format("YYYY-MM-DD HH:mm:ss")}',${arr.join(",")})` sql = `insert into ${table} (id,createTime,${cols.join(",")}) values('${uuid()}','${dayjs().format("YYYY-MM-DD HH:mm:ss")}',${arr.join(",")})`