Calculation/app/controller/revise_controller.js

'use strict';

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

const stdDataAddType = {
    withParent: 1,
    child: 2,
    next: 3,
};
const audit = require('../const/audit');
const accountGroup = require('../const/account_group').group;
const tenderMenu = require('../../config/menu').tenderMenu;
const measureType = require('../const/tender').measureType;
const shenpiConst = require('../const/shenpi');
const LzString = require('lz-string');
const stdConst = require('../const/standard');
const spreadSetting = require('../lib/spread_setting');
const path = require('path');
const sendToWormhole = require('stream-wormhole');

module.exports = app => {
    class ReviseController extends app.BaseController {

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

        /**
         * 是否可以新增修订
         * @param ctx
         * @return {Promise<boolean>}
         * @private
         */
        async _getAddReviseValid(ctx) {
            const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
            const lastStage = await ctx.service.stage.getFlowLatestStage(ctx.tender.id, true);
            const addVisible = (ctx.tender.data.user_id === ctx.session.sessionUser.accountId) &&
                (ctx.tender.data.ledger_status === audit.ledger.status.checked) &&
                (!revise || !revise.valid || revise.status === audit.revise.status.checked);
            const addValid = addVisible && (!lastStage || lastStage.status === audit.stage.status.uncheck ||
                lastStage.status === audit.stage.status.checkNo || lastStage.status === audit.stage.status.checked);
            let changeValid = true;
            // 判断变更是否存在审批中，有则可能无法新增修订
            const changeList = await ctx.service.change.getAllDataByCondition({
                where: {
                    tid: ctx.tender.id,
                    status: [audit.change.status.checking, audit.change.status.checkNoPre],
                },
            });
            if (changeList.length > 0) {
                // 判断是否已存在新增部位，有则可能无法新增修订
                const changeLedgerList = await ctx.service.changeLedger.getAllDataByCondition({ where: { tender_id: ctx.tender.id, is_leaf: 1 } });
                const changePosList = await ctx.service.changePos.getAllDataByCondition({ where: { tid: ctx.tender.id } });
                // 判断变更是否已添加新增部位，有则可能无法新增修订
                if (changeLedgerList.length > 0 || changePosList.length > 0) {
                    // 判断审批中的变更令是否有调用了新增部位，有则无法新增修订，都没有则可新增修订
                    for (const c of changeList) {
                        const caList = await ctx.service.changeAuditList.getList(c.cid, 0);
                        const gclIdList = ctx.helper._.uniq(ctx.helper._.map(caList, 'gcl_id'));
                        for (const gcl of gclIdList) {
                            if (gcl && (ctx.helper._.findIndex(changeLedgerList, { id: gcl }) !== -1)) {
                                changeValid = false;
                                break;
                            }
                        }
                        if (!changeValid) {
                            break;
                        }
                        const posIdList = ctx.helper._.uniq(ctx.helper._.map(caList, 'mx_id'));
                        for (const pos of posIdList) {
                            if (pos && (ctx.helper._.findIndex(changePosList, { id: pos }) !== -1)) {
                                changeValid = false;
                                break;
                            }
                        }
                        if (!changeValid) {
                            break;
                        }
                    }
                }
            }
            return [addVisible, addValid, changeValid];
        }

        /**
         * 台账修订页面 (Get)
         *
         * @param {object} ctx - egg全局变量
         * @return {void}
         */
        async index(ctx) {
            try {
                // 分页相关
                const user = await this.ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
                const condition = { tid: ctx.tender.id };
                if (!user.show_revise_invalid) condition.valid = 1;
                const count = await ctx.service.ledgerRevise.count(condition);
                const ledgerRevise = await ctx.service.ledgerRevise.getReviseList(ctx.tender.id, user.show_revise_invalid);
                if (ledgerRevise.length > 0) {
                    const revise = ledgerRevise[0];
                    if (ctx.page === 1) {
                        if (revise.status === audit.revise.status.checked || !revise.valid) {
                            revise.lastest = true;
                        } else {
                            if (ledgerRevise.length > 1) ledgerRevise[1].lastest = true;
                            // if (revise.status === audit.revise.status.checking) {
                            //     revise.curAuditor = await ctx.service.reviseAudit.getCurAuditor(revise.id, revise.times);
                            // }
                        }
                    }
                }
                for (const lr of ledgerRevise) {
                    if (lr.valid) {
                        lr.curAuditors = await ctx.service.reviseAudit.getAuditorsByStatus(lr.id, lr.status, lr.times);
                        lr.curAuditorIds = lr.curAuditors.map(x => { return x.audit_id; });
                    }
                }
                const [addVisible, addValid, changeValid] = await this._getAddReviseValid(ctx);
                const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
                    ctx.tender.data.valuation, ctx.tender.data.measure_type);
                const renderData = {
                    tender: ctx.tender.data,
                    tenderMenu: this.menu.tenderMenu,
                    preUrl: '/tender/' + ctx.tender.id,
                    pageInfo: {
                        page: ctx.page,
                        total: Math.ceil(count / app.config.pageSize),
                        queryData: JSON.stringify(ctx.urlInfo.query),
                    },
                    ledgerRevise,
                    addVisible,
                    addValid,
                    changeValid,
                    auditConst: audit.revise,
                    auditType: audit.auditType,
                    auditConst2: JSON.stringify(audit.revise),
                    stdBills,
                    stdChapters,
                    show_invalid: user.show_revise_invalid,
                };
                await this.layout('revise/index.ejs', renderData, 'revise/modal.ejs');
            } catch (err) {
                this.log(err);
                ctx.redirect(ctx.request.header.referer);
            }
        }

        async showInvalid(ctx) {
            try {
                await ctx.service.projectAccount.defaultUpdate({ id: ctx.session.sessionUser.accountId, show_revise_invalid: ctx.query.show });
            } catch (err) {
                this.log(err);
            }
            ctx.redirect(ctx.request.header.referer);
        }

        /**
         * 修订审批流程(Get)
         * @param ctx
         * @return {Promise<void>}
         */
        async reviseAuditors(ctx) {
            try {
                const rid = JSON.parse(ctx.request.body.data).id;
                const reviseInfo = await ctx.service.ledgerRevise.getDataById(rid);
                await ctx.service.reviseAudit.loadReviseUser(reviseInfo);
                await ctx.service.reviseAudit.loadReviseAuditViewData(reviseInfo);
                ctx.body = { err: 0, msg: '', data: reviseInfo};
            } catch (error) {
                this.log(error);
                ctx.body = { err: 1, msg: error.toString(), data: null };
            }
        }

        /**
         * 新增 修订 (Post)
         * @param ctx
         * @return {Promise<void>}
         */
        async add(ctx) {
            try {
                const [addValid, changeValid] = await this._getAddReviseValid(ctx);
                if (!addValid) {
                    throw '无法新增修订';
                }
                if (!changeValid) {
                    throw '台账修订会影响审批中的变更令（包含新增部位），请审批完成后再创建台账修订';
                }
                const revise = await ctx.service.ledgerRevise.add(ctx.tender.id, ctx.session.sessionUser.accountId);
                ctx.redirect(`/tender/${ctx.tender.id}/revise/${revise.id}/info`);
            } catch (err) {
                this.log(err);
                ctx.redirect(ctx.request.header.referer);
            }
        }

        /**
         * 作废 修订 (Post)
         * @param ctx
         * @return {Promise<void>}
         */
        async cancel(ctx) {
            try {
                const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
                if (!revise) throw '当前标段无任何修订数据';

                if (revise.uid !== ctx.session.sessionUser.accountId) {
                    throw '您无权作废该修订';
                }
                if (revise.status === audit.revise.checking) {
                    throw '修订审批中，不可作废';
                } else if (revise.status === audit.revise.checked) {
                    throw '修订已审批通过，不可作废';
                }
                if (revise.valid) {
                    revise.readySettle = await this.service.settle.getReadySettle(revise.tid);
                    const result = await ctx.service.ledgerRevise.cancelRevise(revise);
                }

                ctx.redirect('/tender/' + ctx.tender.id + '/revise/');
            } catch (err) {
                this.log(err);
                ctx.redirect(ctx.request.header.referer);
            }
        }

        /**
         * 保存 修订详情 (Ajax-post)
         * @param ctx
         * @return {Promise<void>}
         */
        async save(ctx) {
            try {
                const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
                if (!revise.valid) {
                    throw '该修订已作废';
                } else if (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo) {
                    if (ctx.session.sessionUser.accountId !== revise.uid) {
                        throw '您无权修改';
                    }
                } else if (revise.status === audit.revise.status.checking) {
                    throw '修订在审批中，不可修改修订数据';
                } else if (revise.staut === audit.revise.status.checked) {
                    throw '修订已经审批通过，不可修改修订数据，请新增下一修订';
                }
                const data = JSON.parse(ctx.request.body.data);
                if (data.content === undefined) {
                    throw '保存数据有误';
                }
                const result = await ctx.service.ledgerRevise.defaultUpdate({ id: revise.id, content: data.content });
                if (result.affectedRows !== 1) {
                    throw '保存数据失败，请重试';
                }
                ctx.body = { err: 0, msg: '', data: null };
            } catch (err) {
                this.log(err);
                ctx.body = this.ajaxErrorBody(err, '保存数据失败，请重试');
            }
        }

        async _getDefaultReviseInfoData(ctx, revise) {
            const [ledgerSpread, posSpread] = await spreadSetting.getLedgerSpreadSetting(ctx, revise.tid,
                revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked);
            const [stdBills, stdChapters] = await this.ctx.service.valuation.getValuationStdList(
                ctx.tender.data.valuation, ctx.tender.data.measure_type);

            await ctx.service.reviseAudit.loadReviseUser(revise);
            await ctx.service.reviseAudit.loadReviseAuditViewData(revise);

            return {
                revise, tender: ctx.tender.data,
                ledgerSpread, posSpread, tenderMenu, measureType,
                audit: audit.revise,
                auditType: audit.auditType,
                jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.info),
                stdBills,
                auditConst: audit.revise,
                stdChapters,
                shenpiConst,
                nodeType: stdConst.nodeType,
                settleStatus: ctx.service.settle.settleStatus,
            };
        }

        /**
         * 历史修订页面(修订完成后，用于查看)
         * @param ctx
         * @param revise
         * @return {Promise<void>}
         * @private
         */
        async _getHistoryReviseInfo(ctx, revise) {
            const renderData = await this._getDefaultReviseInfoData(ctx, revise);
            renderData.ledgerSpread.readOnly = true;
            renderData.posSpread.readOnly = true;
            renderData.readOnly = true;
            renderData.history = true;
            renderData.historyRevise = await ctx.service.ledgerRevise.getAllReviseList(ctx.tender.id);
            renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
            renderData.preUrl = ctx.url.replace('/info', '');
            await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
        }

        /**
         * 修订页面(草稿，审批中)
         * @param ctx
         * @param revise
         * @return {Promise<void>}
         * @private
         */
        async _getAuditReviseInfo(ctx, revise) {
            const renderData = await this._getDefaultReviseInfoData(ctx, revise);
            renderData.readOnly = true;
            renderData.ledgerSpread.readOnly = true;
            renderData.posSpread.readOnly = true;
            renderData.history = false;
            renderData.historyRevise = [];
            renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
            renderData.preUrl = ctx.url.replace('/info', '');
            await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
        }

        async _getDraftReviseInfo(ctx, revise) {
            const renderData = await this._getDefaultReviseInfoData(ctx, revise);
            // 台账只读、使用数据
            renderData.readOnly = false;
            // 修订历史
            renderData.history = false;
            renderData.historyRevise = [];
            // 添加审批人相关
            // renderData.accountGroup = accountGroup;
            renderData.accountList = await ctx.service.projectAccount.getAllSubProjectAccount(ctx.subProject);
            const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
            renderData.accountGroup = unitList.map(item => {
                const groupList = renderData.accountList.filter(item1 => item1.company === item.name);
                return { groupName: item.name, groupList };
            }).filter(x => { return x.groupList.length > 0; });
            renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
            renderData.preUrl = ctx.url.replace('/info', '');
            await this.layout('revise/info.ejs', renderData, 'revise/info_modal.ejs');
        }

        /**
         * 修订 详细页面(Get)
         * @param ctx
         * @return {Promise<void>}
         */
        async info(ctx) {
            try {
                const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
                if (!revise) throw '台账修订数据有误';

                if (revise.uid === ctx.session.sessionUser.accountId &&
                    (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo)) {
                    await this._getDraftReviseInfo(ctx, revise);
                } else if (revise.status === audit.revise.status.checked) {
                    await this._getHistoryReviseInfo(ctx, revise);
                } else {
                    await this._getAuditReviseInfo(ctx, revise);
                }
            } catch (err) {
                this.log(err);
                ctx.redirect(ctx.request.header.referer);
            }
        }

        async loadInfoData(ctx) {
            try {
                const revise = await ctx.revise;

                const reviseBills = revise.readOnly
                    ? await ctx.helper.loadLedgerDataFromOss(revise.curHis.bills_file)
                    : await ctx.service.reviseBills.getData(ctx.tender.id);

                const revisePos = revise.readOnly
                    ? await ctx.helper.loadLedgerDataFromOss(revise.curHis.pos_file)
                    : await ctx.service.revisePos.getData(ctx.tender.id);

                // 已计量
                if (revise.uid === ctx.session.sessionUser.accountId &&
                    (revise.status === audit.revise.status.uncheck || revise.status === audit.revise.status.checkNo)) {
                    const stages = await ctx.service.stage.getAllDataByCondition({
                        where: { tid: ctx.tender.id },
                        orders: [['order', 'desc']],
                    });
                    if (stages.length > 0) {
                        const usedBills = [], usedPos = [];
                        for (const s of stages) {
                            if (s.status === audit.stage.status.checked) {
                                const usedPreBills = await ctx.service.stageBillsFinal.getUsedBills(ctx.tender.id, s.order);
                                usedBills.push(...usedPreBills);
                                const usedPrePos = await ctx.service.stagePosFinal.getUsedPos(ctx.tender.id, s.order);
                                usedPos.push(...usedPrePos);
                                break;
                            } else {
                                const usedCurBills = await ctx.service.stageBills.getStageUsedBills(ctx.tender.id, s.id);
                                usedBills.push(...usedCurBills);
                                const usedCurPos = await ctx.service.stagePos.getStageUsedPos(ctx.tender.id, s.id);
                                usedPos.push(...usedCurPos);
                            }
                        }
                        for (const b of reviseBills) {
                            b.used = usedBills.indexOf(b.id) >= 0;
                        }
                        for (const p of revisePos) {
                            p.used = usedPos.indexOf(p.id) >= 0;
                        }
                    }
                }
                const stage = await ctx.service.stage.getFlowLatestStage(ctx.revise.tid, true);
                const curBills = stage ? await ctx.service.stageBills.getLastestStageData2(ctx.tender.id, stage.id) : [];
                const preBills = stage && stage.order > 0 ? await ctx.service.stageBillsFinal.getFinalData(ctx.tender.data, stage.order - 1) : [];
                const curPos = stage ? await ctx.service.stagePos.getLastestStageData2(ctx.tender.id, stage.id) : [];
                const prePos = stage && stage.order > 0 ? await ctx.service.stagePosFinal.getFinalData(ctx.tender.data, stage.order - 1) : [];
                // 结算状态
                const settleStatusBills = ctx.revise.readySettle ? await ctx.service.settleBills.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}): [];
                this.ctx.helper.assignRelaData(reviseBills, [
                    { data: curBills, fields: ['contract_qty'], prefix: '', relaId: 'lid' },
                    { data: preBills, fields: ['contract_qty'], prefix: 'pre_', relaId: 'lid' },
                    { data: settleStatusBills, fields: ['settle_status'], prefix: '', relaId: 'lid' },
                ]);
                const settleStatusPos = ctx.revise.readySettle ? await ctx.service.settlePos.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}) : [];
                this.ctx.helper.assignRelaData(revisePos, [
                    { data: curPos, fields: ['contract_qty'], prefix: '', relaId: 'pid' },
                    { data: prePos, fields: ['contract_qty'], prefix: 'pre_', relaId: 'pid' },
                    { data: settleStatusPos, fields: ['settle_status'], prefix: '', relaId: 'pid' },
                ]);
                const ledgerTags = await this.ctx.service.ledgerTag.getDatas(ctx.tender.id);
                const price = !revise.readOnly ? await this.ctx.service.revisePrice.getAllDataByCondition({ where: { rid: revise.id } }) : [];
                const att = await this.ctx.service.ledgerAtt.getReviseViewData(ctx.tender.id, ctx.revise.id);
                ctx.body = { err: 0, msg: '', data: { bills: reviseBills, pos: revisePos, tags: ledgerTags, price, att } };
            } catch (err) {
                ctx.helper.log(err);
                this.ajaxErrorBody(err, '加载台账修订数据错误');
            }
        }

        async checkData(ctx) {
            try {
                const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
                if (!revise) throw '台账修订数据有误';

                const reviseBills = await ctx.service.reviseBills.getData(ctx.tender.id);
                const revisePos = await ctx.service.revisePos.getData(ctx.tender.id);

                const checkDataModel = require('../lib/ledger').checkData;
                const reviseCheck = new checkDataModel(ctx, measureType);
                reviseCheck.loadData(reviseBills, revisePos);
                ctx.tender.info.ledger_check.same_code && reviseCheck.checkSameCode();
                ctx.tender.info.ledger_check.sibling && reviseCheck.checkSibling();

                if (ctx.tender.data.measure_type === measureType.tz.value) reviseCheck.checkBillsQty(['sgfh_qty', 'qtcl_qty', 'sjcl_qty', 'quantity']);
                reviseCheck.checkBillsTp([
                    {qty: 'sgfh_qty', tp: 'sgfh_tp'}, {qty: 'qtcl_qty', tp: 'qtcl_tp'},
                    {qty: 'sjcl_qty', tp: 'sjcl_tp'}, {qty: 'quantity', tp: 'total_price'}
                ], this.ctx.tender.info.decimal, x => { return !x.check_calc; });
                ctx.body = { err: 0, msg: '', data: reviseCheck.checkResult };
            } catch (err) {
                this.log(err);
                ctx.body = this.ajaxErrorBody(err, '检查数据错误');
            }
        }

        async history(ctx) {
            try {
                const revise = ctx.revise;
                await ctx.service.reviseAudit.loadReviseUser(revise);
                await ctx.service.reviseAudit.loadReviseAuditViewData(revise);

                const [ledgerSpread, posSpread] = await spreadSetting.getLedgerSpreadSetting(ctx, revise.tid,
                    revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked);
                ledgerSpread.readOnly = true;
                posSpread.readOnly = true;
                const historyRevise = await ctx.service.ledgerRevise.getAllReviseList(ctx.tender.id);
                const user = await ctx.service.projectAccount.getAccountInfoById(revise.uid);
                const renderData = {
                    preUrl: ctx.url.replace('/info', ''),
                    measureType, audit, revise,
                    ledgerSpread, posSpread,
                    readOnly: true,
                    historyRevise,
                    auditConst: audit.revise,
                    auditType: audit.auditType,
                    user,
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.history),
                    nodeType: stdConst.nodeType,
                    settleStatus: ctx.service.settle.settleStatus,
                };
                await this.layout('revise/history.ejs', renderData, 'revise/history_modal.ejs');
            } catch (err) {
                this.log(err);
                ctx.redirect(ctx.request.header.referer);
            }
        }

        async checkRevise(ctx) {
            const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
            if (revise.uid !== ctx.session.sessionUser.accountId) {
                throw '修订数据错误';
            } else if (revise.status === audit.revise.status.checking) {
                throw '修订审批中，不可修改';
            } else if (revise.status === audit.revise.status.checked) {
                throw '修订已完成，如需修订台账，请新增修订';
            }
            return revise;
        }

        async _billsBase(revise, type, data) {
            if (isNaN(data.id) || data.id <= 0) throw '数据错误';
            if (type !== 'add') {
                if (isNaN(data.count) || data.count <= 0) data.count = 1;
            }
            switch (type) {
                case 'add':
                    return await this.ctx.service.reviseBills.addReviseNode(revise.tid, revise.id, data.id, data.count);
                case 'delete':
                    return await this.ctx.service.reviseBills.delete(revise.tid, data.id, data.count);
                case 'up-move':
                    return await this.ctx.service.reviseBills.upMoveNode(revise.tid, data.id, data.count);
                case 'down-move':
                    return await this.ctx.service.reviseBills.downMoveNode(revise.tid, data.id, data.count);
                case 'up-level':
                    return await this.ctx.service.reviseBills.upLevelNode(revise.tid, data.id, data.count);
                case 'down-level':
                    return await this.ctx.service.reviseBills.downLevelNode(revise.tid, data.id, data.count);
            }
        }
        async _batchInsert(revise, data) {
            if ((isNaN(data.id) || data.id <= 0) || !data.batchType) {
                throw '参数错误';
            }
            switch (data.batchType) {
                case 'child':
                    return await this.ctx.service.reviseBills.batchInsertChild(revise.tid, revise.id, data.id, data.batchData);
                case 'next':
                    return await this.ctx.service.reviseBills.batchInsertNext(revise.tid, revise.id, data.id, data.batchData);
                default:
                    throw '参数错误';
            }
        }
        async _pasteBlock(revise, data) {
            if ((isNaN(data.id) || data.id <= 0) ||
                (!data.tid && data.tid <= 0) ||
                (!data.block || data.block.length <= 0)) throw '参数错误';
            return await this.ctx.service.reviseBills.pasteBlockData(this.ctx.tender.id, data.id, data.block, { crid: revise.id });
        }
        async _addStd(revise, data) {
            if ((isNaN(data.id) || data.id <= 0) || !data.stdType || !data.stdData) throw '参数错误';
            // todo 校验项目是否使用该库的权限

            switch (data.stdType) {
                case 'xmj':
                    return await this.ctx.service.reviseBills.addStdNodeWithParent(revise.tid, data.stdData, revise.id);
                case 'gcl':
                    return data.withParent
                        ? await this.ctx.service.reviseBills.addGclStdNodeWithParent(revise.tid, data.id, data.stdData, revise.id)
                        : await this.ctx.service.reviseBills.addGclStdNode(revise.tid, data.id, data.stdData[data.stdData.length - 1], revise.id);
                default:
                    throw '未知标准库';
            }
        }
        async _addDeal(revise, data) {
            if (!data.type || !data.dealBills) throw '数据错误';
            data.dealBills.unit_price = this.ctx.helper.round(data.dealBills.unit_price, this.ctx.tender.info.decimal.up);
            if (data.type === 'child') {
                return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.dealBills, revise.id);
            } else if (data.type === 'next') {
                return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.dealBills, revise.id);
            }
            throw '数据错误';

        }
        async _addBg(revise, data) {
            if (!data.type || !data.bgBills) throw '数据错误';
            data.bgBills.unit_price = this.ctx.helper.round(data.bgBills.unit_price, this.ctx.tender.info.decimal.up);
            if (data.type === 'child') {
                return await this.ctx.service.reviseBills.addChild(revise.tid, data.id, data.bgBills, revise.id);
            } else if (data.type === 'next') {
                return await this.ctx.service.reviseBills.addBillsNode(revise.tid, data.id, data.bgBills, revise.id);
            }
            throw '数据错误';

        }
        async _updatePos(revise, data) {
            // await this.checkMeasureType(measureType.tz.value);
            if (!data.posPostType) throw '数据错误';
            switch (data.posPostType) {
                case 'add':
                    return await this.ctx.service.revisePos.addPos(revise.tid, revise.id, data.postData);
                case 'update':
                    if (data.postData instanceof Array) {
                        return await this.ctx.service.revisePos.updatePosArr(revise.tid, data.postData);
                    }
                    return await this.ctx.service.revisePos.updatePos(revise.tid, data.postData);

                case 'delete':
                    return await this.ctx.service.revisePos.deletePos(revise.tid, data.postData);
                case 'paste':
                    return await this.ctx.service.revisePos.pastePosData(revise.tid, revise.id, data.postData);
                case 'insert':
                    return await this.ctx.service.revisePos.insertPos(revise.tid, revise.id, data.postData);
                default:
                    throw '未知操作';
            }
        }
        async update(ctx) {
            try {
                if (!ctx.tender.data) throw '标段数据错误';
                const data = JSON.parse(ctx.request.body.data);
                if (!data.postType || !data.postData) throw '数据错误';
                const responseData = { err: 0, msg: '', data: {} };

                const revise = await this.checkRevise(ctx);

                switch (data.postType) {
                    case 'add':
                    case 'delete':
                    case 'up-move':
                    case 'down-move':
                    case 'up-level':
                    case 'down-level':
                        responseData.data = await this._billsBase(revise, data.postType, data.postData);
                        break;
                    case 'update':
                        ctx.helper.checkDgnQtyPrecision(data.postData);
                        responseData.data = await this.ctx.service.reviseBills.updateCalc(revise.tid, data.postData);
                        break;
                    case 'batch-insert':
                        responseData.data = await this._batchInsert(revise, data.postData);
                        break;
                    case 'add-deal':
                        responseData.data = await this._addDeal(revise, data.postData);
                        break;
                    case 'add-bg':
                        responseData.data = await this._addDeal(revise, data.postData);
                        break;
                    case 'add-std':
                        responseData.data = await this._addStd(revise, data.postData);
                        break;
                    case 'paste-block':
                        responseData.data = await this._pasteBlock(revise, data.postData);
                        break;
                    case 'pos':
                        responseData.data = await this._updatePos(revise, data);
                        break;
                    default:
                        throw '未知操作';
                }
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = this.ajaxErrorBody(err, '数据错误');
            }
        }

        /**
         * 上传 清单Excel 并导入
         * @param ctx
         * @return {Promise<void>}
         */
        async uploadExcel(ctx) {
            try {
                const revise = await this.checkRevise(ctx);

                const ueType = ctx.params.ueType;
                const compressData = ctx.request.body.data;
                const data = JSON.parse(LzString.decompressFromUTF16(compressData));
                const responseData = { err: 0, msg: '', data: {} };
                switch (ueType) {
                    case 'gcl2xmj':
                        responseData.data = await ctx.service.reviseBills.importGclExcel(data.id, data.sheet, { crid: revise.id });
                        break;
                }
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }

        }

        /**
         * 填设计量(Ajax)
         *
         * @param ctx
         * @return {Promise<void>}
         */
        async deal2sgfh(ctx) {
            try {
                if (this.ctx.tender.measure_type === measureType.tz.value) throw '该功能仅工程量清单模式可用';

                await this.ctx.service.reviseBills.deal2sgfh(ctx.tender.id);
                const ledgerData = await ctx.service.reviseBills.getData(ctx.tender.id);
                ctx.body = { err: 0, msg: '', data: { bills: ledgerData } };
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        /**
         * 新增审批人(Ajax)
         *
         * @param ctx
         * @return {Promise<void>}
         */
        async addAuditor(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                const id = data.auditorId;
                if (isNaN(id) || id <= 0) {
                    throw '参数错误';
                }
                const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
                if (!revise) throw '台账修订数据有误';
                // 检查权限等
                if (revise.uid !== ctx.session.sessionUser.accountId) throw '您无权添加审核人';
                if (revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
                    throw '当前不允许添加审核人';
                }
                // 检查审核人是否已存在
                const exist = await ctx.service.reviseAudit.getAuditor(revise.id, id, revise.times);
                if (exist) throw '该审核人已存在，请勿重复添加';
                const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.revise, sp_status: shenpiConst.sp_status.gdzs });
                const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.revise === shenpiConst.sp_status.gdzs ? 1 : 0;
                const result = await ctx.service.reviseAudit.addAuditor(revise, id, is_gdzs);
                if (!result) throw '添加审核人失败';

                const resultData = await ctx.service.reviseAudit.getUserGroup(revise.id, revise.times);
                ctx.body = { err: 0, msg: '', data: resultData };
            } catch (err) {
                this.log(err, '数据错误');
                ctx.body = this.ajaxErrorBody(err);
            }
        }
        /**
         * 移除审批人(Ajax)
         *
         * @param ctx
         * @return {Promise<void>}
         */
        async removeAuditor(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
                if (isNaN(id) || id <= 0) {
                    throw '参数错误';
                }
                const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
                if (!revise) throw '台账修订数据有误';

                const result = await ctx.service.reviseAudit.deleteAuditor(revise, id);
                if (!result) {
                    throw '移除审核人失败';
                }

                const resultData = await ctx.service.reviseAudit.getAuditors(revise.id, revise.times);
                ctx.body = { err: 0, msg: '', data: resultData };
            } catch (err) {
                this.log(err, '数据错误');
                ctx.body = this.ajaxErrorBody(err);
            }
        }
        /**
         * 上报(ajax-post)
         *
         * @param ctx
         * @return {Promise<void>}
         */
        async start(ctx) {
            try {
                const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
                if (!revise || revise.status === audit.revise.status.checking || revise.status === audit.revise.status.checked) {
                    throw '台账修订数据有误';
                }
                if (revise.content === '') {
                    throw '未填写修订内容，请先填写并保存修订内容';
                }
                if (revise.uid !== ctx.session.sessionUser.accountId) throw '上报失败';
                revise.readySettle = await this.service.settle.getReadySettle(revise.tid);

                await ctx.service.reviseAudit.start(revise, revise.times);
                ctx.body = { err: 0, msg: '', data: {} };
            } catch (err) {
                this.log(err);
                ctx.session.postError = err.toString();
                ctx.body = this.ajaxErrorBody(err, '上报失败');
            }
        }
        /**
         * 审批(post)
         *
         * @param ctx
         * @return {Promise<void>}
         */
        async check(ctx) {
            try {
                const revise = ctx.revise;
                if (!revise || revise.status !== audit.revise.status.checking) throw '台账修订数据有误';

                const curAudits = await ctx.service.reviseAudit.getCurAuditors(revise.id, revise.times);
                const curAuditorIds = curAudits.map(x => { return x.audit_id; });
                if (curAuditorIds.indexOf(ctx.session.sessionUser.accountId) < 0) throw '审批失败';

                const checkType = parseInt(ctx.request.body.checkType);
                if (!checkType || isNaN(checkType)) throw '提交数据错误';

                await ctx.service.reviseAudit.check(ctx.revise, checkType, ctx.request.body.opinion, revise.times);

                ctx.redirect(ctx.request.headers.referer);
            } catch (err) {
                this.log(err);
                this.postError(err, '审批失败');
                ctx.redirect(ctx.request.headers.referer);
            }
        }

        async _getLastStage(ctx) {
            const stages = await ctx.service.stage.getAllDataByCondition({
                where: {tid: ctx.tender.id},
                orders: [['order', 'desc']],
            });
            if (stages.length > 0) {
                if (stages[0].status !== audit.stage.status.uncheck || stages[0].user_id === ctx.session.sessionUser.accountId) {
                    return stages[0]
                } else if (stages.length > 1) {
                    return stages[1];
                }
            }
            return null;
        }

        async compare(ctx) {
            const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
            if (!revise) throw '台账修订数据有误';

            const lastStage = await this._getLastStage(ctx);

            const renderData = {
                preUrl: ctx.url.replace('/compare', ''),
                revise,
                measureType,
                lastStage,
                audit,
                jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.compare),
            };
            await this.layout('revise/compare.ejs', renderData, 'revise/compare_modal.ejs');
        }

        _loadPreData(curData, preData, field, prefix, relaId, extraFields = []) {
            if (preData.length === 0) return;
            for (const pd of preData) {
                const cd = curData.find(x => {return x[relaId] === pd[relaId]});
                if (cd) {
                    for (const f of field) {
                        cd[prefix + f] = pd[f];
                    }
                } else {
                    const ncd = {id: pd.id};
                    ncd[relaId] = pd[relaId];
                    for (const ef of extraFields) {
                        ncd[ef] = pd[ef];
                    }
                    for (const f of field) {
                        ncd[prefix + f] = pd[f];
                    }
                    curData.push(ncd);
                }
            }
        }

        async _loadLastStageBillsData(ctx) {
            let curStageData;
            if (ctx.lastStage.readOnly) {
                curStageData = await ctx.service.stageBills.getAuditorStageData2(ctx.tender.id,
                    ctx.lastStage.id, ctx.lastStage.curTimes, ctx.lastStage.curOrder);
            } else {
                curStageData = await ctx.service.stageBills.getLastestStageData2(ctx.tender.id, ctx.lastStage.id);
            }
            const preStageData = ctx.lastStage.order > 1
                ? await ctx.service.stageBillsFinal.getFinalData(ctx.tender.data, ctx.lastStage.order - 1)
                : [];
            this._loadPreData(curStageData, preStageData, ['contract_qty', 'contract_tp', 'qc_qty', 'qc_tp'], 'pre_', 'lid');
            return curStageData;
        }

        async _loadLastStagePosData(ctx) {
            let curStageData;
            if (ctx.lastStage.readOnly) {
                curStageData = await ctx.service.stagePos.getAuditorStageData2(ctx.tender.id,
                    ctx.lastStage.id, ctx.lastStage.curTimes, ctx.lastStage.curOrder);
            } else {
                curStageData = await ctx.service.stagePos.getLastestStageData2(ctx.tender.id, ctx.lastStage.id);
            }
            const preStageData = ctx.lastStage.order > 1
                ? await ctx.service.stagePosFinal.getFinalData(ctx.tender.data, ctx.lastStage.order - 1)
                : [];
            this._loadPreData(curStageData, preStageData, ['contract_qty', 'qc_qty'], 'pre_', 'pid', ['lid']);
            return curStageData;
        }

        async _loadChange(ctx) {
            const change = await ctx.service.change.getAllDataByCondition({
                columns: [ 'cid', 'code', 'name', 'w_code' ],
                where: { tid: ctx.tender.id },
                orders: [['code', 'asc']],
            });
            const changeBills = await ctx.service.changeAuditList.getAllDataByCondition({
                columns: [ 'cid', 'code', 'name', 'unit', 'unit_price' ],
                where: { tid: ctx.tender.id }
            });
            const changeIndex = {};
            change.forEach(x => { changeIndex[x.cid] = x; x.bills = [] });
            changeBills.forEach(cb => {
                const c = changeIndex[cb.cid];
                if (!c) return;
                c.bills.push(cb);
            });
            const helper = ctx.helper;
            change.forEach(x => {
                x.bills.sort((a, b) => { return helper.compareCode(a.code, b.code)});
            });
            return change;
        }

        async _loadDataByFilter(ctx, filter) {
            switch(filter) {
                case 'bills':
                    const billsData = ctx.revise.preHis ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.preHis.bills_file) : [];
                    const settleStatusBills = ctx.revise.readySettle ? await ctx.service.settleBills.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}): [];
                    this.ctx.helper.assignRelaData(billsData, [
                        { data: settleStatusBills, fields: ['settle_status'], prefix: '', relaId: 'lid' },
                    ]);
                    return billsData;
                case 'pos':
                    const posData = ctx.revise.preHis ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.preHis.pos_file) : [];
                    const settleStatusPos = ctx.revise.readySettle ? await ctx.service.settlePos.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}) : [];
                    this.ctx.helper.assignRelaData(posData, [
                        { data: settleStatusPos, fields: ['settle_status'], prefix: '', relaId: 'pid' },
                    ]);
                    return posData;
                case 'reviseBills':
                    const reviseBillsData = ctx.revise.readOnly && ctx.revise.curHis
                        ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.curHis.bills_file)
                        : await ctx.service.reviseBills.getAllDataByCondition({ where: { tender_id: ctx.tender.id } });
                    const settleBills = ctx.revise.readySettle ? await ctx.service.settleBills.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}): [];
                    this.ctx.helper.assignRelaData(reviseBillsData, [
                        { data: settleBills, fields: ['settle_status'], prefix: '', relaId: 'lid' },
                    ]);
                    return reviseBillsData;
                case 'revisePos':
                    const revisePosData = ctx.revise.readOnly && ctx.revise.curHis
                        ? await this.ctx.helper.loadLedgerDataFromOss(ctx.revise.curHis.pos_file)
                        : await ctx.service.revisePos.getAllDataByCondition({ where: { tid: ctx.tender.id } });
                    const settlePos = ctx.revise.readySettle ? await ctx.service.settlePos.getAllDataByCondition({ where: { settle_id: ctx.revise.readySettle.id }}) : [];
                    this.ctx.helper.assignRelaData(revisePosData, [
                        { data: settlePos, fields: ['settle_status'], prefix: '', relaId: 'pid' },
                    ]);
                    return revisePosData;
                case 'stageBills':
                case 'stagePos':
                    if (!ctx.lastStage) ctx.lastStage = await ctx.service.stage.getFlowLatestStage(ctx.revise.tid, true);
                    if (!ctx.lastStage) return [];
                    await this.ctx.service.stage.doCheckStage(ctx.lastStage);
                    if (filter === 'stageBills') {
                        return await this._loadLastStageBillsData(ctx);
                    } else {
                        return await this._loadLastStagePosData(ctx);
                    }
                case 'dealBills': return await ctx.service.dealBills.getAllDataByCondition({where: {tender_id: ctx.tender.id}});
                case 'spec':
                    const spec = {zlj: stdConst.zlj, jrg: stdConst.jrg};
                    spec.zlj.deal_bills_tp = ctx.tender.info.deal_param.zanLiePrice;
                    return spec;
                case 'tags':
                    return await this.ctx.service.ledgerTag.getDatas(ctx.tender.id);
                case 'price':
                    return await this.ctx.service.revisePrice.getAllDataByCondition({ where: { rid: ctx.revise.id } });
                case 'change':
                    return await this._loadChange(ctx);
                case 'att':
                    return await this.ctx.service.ledgerAtt.getReviseViewData(ctx.tender.id, ctx.revise.id);
                default: throw '请求的数据不存在';
            }
        }

        async loadData(ctx) {
            try {
                const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
                if (!revise) throw '台账修订数据有误';

                const data = JSON.parse(ctx.request.body.data);
                const filter = data.filter ? data.filter.split(';') : [];

                const responseData = { err: 0, msg: '', data: {} };
                for (const f of filter) {
                    if (!f) continue;
                    responseData.data[f] = await this._loadDataByFilter(ctx, f);
                }
                ctx.body = responseData;
            } catch (err) {
                this.ctx.helper.log(err);
                this.ajaxErrorBody(err, '加载数据错误，请刷新页面重试');
            }
        }

        async gclCompare(ctx) {
            const revise = await ctx.service.ledgerRevise.getLastestRevise(ctx.tender.id);
            if (!revise) throw '台账修订数据有误';

            const renderData = {
                measureType,
                preUrl: ctx.url.replace('/gcl-compare', ''),
                revise,
                jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.gclCompare),
            };
            await this.layout('revise/gcl_compare.ejs', renderData);
        }

        async price(ctx) {
            if (!ctx.revise) throw '台账修订数据有误';
            const renderData = {
                preUrl: ctx.url.replace('/price', ''),
                revise: ctx.revise,
                jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.revise.price),
                settleStatus: ctx.service.settle.settleStatus,
            };
            await this.layout('revise/price.ejs', renderData, 'revise/price_modal.ejs');
        }

        async priceUpdate(ctx) {
            try {
                if (!ctx.revise) throw '台账修订数据有误';

                const data = JSON.parse(ctx.request.body.data);
                const result = await ctx.service.revisePrice.updateDatas(data);
                ctx.body = { err: 0, msg: '', data: result };
            } catch (err) {
                ctx.log(err);
                ctx.ajaxErrorBody(err, '保存数据失败');
            }
        }

        async uploadFile(ctx) {
            let stream;
            try {
                const parts = ctx.multipart({ autoFields: true });
                const files = [];
                let index = 0;
                const extra_upload = ctx.revise.audit_status === audit.revise.status.checked;
                stream = await parts();
                while (stream) {
                    // 判断用户是否选择上传文件
                    if (!stream.filename) {
                        throw '请选择上传的文件!';
                    }
                    const fileInfo = path.parse(stream.filename);
                    const create_time = Date.parse(new Date()) / 1000;
                    const filepath = `${ctx.session.sessionProject.id}/${ctx.tender.id}/revise/att_${create_time + index.toString() + fileInfo.ext}`;

                    await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);

                    if (stream) await sendToWormhole(stream);

                    // 保存数据到att表
                    const fileData = {
                        tid: ctx.tender.id,
                        revise_id: ctx.revise.id,
                        revising: !extra_upload,
                        in_time: create_time,
                        filename: fileInfo.name,
                        fileext: fileInfo.ext,
                        filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
                        filepath,
                        extra_upload,
                    };
                    const result = await ctx.service.ledgerAtt.save(parts.field, fileData, ctx.session.sessionUser.accountId);
                    if (!result) throw '保存数据失败';
                    const attData = await ctx.service.ledgerAtt.getViewDataByFid(result.insertId);
                    files.length !== 0 ? files.unshift(attData) : files.push(attData);
                    ++index;
                    if (Array.isArray(parts.field.size) && index < parts.field.size.length) {
                        stream = await parts();
                    } else {
                        stream = undefined;
                    }
                }
                ctx.body = { err: 0, msg: '', data: files };
            } catch (err) {
                ctx.log(err);
                // 失败需要消耗掉stream 以防卡死
                if (stream) await sendToWormhole(stream);
                ctx.ajaxErrorBody(err, '上传文件失败');
            }
        }
        async deleteFile(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                const fileInfo = await ctx.service.ledgerAtt.getDataById(data.id);
                if (!fileInfo || !Object.keys(fileInfo).length) throw '该文件不存在';
                if (!fileInfo.extra_upload && ctx.revise.status === audit.revise.status.checked) throw '无权限删除';

                if (fileInfo !== undefined && fileInfo !== '') {
                    // 先删除文件
                    await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
                    // 再删除数据库
                    await ctx.service.ledgerAtt.deleteById(data.id);
                } else {
                    throw '不存在该文件';
                }
                ctx.body = { err: 0, msg: '', data: null}
            } catch (err) {
                ctx.log(err);
                ctx.ajaxErrorBody(err, '删除文件失败');
            }
        }
        async saveFile(ctx) {
            let stream;
            try {
                stream = await ctx.getFileStream({ requireFile: false });
                let fileData = {};
                if (stream.filename !== undefined) {
                    const create_time = Date.parse(new Date()) / 1000;
                    const fileInfo = path.parse(stream.filename);
                    const filepath = `${ctx.session.sessionProject.id}/${ctx.tender.id}/revise/att_${create_time + fileInfo.ext}`;

                    // 保存文件
                    await ctx.oss.put(ctx.app.config.fujianOssFolder + filepath, stream);
                    // 保存数据到att表
                    fileData = {
                        filesize: stream.fields.size,
                        filepath,
                    };
                }
                const org = await ctx.service.ledgerAtt.getDataById(stream.fields.id);
                const result = await ctx.service.ledgerAtt.updateByID(stream.fields, fileData);
                if (!result) throw '保存数据失败';
                // 删除原附件
                await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + org.filepath);
                const attData = await ctx.service.ledgerAtt.getViewDataByFid(stream.fields.id);
                ctx.body = { err: 0, msg: '', data: attData };
                responseData.data = attData;
            } catch (err) {
                ctx.log(err);
                // 失败需要消耗掉stream 以防卡死
                if (stream) await sendToWormhole(stream);
                ctx.ajaxErrorBody(err, '保存数据失败');
            }
        }
    }

    return ReviseController;
};