'use strict'; /** * * * @author Mai * @date * @version */ const BudgetSource = require('../lib/rm/tender_budget'); const MaterialSource = require('../lib/rm/material'); const rptCustomData = require('../lib/rptCustomData'); const bindData = { materialGather: ['mem_material_gather_bills', 'mem_material_gather_xmj', 'mem_material_gather_gl'], gatherChange: ['mem_gather_change', 'mem_gather_change_bills'], fjChange: ['mem_fj_change_progress', 'mem_fj_change_sum'], }; const sourceTypeConst = require('../const/source_type'); module.exports = app => { class Report extends app.BaseService { /** * 构造函数 * * @param {Object} ctx - egg全局context * @return {void} */ constructor(ctx) { super(ctx); } async checkStg(ctx, params) { if (ctx.stage === null || ctx.stage === undefined || parseInt(ctx.stage.id) !== parseInt(params.stage_id)) { await ctx.service.stage.checkStage(params.stage_id); if (ctx.stage) { params.stage_order = ctx.stage.curOrder; } } } getFilter(sourceFilters) { const common = [], spec = []; for (const sf of sourceFilters) { let bSpec = false; for (const key in bindData) { const b = bindData[key]; if (b.indexOf(sf) >= 0) { bSpec = true; if (spec.indexOf(key) === -1) { spec.push(key); break; } } } if (!bSpec) common.push(sf); } return [common, spec]; } getFieldKeys(source, filter) { const result = []; for (const f of filter) { if (source[f]) result.push(...source[f]); } return result; } async tender(params, sourceFilters, memFieldKeys, customDefine, customSelect) { const [filters, specFilters] = this.getFilter(sourceFilters); const service = this.ctx.service; await service.tender.checkTender(params.tender_id); const materialSource = new MaterialSource(this.ctx); const rst = {}; const runnableRst = []; const runnableKey = []; // 这个配合runnableRst用，未来考虑并行查询优化 const budgetSource = new BudgetSource(this.ctx); for (const filter of filters) { if (runnableKey.indexOf(filter) < 0) { switch (filter) { case 'project' : runnableRst.push(service.project.getProjectById(params.project_id)); runnableKey.push(filter); break; case 'tender_info' : runnableRst.push(service.tenderInfo.getTenderInfoEx(params.tender_id)); runnableKey.push(filter); break; case 'advance_pay': runnableRst.push(service.advance.getAllDataByCondition({ where: { tid: params.tender_id } })); runnableKey.push(filter); break; case 'deal_bills' : runnableRst.push(service.dealBills.getDataByTenderId(params.tender_id)); runnableKey.push('deal_bills'); break; case 'ledger' : runnableRst.push(service.ledger.getData(params.tender_id, 0)); runnableKey.push(filter); break; case 'stage_bills': runnableRst.push(service.stageBills.getLastestStageData2(params.tender_id, params.stage_id)); runnableKey.push(filter); break; case 'stage_bills_final': await this.checkStg(this.ctx, params); runnableRst.push(service.stageBillsFinal.getFinalDataEx(params.tender_id, params.stage_order)); runnableKey.push(filter); break; case 'stage': runnableRst.push(service.stage.getStageById(params.stage_id)); runnableKey.push(filter); break; case 'stage_pay': await this.checkStg(this.ctx, params); runnableRst.push(service.stagePay.getStagePays(this.ctx.stage)); runnableKey.push(filter); break; case 'mem_stage_im_zl': runnableRst.push(service.reportMemory.getStageImZlData(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_month_progress': runnableRst.push(service.reportMemory.getMonthProgress(params.tender_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'stage_audit': runnableRst.push(service.reportMemory.getStageAuditors(params.tender_id, params.stage_id)); runnableKey.push(filter); break; case 'mem_stage_audit_ass': runnableRst.push(service.reportMemory.getStageAuditAss(params.tender_id, params.stage_id)); runnableKey.push(filter); break; case 'mem_stage_bills': runnableRst.push(service.reportMemory.getStageBillsData(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_stage_bills_filter': runnableRst.push(service.reportMemory.getStageBillsData(params.tender_id, params.stage_id, memFieldKeys[filter], true)); runnableKey.push(filter); break; case 'mem_stage_pos': runnableRst.push(service.reportMemory.getStagePosData(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_stage_pos_compare': runnableRst.push(service.reportMemory.getStagePosCompareData(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_stage_bills_compare': runnableRst.push(service.reportMemory.getStageBillsCompareData(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_stage_bills_compare_filter': runnableRst.push(service.reportMemory.getStageBillsCompareData(params.tender_id, params.stage_id, memFieldKeys[filter], true)); runnableKey.push(filter); break; case 'mem_stage_pay': runnableRst.push(service.reportMemory.getStagePayData(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'change': runnableRst.push(service.change.getListByStatus(params.tender_id, 3)); // 获取所有审核通过的变更主信息 runnableKey.push(filter); break; case 'change_audit_list': runnableRst.push(service.changeAuditList.getChangeAuditBills(params.tender_id)); // 获取所有审核通过的变更清单 runnableKey.push(filter); break; case 'mem_stage_jgcl': runnableRst.push(service.reportMemory.getStageJgcl(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_stage_bonus': runnableRst.push(service.reportMemory.getStageBonus(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_stage_other': runnableRst.push(service.reportMemory.getStageOther(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_stage_safe_prod': runnableRst.push(service.reportMemory.getStageSafeProd(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_stage_temp_land': runnableRst.push(service.reportMemory.getStageTempLand(params.tender_id, params.stage_id, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_gather_tender_info': runnableRst.push(service.rptGatherMemory.getGatherTenderInfo(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null)); runnableKey.push(filter); break; case 'mem_gather_stage_pay': runnableRst.push(service.rptGatherMemory.getGatherStagePay(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null)); runnableKey.push(filter); break; case 'mem_gather_deal_bills': runnableRst.push(service.rptGatherMemory.getGatherDealBills(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null)); runnableKey.push(filter); break; case 'mem_gather_stage_jgcl': runnableRst.push(service.rptGatherMemory.getGatherStageJgcl(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null)); runnableKey.push(filter); break; case 'mem_gather_stage_bonus': runnableRst.push(service.rptGatherMemory.getGatherStageBonus(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null)); runnableKey.push(filter); break; case 'mem_gather_stage_other': runnableRst.push(service.rptGatherMemory.getGatherStageOther(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null)); runnableKey.push(filter); break; case 'mem_gather_stage_safe_prod': runnableRst.push(service.rptGatherMemory.getGatherStageSafeProd(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null)); runnableKey.push(filter); break; case 'mem_gather_stage_temp_land': runnableRst.push(service.rptGatherMemory.getGatherStageTempLand(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null)); runnableKey.push(filter); break; case 'mem_gather_advance_pay': runnableRst.push(service.rptGatherMemory.getGatherAdvancePay(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null)); runnableKey.push(filter); break; case 'mem_select_material': runnableRst.push(service.material.getSelectMaterial(params.tender_id, params.material_order)); runnableKey.push(filter); break; case 'mem_select_material_audit': runnableRst.push(materialSource.getSelectMaterialAuditors(params.tender_id, params.material_order)); runnableKey.push(filter); break; case 'mem_material': runnableRst.push(materialSource.getMaterial(params.tender_id, params.material_order, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_material_gl': runnableRst.push(materialSource.getMaterialGl(params.tender_id, params.material_order, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_material_gl_detail': runnableRst.push(materialSource.getMaterialGlDetail(params.tender_id, params.material_order, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_material_bills': runnableRst.push(materialSource.getMaterialBills(params.tender_id, params.material_order, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_material_bills_filter': runnableRst.push(materialSource.getMaterialBills(params.tender_id, params.material_order, memFieldKeys[filter], true)); runnableKey.push(filter); break; case 'mem_material_pos': runnableRst.push(materialSource.getMaterialPos(params.tender_id, params.material_order, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_material_stage': runnableRst.push(materialSource.getMaterialStage(params.tender_id, params.material_order, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_stage_sum_bills': runnableRst.push(service.rptStageSumMemory.getStageSumBills(params.tender_id, memFieldKeys[filter], customDefine.stage_select, customSelect ? customSelect.stage_select : null)); runnableKey.push(filter); break; case 'mem_stage_sum_bills_filter': runnableRst.push(service.rptStageSumMemory.getStageSumBills(params.tender_id, memFieldKeys[filter], customDefine.stage_select, customSelect ? customSelect.stage_select : null, true)); runnableKey.push(filter); break; case 'mem_stage_sum_pos': runnableRst.push(service.rptStageSumMemory.getStageSumPos(params.tender_id, memFieldKeys[filter], customDefine.stage_select, customSelect ? customSelect.stage_select : null)); runnableKey.push(filter); break; case 'mem_stage_sum_pay': runnableRst.push(service.rptStageSumMemory.getStageSumPay(params.tender_id, memFieldKeys[filter], customDefine.stage_select, customSelect ? customSelect.stage_select : null)); runnableKey.push(filter); break; case 'mem_material_sum_gl': runnableRst.push(service.rptStageSumMemory.getMaterialSumGl(params.tender_id, memFieldKeys[filter], customDefine.material_sum_select, customSelect ? customSelect.material_sum_select : null)); runnableKey.push(filter); break; case 'ledger_cooperation': runnableRst.push(service.ledgerCooperation.getValidData(params.tender_id)); runnableKey.push(filter); break; case 'mem_sign_select': runnableRst.push(service.reportMemory.getSignSelect(params.tender_id, params.stage_id, customSelect)); runnableKey.push(filter); break; case 'mem_stage_change': runnableRst.push(service.stageChange.getAllDataByCondition({ where: { tid: params.tender_id, sid: params.stage_id } })); runnableKey.push(filter); break; case 'mem_stage_change_bills': runnableRst.push(service.stageChangeFinal.getFinalData(params.tender_id)); runnableKey.push(filter); break; case 'mem_stage_import_change': runnableRst.push(service.stageImportChange.getFinalData(params.tender_id)); runnableKey.push(filter); break; case 'mem_ledger_tag': runnableRst.push(service.ledgerTag.getDatas(params.tender_id)); runnableKey.push(filter); break; case 'mem_stage_tag': runnableRst.push(service.ledgerTag.getDatas(params.tender_id, params.stage_id)); runnableKey.push(filter); break; case 'mem_all_tag': runnableRst.push(service.ledgerTag.getAllDataByCondition({ where: { tid: params.tender_id } })); runnableKey.push(filter); break; case 'mem_change_info': runnableRst.push(service.reportMemory.getChangeInfo(params.tender_id, params.stage_id)); runnableKey.push(filter); break; case 'mem_change_info_bills': runnableRst.push(service.reportMemory.getChangeInfoBills(params.tender_id, params.stage_id)); runnableKey.push(filter); break; case 'mem_stage_rela_im': runnableRst.push(service.stageRelaIm.getAllDataByCondition({ where: { tid: params.tender_id, sid: params.stage_id } })); runnableKey.push(filter); break; case 'mem_stage_rela_im_bills': runnableRst.push(service.stageRelaImBills.getAllDataByCondition({ where: { tid: params.tender_id, sid: params.stage_id } })); runnableKey.push(filter); break; case 'mem_budget_info': runnableRst.push(params.budget_id ? budgetSource.budgetInfo(params.budget_id) : budgetSource.tenderBudgetInfo(params.tender_id)); runnableKey.push(filter); break; case 'mem_budget_gu': runnableRst.push(params.budget_id ? budgetSource.budgetGu(params.budget_id) : budgetSource.tenderGu(params.tender_id)); runnableKey.push(filter); break; case 'mem_budget_gai': runnableRst.push(params.budget_id ? budgetSource.budgetGai(params.budget_id) : budgetSource.tenderGai(params.tender_id)); runnableKey.push(filter); break; case 'mem_budget_yu': runnableRst.push(params.budget_id ? budgetSource.budgetYu(params.budget_id) : budgetSource.tenderYu(params.tender_id)); runnableKey.push(filter); break; case 'mem_budget_zb': runnableRst.push(params.budget_id ? budgetSource.budgetZb(params.budget_id) : budgetSource.tenderZb(params.tender_id)); runnableKey.push(filter); break; case 'mem_budget_final': runnableRst.push(params.budget_id ? budgetSource.budgetFinal(params.budget_id) : budgetSource.tenderFinal(params.tender_id)); runnableKey.push(filter); break; case 'mem_budget_gu_filter': runnableRst.push(params.budget_id ? budgetSource.budgetGu(params.budget_id, true) : budgetSource.tenderGu(params.tender_id, true)); runnableKey.push(filter); break; case 'mem_budget_gai_filter': runnableRst.push(params.budget_id ? budgetSource.budgetGai(params.budget_id, true) : budgetSource.tenderGai(params.tender_id, true)); runnableKey.push(filter); break; case 'mem_budget_yu_filter': runnableRst.push(params.budget_id ? budgetSource.budgetYu(params.budget_id, true) : budgetSource.tenderYu(params.tender_id, true)); runnableKey.push(filter); break; case 'mem_budget_zb_filter': runnableRst.push(params.budget_id ? budgetSource.budgetZb(params.budget_id, true) : budgetSource.tenderZb(params.tender_id, true)); runnableKey.push(filter); break; case 'mem_budget_final_filter': runnableRst.push(params.budget_id ? budgetSource.budgetFinal(params.budget_id, true) : budgetSource.tenderFinal(params.tender_id, true)); runnableKey.push(filter); break; case 'mem_pm_deal_pay': runnableRst.push(service.reportMemory.getPmDeal()); runnableKey.push(filter); break; case 'mem_pm_deal_tree': runnableRst.push(service.reportMemory.getPmDealTree()); runnableKey.push(filter); break; case 'mem_schedule_month': runnableRst.push(service.scheduleMonth.getReportData(params.tender_id)); runnableKey.push(filter); break; case 'mem_schedule_stage': runnableRst.push(service.scheduleStage.getReportData(params.tender_id)); runnableKey.push(filter); case 'mem_schedule': runnableRst.push(service.schedule.getDataByCondition({ tid: params.tender_id })); runnableKey.push(filter); break; default: break; } } } const queryRst = await Promise.all(runnableRst); for (let idx = 0; idx < runnableKey.length; idx++) { rst[runnableKey[idx]] = queryRst[idx]; } for (const filter of filters) { switch (filter) { case 'mem_custom_select': rst[filter] = customSelect; break; case 'mem_stage_im_tz': rst[filter] = await service.reportMemory.getStageImTzData(params.tender_id, params.stage_id, memFieldKeys[filter]); break; case 'mem_stage_im_tz_bills': rst[filter] = await service.reportMemory.getStageImTzBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]); break; case 'mem_union_data': rst[filter] = []; break; case 'mem_import_change': rst[filter] = await service.reportMemory.getImportChangeData(params.tender_id, params.stage_id, memFieldKeys[filter]); break; case 'mem_import_change_bills': rst[filter] = await service.reportMemory.getImportChangeBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]); break; case 'mem_change': rst[filter] = await service.reportMemory.getChangeData(params.tender_id, params.stage_id, memFieldKeys[filter]); break; case 'mem_change_bills': rst[filter] = await service.reportMemory.getChangeBillsData(params.tender_id, params.stage_id, memFieldKeys[filter]); break; case 'mem_change_audit': rst[filter] = await service.reportMemory.getChangeAuditData(params.tender_id, params.stage_id, memFieldKeys[filter]); break; case 'mem_change_apply': rst[filter] = await service.reportMemory.getChangeApplyData(params.tender_id); break; case 'mem_change_apply_bills': rst[filter] = await service.reportMemory.getChangeApplyBillsData(params.tender_id); break; case 'mem_change_apply_audit': rst[filter] = await service.reportMemory.getChangeApplyAuditData(params.tender_id); break; case 'mem_change_plan': rst[filter] = await service.reportMemory.getChangePlanData(params.tender_id); break; case 'mem_change_plan_bills': rst[filter] = await service.reportMemory.getChangePlanBillsData(params.tender_id); break; case 'mem_change_plan_audit': rst[filter] = await service.reportMemory.getChangePlanAuditData(params.tender_id); break; case 'mem_change_project': rst[filter] = await service.reportMemory.getChangeProjectData(params.tender_id); break; case 'mem_change_project_audit': rst[filter] = await service.reportMemory.getChangeProjectAuditData(params.tender_id); break; case 'mem_jh_im_change': const jhHelper1 = new rptCustomData.jhHelper(this.ctx); rst[filter] = await jhHelper1.convert(params.tender_id, params.stage_id, memFieldKeys[filter], customDefine.option); break; case 'mem_jh_gather_im_change': const jhHelper2 = new rptCustomData.jhHelper(this.ctx); rst[filter] = await jhHelper2.gather(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null); break; case 'mem_jh_gather_stage_bills_compare': const jhHelper3 = new rptCustomData.jhHelper(this.ctx); rst[filter] = await jhHelper3.gatherBills(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null); break; case 'mem_gather_stage_bills': rst[filter] = await service.rptGatherMemory.getGatherStageBills(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null); break; case 'mem_gather_stage_bills_filter': rst[filter] = await service.rptGatherMemory.getGatherStageBills(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null, true); break; case 'mem_gather_stage_pos': rst[filter] = await service.rptGatherMemory.getGatherStagePos(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null); break; // case 'mem_material_bills': // rst[filter] = await service.rptGatherMemory.getMaterialBills(params.tender_id, params.material_order, memFieldKeys[filter]); // break; // case 'mem_material_bills_gl': // rst[filter] = await service.rptGatherMemory.getMaterialBillsGl(params.tender_id, params.material_order, memFieldKeys[filter]); // break; default: break; } } for (const s of specFilters) { let Result; switch (s) { case 'materialGather': Result = await materialSource.getMaterialGatherBills(params.tender_id, params.material_order); break; case 'gatherChange': Result = await service.rptGatherMemory.getGatherChange(this.getFieldKeys(memFieldKeys, bindData.gatherChange), customDefine.gather_select, customSelect ? customSelect.gather_select : null); break; case 'fjChange': const fjHelper = new rptCustomData.fjHelper(this.ctx); Result = await fjHelper.getChangeProgressData(params.tender_id, params.stage_id); break; default: Result = {}; break; } for (const d in Result) { rst[d] = Result[d]; } } return rst; } async payment_safe(params, sourceFilters, memFieldKeys, customDefine, customSelect) { const RptPaymentSafe = require('../lib/rm/payment_safe'); const rptPaymentSafe = new RptPaymentSafe(this.ctx); return rptPaymentSafe.getReportData(params, sourceFilters, memFieldKeys, customDefine, customSelect); } async payment(params, sourceFilters, memFieldKeys, customDefine, customSelect) { const RptPayment = require('../lib/rm/payment'); const rptPayment = new RptPayment(this.ctx); return rptPayment.getReportData(params, sourceFilters, memFieldKeys, customDefine, customSelect); } async budget(params, sourceFilters, memFieldKeys, customDefine, customSelect) { const RptPayment = require('../lib/rm/budget'); const rptPayment = new RptPayment(this.ctx); return rptPayment.getReportData(params, sourceFilters, memFieldKeys, customDefine, customSelect); } async getReportData(source_type, params, sourceFilters, memFieldKeys, customDefine, customSelect) { const sourceType = sourceTypeConst.sourceTypeData.find(x => { return x.id === source_type; }); if (!sourceType && !this[sourceType.key]) return {}; return await this[sourceType.key](params, sourceFilters, memFieldKeys, customDefine, customSelect); } } return Report; };