DeleteRule.js 1.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849
  1. const API = require("../../../lib/API");
  2. const db = require("../../../plugin/DataBase/db");
  3. const AccessControl = require("../../../lib/AccessControl");
  4. const { BaseStdResponse } = require("../../../BaseStdResponse");
  5. class DeleteRule extends API {
  6. constructor() {
  7. super();
  8. this.setPath('/QK/Rule')
  9. this.setMethod('DELETE')
  10. }
  11. async onRequest(req, res) {
  12. let { uuid, session, id } = req.body
  13. if ([uuid, session, id].some(value => value === '' || value === null || value === undefined))
  14. return res.json({
  15. ...BaseStdResponse.MISSING_PARAMETER
  16. })
  17. // 检查 session
  18. if (!await AccessControl.checkSession(uuid, session))
  19. return res.status(401).json({
  20. ...BaseStdResponse.ACCESS_DENIED
  21. })
  22. let sql = 'DELETE FROM qk_rule WHERE id = ? AND create_user = ?'
  23. let r = await db.query(sql, [id, uuid])
  24. try {
  25. if (r && r.affectedRows > 0) {
  26. res.json({
  27. ...BaseStdResponse.OK
  28. })
  29. } else {
  30. res.json({ ...BaseStdResponse.ERR, endpoint: 7894378, msg: '删除规则失败!数据库错误' })
  31. }
  32. } catch (err) {
  33. this.logger.error(`删除规则失败!${err.stack}`)
  34. res.json({
  35. ...BaseStdResponse.ERR,
  36. msg: "删除规则失败!",
  37. });
  38. }
  39. }
  40. }
  41. module.exports.DeleteRule = DeleteRule