report.js 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const rptCustomData = require('../lib/rptCustomData');
  10. module.exports = app => {
  11. class Report extends app.BaseService {
  12. /**
  13. * 构造函数
  14. *
  15. * @param {Object} ctx - egg全局context
  16. * @return {void}
  17. */
  18. constructor(ctx) {
  19. super(ctx);
  20. }
  21. async checkStg(ctx, params) {
  22. if (ctx.stage === null || ctx.stage === undefined || parseInt(ctx.stage.id) !== parseInt(params.stage_id)) {
  23. await ctx.service.stage.checkStage(params.stage_id);
  24. if (ctx.stage) {
  25. params.stage_order = ctx.stage.curOrder;
  26. }
  27. }
  28. }
  29. async getReportData(params, filters, memFieldKeys, customDefine, customSelect) {
  30. const service = this.ctx.service;
  31. await service.tender.checkTender(params.tender_id);
  32. const rst = {};
  33. const runnableRst = [];
  34. const runnableKey = []; // 这个配合runnableRst用,未来考虑并行查询优化
  35. for (const filter of filters) {
  36. if (runnableKey.indexOf(filter) < 0) {
  37. switch (filter) {
  38. case 'project' :
  39. runnableRst.push(service.project.getProjectById(params.project_id));
  40. runnableKey.push(filter);
  41. break;
  42. case 'tender_info' :
  43. runnableRst.push(service.tenderInfo.getTenderInfoEx(params.tender_id));
  44. runnableKey.push(filter);
  45. break;
  46. case 'advance_pay':
  47. runnableRst.push(service.advance.getAllDataByCondition({ where: { tid: params.tender_id } }));
  48. runnableKey.push(filter);
  49. break;
  50. case 'deal_bills' :
  51. runnableRst.push(service.dealBills.getDataByTenderId(params.tender_id));
  52. runnableKey.push('deal_bills');
  53. break;
  54. case 'ledger' :
  55. runnableRst.push(service.ledger.getData(params.tender_id, 0));
  56. runnableKey.push(filter);
  57. break;
  58. case 'stage_bills':
  59. runnableRst.push(service.stageBills.getLastestStageData(params.tender_id, params.stage_id));
  60. runnableKey.push(filter);
  61. break;
  62. case 'stage_bills_final':
  63. await this.checkStg(this.ctx, params);
  64. runnableRst.push(service.stageBillsFinal.getFinalDataEx(params.tender_id, params.stage_order));
  65. runnableKey.push(filter);
  66. break;
  67. case 'stage':
  68. runnableRst.push(service.stage.getStageById(params.stage_id));
  69. runnableKey.push(filter);
  70. break;
  71. case 'stage_pay':
  72. await this.checkStg(this.ctx, params);
  73. runnableRst.push(service.stagePay.getAuditorStageData(params.stage_id, params.stage_times, params.stage_order));
  74. runnableKey.push(filter);
  75. break;
  76. case 'mem_stage_im_zl':
  77. runnableRst.push(service.reportMemory.getStageImZlData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  78. runnableKey.push(filter);
  79. break;
  80. case 'mem_month_progress':
  81. runnableRst.push(service.reportMemory.getMonthProgress(params.tender_id, memFieldKeys[filter]));
  82. runnableKey.push(filter);
  83. break;
  84. case 'stage_audit':
  85. runnableRst.push(service.reportMemory.getStageAuditors(params.tender_id, params.stage_id));
  86. runnableKey.push(filter);
  87. break;
  88. case 'mem_stage_bills':
  89. runnableRst.push(service.reportMemory.getStageBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  90. runnableKey.push(filter);
  91. break;
  92. case 'mem_stage_pos':
  93. runnableRst.push(service.reportMemory.getStagePosData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  94. runnableKey.push(filter);
  95. break;
  96. case 'mem_stage_pos_compare':
  97. runnableRst.push(service.reportMemory.getStagePosCompareData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  98. runnableKey.push(filter);
  99. break;
  100. case 'mem_stage_bills_compare':
  101. runnableRst.push(service.reportMemory.getStageBillsCompareData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  102. runnableKey.push(filter);
  103. break;
  104. case 'mem_stage_pay':
  105. runnableRst.push(service.reportMemory.getStagePayData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  106. runnableKey.push(filter);
  107. break;
  108. case 'change':
  109. runnableRst.push(service.change.getListByStatus(params.tender_id, 3)); // 获取所有审核通过的变更主信息
  110. runnableKey.push(filter);
  111. break;
  112. case 'change_audit_list':
  113. runnableRst.push(service.changeAuditList.getChangeAuditBills(params.tender_id)); // 获取所有审核通过的变更清单
  114. runnableKey.push(filter);
  115. console.log(filter);
  116. break;
  117. case 'mem_stage_jgcl':
  118. runnableRst.push(service.reportMemory.getStageJgcl(params.tender_id, params.stage_id, memFieldKeys[filter]));
  119. runnableKey.push(filter);
  120. break;
  121. case 'mem_stage_bonus':
  122. runnableRst.push(service.reportMemory.getStageBonus(params.tender_id, params.stage_id, memFieldKeys[filter]));
  123. runnableKey.push(filter);
  124. break;
  125. case 'mem_stage_other':
  126. runnableRst.push(service.reportMemory.getStageOther(params.tender_id, params.stage_id, memFieldKeys[filter]));
  127. runnableKey.push(filter);
  128. break;
  129. case 'mem_gather_stage_bills':
  130. runnableRst.push(service.rptGatherMemory.getGatherStageBills(memFieldKeys[filter],
  131. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  132. runnableKey.push(filter);
  133. break;
  134. case 'mem_gather_tender_info':
  135. runnableRst.push(service.rptGatherMemory.getGatherTenderInfo(memFieldKeys[filter],
  136. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  137. runnableKey.push(filter);
  138. break;
  139. case 'mem_gather_stage_pay':
  140. runnableRst.push(service.rptGatherMemory.getGatherStagePay(memFieldKeys[filter],
  141. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  142. runnableKey.push(filter);
  143. break;
  144. case 'mem_gather_deal_bills':
  145. runnableRst.push(service.rptGatherMemory.getGatherDealBills(memFieldKeys[filter],
  146. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  147. runnableKey.push(filter);
  148. break;
  149. case 'mem_material':
  150. runnableRst.push(service.reportMemory.getMaterial(params.tender_id, params.material_order, memFieldKeys[filter]));
  151. runnableKey.push(filter);
  152. break;
  153. case 'mem_material_gl':
  154. runnableRst.push(service.reportMemory.getMaterialGl(params.tender_id, params.material_order, memFieldKeys[filter]));
  155. runnableKey.push(filter);
  156. break;
  157. case 'mem_material_gl_detail':
  158. runnableRst.push(service.reportMemory.getMaterialGlDetail(params.tender_id, params.material_order, memFieldKeys[filter]));
  159. runnableKey.push(filter);
  160. break;
  161. case 'mem_material_bills':
  162. runnableRst.push(service.reportMemory.getMaterialBills(params.tender_id, params.material_order, memFieldKeys[filter]));
  163. runnableKey.push(filter);
  164. break;
  165. case 'mem_material_pos':
  166. runnableRst.push(service.reportMemory.getMaterialPos(params.tender_id, params.material_order, memFieldKeys[filter]));
  167. runnableKey.push(filter);
  168. break;
  169. case 'mem_stage_sum_bills':
  170. runnableRst.push(service.rptStageSumMemory.getStageSumBills(params.tender_id, memFieldKeys[filter],
  171. customDefine.stage_select, customSelect ? customSelect.stage_select : null));
  172. runnableKey.push(filter);
  173. break;
  174. case 'mem_stage_sum_pay':
  175. runnableRst.push(service.rptStageSumMemory.getStageSumPay(params.tender_id, memFieldKeys[filter],
  176. customDefine.stage_select, customSelect ? customSelect.stage_select : null));
  177. runnableKey.push(filter);
  178. break;
  179. case 'ledger_cooperation':
  180. runnableRst.push(service.ledgerCooperation.getValidData(params.tender_id));
  181. runnableKey.push(filter);
  182. break;
  183. case 'mem_sign_select':
  184. runnableRst.push(service.reportMemory.getSignSelect(params.tender_id, params.stage_id, customSelect));
  185. runnableKey.push(filter);
  186. break;
  187. case 'mem_stage_change':
  188. runnableRst.push(service.stageChange.getAllDataByCondition({ where: { tid: params.tender_id, sid: params.stage_id } }));
  189. runnableKey.push(filter);
  190. break;
  191. case 'mem_stage_change_bills':
  192. runnableRst.push(service.stageChangeFinal.getFinalData(params.tender_id));
  193. runnableKey.push(filter);
  194. break;
  195. case 'mem_ledger_tag':
  196. runnableRst.push(service.ledgerTag.getDatas(params.tender_id));
  197. runnableKey.push(filter);
  198. break;
  199. case 'mem_stage_tag':
  200. runnableRst.push(service.ledgerTag.getDatas(params.tender_id, params.stage_id));
  201. runnableKey.push(filter);
  202. break;
  203. case 'mem_all_tag':
  204. runnableRst.push(service.ledgerTag.getAllDataByCondition({ where: { tid: params.tender_id } }));
  205. runnableKey.push(filter);
  206. break;
  207. default:
  208. break;
  209. }
  210. }
  211. }
  212. const queryRst = await Promise.all(runnableRst);
  213. for (let idx = 0; idx < runnableKey.length; idx++) {
  214. rst[runnableKey[idx]] = queryRst[idx];
  215. }
  216. for (const filter of filters) {
  217. switch (filter) {
  218. case 'mem_custom_select':
  219. rst[filter] = customSelect;
  220. break;
  221. case 'mem_stage_im_tz':
  222. rst[filter] = await service.reportMemory.getStageImTzData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  223. break;
  224. case 'mem_stage_im_tz_bills':
  225. rst[filter] = await service.reportMemory.getStageImTzBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  226. break;
  227. case 'mem_union_data':
  228. rst[filter] = [];
  229. break;
  230. case 'mem_change':
  231. rst[filter] = await service.reportMemory.getChangeData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  232. break;
  233. case 'mem_change_bills':
  234. rst[filter] = await service.reportMemory.getChangeBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  235. break;
  236. case 'mem_jh_im_change':
  237. const jhHelper1 = new rptCustomData.jhHelper(this.ctx);
  238. rst[filter] = await jhHelper1.convert(params.tender_id, params.stage_id, memFieldKeys[filter], customDefine.setting);
  239. break;
  240. case 'mem_jh_gather_im_change':
  241. const jhHelper2 = new rptCustomData.jhHelper(this.ctx);
  242. rst[filter] = await jhHelper2.gather(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  243. break;
  244. // case 'mem_material_bills':
  245. // rst[filter] = await service.rptGatherMemory.getMaterialBills(params.tender_id, params.material_order, memFieldKeys[filter]);
  246. // break;
  247. // case 'mem_material_bills_gl':
  248. // rst[filter] = await service.rptGatherMemory.getMaterialBillsGl(params.tender_id, params.material_order, memFieldKeys[filter]);
  249. // break;
  250. default:
  251. break;
  252. }
  253. }
  254. return rst;
  255. }
  256. }
  257. return Report;
  258. };