Calculation/app/service/report_memory.js

'use strict';

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

const _ = require('lodash');

const StageIm = require('../lib/stage_im');
const imType = require('../const/tender').imType;
const audit = require('../const/audit');
const changeConst = require('../const/change');
const materialConst = require('../const/material');
// const path = require('path');
// const fs = require('fs');

const stageImTz = 'mem_stage_im_tz';
const stageImTzBills = 'mem_stage_im_tz_bills';
const stageImZl = 'mem_stage_im_zl';
const stageImVersion = '1.3';

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

const billsFields = (function () {
    const cur = ['contract_qty', 'contract_tp', 'contract_expr', 'qc_qty', 'qc_tp', 'gather_qty', 'gather_tp', 'postil'];
    const pre = ['pre_contract_qty', 'pre_contract_tp', 'pre_qc_qty', 'pre_qc_tp', 'pre_gather_qty', 'pre_gather_tp'];
    const end = ['end_contract_qty', 'end_contract_tp', 'end_qc_qty', 'end_qc_tp', 'end_gather_qty', 'end_gather_tp'];
    const final = ['final_tp', 'final_ratio'];
    const stageDgn = ['deal_dgn_qty1', 'deal_dgn_qty2', 'c_dgn_qty1', 'c_dgn_qty2'];

    const stage = cur.concat(pre, end, final);
    const stageEnd = pre.concat(end, final);
    const bgl = ['qc_bgl_code'];
    const leafXmj = ['leaf_xmj_id'];

    return {cur, pre, end, final, stageDgn, stage, stageEnd, bgl, leafXmj};
})();
const posFields = (function () {
    const cur = ['contract_qty', 'qc_qty', 'gather_qty', 'postil'];
    const pre = ['pre_contract_qty', 'pre_qc_qty', 'pre_gather_qty'];
    const end = ['end_contract_qty', 'end_qc_qty', 'end_gather_qty'];
    const final = ['final_ratio'];

    const stage = cur.concat(pre, end, final);
    const stageEnd = pre.concat(end, final);
    const bgl = ['qc_bgl_code'];

    return {cur, pre, end, final, stage, stageEnd, bgl};
})();

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

        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局context
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            const self = this;
            this.tableName = 'report_memory';
            // 基础数据类
            // mainData
            this.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', 'pre_contract_tp', 'pre_qc_tp', 'pre_gather_tp'],
                calc: function (node) {
                    if (node.children && node.children.length === 0) {
                        node.pre_gather_qty = self.ctx.helper.add(node.pre_contract_qty, node.pre_qc_qty);
                        node.gather_qty = self.ctx.helper.add(node.contract_qty, node.qc_qty);
                        node.end_contract_qty = self.ctx.helper.add(node.pre_contract_qty, node.contract_qty);
                        node.end_qc_qty = self.ctx.helper.add(node.pre_qc_qty, node.qc_qty);
                        node.end_gather_qty = self.ctx.helper.add(node.pre_gather_qty, node.gather_qty);
                    }
                    node.pre_gather_tp = self.ctx.helper.add(node.pre_contract_tp, node.pre_qc_tp);
                    node.gather_tp = self.ctx.helper.add(node.contract_tp, node.qc_tp);
                    node.end_contract_tp = self.ctx.helper.add(node.pre_contract_tp, node.contract_tp);
                    node.end_qc_tp = self.ctx.helper.add(node.pre_qc_tp, node.qc_tp);
                    node.end_gather_tp = self.ctx.helper.add(node.pre_gather_tp, node.gather_tp);

                    node.final_tp = self.ctx.helper.add(node.total_price, node.end_qc_tp);
                    node.final_ratio = self.ctx.helper.mul(self.ctx.helper.div(node.end_gather_tp, node.final_tp, 4), 100);
                }
            });
            this.pos = new Ledger.pos({
                id: 'id', ledgerId: 'lid',
                updateFields: ['contract_qty', 'qc_qty', 'postil'],
                calc: function (p) {
                    p.pre_gather_qty = ctx.helper.add(p.pre_contract_qty, p.pre_qc_qty);
                    p.gather_qty = ctx.helper.add(p.contract_qty, p.qc_qty);
                    p.end_contract_qty = self.ctx.helper.add(p.pre_contract_qty, p.contract_qty);
                    p.end_qc_qty = self.ctx.helper.add(p.pre_qc_qty, p.qc_qty);
                    p.end_gather_qty = self.ctx.helper.add(p.pre_gather_qty, p.gather_qty);
                }
            });
            // 需要缓存的数据
            this.stageImData = null;
            this.changeData = null;
            this.stageValidRole = [];
        }

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

        // build-time: 162-384ms, redis-cache: 0-41ms, mysql + IO: 116-146ms
        // 一定程度上算是大Value缓存，数据多了以后：
        // 1. 达到redis内存阈值时，数据会swap到磁盘，此时将消耗IO时间
        // 2. redis单独服务器
        // 3. redis集群
        async _getReportMemoryCache(name, tid, sid, time, version = '') {
            // redis
            const cacheKey = name + '-t' + tid + (sid ? '-s' + sid : '') + (time ? '-' + time : '') + version;
            const data = await this.cache.get(cacheKey);
            if (data) {
                return eval(data);
            } else {
                return null;
            }

            // mysql + IO
            // const rm = await this.getDataByCondition({
            //     tid: tid, sid: sid, name: name, time: time
            // });
            // if (rm && rm.file) {
            //     const file = path.join(this.ctx.app.config.filePath, 'report', 'cache', rm.file);
            //     if (fs.existsSync(file)) {
            //         const data = await fs.readFileSync(file, 'utf8');
            //         return eval(data);
            //     } else {
            //         return null;
            //     }
            // }
        }

        async _setReportMemoryCache(name, tid, sid, time, data, version = '') {
            // redis
            const cacheKey = name + '-t' + tid + (sid ? '-s' + sid : '') + (time ? '-' + time : '') + version;
            this.cache.set(cacheKey, JSON.stringify(data), 'EX', this.ctx.app.config.cacheTime);

            // mysql + IO
            // const file = path.join('report', 'cache', 'rm' + (new Date()).getTime() + '.json');
            // await this.ctx.helper.saveBufferFile(JSON.stringify(data), path.join(this.ctx.app.config.filePath, file));
            // const rm = await this.getDataByCondition({
            //     tid: tid, sid: sid, name: name, time: time
            // });
            // if (rm) {
            //     await this.db.update(this.tableName, {id: rm.id, file: file});
            // } else {
            //     await this.db.insert(this.tableName, {tid: tid, sid: sid, name: name, time: time, file: file});
            // }
        }

        async _generateStageIm(tid, sid, isTz = true) {
            if (isTz && [imType.tz.value, imType.bb.value].indexOf(this.ctx.stage.im_type) === -1) {
                throw '您查看的报表跟设置不符，请查看“总量控制”的报表';
            } else if (!isTz && [imType.zl.value, imType.bw.value].indexOf(this.ctx.stage.im_type) === -1) {
                throw '您查看的报表跟设置不符，请查看“0号台账”的报表';
            }
            const stageIm = new StageIm(this.ctx);
            await stageIm.buildImData();
            this.stageImData.main = stageIm.ImData;
            if (isTz) {
                this.stageImData.bills = stageIm.ImBillsData;
                await this._setReportMemoryCache(stageImTz, tid, sid, this.ctx.stage.cacheTime, this.stageImData.main, stageImVersion);
                await this._setReportMemoryCache(stageImTzBills, tid, sid, this.ctx.stage.cacheTime, this.stageImData.bills, stageImVersion);
            } else {
                await this._setReportMemoryCache(stageImZl, tid, sid, this.ctx.stage.cacheTime, this.stageImData.main, stageImVersion);
            }
        }

        async getStageImTzData(tid, sid, fields, readCache = true) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                await this.ctx.service.stage.checkStage(sid);
                if (readCache) {
                    const cache = await this._getReportMemoryCache('mem_stage_im_tz', tid, sid, this.ctx.stage.cacheTime, stageImVersion);
                    if (cache) return cache;
                }

                if (!this.stageImData) {
                    this.stageImData = {};
                    try {
                        await this._generateStageIm(tid, sid);
                    } catch (err) {
                        if (err.stack) {
                            this.ctx.logger.error(err);
                        }
                        this.stageImData.main = err.stack ? '数据错误' : err;
                        this.stageImData.bills = this.stageImData.main;
                    }
                }
                return this.stageImData.main;
            } catch (err) {
                return [];
            }
        }

        async getStageImTzBillsData(tid, sid, fields, readCache = true) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                await this.ctx.service.stage.checkStage(sid);
                if (readCache) {
                    const cache = await this._getReportMemoryCache('mem_stage_im_tz_bills', tid, sid, this.ctx.stage.cacheTime, stageImVersion);
                    if (cache) return cache;
                }

                if (!this.stageImData) {
                    this.stageImData = {};
                    try {
                        await this._generateStageIm(tid, sid);
                    } catch (err) {
                        if (err.stack) {
                            this.ctx.logger.error(err);
                        }
                        this.stageImData.main = err.stack ? '数据错误' : err;
                        this.stageImData.bills = this.stageImData.main;
                    }
                }
                return this.stageImData.bills;
            } catch (err) {
                return [];
            }
        }

        async getStageImZlData(tid, sid, fields, readCache = true) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                await this.ctx.service.stage.checkStage(sid);
                if (readCache) {
                    const cache = await this._getReportMemoryCache('mem_stage_im_zl', tid, sid, this.ctx.stage.cacheTime, stageImVersion);
                    if (cache) return cache;
                }

                this.stageImData = {};
                try {
                    await this._generateStageIm(tid, sid, false);
                } catch (err) {
                    if (err.stack) {
                        this.ctx.logger.error(err);
                    }
                    this.stageImData.main = err.statck ? '数据错误' : err;
                }
                return this.stageImData.main;
            } catch (err) {
                return [];
            }
        }

        async getMonthProgress(tid, fields) {
            const helper = this.ctx.helper;
            await this.ctx.service.tender.checkTender(tid);
            const tender = this.ctx.tender;

            const stages = await this.ctx.service.stage.getValidStages(tender.id);
            const lastStage = stages.length > 0 ? stages[0] : null;
            if (lastStage) {
                await this.ctx.service.stage.checkStageGatherData(lastStage);
                tender.gather_tp = helper.add(lastStage.contract_tp, lastStage.qc_tp);
                tender.end_contract_tp = helper.add(lastStage.contract_tp, lastStage.pre_contract_tp);
                tender.end_qc_tp = helper.add(lastStage.qc_tp, lastStage.pre_qc_tp);
                tender.end_gather_tp = helper.add(tender.end_contract_tp, tender.end_qc_tp);
                tender.pre_gather_tp = helper.add(lastStage.pre_contract_tp, lastStage.pre_qc_tp);
                tender.yf_tp = lastStage.yf_tp;
                tender.qc_ratio = helper.mul(helper.div(tender.end_qc_tp, tender.info.deal_param.contractPrice, 2), 100);
                tender.sum = helper.add(tender.total_price, tender.end_qc_tp);
                tender.pre_ratio = helper.mul(helper.div(tender.pre_gather_tp, tender.sum, 2), 100);
                tender.cur_ratio = helper.mul(helper.div(tender.gather_tp, tender.sum, 2), 100);
                tender.other_tp = helper.sub(helper.sub(tender.sum, tender.pre_gather_tp), tender.gather_tp);
                tender.other_ratio = Math.max(0, 100 - tender.pre_ratio - tender.cur_ratio);
            }
            const monthProgress = [];
            for (const s of stages) {
                if (s.s_time) {
                    let progress = monthProgress.find(function (x) {
                        return x.month === s.s_time;
                    });
                    if (!progress) {
                        progress = {month: s.s_time};
                        monthProgress.push(progress);
                    }
                    progress.tp = helper.add(helper.add(progress.tp, s.contract_tp), s.qc_tp);
                }
            }
            monthProgress.sort(function (x, y) {
                return Date.parse(x.month) - Date.parse(y.month);
            });
            let sum = 0;
            for (const p of monthProgress) {
                p.ratio = helper.mul(helper.div(p.tp, tender.sum, 4), 100);
                sum = helper.add(sum, p.tp);
                p.end_tp = sum;
                p.end_ratio = helper.mul(helper.div(p.end_tp, tender.sum, 4), 100);
            }
            return monthProgress;
        }

        async _calcBillsBgl() {
            if (!this.ctx.stage) return;

            const helper = this.ctx.helper;
            const tender = this.ctx.tender;
            const stage = this.ctx.stage;
            const bglData = this.ctx.stage.readOnly
                ? await this.ctx.service.stageChange.getAuditorAllStageData(tender.id, stage.id, stage.curTimes, stage.curOrder)
                : await this.ctx.service.stageChange.getLastestAllStageData(tender.id, stage.id);

            for (const node of this.billsTree.nodes) {
                node.qc_bgl_code = '';
                if (node.children && node.children.length > 0) continue;

                const nodeBgl = helper._.filter(bglData, {lid: node.id});
                if (nodeBgl.length === 0) continue;
                helper._.pullAll(bglData, nodeBgl);
                const validBgl = helper._.filter(nodeBgl, function (x) {
                    return !helper.checkZero(x.qty);
                });
                node.qc_bgl_code = helper._.uniq(helper._.map(validBgl, 'c_code')).join(';');
            }
        }

        _calcLeafXmjRela() {
            for (const node of this.billsTree.nodes) {
                if (node.b_code) {
                    const leafXmj = this.billsTree.getLeafXmjParent(node);
                    node.leaf_xmj_id = leafXmj ? leafXmj.id : -1;
                }
            }
        }

        async getStageBillsData(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                if (sid) {
                    await this.ctx.service.stage.checkStage(sid);
                }

                const billsData = await this.ctx.service.ledger.getData(this.ctx.tender.id);
                if (this._checkFieldsExist(fields, billsFields.stageDgn)) {
                    const dgnData = await this.ctx.service.stageBillsDgn.getDgnData(this.ctx.tender.id);
                    for (const d of dgnData) {
                        const l = this.ctx.helper._.find(billsData, {id: d.id});
                        this.ctx.helper._.assignIn(l, d);
                    }
                }
                if (this._checkFieldsExist(fields, billsFields.stage)) {
                    if (this.ctx.stage.readOnly) {
                        const curStage = await this.ctx.service.stageBills.getAuditorStageData(this.ctx.tender.id,
                            this.ctx.stage.id, this.ctx.stage.curTimes, this.ctx.stage.curOrder);
                        this.ctx.helper.assignRelaData(billsData, [
                            {data: curStage, fields: ['contract_qty', 'contract_tp', 'contract_expr', 'qc_qty', 'qc_tp', 'postil'], prefix: '', relaId: 'lid'}
                        ]);
                    } else {
                        const curStage = await this.ctx.service.stageBills.getLastestStageData(this.ctx.tender.id, this.ctx.stage.id);
                        this.ctx.helper.assignRelaData(billsData, [
                            {data: curStage, fields: ['contract_qty', 'contract_tp', 'contract_expr', 'qc_qty', 'qc_tp', 'postil'], prefix: '', relaId: 'lid'}
                        ]);
                    }
                }
                if (this._checkFieldsExist(fields, billsFields.stageEnd)) {
                    const preStage = this.ctx.stage.order > 1 ? await this.ctx.service.stageBillsFinal.getFinalData(this.ctx.tender, this.ctx.stage.order - 1) : [];
                    this.ctx.helper.assignRelaData(billsData, [
                        {data: preStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: 'pre_', relaId: 'lid'}
                    ]);
                }

                this.billsTree.loadDatas(billsData);
                this.billsTree.setting.calcFields = ['deal_tp', 'total_price', 'contract_tp', 'qc_tp', 'gather_tp', 'pre_contract_tp', 'pre_qc_tp', 'pre_gather_tp'];
                this.billsTree.calculateAll();

                if (this._checkFieldsExist(fields, billsFields.bgl)) {
                    await this._calcBillsBgl();
                }

                if (this._checkFieldsExist(fields, billsFields.leafXmj)) {
                    this._calcLeafXmjRela();
                }

                return this.billsTree.getDatas([
                    'id', 'tender_id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf',
                    'code', 'b_code', 'name', 'unit', 'unit_price',
                    'deal_qty', 'deal_tp',
                    'sgfh_qty', 'sgfh_tp', 'sjcl_qty', 'sjcl_tp', 'qtcl_qty', 'qtcl_tp', 'quantity', 'total_price',
                    'dgn_qty1', 'dgn_qty2',
                    'drawing_code', 'memo', 'node_type', 'is_tp',
                    'contract_qty', 'contract_tp', 'qc_qty', 'qc_tp', 'gather_qty', 'gather_tp', 'postil',
                    'pre_contract_qty', 'pre_contract_tp', 'pre_qc_qty', 'pre_qc_tp', 'pre_gather_qty', 'pre_gather_tp',
                    'end_contract_qty', 'end_contract_tp', 'end_qc_qty', 'end_qc_tp', 'end_gather_qty', 'end_gather_tp',
                    'final_tp', 'final_ratio',
                    'qc_bgl_code',
                    'chapter',
                    'leaf_xmj_id',
                    'sgfh_expr', 'sjcl_expr', 'qtcl_expr', 'contract_expr',
                    'deal_dgn_qty1', 'deal_dgn_qty2', 'c_dgn_qty1', 'c_dgn_qty2',
                ]);
            } catch(err) {
                return []
            }
        }

        async _calcPosBgl() {
            if (!this.ctx.stage) return;

            const helper = this.ctx.helper;
            const tender = this.ctx.tender;
            const stage = this.ctx.stage;
            const bglData = this.ctx.stage.readOnly
                ? await this.ctx.service.stageChange.getAuditorAllStageData(tender.id, stage.id, stage.curTimes, stage.curOrder)
                : await this.ctx.service.stageChange.getLastestAllStageData(tender.id, stage.id);

            for (const p of this.pos.datas) {
                p.qc_bgl_code = '';

                const pBgl = helper._.filter(bglData, {lid: p.lid, pid: p.id});
                if (pBgl.length === 0) continue;
                helper._.pullAll(bglData, pBgl);
                const validBgl = helper._.filter(pBgl, function (x) {
                    return !helper.checkZero(x.qty);
                });
                p.qc_bgl_code = helper._.uniq(helper._.map(validBgl, 'c_code')).join(';');
            }
        }

        async getStagePosData(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                if (sid) {
                    await this.ctx.service.stage.checkStage(sid);
                }

                const posData = await this.ctx.service.pos.getAllDataByCondition({ where: {tid: this.ctx.tender.id }});
                if (this._checkFieldsExist(fields, posFields.stage)) {
                    if (this.ctx.stage.readOnly) {
                        const curPosStage = await this.ctx.service.stagePos.getAuditorStageData2(this.ctx.tender.id,
                            this.ctx.stage.id, this.ctx.stage.curTimes, this.ctx.stage.curOrder);
                        this.ctx.helper.assignRelaData(posData, [
                            {data: curPosStage, fields: ['contract_qty', 'qc_qty', 'contract_expr', 'postil'], prefix: '', relaId: 'pid'}
                        ]);
                    } else {
                        const curPosStage = await this.ctx.service.stagePos.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id);
                        this.ctx.helper.assignRelaData(posData, [
                            {data: curPosStage, fields: ['contract_qty', 'qc_qty', 'contract_expr', 'postil'], prefix: '', relaId: 'pid'}
                        ]);
                    }
                }
                if (this._checkFieldsExist(fields, posFields.stageEnd)) {
                    const prePosStage = this.ctx.stage.order > 1 ? await this.ctx.service.stagePosFinal.getFinalData(this.ctx.tender, this.ctx.stage.order - 1) : [];
                    this.ctx.helper.assignRelaData(posData, [
                        {data: prePosStage, fields: ['contract_qty', 'qc_qty'], prefix: 'pre_', relaId: 'pid'}
                    ]);
                }
                this.pos.loadDatas(posData);
                this.pos.calculateAll();

                if (this._checkFieldsExist(fields, posFields.bgl)) {
                    await this._calcPosBgl();
                }

                return this.pos.getDatas();
            } catch (err) {
                return [];
            }
        }

        _getStageValidRole () {
            if (!this.ctx.stage) throw '期数据错误，请重试';
            if (this.stageValidRole && this.stageValidRole.length > 0) return;

            const result = [{dataOrder: 0, flowOrder: 0, uid: this.ctx.stage.user_id}];
            for (const auditor of this.ctx.stage.auditors) {
                if (auditor.status === audit.stage.status.checked ||
                    (auditor.status === audit.stage.status.checking && !this.ctx.stage.readOnly)) {
                    const role = result.find(function (r) {
                        return r.uid === auditor.aid;
                    });
                    if (role) {
                        role.dataOrder = auditor.order;
                    } else {
                        result.push({
                            dataOrder: auditor.order,
                            flowOrder: result.length,
                            uid: auditor.aid
                        })
                    }
                }
            }
            this.stageValidRole = result;
        };

        async getStageBillsCompareData(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                await this.ctx.service.stage.checkStage(sid);
                await this._getStageValidRole();

                const stage = this.ctx.stage, helper = this.ctx.helper;
                const validRole = this.stageValidRole;
                const billsData = await this.ctx.service.ledger.getData(this.ctx.tender.id);
                const allStageBills = await this.ctx.service.stageBills.getAllDataByCondition({where: {sid: sid}});

                const stageBillsIndex = {}, timesLen = 100;
                for (const role of validRole) {
                    const stageBills = this.ctx.helper._.filter(allStageBills, function (x) {
                        return x.times < stage.curTimes || (x.times === stage.curTimes && x.order <= role.dataOrder);
                    });
                    this.ctx.helper._.pullAll(allStageBills, stageBills);
                    for (const sb of stageBills) {
                        const key = 'sb-' + sb.lid;
                        const sbi = stageBillsIndex[key];
                        if (sbi) {
                            if ((sbi.times * timesLen + sbi.order) < (sb.times * timesLen + sb.order)) stageBillsIndex[key] = sb;
                        } else {
                            stageBillsIndex[key] = sb;
                        }
                    }
                    const filterStageBills = [];
                    for (const prop in stageBillsIndex) {
                        filterStageBills.push(stageBillsIndex[prop]);
                    }
                    this.ctx.helper.assignRelaData(billsData, [
                        {data: filterStageBills, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: 'r' + role.flowOrder + '_', relaId: 'lid'}
                    ]);
                }

                if (this._checkFieldsExist(fields, billsFields.stageEnd)) {
                    const preStage = this.ctx.stage.order > 1 ? await this.ctx.service.stageBillsFinal.getFinalData(this.ctx.tender, this.ctx.stage.order - 1) : [];
                    this.ctx.helper.assignRelaData(billsData, [
                        {data: preStage, fields: ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], prefix: 'pre_', relaId: 'lid'}
                    ]);
                }
                this.billsTree.loadDatas(billsData);

                this.billsTree.setting.calcFields = ['deal_tp', 'total_price', 'pre_contract_tp', 'pre_qc_tp', 'pre_gather_tp'];
                for (const role of validRole) {
                    const prefix = 'r' + role.flowOrder + '_';
                    this.billsTree.setting.calcFields.push(prefix + 'contract_tp', prefix + 'qc_tp', prefix + 'gather_tp');
                }

                this.billsTree.calculateAll(function(node) {
                    let prefix = '';
                    if (node.children && node.children.length === 0) {
                        node.pre_gather_qty = helper.add(node.pre_contract_qty, node.pre_qc_qty);
                        for (const role of validRole) {
                            prefix = 'r' + role.flowOrder + '_';
                            node[prefix + 'gather_qty'] = helper.add(node[prefix + 'contract_qty'], node[prefix + 'qc_qty']);
                        }
                    }
                    node.pre_gather_tp = helper.add(node.pre_contract_tp, node.pre_qc_tp);
                    for (const role of validRole) {
                        prefix = 'r' + role.flowOrder + '_';
                        node[prefix + 'gather_tp'] = helper.add(node[prefix + 'contract_tp'], node[prefix + 'qc_tp']);
                    }
                });

                if (this._checkFieldsExist(fields, billsFields.leafXmj)) {
                    this._calcLeafXmjRela();
                }

                return this.billsTree.getDefaultDatas();
                // return this.billsTree.getDatas([
                //     'id', 'tender_id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf',                 //8
                //     'code', 'b_code', 'name', 'unit', 'unit_price',                                                         //5
                //     'deal_qty', 'deal_tp', 'quantity', 'total_price', 'dgn_qty1', 'dgn_qty2',                               //6
                //     'drawing_code', 'memo', 'node_type', 'is_tp',                                                           //4
                //     'r0_contract_qty', 'r0_contract_tp', 'r0_qc_qty', 'r0_qc_tp', 'r0_gather_qty', 'r0_gather_tp',          //6
                //     'r1_contract_qty', 'r1_contract_tp', 'r1_qc_qty', 'r1_qc_tp', 'r1_gather_qty', 'r1_gather_tp',
                //     'r2_contract_qty', 'r2_contract_tp', 'r2_qc_qty', 'r2_qc_tp', 'r2_gather_qty', 'r2_gather_tp',
                //     'r3_contract_qty', 'r3_contract_tp', 'r3_qc_qty', 'r3_qc_tp', 'r3_gather_qty', 'r3_gather_tp',
                //     'r4_contract_qty', 'r4_contract_tp', 'r4_qc_qty', 'r4_qc_tp', 'r4_gather_qty', 'r4_gather_tp',
                //     'r5_contract_qty', 'r5_contract_tp', 'r5_qc_qty', 'r5_qc_tp', 'r5_gather_qty', 'r5_gather_tp',
                //     'r6_contract_qty', 'r6_contract_tp', 'r6_qc_qty', 'r6_qc_tp', 'r6_gather_qty', 'r6_gather_tp',
                //     'r7_contract_qty', 'r7_contract_tp', 'r7_qc_qty', 'r7_qc_tp', 'r7_gather_qty', 'r7_gather_tp',
                //     'r8_contract_qty', 'r8_contract_tp', 'r8_qc_qty', 'r8_qc_tp', 'r8_gather_qty', 'r8_gather_tp',
                //     'r9_contract_qty', 'r9_contract_tp', 'r9_qc_qty', 'r9_qc_tp', 'r9_gather_qty', 'r9_gather_tp',
                //     'r10_contract_qty', 'r10_contract_tp', 'r10_qc_qty', 'r10_qc_tp', 'r10_gather_qty', 'r10_gather_tp',
                //     'pre_contract_qty', 'pre_contract_tp', 'pre_qc_qty', 'pre_qc_tp', 'pre_gather_qty', 'pre_gather_tp',
                //     'chapter',                                                                                              //1
                // ]);
            } catch (err) {
                return [];
            }
        }

        async getStagePosCompareData(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                await this.ctx.service.stage.checkStage(sid);
                await this._getStageValidRole();

                const stage = this.ctx.stage, helper = this.ctx.helper;
                const validRole = this.stageValidRole;

                const allStagePos = await this.ctx.service.stagePos.getAllDataByCondition({where: {sid: sid}});
                const posData = await this.ctx.service.pos.getAllDataByCondition({ where: {tid: this.ctx.tender.id }});
                const prePosStage = this.ctx.stage.order > 1 ? await this.ctx.service.stagePosFinal.getFinalData(this.ctx.tender, this.ctx.stage.order - 1) : [];
                this.ctx.helper.assignRelaData(posData, [
                    {data: prePosStage, fields: ['contract_qty', 'qc_qty'], prefix: 'pre_', relaId: 'pid'}
                ]);
                const stagePosIndex = {}, timesLen = 100;
                for (const role of validRole) {
                    const stagePos = this.ctx.helper._.filter(allStagePos, function (x) {
                        return x.times < stage.curTimes || (x.times === stage.curTimes && x.order <= role.dataOrder);
                    });
                    this.ctx.helper._.pullAll(allStagePos, stagePos);
                    for (const sp of stagePos) {
                        const key = 'sp-' + sp.pid;
                        const spi = stagePosIndex[key];
                        if (spi) {
                            if ((spi.times * timesLen + spi.order) < (sp.times * timesLen + sp.order)) stagePosIndex[key] = sp;
                        } else {
                            stagePosIndex[key] = sp;
                        }
                    }
                    const filterStagePos = [];
                    for (const prop in stagePosIndex) {
                        filterStagePos.push(stagePosIndex[prop]);
                    }
                    this.ctx.helper.assignRelaData(posData, [
                        {data: filterStagePos, fields: ['contract_qty', 'qc_qty'], prefix: 'r' + role.flowOrder + '_', relaId: 'pid'}
                    ]);
                }
                this.pos.loadDatas(posData);
                this.pos.calculateAll(function (p) {
                    p.pre_gather_qty = helper.add(p.pre_contract_qty, p.pre_qc_qty);
                    for (const role of validRole) {
                        const prefix = 'r' + role.flowOrder + '_';
                        p[prefix + 'gather_qty'] = helper.add(p[prefix + 'contract_qty'], p[prefix + 'qc_qty']);
                    }

                });

                return this.pos.getDatas();
            } catch (err) {
                return [];
            }
        }

        async getStagePayData(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                await this.ctx.service.stage.checkStage(sid);
                const stage = this.ctx.stage;

                const dealPay = await this.ctx.service.stagePay.getStagePays(this.ctx.stage);

                if (!this.ctx.stage.readOnly) {
                    // 计算 本期金额
                    const PayCalculator = require('../lib/pay_calc');
                    const payCalculator = new PayCalculator(this.ctx, this.ctx.stage, this.ctx.tender.info);
                    await payCalculator.calculateAll(dealPay);
                }
                if (this._checkFieldsExist(fields, ['start_stage_order']) && this.ctx.stage.status !== audit.stage.status.checked) {
                    for (const dp of dealPay) {
                        if (!dp.start_stage_order || dp.start_stage_order === this.ctx.stage.order) {
                            dp.start_stage_order = this.ctx.helper.checkZero(dp.tp) ? null : this.ctx.stage.order;
                        }
                    }
                }

                if (this._checkFieldsExistReg(fields, 'r[0-9]+_tp')) {
                    this._getStageValidRole();
                    const allStagePays = await this.ctx.service.stagePay.getAllDataByCondition({
                        where: {sid: stage.id, stimes: stage.curTimes}
                    });

                    for (const [i, role] of this.stageValidRole.entries()) {
                        if (i < this.stageValidRole.length - 1) {
                            const stagePays = this.ctx.helper._.filter(allStagePays, function (x) {
                                return x.stimes === stage.curTimes && x.sorder === role.dataOrder;
                            });
                            this.ctx.helper._.pullAll(allStagePays, stagePays);

                            for (const sp of stagePays) {
                                const dp = dealPay.find(function (x) {return x.pid === sp.pid});
                                if (dp) {
                                    dp['r' + role.flowOrder + '_tp'] = sp.tp;
                                }
                            }
                        } else {
                            for (const dp of dealPay) {
                                dp['r' + role.flowOrder + '_tp'] = dp.tp;
                            }
                        }
                    }
                }
                return dealPay;
            } catch (err) {
                return [];
            }
        }

        _getChangeConstName(define, value) {
            for (const prop in define) {
                if (define[prop].value === value) {
                    return define[prop].name;
                }
            }
            return '';
        }

        async _generateChange(tid) {
            if (this.changeData !== null) return;
            const self = this;
            try {
                const decimal = this.ctx.tender.info.decimal, ctx = this.ctx;
                const change = await this.ctx.service.change.getAllCheckedChanges(tid);
                for (const c of change) {
                    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 = await this.ctx.service.changeAuditList.getChangeAuditBills(tid);
                for (const d of changeBills) {
                    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);

                    const auditAmount = d.audit_amount.split(',');
                    const relaChange = ctx.helper._.find(change, {cid: d.cid});
                    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]);
                        }
                    }
                }

                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;
                });
                this.changeData = {change: change, bills: changeBills};
            } catch(err) {
                this.ctx.helper.log(err);
                throw err;
                this.changeData = {change: [], bills: []};
            }

        }

        async getChangeData(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);

                await this._generateChange(tid);
                return this.changeData.change;
            } catch (err) {
                return [];
            }
        }

        async getChangeBillsData(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);

                await this._generateChange(tid);
                return this.changeData.bills;
            } catch (err) {
                return [];
            }
        }

        async getStageJgcl(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                await this.ctx.service.stage.checkStage(sid);

                const data = await this.ctx.service.stageJgcl.getStageData(this.ctx.stage);
                const preData = await this.ctx.service.stageJgcl.getPreStageData(this.ctx.stage.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;
                    }
                }
                return data;
            } catch (err) {
                return [];
            }
        }

        async getStageBonus(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                await this.ctx.service.stage.checkStage(sid);

                const data = await this.ctx.service.stageBonus.getEndStageData(this.ctx.stage.order);
                return data;
            } catch (err) {
                return [];
            }
        }

        async getStageOther(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);
                await this.ctx.service.stage.checkStage(sid);

                const data = await this.ctx.service.stageOther.getStageData(this.ctx.stage);
                const preData = await this.ctx.service.stageOther.getPreStageData(this.ctx.stage.order);
                for (const d of data) {
                    const pd = this.ctx.helper._.find(preData, {uuid: d.uuid});
                    if (pd) {
                        d.pre_tp = pd.tp;
                    }
                }
                return data;
            } catch (err) {
                return [];
            }
        }

        async getMaterial(tender_id, material_order, memFieldKeys) {
            return await this.ctx.service.material.getValidMaterials(tender_id);
        }

        _completeMaterialGl(materialGl) {
            const tTypeStr = [], mTypeStr = [];
            for (const t of materialConst.t_type) {
                tTypeStr[t.value] = t.text;
            }
            for (const m of materialConst.m_type) {
                mTypeStr[m.value] = m.text;
            }
            for (const gl of materialGl) {
                gl.tp = this.ctx.helper.mul(gl.quantity, gl.m_spread, 2);
                gl.t_type_str = tTypeStr[gl.t_type];
                gl.m_type_str = mTypeStr[gl.m_type];
                gl.end_tp = this.ctx.helper.add(gl.tp, gl.pre_tp);
            }
        }

        async getMaterialGl(tender_id, material_order, memFieldKeys) {
            const materials = await this.ctx.service.material.getAllDataByCondition({
                where: {tid: tender_id},
                orders: [['order', 'desc']],
            });
            if (materials.length > 0) {
                let result;
                if (materials[0].order === material_order) {
                    result = await this.ctx.service.materialBills.getAllDataByCondition({
                        where: {tid: tender_id}
                    });
                } else {
                    const material = this.ctx.helper._.find(materials, {order: material_order});
                    if (!material) return [];
                    const sql = 'SELECT m.id, m.tid, m.mid, m.t_type, m.code, m.name, m.unit, m.spec, m.m_type,' +
                        '    m.basic_price, m.basic_times, m.remark, m.in_time,' +
                        '    mh.quantity, mh.expr, mh.msg_tp, mh.msg_times, mh.msg_spread, mh.m_up_risk, mh.m_down_risk, mh.m_spread' +
                        '  FROM ' + this.ctx.service.materialBills.tableName + ' m' +
                        '  LEFT JOIN ' + this.ctx.service.materialBillsHistory.tableName + ' mh' +
                        '  ON m.id = mh.mb_id' +
                        '  WHERE mh.mid = ?';
                    const sqlParam = [material.id];
                    result = await this.ctx.app.mysql.query(sql, sqlParam);
                }
                this._completeMaterialGl(result);
                return result;
            } else {
                return [];
            }
        }

        async getSumStageBillsData(tid, sid, fields) {
            try {
                await this.ctx.service.tender.checkTender(tid);

                const billsData = await this.ctx.service.ledger.getData(this.ctx.tender.id);
                const checkStageField = function (stageOrder) {
                    for (const f of fields) {
                        if (f.indexOf('s' + stageOrder + '_') >= 0) {
                            return true;
                        }
                    }
                    return false;
                };

                const calcFields = ['deal_tp', 'total_price'], calcPrefix = [];
                const stages = this.ctx.service.stage.getValidStages(this.ctx.tender.id);
                for (const stage of stages) {
                    if (!checkStageField(stage.order)) return;

                    await this.ctx.service.stage.doCheckStage(stage);
                    calcFields.push('s' + stage.order + '_contract_tp');
                    calcFields.push('s' + stage.order + '_qc_tp');
                    calcFields.push('s' + stage.order + '_gather_tp');
                    calcFields.push('s' + stage.order + '_');

                    const curStage = stage.readOnly
                        ? await this.ctx.service.stageBills.getAuditorStageData(this.ctx.tender.id, stage.id, stage.curTimes, stage.curOrder)
                        : await this.ctx.service.stageBills.getLastestStageData(this.ctx.tender.id, stage.id);
                    this.ctx.helper.assignRelaData(billsData, [
                        {data: curStage, fields: ['contract_qty', 'contract_tp', 'contract_expr', 'qc_qty', 'qc_tp'], prefix: 's' + stage.order + '_', relaId: 'lid'}
                    ]);
                }

                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: calcFields,
                    calc: function (node) {
                        for (const prefix of calcPrefix) {
                            if (node.children && node.children.length === 0) {
                                node[prefix + 'gather_qty'] = self.ctx.helper.add(node[prefix + 'contract_qty'], node[prefix + 'qc_qty']);
                            }
                            node[prefix + 'gather_tp'] = self.ctx.helper.add(node[prefix + 'contract_tp'], node[prefix + 'qc_tp']);
                        }
                    }
                });
                billsTree.loadDatas(billsData);
                billsTree.calculateAll();
                return billsTree.getDefaultDatas();
            } catch (err) {
                return [];
            }
        }
    }

    return ReportMemory;
};