Calculation/app/middleware/material_check.js

'use strict';

/**
 *
 * @author EllisRan
 * @date
 * @version
 */

const status = require('../const/audit').material.status;
const shenpiConst = require('../const/shenpi');
const materialConst = require('../const/material');
const _ = require('lodash');

module.exports = options => {
    /**
     * 材料调差校验 中间件
     * 1. 读取材料调差数据
     * 2. 检验用户是否参与材料调差（不校验具体权限）
     *
     * 写入ctx.material数据
     * 其中:
     * material.auditors: 审批人列表(退回原报时，加载上一流程)
     * material.curAuditor: 当前审批人(未上报为空，审批通过 or 退回原报时，为空)
     * material.readonly: 登录人，是否可操作
     * material.curTimes: 当前登录人，操作、查阅数据times
     * material.curOrder: 当前登录人，操作、查阅数据order
     *
     * 该方法为通用方法，如需material其他数据，请在controller中查询
     *
     * @param {function} next - 中间件继续执行的方法
     * @return {void}
     */
    return function* materialCheck(next) {
        try {
            if (!this.session.sessionProject.page_show.openMaterial) {
                throw '该功能已关闭';
            }
            // 读取标段数据
            const materialOrder = parseInt(this.params.order);
            if (materialOrder <= 0) {
                throw '您访问的期不存在';
            }
            const material = yield this.service.material.getDataByCondition({
                tid: this.tender.id,
                order: materialOrder,
            });
            if (!material) {
                throw '材料调差期数据错误';
            }
            const openMaterialTax = this.session.sessionProject.page_show.openMaterialTax;
            if ((material.status === status.uncheck || material.status === status.checkNo) && material.material_tax !== openMaterialTax) {
                yield this.service.material.updateMaterialTax(material.id, openMaterialTax);
                material.material_tax = openMaterialTax;
            }
            // 读取原报、审核人数据
            material.auditors = yield this.service.materialAudit.getAuditors(material.id, material.times);
            // if (material.status > 1) {
            //     material.auditors2 === 2 ? material.auditors : (yield this.service.materialAudit.getAuditors(material.id, material.times - 1));
            // }
            material.curAuditor = yield this.service.materialAudit.getCurAuditor(material.id, material.times);

            // 权限相关
            // todo 校验权限 （标段参与人、分享）
            const accountId = this.session.sessionUser.accountId,
                auditorIds = _.map(material.auditors, 'aid'),
                shareIds = [];
            if (accountId === material.user_id) { // 原报
                // if (material.curAuditor) {
                //     material.readOnly = material.status === status.checking && material.curAuditor.user_id === accountId;
                // } else {
                //     material.readOnly = material.status !== status.uncheck && material.status !== status.checkNo;
                // }
                material.curTimes = material.times;
                if (material.status === status.uncheck || material.status === status.checkNo) {
                    material.curOrder = 0;
                } else if (material.status === status.checked) {
                    material.curOrder = _.max(_.map(material.auditors, 'order'));
                } else {
                    material.curOrder = material.curAuditor.aid === accountId ? material.curAuditor.order : material.curAuditor.order - 1;
                }
                material.filePermission = true;
            } else if (this.tender.isTourist) {
                material.curTimes = material.times;
                if (material.status === status.uncheck || material.status === status.checkNo) {
                    material.curOrder = 0;
                } else if (material.status === status.checked) {
                    material.curOrder = _.max(_.map(material.auditors, 'order'));
                } else {
                    material.curOrder = material.curAuditor.order;
                }
                material.filePermission = this.tender.touristPermission.file || auditorIds.indexOf(accountId) !== -1;
            } else if (auditorIds.indexOf(accountId) !== -1) { // 审批人
                if (material.status === status.uncheck) {
                    throw '您无权查看该数据';
                }
                // material.readOnly = material.status !== status.checking || accountId !== material.curAuditor.aid;
                material.curTimes = material.status === status.checkNo ? material.times - 1 : material.times;
                if (material.status === status.checked) {
                    material.curOrder = _.max(_.map(material.auditors, 'order'));
                } else if (material.status === status.checkNo) {
                    const audit = this.service.materialAudit.getDataByCondition({
                        mid: material.id, times: material.times, status: status.checkNo,
                    });
                    material.curOrder = audit.order;
                } else {
                    material.curOrder = accountId === material.curAuditor.aid ? material.curAuditor.order : material.curAuditor.order - 1;
                }
                material.filePermission = true;
            } else if (shareIds.indexOf(accountId) !== -1) { // 分享人
                if (material.status === status.uncheck) {
                    throw '您无权查看该数据';
                }
                // material.readOnly = true;
                material.curTimes = material.status === status.checkNo ? material.times - 1 : material.times;
                material.curOrder = material.status === status.checked ? _.max(_.map(material.auditors, 'order')) : material.curAuditor.order - 1;
                material.filePermission = false;
            } else if (this.session.sessionUser.is_admin) {
                material.curTimes = material.times;
                if (material.status === status.uncheck || material.status === status.checkNo) {
                    material.curOrder = 0;
                } else if (material.status === status.checked) {
                    material.curOrder = _.max(_.map(material.auditors, 'order'));
                } else {
                    material.curOrder = material.curAuditor.order;
                }
                material.filePermission = true;
            } else { // 其他不可见
                throw '您无权查看该数据';
            }

            // 获取最新的期
            material.highOrder = yield this.service.material.count({
                tid: this.tender.id,
            });
            // 调差的readOnly 指表格和页面只能看不能改，和审批无关
            material.readOnly = !(((material.status === status.uncheck || material.status === status.checkNo) && accountId === material.user_id)
                || (this.session.sessionProject.page_show.openMaterialEditForAudit && (material.status === status.checking || material.status === status.checkNoPre) && material.curAuditor.aid === accountId));
            material.editForAudit = this.session.sessionProject.page_show.openMaterialEditForAudit && (material.status === status.checking || material.status === status.checkNoPre) && material.curAuditor.aid === accountId;
            material.decimal = material.decimal ? JSON.parse(material.decimal) : materialConst.decimal;
            this.material = material;
            // 根据状态判断是否需要更新审批人列表
            if ((material.status === status.uncheck || material.status === status.checkNo) && this.tender.info.shenpi.material !== shenpiConst.sp_status.sqspr) {
                const shenpi_status = this.tender.info.shenpi.material;
                // 进一步比较审批流是否与审批流程设置的相同，不同则替换为固定审批流或固定的终审
                const auditList = yield this.service.materialAudit.getAllDataByCondition({ where: { mid: material.id, times: material.times }, orders: [['order', 'asc']] });
                const auditIdList = _.map(auditList, 'aid');
                if (shenpi_status === shenpiConst.sp_status.gdspl) {
                    const shenpiList = yield this.service.shenpiAudit.getAllDataByCondition({ where: { tid: material.tid, sp_type: shenpiConst.sp_type.material, sp_status: shenpi_status } });
                    const shenpiIdList = _.map(shenpiList, 'audit_id');
                    // 判断2个id数组是否相同，不同则删除原审批流，切换成固定的审批流
                    if (!_.isEqual(auditIdList, shenpiIdList)) {
                        yield this.service.materialAudit.updateNewAuditList(material, shenpiIdList);
                    }
                } else if (shenpi_status === shenpiConst.sp_status.gdzs) {
                    const shenpiInfo = yield this.service.shenpiAudit.getDataByCondition({ tid: material.tid, sp_type: shenpiConst.sp_type.material, sp_status: shenpi_status });
                    // 判断最后一个id是否与固定终审id相同，不同则删除原审批流中如果存在的id和添加终审
                    if (shenpiInfo && shenpiInfo.audit_id !== _.last(auditIdList)) {
                        yield this.service.materialAudit.updateLastAudit(material, auditList, shenpiInfo.audit_id);
                    } else if (!shenpiInfo) {
                        // 不存在终审人的状态下这里恢复为授权审批人
                        this.tender.info.shenpi.material = shenpiConst.sp_status.sqspr;
                    }
                }
            }
            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,
                }));
            }
            // 重定向值标段管理
            if (err === '您无权查看该数据') {
                this.tender ? this.redirect('/tender/' + this.tender.id + '/measure/material') : this.redirect('/list');
            }
            this.redirect(this.request.headers.referer);
        }
    };
};