Calculation/app/controller/wap_controller.js

'use strict';

/**
 * 登录页面控制器
 *
 * @author CaiAoLin
 * @date 2017/11/15
 * @version
 */
const URL = require('url');
const maintainConst = require('../const/maintain');
const auditConst = require('../const/audit');
const changeConst = require('../const/change');

module.exports = app => {

    class WapController extends app.BaseController {

        /**
         * 登录页面
         *
         * @param {Object} ctx - egg全局页面
         * @return {void}
         */
        async index(ctx) {
            if (!ctx.helper.isMobile(ctx.request.header['user-agent'])) {
                ctx.redirect('/');
                return;
            }
            const errorMessage = ctx.session.loginError;
            // 显示完删除
            ctx.session.loginError = null;
            // 获取系统维护信息
            const maintainData = await ctx.service.maintain.getDataById(1);

            if (!ctx.app.config.is_debug) {
                await ctx.service.maintain.syncMaintainData();
            }
            let projectData = '';
            if (ctx.session.wapTenderID) {
                const tenderData = await ctx.service.tender.getDataById(ctx.session.wapTenderID);
                if (tenderData) projectData = await ctx.service.project.getDataById(tenderData.project_id);
            }

            const renderData = {
                maintainData,
                maintainConst,
                errorMessage,
                projectData,
            };
            await ctx.render('wap/login.ejs', renderData);
        }

        /**
         * 登录操作
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async login(ctx) {
            let loginType = ctx.request.body.type;
            try {
                loginType = parseInt(loginType);
                const result = await ctx.service.projectAccount.accountLogin(ctx.request.body, loginType);

                if (!result) {
                    throw '用户名或密码错误';
                }

                if (result === 2) {
                    throw '该账号已被停用，请联系销售人员';
                }

                // 调用 rotateCsrfSecret 刷新用户的 CSRF token
                ctx.rotateCsrfSecret();

                // 判断是否已经有对应用户信息，没有则跳转初始化页面
                const needBoot = await ctx.service.customer.isNeedBoot(ctx.request.body);
                const url = needBoot ? '/boot' : '/wap/dashboard';

                const query = URL.parse(ctx.request.header.referer, true).query;
                let referer = '';
                if (ctx.session.wapTenderID) {
                    referer = query.referer ? query.referer + '#shenpi' : url;
                    ctx.session.wapTenderID = null;
                }
                ctx.redirect(referer ? referer : url);
            } catch (error) {
                this.log(error);
                ctx.session.loginError = error;
                ctx.redirect('/wap');
            }
        }

        /**
         * 退出登录
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async logout(ctx) {
            // 删除session并跳转
            ctx.session = null;
            ctx.redirect('/wap');
        }


        /**
         * 待办页
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async dashboard(ctx) {
            // 获取待审批的期
            const auditStages = await ctx.service.stageAudit.getAuditStageByWap(ctx.session.sessionUser.accountId);
            for (const audit of auditStages) {
                await this.ctx.service.stage.checkStageGatherData(audit);
                audit.gather_tp = ctx.helper.add(audit.contract_tp, audit.qc_tp);
                audit.end_contract_tp = ctx.helper.add(audit.contract_tp, audit.pre_contract_tp);
                audit.end_qc_tp = ctx.helper.add(audit.qc_tp, audit.pre_qc_tp);
                audit.end_gather_tp = ctx.helper.add(audit.end_contract_tp, audit.end_qc_tp);
                audit.pre_gather_tp = ctx.helper.add(audit.pre_contract_tp, audit.pre_qc_tp);
            }
            // 获取待审批的变更期
            const auditChanges = await ctx.service.changeAudit.getAuditChangeByWap(ctx.session.sessionUser.accountId);
            const renderData = {
                auditStages,
                auditChanges,
                changeConst,
                tpUnit: 2,
            };
            await ctx.render('wap/dashboard.ejs', renderData);
        }

        /**
         * 标段列表页
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async list(ctx) {
            try {
                // 获取用户新建标段权利
                const accountInfo = await this.ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
                const userPermission = accountInfo !== undefined && accountInfo.permission !== '' ? JSON.parse(accountInfo.permission) : null;

                const tenderList = await this.ctx.service.tender.getList('', userPermission);
                for (const t of tenderList) {
                    this.ctx.query_tender = t;
                    if (t.user_id === this.ctx.session.sessionUser.accountId && (
                        t.ledger_status === auditConst.ledger.status.checkNo || t.ledger_status === auditConst.ledger.status.uncheck)) {
                        const sum = await this.ctx.service.ledger.addUp({tender_id: t.id/*, is_leaf: true*/});
                        t.total_price = sum.total_price;
                        t.deal_tp = sum.deal_tp;
                    }
                    if (t.ledger_status === auditConst.ledger.status.checked) {
                        t.lastStage = await this.ctx.service.stage.getLastestStage(t.id, true);

                        if (!t.lastStage) continue;
                        if (t.lastStage.status === auditConst.stage.status.uncheck && t.lastStage.user_id !== this.ctx.session.sessionUser.accountId) {
                            t.lastStage = await this.ctx.service.stage.getLastestStage(t.id);
                        }

                        if (!t.lastStage) continue;
                        await this.ctx.service.stage.checkStageGatherData(t.lastStage);
                    }
                }
                this.ctx.query_tender = null;
                const categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
                const valuations = await this.ctx.service.valuation.getProjectValidValuation(this.ctx.session.sessionProject.id);
                const renderData = {
                    tenderList,
                    categoryData,
                    auditConst,
                    userPermission,
                    valuations,
                    uid: this.ctx.session.sessionUser.accountId,
                    pid: this.ctx.session.sessionProject.id,
                };
                await ctx.render('wap/list.ejs', renderData);
            } catch (err) {
                this.log(err);
                this.ctx.redirect('/wap/dashboard');
            }
        }

        /**
         * 标段详细页
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async tender(ctx) {
            try {
                const tender = ctx.tender.data;
                if (tender.user_id === this.ctx.session.sessionUser.accountId && (
                    tender.ledger_status === auditConst.ledger.status.checkNo || tender.ledger_status === auditConst.ledger.status.uncheck)) {
                    const sum = await this.ctx.service.ledger.addUp({tender_id: tender.id/*, is_leaf: true*/});
                    tender.total_price = sum.total_price;
                    tender.deal_tp = sum.deal_tp;
                }
                const stages = await ctx.service.stage.getValidStages(ctx.tender.id);
                const lastStage = stages.length > 0 ? stages[0] : null; //await ctx.service.stage.getLastestStage(ctx.tender.id);
                if (lastStage) {
                    await this.ctx.service.stage.checkStageGatherData(lastStage);
                    tender.gather_tp = ctx.helper.add(lastStage.contract_tp, lastStage.qc_tp);
                    tender.end_contract_tp = ctx.helper.add(lastStage.contract_tp, lastStage.pre_contract_tp);
                    tender.end_qc_tp = ctx.helper.add(lastStage.qc_tp, lastStage.pre_qc_tp);
                    tender.end_gather_tp = ctx.helper.add(tender.end_contract_tp, tender.end_qc_tp);
                    tender.pre_gather_tp = ctx.helper.add(lastStage.pre_contract_tp, lastStage.pre_qc_tp);
                    tender.yf_tp = lastStage.yf_tp;
                    tender.qc_ratio = ctx.helper.mul(ctx.helper.div(tender.end_qc_tp, ctx.tender.info.deal_param.contractPrice, 2), 100);
                    tender.sum = ctx.helper.add(tender.total_price, tender.end_qc_tp);
                    tender.pre_ratio = ctx.helper.mul(ctx.helper.div(tender.pre_gather_tp, tender.sum, 2), 100);
                    tender.cur_ratio = ctx.helper.mul(ctx.helper.div(tender.gather_tp, tender.sum, 2), 100);
                    tender.other_tp = ctx.helper.sub(ctx.helper.sub(tender.sum, tender.pre_gather_tp), tender.gather_tp);
                    tender.other_ratio = Math.max(0, 100 - tender.pre_ratio - tender.cur_ratio);
                }
                const monthProgress = [];
                for (const s of stages) {
                    if (s.s_time) {
                        let progress = monthProgress.find(function(x) {
                            return x.month === s.s_time;
                        });
                        if (!progress) {
                            progress = { month: s.s_time };
                            monthProgress.push(progress);
                        }
                        progress.tp = ctx.helper.add(ctx.helper.add(progress.tp, s.contract_tp), s.qc_tp);
                    }
                }
                monthProgress.sort(function(x, y) {
                    return Date.parse(x.month) - Date.parse(y.month);
                });
                let sum = 0;
                for (const p of monthProgress) {
                    p.ratio = ctx.helper.mul(ctx.helper.div(p.tp, tender.sum, 4), 100);
                    sum = ctx.helper.add(sum, p.tp);
                    p.end_tp = sum;
                    p.end_ratio = ctx.helper.mul(ctx.helper.div(p.end_tp, tender.sum, 4), 100);
                }

                // 变更令列表
                const changes = await ctx.service.change.getListByStatus(tender.id, 0, 0);

                for (const c of changes) {
                    c.curAuditor = await ctx.service.changeAudit.getLastUser(c.cid, c.times);
                }

                const renderData = {
                    tender,
                    stages,
                    changes,
                    auditConst: auditConst.stage,
                    auditChangeConst: auditConst.flow,
                    changeConst,
                    tpUnit: ctx.tender.info.decimal.tp,
                    monthProgress,
                    stagesEcharts: JSON.parse(JSON.stringify(stages)).reverse(),
                };
                if (stages.length > 0) {
                    for (const s of stages) {
                        // s.curAuditor = null;
                        // 根据期状态返回展示用户
                        s.curAuditor = await ctx.service.stageAudit.getAuditorByStatus(s.id, s.status, s.times);
                        if (s.status === auditConst.stage.status.checkNoPre) {
                            s.curAuditor2 = await ctx.service.stageAudit.getAuditorByStatus(s.id, auditConst.stage.status.checking);
                        }
                    }
                    renderData.stage = stages[0];
                    const times = renderData.stage.status === auditConst.stage.status.checkNo ? renderData.stage.times - 1 : renderData.stage.times;
                    renderData.stage.user = await ctx.service.projectAccount.getAccountInfoById(renderData.stage.user_id);
                    renderData.stage.auditors = await ctx.service.stageAudit.getAuditors(renderData.stage.id, times);
                    // 获取审批流程中左边列表
                    renderData.stage.auditors2 = await ctx.service.stageAudit.getAuditGroupByList(renderData.stage.id, times);
                }
                await ctx.render('wap/tender.ejs', renderData);
            } catch (err) {
                this.log(err);
                ctx.redirect('/wap/list');
            }
        }

        /**
         * 期审批详细页
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async stage(ctx) {
            try {
                const tender = ctx.tender.data;
                const stages = await ctx.service.stage.getValidStages(ctx.tender.id);
                const lastStage = stages.length > 0 ? stages[0] : null;
                if (lastStage) {
                    await this.ctx.service.stage.checkStageGatherData(lastStage);
                }
                const stage = lastStage;
                const renderData = {
                    tender,
                    stage,
                    auditConst: auditConst.stage,
                };
                const times = renderData.stage.status === auditConst.stage.status.checkNo ? renderData.stage.times - 1 : renderData.stage.times;
                renderData.stage.user = await ctx.service.projectAccount.getAccountInfoById(renderData.stage.user_id);
                renderData.stage.auditors = await ctx.service.stageAudit.getAuditors(renderData.stage.id, times);
                // 获取审批流程中左边列表
                renderData.stage.auditors2 = await ctx.service.stageAudit.getAuditGroupByList(renderData.stage.id, times);
                await ctx.render('wap/shenpi_stage.ejs', renderData);
            } catch (err) {
                this.log(err);
                ctx.redirect('/wap/list');
            }
        }

        /**
         * 变更审批详细页
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async change(ctx) {
            try {
                const tender = ctx.tender.data;
                const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });
                const times = change.status !== auditConst.flow.status.back ? change.times : change.times - 1;
                const auditList = await ctx.service.changeAudit.getListOrderByTimes(change.cid, times);
                const auditGroupList = await ctx.service.changeAudit.getListGroupByTimes(change.cid, times);
                const renderData = {
                    tender,
                    change,
                    auditList,
                    auditGroupList,
                    auditConst: auditConst.flow,
                    changeConst,
                    tpUnit: ctx.tender.info.decimal.tp,
                };
                await ctx.render('wap/shenpi_change.ejs', renderData);
            } catch (err) {
                this.log(err);
                ctx.redirect('/wap/list');
            }
        }

        /**
         * 变更令审批
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async changeApproval(ctx) {
            try {
                const changeData = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.change_id });
                if (!changeData) {
                    throw '变更令数据错误';
                }
                const status = parseInt(ctx.request.body.status);
                const pid = this.ctx.session.sessionProject.id;
                let result = false;
                switch (status) {
                    case 3:// 审批通过
                        // 获取前一个人的list，生成bills_list
                        // 获取已选清单
                        const changeList = await ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: ctx.request.body.change_id } });
                        const bills_array = [];
                        for (const cl of changeList) {
                            const bill = cl.id + '_' + cl.spamount;
                            bills_array.push(bill);
                        }
                        const postData = ctx.request.body;
                        postData.bills_list = bills_array.join(',');
                        result = await ctx.service.change.approvalSuccess(pid, ctx.request.body, changeData);
                        break;
                    case 4:// 审批终止
                        result = await ctx.service.change.approvalStop(ctx.request.body);
                        break;
                    case 5:// 审批退回到原报人
                        result = await ctx.service.change.approvalBack(pid, ctx.request.body, changeData);
                        break;
                    case 6:// 审批退回到上一个审批人
                        result = await ctx.service.change.approvalBackNew(pid, ctx.request.body, changeData);
                        break;
                    default:break;
                }
                if (!result) {
                    throw '审批失败';
                }
                ctx.redirect(ctx.request.header.referer);
            } catch (err) {
                console.log(err);
                ctx.redirect(ctx.request.header.referer);
            }
        }
    }

    return WapController;
};