'use strict'; /** * * * @author Mai * @date * @version */ 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; } } } async getReportData(params, filters, memFieldKeys, customDefine, customSelect) { const service = this.ctx.service; const rst = {}; const runnableRst = []; const runnableKey = []; // 这个配合runnableRst用，未来考虑并行查询优化 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.getLastestStageData(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.getAuditorStageData(params.stage_id, params.stage_times, params.stage_order)); 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 'mem_stage_bills': runnableRst.push(service.reportMemory.getStageBillsData(params.tender_id, params.stage_id, memFieldKeys[filter])); 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_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_gather_stage_bills': runnableRst.push(service.rptGatherMemory.getGatherStageBills(memFieldKeys[filter], customDefine.gather_select, customSelect ? customSelect.gather_select : null)); 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_material': runnableRst.push(service.reportMemory.getMaterial(params.tender_id, params.material_order, memFieldKeys[filter])); runnableKey.push(filter); break; case 'mem_material_gl': runnableRst.push(service.reportMemory.getMaterialGl(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_pay': runnableRst.push(service.rptStageSumMemory.getStageSumPay(params.tender_id, memFieldKeys[filter], customDefine.stage_select, customSelect ? customSelect.stage_select : null)); 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_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_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_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; } } return rst; } } return Report; };