stage_check.js 8.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161
  1. 'use strict';
  2. /**
  3. *
  4. * @author Mai
  5. * @date
  6. * @version
  7. */
  8. const status = require('../const/audit').stage.status;
  9. const reviseStatus = require('../const/audit').revise.status;
  10. const shenpiConst = require('../const/shenpi');
  11. const _ = require('lodash');
  12. module.exports = options => {
  13. /**
  14. * 期校验 中间件
  15. * 1. 读取期数据
  16. * 2. 检验用户是否参与期(不校验具体权限)
  17. *
  18. * 写入ctx.stage数据
  19. * 其中:
  20. * stage.auditors: 审批人列表(退回原报时,加载上一流程)
  21. * stage.curAuditor: 当前审批人(未上报为空,审批通过 or 退回原报时,为空)
  22. * stage.readonly: 登录人,是否可操作
  23. * stage.curTimes: 当前登录人,操作、查阅数据times
  24. * stage.curOrder: 当前登录人,操作、查阅数据order
  25. *
  26. * 该方法为通用方法,如需stage其他数据,请在controller中查询
  27. *
  28. * @param {function} next - 中间件继续执行的方法
  29. * @return {void}
  30. */
  31. return function* stageCheck(next) {
  32. try {
  33. // 读取标段数据
  34. const stageOrder = parseInt(this.params.order);
  35. if (stageOrder <= 0) {
  36. throw '您访问的期不存在';
  37. }
  38. const stage = yield this.service.stage.getDataByCondition({
  39. tid: this.tender.id,
  40. order: stageOrder,
  41. });
  42. if (!stage) {
  43. throw '期数据错误';
  44. }
  45. // 读取原报、审核人数据
  46. stage.auditors = yield this.service.stageAudit.getAuditors(stage.id, stage.times);
  47. stage.curAuditor = yield this.service.stageAudit.getCurAuditor(stage.id, stage.times);
  48. // 获取最新的期
  49. stage.highOrder = yield this.service.stage.count({
  50. tid: this.tender.id,
  51. });
  52. const materials = yield this.service.material.getAllDataByCondition({ columns: ['stage_id', 's_order'], where: { tid: this.tender.id } });
  53. stage.hadMaterial = materials.find(function(item) {
  54. return item.s_order.split(',').indexOf(stage.highOrder.toString()) !== -1;
  55. });
  56. // 权限相关
  57. // todo 校验权限 (标段参与人、分享)
  58. const accountId = this.session.sessionUser.accountId,
  59. auditorIds = _.map(stage.auditors, 'aid'),
  60. shareIds = [];
  61. stage.users = stage.status === status.uncheck ? [stage.user_id] : [stage.user_id, ...auditorIds];
  62. const permission = this.session.sessionUser.permission;
  63. if (accountId === stage.user_id) { // 原报
  64. if (stage.curAuditor) {
  65. stage.readOnly = stage.curAuditor.aid !== accountId;
  66. } else {
  67. stage.readOnly = stage.status !== status.uncheck && stage.status !== status.checkNo;
  68. }
  69. stage.curTimes = stage.times;
  70. if (stage.status === status.uncheck || stage.status === status.checkNo) {
  71. stage.curOrder = 0;
  72. } else if (stage.status === status.checked) {
  73. stage.curOrder = _.max(_.map(stage.auditors, 'order'));
  74. } else {
  75. stage.curOrder = stage.curAuditor.aid === accountId ? stage.curAuditor.order : stage.curAuditor.order - 1;
  76. }
  77. } else if (auditorIds.indexOf(accountId) !== -1) { // 审批人
  78. if (stage.status === status.uncheck) {
  79. throw '您无权查看该数据';
  80. }
  81. stage.curTimes = stage.status === status.checkNo ? stage.times - 1 : stage.times;
  82. if (stage.status === status.checked) {
  83. stage.curOrder = _.max(_.map(stage.auditors, 'order'));
  84. } else if (stage.status === status.checkNo) {
  85. const audit = yield this.service.stageAudit.getDataByCondition({
  86. sid: stage.id, times: stage.times - 1, status: status.checkNo,
  87. });
  88. stage.curOrder = audit.order;
  89. } else {
  90. stage.curOrder = accountId === stage.curAuditor.aid ? stage.curAuditor.order : stage.curAuditor.order - 1;
  91. }
  92. stage.readOnly = (stage.status !== status.checking && stage.status !== status.checkNoPre) || accountId !== stage.curAuditor.aid;
  93. } else if (shareIds.indexOf(accountId) !== -1 || (permission !== null && permission.tender !== undefined && permission.tender.indexOf('2') !== -1)) { // 分享人
  94. if (stage.status === status.uncheck) {
  95. throw '您无权查看该数据';
  96. }
  97. stage.readOnly = true;
  98. stage.curTimes = stage.status === status.checkNo ? stage.times - 1 : stage.times;
  99. if (stage.status === status.checkNo) {
  100. const audit = yield this.service.stageAudit.getDataByCondition({
  101. sid: stage.id, times: stage.times - 1, status: status.checkNo,
  102. });
  103. stage.curOrder = audit.order;
  104. } else {
  105. stage.curOrder = stage.status === status.checked ? _.max(_.map(stage.auditors, 'order')) : stage.curAuditor.order - 1;
  106. }
  107. } else { // 其他不可见
  108. throw '您无权查看该数据';
  109. }
  110. const lastRevise = yield this.service.ledgerRevise.getLastestRevise(this.tender.id);
  111. stage.revising = (lastRevise && lastRevise.status !== reviseStatus.checked) || false;
  112. this.stage = stage;
  113. // 根据状态判断是否需要更新审批人列表
  114. if ((stage.status === status.uncheck || stage.status === status.checkNo) && this.tender.info.shenpi.stage !== shenpiConst.sp_status.sqspr) {
  115. const shenpi_status = this.tender.info.shenpi.stage;
  116. // 进一步比较审批流是否与审批流程设置的相同,不同则替换为固定审批流或固定的终审
  117. const auditList = yield this.service.stageAudit.getAllDataByCondition({ where: { sid: stage.id, times: stage.times } });
  118. const auditIdList = _.map(auditList, 'aid');
  119. if (shenpi_status === shenpiConst.sp_status.gdspl) {
  120. const shenpiList = yield this.service.shenpiAudit.getAllDataByCondition({ where: { tid: stage.tid, sp_type: shenpiConst.sp_type.stage, sp_status: shenpi_status } });
  121. const shenpiIdList = _.map(shenpiList, 'audit_id');
  122. // 判断2个id数组是否相同,不同则删除原审批流,切换成固定的审批流
  123. if (!_.isEqual(auditIdList, shenpiIdList)) {
  124. yield this.service.stageAudit.updateNewAuditList(stage, shenpiIdList);
  125. }
  126. } else if (shenpi_status === shenpiConst.sp_status.gdzs) {
  127. const shenpiInfo = yield this.service.shenpiAudit.getDataByCondition({ tid: stage.tid, sp_type: shenpiConst.sp_type.stage, sp_status: shenpi_status });
  128. // 判断最后一个id是否与固定终审id相同,不同则删除原审批流中如果存在的id和添加终审
  129. if (shenpiInfo && shenpiInfo.audit_id !== _.last(auditIdList)) {
  130. yield this.service.stageAudit.updateLastAudit(stage, auditList, shenpiInfo.audit_id);
  131. } else if (!shenpiInfo) {
  132. // 不存在终审人的状态下这里恢复为授权审批人
  133. this.tender.info.shenpi.stage = shenpiConst.sp_status.sqspr;
  134. }
  135. }
  136. }
  137. yield next;
  138. } catch (err) {
  139. this.helper.log(err);
  140. // 输出错误到日志
  141. if (err.stack) {
  142. this.logger.error(err);
  143. } else {
  144. this.getLogger('fail').info(JSON.stringify({
  145. error: err,
  146. project: this.session.sessionProject,
  147. user: this.session.sessionUser,
  148. body: this.session.body,
  149. }));
  150. }
  151. // 重定向值标段管理
  152. this.redirect(this.request.headers.referer);
  153. }
  154. };
  155. };