tender.js 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date
  7. * @version
  8. */
  9. const RptMemBase = require('./base');
  10. const bindData = {
  11. materialGather: ['mem_material_gather_bills', 'mem_material_gather_xmj', 'mem_material_gather_gl'],
  12. gatherChange: ['mem_gather_change', 'mem_gather_change_bills'],
  13. fjChange: ['mem_fj_change_progress', 'mem_fj_change_sum'],
  14. };
  15. const BudgetSource = require('./budget');
  16. const MaterialSource = require('./material');
  17. const rptCustomData = require('../rptCustomData');
  18. class rptMemPaymentSafe extends RptMemBase {
  19. constructor(ctx) {
  20. super(ctx, bindData);
  21. }
  22. async checkStg(ctx, params) {
  23. if (ctx.stage === null || ctx.stage === undefined || parseInt(ctx.stage.id) !== parseInt(params.stage_id)) {
  24. await ctx.service.stage.checkStage(params.stage_id);
  25. if (ctx.stage) {
  26. params.stage_order = ctx.stage.curOrder;
  27. }
  28. }
  29. }
  30. async doBeforeLoadReport(params) {
  31. await this.ctx.service.tender.checkTender(params.tender_id);
  32. await this.checkStg(this.ctx, params);
  33. }
  34. getCommonData(params, tableName, fields, customDefine, customSelect) {
  35. const service = this.ctx.service;
  36. const budgetSource = new BudgetSource(this.ctx);
  37. switch (tableName) {
  38. case 'project' :
  39. return service.project.getProjectById(params.project_id);
  40. case 'tender_info' :
  41. return service.tenderInfo.getTenderInfoEx(params.tender_id);
  42. case 'advance_pay':
  43. return service.advance.getAllDataByCondition({ where: { tid: params.tender_id } });
  44. case 'deal_bills' :
  45. return service.dealBills.getDataByTenderId(params.tender_id);
  46. case 'ledger' :
  47. return service.ledger.getData(params.tender_id, 0);
  48. case 'stage_bills':
  49. return service.stageBills.getLastestStageData2(params.tender_id, params.stage_id);
  50. case 'stage_bills_final':
  51. return service.stageBillsFinal.getFinalDataEx(params.tender_id, params.stage_order);
  52. case 'stage':
  53. return service.stage.getStageById(params.stage_id);
  54. case 'stage_pay':
  55. return service.stagePay.getStagePays(ctx.stage);
  56. case 'mem_stage_im_zl':
  57. return service.reportMemory.getStageImZlData(params.tender_id, params.stage_id, fields);
  58. case 'mem_month_progress':
  59. return service.reportMemory.getMonthProgress(params.tender_id, fields);
  60. case 'stage_audit':
  61. return service.reportMemory.getStageAuditors(params.tender_id, params.stage_id);
  62. case 'mem_stage_audit_ass':
  63. return service.reportMemory.getStageAuditAss(params.tender_id, params.stage_id);
  64. case 'mem_stage_bills':
  65. return service.reportMemory.getStageBillsData(params.tender_id, params.stage_id, fields);
  66. case 'mem_stage_bills_filter':
  67. return service.reportMemory.getStageBillsData(params.tender_id, params.stage_id, fields, true);
  68. case 'mem_stage_pos':
  69. return service.reportMemory.getStagePosData(params.tender_id, params.stage_id, fields);
  70. case 'mem_stage_pos_compare':
  71. return service.reportMemory.getStagePosCompareData(params.tender_id, params.stage_id, fields);
  72. case 'mem_stage_bills_compare':
  73. return service.reportMemory.getStageBillsCompareData(params.tender_id, params.stage_id, fields);
  74. case 'mem_stage_bills_compare_filter':
  75. return service.reportMemory.getStageBillsCompareData(params.tender_id, params.stage_id, fields, true);
  76. case 'mem_stage_pay':
  77. return service.reportMemory.getStagePayData(params.tender_id, params.stage_id, fields);
  78. case 'change':
  79. return service.change.getListByStatus(params.tender_id, 3); // 获取所有审核通过的变更主信息
  80. case 'change_audit_list':
  81. return service.changeAuditList.getChangeAuditBills(params.tender_id); // 获取所有审核通过的变更清单
  82. case 'mem_stage_jgcl':
  83. return service.reportMemory.getStageJgcl(params.tender_id, params.stage_id, fields);
  84. case 'mem_stage_bonus':
  85. return service.reportMemory.getStageBonus(params.tender_id, params.stage_id, fields);
  86. case 'mem_stage_other':
  87. return service.reportMemory.getStageOther(params.tender_id, params.stage_id, fields);
  88. case 'mem_stage_safe_prod':
  89. return service.reportMemory.getStageSafeProd(params.tender_id, params.stage_id, fields);
  90. case 'mem_stage_temp_land':
  91. return service.reportMemory.getStageTempLand(params.tender_id, params.stage_id, fields);
  92. case 'mem_gather_tender_info':
  93. return service.rptGatherMemory.getGatherTenderInfo(fields,
  94. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  95. case 'mem_gather_stage_pay':
  96. return service.rptGatherMemory.getGatherStagePay(fields,
  97. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  98. case 'mem_gather_deal_bills':
  99. return service.rptGatherMemory.getGatherDealBills(fields,
  100. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  101. case 'mem_gather_stage_jgcl':
  102. return service.rptGatherMemory.getGatherStageJgcl(fields,
  103. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  104. case 'mem_gather_stage_bonus':
  105. return service.rptGatherMemory.getGatherStageBonus(fields,
  106. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  107. case 'mem_gather_stage_other':
  108. return service.rptGatherMemory.getGatherStageOther(fields,
  109. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  110. case 'mem_gather_stage_safe_prod':
  111. return service.rptGatherMemory.getGatherStageSafeProd(fields,
  112. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  113. case 'mem_gather_stage_temp_land':
  114. return service.rptGatherMemory.getGatherStageTempLand(fields,
  115. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  116. case 'mem_select_material':
  117. return service.material.getSelectMaterial(params.tender_id, params.material_order);
  118. case 'mem_select_material_audit':
  119. return materialSource.getSelectMaterialAuditors(params.tender_id, params.material_order);
  120. case 'mem_material':
  121. return materialSource.getMaterial(params.tender_id, params.material_order, fields);
  122. case 'mem_material_gl':
  123. return materialSource.getMaterialGl(params.tender_id, params.material_order, fields);
  124. case 'mem_material_gl_detail':
  125. return materialSource.getMaterialGlDetail(params.tender_id, params.material_order, fields);
  126. case 'mem_material_bills':
  127. return materialSource.getMaterialBills(params.tender_id, params.material_order, fields);
  128. case 'mem_material_bills_filter':
  129. return materialSource.getMaterialBills(params.tender_id, params.material_order, fields, true);
  130. case 'mem_material_pos':
  131. return materialSource.getMaterialPos(params.tender_id, params.material_order, fields);
  132. case 'mem_material_stage':
  133. return materialSource.getMaterialStage(params.tender_id, params.material_order, fields);
  134. case 'mem_stage_sum_bills':
  135. return service.rptStageSumMemory.getStageSumBills(params.tender_id, fields,
  136. customDefine.stage_select, customSelect ? customSelect.stage_select : null);
  137. case 'mem_stage_sum_bills_filter':
  138. return service.rptStageSumMemory.getStageSumBills(params.tender_id, fields,
  139. customDefine.stage_select, customSelect ? customSelect.stage_select : null, true);
  140. case 'mem_stage_sum_pos':
  141. return service.rptStageSumMemory.getStageSumPos(params.tender_id, fields,
  142. customDefine.stage_select, customSelect ? customSelect.stage_select : null);
  143. case 'mem_stage_sum_pay':
  144. return service.rptStageSumMemory.getStageSumPay(params.tender_id, fields,
  145. customDefine.stage_select, customSelect ? customSelect.stage_select : null);
  146. case 'mem_material_sum_gl':
  147. return service.rptStageSumMemory.getMaterialSumGl(params.tender_id, fields,
  148. customDefine.material_sum_select, customSelect ? customSelect.material_sum_select : null);
  149. case 'ledger_cooperation':
  150. return service.ledgerCooperation.getValidData(params.tender_id);
  151. case 'mem_sign_select':
  152. return service.reportMemory.getSignSelect(params.tender_id, params.stage_id, customSelect);
  153. case 'mem_stage_change':
  154. return service.stageChange.getAllDataByCondition({ where: { tid: params.tender_id, sid: params.stage_id } });
  155. case 'mem_stage_change_bills':
  156. return service.stageChangeFinal.getFinalData(params.tender_id);
  157. case 'mem_stage_import_change':
  158. return service.stageImportChange.getFinalData(params.tender_id);
  159. case 'mem_ledger_tag':
  160. return service.ledgerTag.getDatas(params.tender_id);
  161. case 'mem_stage_tag':
  162. return service.ledgerTag.getDatas(params.tender_id, params.stage_id);
  163. case 'mem_all_tag':
  164. return service.ledgerTag.getAllDataByCondition({ where: { tid: params.tender_id } });
  165. case 'mem_change_info':
  166. return service.reportMemory.getChangeInfo(params.tender_id, params.stage_id);
  167. case 'mem_change_info_bills':
  168. return service.reportMemory.getChangeInfoBills(params.tender_id, params.stage_id);
  169. case 'mem_stage_rela_im':
  170. return service.stageRelaIm.getAllDataByCondition({ where: { tid: params.tender_id, sid: params.stage_id } });
  171. case 'mem_stage_rela_im_bills':
  172. return service.stageRelaImBills.getAllDataByCondition({ where: { tid: params.tender_id, sid: params.stage_id } });
  173. case 'mem_budget_gu':
  174. return params.budget_id ? budgetSource.budgetGu(params.budget_id) : budgetSource.tenderGu(params.tender_id);
  175. case 'mem_budget_gai':
  176. return params.budget_id ? budgetSource.budgetGai(params.budget_id) : budgetSource.tenderGai(params.tender_id);
  177. case 'mem_budget_yu':
  178. return params.budget_id ? budgetSource.budgetYu(params.budget_id) : budgetSource.tenderYu(params.tender_id);
  179. case 'mem_budget_zb':
  180. return params.budget_id ? budgetSource.budgetZb(params.budget_id) : budgetSource.tenderZb(params.tender_id);
  181. case 'mem_budget_final':
  182. return params.budget_id ? budgetSource.budgetFinal(params.budget_id) : budgetSource.tenderFinal(params.tender_id);
  183. case 'mem_budget_gu_filter':
  184. return params.budget_id ? budgetSource.budgetGu(params.budget_id, true) : budgetSource.tenderGu(params.tender_id, true);
  185. case 'mem_budget_gai_filter':
  186. return params.budget_id ? budgetSource.budgetGai(params.budget_id, true) : budgetSource.tenderGai(params.tender_id, true);
  187. case 'mem_budget_yu_filter':
  188. return params.budget_id ? budgetSource.budgetYu(params.budget_id, true) : budgetSource.tenderYu(params.tender_id, true);
  189. case 'mem_budget_zb_filter':
  190. return params.budget_id ? budgetSource.budgetZb(params.budget_id, true) : budgetSource.tenderZb(params.tender_id, true);
  191. case 'mem_budget_final_filter':
  192. return params.budget_id ? budgetSource.budgetFinal(params.budget_id, true) : budgetSource.tenderFinal(params.tender_id, true);
  193. case 'mem_pm_deal_pay':
  194. return service.reportMemory.getPmDeal();
  195. default:
  196. break;
  197. }
  198. }
  199. async getFlowData(params, key, fields, customDefine, customSelect) {
  200. const service = this.ctx.service;
  201. switch (filter) {
  202. case 'mem_custom_select':
  203. return customSelect;
  204. case 'mem_stage_im_tz':
  205. return await service.reportMemory.getStageImTzData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  206. case 'mem_stage_im_tz_bills':
  207. return await service.reportMemory.getStageImTzBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  208. case 'mem_union_data':
  209. return [];
  210. case 'mem_import_change':
  211. return await service.reportMemory.getImportChangeData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  212. case 'mem_import_change_bills':
  213. return await service.reportMemory.getImportChangeBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  214. case 'mem_change':
  215. return await service.reportMemory.getChangeData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  216. case 'mem_change_bills':
  217. return await service.reportMemory.getChangeBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  218. case 'mem_change_audit':
  219. return await service.reportMemory.getChangeAuditData(params.tender_id, params.stage_id, memFieldKeys[filter]);
  220. case 'mem_change_apply':
  221. return await service.reportMemory.getChangeApplyData(params.tender_id);
  222. case 'mem_change_apply_bills':
  223. return await service.reportMemory.getChangeApplyBillsData(params.tender_id);
  224. case 'mem_change_apply_audit':
  225. return await service.reportMemory.getChangeApplyAuditData(params.tender_id);
  226. case 'mem_change_plan':
  227. return await service.reportMemory.getChangePlanData(params.tender_id);
  228. case 'mem_change_plan_bills':
  229. return await service.reportMemory.getChangePlanBillsData(params.tender_id);
  230. case 'mem_change_plan_audit':
  231. return await service.reportMemory.getChangePlanAuditData(params.tender_id);
  232. case 'mem_change_project':
  233. return await service.reportMemory.getChangeProjectData(params.tender_id);
  234. case 'mem_change_project_audit':
  235. return await service.reportMemory.getChangeProjectAuditData(params.tender_id);
  236. case 'mem_jh_im_change':
  237. const jhHelper1 = new rptCustomData.jhHelper(this.ctx);
  238. return await jhHelper1.convert(params.tender_id, params.stage_id, memFieldKeys[filter], customDefine.option);
  239. case 'mem_jh_gather_im_change':
  240. const jhHelper2 = new rptCustomData.jhHelper(this.ctx);
  241. return await jhHelper2.gather(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  242. case 'mem_jh_gather_stage_bills_compare':
  243. const jhHelper3 = new rptCustomData.jhHelper(this.ctx);
  244. return await jhHelper3.gatherBills(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  245. case 'mem_gather_stage_bills':
  246. return await service.rptGatherMemory.getGatherStageBills(memFieldKeys[filter],
  247. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  248. case 'mem_gather_stage_bills_filter':
  249. return await service.rptGatherMemory.getGatherStageBills(memFieldKeys[filter],
  250. customDefine.gather_select, customSelect ? customSelect.gather_select : null, true);
  251. case 'mem_gather_stage_pos':
  252. return await service.rptGatherMemory.getGatherStagePos(memFieldKeys[filter],
  253. customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  254. // case 'mem_material_bills':
  255. // return await service.rptGatherMemory.getMaterialBills(params.tender_id, params.material_order, memFieldKeys[filter]);
  256. // case 'mem_material_bills_gl':
  257. // return await service.rptGatherMemory.getMaterialBillsGl(params.tender_id, params.material_order, memFieldKeys[filter]);
  258. default:
  259. return [];
  260. }
  261. }
  262. async getBindData(params, key, fields, customDefine, customSelect) {
  263. const service = this.ctx.service;
  264. switch (key) {
  265. case 'materialGather':
  266. const materialSource = new MaterialSource(this.ctx);
  267. return await materialSource.getMaterialGatherBills(params.tender_id, params.material_order);
  268. case 'gatherChange':
  269. return await service.rptGatherMemory.getGatherChange(fields, customDefine.gather_select, customSelect ? customSelect.gather_select : null);
  270. case 'fjChange':
  271. const fjHelper = new rptCustomData.fjHelper(this.ctx);
  272. return await fjHelper.getChangeProgressData(params.tender_id, params.stage_id);
  273. default:
  274. return {};
  275. }
  276. }
  277. }
  278. module.exports = rptMemPaymentSafe;