Calculation/app/controller/advance_controller.js

'use strict'
const accountGroup = require('../const/account_group').group
const auditConst = require('../const/audit').advance

module.exports = app => {
    class advanceController extends app.BaseController {
        /**
         * 开工预付款页面(AJAX) GET
         * @param {Object} ctx 全局上下文
         */
        async index(ctx) {
            const type = auditConst.type.start
            const advanceList = await ctx.service.advance.getAdvanceList(ctx.tender.id, type)
            const latestOrder = await ctx.service.advance.getLastestAdvance(ctx.tender.id, type, true)
            const renderData = {
                type,
                advanceList,
                latestOrder,
                auditConst,
                preUrl: `/tender/${ctx.tender.id}/advance/${type}/create`,
                jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.advance.main),
                advancePayTotal: ctx.tender.info.deal_param.startAdvance
            }
            await this.layout('advance/index.ejs', renderData, 'advance/modal.ejs')
        }

        /**
         * 材料预付款页面(AJAX) GET
         * @param {Object} ctx 全局上下文
         */
        async materialList(ctx) {
            const type = auditConst.type.material
            const advanceList = await ctx.service.advance.getAdvanceList(ctx.tender.id, type)
            const latestOrder = await ctx.service.advance.getLastestAdvance(ctx.tender.id, type, true)
            const renderData = {
                type,
                advanceList,
                latestOrder,
                auditConst,
                preUrl: `/tender/${ctx.tender.id}/advance/${type}/create`,
                jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.advance.main),
                advancePayTotal: ctx.tender.info.deal_param.materialAdvance
            }
            await this.layout('advance/index.ejs', renderData, 'advance/modal.ejs')
        }

        /**
         * 获取通用的renderData（用于layout, Menu, subMenu部分）
         * @param {Object} ctx 全局上下文
         * @return {{auditConst, jsFiles, accountGroup?, accountList?, auditors, auditHistory, preUrl}}
         * @private
         */
        async _getDefaultRenderData(ctx) {
            const data = {
                auditConst,
                jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.advance.info),
                preUrl: `/tender/${ctx.tender.id}/advance/${ctx.advance.id}`
            }
            // 获取所有项目参与者
            if ((ctx.advance.status === auditConst.status.uncheck || ctx.advance.status === auditConst.status.checkNo) && ctx.session.sessionUser.accountId === ctx.advance.uid) {
                data.accountGroup = accountGroup
                // 获取所有项目参与者
                const accountList = await ctx.service.projectAccount.getAllDataByCondition({
                    where: { project_id: ctx.session.sessionProject.id, enable: 1 },
                    columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group']
                })
                data.accountList = accountList
            }
            // 获取审核人左边列表
            data.auditors = await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, ctx.advance.times)
            // 获取审批流程中右边列表
            const auditHistory = []
            const times = ctx.advance.status === auditConst.status.checkNo ? ctx.advance.times - 1 : ctx.advance.times
            if (times >= 1) {
                for (let i = 1; i <= times; i++) {
                    auditHistory.push(await ctx.service.advanceAudit.getAuditors(ctx.advance.id, i))
                }
            }
            data.auditHistory = auditHistory
            return data
        }

        /**
         * 预付款详情页(AJAX) GET
         * @param {Object} ctx 全局上下文
         */
        async detail(ctx) {
            const advancePayTotal = ctx.advance.type === 0 ? ctx.tender.info.deal_param.startAdvance : ctx.tender.info.deal_param.materialAdvance
            try {
                const renderData = await this._getDefaultRenderData(ctx)
                const { uncheck, checkNo } = auditConst.status
                const { status } = ctx.advance
                // 获取上一期预付款记录
                const prevAdvance = await ctx.service.advance.getPreviousRecord(ctx.tender.id, ctx.advance.type)
                renderData.isEdited = status === uncheck || status === checkNo
                renderData.advance = ctx.advance
                renderData.advancePayTotal = advancePayTotal
                renderData.prevAdvance = prevAdvance
                await this.layout('advance/detail.ejs', renderData, 'advance/modal_audit.ejs')
            } catch (error) {
                this.log(error)
                ctx.redirect('/tender/' + ctx.tender.id + '/advance')
            }
        }

        /**
         * 添加新一期
         * @param {Object} ctx 全局上下文
         */
        async create(ctx) {
            const response = { err: 0, msg: '', data: {} }
            const type = parseInt(ctx.params.type)
            try {
                const record = await ctx.service.advance.createRecord(type)
                response.data = record
            } catch (error) {
                response.err = 1
                response.msg = error
            }
            ctx.body = response
        }

        /**
         * 添加审批人
         * @param {Object} ctx 全局上下文
         */
        async addAudit(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data)
                const audit_id = data && this.app._.toInteger(data.auditorId)
                if (isNaN(audit_id) || audit_id <= 0) {
                    throw '参数错误'
                }
                // 检查权限等
                if (ctx.advance.uid !== ctx.session.sessionUser.accountId) {
                    throw '您无权添加审核人'
                }
                if (ctx.advance.status === auditConst.status.checking || ctx.advance.status === auditConst.status.checked) {
                    throw '当前不允许添加审核人'
                }
                // 检查审核人是否已存在
                const exist = this.app._.find(ctx.advance.auditors, { audit_id })
                if (exist) {
                    throw '该审核人已存在，请勿重复添加'
                }

                const result = await ctx.service.advanceAudit.addAuditor(ctx.advance.id, audit_id, ctx.advance.times)
                if (!result) {
                    throw '添加审核人失败'
                }

                const audit = await ctx.service.advanceAudit.getAuditor(ctx.advance.id, audit_id, ctx.advance.times)
                ctx.body = { err: 0, msg: '', data: audit }
            } catch (err) {
                this.log(err)
                ctx.body = { err: 1, msg: err.toString(), data: null }
            }
        }
        /**
         * 移除审批人
         * @param {Object} ctx 全局上下文
         */
        async deleteAudit(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data)
                const id = data && data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId)
                if (isNaN(id) || id <= 0) {
                    throw '参数错误'
                }

                const result = await ctx.service.advanceAudit.deleteAuditor(ctx.advance.id, id, ctx.advance.times)
                if (!result) {
                    throw '移除审核人失败'
                }

                const auditors = await ctx.service.advanceAudit.getAuditGroupByList(ctx.advance.id, ctx.advance.times)
                ctx.body = { err: 0, msg: '', data: auditors }
            } catch (err) {
                ctx.body = { err: 1, msg: err.toString(), data: null }
            }
        }

        /**
         * 上报审批
         * @param {Object} ctx 全局上下文
         */
        async start(ctx) {
            const data = JSON.parse(ctx.request.body.data)
            try {
                // 检查权限等
                if (!ctx.advance) {
                    throw '数据错误'
                }
                if (ctx.advance.uid !== ctx.session.sessionUser.accountId) {
                    throw '您无权上报该期数据'
                }
                if (ctx.advance.status === auditConst.status.checking || ctx.advance.status === auditConst.status.checked) {
                    throw '该预付款期数据当前无法上报'
                }
                await ctx.service.advanceAudit.start(ctx.advance.id, ctx.advance.times, data)
                ctx.body = { err: 0, msg: '' }
            } catch (error) {
                this.log(error)
                ctx.session.postError = error.toString()
                ctx.body = { err: 1, msg: error.toString() }
            }
        }

        /**
         * 审批
         * @param {Object} ctx 全局上下文
         */
        async checkAudit(ctx) {
            try {
                if (!ctx.advance || ctx.advance.status !== auditConst.status.checking) {
                    throw '当前材料调差期数据有误'
                }
                if (!ctx.advance.curAuditor || ctx.advance.curAuditor.audit_id !== ctx.session.sessionUser.accountId) {
                    throw '您无权进行该操作'
                }
                const data = {
                    checkType: parseInt(ctx.request.body.checkType),
                    opinion: ctx.request.body.opinion
                }
                if (!data.checkType || isNaN(data.checkType)) {
                    throw '提交数据错误'
                }
                if (data.checkType === auditConst.status.checkNo) {
                    if (!data.checkType || isNaN(data.checkType)) {
                        throw '提交数据错误'
                    }
                }

                await ctx.service.advanceAudit.check(ctx.advance.id, data, ctx.advance.times)

                ctx.redirect(ctx.request.header.referer)
            } catch (err) {
                this.log(err)
                ctx.session.postError = err.toString()
                ctx.redirect(ctx.request.header.referer)
            }
        }
    }
    return advanceController
}