change_audit.js 5.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date 2018/8/14
  7. * @version
  8. */
  9. const audit = require('../const/audit');
  10. module.exports = app => {
  11. class ChangeAudit extends app.BaseService {
  12. /**
  13. * 构造函数
  14. *
  15. * @param {Object} ctx - egg全局变量
  16. * @return {void}
  17. */
  18. constructor(ctx) {
  19. super(ctx);
  20. this.tableName = 'change_audit';
  21. }
  22. /**
  23. * 获取最后一位审批人
  24. * @param {int} cid - 变更令id
  25. * @param {int} times - 次数
  26. * @param {int} site - 位置
  27. * @return {void}
  28. */
  29. async getLastUser(cid, times, site = 1) {
  30. this.initSqlBuilder();
  31. this.sqlBuilder.setAndWhere('cid', {
  32. value: this.db.escape(cid),
  33. operate: '=',
  34. });
  35. this.sqlBuilder.setAndWhere('times', {
  36. value: times,
  37. operate: '=',
  38. });
  39. this.sqlBuilder.setAndWhere('status', {
  40. value: 1,
  41. operate: '!=',
  42. });
  43. if (site === 0) {
  44. this.sqlBuilder.setAndWhere('usite', {
  45. value: site,
  46. operate: '=',
  47. });
  48. }
  49. this.sqlBuilder.orderBy = [['usort', 'DESC']];
  50. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName);
  51. const data = await this.db.queryOne(sql, sqlParam);
  52. return data;
  53. }
  54. /**
  55. * 获取当前审批人查看info时的状态
  56. * @param {Object} change - 变更令数据
  57. * @return {void}
  58. */
  59. async getStatusByChange(change) {
  60. const statusConst = audit.flow.status;
  61. const auditStatusConst = audit.flow.auditStatus;
  62. const uid = this.ctx.session.sessionUser.accountId;
  63. const changeAuditInfo = await this.getAllDataByCondition({ where: { cid: change.cid, times: change.times, uid }, order: ['id', 'DESC'] });
  64. if (changeAuditInfo === null) {
  65. // 无权限查看此变更令
  66. return 0;
  67. }
  68. if (change.status === statusConst.uncheck && uid === change.uid) {
  69. // 待上报
  70. return 1;
  71. } else if (change.status === statusConst.back && uid === change.uid) {
  72. // 待重新上报
  73. return 2;
  74. } else if (change.status === statusConst.back && uid !== change.uid) {
  75. // 被退回但你不是原报人
  76. return 3;
  77. } else if (change.status === statusConst.checked) {
  78. // 已完成
  79. return 4;
  80. } else if (change.status === statusConst.checkNo) {
  81. // 已终止
  82. return 5;
  83. } else if (change.status === statusConst.checking && changeAuditInfo.status === auditStatusConst.checking) {
  84. // 待你审批
  85. return 6;
  86. } else if (change.status === statusConst.checking && changeAuditInfo.status !== auditStatusConst.checking) {
  87. // 审批中但你未到你审批或你已审批
  88. return 7;
  89. }
  90. // 无权限查看此变更令
  91. return 0;
  92. }
  93. /**
  94. * 根据用户查看此变更状态获取审批人列表
  95. * @param {Object} change - 变更令
  96. * @param {int} status - 状态
  97. * @return {object} list - 列表
  98. */
  99. async getListByStatus(change, status) {
  100. let sql = '';
  101. let sqlParam = '';
  102. switch (status) {
  103. case 1:// 待上报
  104. case 2:// 待重新上报
  105. sql = 'SELECT * FROM ?? WHERE ' +
  106. 'cid = ? AND times = ? GROUP BY usite';
  107. sqlParam = [this.tableName, change.cid,
  108. change.times];
  109. break;
  110. case 3: // 被退回但你不是原报人
  111. case 4:// 已完成
  112. case 5:// 已终止
  113. // 获取完整的审批顺序
  114. sql = 'SELECT a.* FROM ?? AS a WHERE ' +
  115. 'a.cid IN (SELECT b.cid FROM ?? AS b WHERE b.uid = ? GROUP BY b.cid) AND ' +
  116. 'a.status = ? AND a.tid = ?';
  117. sqlParam = [this.tableName, this.ctx.service.changeAudit.tableName,
  118. this.ctx.session.sessionUser.accountId, status, ''];
  119. break;
  120. case 7:// 审批中但你未到你审批或你已审批
  121. break;
  122. case 6:// 待你审批
  123. default:// 无权限查看此变更令
  124. break;
  125. }
  126. const list = await this.db.query(sql, sqlParam);
  127. return list;
  128. }
  129. /**
  130. * 删除变更令审批人列表
  131. * @param {Object} transaction - 事务
  132. * @param {Object} cid - 变更令id
  133. * @param {int} times - 次数
  134. * @return {object} 返回结果
  135. */
  136. async deleteAuditData(transaction, cid, times) {
  137. this.initSqlBuilder();
  138. this.sqlBuilder.setAndWhere('cid', {
  139. value: this.db.escape(cid),
  140. operate: '=',
  141. });
  142. this.sqlBuilder.setAndWhere('times', {
  143. value: times,
  144. operate: '=',
  145. });
  146. this.sqlBuilder.setAndWhere('usite', {
  147. value: 0,
  148. operate: '!=',
  149. });
  150. const [sql, sqlParam] = this.sqlBuilder.build(this.tableName, 'delete');
  151. const result = await transaction.query(sql, sqlParam);
  152. return result;
  153. }
  154. }
  155. return ChangeAudit;
  156. };