role_rpt_rel.js 7.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196
  1. 'use strict';
  2. /**
  3. * Created by Tony on 2019/9/26.
  4. */
  5. const BaseService = require('../base/base_service');
  6. module.exports = app => {
  7. class RoleRptRel extends BaseService {
  8. /**
  9. * 构造函数
  10. *
  11. * @param {Object} ctx - egg全局变量
  12. * @return {void}
  13. */
  14. constructor(ctx) {
  15. super(ctx);
  16. this.tableName = 'role_rpt_rel';
  17. this.dataId = 'id';
  18. }
  19. async getRoleRptRelById(id) {
  20. this.initSqlBuilder();
  21. this.sqlBuilder.setAndWhere('id', {
  22. value: id,
  23. operate: '=',
  24. });
  25. this.sqlBuilder.columns = ['id', 'tender_id', 'rpt_id', 'rel_content'];
  26. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  27. const list = await this.db.query(sql, sqlParam);
  28. return list;
  29. }
  30. async getRoleRptRelByTenderId(tenderId, stageId) {
  31. this.initSqlBuilder();
  32. this.sqlBuilder.setAndWhere('tender_id', {
  33. value: tenderId,
  34. operate: '=',
  35. });
  36. if (stageId) {
  37. this.sqlBuilder.setAndWhere('sid', {
  38. value: stageId,
  39. operate: '=',
  40. });
  41. }
  42. this.sqlBuilder.columns = ['id', 'tender_id', 'rpt_id', 'sid', 'rel_content'];
  43. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  44. const list = await this.db.query(sql, sqlParam);
  45. // console.log(list);
  46. return list;
  47. }
  48. async getCrossTenderRoleRptRels(selectedTenders) {
  49. let rst = [];
  50. // 条件比较特别,需要直接写sql
  51. if (selectedTenders.length > 0) {
  52. let where_sql = '';
  53. for (let idx = 0; idx < selectedTenders.length; idx++) {
  54. if (idx === 0) {
  55. where_sql = '(tender_id = ' + selectedTenders[idx][0] + ' AND sid = ' + selectedTenders[idx][1] + ' AND rpt_id = ' + selectedTenders[idx][2] + ')';
  56. } else {
  57. where_sql = where_sql + ' OR (tender_id = ' + selectedTenders[idx][0] + ' AND sid = ' + selectedTenders[idx][1] + ' AND rpt_id = ' + selectedTenders[idx][2] + ')';
  58. }
  59. }
  60. const sql = 'SELECT ?? FROM ?? WHERE ' + where_sql;
  61. const columns = ['id', 'tender_id', 'rpt_id', 'sid', 'rel_content'];
  62. const sqlParam = [columns, this.tableName];
  63. rst = await this.db.query(sql, sqlParam);
  64. console.log(rst);
  65. }
  66. return rst;
  67. }
  68. async getRoleRptRelByDetailIds(tenderId, rptId, sid) {
  69. this.initSqlBuilder();
  70. this.sqlBuilder.setAndWhere('tender_id', {
  71. value: tenderId,
  72. operate: '=',
  73. });
  74. if (rptId instanceof Array) {
  75. this.sqlBuilder.setAndWhere('rpt_id', {
  76. value: rptId,
  77. operate: 'in',
  78. });
  79. } else {
  80. this.sqlBuilder.setAndWhere('rpt_id', {
  81. value: rptId,
  82. operate: '=',
  83. });
  84. }
  85. this.sqlBuilder.setAndWhere('sid', {
  86. value: sid,
  87. operate: '=',
  88. });
  89. this.sqlBuilder.columns = ['id', 'tender_id', 'rpt_id', 'sid', 'rel_content'];
  90. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  91. // console.log(sql);
  92. // console.log(this.tableName);
  93. // console.log(sqlParam);
  94. const list = await this.db.query(sql, sqlParam);
  95. // console.log(list);
  96. return list;
  97. }
  98. async createRoleRelationship(tender_id, rpt_id, sid, relArr) {
  99. let rst = null;
  100. this.transaction = await this.db.beginTransaction();
  101. try {
  102. const data = {
  103. tender_id: tender_id,
  104. rpt_id: rpt_id,
  105. sid: sid,
  106. rel_content: JSON.stringify(relArr),
  107. };
  108. rst = await this.transaction.insert(this.tableName, data);
  109. await this.transaction.commit();
  110. } catch (ex) {
  111. console.log(ex);
  112. // 回滚
  113. await this.transaction.rollback();
  114. }
  115. return rst;
  116. }
  117. async addInitialStageData(tender_id, stage, preStage) {
  118. // 在加stage的时候需要挂上这个,copy之前的签名人
  119. const rst = [];
  120. const preRoleRelList = await this.getRoleRptRelByTenderId(tender_id, preStage.id);
  121. for (const rptRoleRel of preRoleRelList) {
  122. const relList = JSON.parse(rptRoleRel.rel_content);
  123. // const newRptRoleRel = {tender_id: tender_id, rpt_id: rptRoleRel.rpt_id, sid: stage.id, rel_content: ''};
  124. const newRelList = [];
  125. for (const role of relList) {
  126. const newRole = {};
  127. newRelList.push(newRole);
  128. for (const key in role) {
  129. if (key !== 'sign_date') {
  130. newRole[key] = role[key];
  131. } else {
  132. newRole[key] = '';
  133. }
  134. }
  135. }
  136. // rst.push(await this.createRoleRelationship(tender_id, rptRoleRel.rpt_id, stage.id, newRelList));
  137. await this.createRoleRelationship(tender_id, rptRoleRel.rpt_id, stage.id, newRelList); // 暂时用不到,就先不返回结果
  138. }
  139. return rst;
  140. }
  141. async updateRoleRelationship(id, tender_id, rpt_id, sid, relArr) {
  142. let rst = null;
  143. if (id < 0) {
  144. rst = this.createRoleRelationship(tender_id, rpt_id, sid, relArr);
  145. } else {
  146. this.transaction = await this.db.beginTransaction();
  147. try {
  148. const data = { id: id, tender_id: tender_id, rpt_id: rpt_id, sid: sid, rel_content: JSON.stringify(relArr) };
  149. rst = await this.transaction.update(this.tableName, data);
  150. this.transaction.commit();
  151. } catch (ex) {
  152. console.log(ex);
  153. // 回滚
  154. await this.transaction.rollback();
  155. }
  156. }
  157. return rst;
  158. }
  159. async updateMultiRoleRelationship(orgParams, newRelArr) {
  160. let rst = false;
  161. this.transaction = await this.db.beginTransaction();
  162. try {
  163. // const data = { id: id, tender_id: tender_id, rpt_id: rpt_id, sid: sid, rel_content: JSON.stringify(relArr) };
  164. // rst = await this.transaction.update(this.tableName, data);
  165. // this.transaction.commit();
  166. for (let idx = 0; idx < orgParams.length; idx++) {
  167. const param = orgParams[idx];
  168. const data = { tender_id: param[0], sid: param[1], rpt_id: param[2] };
  169. await this.transaction.delete(this.tableName, data);
  170. this.createRoleRelationship(param[0], param[2], param[0], newRelArr);
  171. }
  172. rst = true;
  173. this.transaction.commit();
  174. } catch (ex) {
  175. console.log(ex.toString());
  176. // 回滚
  177. await this.transaction.rollback();
  178. }
  179. return rst;
  180. }
  181. }
  182. return RoleRptRel;
  183. };