Calculation/app/controller/ledger_audit_controller.js

'use strict';

/**
 *
 *
 * @author Mai
 * @date 2018/5/28
 * @version
 */
const auditConst = require('../const/audit').flow;
const spreadConst = require('../const/spread');

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

        /**
         * 台账审批页面(get)
         *
         * @param ctx
         * @returns {Promise<void>}
         */
        async index(ctx) {
            try {
                const renderData = {
                    tender: ctx.tender.data,
                    tenderMenu: this.menu.tenderMenu,
                    preUrl: '/tender/' + ctx.tender.id,
                };

                const curAuditor = await ctx.service.ledgerAudit.getCurAuditor(ctx.tender.id, ctx.tender.data.ledger_times);
                if (curAuditor && curAuditor.audit_id !== ctx.session.sessionUser.accountId) {
                    throw '审核信息错误';
                }

                const auditors = await ctx.service.ledgerAudit.getAuditors(ctx.tender.id, ctx.tender.data.ledger_times);
                const ledgerData = await ctx.service.ledger.getDataByTenderId(ctx.tender.id);
                const content = await ctx.service.ledgerAuditContent.getAllDataByCondition({
                    where: {
                        tender_id: ctx.tender.id,
                        times: ctx.tender.data.ledger_times,
                        audit_id: auditors[0].audit_id,
                    }
                });
                renderData.curAuditor = curAuditor;
                renderData.auditConst = auditConst;
                renderData.auditors = auditors;
                renderData.content = content;
                renderData.ledger = JSON.stringify(ledgerData);
                renderData.ledgerSpreadSetting = JSON.stringify(spreadConst.ledgerSpread);
                renderData.readOnly = true;
                await this.layout('ledger/audit.ejs', renderData, 'ledger/audit_modal.ejs');
            } catch(err) {
                this.log(err);
                ctx.redirect('/tender/'+ ctx.tender.id);
            }
        }

        /**
         * 新增审批人(Ajax)
         *
         * @param ctx
         * @returns {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 '参数错误';
                }

                const result = await ctx.service.ledgerAudit.addAuditor(ctx.tender.id, id);
                if (!result) {
                    throw '添加审核人失败';
                }

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

            ctx.body = responseData;
        }

        /**
         * 移除审批人(Ajax)
         *
         * @param ctx
         * @returns {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);
                if (!result) {
                    throw '移除审核人失败';
                }

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

            ctx.body = responseData;
        }

        /**
         * 上报(post)
         *
         * @param ctx
         * @returns {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.redirect('/tender/' + ctx.tender.id + '/ledger/explode');
            } catch (err) {
                this.log(err);
                ctx.session.postError = err.toString();
                ctx.redirect('/tender/' + ctx.tender.id + '/ledger/explode');
            }
        }

        /**
         * 审批(post)
         *
         * @param ctx
         * @returns {Promise<void>}
         */
        async check(ctx) {
            try {
                const tender = ctx.tender;
                if (!tender.data || tender.data.ledger_status !== auditConst.status.checking ) {
                    throw '当前标段数据有误';
                }
                const curAudit = await ctx.service.ledgerAudit.getCurAuditor(tender.id, tender.data.ledger_times);
                if (curAudit.audit_id !== ctx.session.sessionUser.accountId) {
                    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/explode');
            } catch (err) {
                this.log(err);
                ctx.session.postError = err.toString();
                ctx.redirect(ctx.request.header.referer);
            }
        }

        /**
         * 添加清单意见(Ajax)
         * @param ctx
         * @returns {Promise<void>}
         */
        async addContent(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: [],
            };
            try {
                const tender = ctx.tender;
                if (!tender.data || tender.data.ledger_status !== auditConst.status.checking ) {
                    throw '当前标段数据有误';
                }
                const curAudit = await ctx.service.ledgerAudit.getCurAuditor(tender.id, tender.data.ledger_times);
                if (curAudit.audit_id !== ctx.session.sessionUser.accountId) {
                    throw '添加清单意见失败';
                }
                const data = JSON.parse(ctx.request.body.data);

                await ctx.service.ledgerAuditContent.add(tender.data, curAudit.audit_id, data);
                responseData.data = await ctx.service.ledgerAuditContent.getAllDataByCondition({
                    where: {tender_id: tenderId, times: tender.data.ledger_times, audit_id: curAudit.audit_id}
                });
            } catch (err) {
                this.log(err);
                responseData.err = 1;
                responseData.msg = err.toString();
            }

            ctx.body = responseData;
        }

        /**
         * 获取审核人的全部清单意见
         * @param ctx
         * @returns {Promise<void>}
         */
        async getContent(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: [],
            };
            try {
                const data = JSON.parse(ctx.request.body.data);

                const times = ctx.tender.data.ledger_status === auditConst.status.checkNo ? ctx.tender.data.ledger_times - 1 : ctx.tender.data.ledger_times;
                responseData.data = await ctx.service.ledgerAuditContent.getAllDataByCondition({
                    where: {tender_id: ctx.tender.id, times: times, audit_id: data.audit_id}
                });
            } catch (err) {
                this.log(err);
                responseData.err = 1;
                responseData.msg = err.toString();
            }

            ctx.body = responseData;
        }
    }

    return LedgerAuditController;
};