ledger_audit_controller.js 10.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date 2018/5/28
  7. * @version
  8. */
  9. const auditConst = require('../const/audit').ledger;
  10. const spreadConst = require('../const/spread');
  11. const shenpiConst = require('../const/shenpi');
  12. const measureType = require('../const/tender').measureType;
  13. module.exports = app => {
  14. class LedgerAuditController extends app.BaseController {
  15. /**
  16. * 构造函数
  17. *
  18. * @param {Object} ctx - egg全局context
  19. * @return {void}
  20. */
  21. constructor(ctx) {
  22. super(ctx);
  23. ctx.showProject = true;
  24. }
  25. /**
  26. * 获取SpreadSetting
  27. * @private
  28. */
  29. _getSpreadSetting() {
  30. const _ = this.app._;
  31. function removeFieldCols(setting, cols) {
  32. _.remove(setting.cols, function(c) {
  33. return cols.indexOf(c.field) > -1;
  34. });
  35. }
  36. const tender = this.ctx.tender;
  37. const setting = tender.data.measure_type === measureType.tz.value
  38. ? (tender.info.display.ledger.clQty ? spreadConst.withCl : spreadConst.withoutCl)
  39. : (tender.info.display.ledger.clQty ? spreadConst.withClGcl : spreadConst.withoutClGcl);
  40. const ledger = JSON.parse(JSON.stringify(setting.ledger));
  41. const pos = setting.pos ? JSON.parse(JSON.stringify(setting.pos)) : spreadConst.blank;
  42. ledger.readOnly = true;
  43. pos.readOnly = true;
  44. if (tender.data.measure_type === measureType.tz.value) {
  45. removeFieldCols(ledger, spreadConst.filterCols.tzWithoutCols);
  46. }
  47. if (!tender.info.display.ledger.dgnQty) {
  48. removeFieldCols(ledger, spreadConst.filterCols.dgnCols);
  49. }
  50. return [ledger, pos];
  51. }
  52. /**
  53. * 台账审批页面(get)
  54. *
  55. * @param ctx
  56. * @return {Promise<void>}
  57. */
  58. async index(ctx) {
  59. try {
  60. const renderData = {
  61. tender: ctx.tender.data,
  62. tenderInfo: ctx.tender.info,
  63. tenderMenu: this.menu.tenderMenu,
  64. preUrl: '/tender/' + ctx.tender.id,
  65. measureType,
  66. };
  67. const [ledgerSpread, posSpread] = this._getSpreadSetting();
  68. const curAuditor = await ctx.service.ledgerAudit.getCurAuditor(ctx.tender.id, ctx.tender.data.ledger_times);
  69. if (!curAuditor && (ctx.tender.data.ledger_status !== auditConst.status.checkNo && ctx.tender.data.ledger_status !== auditConst.status.checked)) {
  70. throw '审核信息错误';
  71. }
  72. renderData.user = await ctx.service.projectAccount.getAccountInfoById(ctx.tender.data.user_id);
  73. renderData.auditHistory = [];
  74. const times = ctx.tender.data.ledger_status === auditConst.status.checkNo ? ctx.tender.data.ledger_times - 1 : ctx.tender.data.ledger_times;
  75. const auditors = await ctx.service.ledgerAudit.getAuditorsWithOwner(ctx.tender.id, times);
  76. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) {
  77. if (auditors.length > 0) {
  78. const auditor = auditors.find(function(a) { return a.audit_id === ctx.session.sessionUser.accountId; });
  79. if (!auditor) {
  80. throw '您无权查看台账审批';
  81. }
  82. }
  83. }
  84. if (times >= 1) {
  85. for (let i = 1; i <= times; i++) {
  86. renderData.auditHistory.push(await ctx.service.ledgerAudit.getAuditors(ctx.tender.id, i));
  87. }
  88. }
  89. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  90. renderData.curAuditor = curAuditor;
  91. renderData.auditConst = auditConst;
  92. renderData.auditors = auditors;
  93. renderData.ledger = JSON.stringify(ledgerData);
  94. renderData.ledgerSpreadSetting = JSON.stringify(ledgerSpread);
  95. renderData.posSpreadSetting = JSON.stringify(posSpread);
  96. renderData.readOnly = true;
  97. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.ledger.audit);
  98. await this.layout('ledger/audit.ejs', renderData, 'ledger/audit_modal.ejs');
  99. } catch (err) {
  100. this.log(err);
  101. ctx.redirect('/tender/' + ctx.tender.id);
  102. }
  103. }
  104. /**
  105. * 新增审批人(Ajax)
  106. *
  107. * @param ctx
  108. * @return {Promise<void>}
  109. */
  110. async add(ctx) {
  111. const responseData = {
  112. err: 0,
  113. msg: '',
  114. data: [],
  115. };
  116. try {
  117. const data = JSON.parse(ctx.request.body.data);
  118. const id = data.auditorId;
  119. if (isNaN(id) || id <= 0) {
  120. throw '参数错误';
  121. }
  122. // 检查权限等
  123. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) {
  124. throw '您无权添加审核人';
  125. }
  126. if (ctx.tender.data.status === auditConst.status.checking || ctx.tender.data.status === auditConst.status.checked) {
  127. throw '当前不允许添加审核人';
  128. }
  129. // 检查审核人是否已存在
  130. const exist = await ctx.service.ledgerAudit.getAuditor(ctx.tender.id, id, ctx.tender.data.ledger_times);
  131. if (exist) {
  132. throw '该审核人已存在,请勿重复添加';
  133. }
  134. const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.ledger, sp_status: shenpiConst.sp_status.gdzs });
  135. const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.ledger === shenpiConst.sp_status.gdzs ? 1 : 0;
  136. const result = await ctx.service.ledgerAudit.addAuditor(ctx.tender.id, id, ctx.tender.data.ledger_times, is_gdzs);
  137. if (!result) {
  138. throw '添加审核人失败';
  139. }
  140. // responseData.data = await ctx.service.ledgerAudit.getAuditor(ctx.tender.id, id, ctx.tender.data.ledger_times);
  141. responseData.data = await ctx.service.ledgerAudit.getAuditorsWithOwner(ctx.tender.id, ctx.tender.data.ledger_times);
  142. } catch (err) {
  143. responseData.err = 1;
  144. responseData.msg = err.toString();
  145. }
  146. ctx.body = responseData;
  147. }
  148. /**
  149. * 移除审批人(Ajax)
  150. *
  151. * @param ctx
  152. * @return {Promise<void>}
  153. */
  154. async remove(ctx) {
  155. const responseData = {
  156. err: 0,
  157. msg: '',
  158. data: [],
  159. };
  160. try {
  161. const data = JSON.parse(ctx.request.body.data);
  162. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  163. if (isNaN(id) || id <= 0) {
  164. throw '参数错误';
  165. }
  166. const result = await ctx.service.ledgerAudit.deleteAuditor(ctx.tender.id, id, ctx.tender.data.ledger_times);
  167. if (!result) {
  168. throw '移除审核人失败';
  169. }
  170. responseData.data = await ctx.service.ledgerAudit.getAuditors(ctx.tender.id, ctx.tender.data.ledger_times);
  171. } catch (err) {
  172. responseData.err = 1;
  173. responseData.msg = err.toString();
  174. }
  175. ctx.body = responseData;
  176. }
  177. /**
  178. * 上报(post)
  179. *
  180. * @param ctx
  181. * @return {Promise<void>}
  182. */
  183. async start(ctx) {
  184. try {
  185. if (!ctx.tender.data || ctx.tender.data.ledger_status === auditConst.status.checking || ctx.tender.data.ledger_status === auditConst.status.checked) {
  186. throw '标段数据有误';
  187. }
  188. if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) {
  189. throw '上报失败';
  190. }
  191. await ctx.service.ledgerAudit.start(ctx.tender.id, ctx.tender.data.ledger_times);
  192. ctx.body = { err: 0, msg: '', data: { url: '/tender/' + ctx.tender.id + '/ledger' } };
  193. } catch (err) {
  194. this.log(err);
  195. ctx.session.postError = err.toString();
  196. ctx.body = this.ajaxErrorBody(err, '上报失败,请刷新页面重试');
  197. }
  198. }
  199. /**
  200. * 审批(post)
  201. *
  202. * @param ctx
  203. * @return {Promise<void>}
  204. */
  205. async check(ctx) {
  206. try {
  207. const tender = ctx.tender;
  208. if (!tender.data || tender.data.ledger_status !== auditConst.status.checking) {
  209. throw '当前标段数据有误';
  210. }
  211. const curAudit = await ctx.service.ledgerAudit.getCurAuditor(tender.id, tender.data.ledger_times);
  212. if (curAudit.audit_id !== ctx.session.sessionUser.accountId) {
  213. throw '审批失败';
  214. }
  215. const checkType = parseInt(ctx.request.body.checkType);
  216. if (!checkType || isNaN(checkType)) {
  217. throw '提交数据错误';
  218. }
  219. await ctx.service.ledgerAudit.check(tender.id, checkType, ctx.request.body.opinion, tender.data.ledger_times);
  220. ctx.redirect('/tender/' + ctx.tender.id + '/ledger');
  221. } catch (err) {
  222. this.log(err);
  223. ctx.session.postError = err.toString();
  224. ctx.redirect(ctx.request.header.referer);
  225. }
  226. }
  227. }
  228. return LedgerAuditController;
  229. };