Calculation/app/controller/ledger_audit_controller.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date 2018/5/28
 * @version
 */
const auditConst = require('../const/audit').ledger;
const shenpiConst = require('../const/shenpi');
const measureType = require('../const/tender').measureType;
const spreadSetting = require('../lib/spread_setting');
const stdConst = require('../const/standard');

module.exports = app => {
    class LedgerAuditController extends app.BaseController {
        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局context
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            ctx.showProject = true;
        }

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

                responseData.data = await ctx.service.ledgerAudit.getUserGroup(ctx.tender.id, ctx.tender.data.ledger_times);
            } catch (err) {
                responseData.err = 1;
                responseData.msg = err.toString();
            }

            ctx.body = responseData;
        }

        /**
         * 移除审批人(Ajax)
         *
         * @param ctx
         * @return {Promise<void>}
         */
        async remove(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: [],
            };
            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 result = await ctx.service.ledgerAudit.deleteAuditor(ctx.tender.id, id, ctx.tender.data.ledger_times);
                if (!result) {
                    throw '移除审核人失败';
                }

                responseData.data = await ctx.service.ledgerAudit.getAuditors(ctx.tender.id, ctx.tender.data.ledger_times);
            } catch (err) {
                responseData.err = 1;
                responseData.msg = err.toString();
            }

            ctx.body = responseData;
        }

        /**
         * 上报(post)
         *
         * @param ctx
         * @return {Promise<void>}
         */
        async start(ctx) {
            try {
                if (!ctx.tender.data || ctx.tender.data.ledger_status === auditConst.status.checking || ctx.tender.data.ledger_status === auditConst.status.checked) {
                    throw '标段数据有误';
                }
                if (ctx.tender.data.user_id !== ctx.session.sessionUser.accountId) {
                    throw '上报失败';
                }

                await ctx.service.ledgerAudit.start(ctx.tender.id, ctx.tender.data.ledger_times);

                ctx.body = { err: 0, msg: '', data: { url: '/tender/' + ctx.tender.id + '/ledger' } };
            } 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 tender = ctx.tender;
                if (!tender.data || tender.data.ledger_status !== auditConst.status.checking) {
                    throw '当前标段数据有误';
                }
                const curAudits = await ctx.service.ledgerAudit.getCurAuditors(tender.id, tender.data.ledger_times);
                const curAuditIds = curAudits.map(x => { return x.audit_id; });
                if (curAuditIds.indexOf(ctx.session.sessionUser.accountId) < 0) {
                    throw '审批失败';
                }
                const checkType = parseInt(ctx.request.body.checkType);
                if (!checkType || isNaN(checkType)) {
                    throw '提交数据错误';
                }

                await ctx.service.ledgerAudit.check(tender.id, checkType, ctx.request.body.opinion, tender.data.ledger_times);

                ctx.redirect('/tender/' + ctx.tender.id + '/ledger');
            } catch (err) {
                this.log(err);
                ctx.session.postError = err.toString();
                ctx.redirect(ctx.request.header.referer);
            }
        }

        /**
         * 重新审批(post)
         *
         * @param ctx
         * @return {Promise<void>}
         */
        async checkAgain(ctx) {
            try {
                const tender = ctx.tender;
                if (!tender.data || tender.data.ledger_status !== auditConst.status.checked) {
                    throw '当前标段数据有误';
                }
                const revise = await this.ctx.service.ledgerRevise.getLastestRevise(tender.id);
                if (revise) throw '当前标段存在台账修订，不可重新审批';
                const stage = await this.ctx.service.stage.getDataByCondition({ tid: tender.id });
                if (stage) throw '当前标段已开始计量，不可重新审批';

                await ctx.service.ledgerAudit.checkAgain(tender.id, tender.data.ledger_times);

                ctx.redirect('/tender/' + ctx.tender.id + '/ledger');
            } catch (err) {
                this.log(err);
                ctx.session.postError = err.toString();
                ctx.redirect(ctx.request.header.referer);
            }
        }

        async saveAudit(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                if (ctx.session.sessionUser.is_admin && ctx.tender.ledger_status !== auditConst.status.checked) {
                    await ctx.service.ledgerAudit.saveAudit(ctx.tender.id, ctx.tender.data.ledger_times, 0, data);
                    const auditorUniqs = await ctx.service.ledgerAudit.getUniqUserGroup(ctx.tender.id, ctx.tender.data.ledger_times);
                    const auditors = await ctx.service.ledgerAudit.getAuditors(ctx.tender.id, ctx.tender.data.ledger_times);
                    ctx.body = { err: 0, msg: '', data: { auditorUniqs, auditors } };
                } else {
                    throw '您无权进行该操作';
                }
            } catch (err) {
                this.log(err);
                // ctx.session.postError = err.toString();
                // ctx.redirect(ctx.request.header.referer);
                ctx.body = {
                    err: 1,
                    // url: ctx.request.header.referer,
                    msg: err,
                };
            }
        }
    }

    return LedgerAuditController;
};