measure_controller.js 12 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311
  1. 'use strict';
  2. /**
  3. * 计量相关控制器
  4. *
  5. * @author olym
  6. * @date 2018/2/11
  7. * @version
  8. */
  9. const spreadConst = require('../const/spread');
  10. const codeRuleConst = require('../const/code_rule');
  11. const auditConst = require('../const/audit').stage;
  12. const auditType = require('../const/audit').auditType;
  13. const moment = require('moment');
  14. const measureType = require('../const/tender').measureType;
  15. module.exports = app => {
  16. class MeasureController extends app.BaseController {
  17. /**
  18. * 构造函数
  19. *
  20. * @param {Object} ctx - egg全局变量
  21. * @return {void}
  22. */
  23. constructor(ctx) {
  24. super(ctx);
  25. ctx.showProject = true;
  26. ctx.showTender = true;
  27. ctx.showTitle = true;
  28. }
  29. /**
  30. * 期列表(Get)
  31. * @param ctx
  32. * @return {Promise<void>}
  33. */
  34. async stage(ctx) {
  35. try {
  36. const renderData = {
  37. tender: ctx.tender.data,
  38. tenderMenu: this.menu.tenderMenu,
  39. preUrl: '/tender/' + ctx.tender.id,
  40. auditConst,
  41. auditConst2: JSON.stringify(auditConst),
  42. auditType,
  43. };
  44. renderData.stages = await ctx.service.stage.getValidStages(ctx.tender.id, this.ctx.session.sessionUser.is_admin);
  45. for (const s of renderData.stages) {
  46. // 根据期状态返回展示用户
  47. s.curAuditors = await ctx.service.stageAudit.getAuditorsByStatus(s.id, s.status, s.times);
  48. if (s.status === auditConst.status.checkNoPre) {
  49. s.curAuditors2 = await ctx.service.stageAudit.getAuditorsByStatus(s.id, auditConst.status.checking, s.times);
  50. }
  51. }
  52. renderData.unCompleteStageCount = renderData.stages.filter(s => { return s.status !== auditConst.status.checked; }).length;
  53. await this.layout('measure/stage.ejs', renderData, 'measure/stage_modal.ejs');
  54. } catch (err) {
  55. this.log(err);
  56. ctx.redirect(this.menu.menu.dashboard.url);
  57. }
  58. }
  59. /**
  60. * 期审批流程(Get)
  61. * @param ctx
  62. * @return {Promise<void>}
  63. */
  64. async stageAuditors(ctx) {
  65. try {
  66. const order = JSON.parse(ctx.request.body.data).order;
  67. const tenderId = ctx.params.id;
  68. const stageInfo = await ctx.service.stage.getDataByCondition({ tid: tenderId, order });
  69. await ctx.service.stage.loadStageUser(stageInfo);
  70. await ctx.service.stage.loadStageAuditViewData(stageInfo);
  71. ctx.body = { err: 0, msg: '', data: stageInfo };
  72. } catch (error) {
  73. this.log(error);
  74. ctx.body = { err: 1, msg: error.toString(), data: null };
  75. }
  76. }
  77. /**
  78. * 新增期(Post)
  79. * @param ctx
  80. * @return {Promise<void>}
  81. */
  82. async add(ctx) {
  83. try {
  84. if (ctx.session.sessionUser.accountId !== ctx.tender.data.user_id) {
  85. throw '您无权创建计量期';
  86. }
  87. const date = ctx.request.body.date;
  88. const period = ctx.request.body.period;
  89. if (!date || !period) {
  90. throw '请选择计量年月和开始-截止日期';
  91. }
  92. const stages = await ctx.service.stage.getAllDataByCondition({ where: { tid: ctx.tender.id }});
  93. const unCompleteStageCount = stages.filter(s => { return s.status !== auditConst.status.checked; }).length;
  94. if (unCompleteStageCount.length > 0) {
  95. if (ctx.session.sessionProject.page_show.openMultiStageCalc) {
  96. if (unCompleteStageCount >= ctx.session.sessionProject.page_show.maxMultiStageCount)
  97. throw `最多只可同时进行${ctx.session.sessionProject.page_show.maxMultiStageCount}期计量`;
  98. } else {
  99. throw `最新一起未审批通过,请审批通过后再新增计量`
  100. }
  101. }
  102. const newStage = await ctx.service.stage.addStage(ctx.tender.id, date, period);
  103. if (!newStage) {
  104. throw '新增计量期失败,请重试';
  105. }
  106. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage/' + newStage.order);
  107. } catch (err) {
  108. this.log(err);
  109. ctx.redirect(ctx.request.header.referer);
  110. }
  111. }
  112. /**
  113. * 编辑期(Post)
  114. * @param ctx
  115. * @return {Promise<void>}
  116. */
  117. async save(ctx) {
  118. try {
  119. const data = {
  120. order: ctx.request.body.order,
  121. date: ctx.request.body.date,
  122. period: ctx.request.body.period,
  123. };
  124. const stage = await ctx.service.stage.getDataByCondition({
  125. tid: ctx.tender.id,
  126. order: data.order,
  127. });
  128. if (!stage) {
  129. throw '提交数据错误';
  130. }
  131. // if (stage.status === auditConst.status.checked) {
  132. // throw '该计量期当前不可编辑';
  133. // }
  134. if (ctx.session.sessionUser.accountId !== stage.user_id) {
  135. throw '您无权修改该数据';
  136. }
  137. await this.ctx.service.stage.saveStage(ctx.tender.id, data.order, data.date, data.period);
  138. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage/');
  139. } catch (err) {
  140. this.log(err);
  141. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage/');
  142. }
  143. }
  144. /**
  145. * 多期汇总 (Get)
  146. * @param ctx
  147. * @return {Promise<void>}
  148. */
  149. async gather(ctx) {
  150. try {
  151. const renderData = {
  152. tender: ctx.tender.data,
  153. tenderMenu: this.menu.tenderMenu,
  154. preUrl: '/tender/' + ctx.tender.id,
  155. };
  156. await this.layout('measure/gather.ejs', renderData);
  157. } catch (err) {
  158. this.log(err);
  159. ctx.redirect(this.menu.menu.dashboard.url);
  160. }
  161. }
  162. /**
  163. * 多期比较(Get)
  164. * @param ctx
  165. * @return {Promise<void>}
  166. */
  167. async compare(ctx) {
  168. try {
  169. const renderData = {
  170. tender: ctx.tender.data,
  171. tenderMenu: this.menu.tenderMenu,
  172. preUrl: '/tender/' + ctx.tender.id,
  173. };
  174. renderData.stages = await ctx.service.stage.getAllDataByCondition({
  175. where: { tid: ctx.tender.id, status: auditConst.status.checked },
  176. orders: [['order', 'asc']],
  177. });
  178. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.measure.compare);
  179. await this.layout('measure/compare.ejs', renderData, 'measure/compare_modal.ejs');
  180. } catch (err) {
  181. this.log(err);
  182. ctx.redirect(this.menu.menu.dashboard.url);
  183. }
  184. }
  185. joinData(main, idField, rela) {
  186. const index = {},
  187. indexPre = 'id_';
  188. const loadFields = function(datas, fields, prefix, relaId) {
  189. for (const d of datas) {
  190. const key = indexPre + d[relaId];
  191. let m = index[key];
  192. if (!m) {
  193. m = {};
  194. m[idField] = d[relaId];
  195. main.push(m);
  196. index[indexPre + d[relaId]] = m;
  197. }
  198. for (const f of fields) {
  199. if (d[f] !== undefined) {
  200. m[prefix + f] = d[f];
  201. }
  202. }
  203. }
  204. };
  205. for (const m of main) {
  206. index[indexPre + m[idField]] = m;
  207. for (const r of rela) {
  208. if (r.defaultData) _.assignIn(m, r.defaultData);
  209. }
  210. }
  211. for (const r of rela) {
  212. loadFields(r.data, r.fields, r.prefix, r.relaId);
  213. }
  214. }
  215. /**
  216. * 多期比较 - 获取数据(Ajax)
  217. * @param ctx
  218. * @return {Promise<void>}
  219. */
  220. async loadCompareData(ctx) {
  221. try {
  222. const data = JSON.parse(ctx.request.body.data);
  223. const result = {
  224. main: null,
  225. stages: [],
  226. };
  227. if (data.main) {
  228. result.main = {};
  229. result.main.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  230. result.main.pos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  231. result.main.deal = await ctx.service.dealBills.getAllDataByCondition({ where: { tender_id: ctx.tender.id } });
  232. }
  233. if (data.stages) {
  234. for (const order of data.stages) {
  235. const data = { order, bills: [], pos: [] };
  236. const stage = await this.ctx.service.stage.getDataByCondition({ tid: ctx.tender.id, order });
  237. data.bills = await ctx.service.stageBills.getLastestStageData2(ctx.tender.id, stage.id);
  238. const bpcData = await ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: stage.id } });
  239. this.joinData(data.bills, 'lid', [
  240. { data: bpcData, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp'], prefix: '', relaId: 'lid' },
  241. ]);
  242. data.pos = await ctx.service.stagePos.getLastestStageData2(ctx.tender.id, stage.id);
  243. result.stages.push(data);
  244. }
  245. }
  246. ctx.body = { err: 0, msg: '', data: result };
  247. } catch (err) {
  248. this.log(err);
  249. ctx.body = this.ajaxErrorBody(err, '获取数据错误');
  250. }
  251. }
  252. /**
  253. * 删除期(Post)
  254. * @param ctx
  255. * @return {Promise<void>}
  256. */
  257. async delete(ctx) {
  258. try {
  259. const stage_id = ctx.request.body.stage_id;
  260. const stageInfo = await ctx.service.stage.getDataById(stage_id);
  261. // 获取最新的期数
  262. const stage_highOrder = await ctx.service.stage.count({
  263. tid: ctx.tender.id,
  264. });
  265. const readySettle = await ctx.service.settle.getReadySettle(stageInfo.tid);
  266. if (readySettle && readySettle.final_sorder >= stageInfo.order) {
  267. throw '已结算,不可删除';
  268. }
  269. if (ctx.request.body.confirm !== undefined && ctx.request.body.confirm !== '确认删除本期') {
  270. throw '请输入正确的文本信息';
  271. }
  272. const relaStage = await ctx.service.stageRela.getDataByCondition({ rela_sid: stage_id });
  273. if (relaStage) throw `该期已关联到标段"${relaStage.rela_tname}",不可删除`;
  274. if (stageInfo && (ctx.session.sessionUser.accountId === stageInfo.user_id || (ctx.session.sessionUser.is_admin && ctx.request.body.confirm === '确认删除本期')) && stage_highOrder === stageInfo.order) {
  275. const result = await ctx.service.stage.deleteStage(stage_id);
  276. if (!result) {
  277. throw '删除计量期失败,请重试';
  278. }
  279. } else {
  280. throw '您无权删除计量期';
  281. }
  282. if (ctx.request.body.stage_order !== undefined && parseInt(ctx.request.body.stage_order) !== stage_highOrder) {
  283. ctx.redirect(ctx.request.header.referer);
  284. } else {
  285. ctx.redirect('/tender/' + ctx.tender.id + '/measure/stage/');
  286. }
  287. } catch (err) {
  288. this.log(err);
  289. console.log(err);
  290. ctx.redirect(ctx.request.header.referer);
  291. }
  292. }
  293. }
  294. return MeasureController;
  295. };