Calculation/app/middleware/change_plan_check.js

'use strict';

/**
 *
 *
 * @author Ellisran
 * @date 2020/10/15
 * @version
 */

const status = require('../const/audit').changeApply.status;
const _ = require('lodash');

module.exports = options => {
    /**
     * 标段校验 中间件
     * 1. 读取标段数据（包括属性）
     * 2. 检验用户是否可见标段（不校验具体权限）
     *
     * @param {function} next - 中间件继续执行的方法
     * @return {void}
     */
    return function* changePlanCheck(next) {
        try {
            // 获取revise
            if (!this.session.sessionProject.page_show.openChangePlan) {
                throw '该功能已关闭';
            }
            const cpid = this.params.cpid || this.request.body.cpid;
            if (!cpid) {
                throw '您访问的变更方案不存在';
            }
            const change = yield this.service.changePlan.getDataById(cpid);
            // 读取原报、审核人数据
            change.auditors = yield this.service.changePlanAudit.getAuditors(change.id, change.times);
            change.curAuditor = yield this.service.changePlanAudit.getCurAuditor(change.id, change.times);

            if (!change) throw '变更令数据有误';
            // 权限相关
            // todo 校验权限 （标段参与人、分享）
            const accountId = this.session.sessionUser.accountId,
                auditorIds = _.map(change.auditors, 'aid'),
                shareIds = [];
            if (accountId === change.uid) { // 原报
                // if (change.curAuditor) {
                //     change.readOnly = change.status === status.checking && change.curAuditor.user_id === accountId;
                // } else {
                //     change.readOnly = change.status !== status.uncheck && change.status !== status.back;
                // }
                change.curTimes = change.times;
                if (change.status === status.uncheck || change.status === status.checkNo) {
                    change.curOrder = 0;
                } else if (change.status === status.checked) {
                    change.curOrder = _.max(_.map(change.auditors, 'order'));
                } else {
                    change.curOrder = change.curAuditor.aid === accountId ? change.curAuditor.order : change.curAuditor.order - 1;
                }
                change.filePermission = true;
            } else if (this.tender.isTourist) {
                change.curTimes = change.times;
                if (change.status === status.uncheck || change.status === status.checkNo) {
                    change.curOrder = 0;
                } else if (change.status === status.checked) {
                    change.curOrder = _.max(_.map(change.auditors, 'order'));
                } else {
                    change.curOrder = change.curAuditor.order;
                }
                change.filePermission = this.tender.touristPermission.file || auditorIds.indexOf(accountId) !== -1;
            } else if (auditorIds.indexOf(accountId) !== -1) { // 审批人
                if (change.status === status.uncheck) {
                    throw '您无权查看该数据';
                }
                // change.readOnly = change.status !== status.checking || accountId !== change.curAuditor.aid;
                change.curTimes = change.status === status.checkNo ? change.times - 1 : change.times;
                if (change.status === status.checked) {
                    change.curOrder = _.max(_.map(change.auditors, 'order'));
                } else if (change.status === status.checkNo) {
                    const audit = this.service.changePlanAudit.getDataByCondition({
                        cpid: change.id, times: change.times, status: status.checkNo,
                    });
                    change.curOrder = audit.order;
                } else {
                    change.curOrder = accountId === change.curAuditor.aid ? change.curAuditor.order : change.curAuditor.order - 1;
                }
                change.filePermission = true;
            } else if (shareIds.indexOf(accountId) !== -1) { // 分享人
                if (change.status === status.uncheck) {
                    throw '您无权查看该数据';
                }
                // change.readOnly = true;
                change.curTimes = change.status === status.checkNo ? change.times - 1 : change.times;
                change.curOrder = change.status === status.checked ? _.max(_.map(change.auditors, 'order')) : change.curAuditor.order - 1;
                change.filePermission = false;
            } else { // 其他不可见
                throw '您无权查看该数据';
            }
            // 调差的readOnly 指表格和页面只能看不能改，和审批无关
            change.readOnly = !((change.status === status.uncheck || change.status === status.checkNo) && accountId === change.uid);
            change.shenpiPower = change.status === status.checking && change.curAuditor.aid === accountId;
            this.change = change;
            yield next;
        } catch (err) {
            console.log(err);
            // 输出错误到日志
            if (err.stack) {
                this.logger.error(err);
            } else {
                this.getLogger('fail').info(JSON.stringify({
                    error: err,
                    project: this.session.sessionProject,
                    user: this.session.sessionUser,
                    body: this.session.body,
                }));
            }
            // 重定向值标段管理
            this.redirect(this.request.headers.referer);
        }
    };
};