Calculation/app/service/stage_change.js

'use strict';

/**
 * 期 - 变更数据
 *
 * @author Mai
 * @date
 * @version
 */

const defaultPid = -1; // 非pid
const audit = require('../const/audit');
const timesLen = audit.stage.timesLen;
const changeConst = require('../const/change');

class autoUseChange {
    constructor(helper, info) {
        this.helper = helper;
        this.precision = info.precision;
        this.decimal = info.decimal;

        this.insertBills = [];
        this.insertPos = [];
        this.updateBills = [];
        this.updatePos = [];
        this.insertChange = [];

        this.changeBills = {};
        this.changePos = {};
    }

    init(source) {
        this.default = source.default;

        const LedgerModel = require('../lib/ledger');
        this.ledgerTree = new LedgerModel.billsTree(this.ctx, {
            id: 'ledger_id', pid: 'ledger_pid', order: 'order', level: 'level', rootId: -1, calcFields: [],
        });
        this.pos = new LedgerModel.pos({ id: 'id', ledgerId: 'lid' });
        this.ledgerTree.loadDatas(source.ledgerData);
        this.pos.loadDatas(source.posData);

        this.stageBills = source.stageBills;
        this.stagePos = source.stagePos;
    }

    findBillsPos(changeBills){
        if (changeBills.gcl_id) {
            const node = this.ledgerTree.nodes.find(x => {return x.id === changeBills.gcl_id});
            const posData = this.pos.getLedgerPos(node.id) || [];
            const changePos = posData.find(x => { return x.name === changeBills.bwmx; });
            return { bills: node, lid: node.id, pid: changePos ? changePos.id : (posData.length > 0 ? posData[0].id : '-1') };
        } else {
            const cb = {
                b_code: changeBills.code || '',
                name: changeBills.name || '',
                unit: changeBills.unit || '',
                unit_price: changeBills.unit_price || 0,
                is_tp: false,
            };
            for (const node of this.ledgerTree.nodes) {
                if (node.children && node.children.length > 0) continue;

                const b = {
                    b_code: node.b_code || '',
                    name: node.name || '',
                    unit: node.unit || '',
                    unit_price: node.unit_price || 0,
                    is_tp: !!node.is_tp,
                };
                if (this.helper._.isMatch(cb, b)) {
                    const posData = this.pos.getLedgerPos(node.id) || [];
                    return { bills: node, lid: node.id, pid: posData.length > 0 ? posData[0].id : '-1' };
                }
            }
            return null;
        }
    }

    useBills(bills) {
        const billsPos = this.findBillsPos(bills);
        if (!billsPos) return;
        this.insertChange.push({
            tid: this.default.tid, sid: this.default.sid,
            lid: billsPos.lid, pid: billsPos.pid, cid: bills.cid, cbid: bills.id,
            qty: bills.valid_qty, stimes: 1, sorder: 0,
        });

        if (billsPos.pid !== '-1') {
            const cp = this.changePos[billsPos.pid];
            if (!cp) {
                this.changePos[billsPos.pid] = { lid: billsPos.lid, pid: billsPos.pid, qty: bills.valid_qty, bills: billsPos.bills };
            } else {
                cp.qty = this.helper.add(cp.qty, bills.valid_qty);
            }
        } else {
            const cb = this.changeBills[billsPos.lid];
            if (!cb) {
                this.changeBills[billsPos.lid] = { lid: billsPos.lid, qty: bills.valid_qty, bills: billsPos.bills };
            } else {
                cb.qty = this.helper.add(cb.qty, bills.valid_qty);
            }
        }
    }

    calculateAll() {
        for (const pid in this.changePos) {
            const cp = this.changePos[pid];
            if (!cp) continue;

            const precision = this.helper.findPrecision(this.precision, cp.bills.unit);
            const qc_qty = this.helper.round(cp.qty, precision.value);
            const sp = this.stagePos.find(x => {return x.pid === pid});
            if (sp) {
                this.updatePos.push({ id: sp.id, qc_qty });
            } else {
                this.insertPos.push({
                    tid: this.default.tid, sid: this.default.sid, said: this.default.said,
                    lid: cp.lid, pid, qc_qty, times: 1, order: 0
                });
            }
            const cb = this.changeBills[cp.lid];
            if (!cb) {
                this.changeBills[cp.lid] = { lid: cp.lid, qty: cp.qty, bills: cp.bills };
            } else {
                cb.qty = this.helper.add(cb.qty, cp.qty);
            }
        }
        for (const lid in this.changeBills) {
            const cb = this.changeBills[lid];
            if (!cb) continue;
            const precision = this.helper.findPrecision(this.precision, cb.bills.unit);
            const qc_qty = this.helper.round(cb.qty, precision.value);
            const qc_tp = this.helper.mul(cb.qty, cb.bills.unit_price, this.decimal.tp);
            const sb = this.stageBills.find(x => {return x.lid === lid});
            if (sb) {
                this.updateBills.push({ id: sb.id, qc_qty, qc_tp });
            } else {
                this.insertBills.push({
                    tid: this.default.tid, sid: this.default.sid, said: this.default.said,
                    lid, qc_qty, qc_tp, times: 1, order: 0
                });
            }
        }
    }

    use(source, validChangeBills) {
        this.init(source);

        for (const bills of validChangeBills) {
            this.useBills(bills);
        }
        this.calculateAll();
    }
}

module.exports = app => {

    class StageChange extends app.BaseService {

        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            this.tableName = 'stage_change';
        }

        /**
         * 查询 调用的变更令 最新数据
         * @param {Number} tid - 标段id
         * @param {Number} sid - 期id
         * @param {Number} lid - 台账节点id
         * @param {Number} pid - 部位明细id
         * @return {Promise<*>}
         */
        async getLastestStageData(tid, sid, lid, pid, noValue) {
            const filter = noValue !== undefined ? ' And no_value = ?' : '';
            const sql = 'SELECT c.*,' +
                '  oc.p_code As c_code, oc.new_code As c_new_code' +
                '  FROM ' + this.tableName + ' As c ' +
                '  INNER JOIN ( ' +
                '    SELECT MAX(`stimes` * ' + timesLen + ' + `sorder`) As `progress`, `lid`, `pid`, `sid`, `cid`, `cbid`, `no_value` From ' + this.tableName +
                '      WHERE tid = ? And sid = ? And lid = ? And pid = ?' + filter +
                '      GROUP By `lid`, `pid`, `cbid`, `no_value`' +
                '  ) As m ' +
                '  ON (c.stimes * ' + timesLen + ' + c.sorder) = m.progress And c.lid = m.lid And c.pid = m.pid And c.`sid` = m.`sid` And c.`cbid` = m.`cbid` And c.`no_value` = m.`no_value`' +
                '  LEFT JOIN ' + this.ctx.service.change.tableName + ' As oc' +
                '  ON c.cid = oc.cid' +
                '  LEFT JOIN ' + this.ctx.service.changeAuditList.tableName + ' As ocb' +
                '  ON c.cbid = ocb.id' +
                '  WHERE not ISNULL(ocb.id)';
            const sqlParam = [tid, sid, lid, pid ? pid : -1];
            if (noValue !== undefined) sqlParam.push(noValue);
            return await this.db.query(sql, sqlParam);
        }

        /**
         * 查询 调用的变更令 某轮 某人的数据
         * @param {Number} tid - 标段id
         * @param {Number} sid - 期id
         * @param {Number} times - 第几轮
         * @param {Number} order - 第几人
         * @param {Number} lid - 台账节点id
         * @param {Number} pid - 部位明细id
         * @return {Promise<*>}
         */
        async getAuditorStageData(tid, sid, times, order, lid, pid, noValue) {
            const filter = noValue !== undefined ? ' And no_value = ?' : '';
            const sql = 'SELECT c.*,' +
                '  oc.p_code As c_code, oc.new_code As c_new_code, oc.quality, ocb.code as b_code, ocb.name, ocb.unit' +
                '  FROM ' + this.tableName + ' As c ' +
                '  INNER JOIN ( ' +
                '    SELECT MAX(`stimes` * ' + timesLen + ' + `sorder`) As `progress`, `lid`, `pid`, `sid`, `cid`, `cbid`, `no_value` From ' + this.tableName +
                '      WHERE tid = ? And sid = ? And (`stimes` < ? OR (`stimes` = ? AND `sorder` <= ?)) And lid = ? And pid = ?' + filter +
                '      GROUP By `lid`, `pid`, cbid, no_value' +
                '  ) As m ' +
                '  ON (c.stimes * ' + timesLen + ' + c.sorder) = m.progress And c.lid = m.lid And c.pid = m.pid And c.`sid` = m.`sid` And c.`cbid` = m.`cbid` And c.`no_value` = m.`no_value`' +
                '  LEFT JOIN ' + this.ctx.service.change.tableName + ' As oc' +
                '  ON c.cid = oc.cid' +
                '  LEFT JOIN ' + this.ctx.service.changeAuditList.tableName + ' As ocb' +
                '  ON c.cbid = ocb.id' +
                '  WHERE not ISNULL(ocb.id)';
            const sqlParam = [tid, sid, times, times, order, lid, pid ? pid : -1];
            if (noValue !== undefined) sqlParam.push(noValue);
            return await this.db.query(sql, sqlParam);
        }

        async getLastestAllStageData(tid, sid) {
            const sql = 'SELECT c.*,' +
                '  oc.p_code As c_code, oc.new_code As c_new_code, oc.quality, ocb.code as b_code, ocb.name, ocb.unit' +
                '  FROM ' + this.tableName + ' As c ' +
                '  INNER JOIN ( ' +
                '    SELECT MAX(`stimes` * ' + timesLen + ' + `sorder`) As `progress`, `lid`, `pid`, `sid`, `cid`, `cbid`, `no_value` From ' + this.tableName +
                '      WHERE tid = ? And sid = ?' +
                '      GROUP By `lid`, `pid`, cbid, no_value' +
                '  ) As m ' +
                '  ON (c.stimes * ' + timesLen + ' + c.sorder) = m.progress And c.lid = m.lid And c.pid = m.pid And c.`sid` = m.`sid` And c.`cbid` = m.`cbid` And c.`no_value` = m.`no_value`' +
                '  LEFT JOIN ' + this.ctx.service.change.tableName + ' As oc' +
                '  ON c.cid = oc.cid' +
                '  LEFT JOIN ' + this.ctx.service.changeAuditList.tableName + ' As ocb' +
                '  ON c.cbid = ocb.id' +
                '  WHERE not ISNULL(ocb.id)';
            const sqlParam = [tid, sid];
            return await this.db.query(sql, sqlParam);
        }

        async getAuditorAllStageData(tid, sid, times, order) {
            const sql = 'SELECT c.*, ' +
                '  oc.p_code As c_code, oc.new_code As c_new_code, oc.quality, ocb.code as b_code, ocb.name, ocb.unit' +
                '  FROM ' + this.tableName + ' As c ' +
                '  INNER JOIN ( ' +
                '    SELECT MAX(`stimes` * ' + timesLen + ' + `sorder`) As `progress`, `lid`, `pid`, `sid`, `cid`, `cbid`, `no_value` From ' + this.tableName +
                '      WHERE tid = ? And sid = ? And (`stimes` < ? OR (`stimes` = ? AND `sorder` <= ?))' +
                '      GROUP By `lid`, `pid`, cbid, no_value' +
                '  ) As m ' +
                '  ON (c.stimes * ' + timesLen + ' + c.sorder) = m.progress And c.lid = m.lid And c.pid = m.pid And c.`sid` = m.`sid` And c.`cbid` = m.`cbid` And c.`no_value` = m.`no_value`' +
                '  LEFT JOIN ' + this.ctx.service.change.tableName + ' As oc' +
                '  ON c.cid = oc.cid' +
                '  LEFT JOIN ' + this.ctx.service.changeAuditList.tableName + ' As ocb' +
                '  ON c.cbid = ocb.id' +
                '  WHERE not ISNULL(ocb.id)';
            const sqlParam = [tid, sid, times, times, order];
            return await this.db.query(sql, sqlParam);
        }

        /**
         * 台账，调用变更令
         *
         * @param {Object} bills - 台账节点数据
         * @param {Array} changes - 调用的变更令
         * @return {Promise<void>}
         */
        async billsChange(bills, noValue, changes) {
            const self = this;
            function getNewChange(cid, cbid, times, order, qty, minus, no_value) {
                return {
                    tid: self.ctx.tender.id, sid: self.ctx.stage.id,
                    lid: bills.id, pid: -1,
                    cid, cbid,
                    stimes: times, sorder: order,
                    qty, minus, no_value,
                };
            }
            const ledgerBills = await this.ctx.service.ledger.getCompleteDataById(bills.id);
            if (!ledgerBills || ledgerBills.tender_id !== this.ctx.tender.id) {
                throw '提交数据错误';
            }
            const precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, ledgerBills.unit);
            // 获取原变更令
            const oldChanges = await this.getLastestStageData(this.ctx.tender.id, this.ctx.stage.id, bills.id, -1, noValue);
            // 获取更新数据
            const updateChanges = [],
                newChanges = [];
            let billsQty = 0;
            for (const oc of oldChanges) {
                const nc = this._.find(changes, { cid: oc.cid, cbid: oc.cbid });
                if (!nc || nc.qty !== oc.qty) {
                    const qty = nc ? this.round(nc.qty, precision.value) : null;
                    const change = getNewChange(oc.cid, oc.cbid, this.ctx.stage.curTimes, this.ctx.stage.curOrder, qty, nc ? nc.minus : oc.minus, noValue);
                    billsQty = this.ctx.helper.add(billsQty, change.qty);
                    if (oc.stimes === this.ctx.stage.curTimes && oc.sorder === this.ctx.stage.curOrder) {
                        change.id = oc.id;
                        updateChanges.push(change);
                    } else {
                        newChanges.push(change);
                    }
                } else {
                    billsQty = this.ctx.helper.add(billsQty, oc.qty);
                }
            }
            for (const c of changes) {
                const nc = this._.find(oldChanges, { cid: c.cid, cbid: c.cbid });
                if (!nc) {
                    const change = getNewChange(c.cid, c.cbid, this.ctx.stage.curTimes, this.ctx.stage.curOrder, this.round(c.qty, precision.value), c.minus, noValue);
                    billsQty = this.ctx.helper.add(billsQty, change.qty);
                    newChanges.push(change);
                }
            }
            // 更新数据
            const transaction = await this.db.beginTransaction();
            try {
                if (newChanges.length > 0) await transaction.insert(this.tableName, newChanges);
                if (updateChanges.length > 0) await transaction.updateRows(this.tableName, updateChange);
                const stageBills = await this.ctx.service.stageBills.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id, bills.id);
                const sbUpdate = noValue ? {qc_minus_qty: billsQty} : {qc_qty: billsQty};
                await this.ctx.service.stageBills.updateStageBillsQty(transaction, ledgerBills, stageBills, sbUpdate);
                await transaction.commit();
            } catch (err) {
                await transaction.rollback();
                throw err;
            }
            const result = await this.ctx.service.stageBills.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id, [bills.id]);
            return { bills: { curStageData: result } };
        }

        /**
         * 部位明细，调用变更令
         *
         * @param {Object} pos - 部位明细数据
         * @param {Array} changes - 调用的变更令
         * @return {Promise<{}>}
         */
        async posChange(pos, noValue, changes) {
            const self = this;
            function getNewChange(cid, cbid, times, order, qty, minus, no_value) {
                return {
                    tid: self.ctx.tender.id, sid: self.ctx.stage.id,
                    lid: pos.lid, pid: pos.id,
                    cid, cbid,
                    stimes: times, sorder: order,
                    qty, minus, no_value,
                };
            }
            const ledgerBills = await this.ctx.service.ledger.getCompleteDataById(pos.lid);
            if (!ledgerBills || ledgerBills.tender_id !== this.ctx.tender.id) {
                throw '提交数据错误';
            }
            const precision = this.ctx.helper.findPrecision(this.ctx.tender.info.precision, ledgerBills.unit);
            // 获取原变更令
            const oldChanges = await this.getLastestStageData(this.ctx.tender.id, this.ctx.stage.id, pos.lid, pos.id, noValue);
            const updateChanges = [],
                newChanges = [];
            let posQty = 0;
            for (const oc of oldChanges) {
                const nc = this._.find(changes, { cid: oc.cid, cbid: oc.cbid });
                if (!nc || nc.qty !== oc.qty) {
                    const qty = nc ? this.round(nc.qty, precision.value) : null;
                    const change = getNewChange(oc.cid, oc.cbid, this.ctx.stage.curTimes, this.ctx.stage.curOrder, qty, nc ? nc.minus : oc.minus, noValue);
                    posQty = this.ctx.helper.add(posQty, change.qty);
                    if (oc.stimes === this.ctx.stage.curTimes && oc.sorder === this.ctx.stage.curOrder) {
                        change.id = oc.id;
                        updateChanges.push(change);
                    } else {
                        newChanges.push(change);
                    }
                } else {
                    posQty = this.ctx.helper.add(posQty, oc.qty);
                }
            }
            for (const c of changes) {
                const nc = this._.find(oldChanges, { cid: c.cid, cbid: c.cbid });
                if (!nc) {
                    const change = getNewChange(c.cid, c.cbid, this.ctx.stage.curTimes, this.ctx.stage.curOrder, this.round(c.qty, precision.value), c.minus, noValue);
                    posQty = this.ctx.helper.add(posQty, change.qty);
                    newChanges.push(change);
                }
            }
            // 更新数据
            const transaction = await this.db.beginTransaction();
            try {
                if (newChanges.length > 0) await transaction.insert(this.tableName, newChanges);
                if (updateChanges.length > 0) await transaction.updateRows(this.tableName, updateChanges);
                await this.ctx.service.stagePos.updateChangeQuantity(transaction, pos, posQty, noValue);
                await transaction.commit();
            } catch (err) {
                await transaction.rollback();
                throw err;
            }

            // 获取返回数据
            try {
                const data = { bills: {}, pos: {} };
                data.bills.curStageData = await this.ctx.service.stageBills.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id, [pos.lid]);
                data.pos.curStageData = await this.ctx.service.stagePos.getLastestStageData2(this.ctx.tender.id, this.ctx.stage.id, { pid: pos.id });
                return data;
            } catch (err) {
                throw '获取数据错误，请刷新页面';
            }
        }

        /**
         * 获取 变更令 - 变更清单 使用情况
         * @param {Number} sid - 查询期id
         * @param {uuid} cid - 变更令id
         * @return {Promise<void>}
         */
        async getUsedData(tid, cid) {
            if (this.ctx.stage.status === audit.stage.status.checked) {
                const sql = 'SELECT scf.* ' +
                    '  FROM ' + this.ctx.service.stageChangeFinal.tableName + ' scf ' +
                    '  LEFT JOIN ' + this.ctx.service.stage.tableName + ' s ON scf.sid = s.id' +
                    '  WHERE scf.tid = ? And scf.cid = ? And s.order <= ?';
                const result = await this.db.query(sql, [tid, cid, this.ctx.stage.order]);
                return result;
            } else {
                const preSql = 'SELECT scf.* ' +
                    '  FROM ' + this.ctx.service.stageChangeFinal.tableName + ' scf ' +
                    '  LEFT JOIN ' + this.ctx.service.stage.tableName + ' s ON scf.sid = s.id' +
                    '  WHERE scf.tid = ? And scf.cid = ? And s.order < ?';
                const pre = await this.db.query(preSql, [tid, cid, this.ctx.stage.order]);
                const sql = 'SELECT * FROM ' + this.tableName + ' WHERE sid = ?';
                const curAll = await this.db.query(sql, [this.ctx.stage.id]);
                const cur = this.ctx.helper.filterLastestData(curAll, ['lid', 'pid', 'cbid', 'no_value'], 'stimes', 'sorder');
                return [...pre, ...cur];
            }
        }

        async getFinalUsedData(tid, cid) {
            const stage = await this.ctx.service.stage.getLastestStage(tid, true);
            if (!stage) { // 防止未创建期时调用
                return [];
            }
            if (stage.status === audit.stage.status.checked) {
                const sql = 'SELECT scf.* ' +
                    '  FROM ' + this.ctx.service.stageChangeFinal.tableName + ' scf ' +
                    '  LEFT JOIN ' + this.ctx.service.stage.tableName + ' s ON scf.sid = s.id' +
                    '  WHERE scf.tid = ? And scf.cid = ? And s.order <= ?';
                const result = await this.db.query(sql, [tid, cid, stage.order]);
                return result;
            } else {
                const preSql = 'SELECT scf.* ' +
                    '  FROM ' + this.ctx.service.stageChangeFinal.tableName + ' scf ' +
                    '  LEFT JOIN ' + this.ctx.service.stage.tableName + ' s ON scf.sid = s.id' +
                    '  WHERE scf.tid = ? And scf.cid = ? And s.order < ?';
                const pre = await this.db.query(preSql, [tid, cid, stage.order]);
                const sql = 'SELECT * FROM ' + this.tableName + ' WHERE sid = ? and cid = ?';
                const curAll = await this.db.query(sql, [stage.id, cid]);
                const cur = this.ctx.helper.filterLastestData(curAll, ['lid', 'pid', 'cbid', 'no_value'], 'stimes', 'sorder');
                return [...pre, ...cur];
            }
        }

        /**
         * 获取 变更令 - 变更清单 当期使用情况
         * @param {Number} sid - 查询期id
         * @param {uuid} cid - 变更令id
         * @return {Promise<*>}
         */
        async getStageUsedData(sid, cid) {
            const data = await this.getAllDataByCondition({ where: { sid, cid } });
            const _ = this.ctx.helper._;
            const filter = this.ctx.helper.filterLastestData(data, ['lid', 'pid', 'cbid', 'no_value'], 'stimes', 'sorder');
            if (filter.length === 0) return filter;

            const bills = await this.ctx.service.ledger.getAllDataByCondition({
                where: { id: _.uniq(_.map(filter, 'lid')) }
            });
            const pos = await this.ctx.service.pos.getAllDataByCondition({
                where: { id: _.uniq(_.map(filter, 'pid')) }
            });
            return filter.map(x => {
                const b = bills.find(y => { return y.id === x.lid });
                const p = pos.find(y => { return y.id === x.pid });
                return {
                    ...x,
                    ledger_id: b.ledger_id, l_code: b.b_code, l_name: b.name, l_unit: b.unit, l_up: b.unit_price,
                    l_deal_qty: b.deal_qty, l_deal_tp: b.deal_tp, l_qty: b.quantity, l_tp: b.total_price, l_drawing_code: b.drawing_code,
                    p_name: p ? p.name : '', p_drawing_code: p ? p.drawing_code : '', p_qty: p ? p.quantity : '',
                };
            });
        }

        /**
         * 获取 本期 使用的变更令
         * @param sid
         * @return {Promise<void>}
         */
        async getStageUsedChangeId(sid) {
            const sql = 'SELECT lid, pid, cid, cbid, qty, stimes, sorder FROM ' + this.tableName + ' WHERE sid = ?';
            const curAll = await this.db.query(sql, [sid]);
            const cur = this.ctx.helper.filterLastestData(curAll, ['lid', 'pid', 'cbid'], 'stimes', 'sorder');
            return this._.map(this._.filter(cur, 'qty'), 'cid');
        }

        async getFinalStageData(tid, sid) {
            const data = await this.getAllDataByCondition({ where: { tid, sid } });
            return this.ctx.helper.filterLastestData(data, ['lid', 'pid', 'cbid', 'no_value'], 'stimes', 'sorder');
        }

        async getSumLoadFinalData(sid) {
            const sql = 'Select cf.tid, cf.sid, cf.lid, cf.pid, cf.cid, cf.cbid, cf.qty, cf.stimes, cf.sorder, c.code As c_code' +
                '  FROM ' + this.tableName + ' cf' +
                '  Left Join ' + this.ctx.service.change.tableName + ' c ON cf.cid = c.cid' +
                '  Where cf.sid = ?';
            const result = await this.db.query(sql, [sid]);
            return this.ctx.helper.filterLastestData(result, ['lid', 'pid', 'cbid', 'no_value'], 'stimes', 'sorder');
        }

        async _getTender(stage) {
            if (this.ctx.tender) return this.ctx.tender;
            const tender = { id: stage.tid };
            tender.data = await this.ctx.service.tender.getTender(stage.tid);
            tender.info = await this.service.tenderInfo.getTenderInfo(tender.id);
            return tender;
        }

        async getSubtotal(stage) {
            const helper = this.ctx.helper;
            const tender = await this._getTender(stage);
            const sql = 'SELECT sc.*, c.quality FROM ' + this.tableName + ' sc' +
                '  LEFT JOIN ' + this.ctx.service.change.tableName + ' c ON sc.cid = c.cid' +
                '  WHERE sid = ? ' + (stage.readOnly ? ` and (stimes < ${stage.curTimes} or (stimes = ${stage.curTimes} and sorder <= ${stage.curOrder}))` : '');
            let data = await this.db.query(sql, [stage.id]);
            data = helper.filterLastestData(data, ['lid', 'pid', 'cbid'], 'stimes', 'sorder');
            const bqData = [];
            for (const d of data) {
                if (!d.qty) continue;
                let bd = bqData.find(x => { return x.lid === d.lid && x.quality === d.quality; });
                if (!bd) {
                    const bills = await this.db.get(this.ctx.service.ledger.departTableName(tender.id), { id: d.lid });
                    if (!bills) continue;
                    bd = { lid: d.lid, quality: d.quality, unit_price: bills.unit_price };
                    bqData.push(bd);
                }
                const tp = this.ctx.helper.mul(d.qty, bd.unit_price, tender.info.decimal.tp);
                bd.tp = this.ctx.helper.add(bd.tp, tp);
            }
            const result = {};
            result.common = helper.sum(helper._.map(bqData.filter(x => {return x.quality === changeConst.quality.common.value; }), 'tp'));
            result.more = helper.sum(helper._.map(bqData.filter(x => {return x.quality === changeConst.quality.more.value; }), 'tp'));
            result.great = helper.sum(helper._.map(bqData.filter(x => {return x.quality === changeConst.quality.great.value; }), 'tp'));
            return result;
        }

        async _getChangeBillsWithUsedInfo(stage) {
            if (stage.status === audit.stage.status.checked) {
                const sql = 'SELECT scf.* ' +
                    '  FROM ' + this.ctx.service.stageChangeFinal.tableName + ' scf ' +
                    '  LEFT JOIN ' + this.ctx.service.stage.tableName + ' s ON scf.sid = s.id' +
                    '  WHERE scf.tid = ? And s.order <= ?';
                const result = await this.db.query(sql, [stage.tid, stage.order]);
                return result;
            } else {
                const preSql = 'SELECT scf.* ' +
                    '  FROM ' + this.ctx.service.stageChangeFinal.tableName + ' scf ' +
                    '  LEFT JOIN ' + this.ctx.service.stage.tableName + ' s ON scf.sid = s.id' +
                    '  WHERE scf.tid = ? And s.order < ?';
                const pre = await this.db.query(preSql, [stage.tid, stage.order]);
                const sql = 'SELECT * FROM ' + this.tableName + ' WHERE sid = ? AND (stimes * 100 + sorder) <= (? * 100 + ?)';
                const curAll = await this.db.query(sql, [stage.id, stage.curTimes, stage.curOrder]);
                const cur = this.ctx.helper.filterLastestData(curAll, ['lid', 'pid', 'cbid', 'no_value'], 'stimes', 'sorder');
                return [...pre, ...cur];
            }
        }

        async getChangeWithUsedInfo(stage) {
            const change = await this.ctx.service.change.getAllDataByCondition({
                where: { tid: stage.tid, status: audit.flow.status.checked },
                orders: [['code', 'asc']],
            });
            if (change.length === 0) return [];

            const changeBills = await this.ctx.service.changeAuditList.getAllDataByCondition({
                where: { cid: change.map(x => { return x.cid; }) }
            });
            const changeBillsIndex = {}, changeBillsPart = {};
            for (const cb of changeBills) {
                changeBillsIndex[cb.id] = cb;
                if (!changeBillsPart[cb.cid]) changeBillsPart[cb.cid] = [];
                changeBillsPart[cb.cid].push(cb);
            }
            const stageChangeBills = await this._getChangeBillsWithUsedInfo(stage);
            for (const scb of stageChangeBills) {
                if (!scb.qty) continue;

                const cb = changeBillsIndex[scb.cbid];
                if (cb) cb.used_qty = this.ctx.helper.add(cb.used_qty, scb.qty);
            }
            for (const cid in changeBillsPart) {
                const c = change.find(x => { return x.cid === cid });
                if (!c) continue;

                for (const cb of changeBillsPart[cid]) {
                    cb.tp = this.ctx.helper.mul(cb.spamount, cb.unit_price, c.tp_decimal || this.ctx.tender.info.decimal.tp);
                    cb.used_tp = this.ctx.helper.mul(cb.used_qty, cb.unit_price, this.ctx.tender.info.decimal.tp);

                    c.used_tp = this.ctx.helper.add(c.used_tp, cb.used_tp);
                    if (cb.spamount > 0) {
                        c.p_tp = this.ctx.helper.add(c.p_tp, cb.tp);
                        c.p_used_tp = this.ctx.helper.add(c.p_used_tp, cb.used_tp);
                    } else if (cb.spamount < 0){
                        c.n_tp = this.ctx.helper.add(c.n_tp, cb.tp);
                        c.n_used_tp = this.ctx.helper.add(c.n_used_tp, cb.used_tp);
                    }
                }
                c.used_pt = c.total_price ? this.ctx.helper.mul(this.ctx.helper.div(c.used_tp, c.total_price, 4), 100) : 0;
                c.p_used_pt = c.p_tp ? this.ctx.helper.mul(this.ctx.helper.div(c.p_used_tp, c.p_tp, 4), 100) : 0;
                c.n_used_pt = c.n_tp ? this.ctx.helper.mul(this.ctx.helper.div(c.n_used_tp, c.n_tp, 4), 100) : 0;
            }
            return change;
        }

        async getStageMinusChange(stage) {
            const data = await this.getAllDataByCondition({ where: { sid: stage.id, minus: 1 } });
            return this.ctx.helper.filterLastestData(data, ['lid', 'pid', 'cbid'], 'stimes', 'sorder');
        };

        async getBillsMinusQty(stage, lid) {
            const data = await this.getAllDataByCondition({ where: { sid: stage.id, lid, minus: 1 } });
            const filter = this.ctx.helper.filterLastestData(data, ['lid', 'pid', 'cbid'], 'stimes', 'sorder');
            return { lid, qty: this.ctx.helper.sum(filter.map(x => { return x.qty; })) };
        };

        async getPosMinusQty(stage, pid) {
            const data = await this.getAllDataByCondition({ where: { sid: stage.id, pid, minus: 1 } });
            const filter = this.ctx.helper.filterLastestData(data, ['lid', 'pid', 'cbid'], 'stimes', 'sorder');
            return { pid, qty: this.ctx.helper.sum(filter.map(x => { return x.qty; })) };
        };

        async autoUseChangeBills(tender, stage, data) {
            for (const d of data) {
                const changeBills = await this.ctx.service.changeAuditList.getDataById(d.cbid);
                const bills = await this.ctx.service.ledger.getDataById(data.lid);
                const pos = await this.ctx.service.pos.getDataById(data.pid);
                if (pos && pos.lid !== bills.id) throw '数据错误';

                const allSc = await this.getAllDataByCondition({ where: { cbid: d.cbid, lid: data.lid, pid: data.pid } });
                const curSc = this.ctx.helper.filterLastestData(allSc, ['lid', 'pid', 'cbid'], 'stimes', 'sorder');
            }
            const changeBills = await this.ctx.service.changeAuditList.getDataById(cbid);
            const source = changeBills.gcl_id
                ? await this.ctx.service.ledger.getDataByCondition({ where: { id: [changeBills.gcl_id] } })
                : await this.ctx.service.ledger.getDataByCondition({ where: { tid: tender.id, b_code: changeBills.code, name: changeBills.name, unit: changeBills.unit, unit_price: changeBills.unit_price, is_leaf: true }});
            if (source.length < 1) then
            const pos = this.ctx.service.pos.getDataByCondition({ where: { lid: bills.id, name: changeBills.bwmx} });
        };

        async autoUseAllChange(tender, stage) {
            const validChangeBills = await this.ctx.service.stageChangeFinal.getAllChangeBillsValidQty(tender.id);
            const ledgerData = await this.ctx.service.ledger.getAllDataByCondition({
                columns: ['id', 'ledger_id', 'ledger_pid', 'level', 'order', 'full_path', 'is_leaf', 'code', 'b_code', 'name', 'unit', 'unit_price'],
                where: { tender_id: stage.tid },
            });
            const extraData = await this.ctx.service.ledgerExtra.getData(this.ctx.tender.id, ['is_tp']);
            this.ctx.helper.assignRelaData(ledgerData, [
                { data: extraData, fields: ['is_tp'], prefix: '', relaId: 'id' },
            ]);

            const posData = await this.ctx.service.pos.getAllDataByCondition({
                columns: ['id', 'lid', 'name', 'porder'],
                where: { tid: stage.tid },
            });
            const stageBills = await this.ctx.service.stageBills.getAllDataByCondition({ where: { sid: stage.id } });
            const stagePos = await this.ctx.service.stagePos.getAllDataByCondition({ where: { sid: stage.id } });
            const useModal = new autoUseChange(this.ctx.helper, tender.info);
            useModal.use({ledgerData, posData, stageBills, stagePos, default: { tid: stage.tid, sid: stage.id, said: this.ctx.session.sessionUser.accountId } }, validChangeBills);

            const conn = await this.db.beginTransaction();
            try {
                if (useModal.insertBills.length > 0) conn.insert(this.ctx.service.stageBills.tableName, useModal.insertBills);
                if (useModal.updateBills.length > 0) conn.updateRows(this.ctx.service.stageBills.tableName, useModal.updateBills);
                if (useModal.insertPos.length > 0) conn.insert(this.ctx.service.stagePos.tableName, useModal.insertPos);
                if (useModal.updatePos.length > 0) conn.updateRows(this.ctx.service.stagePos.tableName, useModal.updatePos);
                await conn.delete(this.tableName, { sid: stage.id });
                await conn.insert(this.tableName, useModal.insertChange);
                await conn.commit();
            } catch (err) {
                await conn.rollback();
                this.ctx.log(err);
                throw '保存导入数据失败';
            }
        }
    }

    return StageChange;

};