report.js 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const BudgetSource = require('../lib/rm/tender_budget');
  10. const MaterialSource = require('../lib/rm/material');
  11. const rptCustomData = require('../lib/rptCustomData');
  12. const bindData = {
  13. materialGather: ['mem_material_gather_bills', 'mem_material_gather_xmj', 'mem_material_gather_gl'],
  14. gatherChange: ['mem_gather_change', 'mem_gather_change_bills'],
  15. fjChange: ['mem_fj_change_progress', 'mem_fj_change_sum'],
  16. };
  17. const sourceTypeConst = require('../const/source_type');
  18. module.exports = app => {
  19. class Report extends app.BaseService {
  20. /**
  21. * 构造函数
  22. *
  23. * @param {Object} ctx - egg全局context
  24. * @return {void}
  25. */
  26. constructor(ctx) {
  27. super(ctx);
  28. }
  29. async checkStg(ctx, params) {
  30. if (ctx.stage === null || ctx.stage === undefined || parseInt(ctx.stage.id) !== parseInt(params.stage_id)) {
  31. await ctx.service.stage.checkStage(params.stage_id);
  32. if (ctx.stage) {
  33. params.stage_order = ctx.stage.curOrder;
  34. }
  35. }
  36. }
  37. getFilter(sourceFilters) {
  38. const common = [], spec = [];
  39. for (const sf of sourceFilters) {
  40. let bSpec = false;
  41. for (const key in bindData) {
  42. const b = bindData[key];
  43. if (b.indexOf(sf) >= 0) {
  44. bSpec = true;
  45. if (spec.indexOf(key) === -1) {
  46. spec.push(key);
  47. break;
  48. }
  49. }
  50. }
  51. if (!bSpec) common.push(sf);
  52. }
  53. return [common, spec];
  54. }
  55. getFieldKeys(source, filter) {
  56. const result = [];
  57. for (const f of filter) {
  58. if (source[f]) result.push(...source[f]);
  59. }
  60. return result;
  61. }
  62. async tender(params, sourceFilters, memFieldKeys, customDefine, customSelect) {
  63. const [filters, specFilters] = this.getFilter(sourceFilters);
  64. const service = this.ctx.service;
  65. await service.tender.checkTender(params.tender_id);
  66. const materialSource = new MaterialSource(this.ctx);
  67. const rst = {};
  68. const runnableRst = [];
  69. const runnableKey = []; // 这个配合runnableRst用,未来考虑并行查询优化
  70. const budgetSource = new BudgetSource(this.ctx);
  71. for (const filter of filters) {
  72. if (runnableKey.indexOf(filter) < 0) {
  73. switch (filter) {
  74. case 'project' :
  75. runnableRst.push(service.project.getProjectById(params.project_id));
  76. runnableKey.push(filter);
  77. break;
  78. case 'tender_info' :
  79. runnableRst.push(service.tenderInfo.getTenderInfoEx(params.tender_id));
  80. runnableKey.push(filter);
  81. break;
  82. case 'advance_pay':
  83. runnableRst.push(service.advance.getAllDataByCondition({ where: { tid: params.tender_id } }));
  84. runnableKey.push(filter);
  85. break;
  86. case 'deal_bills' :
  87. runnableRst.push(service.dealBills.getDataByTenderId(params.tender_id));
  88. runnableKey.push('deal_bills');
  89. break;
  90. case 'ledger' :
  91. runnableRst.push(service.ledger.getData(params.tender_id, 0));
  92. runnableKey.push(filter);
  93. break;
  94. case 'stage_bills':
  95. runnableRst.push(service.stageBills.getLastestStageData2(params.tender_id, params.stage_id));
  96. runnableKey.push(filter);
  97. break;
  98. case 'stage_bills_final':
  99. await this.checkStg(this.ctx, params);
  100. runnableRst.push(service.stageBillsFinal.getFinalDataEx(params.tender_id, params.stage_order));
  101. runnableKey.push(filter);
  102. break;
  103. case 'stage':
  104. runnableRst.push(service.stage.getStageById(params.stage_id));
  105. runnableKey.push(filter);
  106. break;
  107. case 'stage_pay':
  108. await this.checkStg(this.ctx, params);
  109. runnableRst.push(service.stagePay.getStagePays(this.ctx.stage));
  110. runnableKey.push(filter);
  111. break;
  112. case 'mem_stage_im_zl':
  113. runnableRst.push(service.reportMemory.getStageImZlData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  114. runnableKey.push(filter);
  115. break;
  116. case 'mem_month_progress':
  117. runnableRst.push(service.reportMemory.getMonthProgress(params.tender_id, memFieldKeys[filter]));
  118. runnableKey.push(filter);
  119. break;
  120. case 'stage_audit':
  121. runnableRst.push(service.reportMemory.getStageAuditors(params.tender_id, params.stage_id));
  122. runnableKey.push(filter);
  123. break;
  124. case 'mem_stage_audit_ass':
  125. runnableRst.push(service.reportMemory.getStageAuditAss(params.tender_id, params.stage_id));
  126. runnableKey.push(filter);
  127. break;
  128. case 'mem_stage_bills':
  129. runnableRst.push(service.reportMemory.getStageBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  130. runnableKey.push(filter);
  131. break;
  132. case 'mem_stage_bills_filter':
  133. runnableRst.push(service.reportMemory.getStageBillsData(params.tender_id, params.stage_id, memFieldKeys[filter], true));
  134. runnableKey.push(filter);
  135. break;
  136. case 'mem_stage_pos':
  137. runnableRst.push(service.reportMemory.getStagePosData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  138. runnableKey.push(filter);
  139. break;
  140. case 'mem_stage_pos_compare':
  141. runnableRst.push(service.reportMemory.getStagePosCompareData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  142. runnableKey.push(filter);
  143. break;
  144. case 'mem_stage_bills_compare':
  145. runnableRst.push(service.reportMemory.getStageBillsCompareData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  146. runnableKey.push(filter);
  147. break;
  148. case 'mem_stage_bills_compare_filter':
  149. runnableRst.push(service.reportMemory.getStageBillsCompareData(params.tender_id, params.stage_id, memFieldKeys[filter], true));
  150. runnableKey.push(filter);
  151. break;
  152. case 'mem_stage_pay':
  153. runnableRst.push(service.reportMemory.getStagePayData(params.tender_id, params.stage_id, memFieldKeys[filter]));
  154. runnableKey.push(filter);
  155. break;
  156. case 'change':
  157. runnableRst.push(service.change.getListByStatus(params.tender_id, 3)); // 获取所有审核通过的变更主信息
  158. runnableKey.push(filter);
  159. break;
  160. case 'change_audit_list':
  161. runnableRst.push(service.changeAuditList.getChangeAuditBills(params.tender_id)); // 获取所有审核通过的变更清单
  162. runnableKey.push(filter);
  163. break;
  164. case 'mem_stage_jgcl':
  165. runnableRst.push(service.reportMemory.getStageJgcl(params.tender_id, params.stage_id, memFieldKeys[filter]));
  166. runnableKey.push(filter);
  167. break;
  168. case 'mem_stage_bonus':
  169. runnableRst.push(service.reportMemory.getStageBonus(params.tender_id, params.stage_id, memFieldKeys[filter]));
  170. runnableKey.push(filter);
  171. break;
  172. case 'mem_stage_other':
  173. runnableRst.push(service.reportMemory.getStageOther(params.tender_id, params.stage_id, memFieldKeys[filter]));
  174. runnableKey.push(filter);
  175. break;
  176. case 'mem_stage_safe_prod':
  177. runnableRst.push(service.reportMemory.getStageSafeProd(params.tender_id, params.stage_id, memFieldKeys[filter]));
  178. runnableKey.push(filter);
  179. break;
  180. case 'mem_stage_temp_land':
  181. runnableRst.push(service.reportMemory.getStageTempLand(params.tender_id, params.stage_id, memFieldKeys[filter]));
  182. runnableKey.push(filter);
  183. break;
  184. case 'mem_gather_tender_info':
  185. runnableRst.push(service.rptGatherMemory.getGatherTenderInfo(memFieldKeys[filter],
  186. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  187. runnableKey.push(filter);
  188. break;
  189. case 'mem_gather_stage_pay':
  190. runnableRst.push(service.rptGatherMemory.getGatherStagePay(memFieldKeys[filter],
  191. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  192. runnableKey.push(filter);
  193. break;
  194. case 'mem_gather_deal_bills':
  195. runnableRst.push(service.rptGatherMemory.getGatherDealBills(memFieldKeys[filter],
  196. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  197. runnableKey.push(filter);
  198. break;
  199. case 'mem_gather_stage_jgcl':
  200. runnableRst.push(service.rptGatherMemory.getGatherStageJgcl(memFieldKeys[filter],
  201. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  202. runnableKey.push(filter);
  203. break;
  204. case 'mem_gather_stage_bonus':
  205. runnableRst.push(service.rptGatherMemory.getGatherStageBonus(memFieldKeys[filter],
  206. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  207. runnableKey.push(filter);
  208. break;
  209. case 'mem_gather_stage_other':
  210. runnableRst.push(service.rptGatherMemory.getGatherStageOther(memFieldKeys[filter],
  211. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  212. runnableKey.push(filter);
  213. break;
  214. case 'mem_gather_stage_safe_prod':
  215. runnableRst.push(service.rptGatherMemory.getGatherStageSafeProd(memFieldKeys[filter],
  216. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  217. runnableKey.push(filter);
  218. break;
  219. case 'mem_gather_stage_temp_land':
  220. runnableRst.push(service.rptGatherMemory.getGatherStageTempLand(memFieldKeys[filter],
  221. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  222. runnableKey.push(filter);
  223. break;
  224. case 'mem_gather_advance_pay':
  225. runnableRst.push(service.rptGatherMemory.getGatherAdvancePay(memFieldKeys[filter],
  226. customDefine.gather_select, customSelect ? customSelect.gather_select : null));
  227. runnableKey.push(filter);
  228. break;
  229. case 'mem_select_material':
  230. runnableRst.push(service.material.getSelectMaterial(params.tender_id, params.material_order));
  231. runnableKey.push(filter);
  232. break;
  233. case 'mem_select_material_audit':
  234. runnableRst.push(materialSource.getSelectMaterialAuditors(params.tender_id, params.material_order));
  235. runnableKey.push(filter);
  236. break;
  237. case 'mem_material':
  238. runnableRst.push(materialSource.getMaterial(params.tender_id, params.material_order, memFieldKeys[filter]));
  239. runnableKey.push(filter);
  240. break;
  241. case 'mem_material_gl':
  242. runnableRst.push(materialSource.getMaterialGl(params.tender_id, params.material_order, memFieldKeys[filter]));
  243. runnableKey.push(filter);
  244. break;
  245. case 'mem_material_gl_detail':
  246. runnableRst.push(materialSource.getMaterialGlDetail(params.tender_id, params.material_order, memFieldKeys[filter]));
  247. runnableKey.push(filter);
  248. break;
  249. case 'mem_material_bills':
  250. runnableRst.push(materialSource.getMaterialBills(params.tender_id, params.material_order, memFieldKeys[filter]));
  251. runnableKey.push(filter);
  252. break;
  253. case 'mem_material_bills_filter':
  254. runnableRst.push(materialSource.getMaterialBills(params.tender_id, params.material_order, memFieldKeys[filter], true));
  255. runnableKey.push(filter);
  256. break;
  257. case 'mem_material_pos':
  258. runnableRst.push(materialSource.getMaterialPos(params.tender_id, params.material_order, memFieldKeys[filter]));
  259. runnableKey.push(filter);
  260. break;
  261. case 'mem_material_stage':
  262. runnableRst.push(materialSource.getMaterialStage(params.tender_id, params.material_order, memFieldKeys[filter]));
  263. runnableKey.push(filter);
  264. break;
  265. case 'mem_stage_sum_bills':
  266. runnableRst.push(service.rptStageSumMemory.getStageSumBills(params.tender_id, memFieldKeys[filter],
  267. customDefine.stage_select, customSelect ? customSelect.stage_select : null));
  268. runnableKey.push(filter);
  269. break;
  270. case 'mem_stage_sum_bills_filter':
  271. runnableRst.push(service.rptStageSumMemory.getStageSumBills(params.tender_id, memFieldKeys[filter],
  272. customDefine.stage_select, customSelect ? customSelect.stage_select : null, true));
  273. runnableKey.push(filter);
  274. break;
  275. case 'mem_stage_sum_pos':
  276. runnableRst.push(service.rptStageSumMemory.getStageSumPos(params.tender_id, memFieldKeys[filter],
  277. customDefine.stage_select, customSelect ? customSelect.stage_select : null));
  278. runnableKey.push(filter);
  279. break;
  280. case 'mem_stage_sum_pay':
  281. runnableRst.push(service.rptStageSumMemory.getStageSumPay(params.tender_id, memFieldKeys[filter],
  282. customDefine.stage_select, customSelect ? customSelect.stage_select : null));
  283. runnableKey.push(filter);
  284. break;
  285. case 'mem_material_sum_gl':
  286. runnableRst.push(service.rptStageSumMemory.getMaterialSumGl(params.tender_id, memFieldKeys[filter],
  287. customDefine.material_sum_select, customSelect ? customSelect.material_sum_select : null));
  288. runnableKey.push(filter);
  289. break;
  290. case 'ledger_cooperation':
  291. runnableRst.push(service.ledgerCooperation.getValidData(params.tender_id));
  292. runnableKey.push(filter);
  293. break;
  294. case 'mem_sign_select':
  295. runnableRst.push(service.reportMemory.getSignSelect(params.tender_id, params.stage_id, customSelect));
  296. runnableKey.push(filter);
  297. break;
  298. case 'mem_stage_change':
  299. runnableRst.push(service.stageChange.getAllDataByCondition({ where: { tid: params.tender_id, sid: params.stage_id } }));
  300. runnableKey.push(filter);
  301. break;
  302. case 'mem_stage_change_bills':
  303. runnableRst.push(service.stageChangeFinal.getFinalData(params.tender_id));
  304. runnableKey.push(filter);
  305. break;
  306. case 'mem_stage_import_change':
  307. runnableRst.push(service.stageImportChange.getFinalData(params.tender_id));
  308. runnableKey.push(filter);
  309. break;
  310. case 'mem_ledger_tag':
  311. runnableRst.push(service.ledgerTag.getDatas(params.tender_id));
  312. runnableKey.push(filter);
  313. break;
  314. case 'mem_stage_tag':
  315. runnableRst.push(service.ledgerTag.getDatas(params.tender_id, params.stage_id));
  316. runnableKey.push(filter);
  317. break;
  318. case 'mem_all_tag':
  319. runnableRst.push(service.ledgerTag.getAllDataByCondition({ where: { tid: params.tender_id } }));
  320. runnableKey.push(filter);
  321. break;
  322. case 'mem_change_info':
  323. runnableRst.push(service.reportMemory.getChangeInfo(params.tender_id, params.stage_id));
  324. runnableKey.push(filter);
  325. break;
  326. case 'mem_change_info_bills':
  327. runnableRst.push(service.reportMemory.getChangeInfoBills(params.tender_id, params.stage_id));
  328. runnableKey.push(filter);
  329. break;
  330. case 'mem_stage_rela_im':
  331. runnableRst.push(service.stageRelaIm.getAllDataByCondition({ where: { tid: params.tender_id, sid: params.stage_id } }));
  332. runnableKey.push(filter);
  333. break;
  334. case 'mem_stage_rela_im_bills':
  335. runnableRst.push(service.stageRelaImBills.getAllDataByCondition({ where: { tid: params.tender_id, sid: params.stage_id } }));
  336. runnableKey.push(filter);
  337. break;
  338. case 'mem_budget_info':
  339. runnableRst.push(params.budget_id ? budgetSource.budgetInfo(params.budget_id) : budgetSource.tenderBudgetInfo(params.tender_id));
  340. runnableKey.push(filter);
  341. break;
  342. case 'mem_budget_gu':
  343. runnableRst.push(params.budget_id ? budgetSource.budgetGu(params.budget_id) : budgetSource.tenderGu(params.tender_id));
  344. runnableKey.push(filter);
  345. break;
  346. case 'mem_budget_gai':
  347. runnableRst.push(params.budget_id ? budgetSource.budgetGai(params.budget_id) : budgetSource.tenderGai(params.tender_id));
  348. runnableKey.push(filter);
  349. break;
  350. case 'mem_budget_yu':
  351. runnableRst.push(params.budget_id ? budgetSource.budgetYu(params.budget_id) : budgetSource.tenderYu(params.tender_id));
  352. runnableKey.push(filter);
  353. break;
  354. case 'mem_budget_zb':
  355. runnableRst.push(params.budget_id ? budgetSource.budgetZb(params.budget_id) : budgetSource.tenderZb(params.tender_id));
  356. runnableKey.push(filter);
  357. break;
  358. case 'mem_budget_final':
  359. runnableRst.push(params.budget_id ? budgetSource.budgetFinal(params.budget_id) : budgetSource.tenderFinal(params.tender_id));
  360. runnableKey.push(filter);
  361. break;
  362. case 'mem_budget_gu_filter':
  363. runnableRst.push(params.budget_id ? budgetSource.budgetGu(params.budget_id, true) : budgetSource.tenderGu(params.tender_id, true));
  364. runnableKey.push(filter);
  365. break;
  366. case 'mem_budget_gai_filter':
  367. runnableRst.push(params.budget_id ? budgetSource.budgetGai(params.budget_id, true) : budgetSource.tenderGai(params.tender_id, true));
  368. runnableKey.push(filter);
  369. break;
  370. case 'mem_budget_yu_filter':
  371. runnableRst.push(params.budget_id ? budgetSource.budgetYu(params.budget_id, true) : budgetSource.tenderYu(params.tender_id, true));
  372. runnableKey.push(filter);
  373. break;
  374. case 'mem_budget_zb_filter':
  375. runnableRst.push(params.budget_id ? budgetSource.budgetZb(params.budget_id, true) : budgetSource.tenderZb(params.tender_id, true));
  376. runnableKey.push(filter);
  377. break;
  378. case 'mem_budget_final_filter':
  379. runnableRst.push(params.budget_id ? budgetSource.budgetFinal(params.budget_id, true) : budgetSource.tenderFinal(params.tender_id, true));
  380. runnableKey.push(filter);
  381. break;
  382. case 'mem_pm_deal_pay':
  383. runnableRst.push(service.reportMemory.getPmDeal());
  384. runnableKey.push(filter);
  385. break;
  386. case 'mem_pm_deal_tree':
  387. runnableRst.push(service.reportMemory.getPmDealTree());
  388. runnableKey.push(filter);
  389. break;
  390. case 'mem_schedule_month':
  391. runnableRst.push(service.scheduleMonth.getReportData(params.tender_id));
  392. runnableKey.push(filter);
  393. break;
  394. case 'mem_schedule_stage':
  395. runnableRst.push(service.scheduleStage.getReportData(params.tender_id));
  396. runnableKey.push(filter);
  397. case 'mem_schedule':
  398. runnableRst.push(service.schedule.getDataByCondition({ tid: params.tender_id }));
  399. runnableKey.push(filter);
  400. break;
  401. default:
  402. break;
  403. }
  404. }
  405. }
  406. const queryRst = await Promise.all(runnableRst);
  407. for (let idx = 0; idx < runnableKey.length; idx++) {
  408. rst[runnableKey[idx]] = queryRst[idx];
  409. }
  410. for (const filter of filters) {
  411. switch (filter) {
  412. case 'mem_custom_select':
  413. rst[filter] = customSelect;
  414. break;
  415. case 'mem_stage_im_tz':
  416. rst[filter] = await service.reportMemory.getStageImTzData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  417. break;
  418. case 'mem_stage_im_tz_bills':
  419. rst[filter] = await service.reportMemory.getStageImTzBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  420. break;
  421. case 'mem_union_data':
  422. rst[filter] = [];
  423. break;
  424. case 'mem_import_change':
  425. rst[filter] = await service.reportMemory.getImportChangeData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  426. break;
  427. case 'mem_import_change_bills':
  428. rst[filter] = await service.reportMemory.getImportChangeBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  429. break;
  430. case 'mem_change':
  431. rst[filter] = await service.reportMemory.getChangeData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  432. break;
  433. case 'mem_change_bills':
  434. rst[filter] = await service.reportMemory.getChangeBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  435. break;
  436. case 'mem_change_audit':
  437. rst[filter] = await service.reportMemory.getChangeAuditData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  438. break;
  439. case 'mem_change_apply':
  440. rst[filter] = await service.reportMemory.getChangeApplyData(params.tender_id);
  441. break;
  442. case 'mem_change_apply_bills':
  443. rst[filter] = await service.reportMemory.getChangeApplyBillsData(params.tender_id);
  444. break;
  445. case 'mem_change_apply_audit':
  446. rst[filter] = await service.reportMemory.getChangeApplyAuditData(params.tender_id);
  447. break;
  448. case 'mem_change_plan':
  449. rst[filter] = await service.reportMemory.getChangePlanData(params.tender_id);
  450. break;
  451. case 'mem_change_plan_bills':
  452. rst[filter] = await service.reportMemory.getChangePlanBillsData(params.tender_id);
  453. break;
  454. case 'mem_change_plan_audit':
  455. rst[filter] = await service.reportMemory.getChangePlanAuditData(params.tender_id);
  456. break;
  457. case 'mem_change_project':
  458. rst[filter] = await service.reportMemory.getChangeProjectData(params.tender_id);
  459. break;
  460. case 'mem_change_project_audit':
  461. rst[filter] = await service.reportMemory.getChangeProjectAuditData(params.tender_id);
  462. break;
  463. case 'mem_jh_im_change':
  464. const jhHelper1 = new rptCustomData.jhHelper(this.ctx);
  465. rst[filter] = await jhHelper1.convert(params.tender_id, params.stage_id, memFieldKeys[filter], customDefine.option);
  466. break;
  467. case 'mem_jh_gather_im_change':
  468. const jhHelper2 = new rptCustomData.jhHelper(this.ctx);
  469. rst[filter] = await jhHelper2.gather(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  470. break;
  471. case 'mem_jh_gather_stage_bills_compare':
  472. const jhHelper3 = new rptCustomData.jhHelper(this.ctx);
  473. rst[filter] = await jhHelper3.gatherBills(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  474. break;
  475. case 'mem_gather_stage_bills':
  476. rst[filter] = await service.rptGatherMemory.getGatherStageBills(memFieldKeys[filter],
  477. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  478. break;
  479. case 'mem_gather_stage_bills_filter':
  480. rst[filter] = await service.rptGatherMemory.getGatherStageBills(memFieldKeys[filter],
  481. customDefine.gather_select, customSelect ? customSelect.gather_select : null, true);
  482. break;
  483. case 'mem_gather_stage_pos':
  484. rst[filter] = await service.rptGatherMemory.getGatherStagePos(memFieldKeys[filter],
  485. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  486. break;
  487. // case 'mem_material_bills':
  488. // rst[filter] = await service.rptGatherMemory.getMaterialBills(params.tender_id, params.material_order, memFieldKeys[filter]);
  489. // break;
  490. // case 'mem_material_bills_gl':
  491. // rst[filter] = await service.rptGatherMemory.getMaterialBillsGl(params.tender_id, params.material_order, memFieldKeys[filter]);
  492. // break;
  493. default:
  494. break;
  495. }
  496. }
  497. for (const s of specFilters) {
  498. let Result;
  499. switch (s) {
  500. case 'materialGather':
  501. Result = await materialSource.getMaterialGatherBills(params.tender_id, params.material_order);
  502. break;
  503. case 'gatherChange':
  504. Result = await service.rptGatherMemory.getGatherChange(this.getFieldKeys(memFieldKeys, bindData.gatherChange),
  505. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  506. break;
  507. case 'fjChange':
  508. const fjHelper = new rptCustomData.fjHelper(this.ctx);
  509. Result = await fjHelper.getChangeProgressData(params.tender_id, params.stage_id);
  510. break;
  511. default:
  512. Result = {};
  513. break;
  514. }
  515. for (const d in Result) {
  516. rst[d] = Result[d];
  517. }
  518. }
  519. return rst;
  520. }
  521. async payment_safe(params, sourceFilters, memFieldKeys, customDefine, customSelect) {
  522. const RptPaymentSafe = require('../lib/rm/payment_safe');
  523. const rptPaymentSafe = new RptPaymentSafe(this.ctx);
  524. return rptPaymentSafe.getReportData(params, sourceFilters, memFieldKeys, customDefine, customSelect);
  525. }
  526. async payment(params, sourceFilters, memFieldKeys, customDefine, customSelect) {
  527. const RptPayment = require('../lib/rm/payment');
  528. const rptPayment = new RptPayment(this.ctx);
  529. return rptPayment.getReportData(params, sourceFilters, memFieldKeys, customDefine, customSelect);
  530. }
  531. async budget(params, sourceFilters, memFieldKeys, customDefine, customSelect) {
  532. const RptPayment = require('../lib/rm/budget');
  533. const rptPayment = new RptPayment(this.ctx);
  534. return rptPayment.getReportData(params, sourceFilters, memFieldKeys, customDefine, customSelect);
  535. }
  536. async getReportData(source_type, params, sourceFilters, memFieldKeys, customDefine, customSelect) {
  537. const sourceType = sourceTypeConst.sourceTypeData.find(x => { return x.id === source_type; });
  538. if (!sourceType && !this[sourceType.key]) return {};
  539. return await this[sourceType.key](params, sourceFilters, memFieldKeys, customDefine, customSelect);
  540. }
  541. }
  542. return Report;
  543. };