数据管理中的修改、删除数据

router/dataMark/dataset.js

@@ -90,12 +90,12 @@ router.post('/getImportRecord', async (req, res) => {
 router.post('/getDataList', async (req, res) => {
   let user = await utils.getUserInfo({ req, res }),
     obj = req.body
-  let sql = `SELECT id,text,is_mark,state FROM mark_data_t WHERE 1=1`
+  let sql = `SELECT id,text,is_mark,state,marked_text,marker_id FROM mark_data_t WHERE dataset_id=?`
   sql = utils.setLike(sql, 'text', obj.text)
   sql = utils.setMoreId(sql, user)
-  let { total } = await utils.getSum({ sql, name: 'mark_data_t', res, req })
+  let { total } = await utils.getSumWhere({ sql, val: [obj.dataset_id], name: 'mark_data_t', res, req })
   sql = utils.pageSize(sql, obj.page, obj.size)
-  let { result } = await pools({ sql, res, req })
+  let { result } = await pools({ sql, val: [obj.dataset_id], req })
   res.send(utils.returnData({ data: result, total }))
 })
 
@@ -123,6 +123,7 @@ router.post('/importData', async (req, res) => {
     writeToDatabase(fileArr, list, req, res)
   }
 })
+// 写入数据库
 const writeToDatabase = (fileArr, list, req, res) => {
   let sqlParamsEntity = []
   let fileImportSql = 'INSERT INTO file_import_t(`id`,`name`,`importer_id`,`time`,`data_volume`,`dataset_id`) VALUES (?,?,?,?,?,?)'
@@ -155,4 +156,38 @@ const writeToDatabase = (fileArr, list, req, res) => {
       res.send(utils.returnData({ code: -1, msg, err, req }))
     })
 }
+
+// 修改text数据
+router.post('/updataData', async (req, res) => {
+  let sql = 'UPDATE mark_data_t SET text=? WHERE id=?'
+  console.log('obj', obj)
+  await pools({ sql, val: [obj.text, obj.id], run: false, res, req })
+})
+
+//删除
+router.post('/delData', async (req, res) => {
+  let sqlParams = []
+  obj = req.body
+  let placeholders = obj.map(() => '?').join(',')
+  let sql = `DELETE FROM mark_data_t WHERE id in (${placeholders})`
+  let sqlUpdata = `UPDATE file_import_t SET data_volume = data_volume - ${obj.length}`
+  sqlParams.push(
+    {
+      sql: sql,
+      values: obj
+    },
+    {
+      sql: sqlUpdata,
+      values: []
+    }
+  )
+  execTransection(sqlParams)
+    .then((resp) => {
+      res.send(utils.returnData({ code: 1, msg: '删除成功', data: [] }))
+    })
+    .catch((err) => {
+      res.send(utils.returnData({ code: -1, msg, err, req }))
+    })
+  // await pools({ sql, val: obj, run: false, res, req }) // 注意这里直接传递obj数组作为参数
+})
 module.exports = router

utils/index.js

@@ -271,7 +271,6 @@ module.exports = {
   async getSumWhere({ sql = '', val = [], name, res, req }) {
     const regex = /WHERE(.+)/
     const result = sql.match(regex)
-    console.log('result', result)
     let where = '1=1'
     if (result && result[1]) where = result[1].trim()
     let sqlRes = `SELECT count(1) FROM ${name} WHERE ${where}`