rpt_archive_encryption.js 4.2 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126
  1. 'use strict';
  2. /**
  3. * Created by Tony on 2021/6/29.
  4. */
  5. const BaseService = require('../base/base_service');
  6. const rptArchiveConst = require('../const/rpt_archive');
  7. module.exports = app => {
  8. class RptArchiveEncryption extends BaseService {
  9. /**
  10. * 构造函数
  11. *
  12. * @param {Object} ctx - egg全局变量
  13. * @return {void}
  14. */
  15. constructor(ctx) {
  16. super(ctx);
  17. this.tableName = 'rpt_archive_encryption';
  18. this.dataId = 'id';
  19. }
  20. async getArchiveEncryptionById(id) {
  21. this.initSqlBuilder();
  22. this.sqlBuilder.setAndWhere('id', {
  23. value: id,
  24. operate: '=',
  25. });
  26. this.sqlBuilder.columns = ['id', 'prj_id', 'stage_id', 'content'];
  27. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  28. const list = await this.db.query(sql, sqlParam);
  29. return list;
  30. }
  31. async getArchiveEncryptionByBzId(prjId, stgId, bzId) {
  32. if (stgId > 0) {
  33. return await this.getPrjStgArchiveEncryption(prjId, stgId);
  34. }
  35. if (!bzId) return [];
  36. this.initSqlBuilder();
  37. this.sqlBuilder.setAndWhere('prj_id', {
  38. value: prjId,
  39. operate: '=',
  40. });
  41. this.sqlBuilder.setAndWhere('stage_id', {
  42. value: stgId,
  43. operate: '=',
  44. });
  45. this.sqlBuilder.setAndWhere('business_id', {
  46. value: `"${bzId}"`,
  47. operate: '=',
  48. });
  49. // this.sqlBuilder.columns = ['id', 'prj_id', 'stage_id', 'content'];
  50. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  51. const rstList = await this.db.query(sql, sqlParam);
  52. return rstList;
  53. }
  54. async getPrjStgArchiveEncryption(prjId, stgId) {
  55. this.initSqlBuilder();
  56. this.sqlBuilder.setAndWhere('prj_id', {
  57. value: prjId,
  58. operate: '=',
  59. });
  60. this.sqlBuilder.setAndWhere('stage_id', {
  61. value: stgId,
  62. operate: '=',
  63. });
  64. this.sqlBuilder.columns = ['id', 'prj_id', 'stage_id', 'content'];
  65. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  66. const rstList = await this.db.query(sql, sqlParam);
  67. return rstList;
  68. }
  69. async createArchiveEncryption(prj_id, stage_id, tender_id, business_id, archiveArr) {
  70. let rst = null;
  71. this.transaction = await this.db.beginTransaction();
  72. try {
  73. const data = {
  74. prj_id,
  75. stage_id,
  76. business_id,
  77. tender_id,
  78. business_type: rptArchiveConst.getBusinessType(stage_id),
  79. content: JSON.stringify(archiveArr),
  80. };
  81. // console.log(data);
  82. rst = await this.transaction.insert(this.tableName, data);
  83. await this.transaction.commit();
  84. } catch (ex) {
  85. console.log(ex);
  86. // 回滚
  87. await this.transaction.rollback();
  88. }
  89. return rst;
  90. }
  91. async updateArchiveEncryption(id, prj_id, stage_id, tender_id, business_id, archiveArr) {
  92. let rst = null;
  93. this.transaction = await this.db.beginTransaction();
  94. try {
  95. const data = {
  96. id,
  97. prj_id,
  98. stage_id,
  99. business_id,
  100. tender_id,
  101. business_type: rptArchiveConst.getBusinessType(stage_id),
  102. content: JSON.stringify(archiveArr),
  103. };
  104. // console.log(data);
  105. rst = await this.transaction.update(this.tableName, data);
  106. await this.transaction.commit();
  107. } catch (ex) {
  108. console.log(ex);
  109. // 回滚
  110. await this.transaction.rollback();
  111. }
  112. return rst;
  113. }
  114. }
  115. return RptArchiveEncryption;
  116. };