schedule_audit.js 1.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. 'use strict';
  2. const scheduleConst = require('../const/schedule');
  3. module.exports = app => {
  4. class ScheduleAudit extends app.BaseService {
  5. constructor(ctx) {
  6. super(ctx);
  7. this.tableName = 'schedule_audit';
  8. }
  9. async addAudit(data) {
  10. const transaction = await this.db.beginTransaction();
  11. try {
  12. const insertData = {
  13. tid: this.ctx.tender.id,
  14. audit_id: data.audit_id,
  15. in_time: new Date(),
  16. };
  17. const result = await transaction.insert(this.tableName, insertData);
  18. await transaction.commit();
  19. return await this.getDataById(result.insertId);
  20. } catch (err) {
  21. await transaction.rollback();
  22. throw err;
  23. }
  24. }
  25. async removeAudit(data) {
  26. const transaction = await this.db.beginTransaction();
  27. try {
  28. await transaction.delete(this.tableName, { id: data.id });
  29. await transaction.commit();
  30. return true;
  31. } catch (err) {
  32. await transaction.rollback();
  33. throw err;
  34. }
  35. }
  36. async editAudit(data) {
  37. const transaction = await this.db.beginTransaction();
  38. try {
  39. if (!this._.includes(this._.values(scheduleConst.permission), data.permission)) {
  40. throw '修改失败';
  41. }
  42. await transaction.update(this.tableName, { id: data.id, permission: data.permission });
  43. await transaction.commit();
  44. return true;
  45. } catch (err) {
  46. await transaction.rollback();
  47. throw err;
  48. }
  49. }
  50. }
  51. return ScheduleAudit;
  52. };