Calculation/app/service/phase_pay.js

'use strict';

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

const audit = require('../const/audit').common;
const projectLogConst = require('../const/project_log');
const shenpiConst = require('../const/shenpi');
const calcBase = [
    {name: '签约合同价', code: 'htj', sort: 10},
    {name: '暂列金额', code: 'zlje', sort: 2},
    {name: '签约合同价(不含暂列金、计日工)', code: 'htjszl', sort: 1},
    {name: '签约开工预付款', code: 'kgyfk', sort: 2},
    {name: '签约材料预付款', code: 'clyfk', sort: 2},
    {name: '本期完成计量', code: 'bqwc', limit: true, sort: 10, checkStart: 'gather_tp'},
    {name: '本期合同计量', code: 'bqht', limit: true, sort: 10, checkStart: 'contract_tp'},
    {name: '本期变更计量', code: 'bqbg', limit: true, sort: 10},
    {name: '本期清单完成计量', code: 'bqqdwc', limit: true, sort: 10},
    {name: '本期清单合同计量', code: 'bqqdht', limit: true, sort: 10},
    {name: '本期清单变更计量', code: 'bqqdbg', limit: true, sort: 10},
    {name: '本期一般变更计量', code: 'ybbqbg', limit: true, sort: 5},
    {name: '本期较大变更计量', code: 'jdbqbg', limit: true, sort: 5},
    {name: '本期重大变更计量', code: 'zdbqbg', limit: true, sort: 5},
    {name: '100章本期完成计量', code: 'ybbqwc', limit: true, sort: 1},
    {name: '本期应付', code: 'bqyf', limit: true, ptNormalLimit: true, sort: 20},
    {name: '奖金', code: 'bonus', limit: true, sort: 1},
    {name: '罚金', code: 'fine', limit: true, sort: 1},
    // {name: '甲供材料', code: 'jgcl', limit: true, sort: 1},
    {name: '甲供材料-本期到场', code: 'jgcldc', limit: true, sort: 1},
    {name: '甲供材料-本期扣回', code: 'jgclkh', limit: true, sort: 1},
];

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

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

        analysisPhasePay(data) {
            if (!data) return;

            const datas = data instanceof Array ? data : [data];
            datas.forEach(x => {
                x.rela_stage = x.rela_stage ? JSON.parse(x.rela_stage) : [];
                x.calc_base = x.calc_base ? JSON.parse(x.calc_base) : [];
            });
        }
        calculatePhasePay(data) {
            const helper = this.ctx.helper;
            const datas = data instanceof Array ? data : [data];
            const formatNum = this.ctx.tender.info.display.thousandth ? this.ctx.helper.formatNum : function(num) { return num ? num + '' : ''; };
            datas.forEach(x => {
                x.end_calc_tp = helper.add(x.calc_tp, x.pre_calc_tp);
                x.end_pay_tp = helper.add(x.pay_tp, x.pre_pay_tp);
                x.end_cut_tp = helper.add(x.cut_tp, x.pre_cut_tp);
                x.end_sf_tp = helper.add(x.sf_tp, x.pre_sf_tp);
                x.end_yf_tp = helper.add(x.yf_tp, x.pre_yf_tp);
                for (const prop in x) {
                    if (prop.indexOf('_tp') > 0) {
                        x['display_' + prop] = formatNum(x[prop]);
                    }
                }
            });
        }

        /**
         * 获取全部修订
         * @param tid
         * @returns {Promise<*>}
         */
        async getAllPhasePay (tid, sort = 'ASC') {
            const result = await this.getAllDataByCondition({
                where: { tid: tid },
                orders: [['phase_order', sort]],
            });
            this.analysisPhasePay(result);
            return result;
        }
        async getPhasePay(id) {
            const result = await this.getDataById(id);
            this.analysisPhasePay(result);
            return result;
        }
        async getPhasePayByOrder(tid, phaseOrder) {
            const result = await this.getDataByCondition({ tid, phase_order: phaseOrder });
            this.analysisPhasePay(result);
            return result;
        }

        async getMaxOrder(tid) {
            const sql = 'SELECT Max(`phase_order`) As max_order FROM ' + this.tableName + ' Where `tid` = ?';
            const sqlParam = [tid];
            const result = await this.db.queryOne(sql, sqlParam);
            return result.max_order || 0;
        }

        async _checkRelaStageConflict(relaStage, phasePay) {
            const pays = await this.getAllPhasePay(phasePay.tid);
            for (const p of pays) {
                if (p.id === phasePay.id) continue;
                for (const s of relaStage) {
                    if (p.rela_stage.find(x => { return x.id === s.id; })) return true;
                }
            }
            return false;
        }
        async getCalcBase(relaStage, prePhase) {
            const result = {};
            for (const stage of relaStage) {
                result.contract_tp = this.ctx.helper.add(result.contract_tp, stage.contract_tp);
                result.qc_tp = this.ctx.helper.add(result.qc_tp, stage.qc_tp);
                result.pc_tp = this.ctx.helper.add(result.pc_tp, stage.pc_tp);

                const qdSum = await this.ctx.service.stageBills.getSumTotalPriceGcl(stage);
                result.qd_contract_tp = this.ctx.helper.add(qdSum.contract_tp || 0, result.qd_contract_tp);
                result.qd_qc_tp = this.ctx.helper.add(qdSum.qc_tp || 0, result.qd_qc_tp);
                result.qd_pc_tp = this.ctx.helper.add(qdSum.pc_tp || 0, result.qd_pc_tp);

                const sumGcl = await this.ctx.service.stageBills.getSumTotalPriceGcl(stage, '^[^0-9]*([0-9]{0,2}-)?1[0-9]{2}(-|$)');
                const sumPc = await this.ctx.service.stageBillsPc.getSumTotalPriceGcl(stage, '^[^0-9]*([0-9]{0,2}-)?1[0-9]{2}(-|$)');
                result.gather_100_tp = this.ctx.helper.sum([sumGcl.contract_tp, sumGcl.qc_tp, sumPc.pc_tp, result.gather_100_tp]);

                const bg = await this.ctx.service.stage.getChangeSubtotal(stage);
                result.common_bg_tp = this.ctx.helper.add(bg.common || 0, result.common_bg_tp);
                result.more_bg_tp = this.ctx.helper.add(bg.more || 0, result.more_bg_tp);
                result.great_bg_tp = this.ctx.helper.add(bg.great || 0, result.great_bg_tp);
            }
            result.gather_tp = this.ctx.helper.sum([result.contract_tp, result.qc_tp, result.pc_tp]) || 0;
            result.qd_gather_tp = this.ctx.helper.sum([result.qd_contract_tp, result.qd_qc_tp, result.qd_pc_tp]) || 0;
            const bonusSum = await this.ctx.service.stageBonus.getSumTp(relaStage);
            result.bonus_positive_tp = bonusSum.positive_tp || 0;
            result.bonus_negative_tp = bonusSum.negative_tp || 0;
            result.bonus_reward_tp = bonusSum.reward_tp || 0;
            result.bonus_forfeit_tp = bonusSum.forfeit_tp || 0;
            result.bonus_tp = bonusSum.sum_tp || 0;
            const jgclSum = await this.ctx.service.stageJgcl.getSumTp(relaStage);
            result.jgcl_arrive_tp = jgclSum.arrive_tp || 0;
            result.jgcl_deduct_tp = jgclSum.deduct_tp || 0;
            result.jgcl_tp = this.ctx.helper.add(result.jgcl_arrive_tp, result.jgcl_deduct_tp);
            const otherSum = await this.ctx.service.stageOther.getSumTp(relaStage);
            result.other_tp = otherSum.sum_tp || 0;
            const safeProdSum = await this.ctx.service.stageSafeProd.getSumTp(relaStage);
            result.safe_prod_tp = safeProdSum.sum_tp || 0;
            const tempLandSum = await this.ctx.service.stageTempLand.getSumTp(relaStage);
            result.temp_land_tp = tempLandSum.sum_tp || 0;

            if (prePhase && prePhase.calc_base) {
                result.pre_contract_tp = this.ctx.helper.add(prePhase.calc_base.contract_tp, prePhase.calc_base.pre_contract_tp);
                result.pre_qc_tp = this.ctx.helper.add(prePhase.calc_base.qc_tp, prePhase.calc_base.pre_qc_tp);
                result.pre_pc_tp = this.ctx.helper.add(prePhase.calc_base.pc_tp, prePhase.calc_base.pre_pc_tp);
                result.pre_gather_tp = this.ctx.helper.add(prePhase.calc_base.gather_tp, prePhase.calc_base.pre_gather_tp);

                result.pre_qd_contract_tp = this.ctx.helper.add(prePhase.calc_base.qd_contract_tp, prePhase.calc_base.pre_qd_contract_tp);
                result.pre_qd_qc_tp = this.ctx.helper.add(prePhase.calc_base.qd_qc_tp, prePhase.calc_base.pre_qd_qc_tp);
                result.pre_qd_pc_tp = this.ctx.helper.add(prePhase.calc_base.qd_pc_tp, prePhase.calc_base.pre_qd_pc_tp);
                result.pre_qd_gather_tp = this.ctx.helper.add(prePhase.calc_base.qd_gather_tp, prePhase.calc_base.pre_qd_gather_tp);

                result.pre_bonus_positive_tp = this.ctx.helper.add(prePhase.calc_base.bonus_positive_tp, prePhase.calc_base.pre_bonus_positive_tp);
                result.pre_bonus_negative_tp = this.ctx.helper.add(prePhase.calc_base.bonus_negative_tp, prePhase.calc_base.pre_bonus_negative_tp);
                result.pre_bonus_reward_tp = this.ctx.helper.add(prePhase.calc_base.bonus_reward_tp, prePhase.calc_base.pre_bonus_reward_tp);
                result.pre_bonus_forfeit_tp = this.ctx.helper.add(prePhase.calc_base.bonus_forfeit_tp, prePhase.calc_base.pre_bonus_forfeit_tp);
                result.pre_bonus_tp = this.ctx.helper.add(prePhase.calc_base.bonus_tp, prePhase.calc_base.pre_bonus_tp);

                result.pre_jgcl_tp = this.ctx.helper.add(prePhase.calc_base.jgcl_tp, prePhase.calc_base.pre_jgcl_tp);
                result.pre_jgcl_arrive_tp = this.ctx.helper.add(prePhase.calc_base.jgcl_arrive_tp, prePhase.calc_base.pre_jgcl_arrive_tp);
                result.pre_jgcl_deduct_tp = this.ctx.helper.add(prePhase.calc_base.jgcl_deduct_tp, prePhase.calc_base.pre_jgcl_deduct_tp);

                result.pre_other_tp = this.ctx.helper.add(prePhase.calc_base.other_tp, prePhase.calc_base.pre_other_tp);
                result.pre_safe_prod_tp = this.ctx.helper.add(prePhase.calc_base.safe_prod_tp, prePhase.calc_base.pre_safe_prod_tp);
                result.pre_temp_land_tp = this.ctx.helper.add(prePhase.calc_base.temp_land_tp, prePhase.calc_base.pre_temp_land_tp);
            }
            return result;
        }
        /**
         * 获取 当期的 计算基数
         * @return {Promise<any>}
         */
        getPhasePayCalcBase(phasePay, tenderInfo) {
            const payCalcBase = JSON.parse(JSON.stringify(calcBase));
            for (const cb of payCalcBase) {
                switch (cb.code) {
                    case 'htj':
                        cb.value = tenderInfo.deal_param.contractPrice;
                        break;
                    case 'zlje':
                        cb.value = tenderInfo.deal_param.zanLiePrice;
                        break;
                    case 'htjszl':
                        cb.value = this.ctx.helper.sub(this.ctx.helper.sub(tenderInfo.deal_param.contractPrice, tenderInfo.deal_param.zanLiePrice), tenderInfo.deal_param.jrgPrice);
                        break;
                    case 'kgyfk':
                        cb.value = tenderInfo.deal_param.startAdvance;
                        break;
                    case 'clyfk':
                        cb.value = tenderInfo.deal_param.materialAdvance;
                        break;
                    case 'bqwc':
                        cb.value = phasePay.calc_base.gather_tp;
                        break;
                    case 'bqht':
                        cb.value = phasePay.calc_base.contract_tp;
                        break;
                    case 'bqbg':
                        cb.value = phasePay.calc_base.qc_tp;
                        break;
                    case 'bqqdwc':
                        cb.value = phasePay.calc_base.qd_gather_tp;
                        break;
                    case 'bqqdht':
                        cb.value = phasePay.calc_base.qd_contract_tp;
                        break;
                    case 'bqqdbg':
                        cb.value = phasePay.calc_base.qd_qc_tp;
                        break;
                    case 'ybbqwc':
                        cb.value = phasePay.calc_base.gather_100_tp;
                        break;
                    case 'ybbqbg':
                        cb.value = phasePay.calc_base.common_bg_tp;
                        break;
                    case 'jdbqbg':
                        cb.value = phasePay.calc_base.more_bg_tp;
                        break;
                    case 'zdbqbg':
                        cb.value = phasePay.calc_base.great_bg_tp;
                        break;
                    case 'bonus':
                        cb.value = phasePay.calc_base.bonus_positive_tp;
                        break;
                    case 'fine':
                        cb.value = phasePay.calc_base.bonus_negative_tp;
                        break;
                    case 'jgcl':
                        cb.value = phasePay.calc_base.jgcl_tp;
                        break;
                    case 'jgcldc':
                        cb.value = phasePay.calc_base.jgcl_arrive_tp;
                        break;
                    case 'jgclkh':
                        cb.value = phasePay.calc_base.jgcl_deduct_tp;
                        break;
                    case 'aqsc':
                        cb.value = phasePay.calc_base.safe_prod_tp;
                        break;
                    case 'lsyd':
                        cb.value = phasePay.calc_base.temp_land_tp;
                        break;
                    default:
                        cb.value = 0;
                }
            }
            return payCalcBase;
        }

        async add(tid, relaStage, phaseDate, memo) {
            if (!tid) throw '数据错误';
            const user_id = this.ctx.session.sessionUser.accountId;

            const maxOrder = await this.getMaxOrder(tid);
            const data = {
                id: this.uuid.v4(), tid: tid, create_user_id: user_id, update_user_id: user_id,
                phase_order: maxOrder + 1, phase_date: phaseDate, memo,
                audit_times: 1, audit_status: audit.status.uncheck,
                rela_stage: JSON.stringify(relaStage.map(s => { return {stage_id: s.id, stage_order: s.order}; })),
            };
            if (await this._checkRelaStageConflict(relaStage, data)) throw '选择的计量期，已被调用，请刷新页面后选择计量期新增合同支付';

            const prePhase = maxOrder > 0 ? await this.getPhasePayByOrder(tid, maxOrder) : null;
            if (prePhase) {
                data.pre_calc_tp = this.ctx.helper.add(prePhase.calc_tp, prePhase.pre_calc_tp);
                data.pre_pay_tp = this.ctx.helper.add(prePhase.pay_tp, prePhase.pre_pay_tp);
                data.pre_cut_tp = this.ctx.helper.add(prePhase.cut_tp, prePhase.pre_cut_tp);
                data.pre_sf_tp = this.ctx.helper.add(prePhase.sf_tp, prePhase.pre_sf_tp);
                data.pre_yf_tp = this.ctx.helper.add(prePhase.yf_tp, prePhase.pre_yf_tp);
            }
            const calcBase = await this.getCalcBase(relaStage, prePhase);
            data.calc_base = JSON.stringify(calcBase);
            const transaction = await this.db.beginTransaction();
            try {
                const result = await transaction.insert(this.tableName, data);
                if (result.affectedRows !== 1) throw '新增合同支付失败';

                await this.ctx.service.phasePayDetail.initPhaseData(transaction, data, prePhase);
                await this.ctx.service.phasePayAudit.copyPreAuditors(transaction, prePhase, data);
                await transaction.commit();
                this.analysisPhasePay(data);
                return data;
            } catch(err) {
                await transaction.rollback();
                throw err;
            }
        }
        async delete(id) {
            const info = await this.getDataById(id);
            const conn = await this.db.beginTransaction();
            try {
                await conn.delete(this.tableName, { id });
                await conn.delete(this.ctx.service.phasePayDetail.tableName, { phase_id: id });
                const files = await this.ctx.service.phasePayFile.getFiles({ where: { phase_id: id} });
                for (const f of files) {
                    this.ctx.app.fujianOss.delete(f.filepath);
                }
                await conn.delete(this.ctx.service.phasePayFile.tableName, { phase_id: id });
                await conn.delete(this.ctx.service.phasePayAudit.tableName, { phase_id: id });
                // 记录删除日志
                await this.ctx.service.projectLog.addProjectLog(conn, projectLogConst.type.phasePay, projectLogConst.status.delete, `第${info.phase_order}期`);
                await conn.commit();
            } catch (err) {
                await conn.rollback();
                throw err;
            }
        }
        async save(phasePay, data) {
            await this.defaultUpdate({id: phasePay.id, phase_date: data.phase_date, memo: data.memo});
        }

        async refreshCalcBase(phasePay) {
            const prePhase = phasePay.phase_order > 1 ? await this.getPhasePayByOrder(phasePay.tid, phasePay.phase_order - 1) : null;
            const relaStage = await this.ctx.service.stage.getAllDataByCondition({ where: { tid: phasePay.tid, order: phasePay.rela_stage.map(x => { return x.stage_order; }) } });
            const calcBase = await this.getCalcBase(relaStage, prePhase);
            const conn = await this.db.beginTransaction();
            try {
                await conn.update(this.tableName, {
                    id: phasePay.id, update_user_id: this.ctx.session.sessionUser.accountId,
                    calc_base: JSON.stringify(calcBase),
                    calc_base_time: new Date()
                });
                phasePay.calc_base = calcBase;
                await this.ctx.service.phasePayDetail.calculateSave(phasePay, conn);
                await conn.commit();
            } catch(err) {
                await conn.rollback();
                throw err;
            }
        }
        async resetRelaStageId(phasePay, relaStage) {
            if (await this._checkRelaStageConflict(relaStage, phasePay)) throw '选择的计量期，已被调用，请刷新页面后选择计量期新增合同支付';
            const prePhase = prePhase.phase_order > 1 ? await this.getPhasePayByOrder(phasePay.tid, phasePay.phase_order - 1) : null;
            const calcBase = await this.getCalcBase(relaStage, prePhase);
            const rela_stage = relaStage.map(s => { return {stage_id: s.id, stage_order: s.order}; });
            const conn = await this.db.beginTransaction();
            try {
                await conn.update(this.tableName, {
                    id: phasePay.id, update_user_id: this.ctx.session.sessionUser.accountId,
                    calc_base: JSON.stringify(calcBase),
                    rela_stage: JSON.stringify(rela_stage),
                    calc_base_time: new Date()
                });
                phasePay.calc_base = calcBase;
                phasePay.rela_stage = relaStage;
                await this.ctx.service.phasePayDetail.calculateSave(phasePay, conn);
                await conn.commit();
            } catch(err) {
                await conn.rollback();
                throw err;
            }
        }

        async loadUser(phasePay) {
            phasePay.user = await this.ctx.service.projectAccount.getAccountInfoById(phasePay.create_user_id);
            phasePay.auditors = await this.ctx.service.phasePayAudit.getAuditors(phasePay.id, phasePay.curTimes || phasePay.audit_times);
            phasePay.auditorIds = this._.map(phasePay.auditors, 'audit_id');
            phasePay.curAuditors = phasePay.auditors.filter(x => { return x.audit_status === audit.status.checking; });
            phasePay.curAuditorIds = phasePay.curAuditors.map(x => { return x.audit_id; });
            phasePay.flowAuditors = phasePay.curAuditors.length === 0 ? [] : phasePay.auditors.filter(x => { return x.active_order === phasePay.curAuditors[0].active_order; });
            phasePay.flowAuditorIds = phasePay.flowAuditors.map(x => { return x.audit_id; });
            phasePay.nextAuditors = phasePay.curAuditors.length > 0 ? phasePay.auditors.filter(x => { return x.active_order === phasePay.curAuditors[0].active_order + 1; }) : [];
            phasePay.nextAuditorIds = this._.map(phasePay.nextAuditors, 'audit_id');
            phasePay.auditorGroups = this.ctx.helper.groupAuditors(phasePay.auditors, 'active_order');
            phasePay.userGroups = this.ctx.helper.groupAuditorsUniq(phasePay.auditorGroups);
            phasePay.finalAuditorIds = phasePay.userGroups.length > 1 ? phasePay.userGroups[phasePay.userGroups.length - 1].map(x => { return x.audit_id; }) : [];
            phasePay.userIds = phasePay.audit_status === audit.status.uncheck // 当前流程下全部参与人id
                ? [phasePay.user_id]
                : phasePay.auditorIds;
        }
        async loadAuditViewData(phasePay) {
            if (!phasePay.user) phasePay.user = await this.ctx.service.projectAccount.getAccountInfoById(phasePay.user_id);
            const auditTimes = phasePay.audit_status === audit.status.checkNo ? phasePay.audit_times - 1 : phasePay.audit_times;
            phasePay.auditHistory = await this.ctx.service.phasePayAudit.getAuditorHistory(phasePay.id, auditTimes);
            // 获取审批流程中左边列表
            if (phasePay.audit_status === audit.status.checkNo && phasePay.create_user_id !== this.ctx.session.sessionUser.accountId) {
                const auditors = await this.ctx.service.phasePayAudit.getAuditors(phasePay.id, phasePay.audit_times - 1); // 全部参与的审批人
                const auditorGroups = this.ctx.helper.groupAuditors(auditors);
                phasePay.hisUserGroup = this.ctx.helper.groupAuditorsUniq(auditorGroups);
            } else {
                phasePay.hisUserGroup = phasePay.userGroups;
            }
        }
        /**
         * cancancel = 0 不可撤回
         * cancancel = 1 原报撤回
         * cancancel = 2 审批人撤回 审批通过
         * cancancel = 3 审批人撤回 审批退回上一人
         * cancancel = 4 审批人撤回 退回原报
         * cancancel = 5 会签未全部审批通过时，审批人撤回 审批通过
         *
         * @param phasePay
         * @returns {Promise<void>}
         */
        async doCheckCanCancel(phasePay) {
            // 默认不可撤回
            phasePay.cancancel = 0;
            // 获取当前审批人的上一个审批人，判断是否是当前登录人，并赋予撤回功能，（当审批人存在有审批过时，上一人不允许再撤回）
            const status = audit.status;
            if (phasePay.audit_status === status.checked || phasePay.audit_status === status.uncheck) return;

            const accountId = this.ctx.session.sessionUser.accountId;
            if (phasePay.audit_status !== status.checkNo) {
                // 找出当前操作人上一个审批人，包括审批完成的和退回上一个审批人的，同时当前操作人为第一人时，就是则为原报
                if (phasePay.flowAuditors.find(x => { return x.audit_status !== status.checking}) && phasePay.flowAuditorIds.indexOf(accountId) < 0) return; // 当前流程存在审批人审批通过时，不可撤回
                if (phasePay.curAuditorIds.indexOf(accountId) < 0 && phasePay.flowAuditorIds.indexOf(accountId) >= 0) {
                    phasePay.cancancel = 5; // 会签未全部审批通过时，审批人撤回审批通过
                    return;
                }

                const preAuditors = phasePay.curAuditors[0] && phasePay.curAuditors[0].active_order !== 1 ? phasePay.auditors.filter(x => { return x.active_order === phasePay.curAuditors[0].active_order - 1; }) : [];
                const preAuditorCheckAgain = preAuditors.find(pa => { return pa.audit_status === status.checkAgain; });
                const preAuditorCheckCancel = preAuditors.find(pa => { return pa.audit_status === status.checkCancel; });
                const preAuditorHasOld = preAuditors.find(pa => { return pa.is_old === 1; });
                const preAuditorIds = (preAuditorCheckAgain ? [] : preAuditors.map(x => { return x.audit_id })); // 重审不可撤回
                if ((this._.isEqual(phasePay.flowAuditorIds, preAuditorIds) && preAuditorCheckCancel) || preAuditorHasOld) {
                    return; // 不可以多次撤回
                }

                const preAuditChecked = preAuditors.find(pa => { return pa.audit_status === status.checked && pa.audit_id === accountId; });
                const preAuditCheckNoPre = preAuditors.find(pa => { return pa.audit_status === status.checkNoPre && pa.audit_id === accountId; });
                if (preAuditorIds.indexOf(accountId) >= 0) {
                    if (preAuditChecked) {
                        phasePay.cancancel = 2;// 审批人撤回审批通过
                    } else if (preAuditCheckNoPre) {
                        phasePay.cancancel = 3;// 审批人撤回审批退回上一人
                    }
                    phasePay.preAuditors = preAuditors;
                } else if (preAuditors.length === 0 && accountId === phasePay.create_user_id) {
                    phasePay.cancancel = 1;// 原报撤回
                }
            } else {
                const lastAuditors = await this.ctx.service.phasePayAudit.getAuditors(phasePay.id, phasePay.audit_times - 1);
                const onAuditor = this._.findLast(lastAuditors, { audit_status: status.checkNo });
                if (onAuditor.audit_id === accountId) {
                    phasePay.cancancel = 4;// 审批人撤回退回原报
                    phasePay.preAuditors = lastAuditors.filter(x => { return x.active_order === onAuditor.active_order });
                }
            }
        }
        async doCheckPhase(phasePay) {
            const accountId = this.ctx.session.sessionUser.accountId;
            // 审批退回时，原报读取本轮流程，其他人读取上一轮流程
            if (phasePay.audit_status === audit.status.checkNo) {
                phasePay.curTimes = phasePay.create_user_id === accountId ? phasePay.audit_times : phasePay.audit_times - 1;
            } else {
                phasePay.curTimes = phasePay.audit_times;
            }
            // 加载参与人
            await this.loadUser(phasePay);

            if (phasePay.audit_status === audit.status.uncheck) {
                phasePay.readOnly = accountId !== phasePay.create_user_id;
                phasePay.curSort = 0;
            } else if (phasePay.audit_status === audit.status.checkNo) {
                phasePay.readOnly = accountId !== phasePay.create_user_id;
                if (!phasePay.readOnly) {
                    phasePay.curSort = 0;
                } else {
                    const checkNoAudit = await this.service.phasePayAudit.getDataByCondition({
                        phase_id: phasePay.id, audit_times: phasePay.audit_times - 1, audit_status: audit.status.checkNo,
                    });
                    phasePay.curSort = checkNoAudit.active_order;
                }
            } else if (phasePay.audit_status === audit.status.checked) {
                phasePay.readOnly = true;
                phasePay.curSort = phasePay.audit_max_sort;
            } else {
                // 会签，会签人部分审批通过时，只读，但是curSort需按原来的取值
                phasePay.curSort = phasePay.flowAuditorIds.indexOf(accountId) >= 0 ? phasePay.curAuditors[0].active_order : phasePay.curAuditors[0].active_order - 1;
                phasePay.readOnly = phasePay.curAuditorIds.indexOf(accountId) < 0;
                phasePay.canCheck = phasePay.readOnly && phasePay.curAuditorIds.indexOf(accountId) > 0;
            }
            await this.doCheckCanCancel(phasePay);
        }
        async checkShenpi(phasePay) {
            const status = audit.status;
            const info = this.ctx.tender.info;
            const shenpi_status = info.shenpi.phasePay;
            if ((phasePay.audit_status === status.uncheck || phasePay.audit_status === status.checkNo) && shenpi_status !== shenpiConst.sp_status.sqspr) {
                // 进一步比较审批流是否与审批流程设置的相同，不同则替换为固定审批流或固定的终审
                const auditList = await this.ctx.service.phasePayAudit.getAllDataByCondition({ where: { phase_id: phasePay.id, audit_times: phasePay.audit_times }, orders: [['audit_order', 'asc']] });
                auditList.shift();
                if (shenpi_status === shenpiConst.sp_status.gdspl) {
                    const shenpiList = await this.ctx.service.shenpiAudit.getAllDataByCondition({ where: { tid: phasePay.tid, sp_type: shenpiConst.sp_type.phasePay, sp_status: shenpi_status } });
                    // 判断2个id数组是否相同，不同则删除原审批流，切换成固定的审批流
                    let sameAudit = auditList.length === shenpiList.length;
                    if (sameAudit) {
                        for (const audit of auditList) {
                            const shenpi = shenpiList.find(x => { return x.audit_id === audit.audit_id; });
                            if (!shenpi || shenpi.audit_order !== audit.audit_order || shenpi.audit_type !== audit.audit_type) {
                                sameAudit = false;
                                break;
                            }
                        }
                    }
                    if (!sameAudit) {
                        await this.ctx.service.phasePayAudit.updateNewAuditList(phasePay, shenpiList);
                        await this.loadUser(phasePay);
                    }
                } else if (shenpi_status === shenpiConst.sp_status.gdzs) {
                    const shenpiInfo = await this.ctx.service.shenpiAudit.getDataByCondition({ tid: phasePay.tid, sp_type: shenpiConst.sp_type.phasePay, sp_status: shenpi_status });
                    // 判断最后一个id是否与固定终审id相同，不同则删除原审批流中如果存在的id和添加终审
                    const lastAuditors = auditList.filter(x => { x.active_order === auditList.active_order; });
                    if (shenpiInfo && (lastAuditors.length === 0 || (lastAuditors.length > 1 || shenpiInfo.audit_id !== lastAuditors[0].audit_id))) {
                        await this.ctx.service.phasePayAudit.updateLastAudit(phasePay, auditList, shenpiInfo.audit_id);
                        await this.loadUser(phasePay);
                    } else if (!shenpiInfo) {
                        // 不存在终审人的状态下这里恢复为授权审批人
                        this.ctx.tender.info.shenpi.phasePay = shenpiConst.sp_status.sqspr;
                    }
                }
            }
        }

        async checkStageRelaPhasePay(stage) {
            if (this.ctx.stageRelaPhasePay !== undefined) return;

            const allPhase = await this.getAllPhasePay(stage.tid);
            for (const phase of allPhase) {
                if (phase.rela_stage.find(x => { return x.stage_id === stage.id; })) {
                    await this.doCheckPhase(phase);
                    this.ctx.stageRelaPhasePay = phase;
                    return;
                }
                const fs = this.ctx.helper._.orderBy(phase.rela_stage.filter(x => { return x.stage_order < stage.order; }), ['stage_order'], ['desc']);
                phase.maxRelaStageOrder = fs.length > 0 ? fs[0].stage_order : 0;
            }
            const fp = this.ctx.helper._.orderBy(allPhase.filter(x => { return x.maxRelaStageOrder > 0; }), ['maxRelaStageOrder'], ['desc']);
            this.ctx.stageRelaPhasePay = fp.length > 0 ? fp[0] : null;
        }
    }

    return PhasePay;
};