123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098 |
- '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.subProject.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.getAllSubProjectAccount(ctx.subProject);
- // 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 };
- // }).filter(x => { return x.groupList.length > 0; });
- // // renderData.permissionConst = ctx.service.subProjPermission.PermissionConst;
- // renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
- // 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.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
- if (!financialPermission.transfer_show) {
- throw '没有查看权限';
- }
- const transferList = await ctx.service.financialTransfer.getList(ctx.subProject.id);
- const renderData = {
- financialPermission,
- transferList,
- moment,
- 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(`/sp/${ctx.subProject.id}/dashboard`);
- }
- }
- async transferAdd(ctx) {
- try {
- const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
- 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('/sp/' + ctx.subProject.id + '/financial/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.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
- if (!financialPermission.transfer_show) {
- throw '没有查看权限';
- }
- const trid = ctx.params.trid;
- 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, filter_fund: 0 } });
- 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: '/sp/' + ctx.subProject.id + '/financial/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(`/sp/${ctx.subProject.id}/financial/transfer`);
- }
- }
- 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.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
- if (!financialPermission.transfer_add) {
- throw '没有权限';
- }
- const trid = ctx.params.trid;
- 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.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
- if (!financialPermission.transfer_file) {
- throw '没有权限';
- }
- const responseData = { err: 0, msg: '', data: {} };
- const id = ctx.params.trid;
- 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.trid;
- 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.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
- if (!financialPermission.transfer_file) {
- throw '没有权限';
- }
- const responseData = { err: 0, msg: '', data: {} };
- const trid = ctx.params.trid;
- const id = ctx.params.ttid;
- 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.ttid;
- 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(`/sp/${ctx.subProject.id}/dashboard`);
- }
- }
- // /**
- // * 变更管理 状态筛选 页面 (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.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
- 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 fptReportTids = ctx.helper._.map(ctx.helper._.filter(fptAudits, { is_report: 1 }), 'tid');
- const filterTids = tid === null ? (ctx.session.sessionUser.is_admin ? null : fptAuditTids) : [tid];
- const tenderCondition = { spid: ctx.subProject.id, filter_fund: 0 };
- 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.getAllSubProjectAccount(ctx.subProject, ['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 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.checked) {
- 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,
- fptReportTids,
- 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 };
- }).filter(x => { return x.groupList.length > 0; });
- 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: `/sp/${ctx.subProject.id}/financial/pay`,
- preUrl2: `/sp/${ctx.subProject.id}/financial/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(`/sp/${ctx.subProject.id}/financial/pay`);
- }
- }
- /**
- * 上报和重新上报
- * @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, ctx.financialPay.status !== auditConst.financial.status.checked);
- break;
- case 'contract_list':
- responseData.data.contracts = await ctx.service.contract.getAllDataByCondition({ where: { tid: ctx.financialPay.tid, contract_type: 1 }, orders: [['level', 'asc'], ['order', 'asc']] });
- 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);
- }
- }
- }
- async summary(ctx) {
- try {
- const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
- if (!financialPermission.transfer_show && !financialPermission.pay_show) {
- throw '没有查看权限';
- }
- const renderData = {
- financialPermission,
- usedList: financialConst.used,
- // preUrl: '/financial',
- jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.summary),
- };
- await this.layout('financial/summary.ejs', renderData);
- } catch (err) {
- this.log(err);
- ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
- }
- }
- async summaryLoad(ctx) {
- try {
- const responseData = {
- err: 0, msg: '', data: {},
- };
- const tid = parseInt(ctx.query.tid) || null;
- 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;
- }
- responseData.data.tenders = hadTender ? await ctx.service.tender.getAllDataByCondition({ where: tenderCondition, columns: ['id', 'name'] }) : [];
- responseData.data.transferList = tid === null ? await ctx.service.financialTransfer.getAllDataByCondition({ where: { spid: ctx.subProject.id } }) : [];
- responseData.data.transferTenderList = tid === null ? await ctx.service.financialTransferTender.getAllDataByCondition({ where: { spid: ctx.subProject.id } }) : [];
- responseData.data.payList = await ctx.service.financialPay.getListByStatus(ctx.subProject.id, 0, filterTids);
- ctx.body = responseData;
- } catch (err) {
- this.log(err);
- ctx.body = { err: 1, msg: err.toString(), data: {} };
- }
- }
- }
- return FinancialController;
- };
|