123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504 |
- 'use strict';
- /**
- *
- *
- * @author Mai
- * @date
- * @version
- */
- const BudgetSource = require('../lib/rm/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.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 '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_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_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_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_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_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;
- 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:
- break;
- }
- for (const d in Result) {
- rst[d] = Result[d];
- }
- }
- return rst;
- }
- 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;
- };
|