| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614 | 
							- 'use strict';
 
- const accountGroup = require('../const/account_group').group;
 
- const auditConst = require('../const/audit').advance;
 
- const shenpiConst = require('../const/shenpi');
 
- const typeConsts = require('../const/advance');
 
- const sendToWormhole = require('stream-wormhole');
 
- const path = require('path');
 
- const fs = require('fs');
 
- module.exports = app => {
 
-     class advanceController extends app.BaseController {
 
-         constructor(ctx) {
 
-             super(ctx);
 
-             const { decimal } = ctx.tender.info;
 
-             this.decimal = decimal.pay ? decimal.payTp : decimal.tp;
 
-         }
 
-         /**
 
-          * 开工预付款页面(AJAX) GET
 
-          * @param {Object} ctx 全局上下文
 
-          */
 
-         async index(ctx) {
 
-             const advanceType = typeConsts.typeCol.find(item => item.key === ctx.params.type);
 
-             const type = advanceType.type;
 
-             const advancePayTotal = ctx.tender.info.deal_param[`${advanceType.key}Advance`];
 
-             const advanceList = await ctx.service.advance.getAdvanceList(ctx.tender.id, type, this.decimal, advancePayTotal);
 
-             const latestOrder = await ctx.service.advance.getLastestAdvance(ctx.tender.id, type, true);
 
-             const progress = await ctx.service.advance.calcProgress(latestOrder, advancePayTotal);
 
-             const showAddBtn = ctx.tender.data.user_id === ctx.session.sessionUser.accountId ? (!latestOrder || (latestOrder.status === auditConst.status.checked && latestOrder.prev_total_amount < advancePayTotal)) : false;
 
-             const renderData = {
 
-                 type,
 
-                 decimal: this.decimal,
 
-                 showAddBtn,
 
-                 advanceList,
 
-                 latestOrder,
 
-                 auditConst,
 
-                 typeColMap: typeConsts.typeColMap,
 
-                 preUrl: `/tender/${ctx.tender.id}/advance/${type}/create`,
 
-                 jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.advance.main),
 
-                 advancePayTotal,
 
-                 progress,
 
-             };
 
-             await this.layout('advance/index.ejs', renderData, 'advance/modal.ejs');
 
-         }
 
-         /**
 
-          * 材料预付款页面(AJAX) GET
 
-          * @param {Object} ctx 全局上下文
 
-          */
 
-         // async materialList(ctx) {
 
-         //     const type = auditConst.type.material;
 
-         //     const advancePayTotal = ctx.tender.info.deal_param.materialAdvance;
 
-         //     const advanceList = await ctx.service.advance.getAdvanceList(ctx.tender.id, type, this.decimal, advancePayTotal);
 
-         //     const latestOrder = await ctx.service.advance.getLastestAdvance(ctx.tender.id, type, true);
 
-         //     const progress = await ctx.service.advance.calcProgress(latestOrder, advancePayTotal);
 
-         //     const showAddBtn = ctx.tender.data.user_id === ctx.session.sessionUser.accountId ? !latestOrder || (latestOrder.status === auditConst.status.checked && latestOrder.prev_total_amount < advancePayTotal) : false;
 
-         //     const renderData = {
 
-         //         type,
 
-         //         decimal: this.decimal,
 
-         //         showAddBtn,
 
-         //         advanceList,
 
-         //         latestOrder,
 
-         //         auditConst,
 
-         //         preUrl: `/tender/${ctx.tender.id}/advance/${type}/create`,
 
-         //         jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.advance.main),
 
-         //         advancePayTotal,
 
-         //         progress,
 
-         //     };
 
-         //     await this.layout('advance/index.ejs', renderData, 'advance/modal.ejs');
 
-         // }
 
-         /**
 
-          * 获取通用的renderData(用于layout, Menu, subMenu部分)
 
-          * @param {Object} ctx 全局上下文
 
-          * @return {{auditConst, jsFiles, accountGroup?, accountList?, auditors, auditHistory, preUrl}} 通用数据
 
-          * @private
 
-          */
 
-         async _getDefaultRenderData(ctx) {
 
-             const data = {
 
-                 auditConst,
 
-                 shenpiConst,
 
-                 jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.advance.info),
 
-                 preUrl: `/tender/${ctx.tender.id}/advance/${ctx.advance.id}`,
 
-                 whiteList: ctx.app.config.multipart.whitelist,
 
-             };
 
-             // 获取所有项目参与者
 
-             if ((ctx.advance.status === auditConst.status.uncheck || ctx.advance.status === auditConst.status.checkNo) && ctx.session.sessionUser.accountId === ctx.advance.uid) {
 
-                 // data.accountGroup = accountGroup;
 
-                 // 获取所有项目参与者
 
-                 const accountList = await ctx.service.projectAccount.getAllSubProjectAccount(ctx.subProject);
 
-                 data.accountList = accountList;
 
-                 const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
 
-                 data.accountGroup = unitList.map(item => {
 
-                     const groupList = accountList.filter(item1 => item1.company === item.name);
 
-                     return { groupName: item.name, groupList };
 
-                 }).filter(x => { return x.groupList.length > 0; });
 
-                 data.auditorList = await ctx.service.advanceAudit.getAuditors(ctx.advance.id, ctx.advance.times);
 
-             }
 
-             // data.fileList = await ctx.service.advanceFile.getAdvanceFiles({ vid: ctx.advance.id });
 
-             // 获取审批流程中右边列表
 
-             const auditHistory = [];
 
-             const times = ctx.advance.status === auditConst.status.checkNo ? ctx.advance.times - 1 : ctx.advance.times;
 
-             // 获取审核人左边列表
 
-             data.auditors = ctx.advance.status === auditConst.status.checkNo && ctx.session.sessionUser.accountId !== ctx.advance.uid ?
 
-                 await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, times) :
 
-                 await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, ctx.advance.times);
 
-             if (times >= 1) {
 
-                 for (let i = 1; i <= times; i++) {
 
-                     auditHistory.push(await ctx.service.advanceAudit.getAuditors(ctx.advance.id, i));
 
-                 }
 
-             }
 
-             data.auditHistory = auditHistory;
 
-             data.fileList = await ctx.service.advanceFile.getAdvanceFiles({ vid: ctx.advance.id }) || [];
 
-             return data;
 
-         }
 
-         /**
 
-          * 权限判断-进入详情页
 
-          * @param {Object} ctx - 全局上下文
 
-          * @return {void}
 
-          * @private
 
-          */
 
-         async _checkCanEntry(ctx) {
 
-             ctx.advance.filePermission = false;
 
-             if (ctx.advance.status === auditConst.status.uncheck) {
 
-                 if (ctx.session.sessionUser.accountId !== ctx.advance.uid && !ctx.tender.isTourist && !ctx.session.sessionUser.is_admin) {
 
-                     throw '无权访问';
 
-                 } else if (ctx.session.sessionUser.accountId === ctx.advance.uid || ctx.tender.touristPermission.file) {
 
-                     ctx.advance.filePermission = true;
 
-                 }
 
-             } else {
 
-                 const auditors = await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, ctx.advance.times);
 
-                 const cur_uid = ctx.session.sessionUser.accountId;
 
-                 if (auditors.findIndex(item => item.audit_id === cur_uid) === -1 && !ctx.tender.isTourist && !ctx.session.sessionUser.is_admin) {
 
-                     throw '无权访问';
 
-                 } else if (auditors.findIndex(item => item.audit_id === cur_uid) !== -1 || ctx.session.sessionUser.accountId === ctx.advance.uid || ctx.tender.touristPermission.file) {
 
-                     ctx.advance.filePermission = true;
 
-                 }
 
-             }
 
-         }
 
-         /**
 
-          * 预付款详情页(AJAX) GET
 
-          * @param {Object} ctx 全局上下文
 
-          */
 
-         async detail(ctx) {
 
-             const advancePayTotal = ctx.tender.info.deal_param[`${typeConsts.typeColMap[ctx.advance.type].value}Advance`];
 
-             try {
 
-                 await this._checkCanEntry(ctx);
 
-                 const { uncheck, checkNo, checked } = auditConst.status;
 
-                 const { status } = ctx.advance;
 
-                 const isEdited = ctx.session.sessionUser.accountId === ctx.advance.uid && (status === uncheck || status === checkNo);
 
-                 const renderData = await this._getDefaultRenderData(ctx);
 
-                 // 获取上一期预付款记录
 
-                 const prevAdvance = await ctx.service.advance.getPreviousRecord(ctx.tender.id, ctx.advance.type);
 
-                 // 最大支付比例
 
-                 const max_pr = ctx.helper.mul(ctx.helper.div(ctx.helper.sub(advancePayTotal, (prevAdvance && prevAdvance.prev_total_amount || 0)), advancePayTotal, 10), 100);
 
-                 const isLimitMax = ctx.helper.round(max_pr, 2) === ctx.advance.pay_ratio;
 
-                 // 特殊处理金额的显示(formatMoney)
 
-                 let cur_amount,
 
-                     prev_total_amount;
 
-                 const s1 = parseFloat(ctx.advance.prev_amount).toString().split('.')[1] || '';
 
-                 const prev_amount = ctx.helper.formatMoney(ctx.advance.prev_amount, ',', isLimitMax ? s1.length : 2);
 
-                 if (status === uncheck || status === checkNo) {
 
-                     // cur_amount = parseFloat(ctx.helper.round(ctx.advance.cur_amount, 2)) || 0;
 
-                     cur_amount = ctx.advance.cur_amount || 0;
 
-                     const s2 = parseFloat(ctx.helper.add(cur_amount, ctx.advance.prev_amount)).toString().split('.')[1] || '';
 
-                     prev_total_amount = ctx.helper.formatMoney(ctx.helper.add(cur_amount, ctx.advance.prev_amount), ',', isLimitMax ? s2.length : 2);
 
-                 } else {
 
-                     cur_amount = ctx.advance.cur_amount;
 
-                     const s2 = parseFloat(ctx.advance.prev_total_amount).toString().split('.')[1] || '';
 
-                     prev_total_amount = ctx.helper.formatMoney(ctx.advance.prev_total_amount, ',', isLimitMax ? s2.length : 2);
 
-                 }
 
-                 ctx.advance.finalAuditorId = status === checked && ctx.advance.auditors && ctx.advance.auditors.length > 0 ? ctx.advance.auditors[ctx.advance.auditors.length - 1].audit_id : false;
 
-                 // 获取用户人验证手机号
 
-                 const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
 
-                 const auth_mobile = pa.auth_mobile;
 
-                 renderData.authMobile = auth_mobile;
 
-                 renderData.isEdited = isEdited;
 
-                 renderData.advance = ctx.advance;
 
-                 renderData.cur_amount = cur_amount;
 
-                 renderData.prev_amount = prev_amount;
 
-                 renderData.prev_total_amount = prev_total_amount;
 
-                 renderData.max_pr = max_pr;
 
-                 renderData.decimal = 2;
 
-                 renderData.typeColMap = typeConsts.typeColMap;
 
-                 renderData.advancePayTotal = advancePayTotal;
 
-                 renderData.prevAdvance = prevAdvance;
 
-                 await this.layout('advance/detail.ejs', renderData, 'advance/modal_audit.ejs');
 
-             } catch (error) {
 
-                 this.log(error);
 
-                 ctx.redirect('/tender/' + ctx.tender.id + '/advance/' + typeConsts.typeColMap[ctx.advance.type].value);
 
-             }
 
-         }
 
-         /**
 
-          * 更新
 
-          * @param {Object} ctx 全局上下文
 
-          */
 
-         async update(ctx) {
 
-             const { id } = ctx.advance;
 
-             const data = JSON.parse(ctx.request.body.data);
 
-             try {
 
-                 const result = await ctx.service.advance.updateAdvance(data, id);
 
-                 if (result) {
 
-                     ctx.body = { err: 0, msg: '请求成功', data: null };
 
-                 } else {
 
-                     ctx.body = { err: 0, msg: '请求失败', data: null };
 
-                 }
 
-             } catch (error) {
 
-                 this.log(error);
 
-                 ctx.body = { code: 1, msg: error.toString() };
 
-             }
 
-         }
 
-         /**
 
-          * 添加新一期
 
-          * @param {Object} ctx 全局上下文
 
-          */
 
-         async create(ctx) {
 
-             const type = parseInt(ctx.params.type);
 
-             try {
 
-                 // 参考变更令的做法,在创建新一期预付款时,需要copy前一个预付款报表的签名信息
 
-                 const lastAdvance = await ctx.service.advance.getLastestAdvance(ctx.tender.id, type, true);
 
-                 const record = await ctx.service.advance.createRecord(type);
 
-                 if (lastAdvance && record) {
 
-                     // 这里advance list是所有类型的合在一起,不会有重复的id
 
-                     await ctx.service.roleRptRel.createRoleRelationshipFromOtherBz(ctx.tender.id, '-400', record.id, lastAdvance.id);
 
-                 }
 
-                 if (!record) {
 
-                     throw '数据错误';
 
-                 }
 
-                 ctx.redirect(`/tender/${ctx.tender.id}/advance/${record.id}/detail`);
 
-             } catch (error) {
 
-                 this.log(error);
 
-                 ctx.redirect(`/tender/${ctx.tender.id}/advance/${typeConsts.typeColMap[ctx.advance.type].value}`);
 
-             }
 
-         }
 
-         /**
 
-          * 删除期
 
-          * @param {*} ctx 全局上下文
 
-          */
 
-         async delete(ctx) {
 
-             try {
 
-                 const data = JSON.parse(ctx.request.body.data);
 
-                 const id = data && this.app._.toInteger(data.id);
 
-                 if (isNaN(id) || id <= 0) {
 
-                     throw '参数错误';
 
-                 }
 
-                 const advance = await ctx.service.advance.getDataById(id);
 
-                 if (!advance) {
 
-                     throw '参数错误';
 
-                 }
 
-                 // 检查权限等
 
-                 if (!ctx.session.sessionUser.is_admin && advance.uid !== ctx.session.sessionUser.accountId) {
 
-                     throw '您无权删除';
 
-                 }
 
-                 if (!ctx.session.sessionUser.is_admin && advance.status !== auditConst.status.uncheck && advance.status !== auditConst.status.checkNo) {
 
-                     // console.log(advance.status !== auditConst.status.uncheck);
 
-                     // console.log(advance.status !== auditConst.status.checkNo);
 
-                     throw '当前不允许删除';
 
-                 }
 
-                 await ctx.service.advance.deleteAdvance(id, ctx.tender.id);
 
-                 ctx.body = { err: 0, msg: '' };
 
-             } catch (error) {
 
-                 this.log(error);
 
-                 ctx.body = { err: 1, msg: error.toString(), data: null };
 
-             }
 
-         }
 
-         /**
 
-          * 添加审批人
 
-          * @param {Object} ctx 全局上下文
 
-          */
 
-         async addAudit(ctx) {
 
-             try {
 
-                 const data = JSON.parse(ctx.request.body.data);
 
-                 const audit_id = data && this.app._.toInteger(data.auditorId);
 
-                 if (isNaN(audit_id) || audit_id <= 0) {
 
-                     throw '参数错误';
 
-                 }
 
-                 // 检查权限等
 
-                 if (ctx.advance.uid !== ctx.session.sessionUser.accountId) {
 
-                     throw '您无权添加审核人';
 
-                 }
 
-                 if (ctx.advance.status === auditConst.status.checking || ctx.advance.status === auditConst.status.checked) {
 
-                     throw '当前不允许添加审核人';
 
-                 }
 
-                 // 检查审核人是否已存在
 
-                 const exist = this.app._.find(ctx.advance.auditors, { audit_id });
 
-                 if (exist) {
 
-                     throw '该审核人已存在,请勿重复添加';
 
-                 }
 
-                 const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.advance, sp_status: shenpiConst.sp_status.gdzs });
 
-                 const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.advance === shenpiConst.sp_status.gdzs ? 1 : 0;
 
-                 const result = await ctx.service.advanceAudit.addAuditor(ctx.tender.id, ctx.advance.id, audit_id, ctx.advance.times, is_gdzs);
 
-                 if (!result) {
 
-                     throw '添加审核人失败';
 
-                 }
 
-                 const auditors = await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, ctx.advance.times);
 
-                 ctx.body = { err: 0, msg: '', data: auditors };
 
-             } catch (err) {
 
-                 this.log(err);
 
-                 ctx.body = { err: 1, msg: err.toString(), data: null };
 
-             }
 
-         }
 
-         /**
 
-          * 移除审批人
 
-          * @param {Object} ctx 全局上下文
 
-          */
 
-         async deleteAudit(ctx) {
 
-             try {
 
-                 const data = JSON.parse(ctx.request.body.data);
 
-                 const id = data && data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
 
-                 if (isNaN(id) || id <= 0) {
 
-                     throw '参数错误';
 
-                 }
 
-                 const result = await ctx.service.advanceAudit.deleteAuditor(ctx.advance.id, id, ctx.advance.times);
 
-                 if (!result) {
 
-                     throw '移除审核人失败';
 
-                 }
 
-                 const auditors = await ctx.service.advanceAudit.getAuditGroupByList(ctx.advance.id, ctx.advance.times);
 
-                 ctx.body = { err: 0, msg: '', data: auditors };
 
-             } catch (err) {
 
-                 ctx.body = { err: 1, msg: err.toString(), data: null };
 
-             }
 
-         }
 
-         /**
 
-          * 上报审批
 
-          * @param {Object} ctx 全局上下文
 
-          */
 
-         async start(ctx) {
 
-             const data = JSON.parse(ctx.request.body.data);
 
-             try {
 
-                 // 检查权限等
 
-                 if (!ctx.advance) {
 
-                     throw '数据错误';
 
-                 }
 
-                 if (ctx.advance.uid !== ctx.session.sessionUser.accountId) {
 
-                     throw '您无权上报该期数据';
 
-                 }
 
-                 if (ctx.advance.status === auditConst.status.checking || ctx.advance.status === auditConst.status.checked) {
 
-                     throw '该预付款期数据当前无法上报';
 
-                 }
 
-                 if (data.cur_amount === 0) {
 
-                     throw '本期金额不能为空';
 
-                 }
 
-                 await ctx.service.advanceAudit.start(ctx.advance.id, ctx.advance.times, data);
 
-                 ctx.body = { err: 0, msg: '' };
 
-             } catch (error) {
 
-                 this.log(error);
 
-                 ctx.session.postError = error.toString();
 
-                 ctx.body = { err: 1, msg: error.toString() };
 
-             }
 
-         }
 
-         /**
 
-          * 审批
 
-          * @param {Object} ctx 全局上下文
 
-          */
 
-         async checkAudit(ctx) {
 
-             try {
 
-                 if (!ctx.advance || ctx.advance.status !== auditConst.status.checking) {
 
-                     throw '当前预付款数据有误';
 
-                 }
 
-                 if (!ctx.advance.curAuditor || ctx.advance.curAuditor.audit_id !== ctx.session.sessionUser.accountId) {
 
-                     throw '您无权进行该操作';
 
-                 }
 
-                 const data = {
 
-                     checkType: parseInt(ctx.request.body.checkType),
 
-                     opinion: ctx.request.body.opinion,
 
-                 };
 
-                 if (!data.checkType || isNaN(data.checkType)) {
 
-                     throw '提交数据错误';
 
-                 }
 
-                 if (data.checkType === auditConst.status.checkNo) {
 
-                     if (!data.checkType || isNaN(data.checkType)) {
 
-                         throw '提交数据错误';
 
-                     }
 
-                 }
 
-                 await ctx.service.advanceAudit.check(ctx.advance.id, data, ctx.advance.times);
 
-                 ctx.redirect(ctx.request.header.referer);
 
-             } catch (err) {
 
-                 this.log(err);
 
-                 ctx.session.postError = err.toString();
 
-                 ctx.redirect(ctx.request.header.referer);
 
-             }
 
-         }
 
-         /**
 
-          * 重新审批
 
-          * @param {Object} ctx - egg全局变量
 
-          * @return {void}
 
-          */
 
-         async checkAgain(ctx) {
 
-             try {
 
-                 if (!ctx.advance || ctx.advance.status !== auditConst.status.checked) {
 
-                     throw '当前预付款数据有误';
 
-                 }
 
-                 const finalAuditorId = ctx.advance.auditors && ctx.advance.auditors.length > 0 ? ctx.advance.auditors[ctx.advance.auditors.length - 1].audit_id : false;
 
-                 if (!finalAuditorId || finalAuditorId !== ctx.session.sessionUser.accountId) {
 
-                     throw '您无权进行该操作';
 
-                 }
 
-                 if (ctx.session.sessionUser.loginStatus === 0) {
 
-                     const code = ctx.request.body.code;
 
-                     const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
 
-                     if (!pa.auth_mobile) {
 
-                         throw '未绑定手机号';
 
-                     }
 
-                     const cacheKey = 'smsCode:' + ctx.session.sessionUser.accountId;
 
-                     const cacheCode = await app.redis.get(cacheKey);
 
-                     // console.log(cacheCode);
 
-                     if (cacheCode === null || code === undefined || cacheCode !== (code + pa.auth_mobile)) {
 
-                         throw '验证码不正确!';
 
-                     }
 
-                 }
 
-                 // 重新审批
 
-                 const result = await ctx.service.advanceAudit.checkAgain(ctx.advance);
 
-                 if (!result) {
 
-                     throw '重新审批失败';
 
-                 }
 
-                 ctx.body = {
 
-                     err: 0,
 
-                     url: ctx.request.header.referer,
 
-                     msg: '',
 
-                 };
 
-             } catch (err) {
 
-                 console.log(err);
 
-                 ctx.body = {
 
-                     err: 1,
 
-                     msg: err,
 
-                 };
 
-             }
 
-         }
 
-         _checkAdvanceFileCanModify(ctx) {
 
-             // 检查登录用户,是否可操作
 
-             const accountId = ctx.session.sessionUser.accountId;
 
-             if (!ctx.advance.curAuditor) {
 
-                 if (ctx.advance.status === auditConst.status.uncheck || ctx.advance.status === auditConst.status.checkNo && accountId === ctx.advance.uid) {
 
-                     return;
 
-                 }
 
-                 throw '该预付款期当前您无权操作';
 
-             } else {
 
-                 if (ctx.advance.curAuditor.audit_id === accountId) return;
 
-                 throw '该预付款期当前您无权操作';
 
-             }
 
-         }
 
-         /**
 
-          * 上传附件
 
-          * @param {*} ctx 上下文
 
-          */
 
-         async upload(ctx) {
 
-             let stream;
 
-             try {
 
-                 // this._checkAdvanceFileCanModify(ctx);
 
-                 const parts = this.ctx.multipart({
 
-                     autoFields: true,
 
-                 });
 
-                 const files = [];
 
-                 const create_time = Date.parse(new Date()) / 1000;
 
-                 let idx = 0;
 
-                 const extra_upload = ctx.advance.status === auditConst.status.checked;
 
-                 while ((stream = await parts()) !== undefined) {
 
-                     if (!stream.filename) {
 
-                         // 如果没有传入直接返回
 
-                         return;
 
-                     }
 
-                     const fileInfo = path.parse(stream.filename);
 
-                     const filepath = `app/public/upload/${this.ctx.tender.id.toString()}/yfk/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 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 = {
 
-                         uid: ctx.session.sessionUser.accountId,
 
-                         vid: ctx.advance.id,
 
-                         tid: ctx.tender.id,
 
-                         create_time: in_time,
 
-                         filepath: file.filepath,
 
-                         filesize: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
 
-                         filename: file.name,
 
-                         fileext: file.ext,
 
-                         extra_upload,
 
-                     };
 
-                     return newFile;
 
-                 });
 
-                 // 执行文件信息写入数据库
 
-                 await ctx.service.advanceFile.saveFileMsgToDb(payload);
 
-                 // 将最新的当前标段的所有文件信息返回
 
-                 const data = await ctx.service.advanceFile.getAdvanceFiles({ vid: ctx.advance.id });
 
-                 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 deleteFile(ctx) {
 
-             try {
 
-                 const { id } = JSON.parse(ctx.request.body.data);
 
-                 const fileInfo = await ctx.service.advanceFile.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.advanceFile.delete(id);
 
-                 } else {
 
-                     throw '不存在该文件';
 
-                 }
 
-                 const data = await ctx.service.advanceFile.getAdvanceFiles({ vid: ctx.advance.id });
 
-                 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 downloadFile(ctx) {
 
-             const id = ctx.params.fid;
 
-             if (id) {
 
-                 try {
 
-                     const fileInfo = await ctx.service.advanceFile.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);
 
-                 }
 
-             }
 
-         }
 
-         /**
 
-          * 获取列表页所需的审核弹窗列表
 
-          * @param {object} ctx 全局上下文
 
-          */
 
-         async getAuditors(ctx) {
 
-             try {
 
-                 const data = {};
 
-                 // 获取审核人左边列表
 
-                 data.auditors = await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, ctx.advance.times);
 
-                 // 获取审批流程中右边列表
 
-                 const auditHistory = [];
 
-                 const times = ctx.advance.status === auditConst.status.checkNo ? ctx.advance.times - 1 : ctx.advance.times;
 
-                 if (times >= 1) {
 
-                     for (let i = 1; i <= times; i++) {
 
-                         auditHistory.push(await ctx.service.advanceAudit.getAuditors(ctx.advance.id, i));
 
-                     }
 
-                 }
 
-                 data.auditHistory = auditHistory;
 
-                 data.user = ctx.advance.user;
 
-                 ctx.body = { err: 0, msg: '请求成功', data };
 
-             } catch (error) {
 
-                 this.log(error);
 
-                 ctx.body = { err: 0, msg: error.toString() };
 
-             }
 
-         }
 
-     }
 
-     return advanceController;
 
- };
 
 
  |