Calculation/app/controller/material_controller.js

'use strict';

/**
 *
 *
 * @author EllisRan
 * @date 2018/6/20
 * @version
 */

const moment = require('moment');
const auditConst = require('../const/audit').material;
const auditStageConst = require('../const/audit').stage;
const tenderConst = require('../const/tender');
const measureType = tenderConst.measureType;
const accountGroup = require('../const/account_group').group;
const materialConst = require('../const/material');
const MaterialCalculator = require('../lib/material_calc');

module.exports = app => {
    class MaterialController extends app.BaseController {
        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            ctx.showProject = true;
            ctx.showTender = true;
            ctx.showTitle = 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,
                    auditConst,
                    auditConst2: JSON.stringify(auditConst),
                };
                renderData.materials = await ctx.service.material.getValidMaterials(ctx.tender.id);
                // 获取未选中和已完成的计量期
                const stages = await ctx.service.stage.getAllDataByCondition({ where: { tid: ctx.tender.id, status: auditStageConst.status.checked } });
                for (const s of renderData.materials) {
                    // s.curAuditor = null;
                    // 根据期状态返回展示用户
                    s.curAuditor = await ctx.service.materialAudit.getAuditorByStatus(s.id, s.status, s.times);
                    const materialStageList = s.stage_id.split(',');
                    for (const ms of materialStageList) {
                        const index = stages.findIndex(function(item) {
                            return item.id === parseInt(ms);
                        });
                        stages.splice(index, 1);
                    }
                }
                renderData.stages = stages;
                await this.layout('material/index.ejs', renderData, 'material/modal.ejs');
            } catch (err) {
                this.log(err);
                ctx.redirect(this.menu.menu.dashboard.url);
            }
        }

        /**
         * 期审批流程(Get)
         * @param ctx
         * @returns {Promise<void>}
         */
        async materialAuditors(ctx) {
            try {
                const responseData = {
                    err: 0, msg: '', data: {},
                };
                const order = JSON.parse(ctx.request.body.data).order;
                const tenderId = ctx.params.id;
                const materialInfo = await ctx.service.material.getDataByCondition({ tid: tenderId, order });
                // 获取审批流程中右边列表
                const auditHistory = [];
                const times = materialInfo.status === auditConst.status.checkNo ? materialInfo.times - 1 : materialInfo.times;
                if (times >= 1) {
                    for (let i = 1; i <= times; i++) {
                        auditHistory.push(await ctx.service.materialAudit.getAuditors(materialInfo.id, i));
                    }
                }
                responseData.data.auditHistory = auditHistory;
                // 获取审批流程中左边列表
                responseData.data.auditors = await ctx.service.materialAudit.getAuditGroupByList(materialInfo.id, times);
                // 获取原报信息
                const materialAuditor = await ctx.service.projectAccount.getAccountInfoById(materialInfo.user_id);
                responseData.data.materialAuditor = materialAuditor;
                ctx.body = responseData;
            } catch (error) {
                this.log(error);
                ctx.body = { err: 1, msg: error.toString(), data: null };
            }
        }

        /**
         * 新增期(Post)
         * @param ctx
         * @returns {Promise<void>}
         */
        async add(ctx) {
            try {
                if (ctx.session.sessionUser.accountId !== ctx.tender.data.user_id) {
                    throw '您无权创建材料调差期';
                }
                const data = ctx.request.body;
                if (data.s_order === '') {
                    throw '没有选中计量期';
                }
                const newMaterial = await ctx.service.material.addMaterial(ctx.tender.id, data);
                if (!newMaterial) {
                    throw '新增材料调差期失败，请重试';
                }
                ctx.redirect('/tender/' + ctx.tender.id + '/measure/material/' + newMaterial.order);
            } catch (err) {
                this.log(err);
                ctx.redirect(ctx.request.header.referer);
            }
        }

        /**
         * 删除期(Post)
         * @param ctx
         * @returns {Promise<void>}
         */
        async delete(ctx) {
            try {
                const material_id = ctx.request.body.material_id;
                const materialInfo = await ctx.service.material.getDataById(material_id);
                // 获取最新的期数
                const material_highOrder = await ctx.service.material.count({
                    tid: ctx.tender.id,
                });
                if (materialInfo === undefined || ctx.session.sessionUser.accountId !== materialInfo.user_id || material_highOrder !== materialInfo.order) {
                    throw '您无权删除材料调差期';
                }
                const result = await ctx.service.material.deleteMaterial(material_id);
                if (!result) {
                    throw '删除材料调差期失败，请重试';
                }
                ctx.redirect('/tender/' + ctx.tender.id + '/measure/material/');
            } catch (err) {
                this.log(err);
                console.log(err);
                ctx.redirect(ctx.request.header.referer);
            }
        }

        /**
         * 获取通用的renderData（用于layout, Menu, subMenu部分）
         * @param ctx
         * @returns {{tender, tenderMenu, auditConst}}
         * @private
         */
        async _getDefaultRenderData(ctx) {
            const data = {
                tender: ctx.tender.data,
                tenderMenu: JSON.parse(JSON.stringify(this.menu.stageMenu)),
                auditConst,
                measureType,
                preUrl: '/tender/' + ctx.tender.id + '/measure/material/' + ctx.params.order,
                material: ctx.material,
            };
            if ((ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo) && ctx.session.sessionUser.accountId === ctx.material.user_id) {
                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.tenderMenu.back.children[0].url = '/tender/' + ctx.tender.id + '/measure/material';
            return data;
        }

        _materialReadOnly(material) {
            return material.status === auditConst.status.checked;
        }

        /**
         * 获取审批界面所需的 原报、审批人数据等
         * @param ctx
         * @returns {Promise<void>}
         * @private
         */
        async _getMaterialAuditViewData(ctx) {
            const times = ctx.material.status === auditConst.status.checkNo ? ctx.material.times - 1 : ctx.material.times;
            ctx.material.user = await ctx.service.projectAccount.getAccountInfoById(ctx.material.user_id);
            ctx.material.auditHistory = [];
            if (ctx.material.times > 1) {
                for (let i = 1; i <= times; i++) {
                    ctx.material.auditHistory.push(await ctx.service.materialAudit.getAuditors(ctx.material.id, i));
                }
            }
            // 获取审批流程中左边列表
            ctx.material.auditors2 = await ctx.service.materialAudit.getAuditGroupByList(ctx.material.id, times);
            if (ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo) {
                ctx.material.auditorList = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
            }
        }

        /**
         * 调差工料页面 (Get)
         * @param {Object} ctx - egg全局变量
         * @returns {Promise<void>}
         */
        async info(ctx) {
            try {
                await this._getMaterialAuditViewData(ctx);
                const renderData = await this._getDefaultRenderData(ctx);
                // 根据期判断需要获取的工料信息值
                const searchsql = { tid: ctx.tender.id };
                if (ctx.material.highOrder !== ctx.material.order) {
                    const midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
                    searchsql.mid = midList;
                }
                // 取所有工料表
                renderData.materialBillsData = await ctx.service.materialBills.getAllDataByCondition({ where: searchsql });
                // 取对应期的截取上期的调差金额和应耗数量
                if (ctx.material.highOrder !== ctx.material.order) {
                    for (const [mindex, mb] of renderData.materialBillsData.entries()) {
                        const [quantity, pre_tp] = await ctx.service.materialBillsHistory.getByMbId(ctx.material.id, ctx.material.order, mb.id);
                        renderData.materialBillsData[mindex].quantity = quantity;
                        renderData.materialBillsData[mindex].pre_tp = pre_tp;
                    }
                }
                // 取所有已被调用的工料清单表
                renderData.materialListData = await ctx.service.materialList.getAllDataByCondition({ tid: ctx.tender.id, mid: ctx.material.id });
                // 基数
                // if (!ctx.material.readOnly) {
                const stage_list = await ctx.service.stage.getStageMsgByStageId(ctx.material.stage_id);
                renderData.calcBase = await ctx.service.stage.getMaterialCalcBase(stage_list, ctx.tender.info);
                // }

                renderData.materialType = JSON.stringify(materialConst);
                renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.info);
                await this.layout('material/info.ejs', renderData, 'material/info_modal.ejs');
            } catch (err) {
                this.log(err);
                ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
            }
        }

        /**
         * 调差清单页面 (Get)
         * @param {Object} ctx - egg全局变量
         * @returns {Promise<void>}
         */
        async list(ctx) {
            try {
                await this._getMaterialAuditViewData(ctx);
                const renderData = await this._getDefaultRenderData(ctx);
                // 根据期判断需要获取的工料信息值表
                const searchsql = { tid: ctx.tender.id };
                let midList = [];
                if (ctx.material.highOrder !== ctx.material.order) {
                    midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
                    searchsql.mid = midList;
                }
                searchsql.t_type = materialConst.t_type[0].value;
                renderData.materialBillsData = await ctx.service.materialBills.getAllDataByCondition({ where: searchsql });
                // 取所有已被调用的工料清单表
                renderData.materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
                renderData.materialNotJoinListData = await ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } });
                renderData.materialType = JSON.stringify(materialConst);
                renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.list);
                // 获取清单数据
                renderData.ledger = await ctx.service.ledger.getData(ctx.tender.id);
                renderData.pos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
                // 获取所选期数据并合并相加同类清单项
                renderData.curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, ctx.material.stage_id);
                renderData.curPosData = await ctx.service.stagePos.getStagesData(ctx.tender.id, ctx.material.stage_id);
                await this.layout('material/list.ejs', renderData, 'material/list_modal.ejs');
            } catch (err) {
                this.log(err);
                ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
            }
        }

        /**
         * 调差清单 - 工料操作 (Ajax)
         * @param ctx
         * @returns {Promise<void>}
         */
        async saveListsData(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                const responseData = {
                    err: 0,
                    msg: '',
                    data: {},
                };
                switch (data.type) {
                    case 'add':
                        responseData.data = await ctx.service.materialList.add(data.postData);
                        break;
                    case 'del':
                        await ctx.service.materialList.del(data.id, data.mb_id);
                        break;
                    case 'update':
                        if (data.updateData.quantity === '' || data.updateData.quantity === null) {
                            throw '请输入数量';
                        }
                        // 判断数量是否为数字
                        if (isNaN(data.updateData.quantity)) {
                            throw '不能输入其它非数字类型字符';
                        }
                        await ctx.service.materialList.save(data.updateData);
                        break;
                    case 'useOther':
                        responseData.data = await ctx.service.materialList.addOther(data.postData);
                        break;
                    case 'join':
                        await ctx.service.materialListNotjoin.del(data.select.id);
                        break;
                    case 'notjoin':
                        responseData.data = await ctx.service.materialListNotjoin.add(data.select);
                        break;
                    default: throw '参数有误';
                }

                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        /**
         * 调差工料 - 编辑工料项 (Ajax)
         * @param ctx
         * @returns {Promise<void>}
         */
        async saveBillsData(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                const responseData = {
                    err: 0,
                    msg: '',
                    data: {},
                };
                switch (data.type) {
                    case 'add':
                        responseData.data = await ctx.service.materialBills.add();
                        break;
                    case 'del':
                        responseData.data.m_tp = await ctx.service.materialBills.del(data.id);
                        break;
                    case 'update':
                        if (data.updateData.code === '' || data.updateData.code === null) {
                            throw '请先输入编号';
                        }
                        // 判断编号为纯数字时，不能为小数
                        if (!isNaN(data.updateData.code) && data.updateData.code.indexOf('.') !== -1) {
                            throw '编号为纯数字时，不能为小数';
                        }
                        if (data.updateData.code.length > 15) {
                            throw '长度不超过15个字符';
                        }
                        // 判断编号是否已存在
                        const billData = await ctx.service.materialBills.getAllDataByCondition({ where: { tid: ctx.tender.id, code: data.updateData.code } });
                        if (billData.length > 1 || (billData.length > 0 && billData[0].id !== data.updateData.id)) {
                            throw '该编号已存在，请重新输入。';
                        }
                        responseData.data.m_tp = await ctx.service.materialBills.save(data.updateData);
                        break;
                    case 'rate':
                        // 判断数量是否为数字
                        if (isNaN(data.rate)) {
                            throw '不能输入其它非数字类型字符';
                        }
                        if (ctx.material.readOnly) {
                            throw '无权操作';
                        }
                        await ctx.service.material.changeRate(data.rate);
                        break;
                    case 'expr':
                        const materialCalculator = new MaterialCalculator(ctx, ctx.material.stage_id, ctx.tender.info);
                        const quantity = await materialCalculator.calculateExpr(data.expr);
                        // 更新quantity值并重新返回计算本期金额，截止本期金额
                        const updateData = {
                            id: data.id,
                            quantity: quantity !== 0 ? quantity : null,
                            expr: data.expr,
                        };
                        responseData.data = await ctx.service.materialBills.updateFYQuantity(updateData);
                        break;
                    default: throw '参数有误';
                }

                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        // 审批相关
        /**
         * 添加审批人
         * @param ctx
         * @returns {Promise<void>}
         */
        async addAudit(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                const id = this.app._.toInteger(data.auditorId);
                if (isNaN(id) || id <= 0) {
                    throw '参数错误';
                }
                // 检查权限等
                if (ctx.material.user_id !== ctx.session.sessionUser.accountId) {
                    throw '您无权添加审核人';
                }
                if (ctx.material.status === auditConst.status.checking || ctx.material.status === auditConst.status.checked) {
                    throw '当前不允许添加审核人';
                }

                ctx.material.auditorList = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
                // 检查审核人是否已存在
                const exist = this.app._.find(ctx.material.auditorList, {aid: id});
                if (exist) {
                    throw '该审核人已存在，请勿重复添加';
                }

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

                const audit = await ctx.service.materialAudit.getAuditor(ctx.material.id, id, ctx.material.times);
                ctx.body = {err: 0, msg: '', data: audit};
            } catch (err) {
                this.log(err);
                ctx.body = {err: 1, msg: err.toString(), data: null};
            }
        }
        /**
         * 移除审批人
         * @param ctx
         * @returns {Promise<void>}
         */
        async deleteAudit(ctx) {
            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.materialAudit.deleteAuditor(ctx.material.id, id, ctx.material.times);
                if (!result) {
                    throw '移除审核人失败';
                }

                const auditors = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
                ctx.body = {err: 0, msg: '', data: auditors};
            } catch (err) {
                ctx.body = {err: 1, msg: err.toString(), data: null};
            }
        }
        /**
         * 上报和重新上报
         * @param ctx
         * @returns {Promise<void>}
         */
        async startAudit(ctx) {
            try {
                // 检查权限等
                if (!ctx.material) {
                    throw '数据错误';
                }
                if (ctx.material.user_id !== ctx.session.sessionUser.accountId) {
                    throw '您无权上报该期数据';
                }
                if (ctx.material.status === auditConst.status.checking || ctx.material.status === auditConst.status.checked) {
                    throw '该材料调差期数据当前无法上报';
                }

                await ctx.service.materialAudit.start(ctx.material.id, ctx.material.times);

                ctx.redirect(ctx.request.header.referer);
            } catch (err) {
                this.log(err);
                ctx.session.postError = err.toString();
                ctx.redirect(ctx.request.header.referer);
            }
        }
        /**
         * 审批
         * @param ctx
         * @returns {Promise<void>}
         */
        async checkAudit(ctx) {
            try {
                if (!this.ctx.material || this.ctx.material.status !== auditConst.status.checking) {
                    throw '当前材料调差期数据有误';
                }
                if (!this.ctx.material.curAuditor || this.ctx.material.curAuditor.aid !== 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.materialAudit.check(ctx.material.id, data, ctx.material.times);

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

    return MaterialController;
};