Calculation/app/service/rpt_gather_memory.js

'use strict';

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

const Ledger = require('../lib/ledger');
const PayCalculator = require('../lib/pay_calc');

const auditConst = require('../const/audit');
const payConst = require('../const/deal_pay');
const changeConst = require('../const/change');

const moment = require('moment');

const indexPre = 'id_';
const normalPrefix = 't_', sumPrefix = 's_', specPrefix = 'ts_';

const gatherUtils = {
    completeGatherData: function (datas, completeDatas) {
        for (const data of datas) {
            for (const cd of completeDatas) {
                data[cd.prefix + 'id'] = cd.id;
                data[cd.prefix + 'name'] = cd.name;
                data[cd.prefix + 'category'] = cd.category;
            }
        }
    },
    gatherStage: function (tender, gatherNode, sourceNode, prefix, helper) {
        gatherNode[prefix + 'id'] = tender.id;
        gatherNode[prefix + 'name'] = tender.name;
        gatherNode[prefix + 'category'] = tender.category;

        gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
        gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
        gatherNode[prefix + "deal_qty"] = helper.add(gatherNode[prefix + "deal_qty"], sourceNode.deal_qty);
        gatherNode[prefix + "deal_tp"] = helper.add(gatherNode[prefix + "deal_tp"], sourceNode.deal_tp);

        gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
        gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);

        gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
        gatherNode[prefix + "contract_tp"] = helper.add(gatherNode[prefix + "contract_tp"], sourceNode.contract_tp);
        gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
        gatherNode[prefix + "qc_tp"] = helper.add(gatherNode[prefix + "qc_tp"], sourceNode.qc_tp);
        gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);
        gatherNode[prefix + "gather_tp"] = helper.add(gatherNode[prefix + "gather_tp"], sourceNode.gather_tp);
        gatherNode[prefix + 'contract_pc_tp'] = helper.add(gatherNode[prefix + 'contract_pc_tp'], sourceNode.contract_pc_tp);
        gatherNode[prefix + 'qc_pc_tp'] = helper.add(gatherNode[prefix + 'qc_pc_tp'], sourceNode.qc_pc_tp);
        gatherNode[prefix + 'pc_tp'] = helper.add(gatherNode[prefix + 'pc_tp'], sourceNode.pc_tp);

        gatherNode[prefix + "pre_contract_qty"] = helper.add(gatherNode[prefix + "pre_contract_qty"], sourceNode.pre_contract_qty);
        gatherNode[prefix + "pre_contract_tp"] = helper.add(gatherNode[prefix + "pre_contract_tp"], sourceNode.pre_contract_tp);
        gatherNode[prefix + "pre_qc_qty"] = helper.add(gatherNode[prefix + "pre_qc_qty"], sourceNode.pre_qc_qty);
        gatherNode[prefix + "pre_qc_tp"] = helper.add(gatherNode[prefix + "pre_qc_tp"], sourceNode.pre_qc_tp);
        gatherNode[prefix + "pre_gather_qty"] = helper.add(gatherNode[prefix + "pre_gather_qty"], sourceNode.pre_gather_qty);
        gatherNode[prefix + "pre_gather_tp"] = helper.add(gatherNode[prefix + "pre_gather_tp"], sourceNode.pre_gather_tp);

        gatherNode[prefix + "end_contract_qty"] = helper.add(gatherNode[prefix + "end_contract_qty"], sourceNode.end_contract_qty);
        gatherNode[prefix + "end_contract_tp"] = helper.add(gatherNode[prefix + "end_contract_tp"], sourceNode.end_contract_tp);
        gatherNode[prefix + "end_qc_qty"] = helper.add(gatherNode[prefix + "end_qc_qty"], sourceNode.end_qc_qty);
        gatherNode[prefix + "end_qc_tp"] = helper.add(gatherNode[prefix + "end_qc_tp"], sourceNode.end_qc_tp);
        gatherNode[prefix + "end_gather_qty"] = helper.add(gatherNode[prefix + "end_gather_qty"], sourceNode.end_gather_qty);
        gatherNode[prefix + "end_gather_tp"] = helper.add(gatherNode[prefix + "end_gather_tp"], sourceNode.end_gather_tp);

        gatherNode[prefix + "deal_dgn_qty1"] = helper.add(gatherNode[prefix + "deal_dgn_qty1"], sourceNode.deal_dgn_qty1);
        gatherNode[prefix + "deal_dgn_qty2"] = helper.add(gatherNode[prefix + "deal_dgn_qty2"], sourceNode.deal_dgn_qty2);
        gatherNode[prefix + "c_dgn_qty1"] = helper.add(gatherNode[prefix + "c_dgn_qty1"], sourceNode.c_dgn_qty1);
        gatherNode[prefix + "c_dgn_qty2"] = helper.add(gatherNode[prefix + "c_dgn_qty2"], sourceNode.c_dgn_qty2);

        gatherNode[prefix + "due_qc_qty"] = helper.add(gatherNode[prefix + "due_qc_qty"], sourceNode.due_qc_qty);
        gatherNode[prefix + "due_qc_tp"] = helper.add(gatherNode[prefix + "due_qc_tp"], sourceNode.due_qc_tp);
        gatherNode[prefix + "due_qc_minus_qty"] = helper.add(gatherNode[prefix + "due_qc_minus_qty"], sourceNode.due_qc_minus_qty);
        gatherNode[prefix + "due_final_qty"] = helper.add(gatherNode[prefix + "due_final_qty"], sourceNode.due_final_qty);
        gatherNode[prefix + "due_final_tp"] = helper.add(gatherNode[prefix + "due_final_tp"], sourceNode.due_final_tp);

        gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
        gatherNode.s_tp = helper.add(gatherNode.s_tp, sourceNode.total_price);
        gatherNode.s_deal_qty = helper.add(gatherNode.s_deal_qty, sourceNode.deal_qty);
        gatherNode.s_deal_tp = helper.add(gatherNode.s_deal_tp, sourceNode.deal_tp);

        gatherNode.s_dgn_qty1 = helper.add(gatherNode.s_dgn_qty1, sourceNode.dgn_qty1);
        gatherNode.s_dgn_qty2 = helper.add(gatherNode.s_dgn_qty2, sourceNode.dgn_qty2);

        gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
        gatherNode.s_contract_tp = helper.add(gatherNode.s_contract_tp, sourceNode.contract_tp);
        gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
        gatherNode.s_qc_tp = helper.add(gatherNode.s_qc_tp, sourceNode.qc_tp);
        gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
        gatherNode.s_gather_tp = helper.add(gatherNode.s_gather_tp, sourceNode.gather_tp);
        gatherNode.s_contract_pc_tp = helper.add(gatherNode.s_contract_pc_tp, sourceNode.contract_pc_tp);
        gatherNode.s_qc_pc_tp = helper.add(gatherNode.s_qc_pc_tp, sourceNode.qc_pc_tp);
        gatherNode.s_pc_tp = helper.add(gatherNode.s_pc_tp, sourceNode.pc_tp);

        gatherNode.s_pre_contract_qty = helper.add(gatherNode.s_pre_contract_qty, sourceNode.pre_contract_qty);
        gatherNode.s_pre_contract_tp = helper.add(gatherNode.s_pre_contract_tp, sourceNode.pre_contract_tp);
        gatherNode.s_pre_qc_qty = helper.add(gatherNode.s_pre_qc_qty, sourceNode.pre_qc_qty);
        gatherNode.s_pre_qc_tp = helper.add(gatherNode.s_pre_qc_tp, sourceNode.pre_qc_tp);
        gatherNode.s_pre_gather_qty = helper.add(gatherNode.s_pre_gather_qty, sourceNode.pre_gather_qty);
        gatherNode.s_pre_gather_tp = helper.add(gatherNode.s_pre_gather_tp, sourceNode.pre_gather_tp);

        gatherNode.s_end_contract_qty = helper.add(gatherNode.s_end_contract_qty, sourceNode.end_contract_qty);
        gatherNode.s_end_contract_tp = helper.add(gatherNode.s_end_contract_tp, sourceNode.end_contract_tp);
        gatherNode.s_end_qc_qty = helper.add(gatherNode.s_end_qc_qty, sourceNode.end_qc_qty);
        gatherNode.s_end_qc_tp = helper.add(gatherNode.s_end_qc_tp, sourceNode.end_qc_tp);
        gatherNode.s_end_gather_qty = helper.add(gatherNode.s_end_gather_qty, sourceNode.end_gather_qty);
        gatherNode.s_end_gather_tp = helper.add(gatherNode.s_end_gather_tp, sourceNode.end_gather_tp);

        gatherNode.s_deal_dgn_qty1 = helper.add(gatherNode.s_deal_dgn_qty1, sourceNode.deal_dgn_qty1);
        gatherNode.s_deal_dgn_qty2 = helper.add(gatherNode.s_deal_dgn_qty2, sourceNode.deal_dgn_qty2);
        gatherNode.s_c_dgn_qty1 = helper.add(gatherNode.s_c_dgn_qty1, sourceNode.c_dgn_qty1);
        gatherNode.s_c_dgn_qty2 = helper.add(gatherNode.s_c_dgn_qty2, sourceNode.c_dgn_qty2);

        gatherNode.s_due_qc_qty = helper.add(gatherNode.s_due_qc_qty, sourceNode.due_qc_qty);
        gatherNode.s_due_qc_tp = helper.add(gatherNode.s_due_qc_tp, sourceNode.due_qc_tp);
        gatherNode.s_due_qc_minus_qty = helper.add(gatherNode.s_due_qc_minus_qty, sourceNode.due_qc_minus_qty);
        gatherNode.s_due_final_qty = helper.add(gatherNode.s_due_final_qty, sourceNode.due_final_qty);
        gatherNode.s_due_final_tp = helper.add(gatherNode.s_due_final_tp, sourceNode.due_final_tp);
    },
    gatherZone: function (tender, gatherNode, sourceNode, prefix, helper) {
        gatherNode[prefix + 'id'] = tender.id;
        gatherNode[prefix + 'name'] = tender.name;
        gatherNode[prefix + 'category'] = tender.category;

        gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
        gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
        gatherNode[prefix + "deal_qty"] = helper.add(gatherNode[prefix + "deal_qty"], sourceNode.deal_qty);
        gatherNode[prefix + "deal_tp"] = helper.add(gatherNode[prefix + "deal_tp"], sourceNode.deal_tp);

        gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
        gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);

        gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
        gatherNode[prefix + "contract_tp"] = helper.add(gatherNode[prefix + "contract_tp"], sourceNode.contract_tp);
        gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
        gatherNode[prefix + "qc_tp"] = helper.add(gatherNode[prefix + "qc_tp"], sourceNode.qc_tp);
        gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);
        gatherNode[prefix + "gather_tp"] = helper.add(gatherNode[prefix + "gather_tp"], sourceNode.gather_tp);
        gatherNode[prefix + 'pc_tp'] = helper.add(gatherNode[prefix + 'pc_tp'], sourceNode.pc_tp);

        gatherNode[prefix + "deal_dgn_qty1"] = helper.add(gatherNode[prefix + "deal_dgn_qty1"], sourceNode.deal_dgn_qty1);
        gatherNode[prefix + "deal_dgn_qty2"] = helper.add(gatherNode[prefix + "deal_dgn_qty2"], sourceNode.deal_dgn_qty2);
        gatherNode[prefix + "c_dgn_qty1"] = helper.add(gatherNode[prefix + "c_dgn_qty1"], sourceNode.c_dgn_qty1);
        gatherNode[prefix + "c_dgn_qty2"] = helper.add(gatherNode[prefix + "c_dgn_qty2"], sourceNode.c_dgn_qty2);

        gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
        gatherNode.s_tp = helper.add(gatherNode.s_tp, sourceNode.total_price);
        gatherNode.s_deal_qty = helper.add(gatherNode.s_deal_qty, sourceNode.deal_qty);
        gatherNode.s_deal_tp = helper.add(gatherNode.s_deal_tp, sourceNode.deal_tp);

        gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
        gatherNode.s_contract_tp = helper.add(gatherNode.s_contract_tp, sourceNode.contract_tp);
        gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
        gatherNode.s_qc_tp = helper.add(gatherNode.s_qc_tp, sourceNode.qc_tp);
        gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
        gatherNode.s_gather_tp = helper.add(gatherNode.s_gather_tp, sourceNode.gather_tp);
        gatherNode.s_pc_tp = helper.add(gatherNode.s_pc_tp, sourceNode.pc_tp);
    },
    gatherLedger: function (tender, gatherNode, sourceNode, prefix, helper) {
        gatherNode[prefix + 'id'] = tender.id;
        gatherNode[prefix + 'name'] = tender.name;
        gatherNode[prefix + 'category'] = tender.category;

        gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
        gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);
        gatherNode[prefix + "deal_qty"] = helper.add(gatherNode[prefix + "deal_qty"], sourceNode.deal_qty);
        gatherNode[prefix + "deal_tp"] = helper.add(gatherNode[prefix + "deal_tp"], sourceNode.deal_tp);

        gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
        gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);

        gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
        gatherNode.s_tp = helper.add(gatherNode.s_tp, sourceNode.total_price);
        gatherNode.s_deal_qty = helper.add(gatherNode.s_deal_qty, sourceNode.deal_qty);
        gatherNode.s_deal_tp = helper.add(gatherNode.s_deal_tp, sourceNode.deal_tp);
    },
    gatherSpecial: function (gatherNode, sourceNode, prefix, helper) {
        gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
        gatherNode[prefix + "tp"] = helper.add(gatherNode[prefix + "tp"], sourceNode.total_price);

        gatherNode[prefix + "dgn_qty1"] = helper.add(gatherNode[prefix + "dgn_qty1"], sourceNode.dgn_qty1);
        gatherNode[prefix + "dgn_qty2"] = helper.add(gatherNode[prefix + "dgn_qty2"], sourceNode.dgn_qty2);
    },
    gatherStagePos: function (tender, gatherNode, sourceNode, prefix, helper) {
        gatherNode[prefix + 'id'] = tender.id;
        gatherNode[prefix + 'name'] = tender.name;
        gatherNode[prefix + 'category'] = tender.category;

        gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);

        gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
        gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
        gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);

        gatherNode[prefix + "pre_contract_qty"] = helper.add(gatherNode[prefix + "pre_contract_qty"], sourceNode.pre_contract_qty);
        gatherNode[prefix + "pre_qc_qty"] = helper.add(gatherNode[prefix + "pre_qc_qty"], sourceNode.pre_qc_qty);
        gatherNode[prefix + "pre_gather_qty"] = helper.add(gatherNode[prefix + "pre_gather_qty"], sourceNode.pre_gather_qty);

        gatherNode[prefix + "end_contract_qty"] = helper.add(gatherNode[prefix + "end_contract_qty"], sourceNode.end_contract_qty);
        gatherNode[prefix + "end_qc_qty"] = helper.add(gatherNode[prefix + "end_qc_qty"], sourceNode.end_qc_qty);
        gatherNode[prefix + "end_gather_qty"] = helper.add(gatherNode[prefix + "end_gather_qty"], sourceNode.end_gather_qty);

        gatherNode[prefix + "due_qc_qty"] = helper.add(gatherNode[prefix + "due_qc_qty"], sourceNode.due_qc_qty);
        gatherNode[prefix + "due_final_qty"] = helper.add(gatherNode[prefix + "due_final_qty"], sourceNode.due_final_qty);
        gatherNode[prefix + "due_qc_minus_qty"] = helper.add(gatherNode[prefix + "due_qc_minus_qty"], sourceNode.due_qc_minus_qty);

        gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);

        gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
        gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
        gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);

        gatherNode.s_pre_contract_qty = helper.add(gatherNode.s_pre_contract_qty, sourceNode.pre_contract_qty);
        gatherNode.s_pre_qc_qty = helper.add(gatherNode.s_pre_qc_qty, sourceNode.pre_qc_qty);
        gatherNode.s_pre_gather_qty = helper.add(gatherNode.s_pre_gather_qty, sourceNode.pre_gather_qty);

        gatherNode.s_end_contract_qty = helper.add(gatherNode.s_end_contract_qty, sourceNode.end_contract_qty);
        gatherNode.s_end_qc_qty = helper.add(gatherNode.s_end_qc_qty, sourceNode.end_qc_qty);
        gatherNode.s_end_gather_qty = helper.add(gatherNode.s_end_gather_qty, sourceNode.end_gather_qty);

        gatherNode.s_due_qc_qty = helper.add(gatherNode.s_due_qc_qty, sourceNode.due_qc_qty);
        gatherNode.s_due_final_qty = helper.add(gatherNode.s_due_final_qty, sourceNode.due_final_qty);
        gatherNode.s_due_qc_minus_qty = helper.add(gatherNode.s_due_qc_minus_qty, sourceNode.due_qc_minus_qty);
    },
    gatherZonePos: function (tender, gatherNode, sourceNode, prefix, helper) {
        gatherNode[prefix + 'id'] = tender.id;
        gatherNode[prefix + 'name'] = tender.name;
        gatherNode[prefix + 'category'] = tender.category;

        gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);

        gatherNode[prefix + "contract_qty"] = helper.add(gatherNode[prefix + "contract_qty"], sourceNode.contract_qty);
        gatherNode[prefix + "qc_qty"] = helper.add(gatherNode[prefix + "qc_qty"], sourceNode.qc_qty);
        gatherNode[prefix + "gather_qty"] = helper.add(gatherNode[prefix + "gather_qty"], sourceNode.gather_qty);

        gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);

        gatherNode.s_contract_qty = helper.add(gatherNode.s_contract_qty, sourceNode.contract_qty);
        gatherNode.s_qc_qty = helper.add(gatherNode.s_qc_qty, sourceNode.qc_qty);
        gatherNode.s_gather_qty = helper.add(gatherNode.s_gather_qty, sourceNode.gather_qty);
    },
    gatherPos: function (tender, gatherNode, sourceNode, prefix, helper) {
        gatherNode[prefix + 'id'] = tender.id;
        gatherNode[prefix + 'name'] = tender.name;
        gatherNode[prefix + 'category'] = tender.category;

        gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);

        gatherNode.s_qty = helper.add(gatherNode.s_qty, sourceNode.quantity);
    },
    gatherSpecialPos: function (gatherNode, sourceNode, prefix, helper) {
        gatherNode[prefix + "qty"] = helper.add(gatherNode[prefix + "qty"], sourceNode.quantity);
    },
};
const rmUtils = require('../lib/rm/rm_utils');

module.exports = app => {
    class RptGatherMemory extends app.BaseService {

        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局context
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            this.resultTree = null;
            this.resultPos = null;
            this.resultTenderInfo = [];
            this.resultDealPay = [];
            this.resultDealBills = [];
        }

        _checkFieldsExistReg(source, regStr) {
            const reg = new RegExp(regStr, 'igm');
            for (const s of source) {
                if (reg.test(s)) {
                    return true;
                }
            }
            return false;
        }

        async _getValidStages(tenderId, sort = 'desc') {
            const stages = await this.db.select(this.ctx.service.stage.tableName, {
                where: { tid: tenderId },
                orders: [['order', sort]],
            });
            if (stages.length !== 0) {
                const lastStage = stages[0];
                if (lastStage.status === auditConst.stage.status.uncheck && lastStage.user_id !== this.ctx.session.sessionUser.accountId) {
                    stages.splice(0, 1);
                }
            }
            return stages;
        }

        async _getCheckedStages(tenderId) {
            const stages = await this.db.select(this.ctx.service.stage.tableName, {
                where: { tid: tenderId },
                orders: [['order', 'desc']],
            });
            if (stages.length !== 0) {
                const lastStage = stages[0];
                if (lastStage.status !== auditConst.stage.status.checked) {
                    stages.splice(0, 1);
                }
            }
            return stages;
        }

        _checkSpecialTender(tender, special) {
            if (special) {
                for (const spec of special) {
                    if (tender[spec.key] === true) return spec.key;
                }
            }
            return '';
        }

        async _getTimeZoneStages(tender, zone) {
            const times = zone.split(' - ');
            if (times.length !== 2) throw '选择的汇总周期无效';
            const beginTime = moment(times[0], 'YYYY-MM');
            const endTime = moment(times[1], 'YYYY-MM');

            const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
            let preStage, endStage;
            for (const stage of stages) {
                const sTime = moment(stage.s_time, 'YYYY-MM');
                if (sTime.isBetween(beginTime, endTime, null, '[]')) {
                    validStages.push(stage);
                } else if (sTime.isBefore(beginTime)) {
                    if (!preStage || moment(preStage.s_time, 'YYYY-MM').isBefore(sTime)) preStage = stage;
                } else if (sTime.isAfter(endTime)) {
                    if (!endStage || moment(endStage.s_time, 'YYYY-MM').isAfter(sTime)) endStage = stage;
                }
            }
            return [validStages, preStage, endStage];
        }
        async _getOrderZoneStages (tender, zone) {
            let [iBegin, iEnd] = zone.split(':');
            iBegin = this.ctx.helper._.toInteger(iBegin) || 0;
            iEnd = this.ctx.helper._.toInteger(iEnd) || 0;
            const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
            let preStage, endStage;
            for (const stage of stages) {
                if (stage.order < iBegin) {
                    if (!preStage || preStage.order < stage.order) preStage = stage;
                } else if (stage.order > iEnd) {
                    if (!endStage || endStage.order > stage.order) endStage = stage;
                } else {
                    validStages.push(stage);
                }
            }
            return [validStages, preStage, endStage];
        }
        async _getCustomZoneStages(tender, zone, timeType) {
            const times = zone.split(' - ');
            if (times.length !== 2) throw '选择的汇总周期无效';
            const beginTime = moment(times[0], 'YYYY-MM-DD');
            const endTime = moment(times[1], 'YYYY-MM-DD');

            const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
            let preStage, endStage;
            for (const stage of stages) {
                let sTime;
                switch (timeType) {
                    case 'final-checked':
                        if (stage.status !== auditConst.stage.status.checked) continue;

                        const finalAudit = await this.ctx.service.stageAudit.getLastestAuditor(stage.id, stage.times, stage.status);
                        if (!finalAudit) continue;

                        sTime = moment(finalAudit.end_time).format('YYYY-MM-DD');
                        break;
                    case 'period-end':
                        sTime = stage.period ? (stage.period.split(' ~ ')[1] ? stage.period.split(' ~ ')[1] : stage.period)  : '';
                        break;
                    default:
                        throw '配置参数错误';
                }
                stage.checked_day = sTime;
                stage.checked_time = moment(sTime, 'YYYY-MM-DD');
                if (stage.checked_time.isBetween(beginTime, endTime, null, '[]')) {
                    validStages.push(stage);
                } else if (stage.checked_time.isBefore(beginTime)) {
                    if (!preStage || preStage.checked_time.isBefore(stage.checked_time)) preStage = stage;
                } else if (stage.checked_time.isAfter(endTime)) {
                    if (!endStage || endStage.checked_time.isAfter(stage.checked_time)) endStage = stage;
                }
            }
            return [validStages, preStage, endStage];
        }
        async _getMonthStages(tender, month) {
            const stages = await this._getValidStages(tender.id, 'asc'), validStages = [];
            for (const stage of stages) {
                if (stage.s_time === month) validStages.push(stage);
            }
            const preStage = stages.length > 0 ? stages.find(x => { return x.order === stages[0].order - 1; }) : null;
            const endStage = stages.length > 0 ? stages.find(x => { return x.order === stages[stages.length - 1].order + 1; }) : null;
            return [validStages, preStage, endStage];
        }

        /**
         * 台账数据
         */

        async _gatherStagesData(completeData, tender, stages, preStage) {
            const resultPos = this.resultPos;
            const helper = this.ctx.helper;
            completeData.id = tender.id;
            completeData.name = tender.name;
            /**
             * 汇总并合并 相关数据
             * @param {Array} index - 主数据
             * @param {Array[]}rela - 相关数据 {data, fields, prefix, relaId}
             */
            const sumAssignRelaData = function (index, rela) {
                const loadFields = function (datas, fields, prefix, relaId) {
                    for (const d of datas) {
                        const key = indexPre + d[relaId];
                        const m = index[key];
                        if (m) {
                            for (const f of fields) {
                                if (d[f] !== undefined) {
                                    m[prefix + f] = helper.add(m[prefix + f], d[f]);
                                }
                            }
                        }
                    }
                };
                for (const r of rela) {
                    loadFields(r.data, r.fields, r.prefix, r.relaId);
                }
            };
            const billsTree = new Ledger.billsTree(this.ctx, {
                id: 'ledger_id',
                pid: 'ledger_pid',
                order: 'order',
                level: 'level',
                rootId: -1,
                keys: ['id', 'tender_id', 'ledger_id'],
                stageId: 'id',
                calcFields: ['deal_tp', 'total_price', 'contract_tp', 'qc_tp', 'gather_tp', 'contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'pre_contract_tp', 'pre_qc_tp', 'pre_gather_tp'],
                calc: function (node) {
                    if (node.children && node.children.length === 0) {
                        node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
                        node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
                        node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
                        node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
                        node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
                    }
                    node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
                    node.gather_tp = helper.add(node.contract_tp, node.qc_tp);
                    node.end_contract_tp = helper.add(node.pre_contract_tp, node.contract_tp);
                    node.end_qc_tp = helper.add(node.pre_qc_tp, node.qc_tp);
                    node.end_gather_tp = helper.add(node.pre_gather_tp, node.gather_tp);
                }
            });
            const billsData = await this.ctx.service.ledger.getData(tender.id);
            const dgnData = await this.ctx.service.stageBillsDgn.getDgnData(tender.id);
            for (const d of dgnData) {
                const l = this.ctx.helper._.find(billsData, {id: d.id});
                this.ctx.helper._.assignIn(l, d);
            }
            const pos = new Ledger.pos({
                id: 'id', ledgerId: 'lid',
                calc: function (node) {
                    node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
                    node.gather_tp = helper.sum([node.contract_tp, node.qc_tp, node.pc_tp]);
                    node.end_contract_tp = helper.sum([node.pre_contract_tp, node.contract_tp, node.contract_pc_tp]);
                    node.end_qc_tp = helper.sum([node.pre_qc_tp, node.qc_tp, node.qc_pc_tp]);
                    node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
                },
            });
            const posData = await this.ctx.service.pos.getAllDataByCondition({ where: { tid: tender.id} });
            let billsIndexData = {};
            for (const bd of billsData) {
                billsIndexData[indexPre + bd.id] = bd;
            }
            let posIndexData = {};
            for (const p of posData) {
                posIndexData[indexPre + p.id] = p;
            }

            if (preStage) {
                await this.ctx.service.stage.doCheckStage(preStage);
                const endStage = await this.ctx.service.stageBillsFinal.getFinalData(tender, preStage.order);
                sumAssignRelaData(billsIndexData, [
                    { data: endStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: 'pre_', relaId: 'lid' },
                ]);
                const endStagePos = await this.ctx.service.stagePosFinal.getFinalData(tender, preStage.order);
                sumAssignRelaData(posIndexData, [
                    {data: endStagePos, fields: ['contract_qty', 'qc_qty'], prefix: 'pre_', relaId: 'lid'},
                ]);
            }

            for (const stage of stages) {
                await this.ctx.service.stage.doCheckStage(stage);
                const curStage = stage.readOnly
                    ? await this.ctx.service.stageBills.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
                    : await this.ctx.service.stageBills.getLastestStageData2(tender.id, stage.id);
                const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: stage.id } });
                sumAssignRelaData(billsIndexData, [
                    {data: curStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: '', relaId: 'lid'},
                    { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp'], prefix: '', relaId: 'lid' },
                ]);
                const curStagePos = stage.readOnly
                    ? await this.ctx.service.stagePos.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
                    : await this.ctx.service.stagePos.getLastestStageData2(tender.id, stage.id);
                sumAssignRelaData(posIndexData, [
                    {data: curStagePos, fields: ['contract_qty', 'qc_qty'], prefix: '', relaId: 'pid'},
                ]);
            }

            billsTree.loadDatas(billsData);
            billsTree.calculateAll();
            pos.loadDatas(posData);
            pos.calculateAll();
            this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
                gatherUtils.gatherStage(tender, gatherNode, sourceNode, completeData.prefix, helper);
            }, function (gatherNode, sourceNode) {
                const posRange = pos.getLedgerPos(sourceNode.id);
                if (!posRange || posRange.length === 0) return;
                resultPos.loadGatherPos(gatherNode.id, posRange, (gatherPos, sourcePos) => {
                    gatherUtils.gatherStagePos(tender, gatherPos, sourcePos, completeData.prefix, helper);
                });
            });
        }
        async _gatherZoneData(tender, completeData, zone) {
            const [stages, preStage, endStage] = await this._getTimeZoneStages(tender, zone);
            await this._gatherStagesData(completeData, tender, stages, preStage);
        }
        async _gatherIndexZoneData(tender, completeData, stageZone) {
            const [stages, preStage, endStage] = await this._getOrderZoneStages(tender, stageZone);
            await this._gatherStagesData(completeData, tender, stages, preStage);
        }
        async _gatherCustomZoneData(tender, completeData, zone, timeType) {
            const [stages, preStage, endStage] = await this._getCustomZoneStages(tender, zone, timeType);
            await this._gatherStagesData(completeData, tender, stages, preStage);
        }
        async _gatherMonthsData(tender, completeData, month) {
            const [stages, preStage, endStage] = await this._getMonthStages(tender, month);
            await this._gatherStagesData(completeData, tender, stages, preStage);
        }

        async _gatherStageData(completeData, tender, stage, hasPre) {
            const helper = this.ctx.helper;
            const resultPos = this.resultPos;
            completeData.id = tender.id;
            completeData.name = tender.name;

            const billsTree = new Ledger.billsTree(this.ctx, {
                id: 'ledger_id',
                pid: 'ledger_pid',
                order: 'order',
                level: 'level',
                rootId: -1,
                keys: ['id', 'tender_id', 'ledger_id'],
                stageId: 'id',
                calcFields: ['deal_tp', 'total_price',
                    'contract_tp', 'qc_tp', 'contract_pc_tp', 'qc_pc_tp', 'pc_tp', 'gather_tp',
                    'pre_contract_tp', 'pre_qc_tp', 'pre_gather_tp',
                    'end_contract_tp', 'end_qc_tp', 'end_gather_tp',
                    'due_qc_tp', 'due_final_tp',
                ],
                calc: function (node) {
                    if (node.children && node.children.length === 0) {
                        node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
                        node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
                        node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
                        node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
                        node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
                        node.due_final_qty = helper.add(node.quantity, node.due_qc_qty);
                    }
                    node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
                    node.gather_tp = helper.sum([node.contract_tp, node.qc_tp, node.pc_tp]);
                    node.end_contract_tp = helper.sum([node.pre_contract_tp, node.contract_tp, node.contract_pc_tp]);
                    node.end_qc_tp = helper.sum([node.pre_qc_tp, node.qc_tp, node.qc_pc_tp]);
                    node.end_gather_tp = helper.add(node.pre_gather_tp, node.gather_tp);
                    node.due_final_tp = helper.add(node.total_price, node.due_qc_tp);
                }
            });
            const billsData = await this.ctx.service.ledger.getData(tender.id);
            const dgnData = await this.ctx.service.stageBillsDgn.getDgnData(tender.id);
            const changeBillsData = await this.ctx.service.changeAuditList.getBillsSum(tender.id);
            this.ctx.helper.assignRelaData(billsData, [
                { data: dgnData, fields: ['deal_dgn_qty1', 'deal_dgn_qty2', 'c_dgn_qty1', 'c_dgn_qty2'], prefix: '', relaId: 'id' },
                { data: changeBillsData, fields: ['qc_qty', 'qc_tp', 'qc_minus_qty'], prefix: 'due_', relaId: 'gcl_id' },
            ]);
            const pos = new Ledger.pos({
                id: 'id', ledgerId: 'lid',
                calc: function (node) {
                    node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
                    node.gather_qty = helper.add(node.contract_qty, node.qc_qty);
                    node.end_contract_qty = helper.add(node.pre_contract_qty, node.contract_qty);
                    node.end_qc_qty = helper.add(node.pre_qc_qty, node.qc_qty);
                    node.end_gather_qty = helper.add(node.pre_gather_qty, node.gather_qty);
                    node.due_final_qty = helper.add(node.quantity, node.due_qc_qty);
                },
            });
            const posData = await this.ctx.service.pos.getPosData({ tid: tender.id });
            const changePosData = await this.ctx.service.changeAuditList.getPosSum(tender.id);
            this.ctx.helper.assignRelaData(posData, [
                { data: changePosData, fields: ['qc_qty', 'qc_minus_qty'], prefix: 'due_', relaId: 'mx_id' },
            ]);
            if (stage) {
                await this.ctx.service.stage.doCheckStage(stage);
                const curStage = stage.readOnly
                    ? await this.ctx.service.stageBills.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
                    : await this.ctx.service.stageBills.getLastestStageData2(tender.id, stage.id);
                const preStage = hasPre && stage.preCheckedStage ? await this.ctx.service.stageBillsFinal.getFinalData(tender, stage.preCheckedStage.order) : [];
                const bpcStage = await this.ctx.service.stageBillsPc.getAllDataByCondition({ where: { sid: stage.id } });
                this.ctx.helper.assignRelaData(billsData, [
                    { data: curStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: '', relaId: 'lid' },
                    { data: preStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: 'pre_', relaId: 'lid' },
                    { data: bpcStage, fields: ['contract_pc_tp', 'qc_pc_tp', 'pc_tp'], prefix: '', relaId: 'lid' },
                ]);

                const curStagePos = stage.readOnly
                    ? await this.ctx.service.stagePos.getAuditorStageData2(tender.id, stage.id, stage.curTimes, stage.curOrder)
                    : await this.ctx.service.stagePos.getLastestStageData2(tender.id, stage.id);
                const preStagePos = hasPre && stage.preCheckedStage ? await this.ctx.service.stagePosFinal.getFinalData(tender, stage.preCheckedStage.order) : [];
                this.ctx.helper.assignRelaData(posData, [
                    { data: curStagePos, fields: ['contract_qty', 'qc_qty'], prefix: '', relaId: 'pid' },
                    { data: preStagePos, fields: ['contract_qty', 'qc_qty'], prefix: 'pre_', relaId: 'pid' },
                ]);
            }
            billsTree.loadDatas(billsData);
            billsTree.calculateAll();
            pos.loadDatas(posData);
            pos.calculateAll();

            this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
                gatherUtils.gatherStage(tender, gatherNode, sourceNode, completeData.prefix, helper);
            }, function (gatherNode, sourceNode) {
                const posRange = pos.getLedgerPos(sourceNode.id);
                if (!posRange || posRange.length === 0) return;
                resultPos.loadGatherPos(gatherNode.id, posRange, (gatherPos, sourcePos) => {
                    gatherUtils.gatherStagePos(tender, gatherPos, sourcePos, completeData.prefix, helper);
                });
            });
        }
        async _gatherMonthData(tender, completeData, month, hasPre) {
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {s_time: month});
            await this._gatherStageData(completeData, tender, stage, hasPre);
        }
        async _gatherIndexData(tender, completeData, index, hasPre) {
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {order: index});
            await this._gatherStageData(completeData, tender, stage, hasPre);
        }
        async _gatherFinalData(tender, completeData, hasPre) {
            const stages = await this._getValidStages(tender.id);
            await this._gatherStageData(completeData, tender, stages[0], hasPre);
        }
        async _gatherCheckedFinalData(tender, completeData, hasPre) {
            const stages = await this._getCheckedStages(tender.id);
            await this._gatherStageData(completeData, tender, stages[0], hasPre);
        }

        async _loadGatherLedger(tender) {
            const billsTree = new Ledger.billsTree(this.ctx, {
                id: 'ledger_id',
                pid: 'ledger_pid',
                order: 'order',
                level: 'level',
                rootId: -1,
                keys: ['id', 'tender_id', 'ledger_id'],
                stageId: 'id',
                calcFields: ['deal_tp', 'total_price'],
            });
            const billsData = await this.ctx.service.ledger.getData(tender.id);
            billsTree.loadDatas(billsData);
            billsTree.calculateAll();
            return billsTree;
        }
        async _loadGatherPos(tender) {
            const pos = new Ledger.pos({ id: 'id', ledgerId: 'lid' });
            const posData = await this.ctx.service.pos.getAllDataByCondition({ where: { tid: tender.id } });
            pos.loadDatas(posData);
            return pos;
        }
        async _gatherLedgerData(tender, completeData) {
            const resultPos = this.resultPos;
            const helper = this.ctx.helper;
            const billsTree = await this._loadGatherLedger(tender);
            const pos = await this._loadGatherPos(tender);
            this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
                gatherUtils.gatherLedger(tender, gatherNode, sourceNode, completeData.prefix, helper);
            }, function (gatherNode, sourceNode) {
                const posRange = pos.getLedgerPos(sourceNode.id);
                if (!posRange || posRange.length === 0) return;
                resultPos.loadGatherPos(posRange, (gatherPos, sourcePos) => {
                    gatherUtils.gatherPos(gatherPos, sourcePos, completeData.prefix, helper);
                });
            });
        }
        async _gatherSpecialData(tender, sKey) {
            const resultPos = this.resultPos;
            const helper = this.ctx.helper;
            const billsTree = await this._loadGatherLedger(tender);
            const pos = await this._loadGatherPos(tender);
            this.resultTree.loadGatherTree(billsTree, function (gatherNode, sourceNode) {
                gatherUtils.gatherSpecial(gatherNode, sourceNode, 'ts_' + sKey + '_', helper);
            }, function (gatherNode, sourceNode) {
                const posRange = pos.getLedgerPos(sourceNode.id);
                if (!posRange || posRange.length === 0) return;
                resultPos.loadGatherPos(gatherNode.id, posRange, (gatherPos, sourcePos) => {
                    gatherUtils.gatherSpecialPos(gatherPos, sourcePos, 'ts_' + sKey + '_', helper);
                });
            });
        }

        async _doGatherStageData(memFieldKeys, gsDefine, gsCustom) {
            if (this.resultTree || this.resultPos) return;
            if (!gsDefine || !gsDefine.enable) return;
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return;

            this.resultTree = new Ledger.gatherTree(this.ctx, {
                id: 'id',
                pid: 'pid',
                order: 'order',
                level: 'level',
                rootId: -1
            });
            this.resultPos = new Ledger.gatherPos({ id: 'id', ledgerId: 'lid' });

            const gsSetting = JSON.parse(gsDefine.setting);
            let commonIndex = 0;
            const completeDatas = [];
            for (const t of gsCustom.tenders) {
                const specialKey = this._checkSpecialTender(t, gsSetting.special);
                const tender = await this.ctx.service.tender.getCheckTender(t.tid);
                if (specialKey === '') {
                    const completeData = {
                        prefix: 't_' + commonIndex + '_',
                    };
                    completeDatas.push(completeData);
                    switch (gsSetting.type) {
                        case 'month':
                            await this._gatherMonthData(tender, completeData, gsCustom.month, gsSetting.hasPre);
                            break;
                        case 'months':
                            await this._gatherMonthsData(tender, completeData, gsCustom.months);
                            break;
                        case 'zone':
                            await this._gatherZoneData(tender, completeData, gsCustom.zone);
                            break;
                        case 'final':
                            await this._gatherFinalData(tender, completeData, gsSetting.hasPre);
                            break;
                        case 'checked-final':
                            await this._gatherCheckedFinalData(tender, completeData, gsSetting.hasPre);
                            break;
                        case 'ledger':
                            await this._gatherLedgerData(tender, completeData);
                            break;
                        case 'stage':
                            await this._gatherIndexData(tender, completeData, gsCustom.stage, gsSetting.hasPre);
                            break;
                        case 'stage-zone':
                            await this._gatherIndexZoneData(tender, completeData, gsCustom.stage_zone);
                            break;
                        case 'custom-zone':
                            await this._gatherCustomZoneData(tender, completeData, gsCustom.custom_zone, gsSetting.timeType);
                            break;
                    }
                    commonIndex++;
                } else {
                    await this._gatherSpecialData(tender, specialKey);
                }
            }

            this.resultTree.resortChildrenDefault();
            gatherUtils.completeGatherData(this.resultTree.nodes, completeDatas);
            gatherUtils.completeGatherData(this.resultPos.datas, completeDatas);
        }

        async getGatherStageBills(memFieldKeys, gsDefine, gsCustom, showLevel) {
            await this._doGatherStageData(memFieldKeys, gsDefine, gsCustom);
            return this.resultTree
                ? (showLevel ? this.resultTree.getDefaultDatasByLevel(this.ctx.tender.rpt_show_level) : this.resultTree.getDefaultDatas())
                : [];
        }
        async getGatherStagePos(memFieldKeys, gsDefine, gsCustom) {
            await this._doGatherStageData(memFieldKeys, gsDefine, gsCustom);
            return this.resultPos ? this.resultPos.getDatas() : [];
        }

        /**
         * 标段信息
         */
        async _getBaseTenderInfo(tender) {
            const info = {
                id: tender.id,
                name: tender.name,

                deal_tp: tender.deal_tp,
                tp: tender.total_price
            };
            const deal_bills_sum = await this.ctx.service.dealBills.getSum(tender.id);
            info.deal_bills_tp = deal_bills_sum ? deal_bills_sum.total_price : 0;
            if (tender.ledger_status === auditConst.ledger.status.uncheck || tender.ledger_status === auditConst.ledger.status.checkNo) {
                const sum = await this.ctx.service.ledger.addUp({tender_id: tender.id/*, is_leaf: true*/});
                info.tp = sum.total_price;
                info.deal_tp = sum.deal_tp;
            }
            info.deal_info = tender.info.deal_info;
            info.construction_unit = tender.info.construction_unit;
            info.tech_param = tender.info.tech_param;
            info.deal_param = tender.info.deal_param;
            info.pay_account = tender.info.pay_account;
            info.deal_param.contractPriceWithoutZL = this.ctx.helper.sub(info.deal_param.contractPrice,
                info.deal_param.zanLiePrice);
            info.bid_info = tender.info.bid_info;
            return info;
        }
        async _getStageTenderInfo(stage, info) {
            if (stage) {
                const helper = this.ctx.helper;
                await this.ctx.service.stage.doCheckStage(stage);
                await this.ctx.service.stage.checkStageGatherData(stage, this.ctx.session.sessionUser.is_admin);

                info.pre_contract_tp = stage.pre_contract_tp;
                info.pre_qc_tp = stage.pre_qc_tp;
                info.pre_gather_tp = helper.add(info.pre_contract_tp, info.pre_qc_tp);

                info.contract_tp = stage.contract_tp;
                info.qc_tp = stage.qc_tp;
                info.gather_tp = helper.add(info.contract_tp, info.qc_tp);

                info.end_contract_tp = helper.add(info.pre_contract_tp, info.contract_tp);
                info.end_qc_tp = helper.add(info.pre_qc_tp, info.qc_tp);
                info.end_gather_tp = helper.add(info.pre_gather_tp, info.gather_tp);

                info.yf_tp = stage.yf_tp;
                info.pre_yf_tp = stage.pre_yf_tp;
                info.end_yf_tp = helper.add(stage.yf_tp, stage.pre_yf_tp);

                info.sf_tp = stage.sf_tp;
                info.pre_sf_tp = stage.pre_sf_tp;
                info.end_sf_tp = helper.add(stage.sf_tp, stage.pre_sf_tp);
            }
        }
        async _getStagesTenderInfo(stages, info, preStage) {
            const helper = this.ctx.helper;
            if (preStage) {
                info.pre_contract_tp = helper.add(preStage.contract_tp, preStage.pre_contract_tp);
                info.pre_qc_tp = helper.add(preStage.qc_tp, preStage.pre_qc_tp);
                info.pre_gather_tp = helper.add(info.pre_contract_tp, info.pre_qc_tp);
                info.pre_yf_tp = helper.add(preStage.yf_tp, preStage.pre_yf_tp);
            }

            for (const stage of stages) {
                await this.ctx.service.stage.doCheckStage(stage);
                await this.ctx.service.stage.checkStageGatherData(stage, this.ctx.session.sessionUser.is_admin);


                info.contract_tp = helper.add(info.contract_tp, stage.contract_tp);
                info.qc_tp = helper.add(info.qc_tp, stage.qc_tp);

                info.yf_tp = helper.add(info.yf_tp, stage.yf_tp);
            }
            info.gather_tp = helper.add(info.contract_tp, info.qc_tp);
            info.end_contract_tp = helper.add(info.pre_contract_tp, info.contract_tp);
            info.end_qc_tp = helper.add(info.pre_qc_tp, info.qc_tp);
            info.end_gather_tp = helper.add(info.pre_gather_tp, info.gather_tp);
            info.end_yf_tp = helper.add(info.pre_yf_tp, info.yf_tp);
        }
        async _gatherZoneTenderInfo(tender, index, zone) {
            const info = await this._getBaseTenderInfo(tender);
            const [stages, preStage, endStage] = await this._getTimeZoneStages(tender, zone);
            await this._getStagesTenderInfo(stages, info, preStage);
            this.resultTenderInfo.push(info);
        }
        async _gatherOrderZoneTenderInfo(tender, index, stageZone) {
            const info = await this._getBaseTenderInfo(tender);
            const [stages, preStage, endStage] = await this._getOrderZoneStages(tender, stageZone);
            await this._getStagesTenderInfo(stages, info, preStage);
            this.resultTenderInfo.push(info);
        }
        async _gatherCustomZoneTenderInfo(tender, index, zone, timeType) {
            const info = await this._getBaseTenderInfo(tender);
            const [stages, preStage, endStage] = await this._getCustomZoneStages(tender, zone, timeType);
            await this._getStagesTenderInfo(stages, info, preStage);
            this.resultTenderInfo.push(info);
        }

        async _gatherMonthTenderInfo(tender, index, month, hasPre) {
            const info = await this._getBaseTenderInfo(tender);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {s_time: month});
            await this._getStageTenderInfo(stage, info);
            this.resultTenderInfo.push(info);
        }
        async _gatherOrderTenderInfo(tender, index, order, hasPre) {
            const info = await this._getBaseTenderInfo(tender);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {order: order});
            await this._getStageTenderInfo(stage, info);
            this.resultTenderInfo.push(info);
        }
        async _gatherFinalTenderInfo(tender, index, hasPre) {
            const info = await this._getBaseTenderInfo(tender);
            const stages = await this._getValidStages(tender.id);
            await this._getStageTenderInfo(stages[0], info);
            this.resultTenderInfo.push(info);
        }
        async _gatherCheckedFinalTenderInfo(tender, index, hasPre) {
            const info = await this._getBaseTenderInfo(tender);
            const stages = await this._getCheckedStages(tender.id);
            await this._getStageTenderInfo(stages[0], info);
            this.resultTenderInfo.push(info);
        }
        async _gatherLedgerTenderInfo(tender, index) {
            const info = await this._getBaseTenderInfo(tender);
            this.resultTenderInfo.push(info);
        }
        async _gatherSpecialTenderInfo(tender, sKey) {
            const info = await this._getBaseTenderInfo(tender);
            info.spec = sKey;
            this.resultTenderInfo.push(info);
        }
        async getGatherTenderInfo(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];

            this.resultTenderInfo = [];
            const gsSetting = JSON.parse(gsDefine.setting);
            let commonIndex = 0;
            for (const t of gsCustom.tenders) {
                const specialKey = this._checkSpecialTender(t, gsSetting.special);
                const tender = await this.ctx.service.tender.getCheckTender(t.tid);
                if (specialKey === '') {
                    switch (gsSetting.type) {
                        case 'month':
                            await this._gatherMonthTenderInfo(tender, commonIndex, gsCustom.month, gsSetting.hasPre);
                            break;
                        case 'zone':
                            await this._gatherZoneTenderInfo(tender, commonIndex, gsCustom.zone);
                            break;
                        case 'final':
                            await this._gatherFinalTenderInfo(tender, commonIndex, gsSetting.hasPre);
                            break;
                        case 'checked-final':
                            await this._gatherCheckedFinalTenderInfo(tender, commonIndex, gsSetting.hasPre);
                            break;
                        case 'ledger':
                            await this._gatherLedgerTenderInfo(tender, commonIndex);
                            break;
                        case 'stage':
                            await this._gatherOrderTenderInfo(tender, commonIndex, gsCustom.stage, gsSetting.hasPre);
                            break;
                        case 'stage-zone':
                            await this._gatherOrderZoneTenderInfo(tender, commonIndex, gsCustom.stage_zone);
                            break;
                        case 'custom-zone':
                            await this._gatherCustomZoneTenderInfo(tender, commonIndex, gsCustom.custom_zone, gsSetting.timeType);
                            break;
                    }
                    commonIndex++;
                } else {
                    await this._gatherSpecialTenderInfo(tender, specialKey);
                }
            }
            return this.resultTenderInfo;
        }

        /**
         * 合同支付
         */
        _gatherPayRecord(dealPay, fun) {
            let rdp;
            if (dealPay.ptype !== payConst.payType.normal) {
                rdp = this.ctx.helper._.find(this.resultDealPay, {ptype: dealPay.ptype});
            } else {
                rdp = this.ctx.helper._.find(this.resultDealPay, {
                    name: dealPay.name,
                    minus: dealPay.minus ? true : false,
                    is_yf: dealPay.is_yf ? true : false,
                });
            }
            if (!rdp) {
                rdp = {
                    ptype: dealPay.ptype,
                    name: dealPay.name,
                    minus: dealPay.minus ? true : false,
                    is_yf: dealPay.is_yf ? true : false,
                };
                this.resultDealPay.push(rdp);
            }
            if (fun) fun(rdp, dealPay);
        }
        async _checkStagePayCalc(tender, stage, dealPay) {
            if (!stage.readOnly) {
                // 计算 本期金额
                const payCalculator = new PayCalculator(this.ctx, stage, tender.info);
                await payCalculator.calculateAll(dealPay);
            }
        }
        async _gatherStagePay(completeData, tender, stage, hasPre) {
            if (stage) {
                completeData.id = tender.id;
                completeData.name = tender.name;
                const helper = this.ctx.helper;
                await this.ctx.service.stage.doCheckStage(stage);

                const dealPay = await this.ctx.service.stagePay.getStagePays(stage);
                await this._checkStagePayCalc(tender, stage, dealPay);
                for (const dp of dealPay) {
                    dp.end_tp = helper.add(dp.pre_tp, dp.tp);
                    this._gatherPayRecord(dp, function (gatherData, sourceData) {
                        gatherData[completeData.prefix + 'id'] = tender.id;
                        gatherData[completeData.prefix + 'name'] = tender.name;

                        gatherData[completeData.prefix + 'tp'] = helper.add(gatherData[completeData.prefix + 'tp'], sourceData.tp);
                        gatherData[completeData.prefix + 'pre_tp'] = helper.add(gatherData[completeData.prefix + 'pre_tp'], sourceData.pre_tp);
                        gatherData[completeData.prefix + 'end_tp'] = helper.add(gatherData[completeData.prefix + 'end_tp'], sourceData.end_tp);

                        gatherData['s_' + 'tp'] = helper.add(gatherData['s_' + 'tp'], sourceData.tp);
                        gatherData['s_' + 'pre_tp'] = helper.add(gatherData['s_' + 'pre_tp'], sourceData.pre_tp);
                        gatherData['s_' + 'end_tp'] = helper.add(gatherData['s_' + 'end_tp'], sourceData.end_tp);
                    });
                }
            }
        }
        async _gatherStagesPay(completeData, tender, stages, preStage) {
            const helper = this.ctx.helper;
            completeData.id = tender.id;
            completeData.name = tender.name;

            if (preStage) await this.ctx.service.stage.doCheckStage(preStage);
            const preDealPay = preStage ? await this.ctx.service.stagePay.getStagePays(preStage) : [];
            for (const dp of preDealPay) {
                dp.end_tp = helper.add(dp.pre_tp, dp.tp);
                this._gatherPayRecord(dp, function (gatherData, sourceData) {
                    gatherData[completeData.prefix + 'id'] = tender.id;
                    gatherData[completeData.prefix + 'name'] = tender.name;

                    gatherData[completeData.prefix + 'pre_tp'] = sourceData.end_tp;
                    gatherData.s_pre_tp = helper.add(gatherData.s_pre_tp, sourceData.end_tp);

                    gatherData[completeData.prefix + 'end_tp'] = sourceData.end_tp;
                    gatherData.s_end_tp = helper.add(gatherData.s_end_tp, sourceData.end_tp);
                });
            }

            for (const stage of stages) {
                await this.ctx.service.stage.doCheckStage(stage);

                const dealPay = await this.ctx.service.stagePay.getStagePays(stage);
                await this._checkStagePayCalc(tender, stage, dealPay);
                for (const dp of dealPay) {
                    dp.end_tp = helper.add(dp.pre_tp, dp.tp);
                    this._gatherPayRecord(dp, function (gatherData, sourceData) {
                        gatherData[completeData.prefix + 'id'] = tender.id;
                        gatherData[completeData.prefix + 'name'] = tender.name;

                        gatherData[completeData.prefix + 'tp'] = helper.add(gatherData[completeData.prefix + 'tp'], sourceData.tp);
                        gatherData['s_' + 'tp'] = helper.add(gatherData['s_' + 'tp'], sourceData.tp);

                        gatherData[completeData.prefix + 'end_tp'] = helper.add(gatherData[completeData.prefix + 'end_tp'], sourceData.tp);
                        gatherData['s_' + 'end_tp'] = helper.add(gatherData['s_' + 'end_tp'], sourceData.tp);
                    });
                }
            }
        }

        async _gatherZoneStagePay(sTender, completeData, zone) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const [stages, preStage, endStage] = await this._getTimeZoneStages(tender, zone);
            await this._gatherStagesPay(completeData, tender, stages, preStage);
        }
        async _gatherOrderZoneStagePay(sTender, completeData, stageZone) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const [stages, preStage, endStage] = await this._getOrderZoneStages(tender, stageZone);
            await this._gatherStagesPay(completeData, tender, stages, preStage);
        }
        async _gatherCustomZoneStagePay(sTender, completeData, zone, timeType) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const [stages, preStage, endStage] = await this._getCustomZoneStages(tender, zone, timeType);
            await this._gatherStagesPay(completeData, tender, stages, preStage);
        }

        async _gatherMonthStagePay(sTender, completeData, month, hasPre) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {s_time: month});
            await this._gatherStagePay(completeData, tender, stage, hasPre);
        }
        async _gatherOrderStagePay(sTender, completeData, order, hasPre) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {order: order});
            await this._gatherStagePay(completeData, tender, stage, hasPre);
        }
        async _gatherFinalStagePay(sTender, completeData, hasPre) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            await this._gatherStagePay(completeData, tender, stages[0], hasPre);
        }
        async _gatherCheckedFinalStagePay(sTender, completeData, hasPre) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getCheckedStages(tender.id);
            await this._gatherStagePay(completeData, tender, stages[0], hasPre);
        }
        async getGatherStagePay(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];

            this.resultDealPay = [];
            const gsSetting = JSON.parse(gsDefine.setting);
            let commonIndex = 0;
            const completeDatas = [];
            for (const tender of gsCustom.tenders) {
                const specialKey = this._checkSpecialTender(tender, gsSetting.special);
                if (specialKey === '') {
                    const completeData = {
                        prefix: 't_' + commonIndex + '_',
                    };
                    completeDatas.push(completeData);
                    switch (gsSetting.type) {
                        case 'month':
                            await this._gatherMonthStagePay(tender, completeData, gsCustom.month, gsSetting.hasPre);
                            break;
                        case 'zone':
                            await this._gatherZoneStagePay(tender, completeData, gsCustom.zone);
                            break;
                        case 'final':
                            await this._gatherFinalStagePay(tender, completeData, gsSetting.hasPre);
                            break;
                        case 'checked-final':
                            await this._gatherCheckedFinalStagePay(tender, completeData, gsSetting.hasPre);
                            break;
                        case 'stage':
                            await this._gatherOrderStagePay(tender, completeData, gsCustom.stage, gsSetting.hasPre);
                            break;
                        case 'stage-zone':
                            await this._gatherOrderZoneStagePay(tender, completeData, gsCustom.stage_zone);
                            break;
                        case 'custom-zone':
                            await this._gatherCustomZoneStagePay(tender, completeData, gsCustom.custom_zone, gsSetting.timeType);
                            break;
                    }
                    commonIndex++;
                }
                // 合同支付，只有在每一期中有数据，故特殊标段直接不汇总合同支付
            }
            gatherUtils.completeGatherData(this.resultDealPay, completeDatas);
            return this.resultDealPay;
        }

        /**
         * 签约清单
         */
        async _gatherDealBills(tender, fun) {
            const dealBills = await this.ctx.service.dealBills.getAllDataByCondition({
                where: { tender_id: tender.id }
            });
            for (const db of dealBills) {
                let rdb = this.ctx.helper._.find(this.resultDealBills, {
                    code: db.code,
                    name: db.name,
                    unit: db.unit,
                    unit_price: db.unit_price ? db.unit_price: 0,
                });
                if (!rdb) {
                    rdb = {
                        code: db.code,
                        name: db.name,
                        unit: db.unit,
                        unit_price: db.unit_price ? db.unit_price: 0,
                    };
                    this.resultDealBills.push(rdb);
                }
                if (fun) fun(rdb, db);
            }
        }
        async _gatherCommonDealBills(sTender, completeData) {
            const self = this;
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            completeData.id = tender.id;
            completeData.name = tender.name;
            await this._gatherDealBills(tender, function (gatherData, sourceData) {
                gatherData[completeData.prefix + 'id'] = tender.id;
                gatherData[completeData.prefix + 'name'] = tender.name;

                gatherData[completeData.prefix + 'qty'] = sourceData.quantity;
                gatherData[completeData.prefix + 'tp'] = sourceData.total_price;

                gatherData['s_' + 'qty'] = self.ctx.helper.add(gatherData['s_' + 'qty'], sourceData.quantity);
                gatherData['s_' + 'tp'] = self.ctx.helper.add(gatherData['s_' + 'tp'], sourceData.total_price);
            });
        }
        async _gatherSpecialDealBills(sTender, sKey) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            await this._gatherDealBills(tender, function (gatherData, sourceData) {
                const prefix = 'ts_' + sKey + '_';

                gatherData[prefix + 'qty'] = sourceData.quantity;
                gatherData[prefix + 'tp'] = sourceData.total_price;
            });
        }
        async getGatherDealBills(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];

            this.resultDealBills = [];
            const gsSetting = JSON.parse(gsDefine.setting);
            let commonIndex = 0;
            const completeDatas = [];
            for (const tender of gsCustom.tenders) {
                const specialKey = this._checkSpecialTender(tender, gsSetting.special);
                if (specialKey === '') {
                    const completeData = {
                        prefix: 't_' + commonIndex + '_',
                    };
                    completeDatas.push(completeData);
                    await this._gatherCommonDealBills(tender, completeData);
                    commonIndex++;
                } else {
                    await this._gatherSpecialDealBills(tender, specialKey);
                }
            }
            gatherUtils.completeGatherData(this.resultDealBills, completeDatas);
            return this.resultDealBills;
        }

        _getChangeConstName(define, value) {
            for (const prop in define) {
                if (define[prop].value === value) {
                    return define[prop].name;
                }
            }
            return '';
        }
        async _gatherChange(tender, hasUsed) {
            const self = this;
            try {
                const info = await this.ctx.service.tenderInfo.getTenderInfo(tender.id);
                const decimal = info.decimal, ctx = this.ctx;
                const where = { tid: tender.id, valid: 1 };
                if (this.ctx.session.sessionProject.page_show.isOnlyChecked) where.status = auditConst.flow.status.checked;
                const change = await this.ctx.service.change.getAllDataByCondition({ where, orders: [['in_time', 'desc']] });
                for (const c of change) {
                    c.tender_name = tender.name;
                    const types = ctx.helper._.map(c.type.split(','), function (t) {
                        return self._getChangeConstName(changeConst.type, ctx.helper._.toInteger(t));
                    });
                    c.type = types.join(';');
                    c.class = this._getChangeConstName(changeConst.class, c.class);
                    c.quality = this._getChangeConstName(changeConst.quality, c.quality);
                    c.charge = this._getChangeConstName(changeConst.charge, c.charge);
                    c.attachments = await ctx.service.changeAtt.getChangeAttachment(c.cid);
                    const names = ctx.helper._.map(c.attachments, function (x) {
                        return x.filename + x.fileext;
                    });
                    c.attNames = names.join('\n');
                }
                const changeBills = hasUsed
                    ? await this.ctx.service.stageChangeFinal.getChangeBillsWithUsedQty(tender.id, this.ctx.session.sessionProject.page_show.isOnlyChecked)
                    : await this.ctx.service.changeAuditList.getChangeAuditBills(tender.id, this.ctx.session.sessionProject.page_show.isOnlyChecked);
                for (const d of changeBills) {
                    d.tender_name = tender.name;
                    d.o_qty = d.oamount;
                    d.o_tp = this.ctx.helper.mul(d.o_qty, d.unit_price, decimal.tp);
                    d.c_qty = d.camount;
                    d.c_tp = this.ctx.helper.mul(d.c_qty, d.unit_price, decimal.tp);
                    d.s_qty = d.samount ? parseFloat(d.samount) : 0;
                    d.s_tp = this.ctx.helper.mul(d.s_qty, d.unit_price, decimal.tp);
                    d.sp_qty = d.spamount;
                    d.sp_tp = this.ctx.helper.mul(d.sp_qty, d.unit_price, decimal.tp);

                    d.used_tp = this.ctx.helper.mul(d.used_qty, d.unit_price, decimal.tp);
                    d.is_used = !!d.used_qty;

                    const auditAmount = d.audit_amount ? d.audit_amount.split(',') : [];
                    const relaChange = ctx.helper._.find(change, {cid: d.cid});
                    d.relaChange = relaChange;
                    if (relaChange) {
                        if (d.is_used) relaChange.is_used = true;
                        relaChange.used_tp = ctx.helper.add(relaChange.used_tp, d.used_tp);
                    }
                    for (const [i, aa] of auditAmount.entries()) {
                        const amountField = 'qty_' + (i+1), tpField = 'tp_' + (i+1);
                        d[amountField] = aa ? parseFloat(aa) : 0;
                        d[tpField] = ctx.helper.mul(d[amountField], d.unit_price, decimal.tp);
                        if (relaChange) {
                            relaChange[tpField] = ctx.helper.add(relaChange[tpField], d[tpField]);
                        }
                    }
                }
                for (const c of change) {
                    c.is_used = !!c.is_used;
                    c.used_ratio = c.total_price ? ctx.helper.mul(ctx.helper.div(c.used_tp, c.total_price), 100) : 0;
                }
                for (const cb of changeBills) {
                    cb.is_used_bgl = cb.relaChange ? cb.relaChange.is_used : cb.is_used;
                    delete cb.relaChange;
                }

                change.sort(function (a, b) {
                    return a.code.localeCompare(b.code);
                });
                changeBills.sort(function (a, b) {
                    const aCIndex = change.findIndex(function (c) {
                        return c.cid === a.cid;
                    });
                    const bCIndex = change.findIndex(function (c) {
                        return c.cid === b.cid;
                    });
                    return aCIndex === bCIndex
                        ? ctx.helper.compareCode(a.code, b.code)
                        : aCIndex - bCIndex;
                });
                return [change, changeBills];
            } catch(err) {
                this.ctx.helper.log(err);
                throw err;
                return [[], []];
            }
        }
        async getGatherChange(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];

            const result = { mem_gather_change: [], mem_gather_change_bills: [] };
            const hasUsed = rmUtils.checkFieldsExist(memFieldKeys, ['used_qty', 'is_used_bgl', 'is_used', 'used_ratio']);
            for (const t of gsCustom.tenders) {
                const tender = await this.ctx.service.tender.getCheckTender(t.tid);
                const [change, changeBills] = await this._gatherChange(tender, hasUsed);
                result.mem_gather_change.push(...change);
                result.mem_gather_change_bills.push(...changeBills);
            }
            return result;
        }

        async _gatherStagesChange(completeData, tender, stages, preStage, gatherType = 'flow'){
            const result = [];
            const findR = function(source) {
                let r = result.find(x => { return x.cbid === source.cbid});
                if (!r) {
                    r = { cid: source.cid, cbid: source.cbid, qty: 0, pre_qty: 0 };
                    result.push(r);
                }
                return r;
            };
            const helper = this.ctx.helper;

            if (preStage) {
                const preStageChange = await this.ctx.service.stageChangeFinal.getEndStageData(stage.tid, preStage.order);
                if (gatherType === 'flow') {
                    result.push(...preStageChange);
                } else {
                    preStageChange.forEach(sc => {
                        const r = findR(sc);
                        r.pre_qty = helper.add(r.pre_qty, sc.qty);
                    });
                }
            }

            for (const stage of stages) {
                let curStageChange;
                if (stage.status === auditConst.stage.status.checked) {
                    curStageChange = await this.ctx.service.stageChangeFinal.getAllDataByCondition({ where: { tid: stage.tid, sid: stage.id } });
                } else {
                    await this.ctx.service.stage.doCheckStage(stage);
                    curStageChange = await this.ctx.service.stageChange.getCurStageData(stage.tid, stage.id, stage.curTimes, stage.curOrder);
                }
                if (gatherType === 'flow') {
                    result.push(...curStageChange);
                } else {
                    curStageChange.forEach(sc => {
                        const r = findR(sc);
                        r.qty = helper.add(r.qty, sc.qty);
                    });
                }
            }

            result.forEach(r => { r.end_qty = helper.add(r.pre_qty, r.qty); });
            return result;
        }
        async _gatherCustomZoneStageChange(sTender, completeData, timeType, gatherType) {
            const [stages, preStage, endStage] = await this._getCustomZoneStages(tender, zone, timeType);
            await this._gatherStagesChange(completeData, tender, stages, preStage, gatherType);
        }
        async _gatherStageChange(completeData, tender, stage, hasPre, gatherType = 'flow'){
            if (!stage) return [];
            const helper = this.ctx.helper;
            await this.ctx.service.stage.doCheckStage(stage);

            const curStageChange = await this.ctx.service.stageChange.getCurStageData(stage.tid, stage.id, stage.curTimes, stage.curOrder);
            const preStageChange = hasPre && stage.preCheckedStage ? await this.ctx.service.stageChangeFinal.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
            if (gatherType === 'flow') return [...preStageChange, ...curStageChange];

            const result = [];
            const findR = function(source) {
                let r = result.find(x => { return x.cbid === source.cbid});
                if (!r) {
                    r = { cid: source.cid, cbid: source.cbid, qty: 0, pre_qty: 0 };
                    result.push(r);
                }
                return r;
            };
            curStageChange.forEach(sc => {
                const r = findR(sc);
                r.qty = helper.add(r.qty, sc.qty);
            });
            preStageChange.forEach(sc => {
                const r = findR(sc);
                r.pre_qty = helper.add(r.pre_qty, sc.qty);
            });
            result.forEach(r => { r.end_qty = helper.add(r.pre_qty, r.qty); });
            return result;
        }
        async _gatherMonthStageChange(sTender, completeData, month, hasPre, gatherType) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {s_time: month});
            await this._gatherStageChange(completeData, tender, stage, hasPre, gatherType);
        }
        async _gatherOrderStageChange(sTender, completeData, order, hasPre, gatherType) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {order: order});
            await this._gatherStageChange(completeData, tender, stage, hasPre, gatherType);
        }
        async _gatherFinalStageChange(sTender, completeData, hasPre, gatherType) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            await this._gatherStageChange(completeData, tender, stages[0], hasPre, gatherType);
        }
        async _gatherCheckedFinalStageChange(sTender, completeData, hasPre, gatherType) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getCheckedStages(tender.id);
            await this._gatherStageChange(completeData, tender, stages[0], hasPre, gatherType);
        }
        async getGatherStageChange(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];
            const gsSetting = JSON.parse(gsDefine.setting);
            if (gsSetting.type !== 'stage') return [];

            this.resultStageChange = [];
            let commonIndex = 0;
            const completeDatas = [];
            for (const tender of gsCustom.tenders) {
                const completeData = { prefix: 't_' + commonIndex + '_' };
                completeDatas.push(completeData);
                switch (gsSetting.type) {
                    case 'month':
                        await this._gatherMonthStageChange(tender, completeData, gsCustom.month, gsSetting.hasPre, gsSetting.gather);
                        break;
                    case 'final':
                        await this._gatherFinalStageChange(tender, completeData, gsSetting.hasPre, gsSetting.gather);
                        break;
                    case 'checked-final':
                        await this._gatherCheckedFinalStageChange(tender, completeData, gsSetting.hasPre, gsSetting.gather);
                        break;
                    case 'stage':
                        await this._gatherOrderStageChange(tender, completeData, gsCustom.stage, gsSetting.hasPre, gsSetting.gather);
                        break;
                    case 'custom-zone':
                        await this._gatherCustomZoneStageChange(tender, completeData, gsCustom.custom_zone, gsSetting.timeType, gsSetting.gather);
                        break;
                }
                commonIndex++;
            }
            return this.resultStageChange;
        }

        async getGatherAdvancePay(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];

            const result = [];
            for (const t of gsCustom.tenders) {
                // const tender = await this.ctx.service.tender.getCheckTender(t.tid);
                const advance_pay = await this.ctx.service.advance.getAllDataByCondition({ where: { tid: t.tid } });
                result.push(...advance_pay);
            }
            return result;
        }

        async _gatherStageJgcl(tender, stage) {
            const data = await this.ctx.service.stageJgcl.getStageData(stage);
            const preData = stage.preCheckedStage ? await this.ctx.service.stageJgcl.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
            for (const d of data) {
                const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
                if (pd) {
                    d.pre_arrive_qty = pd.arrive_qty;
                    d.pre_arrive_tp = pd.arrive_tp;
                    d.pre_deduct_qty = pd.deduct_qty;
                    d.pre_deduct_tp = pd.deduct_tp;
                }
                d.end_arrive_qty = this.ctx.helper.add(d.pre_arrive_qty, d.arrive_qty);
                d.end_arrive_tp = this.ctx.helper.add(d.pre_arrive_tp, d.arrive_tp);
                d.end_deduct_qty = this.ctx.helper.add(d.pre_deduct_qty, d.deduct_qty);
                d.end_deduct_tp = this.ctx.helper.add(d.pre_deduct_tp, d.deduct_tp);
                d.tender_name = tender.name;
            }
            this.resultStageJgcl.push(...data);
        }
        async _gatherMonthStageJgcl(sTender, month) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {s_time: month});
            await this._gatherStageJgcl(tender, stage);
        }
        async _gatherOrderStageJgcl(sTender, order) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {order: order});
            await this._gatherStageJgcl(tender, stage);
        }
        async _gatherFinalStageJgcl(sTender) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            await this._gatherStageJgcl(tender, stages[0]);
        }
        async _gatherCheckedFinalStageJgcl(sTender) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getCheckedStages(tender.id);
            await this._gatherStageJgcl(tender, stages[0]);
        }
        async getGatherStageJgcl(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];

            this.resultStageJgcl = [];
            const gsSetting = JSON.parse(gsDefine.setting);
            for (const tender of gsCustom.tenders) {
                switch (gsSetting.type) {
                    case 'month':
                        await this._gatherMonthStageJgcl(tender, gsCustom.month);
                        break;
                    case 'final':
                        await this._gatherFinalStageJgcl(tender);
                        break;
                    case 'checked-final':
                        await this._gatherCheckedFinalStageJgcl(tender);
                        break;
                    case 'stage':
                        await this._gatherOrderStageJgcl(tender, gsCustom.stage);
                        break;
                }
            }

            return this.resultStageJgcl;
        }

        async _gatherStageBonus(tender, stage) {
            const data = await this.ctx.service.stageBonus.getEndStageData(tender.id, stage.order);
            for (const d of data) {
                const names = this.ctx.helper._.map(d.proof_file, function (x) {
                    return x.filename + x.fileext;
                });
                d.proof = names.join('\n');
                d.tender_name = tender.name;
            }
            this.resultStageBonus.push(...data);
        }
        async _gatherMonthStageBonus(sTender, month) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {s_time: month});
            await this._gatherStageBonus(tender, stage);
        }
        async _gatherOrderStageBonus(sTender, order) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {order: order});
            await this._gatherStageBonus(tender, stage);
        }
        async _gatherFinalStageBonus(sTender) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            await this._gatherStageBonus(tender, stages[0]);
        }
        async _gatherCheckedFinalStageBonus(sTender) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getCheckedStages(tender.id);
            await this._gatherStageBonus(tender, stages[0]);
        }
        async getGatherStageBonus(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];

            this.resultStageBonus = [];
            const gsSetting = JSON.parse(gsDefine.setting);
            for (const tender of gsCustom.tenders) {
                switch (gsSetting.type) {
                    case 'month':
                        await this._gatherMonthStageBonus(tender, gsCustom.month);
                        break;
                    case 'final':
                        await this._gatherFinalStageBonus(tender);
                        break;
                    case 'checked-final':
                        await this._gatherCheckedFinalStageBonus(tender);
                        break;
                    case 'stage':
                        await this._gatherOrderStageBonus(tender, gsCustom.stage);
                        break;
                }
            }
            return this.resultStageBonus;
        }

        async _gatherStageOther(tender, stage) {
            const data = await this.ctx.service.stageOther.getStageData(stage);
            const preData = stage.preCheckedStage ? await this.ctx.service.stageOther.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
            for (const d of data) {
                const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
                if (pd) {
                    d.pre_tp = pd.tp;
                }
                d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
                d.tender_name = tender.name;
            }
            this.resultStageOther.push(...data);
        }
        async _gatherMonthStageOther(sTender, month) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {s_time: month});
            await this._gatherStageOther(tender, stage);
        }
        async _gatherOrderStageOther(sTender, order) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {order: order});
            await this._gatherStageOther(tender, stage);
        }
        async _gatherFinalStageOther(sTender) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            await this._gatherStageOther(tender, stages[0]);
        }
        async _gatherCheckedFinalStageOther(sTender) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getCheckedStages(tender.id);
            await this._gatherStageOther(tender, stages[0]);
        }
        async getGatherStageOther(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];

            this.resultStageOther = [];
            const gsSetting = JSON.parse(gsDefine.setting);
            for (const tender of gsCustom.tenders) {
                switch (gsSetting.type) {
                    case 'month':
                        await this._gatherMonthStageOther(tender, gsCustom.month);
                        break;
                    case 'final':
                        await this._gatherFinalStageOther(tender);
                        break;
                    case 'checked-final':
                        await this._gatherCheckedFinalStageOther(tender);
                        break;
                    case 'stage':
                        await this._gatherOrderStageOther(tender, gsCustom.stage);
                        break;
                }
            }
            return this.resultStageOther;
        }

        async _gatherStageSafeProd(tender, stage) {
            const data = await this.ctx.service.stageSafeProd.getStageData(stage);
            const preData = stage.preCheckedStage ? await this.ctx.service.stageSafeProd.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
            for (const d of data) {
                const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
                if (pd) {
                    d.pre_qty = pd.qty;
                    d.pre_tp = pd.tp;
                }
                d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
                d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
            }
            const helper = this.ctx.helper;
            for (const d of data) {
                let gd = this.resultStageSafeProd.find(x => {
                    return x.name === d.name && x.unit === d.unit && helper.numEqual(x.unit_price, d.unit_price);
                });
                if (!gd) {
                    gd = { name: d.name, unit: d.unit, unit_price: d.unit_price };
                    this.resultStageSafeProd.push(gd);
                }
                gd.s_quantity = helper.add(gd.s_quantity, d.quantity);
                gd.s_total_price = helper.add(gd.s_total_price, d.total_price);
                gd.s_qty = helper.add(gd.s_qty, d.qty);
                gd.s_tp = helper.add(gd.s_tp, d.tp);
                gd.s_pre_qty = helper.add(gd.s_pre_qty, d.pre_qty);
                gd.s_pre_tp = helper.add(gd.s_pre_tp, d.pre_tp);
                gd.s_end_qty = helper.add(gd.s_end_qty, d.end_qty);
                gd.s_end_tp = helper.add(gd.s_end_tp, d.end_tp);
            }
        }
        async _gatherMonthStageSafeProd(sTender, month) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {s_time: month});
            await this._gatherStageSafeProd(tender, stage);
        }
        async _gatherOrderStageSafeProd(sTender, order) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {order: order});
            await this._gatherStageSafeProd(tender, stage);
        }
        async _gatherFinalStageSafeProd(sTender) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            await this._gatherStageSafeProd(tender, stages[0]);
        }
        async _gatherCheckedFinalStageSafeProd(sTender) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getCheckedStages(tender.id);
            await this._gatherStageSafeProd(tender, stages[0]);
        }
        async getGatherStageSafeProd(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];

            this.resultStageSafeProd = [];
            const gsSetting = JSON.parse(gsDefine.setting);
            for (const tender of gsCustom.tenders) {
                switch (gsSetting.type) {
                    case 'month':
                        await this._gatherMonthStageSafeProd(tender, gsCustom.month);
                        break;
                    case 'final':
                        await this._gatherFinalStageSafeProd(tender);
                        break;
                    case 'checked-final':
                        await this._gatherCheckedFinalStageSafeProd(tender);
                        break;
                    case 'stage':
                        await this._gatherOrderStageSafeProd(tender, gsCustom.stage);
                        break;
                }
            }

            return this.resultStageSafeProd;
        }

        async _gatherStageTempLand(tender, stage) {
            const data = await this.ctx.service.stageTempLand.getStageData(stage);
            const preData = stage.preCheckedStage ? await this.ctx.service.stageTempLand.getEndStageData(stage.tid, stage.preCheckedStage.order) : [];
            for (const d of data) {
                const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
                if (pd) {
                    d.pre_qty = pd.qty;
                    d.pre_tp = pd.tp;
                }
                d.end_qty = this.ctx.helper.add(d.pre_qty, d.qty);
                d.end_tp = this.ctx.helper.add(d.pre_tp, d.tp);
            }

            const helper = this.ctx.helper;
            for (const d of data) {
                let gd = this.resultStageTempLand.find(x => {
                    return x.name === d.name && x.unit === d.unit && helper.numEqual(x.unit_price, d.unit_price);
                });
                if (!gd) {
                    gd = { name: d.name, unit: d.unit, unit_price: d.unit_price };
                    this.resultStageTempLand.push(gd);
                }
                gd.s_qty = helper.add(gd.s_qty, d.qty);
                gd.s_tp = helper.add(gd.s_tp, d.tp);
                gd.s_pre_qty = helper.add(gd.s_pre_qty, d.pre_qty);
                gd.s_pre_tp = helper.add(gd.s_pre_tp, d.pre_tp);
                gd.s_end_qty = helper.add(gd.s_end_qty, d.end_qty);
                gd.s_end_tp = helper.add(gd.s_end_tp, d.end_tp);
            }
        }
        async _gatherMonthStageTempLand(sTender, month) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {s_time: month});
            await this._gatherStageTempLand(tender, stage);
        }
        async _gatherOrderStageTempLand(sTender, order) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            const stage = this.ctx.helper._.find(stages, {order: order});
            await this._gatherStageTempLand(tender, stage);
        }
        async _gatherFinalStageTempLand(sTender) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getValidStages(tender.id);
            await this._gatherStageTempLand(tender, stages[0]);
        }
        async _gatherCheckedFinalStageTempLand(sTender) {
            const tender = await this.ctx.service.tender.getCheckTender(sTender.tid);
            const stages = await this._getCheckedStages(tender.id);
            await this._gatherStageTempLand(tender, stages[0]);
        }
        async getGatherStageTempLand(memFieldKeys, gsDefine, gsCustom) {
            if (!gsDefine || !gsDefine.enable) return [];
            if (!gsCustom || !gsCustom.tenders || gsCustom.tenders.length === 0) return [];

            this.resultStageTempLand = [];
            const gsSetting = JSON.parse(gsDefine.setting);
            for (const tender of gsCustom.tenders) {
                switch (gsSetting.type) {
                    case 'month':
                        await this._gatherMonthStageTempLand(tender, gsCustom.month);
                        break;
                    case 'final':
                        await this._gatherFinalStageTempLand(tender);
                        break;
                    case 'checked-final':
                        await this._gatherCheckedFinalStageTempLand(tender);
                        break;
                    case 'stage':
                        await this._gatherOrderStageTempLand(tender, gsCustom.stage);
                        break;
                }
            }

            return this.resultStageTempLand;
        }
    }

    return RptGatherMemory;
};