Calculation/app/controller/financial_controller.js

'use strict';
const auditConst = require('../const/audit');
const shenpiConst = require('../const/shenpi');
const financialConst = require('../const/financial');
const moment = require('moment');
const sendToWormhole = require('stream-wormhole');
const fs = require('fs');
const path = require('path');
module.exports = app => {

    class FinancialController extends app.BaseController {
        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
            ctx.showProject = true;
            // ctx.showTitle = true;
        }
        /**
         * 资金监管项目列表页
         *
         * @param {Object} ctx - egg全局页面
         * @return {void}
         */
        async index(ctx) {
            try {
                if (!ctx.session.sessionProject.page_show.openFinancial) {
                    throw '该功能已关闭或无法查看';
                }
                const renderData = {
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.index),
                    auditConst,
                };
                renderData.projectList = await ctx.service.subProject.getSubProjectByFinancial(ctx.session.sessionProject.id, ctx.session.sessionUser.accountId, ctx.session.sessionUser.is_admin);
                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', 'mobile'],
                });
                for (const proj of renderData.projectList) {
                    const financialPermission = await ctx.service.financialAudit.getPermission(proj.id, ctx.session.sessionUser.accountId);
                    if (financialPermission.transfer_show) {
                        proj.toUrl = 'transfer';
                    } else if (financialPermission.pay_show) {
                        proj.toUrl = 'pay';
                    } else if (!financialPermission.transfer_show && !financialPermission.pay_show) {
                        proj.toUrl = 'transfer';
                    }
                }
                renderData.accountList = accountList;
                const unitList = await ctx.service.constructionUnit.getAllDataByCondition({where: {pid: ctx.session.sessionProject.id}});
                renderData.accountGroup = unitList.map(item => {
                    const groupList = accountList.filter(item1 => item1.company === item.name);
                    return { groupName: item.name, groupList };
                });
                // renderData.permissionConst = ctx.service.subProjPermission.PermissionConst;
                renderData.categoryData = await this.ctx.service.category.getAllCategory(this.ctx.session.sessionProject.id);
                renderData.companys = await this.ctx.service.constructionUnit.getAllDataByCondition({where: {pid: ctx.session.sessionProject.id}});
                // renderData.templates = await this.ctx.service.filingTemplateList.getAllTemplate(ctx.session.sessionProject.id);
                await this.layout('financial/index.ejs', renderData, 'financial/modal.ejs');
            } catch (err) {
                ctx.log(err);
                ctx.session.postError = err.toString();
                ctx.redirect(this.menu.menu.dashboard.url);
            }
        }

        async auditSave(ctx) {
            try {
                if (ctx.session.sessionUser.is_admin === 0) throw '没有设置权限';
                const responseData = {
                    err: 0, msg: '', data: null,
                };
                const data = JSON.parse(ctx.request.body.data);
                if (!data.type) {
                    throw '提交数据错误';
                }
                let uids;
                let result = false;
                let auditList = [];
                switch (data.type) {
                    case 'add-audit':
                        // 判断用户是单个还是数组
                        uids = data.id instanceof Array ? data.id : [data.id];
                        // 判断该用户的组是否已加入到表中，已加入则提示无需添加
                        auditList = await ctx.service.financialAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id } });
                        const addAidList = ctx.helper._.difference(uids, ctx.helper._.map(auditList, 'uid'));
                        if (addAidList.length === 0) {
                            throw '用户已存在成员管理中，无需重复添加';
                        }
                        const accountList = await ctx.service.projectAccount.getAllDataByCondition({ where: { id: addAidList } });
                        await ctx.service.financialAudit.saveAudits(ctx.subProject.id, accountList);
                        responseData.data = await ctx.service.financialAudit.getList(ctx.subProject.id);
                        break;
                    case 'del-audit':
                        uids = data.id instanceof Array ? data.id : [data.id];
                        auditList = await ctx.service.financialAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id, id: uids } });
                        if (auditList.length !== uids.length) {
                            throw '该用户已不存在成员管理中，移除失败';
                        }
                        await ctx.service.financialAudit.delAudit(uids);
                        responseData.data = await ctx.service.financialAudit.getList(ctx.subProject.id);
                        break;
                    case 'save-permission':
                        result = await ctx.service.financialAudit.updatePermission(data.updateData);
                        if (!result) {
                            throw '修改权限失败';
                        }
                        break;
                    case 'list':
                        responseData.data = await ctx.service.financialAudit.getList(ctx.subProject.id);
                        break;
                    default: throw '参数有误';
                }
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        async transfer(ctx) {
            try {
                const financialPermission = await ctx.service.financialAudit.getPermission(ctx.subProject.id, ctx.session.sessionUser.accountId);
                if (!financialPermission.transfer_show) {
                    throw '没有查看权限';
                }
                const transferList = await ctx.service.financialTransfer.getList(ctx.subProject.id);
                const renderData = {
                    financialPermission,
                    transferList,
                    moment,
                    preUrl: '/financial',
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.transfer),
                    whiteList: ctx.app.config.multipart.whitelist,
                };
                await this.layout('financial/transfer.ejs', renderData, 'financial/transfer_modal.ejs');
            } catch (err) {
                ctx.log(err);
                console.log(err);
                ctx.session.postError = err.toString();
                ctx.redirect('/financial');
            }
        }

        async transferAdd(ctx) {
            try {
                const financialPermission = await ctx.service.financialAudit.getPermission(ctx.subProject.id, ctx.session.sessionUser.accountId);
                if (!financialPermission.transfer_add) {
                    throw '没有添加权限';
                }
                const date = ctx.request.body.date;
                const remark = ctx.request.body.remark;
                if (!date) {
                    throw '请选择划拨年月';
                }
                const newTransferId = await ctx.service.financialTransfer.addTransfer(ctx.subProject.id, date, remark);
                if (!newTransferId) {
                    throw '新增资金划拨失败，请重试';
                }
                ctx.redirect('/financial/' + ctx.subProject.id + '/transfer/' + newTransferId + '/tender');
            } catch (err) {
                console.log(err);
                ctx.postError(err, '新增资金划拨失败');
                ctx.redirect(ctx.request.header.referer);
            }
        }

        async transferTender(ctx) {
            try {
                const financialPermission = await ctx.service.financialAudit.getPermission(ctx.subProject.id, ctx.session.sessionUser.accountId);
                if (!financialPermission.transfer_show) {
                    throw '没有查看权限';
                }
                const trid = ctx.params.id;
                const transferInfo = await ctx.service.financialTransfer.getDataById(trid);
                if (!transferInfo) {
                    throw '该资金划拨信息不存在';
                }
                const transferTenderList = await ctx.service.financialTransferTender.getList(trid);
                const tenders = await ctx.service.tender.getAllDataByCondition({ where: { spid: ctx.subProject.id } });
                for (const tt of transferTenderList) {
                    const tenderIndex = ctx.helper._.findIndex(tenders, { id: tt.tid });
                    if (tenderIndex !== -1) {
                        tenders.splice(tenderIndex, 1);
                    }
                }
                const allTransferTenders = await ctx.service.financialTransferTender.getAllDataByCondition({ where: { spid: ctx.subProject.id } });
                for (const t of tenders) {
                    const stages = await ctx.service.stage.getAllDataByCondition({ where: { tid: t.id, status: auditConst.stage.status.checked } });
                    const allTenderStages = ctx.helper._.filter(allTransferTenders, { tid: t.id });
                    for (const ts of allTenderStages) {
                        const sorderArray = ts.sorder ? ts.sorder.split(',') : [];
                        for (const sorder of sorderArray) {
                            const stageIndex = ctx.helper._.findIndex(stages, function(item) {
                                return item.order === parseInt(sorder);
                            });
                            if (stageIndex !== -1) {
                                stages.splice(stageIndex, 1);
                            }
                        }
                    }
                    t.stages = stages;
                }

                const renderData = {
                    financialPermission,
                    transferInfo,
                    transferTenderList,
                    tenders,
                    moment,
                    preUrl: '/financial/' + ctx.subProject.id + '/transfer',
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.transferTender),
                    whiteList: ctx.app.config.multipart.whitelist,
                };
                await this.layout('financial/transfer_tender.ejs', renderData, 'financial/transfer_tender_modal.ejs');
            } catch (err) {
                ctx.log(err);
                console.log(err);
                ctx.session.postError = err.toString();
                ctx.redirect('/financial');
            }
        }

        async transferUpdate(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);
                if (!data.postType || !data.postData) throw '数据错误';
                const responseData = { err: 0, msg: '', data: {} };
                switch (data.postType) {
                    case 'del-transfer':
                        responseData.data = await ctx.service.financialTransfer.delTransfer(data.postData.node);
                        break;
                    case 'lock-transfer':
                        responseData.data = await ctx.service.financialTransfer.lockTransfer(data.postData.node, data.postData.lock);
                        break;
                    case 'save-transfer':
                        responseData.data = await ctx.service.financialTransfer.saveTransfer(data.postData);
                        break;
                    default:
                        throw '未知操作';
                }
                ctx.body = responseData;
            } catch (err) {
                console.log(err);
                this.log(err);
                ctx.body = this.ajaxErrorBody(err, '数据错误');
            }
        }

        async transferTenderUpdate(ctx) {
            try {
                const financialPermission = await ctx.service.financialAudit.getPermission(ctx.subProject.id, ctx.session.sessionUser.accountId);
                if (!financialPermission.transfer_add) {
                    throw '没有权限';
                }
                const trid = ctx.params.id;
                const transferInfo = await ctx.service.financialTransfer.getDataById(trid);
                if (!transferInfo) {
                    throw '该资金划拨信息不存在';
                }
                if (transferInfo.uid !== ctx.session.sessionUser.accountId) {
                    throw '不是你创建的没有权限操作';
                }
                const data = JSON.parse(ctx.request.body.data);
                if (!data.postType || !data.postData) throw '数据错误';
                const responseData = { err: 0, msg: '', data: {} };
                switch (data.postType) {
                    case 'add-tender':
                        const result = await ctx.service.financialTransferTender.addTenders(transferInfo, data.postData.tenders);
                        if (!result) {
                            throw '新增失败';
                        }
                        break;
                    case 'del-tender':
                        responseData.data = await ctx.service.financialTransferTender.delTenders(data.postData.node);
                        break;
                    case 'update-hb_tp':
                        responseData.data = await ctx.service.financialTransferTender.updateHbTp(data.postData.node, data.postData.hb_tp);
                        break;
                    default:
                        throw '未知操作';
                }
                ctx.body = responseData;
            } catch (err) {
                console.log(err);
                this.log(err);
                ctx.body = this.ajaxErrorBody(err, '数据错误');
            }
        }

        /**
         * 上传附件
         * @param {*} ctx 上下文
         */
        async transferUploadFile(ctx) {
            let stream;
            try {
                const financialPermission = await ctx.service.financialAudit.getPermission(ctx.subProject.id, ctx.session.sessionUser.accountId);
                if (!financialPermission.transfer_file) {
                    throw '没有权限';
                }
                const responseData = { err: 0, msg: '', data: {} };
                const id = ctx.params.id;
                if (!id) throw '参数有误';
                const parts = this.ctx.multipart({
                    autoFields: true,
                });
                const files = [];
                const create_time = Date.parse(new Date()) / 1000;
                let idx = 0;
                while ((stream = await parts()) !== undefined) {
                    if (!stream.filename) {
                        // 如果没有传入直接返回
                        return;
                    }
                    const fileInfo = path.parse(stream.filename);
                    const filepath = `sp/financial/${ctx.subProject.id}/transfer/${id}/fujian_${create_time + idx.toString() + fileInfo.ext}`;
                    await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
                    files.push({ filepath, name: stream.filename, ext: fileInfo.ext });
                    ++idx;
                    stream && (await sendToWormhole(stream));
                }
                const in_time = new Date();
                const payload = files.map(file => {
                    let idx;
                    if (Array.isArray(parts.field.name)) {
                        idx = parts.field.name.findIndex(name => name === file.name);
                    } else {
                        idx = 'isString';
                    }
                    const newFile = {
                        spid: ctx.subProject.id,
                        trid: id,
                        uid: ctx.session.sessionUser.accountId,
                        filename: file.name,
                        fileext: file.ext,
                        filesize: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
                        filepath: file.filepath,
                        upload_time: in_time,
                    };
                    return newFile;
                });
                // 执行文件信息写入数据库
                await ctx.service.financialTransferAtt.saveFileMsgToDb(payload);
                // 将最新的当前标段的所有文件信息返回
                responseData.data = await ctx.service.financialTransferAtt.getAtt(id);
                ctx.body = responseData;
            } catch (err) {
                stream && (await sendToWormhole(stream));
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        /**
         * 删除附件
         * @param {Ojbect} ctx 上下文
         */
        async transferDeleteFile(ctx) {
            try {
                const id = ctx.params.id;
                const responseData = { err: 0, msg: '', data: {} };
                const data = JSON.parse(ctx.request.body.data);
                const fileInfo = await ctx.service.financialTransferAtt.getDataById(data.id);
                if (fileInfo || Object.keys(fileInfo).length) {
                    // 先删除文件
                    // await fs.unlinkSync(path.resolve(this.app.baseDir, './app', fileInfo.filepath));
                    await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
                    // 再删除数据库
                    await ctx.service.financialTransferAtt.delete(data.id);
                } else {
                    throw '不存在该文件';
                }
                responseData.data = await ctx.service.financialTransferAtt.getAtt(id);
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        /**
         * 下载附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async transferDownloadFile(ctx) {
            const id = ctx.params.fid;
            if (id) {
                try {
                    const fileInfo = await ctx.service.financialTransferAtt.getDataById(id);
                    if (fileInfo) {
                        // const fileName = path.join(__dirname, '../', 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);
                        } else if (userAgent.indexOf('firefox') >= 0) {
                            disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename) + '"';
                        } else {
                            /* safari等其他非主流浏览器只能自求多福了 */
                            disposition = 'attachment; filename=' + new Buffer(fileInfo.filename).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);
                }
            }
        }

        /**
         * 上传附件
         * @param {*} ctx 上下文
         */
        async transferTenderUploadFile(ctx) {
            let stream;
            try {
                const financialPermission = await ctx.service.financialAudit.getPermission(ctx.subProject.id, ctx.session.sessionUser.accountId);
                if (!financialPermission.transfer_file) {
                    throw '没有权限';
                }
                const responseData = { err: 0, msg: '', data: {} };
                const trid = ctx.params.trid;
                const id = ctx.params.id;
                if (!id) throw '参数有误';
                const parts = this.ctx.multipart({
                    autoFields: true,
                });
                const files = [];
                const create_time = Date.parse(new Date()) / 1000;
                let idx = 0;
                while ((stream = await parts()) !== undefined) {
                    if (!stream.filename) {
                        // 如果没有传入直接返回
                        return;
                    }
                    const fileInfo = path.parse(stream.filename);
                    const filepath = `sp/financial/${ctx.subProject.id}/transfer/${trid}/tender/${id}/fujian_${create_time + idx.toString() + fileInfo.ext}`;
                    await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
                    files.push({ filepath, name: stream.filename, ext: fileInfo.ext });
                    ++idx;
                    stream && (await sendToWormhole(stream));
                }
                const in_time = new Date();
                const payload = files.map(file => {
                    let idx;
                    if (Array.isArray(parts.field.name)) {
                        idx = parts.field.name.findIndex(name => name === file.name);
                    } else {
                        idx = 'isString';
                    }
                    const newFile = {
                        spid: ctx.subProject.id,
                        trid,
                        ftid: id,
                        uid: ctx.session.sessionUser.accountId,
                        filename: file.name,
                        fileext: file.ext,
                        filesize: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
                        filepath: file.filepath,
                        upload_time: in_time,
                    };
                    return newFile;
                });
                // 执行文件信息写入数据库
                await ctx.service.financialTransferTenderAtt.saveFileMsgToDb(payload);
                // 将最新的当前标段的所有文件信息返回
                responseData.data = await ctx.service.financialTransferTenderAtt.getAtt(id);
                ctx.body = responseData;
            } catch (err) {
                stream && (await sendToWormhole(stream));
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        /**
         * 删除附件
         * @param {Ojbect} ctx 上下文
         */
        async transferTenderDeleteFile(ctx) {
            try {
                const id = ctx.params.id;
                const responseData = { err: 0, msg: '', data: {} };
                const data = JSON.parse(ctx.request.body.data);
                const fileInfo = await ctx.service.financialTransferTenderAtt.getDataById(data.id);
                if (fileInfo || Object.keys(fileInfo).length) {
                    // 先删除文件
                    // await fs.unlinkSync(path.resolve(this.app.baseDir, './app', fileInfo.filepath));
                    await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
                    // 再删除数据库
                    await ctx.service.financialTransferTenderAtt.delete(data.id);
                } else {
                    throw '不存在该文件';
                }
                responseData.data = await ctx.service.financialTransferTenderAtt.getAtt(id);
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        /**
         * 下载附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async transferTenderDownloadFile(ctx) {
            const id = ctx.params.fid;
            if (id) {
                try {
                    const fileInfo = await ctx.service.financialTransferTenderAtt.getDataById(id);
                    if (fileInfo) {
                        // const fileName = path.join(__dirname, '../', 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);
                        } else if (userAgent.indexOf('firefox') >= 0) {
                            disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename) + '"';
                        } else {
                            /* safari等其他非主流浏览器只能自求多福了 */
                            disposition = 'attachment; filename=' + new Buffer(fileInfo.filename).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);
                }
            }
        }

        /**
         * 变更管理 页面 (Get)
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async pay(ctx) {
            try {
                const status = parseInt(ctx.query.status) || 0;
                const tid = parseInt(ctx.query.tid) || null;
                const used = ctx.query.used || null;
                await this._filterPay(ctx, status, tid, used);
            } catch (err) {
                this.log(err);
                ctx.redirect('/financial');
            }
        }

        // /**
        //  * 变更管理 状态筛选 页面 (Get)
        //  * @param {Object} ctx - egg全局变量
        //  * @return {void}
        //  */
        // async payStatus(ctx) {
        //     try {
        //         const status = parseInt(ctx.query.status);
        //         const tid = parseInt(ctx.params.tid) || null;
        //         const used = ctx.params.used || null;
        //         await this._filterPay(ctx, status, tid, used);
        //     } catch (err) {
        //         this.logger.error(err);
        //         ctx.redirect('/financial');
        //     }
        // }

        async _filterPay(ctx, status = 0, tid = null, used = null) {
            const financialPermission = await ctx.service.financialAudit.getPermission(ctx.subProject.id, ctx.session.sessionUser.accountId);
            if (!financialPermission.pay_show) {
                throw '没有查看权限';
            }
            const fptAudits = await ctx.service.financialPayTenderAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id, uid: ctx.session.sessionUser.accountId } });
            const fptAuditTids = ctx.helper._.map(fptAudits, 'tid');
            const filterTids = tid === null ? (ctx.session.sessionUser.is_admin ? null : fptAuditTids) : [tid];
            const tenderCondition = { spid: ctx.subProject.id };
            let hadTender = false;
            if (ctx.session.sessionUser.is_admin) {
                hadTender = true;
            } else if (fptAuditTids.length !== 0) {
                hadTender = true;
                tenderCondition.id = fptAuditTids;
            } else {
                hadTender = false;
                tenderCondition.id = -1;
            }
            const tenders = hadTender ? await ctx.service.tender.getAllDataByCondition({ where: tenderCondition, columns: ['id', 'name'] }) : [];
            const filter = JSON.parse(JSON.stringify(auditConst.financial.filter));
            filter.count = [];
            filter.count[filter.status.pending] = await ctx.service.financialPay.getCountByStatus(ctx.subProject.id, filter.status.pending, filterTids, used);// await ctx.service.change.pendingDatas(tender.id, ctx.session.sessionUser.accountId);
            filter.count[filter.status.uncheck] = await ctx.service.financialPay.getCountByStatus(ctx.subProject.id, filter.status.uncheck, filterTids, used);// await ctx.service.change.checkingDatas(tender.id, ctx.session.sessionUser.accountId);
            filter.count[filter.status.checking] = await ctx.service.financialPay.getCountByStatus(ctx.subProject.id, filter.status.checking, filterTids, used);// await ctx.service.change.checkedDatas(tender.id, ctx.session.sessionUser.accountId);
            filter.count[filter.status.checked] = await ctx.service.financialPay.getCountByStatus(ctx.subProject.id, filter.status.checked, filterTids, used);// await ctx.service.change.pendingDatas(tender.id, ctx.session.sessionUser.accountId);
            const payList = await ctx.service.financialPay.getListByStatus(ctx.subProject.id, status, filterTids, used);
            // 获取所有项目参与者
            const accountList = await ctx.service.projectAccount.getAllDataByCondition({
                where: { project_id: ctx.session.sessionProject.id, enable: 1 },
                columns: ['id', 'account', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
            });
            const payTenders = await ctx.service.financialPayTender.getAllDataByCondition({ where: { spid: ctx.subProject.id } });
            for (const t of tenders) {
                const fptReportTids = ctx.helper._.map(ctx.helper._.filter(fptAudits, { is_report: 1 }), 'tid');
                const info = await ctx.service.tenderInfo.getDataByCondition({ tid: t.id });
                t.pay_account = info && info.pay_account ? JSON.parse(info.pay_account).project : '';
                const pt = ctx.helper._.find(payTenders, { tid: t.id });
                t.pt = pt ? pt : { id: 0, tid: t.id, name: '', bank: '', bank_account: '', contact: '', phone: '' };
                if (ctx.session.sessionUser.is_admin || ctx.helper._.includes(fptReportTids, t.id)) {
                    t.dealCode = info && info.deal_info ? JSON.parse(info.deal_info).dealCode : '';
                    const lastPay = await ctx.service.financialPay.getAllDataByCondition({ where: { spid: ctx.subProject.id, tid: t.id }, columns: ['code'], orders: [['id', 'desc']], limit: 1 });
                    t.startNum = 1;
                    if (lastPay.length > 0) {
                        const startArray = lastPay[0].code.split('-');
                        t.startNum = parseInt(startArray[startArray.length - 1]) + 1;
                    }
                }
            }
            for (const pay of payList) {
                const t = ctx.helper._.find(tenders, { id: pay.tid });
                pay.tenderName = t ? t.name : '';
                const userInfo = ctx.helper._.find(accountList, { id: pay.uid });
                pay.username = userInfo ? userInfo.name : '';
                if (pay.status !== auditConst.financial.status.checked || !pay.final_auditor_str) {
                    pay.curAuditors = await ctx.service.financialPayAudit.getAuditorsByStatus(pay.id, pay.status, pay.times);
                    if (pay.status === auditConst.financial.status.checked && pay.curAuditors.length > 0) {
                        const final_auditor_str = pay.curAuditors[0].audit_type === auditConst.auditType.key.common
                            ? pay.curAuditors[0].name + (pay.curAuditors[0].role ? '-' + pay.curAuditors[0].role : '')
                            : ctx.helper.transFormToChinese(pay.curAuditors[0].audit_order) + '审';
                        await ctx.service.financialPay.defaultUpdate({ final_auditor_str }, { where: { id: pay.id } });
                    }
                }
                if (pay.status === auditConst.financial.status.uncheck || pay.status === auditConst.financial.status.checkNo) {
                    pay.entities = await ctx.service.financialPayContract.getEntities(pay.id);
                }
            }
            if (ctx.session.sessionUser.is_admin) {
                for (const t of tenders) {
                    t.permissionList = await ctx.service.financialPayTenderAudit.getList(ctx.subProject.id, t.id, accountList);
                    t.auditGroupList = await ctx.service.shenpiAudit.getAuditGroupList(t.id, shenpiConst.sp_other_type.financial, shenpiConst.sp_status.gdspl);
                }
            }
            const renderData = {
                tenders,
                financialPermission,
                usedList: financialConst.used,
                auditConst: auditConst.financial,
                filter,
                tid,
                status,
                used,
                payList,
                fptAuditTids,
                moment,
                auditType: auditConst.auditType,
                preUrl: '/financial',
                jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.pay),
            };
            if (ctx.session.sessionUser.is_admin) {
                const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
                renderData.accountList = accountList;
                renderData.accountGroup = unitList.map(item => {
                    const groupList = accountList.filter(item1 => item1.company === item.name);
                    return { groupName: item.name, groupList };
                });
                renderData.auditType = auditConst.auditType;
                renderData.shenpi = shenpiConst;
            }
            await this.layout('financial/pay.ejs', renderData, 'financial/pay_modal.ejs');
        }

        async paySave(ctx) {
            try {
                const responseData = {
                    err: 0, msg: '', data: {},
                };
                const data = JSON.parse(ctx.request.body.data);
                if (!data.type) {
                    throw '提交数据错误';
                }
                let uids;
                let result = false;
                let auditList = [];
                switch (data.type) {
                    case 'add-tender-audit':
                        // 判断用户是单个还是数组
                        if (!data.tid) throw '参数有误';
                        uids = data.id instanceof Array ? data.id : [data.id];
                        // 判断该用户的组是否已加入到表中，已加入则提示无需添加
                        auditList = await ctx.service.financialPayTenderAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id, tid: data.tid } });
                        const addAidList = ctx.helper._.difference(uids, ctx.helper._.map(auditList, 'uid'));
                        if (addAidList.length === 0) {
                            throw '用户已存在填报人列表中，无需重复添加';
                        }
                        const accountList = await ctx.service.projectAccount.getAllDataByCondition({ where: { id: addAidList } });
                        await ctx.service.financialPayTenderAudit.saveAudits(ctx.subProject.id, data.tid, accountList);
                        responseData.data = await ctx.service.financialPayTenderAudit.getList(ctx.subProject.id, data.tid);
                        break;
                    case 'del-tender-audit':
                        if (!data.tid) throw '参数有误';
                        uids = data.id instanceof Array ? data.id : [data.id];
                        auditList = await ctx.service.financialPayTenderAudit.getAllDataByCondition({ where: { id: uids } });
                        if (auditList.length !== uids.length) {
                            throw '该用户已不存在填报人列表中，移除失败';
                        }
                        responseData.data = await ctx.service.financialPayTenderAudit.delAudits(ctx.subProject.id, data.tid, auditList);
                        // responseData.data = await ctx.service.financialPayTenderAudit.getList(ctx.subProject.id, data.tid);
                        break;
                    case 'save-permission':
                        result = await ctx.service.financialPayTenderAudit.updatePermission(data.updateData);
                        if (!result) {
                            throw '修改权限失败';
                        }
                        break;
                    case 'copy-tender-audit':
                        responseData.data = await ctx.service.financialPayTenderAudit.copyAudit2otherTender(ctx.subProject.id, data, data.this_tid);
                        break;
                    case 'add-shenpi-audit':
                        responseData.data = await ctx.service.financialPayTenderAudit.addShenpiAudit(ctx.subProject.id, data.shenpi, data.tid);
                        break;
                    case 'copy-shenpi-audit':
                        responseData.data = await ctx.service.financialPayTenderAudit.copyShenpi2otherTender(ctx.subProject.id, data, data.this_tid);
                        break;
                    case 'add-pay':
                        responseData.data = await ctx.service.financialPay.addPay(ctx.subProject.id, data.updateData);
                        break;
                    case 'del-pay':
                        responseData.data = await ctx.service.financialPay.delPay(data.postData.node);
                        break;
                    case 'set-pay-tender':
                        responseData.data = await ctx.service.financialPayTender.savePayTender(ctx.subProject.id, data.updateData);
                        break;
                    case 'get-auditors':
                        const fpInfo = await ctx.service.financialPay.getDataById(data.id);
                        await ctx.service.financialPay.loadPayUser(fpInfo);
                        await ctx.service.financialPay.loadFinancialPayAuditViewData(fpInfo);
                        responseData.data = fpInfo;
                        break;
                    default: throw '参数有误';
                }
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: {} };
            }
        }

        /**
         * 获取审批界面所需的 原报、审批人数据等
         * @param ctx
         * @return {Promise<void>}
         * @private
         */
        async _getFinancialAuditViewData(ctx) {
            await ctx.service.financialPay.loadFinancialPayAuditViewData(ctx.financialPay);
        }

        async payDetail(ctx) {
            try {
                if (!ctx.financialPay.permission.pay_show) {
                    throw '没有查看权限';
                }
                await this._getFinancialAuditViewData(ctx);
                // 获取附件列表
                const fileList = await ctx.service.financialPayAtt.getAtt(ctx.financialPay.id);
                const renderData = {
                    financialPermission: ctx.financialPay.permission,
                    financialPay: ctx.financialPay,
                    usedList: financialConst.used,
                    payTypeList: financialConst.pay_type,
                    auditConst: auditConst.financial,
                    auditType: auditConst.auditType,
                    whiteList: ctx.app.config.multipart.whitelist,
                    moment,
                    fileList,
                    preUrl: '/financial/' + ctx.subProject.id + '/pay',
                    preUrl2: '/financial/' + ctx.subProject.id + '/pay/' + ctx.financialPay.id,
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.payDetail),
                };
                await this.layout('financial/pay_detail.ejs', renderData, 'financial/pay_detail_modal.ejs');
            } catch (err) {
                this.log(err);
                ctx.redirect('/financial');
            }
        }

        /**
         * 上报和重新上报
         * @param ctx
         * @return {Promise<void>}
         */
        async startPayAudit(ctx) {
            try {
                // 检查权限等
                if (!ctx.financialPay) {
                    throw '数据错误';
                }
                if (ctx.financialPay.uid !== ctx.session.sessionUser.accountId) {
                    throw '您无权上报该资金支付数据';
                }
                if (ctx.financialPay.status === auditConst.financial.status.checking || ctx.financialPay.status === auditConst.financial.status.checked) {
                    throw '该资金支付数据当前无法上报';
                }

                await ctx.service.financialPayAudit.start(ctx.financialPay.id, ctx.financialPay.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
         * @return {Promise<void>}
         */
        async checkPayAudit(ctx) {
            try {
                if (!ctx.financialPay || ctx.financialPay.status !== auditConst.financial.status.checking) {
                    throw '当前资金支付数据有误';
                }
                if (ctx.financialPay.curAuditorIds.length === 0 || ctx.financialPay.curAuditorIds.indexOf(ctx.session.sessionUser.accountId) === -1) {
                    throw '您无权进行该操作';
                }
                const data = {
                    checkType: parseInt(ctx.request.body.checkType),
                    opinion: ctx.request.body.opinion,
                };
                if (!data.checkType || isNaN(data.checkType)) {
                    throw '提交数据错误';
                }
                await ctx.service.financialPayAudit.check(ctx.financialPay, data);

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

        async payDetailSave(ctx) {
            try {
                const responseData = {
                    err: 0, msg: '', data: {},
                };
                const data = JSON.parse(ctx.request.body.data);
                if (!data.type) {
                    throw '提交数据错误';
                }
                if (data.type !== 'pay_contract_list' && data.type !== 'file_bill') {
                    if (ctx.financialPay.status !== auditConst.financial.status.uncheck && ctx.financialPay.status !== auditConst.financial.status.checkNo) {
                        throw '该状态下不允许编辑';
                    }
                    if (ctx.financialPay.uid !== ctx.session.sessionUser.accountId) {
                        throw '非该资金支付填报人无权限编辑';
                    }
                }
                switch (data.type) {
                    case 'pay_save':
                        responseData.data = await ctx.service.financialPay.savePay(ctx.financialPay.id, data);
                        break;
                    case 'pay_contract_list':
                        responseData.data = await ctx.service.financialPayContract.getContractList(ctx.financialPay.id);
                        break;
                    case 'contract_list':
                        responseData.data.contracts = await ctx.service.contract.getAllDataByCondition({ where: { tid: ctx.financialPay.tid, contract_type: 1 } });
                        responseData.data.contractTrees = await ctx.service.contractTree.getAllDataByCondition({ where: { tid: ctx.financialPay.tid, contract_type: 1 } });
                        break;
                    case 'contract_white_add':
                        responseData.data = await ctx.service.financialPayContract.addWhiteContract(ctx.financialPay);
                        break;
                    case 'contract_add':
                        responseData.data = await ctx.service.financialPayContract.addContracts(ctx.financialPay, data.contract_ids);
                        break;
                    case 'contract_del':
                        responseData.data = await ctx.service.financialPayContract.delContract(ctx.financialPay.id, data.ids);
                        break;
                    case 'contract_update':
                        responseData.data = await ctx.service.financialPayContract.updateContract(ctx.financialPay.id, data.updateData);
                        break;
                    case 'contract_paste':
                        responseData.data = await ctx.service.financialPayContract.updateContracts(ctx.financialPay.id, data.updateData);
                        break;
                    case 'file_bill':
                        responseData.data = await ctx.service.financialPayAtt.updateBill(data.id, data.bill);
                        break;
                    default: throw '参数有误';
                }
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: {} };
            }
        }

        /**
         * 上传附件
         * @param {*} ctx 上下文
         */
        async payUploadFile(ctx) {
            let stream;
            try {
                const parts = this.ctx.multipart({
                    autoFields: true,
                });
                const files = [];
                const create_time = Date.parse(new Date()) / 1000;
                let idx = 0;
                // const extra_upload = ctx.financialPay.status === auditConst.status.checked;
                while ((stream = await parts()) !== undefined) {
                    if (!stream.filename) {
                        // 如果没有传入直接返回
                        return;
                    }
                    const fileInfo = path.parse(stream.filename);
                    const filepath = `sp/financial/${ctx.subProject.id}/pay/${ctx.financialPay.id}/fujian_${create_time + idx.toString() + fileInfo.ext}`;
                    // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, 'app', filepath));
                    await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
                    files.push({ filepath, name: stream.filename, ext: fileInfo.ext });
                    ++idx;
                    stream && (await sendToWormhole(stream));
                }
                const in_time = new Date();
                const type = parts.field.type ? parseInt(parts.field.type) : 0;
                const fpcid = parts.field.fpcid ? parseInt(parts.field.fpcid) : null;
                const payload = files.map(file => {
                    let idx;
                    if (Array.isArray(parts.field.name)) {
                        idx = parts.field.name.findIndex(name => name === file.name);
                    } else {
                        idx = 'isString';
                    }
                    const newFile = {
                        spid: ctx.subProject.id,
                        fpid: ctx.financialPay.id,
                        fpcid,
                        uid: ctx.session.sessionUser.accountId,
                        filename: file.name,
                        fileext: file.ext,
                        filesize: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
                        filepath: file.filepath,
                        upload_time: in_time,
                        type,
                    };
                    return newFile;
                });
                // 执行文件信息写入数据库
                await ctx.service.financialPayAtt.saveFileMsgToDb(payload);
                // 将最新的当前标段的所有文件信息返回
                const data = await ctx.service.financialPayAtt.getAtt(ctx.financialPay.id, fpcid);
                ctx.body = { err: 0, msg: '', data };
            } catch (err) {
                stream && (await sendToWormhole(stream));
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        /**
         * 删除附件
         * @param {Ojbect} ctx 上下文
         */
        async payDeleteFile(ctx) {
            try {
                const { fpcid, id } = JSON.parse(ctx.request.body.data);
                const fileInfo = await ctx.service.financialPayAtt.getDataById(id);
                if (fileInfo || Object.keys(fileInfo).length) {
                    // 先删除文件
                    // await fs.unlinkSync(path.resolve(this.app.baseDir, './app', fileInfo.filepath));
                    await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
                    // 再删除数据库
                    await ctx.service.financialPayAtt.delete(id);
                } else {
                    throw '不存在该文件';
                }
                const data = await ctx.service.financialPayAtt.getAtt(ctx.financialPay.id, fpcid ? fpcid : null);
                ctx.body = { err: 0, msg: '请求成功', data };
            } catch (err) {
                this.log(err);
                ctx.body = { err: 1, msg: err.toString(), data: null };
            }
        }

        /**
         * 下载附件
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        async payDownloadFile(ctx) {
            const id = ctx.params.fid;
            if (id) {
                try {
                    const fileInfo = await ctx.service.financialPayAtt.getDataById(id);
                    if (fileInfo !== undefined && fileInfo !== '') {
                        // const fileName = path.join(__dirname, '../', 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);
                        } else if (userAgent.indexOf('firefox') >= 0) {
                            disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename) + '"';
                        } else {
                            /* safari等其他非主流浏览器只能自求多福了 */
                            disposition = 'attachment; filename=' + new Buffer(fileInfo.filename).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 FinancialController;
};