Calculation/app/service/report.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date
 * @version
 */

const rptCustomData = require('../lib/rptCustomData');

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;
            await service.tender.checkTender(params.tender_id);
            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.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_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_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_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_select_material':
                            runnableRst.push(service.material.getSelectMaterial(params.tender_id, params.material_order));
                            runnableKey.push(filter);
                            break;
                        case 'mem_select_material_audit':
                            runnableRst.push(service.reportMemory.getSelectMaterialAuditors(params.tender_id, params.material_order));
                            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_material_gl_detail':
                            runnableRst.push(service.reportMemory.getMaterialGlDetail(params.tender_id, params.material_order, memFieldKeys[filter]));
                            runnableKey.push(filter);
                            break;
                        case 'mem_material_bills':
                            runnableRst.push(service.reportMemory.getMaterialBills(params.tender_id, params.material_order, memFieldKeys[filter]));
                            runnableKey.push(filter);
                            break;
                        case 'mem_material_pos':
                            runnableRst.push(service.reportMemory.getMaterialPos(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;
                        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_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_change_apply':
                            runnableRst.push(service.changeApply.getAllDataByCondition({ where: { tid: params.tender_id } }));
                            runnableKey.push(filter);
                            break;
                        case 'mem_change_project':
                            runnableRst.push(service.changeProject.getAllDataByCondition({ where: { 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_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_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_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;
};