Calculation/app/controller/pay_controller.js

'use strict';

/**
 * 合同支付
 *
 * @author Mai
 * @date
 * @version
 */

const audit = require('../const/audit');

module.exports = app => {

    class PayController extends app.BaseController {
        /**
         * 构造函数
         *
         * @param {Object} ctx - egg全局变量
         * @return {void}
         */
        constructor(ctx) {
            super(ctx);
        }

        async index(ctx) {
            try {
                const phasePays = await this.ctx.service.phasePay.getAllPhasePay(ctx.tender.id, 'DESC');
                const relaStage = [];
                for (const p of phasePays) {
                    // todo 加载当前审批人
                    // if (p.audit_status !== checked) await this.ctx.service.phasePay.loadUser(p);
                    p.curAuditors = [];
                    relaStage.push(...p.rela_stage);
                }
                const stages = await this.ctx.service.stage.getAllDataByCondition({ where: { tid: ctx.tender.id }, orders: [['order', 'AEC']] });
                const validStages = stages.filter(s => {
                    return !relaStage.find(r => { return s.id === r.id; });
                });
                this.ctx.service.phasePay.calculatePhasePay(phasePays);
                const renderData = {
                    phasePays,
                    validStages,
                    auditConst: audit.common,
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.phasePay.list)
                };
                await this.layout('phase_pay/index.ejs', renderData, 'phase_pay/modal.ejs');
            } catch (err) {
                ctx.helper.log(err);
            }
        }

        async add(ctx) {
            try {
                if (ctx.session.sessionUser.accountId !== ctx.tender.data.user_id && ctx.tender.userAssistsId.indexOf(ctx.session.sessionUser.accountId) < 0) {
                    throw '您无权创建计量期';
                }
                const date = ctx.request.body.date;
                if (!date) throw '请选择支付年月';
                const stage = ctx.request.body.stage;
                if (!stage) throw '请选择计量期';
                const memo = ctx.request.body.memo;

                const pays = await ctx.service.phasePay.getAllPhasePay(ctx.tender.id, 'DESC');
                const unCompleteCount = pays.filter(s => { return s.status !== audit.common.status.checked; }).length;
                if (unCompleteCount.length > 0) throw `最新一起未审批通过，请审批通过后再新增`;
                // 预留可以关联多期
                const stages = await ctx.service.stage.getAllDataByCondition({ where: { tid: ctx.tender.id, order: stage } });

                const newPhase = await ctx.service.phasePay.add(ctx.tender.id, stages, date, memo);
                if (!newPhase) throw '新增期失败';

                ctx.redirect('/tender/' + ctx.tender.id + '/pay' + newPhase.phase_order);
            } catch (err) {
                this.log(err);
                ctx.postError(err, '新增期失败');
                ctx.redirect(ctx.request.header.referer);
            }
        }

        async del() {

        }

        async save() {

        }

        async detail(ctx) {
            try {
                const pays = await this.ctx.service.phasePayDetail.getDetailData(ctx.phasePay);
                const calcBase = this.ctx.service.phasePay.getPhasePayCalcBase(ctx.phasePay, ctx.tender.info);
                const renderData = {
                    pays,
                    calcBase,
                    jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.phasePay.detail)
                };
                await this.layout('phase_pay/detail.ejs', renderData, 'phase_pay/detail_modal.ejs');
            } catch (err) {
                ctx.helper.log(err);
                ctx.postError(err, '读取合同支付数据错误');
                ctx.redirect(ctx.request.headers.referer);
            }
        }

        async _detailBase(phasePay, type, data) {
            if (isNaN(data.id) || data.id <= 0) throw '数据错误';
            if (type !== 'add') {
                if (isNaN(data.count) || data.count <= 0) data.count = 1;
            }
            switch (type) {
                case 'add':
                    return await this.ctx.service.phasePayDetail.addDetailNode(phasePay, data.id, data.count);
                case 'delete':
                    return await this.ctx.service.phasePayDetail.delete(phasePay.id, data.id, data.count);
                case 'up-move':
                    return await this.ctx.service.phasePayDetail.upMoveNode(phasePay.id, data.id, data.count);
                case 'down-move':
                    return await this.ctx.service.phasePayDetail.downMoveNode(phasePay.id, data.id, data.count);
            }
        }
        async detailUpdate(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 'add':
                    case 'delete':
                    case 'up-move':
                    case 'down-move':
                        responseData.data = await this._billsBase(ctx.detail, data.postType, data.postData);
                        break;
                    case 'update':
                        responseData.data = await this.ctx.service.phasePayDetail.updateCalc(ctx.detail, data.postData);
                        break;
                    default:
                        throw '未知操作';
                }
                ctx.body = responseData;
            } catch (err) {
                this.log(err);
                ctx.body = this.ajaxErrorBody(err, '数据错误');
            }
        }

        async uploadFile(ctx) {
            let stream;
            try {
                const parts = ctx.multipart({ autoFields: true });
                let index = 0;
                const create_time = Date.parse(new Date()) / 1000;
                let stream = await parts();
                const bonus = await ctx.service.stageBonus.getStageDataById(parts.field.bonus_id);
                //if (!bonus || bonus.sid !== ctx.stage.id) throw '该奖罚金，当前不允许上传附件';
                while (stream !== undefined) {
                    if (!stream.filename) {
                        throw '未发现上传文件!';
                    }

                    const fileInfo = path.parse(stream.filename);
                    const dirName = 'app/public/upload/extra/' + moment().format('YYYYMMDD');
                    const fileName = create_time + '_' + index + fileInfo.ext;

                    // 保存文件
                    await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, dirName, fileName));
                    await sendToWormhole(stream);

                    // 插入到stage_pay对应的附件列表中
                    bonus.proof_file.push({
                        filename: fileInfo.name,
                        fileext: fileInfo.ext,
                        filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
                        filepath: path.join(dirName, fileName),
                        uid: ctx.session.sessionUser.accountId,
                        in_time: moment(create_time * 1000).format('YYYY-MM-DD'),
                        renew: bonus.sid === ctx.stage.id ? ctx.stage.status === auditConst.status.checked : true,
                    });
                    ++index;
                    if (Array.isArray(parts.field.size) && index < parts.field.size.length) {
                        stream = await parts();
                    } else {
                        stream = undefined;
                    }
                }
                const result = await ctx.service.stageBonus.updateDatas({
                    update: [
                        { id: bonus.id, proof_file: bonus.proof_file },
                    ]
                });
                for (const pf of bonus.proof_file) {
                    pf.username = (await ctx.service.projectAccount.getAccountInfoById(pf.uid)).name;
                    if (ctx.helper.canPreview(pf.fileext)){
                        pf.viewpath = pf.filepath.substr(3, pf.filepath.length - 3);
                    }
                    delete pf.filepath;
                }
                ctx.body = {err: 0, msg: '', data: bonus.proof_file};
            } catch (error) {
                ctx.helper.log(error);
                // 失败需要消耗掉stream 以防卡死
                if (stream) {
                    await sendToWormhole(stream);
                }
                ctx.body = this.ajaxErrorBody(error, '上传附件失败，请重试');
            }
        }

        async deleteFile(ctx) {
            try {
                const data = JSON.parse(ctx.request.body.data);

                const bonus = await ctx.service.stageBonus.getStageDataById(data.b_id);
                if (!bonus || !bonus.proof_file || !bonus.proof_file[data.index]) throw '删除的文件不存在';

                const fileInfo = bonus.proof_file[data.index];
                if (fileInfo.uid !== ctx.session.sessionUser.accountId) throw '您无权删除该文件';

                const deleteFilePermission = PermissionCheck.delFile(this.ctx.session.sessionUser.permission);
                if (ctx.stage.status === auditConst.status.checked && !fileInfo.renew && !deleteFilePermission) throw '不可删除该文件';

                // 先删除文件
                await fs.unlinkSync(path.join(this.app.baseDir, fileInfo.filepath));
                // 再删除数据库
                bonus.proof_file.splice(data.index, 1);
                const result = await ctx.service.stageBonus.updateDatas({
                    update: [
                        { id: bonus.id, proof_file: bonus.proof_file },
                    ]
                });
                for (const pf of bonus.proof_file) {
                    delete pf.filepath;
                    pf.username = (await ctx.service.projectAccount.getAccountInfoById(pf.uid)).name;
                }
                ctx.body = {err: 0, msg: '', data: bonus.proof_file};
            } catch (err) {
                this.log(err);
                this.ctx.ajaxErrorBody(err, '删除文件失败');
            }
        }
    }

    return PayController;
};