Calculation/app/middleware/tender_check.js

'use strict';

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

const auditConst = require('../const/audit').ledger;
const messageType = require('../const/message_type');

module.exports = options => {
    /**
     * 标段校验 中间件
     * 1. 读取标段数据（包括属性）
     * 2. 检验用户是否可见标段（不校验具体权限）
     *
     * @param {function} next - 中间件继续执行的方法
     * @return {void}
     */
    return function* tenderCheck(next) {
        try {
            // 读取标段数据
            const tender = { id: parseInt(this.params.id), };
            if (!tender.id) {
                throw '当前未打开标段';
            }
            tender.data = yield this.service.tender.getTender(tender.id);
            if (!tender.data) {
                throw '标段数据错误';
            }
            if (!tender.data.measure_type) {
                throw '请先选择计量模式';
            }
            tender.info = yield this.service.tenderInfo.getTenderInfo(tender.id);
            if (!tender.data.ledger_status) {
                tender.data.ledger_status = auditConst.status.uncheck;
            }
            tender.auditLedgerConst = auditConst;
            if (!tender.data.ledger_times) {
                tender.data.ledger_times = 1;
            }
            if (tender.data.project_id !== this.session.sessionProject.id) {
                throw '您无权查看该项目';
            } else {
                const accountId = this.session.sessionUser.accountId;
                if (tender.data.ledger_status === auditConst.status.uncheck) {
                    if (tender.data.user_id !== accountId) {
                        throw '您无权查看该项目';
                    }
                } else {
                    const times = tender.data.ledger_status === auditConst.status.checkNo ? tender.data.ledger_times - 1 : tender.data.ledger_times;
                    const auditors = yield this.service.ledgerAudit.getAuditors(tender.id, times);
                    const auditorsId = this.helper._.map(auditors, 'audit_id');
                    const stageAuditors = yield this.service.stageAudit.getAllAuditors(tender.id);
                    const stageAUditorsId = this.helper._.map(stageAuditors, 'aid');
                    const tenderPermission = this.session.sessionUser.permission ? this.session.sessionUser.permission.tender : null;
                    if (auditorsId.indexOf(accountId) === -1 && tender.data.user_id !== accountId &&
                        (tenderPermission === null || tenderPermission === undefined || tenderPermission.indexOf('2') === -1) &&
                        stageAUditorsId.indexOf(accountId) === -1) {
                        throw '您无权查看该项目';
                    }
                }
            }
            tender.ledgerReadOnly = this.session.sessionUser.accountId !== tender.data.user_id ||
                tender.data.ledger_status === auditConst.status.checking || tender.data.ledger_status === auditConst.status.checked;
            this.tender = tender;
            yield next;
        } catch (err) {
            // 输出错误到日志
            if (err.stack) {
                this.logger.error(err);
            } else {
                this.session.message = {
                    type: messageType.ERROR,
                    icon: 'exclamation-circle',
                    message: err,
                };
                this.getLogger('fail').info(JSON.stringify({
                    error: err,
                    project: this.session.sessionProject,
                    user: this.session.sessionUser,
                    body: this.session.body,
                }));
            }
            // 重定向值标段管理
            this.redirect('/list');
        }
    };
};