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');
const advanceConst = require('../const/advance');
const fs = require('fs');
const path = require('path');
const sendToWormhole = require('stream-wormhole');
const moment = require('moment');

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) {
                if (audit.status !== auditConst.stage.status.uncheck) {
                    const isLastage = await ctx.service.stage.isLastStage(audit.tid, audit.id);
                    if (isLastage) 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);
            // 获取待审批的变更方案
            let auditChangePlans = [];
            if (ctx.session.sessionProject.page_show.openChangePlan) {
                auditChangePlans = await ctx.service.changePlanAudit.getAuditChangePlanByWap(ctx.session.sessionUser.accountId);
            }
            // 获取待审批的台账修订
            const auditRevise = await ctx.service.reviseAudit.getAuditReviseByWap(ctx.session.sessionUser.accountId);
            for (const revise of auditRevise) {
                const yb_audit = await ctx.service.projectAccount.getAccountInfoById(revise.audit_id);
                revise.yb_name = yb_audit.name;
            }
            // 获取待审批的预付款
            const auditAdvance = await ctx.service.advanceAudit.getAuditAdvanceByWap(ctx.session.sessionUser.accountId);
            const renderData = {
                auditStages,
                auditChanges,
                auditChangePlans,
                auditRevise,
                auditAdvance,
                changeConst,
                advanceConst,
                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) {
                    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);
                    }
                }
                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);
                }

                // 变更令列表
                let changePlans = [];
                if (ctx.session.sessionProject.page_show.openChangePlan) {
                    changePlans = await ctx.service.changePlan.getListByStatus(tender.id, 0, 0);
                    for (const c of changePlans) {
                        c.curAuditor = await ctx.service.changePlanAudit.getAuditorByStatus(c.id, c.status, c.times);
                    }
                }

                // 台账修订列表
                const revises = await ctx.service.ledgerRevise.getReviseList(ctx.tender.id);
                for (const lr of revises) {
                    if (lr.valid) {
                        lr.curAuditor = await ctx.service.reviseAudit.getAuditorByStatus(lr.id, lr.status, lr.times);
                    }
                }

                // 预付款期数获取
                const advanceList = [];
                for (const t of advanceConst.typeCol) {
                    const advance = await ctx.service.advance.getLastestAdvance(ctx.tender.id, t.type, true);
                    advanceList.push(advance);
                }

                const renderData = {
                    tender,
                    stages,
                    changes,
                    changePlans,
                    revises,
                    advanceList,
                    auditConst: auditConst.stage,
                    auditChangeConst: auditConst.flow,
                    auditChangePlanConst: auditConst.changePlan,
                    auditReviseConst: auditConst.revise,
                    changeConst,
                    advanceConst,
                    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 changePlan(ctx) {
            try {
                const tender = ctx.tender.data;
                if (!ctx.session.sessionProject.page_show.openChangePlan) {
                    throw '该功能已关闭';
                }
                const change = await ctx.service.changePlan.getDataById(ctx.params.cpid);
                const renderData = {
                    tender,
                    change,
                    auditConst: auditConst.changePlan,
                    changeConst,
                    tpUnit: ctx.tender.info.decimal.tp,
                };
                const times = change.status !== auditConst.changePlan.status.checkNo ? change.times : change.times - 1;
                renderData.change.user = await ctx.service.projectAccount.getAccountInfoById(change.uid);
                renderData.change.auditors = await ctx.service.changePlanAudit.getAuditors(change.id, times);
                // 获取审批流程中左边列表
                renderData.change.auditors2 = await ctx.service.changePlanAudit.getAuditGroupByList(change.id, times);
                await ctx.render('wap/shenpi_change_plan.ejs', renderData);
            } catch (err) {
                this.log(err);
                ctx.redirect('/wap/list');
            }
        }


        /**
         * 修订审批详细页
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async revise(ctx) {
            try {
                const tender = ctx.tender.data;
                const revise = await ctx.service.ledgerRevise.getDataByCondition({ id: ctx.params.rid });
                revise.user = await ctx.service.projectAccount.getAccountInfoById(revise.uid);
                const times = revise.status === auditConst.revise.status.checkNo ? revise.times - 1 : revise.times;
                revise.curAuditor = await ctx.service.reviseAudit.getAuditorByStatus(revise.id, revise.status, times);
                revise.auditors = await ctx.service.reviseAudit.getAuditors(revise.id, times);
                console.log(times, revise.auditors);
                const renderData = {
                    tender,
                    revise,
                    auditConst: auditConst.revise,
                };
                await ctx.render('wap/shenpi_revise.ejs', renderData);
            } catch (err) {
                this.log(err);
                ctx.redirect('/wap/list');
            }
        }

        /**
         * 预付款列表页
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async advance(ctx) {
            try {
                const tender = ctx.tender.data;
                const { decimal } = ctx.tender.info;
                this.decimal = decimal.pay ? decimal.payTp : decimal.tp;
                const advancePayTotalList = [];
                const advanceList = [];
                for (const t of advanceConst.typeCol) {
                    const advancePayTotal = ctx.tender.info.deal_param[t.key + 'Advance'];
                    advancePayTotalList.push(advancePayTotal);
                    const advances = await ctx.service.advance.getAdvanceList(ctx.tender.id, t.type, this.decimal, advancePayTotal);
                    advanceList.push(advances);
                }
                const renderData = {
                    tender,
                    advancePayTotalList,
                    advanceList,
                    auditConst: auditConst.advance,
                    advanceConst,
                };
                await ctx.render('wap/shenpi_advance.ejs', renderData);
            } catch (err) {
                this.log(err);
                ctx.redirect('/wap/list');
            }
        }

        /**
         * 预付款详情页 GET
         * @param {Object} ctx 全局上下文
         */
        async advanceDetail(ctx) {
            try {
                const tender = ctx.tender.data;
                ctx.advance.advancePayTotal = ctx.tender.info.deal_param[ advanceConst.typeCol[ctx.advance.type].key + 'Advance'];
                const times = ctx.advance.status === auditConst.advance.status.checkNo ? ctx.advance.times - 1 : ctx.advance.times;
                if (ctx.advance.status === auditConst.advance.status.checkNo) {
                    ctx.advance.curAuditor = await ctx.service.advanceAudit.getAuditorByStatus(ctx.advance.id, ctx.advance.status, times);
                    ctx.advance.auditors = await ctx.service.advanceAudit.getAuditors(ctx.advance.id, times);
                }
                // 获取审批流程中左边列表
                ctx.advance.auditors2 = await ctx.service.advanceAudit.getAuditGroupByList(ctx.advance.id, times);
                const renderData = {
                    tender,
                    advance: ctx.advance,
                    auditConst: auditConst.advance,
                    advanceConst,
                };
                await ctx.render('wap/shenpi_advance_detail.ejs', renderData);
            } catch (error) {
                this.log(error);
                ctx.redirect('/wap/tender/' + ctx.tender.id + '/advance');
            }
        }

        /**
         * 变更令审批
         * @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);
            }
        }

        /**
         * 收方单附件上传页
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async shoufangUpload(ctx) {
            try {
                const tid = parseInt(ctx.query.tid) || 0;
                const order = parseInt(ctx.query.order) || 0;
                const sfid = parseInt(ctx.query.sfid) || 0;
                if (!tid || !order || !sfid) {
                    throw '参数有误';
                }
                const tender = await ctx.service.tender.getDataById(tid);
                if (!tender) {
                    throw '该标段不存在';
                }
                const sfInfo = await ctx.service.stageShoufang.getDataByCondition({ id: sfid, tid, order });
                if (!sfInfo) {
                    throw '该收方单不存在';
                }
                // 查找对应的台账或计量单元名称

                const ledger = await ctx.service.ledger.getData(tid);
                const ledgerInfo = ctx.helper._.find(ledger, { id: sfInfo.lid });
                let name = ledgerInfo.b_code;
                if (sfInfo.pid) {
                    const pos = await ctx.service.pos.getPosData({ tid });
                    const posInfo = ctx.helper._.find(pos, { lid: sfInfo.lid, id: sfInfo.pid });
                    name += ' / ' + posInfo.name;
                }
                const renderData = {
                    tender,
                    order,
                    name,
                    sfid,
                    whiteList: this.ctx.app.config.multipart.whitelist,
                };
                await ctx.render('wap/shoufangupload.ejs', renderData);
            } catch (error) {
                this.log(error);
                ctx.redirect('/wap/login');
            }
        }

        /**
         * 上传附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async shoufangUpFile(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: [],
            };
            let stream;
            try {
                const parts = ctx.multipart({ autoFields: true });
                const files = [];
                let index = 0;
                while ((stream = await parts()) !== undefined) {
                    // 判断是否存在
                    const sfInfo = await ctx.service.stageShoufang.getDataById(parts.field.sfid);
                    if (!sfInfo) {
                        throw '该清单 / 计量单元下不存在收方单';
                    }
                    // 判断用户是否选择上传文件
                    if (!stream.filename) {
                        throw '请选择上传的文件!';
                    }
                    // const dirName = 'app/public/upload/stage/' + moment().format('YYYYMMDD');
                    // 判断文件夹是否存在，不存在则直接创建文件夹
                    // if (!fs.existsSync(path.join(this.app.baseDir, dirName))) {
                    //     await fs.mkdirSync(path.join(this.app.baseDir, dirName));
                    // }
                    const fileInfo = path.parse(stream.filename);
                    const now_time = new Date();
                    const create_time = Date.parse(now_time) / 1000;
                    const filepath = `app/public/upload/${sfInfo.tid}/stage/shoufang/fujian_${create_time + index.toString() + fileInfo.ext}`;
                    // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, filepath));
                    await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
                    // console.log(await fs.existsSync(path.resolve(this.app.baseDir, 'app', filepath)));
                    // const fileInfo = path.parse(stream.filename);
                    // const fileName = 'stage' + create_time + '_' + index + fileInfo.ext;
                    // 保存文件
                    // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, dirName, fileName));

                    if (stream) {
                        await sendToWormhole(stream);
                    }

                    // 保存数据到att表
                    const fileData = {
                        tid: sfInfo.tid,
                        sid: sfInfo.sid,
                        sfid: sfInfo.id,
                        in_time: now_time,
                        filename: fileInfo.name,
                        fileext: fileInfo.ext,
                        filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
                        filepath,
                    };
                    // if (ctx.reUploadPermission) {
                    //     fileData.re_upload = 1;
                    // }
                    const result = await ctx.service.stageShoufangAtt.save(fileData);
                    if (!result) {
                        throw '导入数据库保存失败';
                    }
                    const attData = await ctx.service.stageShoufangAtt.getDataByFid(result.insertId);
                    attData.in_time = moment(create_time * 1000).format('YYYY-MM-DD');
                    files.length !== 0 ? files.unshift(attData) : files.push(attData);
                    ++index;
                }
                responseData.data = files;
            } catch (err) {
                this.log(err);
                // 失败需要消耗掉stream 以防卡死
                if (stream) {
                    await sendToWormhole(stream);
                }
                this.setMessage(err.toString(), this.messageType.ERROR);
                responseData.err = 1;
                responseData.msg = err.toString();
            }
            ctx.body = responseData;
        }

        /**
         * 删除附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async shoufangDeleteFile(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: '',
            };
            try {

                const data = JSON.parse(ctx.request.body.data);
                const fileInfo = await ctx.service.stageShoufangAtt.getDataById(data.id);
                if (!fileInfo || !Object.keys(fileInfo).length) {
                    throw '该文件不存在';
                }
                if (fileInfo !== undefined && fileInfo !== '') {
                    // 先删除文件
                    // await fs.unlinkSync(path.join(this.app.baseDir, fileInfo.filepath));
                    await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
                    // 再删除数据库
                    await ctx.service.stageShoufangAtt.deleteById(data.id);
                    responseData.data = '';
                } else {
                    throw '不存在该文件';
                }
            } catch (err) {
                responseData.err = 1;
                responseData.msg = err;
            }

            ctx.body = responseData;
        }

        /**
         * 编辑附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async shoufangEditFile(ctx) {
            const responseData = {
                err: 0,
                msg: '',
                data: '',
            };
            try {

                const data = JSON.parse(ctx.request.body.data);
                const fileInfo = await ctx.service.stageShoufangAtt.getDataById(data.id);
                if (!fileInfo || !Object.keys(fileInfo).length) {
                    throw '该文件不存在';
                }
                await ctx.service.stageShoufangAtt.edit(data);
            } catch (err) {
                responseData.err = 1;
                responseData.msg = err;
            }

            ctx.body = responseData;
        }

        /**
         * 下载附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async shoufangDownloadFile(ctx) {
            const id = ctx.params.fid;
            if (id) {
                try {
                    const fileInfo = await ctx.service.stageShoufangAtt.getDataById(id);
                    if (fileInfo !== undefined && fileInfo !== '') {
                        // const fileName = path.join(this.app.baseDir, fileInfo.filepath);
                        // 解决中文无法下载问题
                        const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
                        let disposition = '';
                        if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
                            disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename + fileInfo.fileext);
                        } else if (userAgent.indexOf('firefox') >= 0) {
                            disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename + fileInfo.fileext) + '"';
                        } else {
                            /* safari等其他非主流浏览器只能自求多福了 */
                            disposition = 'attachment; filename=' + new Buffer(fileInfo.filename + fileInfo.fileext).toString('binary');
                        }
                        ctx.response.set({
                            'Content-Type': 'application/octet-stream',
                            'Content-Disposition': disposition,
                            'Content-Length': fileInfo.filesize,
                        });
                        // ctx.body = await fs.createReadStream(fileName);
                        ctx.body = await ctx.helper.ossFileGet(fileInfo.filepath);
                    } else {
                        throw '不存在该文件';
                    }
                } catch (err) {
                    this.log(err);
                    this.setMessage(err.toString(), this.messageType.ERROR);
                }
            }
        }
    }

    return WapController;
};