financial_controller.js 56 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098
  1. 'use strict';
  2. const auditConst = require('../const/audit');
  3. const shenpiConst = require('../const/shenpi');
  4. const financialConst = require('../const/financial');
  5. const moment = require('moment');
  6. const sendToWormhole = require('stream-wormhole');
  7. const fs = require('fs');
  8. const path = require('path');
  9. module.exports = app => {
  10. class FinancialController extends app.BaseController {
  11. /**
  12. * 构造函数
  13. *
  14. * @param {Object} ctx - egg全局变量
  15. * @return {void}
  16. */
  17. constructor(ctx) {
  18. super(ctx);
  19. ctx.showProject = true;
  20. // ctx.showTitle = true;
  21. }
  22. /**
  23. * 资金监管项目列表页
  24. *
  25. * @param {Object} ctx - egg全局页面
  26. * @return {void}
  27. */
  28. // async index(ctx) {
  29. // try {
  30. // if (!ctx.subProject.page_show.openFinancial) {
  31. // throw '该功能已关闭或无法查看';
  32. // }
  33. // const renderData = {
  34. // jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.index),
  35. // auditConst,
  36. // };
  37. // renderData.projectList = await ctx.service.subProject.getSubProjectByFinancial(ctx.session.sessionProject.id, ctx.session.sessionUser.accountId, ctx.session.sessionUser.is_admin);
  38. // const accountList = await ctx.service.projectAccount.getAllSubProjectAccount(ctx.subProject);
  39. // for (const proj of renderData.projectList) {
  40. // const financialPermission = await ctx.service.financialAudit.getPermission(proj.id, ctx.session.sessionUser.accountId);
  41. // if (financialPermission.transfer_show) {
  42. // proj.toUrl = 'transfer';
  43. // } else if (financialPermission.pay_show) {
  44. // proj.toUrl = 'pay';
  45. // } else if (!financialPermission.transfer_show && !financialPermission.pay_show) {
  46. // proj.toUrl = 'transfer';
  47. // }
  48. // }
  49. // renderData.accountList = accountList;
  50. // const unitList = await ctx.service.constructionUnit.getAllDataByCondition({where: {pid: ctx.session.sessionProject.id}});
  51. // renderData.accountGroup = unitList.map(item => {
  52. // const groupList = accountList.filter(item1 => item1.company === item.name);
  53. // return { groupName: item.name, groupList };
  54. // }).filter(x => { return x.groupList.length > 0; });
  55. // // renderData.permissionConst = ctx.service.subProjPermission.PermissionConst;
  56. // renderData.categoryData = await this.ctx.service.category.getAllCategory(ctx.subProject);
  57. // renderData.companys = await this.ctx.service.constructionUnit.getAllDataByCondition({where: {pid: ctx.session.sessionProject.id}});
  58. // // renderData.templates = await this.ctx.service.filingTemplateList.getAllTemplate(ctx.session.sessionProject.id);
  59. // await this.layout('financial/index.ejs', renderData, 'financial/modal.ejs');
  60. // } catch (err) {
  61. // ctx.log(err);
  62. // ctx.session.postError = err.toString();
  63. // ctx.redirect(this.menu.menu.dashboard.url);
  64. // }
  65. // }
  66. // async auditSave(ctx) {
  67. // try {
  68. // if (ctx.session.sessionUser.is_admin === 0) throw '没有设置权限';
  69. // const responseData = {
  70. // err: 0, msg: '', data: null,
  71. // };
  72. // const data = JSON.parse(ctx.request.body.data);
  73. // if (!data.type) {
  74. // throw '提交数据错误';
  75. // }
  76. // let uids;
  77. // let result = false;
  78. // let auditList = [];
  79. // switch (data.type) {
  80. // case 'add-audit':
  81. // // 判断用户是单个还是数组
  82. // uids = data.id instanceof Array ? data.id : [data.id];
  83. // // 判断该用户的组是否已加入到表中,已加入则提示无需添加
  84. // auditList = await ctx.service.financialAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id } });
  85. // const addAidList = ctx.helper._.difference(uids, ctx.helper._.map(auditList, 'uid'));
  86. // if (addAidList.length === 0) {
  87. // throw '用户已存在成员管理中,无需重复添加';
  88. // }
  89. // const accountList = await ctx.service.projectAccount.getAllDataByCondition({ where: { id: addAidList } });
  90. // await ctx.service.financialAudit.saveAudits(ctx.subProject.id, accountList);
  91. // responseData.data = await ctx.service.financialAudit.getList(ctx.subProject.id);
  92. // break;
  93. // case 'del-audit':
  94. // uids = data.id instanceof Array ? data.id : [data.id];
  95. // auditList = await ctx.service.financialAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id, id: uids } });
  96. // if (auditList.length !== uids.length) {
  97. // throw '该用户已不存在成员管理中,移除失败';
  98. // }
  99. // await ctx.service.financialAudit.delAudit(uids);
  100. // responseData.data = await ctx.service.financialAudit.getList(ctx.subProject.id);
  101. // break;
  102. // case 'save-permission':
  103. // result = await ctx.service.financialAudit.updatePermission(data.updateData);
  104. // if (!result) {
  105. // throw '修改权限失败';
  106. // }
  107. // break;
  108. // case 'list':
  109. // responseData.data = await ctx.service.financialAudit.getList(ctx.subProject.id);
  110. // break;
  111. // default: throw '参数有误';
  112. // }
  113. // ctx.body = responseData;
  114. // } catch (err) {
  115. // this.log(err);
  116. // ctx.body = { err: 1, msg: err.toString(), data: null };
  117. // }
  118. // }
  119. async transfer(ctx) {
  120. try {
  121. const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
  122. if (!financialPermission.transfer_show) {
  123. throw '没有查看权限';
  124. }
  125. const transferList = await ctx.service.financialTransfer.getList(ctx.subProject.id);
  126. const renderData = {
  127. financialPermission,
  128. transferList,
  129. moment,
  130. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.transfer),
  131. whiteList: ctx.app.config.multipart.whitelist,
  132. };
  133. await this.layout('financial/transfer.ejs', renderData, 'financial/transfer_modal.ejs');
  134. } catch (err) {
  135. ctx.log(err);
  136. console.log(err);
  137. ctx.session.postError = err.toString();
  138. ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
  139. }
  140. }
  141. async transferAdd(ctx) {
  142. try {
  143. const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
  144. if (!financialPermission.transfer_add) {
  145. throw '没有添加权限';
  146. }
  147. const date = ctx.request.body.date;
  148. const remark = ctx.request.body.remark;
  149. if (!date) {
  150. throw '请选择划拨年月';
  151. }
  152. const newTransferId = await ctx.service.financialTransfer.addTransfer(ctx.subProject.id, date, remark);
  153. if (!newTransferId) {
  154. throw '新增资金划拨失败,请重试';
  155. }
  156. ctx.redirect('/sp/' + ctx.subProject.id + '/financial/transfer/' + newTransferId + '/tender');
  157. } catch (err) {
  158. console.log(err);
  159. ctx.postError(err, '新增资金划拨失败');
  160. ctx.redirect(ctx.request.header.referer);
  161. }
  162. }
  163. async transferTender(ctx) {
  164. try {
  165. const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
  166. if (!financialPermission.transfer_show) {
  167. throw '没有查看权限';
  168. }
  169. const trid = ctx.params.trid;
  170. const transferInfo = await ctx.service.financialTransfer.getDataById(trid);
  171. if (!transferInfo) {
  172. throw '该资金划拨信息不存在';
  173. }
  174. const transferTenderList = await ctx.service.financialTransferTender.getList(trid);
  175. const tenders = await ctx.service.tender.getAllDataByCondition({ where: { spid: ctx.subProject.id, filter_fund: 0 } });
  176. for (const tt of transferTenderList) {
  177. const tenderIndex = ctx.helper._.findIndex(tenders, { id: tt.tid });
  178. if (tenderIndex !== -1) {
  179. tenders.splice(tenderIndex, 1);
  180. }
  181. }
  182. const allTransferTenders = await ctx.service.financialTransferTender.getAllDataByCondition({ where: { spid: ctx.subProject.id } });
  183. for (const t of tenders) {
  184. const stages = await ctx.service.stage.getAllDataByCondition({ where: { tid: t.id, status: auditConst.stage.status.checked } });
  185. const allTenderStages = ctx.helper._.filter(allTransferTenders, { tid: t.id });
  186. for (const ts of allTenderStages) {
  187. const sorderArray = ts.sorder ? ts.sorder.split(',') : [];
  188. for (const sorder of sorderArray) {
  189. const stageIndex = ctx.helper._.findIndex(stages, function(item) {
  190. return item.order === parseInt(sorder);
  191. });
  192. if (stageIndex !== -1) {
  193. stages.splice(stageIndex, 1);
  194. }
  195. }
  196. }
  197. t.stages = stages;
  198. }
  199. const renderData = {
  200. financialPermission,
  201. transferInfo,
  202. transferTenderList,
  203. tenders,
  204. moment,
  205. preUrl: '/sp/' + ctx.subProject.id + '/financial/transfer',
  206. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.transferTender),
  207. whiteList: ctx.app.config.multipart.whitelist,
  208. };
  209. await this.layout('financial/transfer_tender.ejs', renderData, 'financial/transfer_tender_modal.ejs');
  210. } catch (err) {
  211. ctx.log(err);
  212. console.log(err);
  213. ctx.session.postError = err.toString();
  214. ctx.redirect(`/sp/${ctx.subProject.id}/financial/transfer`);
  215. }
  216. }
  217. async transferUpdate(ctx) {
  218. try {
  219. const data = JSON.parse(ctx.request.body.data);
  220. if (!data.postType || !data.postData) throw '数据错误';
  221. const responseData = { err: 0, msg: '', data: {} };
  222. switch (data.postType) {
  223. case 'del-transfer':
  224. responseData.data = await ctx.service.financialTransfer.delTransfer(data.postData.node);
  225. break;
  226. case 'lock-transfer':
  227. responseData.data = await ctx.service.financialTransfer.lockTransfer(data.postData.node, data.postData.lock);
  228. break;
  229. case 'save-transfer':
  230. responseData.data = await ctx.service.financialTransfer.saveTransfer(data.postData);
  231. break;
  232. default:
  233. throw '未知操作';
  234. }
  235. ctx.body = responseData;
  236. } catch (err) {
  237. console.log(err);
  238. this.log(err);
  239. ctx.body = this.ajaxErrorBody(err, '数据错误');
  240. }
  241. }
  242. async transferTenderUpdate(ctx) {
  243. try {
  244. const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
  245. if (!financialPermission.transfer_add) {
  246. throw '没有权限';
  247. }
  248. const trid = ctx.params.trid;
  249. const transferInfo = await ctx.service.financialTransfer.getDataById(trid);
  250. if (!transferInfo) {
  251. throw '该资金划拨信息不存在';
  252. }
  253. if (transferInfo.uid !== ctx.session.sessionUser.accountId) {
  254. throw '不是你创建的没有权限操作';
  255. }
  256. const data = JSON.parse(ctx.request.body.data);
  257. if (!data.postType || !data.postData) throw '数据错误';
  258. const responseData = { err: 0, msg: '', data: {} };
  259. switch (data.postType) {
  260. case 'add-tender':
  261. const result = await ctx.service.financialTransferTender.addTenders(transferInfo, data.postData.tenders);
  262. if (!result) {
  263. throw '新增失败';
  264. }
  265. break;
  266. case 'del-tender':
  267. responseData.data = await ctx.service.financialTransferTender.delTenders(data.postData.node);
  268. break;
  269. case 'update-hb_tp':
  270. responseData.data = await ctx.service.financialTransferTender.updateHbTp(data.postData.node, data.postData.hb_tp);
  271. break;
  272. default:
  273. throw '未知操作';
  274. }
  275. ctx.body = responseData;
  276. } catch (err) {
  277. console.log(err);
  278. this.log(err);
  279. ctx.body = this.ajaxErrorBody(err, '数据错误');
  280. }
  281. }
  282. /**
  283. * 上传附件
  284. * @param {*} ctx 上下文
  285. */
  286. async transferUploadFile(ctx) {
  287. let stream;
  288. try {
  289. const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
  290. if (!financialPermission.transfer_file) {
  291. throw '没有权限';
  292. }
  293. const responseData = { err: 0, msg: '', data: {} };
  294. const id = ctx.params.trid;
  295. if (!id) throw '参数有误';
  296. const parts = this.ctx.multipart({
  297. autoFields: true,
  298. });
  299. const files = [];
  300. const create_time = Date.parse(new Date()) / 1000;
  301. let idx = 0;
  302. while ((stream = await parts()) !== undefined) {
  303. if (!stream.filename) {
  304. // 如果没有传入直接返回
  305. return;
  306. }
  307. const fileInfo = path.parse(stream.filename);
  308. const filepath = `sp/financial/${ctx.subProject.id}/transfer/${id}/fujian_${create_time + idx.toString() + fileInfo.ext}`;
  309. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  310. files.push({ filepath, name: stream.filename, ext: fileInfo.ext });
  311. ++idx;
  312. stream && (await sendToWormhole(stream));
  313. }
  314. const in_time = new Date();
  315. const payload = files.map(file => {
  316. let idx;
  317. if (Array.isArray(parts.field.name)) {
  318. idx = parts.field.name.findIndex(name => name === file.name);
  319. } else {
  320. idx = 'isString';
  321. }
  322. const newFile = {
  323. spid: ctx.subProject.id,
  324. trid: id,
  325. uid: ctx.session.sessionUser.accountId,
  326. filename: file.name,
  327. fileext: file.ext,
  328. filesize: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
  329. filepath: file.filepath,
  330. upload_time: in_time,
  331. };
  332. return newFile;
  333. });
  334. // 执行文件信息写入数据库
  335. await ctx.service.financialTransferAtt.saveFileMsgToDb(payload);
  336. // 将最新的当前标段的所有文件信息返回
  337. responseData.data = await ctx.service.financialTransferAtt.getAtt(id);
  338. ctx.body = responseData;
  339. } catch (err) {
  340. stream && (await sendToWormhole(stream));
  341. this.log(err);
  342. ctx.body = { err: 1, msg: err.toString(), data: null };
  343. }
  344. }
  345. /**
  346. * 删除附件
  347. * @param {Ojbect} ctx 上下文
  348. */
  349. async transferDeleteFile(ctx) {
  350. try {
  351. const id = ctx.params.trid;
  352. const responseData = { err: 0, msg: '', data: {} };
  353. const data = JSON.parse(ctx.request.body.data);
  354. const fileInfo = await ctx.service.financialTransferAtt.getDataById(data.id);
  355. if (fileInfo || Object.keys(fileInfo).length) {
  356. // 先删除文件
  357. // await fs.unlinkSync(path.resolve(this.app.baseDir, './app', fileInfo.filepath));
  358. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
  359. // 再删除数据库
  360. await ctx.service.financialTransferAtt.delete(data.id);
  361. } else {
  362. throw '不存在该文件';
  363. }
  364. responseData.data = await ctx.service.financialTransferAtt.getAtt(id);
  365. ctx.body = responseData;
  366. } catch (err) {
  367. this.log(err);
  368. ctx.body = { err: 1, msg: err.toString(), data: null };
  369. }
  370. }
  371. /**
  372. * 下载附件
  373. * @param {Object} ctx - egg全局变量
  374. * @return {void}
  375. */
  376. async transferDownloadFile(ctx) {
  377. const id = ctx.params.fid;
  378. if (id) {
  379. try {
  380. const fileInfo = await ctx.service.financialTransferAtt.getDataById(id);
  381. if (fileInfo) {
  382. // const fileName = path.join(__dirname, '../', fileInfo.filepath);
  383. // 解决中文无法下载问题
  384. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  385. let disposition = '';
  386. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  387. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename);
  388. } else if (userAgent.indexOf('firefox') >= 0) {
  389. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename) + '"';
  390. } else {
  391. /* safari等其他非主流浏览器只能自求多福了 */
  392. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename).toString('binary');
  393. }
  394. ctx.response.set({
  395. 'Content-Type': 'application/octet-stream',
  396. 'Content-Disposition': disposition,
  397. 'Content-Length': fileInfo.filesize,
  398. });
  399. // ctx.body = await fs.createReadStream(fileName);
  400. ctx.body = await ctx.helper.ossFileGet(fileInfo.filepath);
  401. } else {
  402. throw '不存在该文件';
  403. }
  404. } catch (err) {
  405. this.log(err);
  406. this.setMessage(err.toString(), this.messageType.ERROR);
  407. }
  408. }
  409. }
  410. /**
  411. * 上传附件
  412. * @param {*} ctx 上下文
  413. */
  414. async transferTenderUploadFile(ctx) {
  415. let stream;
  416. try {
  417. const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
  418. if (!financialPermission.transfer_file) {
  419. throw '没有权限';
  420. }
  421. const responseData = { err: 0, msg: '', data: {} };
  422. const trid = ctx.params.trid;
  423. const id = ctx.params.ttid;
  424. if (!id) throw '参数有误';
  425. const parts = this.ctx.multipart({
  426. autoFields: true,
  427. });
  428. const files = [];
  429. const create_time = Date.parse(new Date()) / 1000;
  430. let idx = 0;
  431. while ((stream = await parts()) !== undefined) {
  432. if (!stream.filename) {
  433. // 如果没有传入直接返回
  434. return;
  435. }
  436. const fileInfo = path.parse(stream.filename);
  437. const filepath = `sp/financial/${ctx.subProject.id}/transfer/${trid}/tender/${id}/fujian_${create_time + idx.toString() + fileInfo.ext}`;
  438. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  439. files.push({ filepath, name: stream.filename, ext: fileInfo.ext });
  440. ++idx;
  441. stream && (await sendToWormhole(stream));
  442. }
  443. const in_time = new Date();
  444. const payload = files.map(file => {
  445. let idx;
  446. if (Array.isArray(parts.field.name)) {
  447. idx = parts.field.name.findIndex(name => name === file.name);
  448. } else {
  449. idx = 'isString';
  450. }
  451. const newFile = {
  452. spid: ctx.subProject.id,
  453. trid,
  454. ftid: id,
  455. uid: ctx.session.sessionUser.accountId,
  456. filename: file.name,
  457. fileext: file.ext,
  458. filesize: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
  459. filepath: file.filepath,
  460. upload_time: in_time,
  461. };
  462. return newFile;
  463. });
  464. // 执行文件信息写入数据库
  465. await ctx.service.financialTransferTenderAtt.saveFileMsgToDb(payload);
  466. // 将最新的当前标段的所有文件信息返回
  467. responseData.data = await ctx.service.financialTransferTenderAtt.getAtt(id);
  468. ctx.body = responseData;
  469. } catch (err) {
  470. stream && (await sendToWormhole(stream));
  471. this.log(err);
  472. ctx.body = { err: 1, msg: err.toString(), data: null };
  473. }
  474. }
  475. /**
  476. * 删除附件
  477. * @param {Ojbect} ctx 上下文
  478. */
  479. async transferTenderDeleteFile(ctx) {
  480. try {
  481. const id = ctx.params.ttid;
  482. const responseData = { err: 0, msg: '', data: {} };
  483. const data = JSON.parse(ctx.request.body.data);
  484. const fileInfo = await ctx.service.financialTransferTenderAtt.getDataById(data.id);
  485. if (fileInfo || Object.keys(fileInfo).length) {
  486. // 先删除文件
  487. // await fs.unlinkSync(path.resolve(this.app.baseDir, './app', fileInfo.filepath));
  488. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
  489. // 再删除数据库
  490. await ctx.service.financialTransferTenderAtt.delete(data.id);
  491. } else {
  492. throw '不存在该文件';
  493. }
  494. responseData.data = await ctx.service.financialTransferTenderAtt.getAtt(id);
  495. ctx.body = responseData;
  496. } catch (err) {
  497. this.log(err);
  498. ctx.body = { err: 1, msg: err.toString(), data: null };
  499. }
  500. }
  501. /**
  502. * 下载附件
  503. * @param {Object} ctx - egg全局变量
  504. * @return {void}
  505. */
  506. async transferTenderDownloadFile(ctx) {
  507. const id = ctx.params.fid;
  508. if (id) {
  509. try {
  510. const fileInfo = await ctx.service.financialTransferTenderAtt.getDataById(id);
  511. if (fileInfo) {
  512. // const fileName = path.join(__dirname, '../', fileInfo.filepath);
  513. // 解决中文无法下载问题
  514. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  515. let disposition = '';
  516. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  517. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename);
  518. } else if (userAgent.indexOf('firefox') >= 0) {
  519. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename) + '"';
  520. } else {
  521. /* safari等其他非主流浏览器只能自求多福了 */
  522. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename).toString('binary');
  523. }
  524. ctx.response.set({
  525. 'Content-Type': 'application/octet-stream',
  526. 'Content-Disposition': disposition,
  527. 'Content-Length': fileInfo.filesize,
  528. });
  529. // ctx.body = await fs.createReadStream(fileName);
  530. ctx.body = await ctx.helper.ossFileGet(fileInfo.filepath);
  531. } else {
  532. throw '不存在该文件';
  533. }
  534. } catch (err) {
  535. this.log(err);
  536. this.setMessage(err.toString(), this.messageType.ERROR);
  537. }
  538. }
  539. }
  540. /**
  541. * 变更管理 页面 (Get)
  542. *
  543. * @param {Object} ctx - egg全局变量
  544. * @return {void}
  545. */
  546. async pay(ctx) {
  547. try {
  548. const status = parseInt(ctx.query.status) || 0;
  549. const tid = parseInt(ctx.query.tid) || null;
  550. const used = ctx.query.used || null;
  551. await this._filterPay(ctx, status, tid, used);
  552. } catch (err) {
  553. this.log(err);
  554. ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
  555. }
  556. }
  557. // /**
  558. // * 变更管理 状态筛选 页面 (Get)
  559. // * @param {Object} ctx - egg全局变量
  560. // * @return {void}
  561. // */
  562. // async payStatus(ctx) {
  563. // try {
  564. // const status = parseInt(ctx.query.status);
  565. // const tid = parseInt(ctx.params.tid) || null;
  566. // const used = ctx.params.used || null;
  567. // await this._filterPay(ctx, status, tid, used);
  568. // } catch (err) {
  569. // this.logger.error(err);
  570. // ctx.redirect('/financial');
  571. // }
  572. // }
  573. async _filterPay(ctx, status = 0, tid = null, used = null) {
  574. const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
  575. if (!financialPermission.pay_show) {
  576. throw '没有查看权限';
  577. }
  578. const fptAudits = await ctx.service.financialPayTenderAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id, uid: ctx.session.sessionUser.accountId } });
  579. const fptAuditTids = ctx.helper._.map(fptAudits, 'tid');
  580. const fptReportTids = ctx.helper._.map(ctx.helper._.filter(fptAudits, { is_report: 1 }), 'tid');
  581. const filterTids = tid === null ? (ctx.session.sessionUser.is_admin ? null : fptAuditTids) : [tid];
  582. const tenderCondition = { spid: ctx.subProject.id, filter_fund: 0 };
  583. let hadTender = false;
  584. if (ctx.session.sessionUser.is_admin) {
  585. hadTender = true;
  586. } else if (fptAuditTids.length !== 0) {
  587. hadTender = true;
  588. tenderCondition.id = fptAuditTids;
  589. } else {
  590. hadTender = false;
  591. tenderCondition.id = -1;
  592. }
  593. const tenders = hadTender ? await ctx.service.tender.getAllDataByCondition({ where: tenderCondition, columns: ['id', 'name'] }) : [];
  594. const filter = JSON.parse(JSON.stringify(auditConst.financial.filter));
  595. filter.count = [];
  596. 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);
  597. 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);
  598. 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);
  599. 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);
  600. const payList = await ctx.service.financialPay.getListByStatus(ctx.subProject.id, status, filterTids, used);
  601. // 获取所有项目参与者
  602. const accountList = await ctx.service.projectAccount.getAllSubProjectAccount(ctx.subProject, ['id', 'account', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile']);
  603. const payTenders = await ctx.service.financialPayTender.getAllDataByCondition({ where: { spid: ctx.subProject.id } });
  604. for (const t of tenders) {
  605. const info = await ctx.service.tenderInfo.getDataByCondition({ tid: t.id });
  606. t.pay_account = info && info.pay_account ? JSON.parse(info.pay_account).project : '';
  607. const pt = ctx.helper._.find(payTenders, { tid: t.id });
  608. t.pt = pt ? pt : { id: 0, tid: t.id, name: '', bank: '', bank_account: '', contact: '', phone: '' };
  609. if (ctx.session.sessionUser.is_admin || ctx.helper._.includes(fptReportTids, t.id)) {
  610. t.dealCode = info && info.deal_info ? JSON.parse(info.deal_info).dealCode : '';
  611. const lastPay = await ctx.service.financialPay.getAllDataByCondition({ where: { spid: ctx.subProject.id, tid: t.id }, columns: ['code'], orders: [['id', 'desc']], limit: 1 });
  612. t.startNum = 1;
  613. if (lastPay.length > 0) {
  614. const startArray = lastPay[0].code.split('-');
  615. t.startNum = parseInt(startArray[startArray.length - 1]) + 1;
  616. }
  617. }
  618. }
  619. for (const pay of payList) {
  620. const t = ctx.helper._.find(tenders, { id: pay.tid });
  621. pay.tenderName = t ? t.name : '';
  622. const userInfo = ctx.helper._.find(accountList, { id: pay.uid });
  623. pay.username = userInfo ? userInfo.name : '';
  624. if (pay.status !== auditConst.financial.status.checked || !pay.final_auditor_str) {
  625. pay.curAuditors = await ctx.service.financialPayAudit.getAuditorsByStatus(pay.id, pay.status, pay.times);
  626. if (pay.status === auditConst.financial.status.checked && pay.curAuditors.length > 0) {
  627. const final_auditor_str = pay.curAuditors[0].audit_type === auditConst.auditType.key.common
  628. ? pay.curAuditors[0].name + (pay.curAuditors[0].role ? '-' + pay.curAuditors[0].role : '')
  629. : ctx.helper.transFormToChinese(pay.curAuditors[0].audit_order) + '审';
  630. await ctx.service.financialPay.defaultUpdate({ final_auditor_str }, { where: { id: pay.id } });
  631. }
  632. }
  633. if (pay.status !== auditConst.financial.status.checked) {
  634. pay.entities = await ctx.service.financialPayContract.getEntities(pay.id);
  635. }
  636. }
  637. if (ctx.session.sessionUser.is_admin) {
  638. for (const t of tenders) {
  639. t.permissionList = await ctx.service.financialPayTenderAudit.getList(ctx.subProject.id, t.id, accountList);
  640. t.auditGroupList = await ctx.service.shenpiAudit.getAuditGroupList(t.id, shenpiConst.sp_other_type.financial, shenpiConst.sp_status.gdspl);
  641. }
  642. }
  643. const renderData = {
  644. tenders,
  645. financialPermission,
  646. usedList: financialConst.used,
  647. auditConst: auditConst.financial,
  648. filter,
  649. tid,
  650. status,
  651. used,
  652. payList,
  653. fptAuditTids,
  654. fptReportTids,
  655. moment,
  656. auditType: auditConst.auditType,
  657. // preUrl: '/financial',
  658. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.pay),
  659. };
  660. if (ctx.session.sessionUser.is_admin) {
  661. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  662. renderData.accountList = accountList;
  663. renderData.accountGroup = unitList.map(item => {
  664. const groupList = accountList.filter(item1 => item1.company === item.name);
  665. return { groupName: item.name, groupList };
  666. }).filter(x => { return x.groupList.length > 0; });
  667. renderData.auditType = auditConst.auditType;
  668. renderData.shenpi = shenpiConst;
  669. }
  670. await this.layout('financial/pay.ejs', renderData, 'financial/pay_modal.ejs');
  671. }
  672. async paySave(ctx) {
  673. try {
  674. const responseData = {
  675. err: 0, msg: '', data: {},
  676. };
  677. const data = JSON.parse(ctx.request.body.data);
  678. if (!data.type) {
  679. throw '提交数据错误';
  680. }
  681. let uids;
  682. let result = false;
  683. let auditList = [];
  684. switch (data.type) {
  685. case 'add-tender-audit':
  686. // 判断用户是单个还是数组
  687. if (!data.tid) throw '参数有误';
  688. uids = data.id instanceof Array ? data.id : [data.id];
  689. // 判断该用户的组是否已加入到表中,已加入则提示无需添加
  690. auditList = await ctx.service.financialPayTenderAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id, tid: data.tid } });
  691. const addAidList = ctx.helper._.difference(uids, ctx.helper._.map(auditList, 'uid'));
  692. if (addAidList.length === 0) {
  693. throw '用户已存在填报人列表中,无需重复添加';
  694. }
  695. const accountList = await ctx.service.projectAccount.getAllDataByCondition({ where: { id: addAidList } });
  696. await ctx.service.financialPayTenderAudit.saveAudits(ctx.subProject.id, data.tid, accountList);
  697. responseData.data = await ctx.service.financialPayTenderAudit.getList(ctx.subProject.id, data.tid);
  698. break;
  699. case 'del-tender-audit':
  700. if (!data.tid) throw '参数有误';
  701. uids = data.id instanceof Array ? data.id : [data.id];
  702. auditList = await ctx.service.financialPayTenderAudit.getAllDataByCondition({ where: { id: uids } });
  703. if (auditList.length !== uids.length) {
  704. throw '该用户已不存在填报人列表中,移除失败';
  705. }
  706. responseData.data = await ctx.service.financialPayTenderAudit.delAudits(ctx.subProject.id, data.tid, auditList);
  707. // responseData.data = await ctx.service.financialPayTenderAudit.getList(ctx.subProject.id, data.tid);
  708. break;
  709. case 'save-permission':
  710. result = await ctx.service.financialPayTenderAudit.updatePermission(data.updateData);
  711. if (!result) {
  712. throw '修改权限失败';
  713. }
  714. break;
  715. case 'copy-tender-audit':
  716. responseData.data = await ctx.service.financialPayTenderAudit.copyAudit2otherTender(ctx.subProject.id, data, data.this_tid);
  717. break;
  718. case 'add-shenpi-audit':
  719. responseData.data = await ctx.service.financialPayTenderAudit.addShenpiAudit(ctx.subProject.id, data.shenpi, data.tid);
  720. break;
  721. case 'copy-shenpi-audit':
  722. responseData.data = await ctx.service.financialPayTenderAudit.copyShenpi2otherTender(ctx.subProject.id, data, data.this_tid);
  723. break;
  724. case 'add-pay':
  725. responseData.data = await ctx.service.financialPay.addPay(ctx.subProject.id, data.updateData);
  726. break;
  727. case 'del-pay':
  728. responseData.data = await ctx.service.financialPay.delPay(data.postData.node);
  729. break;
  730. case 'set-pay-tender':
  731. responseData.data = await ctx.service.financialPayTender.savePayTender(ctx.subProject.id, data.updateData);
  732. break;
  733. case 'get-auditors':
  734. const fpInfo = await ctx.service.financialPay.getDataById(data.id);
  735. await ctx.service.financialPay.loadPayUser(fpInfo);
  736. await ctx.service.financialPay.loadFinancialPayAuditViewData(fpInfo);
  737. responseData.data = fpInfo;
  738. break;
  739. default: throw '参数有误';
  740. }
  741. ctx.body = responseData;
  742. } catch (err) {
  743. this.log(err);
  744. ctx.body = { err: 1, msg: err.toString(), data: {} };
  745. }
  746. }
  747. /**
  748. * 获取审批界面所需的 原报、审批人数据等
  749. * @param ctx
  750. * @return {Promise<void>}
  751. * @private
  752. */
  753. async _getFinancialAuditViewData(ctx) {
  754. await ctx.service.financialPay.loadFinancialPayAuditViewData(ctx.financialPay);
  755. }
  756. async payDetail(ctx) {
  757. try {
  758. if (!ctx.financialPay.permission.pay_show) {
  759. throw '没有查看权限';
  760. }
  761. await this._getFinancialAuditViewData(ctx);
  762. // 获取附件列表
  763. const fileList = await ctx.service.financialPayAtt.getAtt(ctx.financialPay.id);
  764. const renderData = {
  765. financialPermission: ctx.financialPay.permission,
  766. financialPay: ctx.financialPay,
  767. usedList: financialConst.used,
  768. payTypeList: financialConst.pay_type,
  769. auditConst: auditConst.financial,
  770. auditType: auditConst.auditType,
  771. whiteList: ctx.app.config.multipart.whitelist,
  772. moment,
  773. fileList,
  774. preUrl: `/sp/${ctx.subProject.id}/financial/pay`,
  775. preUrl2: `/sp/${ctx.subProject.id}/financial/pay/` + ctx.financialPay.id,
  776. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.payDetail),
  777. };
  778. await this.layout('financial/pay_detail.ejs', renderData, 'financial/pay_detail_modal.ejs');
  779. } catch (err) {
  780. this.log(err);
  781. ctx.redirect(`/sp/${ctx.subProject.id}/financial/pay`);
  782. }
  783. }
  784. /**
  785. * 上报和重新上报
  786. * @param ctx
  787. * @return {Promise<void>}
  788. */
  789. async startPayAudit(ctx) {
  790. try {
  791. // 检查权限等
  792. if (!ctx.financialPay) {
  793. throw '数据错误';
  794. }
  795. if (ctx.financialPay.uid !== ctx.session.sessionUser.accountId) {
  796. throw '您无权上报该资金支付数据';
  797. }
  798. if (ctx.financialPay.status === auditConst.financial.status.checking || ctx.financialPay.status === auditConst.financial.status.checked) {
  799. throw '该资金支付数据当前无法上报';
  800. }
  801. await ctx.service.financialPayAudit.start(ctx.financialPay.id, ctx.financialPay.times);
  802. ctx.redirect(ctx.request.header.referer);
  803. } catch (err) {
  804. this.log(err);
  805. ctx.session.postError = err.toString();
  806. ctx.redirect(ctx.request.header.referer);
  807. }
  808. }
  809. /**
  810. * 审批
  811. * @param ctx
  812. * @return {Promise<void>}
  813. */
  814. async checkPayAudit(ctx) {
  815. try {
  816. if (!ctx.financialPay || ctx.financialPay.status !== auditConst.financial.status.checking) {
  817. throw '当前资金支付数据有误';
  818. }
  819. if (ctx.financialPay.curAuditorIds.length === 0 || ctx.financialPay.curAuditorIds.indexOf(ctx.session.sessionUser.accountId) === -1) {
  820. throw '您无权进行该操作';
  821. }
  822. const data = {
  823. checkType: parseInt(ctx.request.body.checkType),
  824. opinion: ctx.request.body.opinion,
  825. };
  826. if (!data.checkType || isNaN(data.checkType)) {
  827. throw '提交数据错误';
  828. }
  829. await ctx.service.financialPayAudit.check(ctx.financialPay, data);
  830. ctx.redirect(ctx.request.header.referer);
  831. } catch (err) {
  832. this.log(err);
  833. ctx.session.postError = err.toString();
  834. ctx.redirect(ctx.request.header.referer);
  835. }
  836. }
  837. async payDetailSave(ctx) {
  838. try {
  839. const responseData = {
  840. err: 0, msg: '', data: {},
  841. };
  842. const data = JSON.parse(ctx.request.body.data);
  843. if (!data.type) {
  844. throw '提交数据错误';
  845. }
  846. if (data.type !== 'pay_contract_list' && data.type !== 'file_bill') {
  847. if (ctx.financialPay.status !== auditConst.financial.status.uncheck && ctx.financialPay.status !== auditConst.financial.status.checkNo) {
  848. throw '该状态下不允许编辑';
  849. }
  850. if (ctx.financialPay.uid !== ctx.session.sessionUser.accountId) {
  851. throw '非该资金支付填报人无权限编辑';
  852. }
  853. }
  854. switch (data.type) {
  855. case 'pay_save':
  856. responseData.data = await ctx.service.financialPay.savePay(ctx.financialPay.id, data);
  857. break;
  858. case 'pay_contract_list':
  859. responseData.data = await ctx.service.financialPayContract.getContractList(ctx.financialPay.id, ctx.financialPay.status !== auditConst.financial.status.checked);
  860. break;
  861. case 'contract_list':
  862. responseData.data.contracts = await ctx.service.contract.getAllDataByCondition({ where: { tid: ctx.financialPay.tid, contract_type: 1 }, orders: [['level', 'asc'], ['order', 'asc']] });
  863. responseData.data.contractTrees = await ctx.service.contractTree.getAllDataByCondition({ where: { tid: ctx.financialPay.tid, contract_type: 1 } });
  864. break;
  865. case 'contract_white_add':
  866. responseData.data = await ctx.service.financialPayContract.addWhiteContract(ctx.financialPay);
  867. break;
  868. case 'contract_add':
  869. responseData.data = await ctx.service.financialPayContract.addContracts(ctx.financialPay, data.contract_ids);
  870. break;
  871. case 'contract_del':
  872. responseData.data = await ctx.service.financialPayContract.delContract(ctx.financialPay.id, data.ids);
  873. break;
  874. case 'contract_update':
  875. responseData.data = await ctx.service.financialPayContract.updateContract(ctx.financialPay.id, data.updateData);
  876. break;
  877. case 'contract_paste':
  878. responseData.data = await ctx.service.financialPayContract.updateContracts(ctx.financialPay.id, data.updateData);
  879. break;
  880. case 'file_bill':
  881. responseData.data = await ctx.service.financialPayAtt.updateBill(data.id, data.bill);
  882. break;
  883. default: throw '参数有误';
  884. }
  885. ctx.body = responseData;
  886. } catch (err) {
  887. this.log(err);
  888. ctx.body = { err: 1, msg: err.toString(), data: {} };
  889. }
  890. }
  891. /**
  892. * 上传附件
  893. * @param {*} ctx 上下文
  894. */
  895. async payUploadFile(ctx) {
  896. let stream;
  897. try {
  898. const parts = this.ctx.multipart({
  899. autoFields: true,
  900. });
  901. const files = [];
  902. const create_time = Date.parse(new Date()) / 1000;
  903. let idx = 0;
  904. // const extra_upload = ctx.financialPay.status === auditConst.status.checked;
  905. while ((stream = await parts()) !== undefined) {
  906. if (!stream.filename) {
  907. // 如果没有传入直接返回
  908. return;
  909. }
  910. const fileInfo = path.parse(stream.filename);
  911. const filepath = `sp/financial/${ctx.subProject.id}/pay/${ctx.financialPay.id}/fujian_${create_time + idx.toString() + fileInfo.ext}`;
  912. // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, 'app', filepath));
  913. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  914. files.push({ filepath, name: stream.filename, ext: fileInfo.ext });
  915. ++idx;
  916. stream && (await sendToWormhole(stream));
  917. }
  918. const in_time = new Date();
  919. const type = parts.field.type ? parseInt(parts.field.type) : 0;
  920. const fpcid = parts.field.fpcid ? parseInt(parts.field.fpcid) : null;
  921. const payload = files.map(file => {
  922. let idx;
  923. if (Array.isArray(parts.field.name)) {
  924. idx = parts.field.name.findIndex(name => name === file.name);
  925. } else {
  926. idx = 'isString';
  927. }
  928. const newFile = {
  929. spid: ctx.subProject.id,
  930. fpid: ctx.financialPay.id,
  931. fpcid,
  932. uid: ctx.session.sessionUser.accountId,
  933. filename: file.name,
  934. fileext: file.ext,
  935. filesize: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
  936. filepath: file.filepath,
  937. upload_time: in_time,
  938. type,
  939. };
  940. return newFile;
  941. });
  942. // 执行文件信息写入数据库
  943. await ctx.service.financialPayAtt.saveFileMsgToDb(payload);
  944. // 将最新的当前标段的所有文件信息返回
  945. const data = await ctx.service.financialPayAtt.getAtt(ctx.financialPay.id, fpcid);
  946. ctx.body = { err: 0, msg: '', data };
  947. } catch (err) {
  948. stream && (await sendToWormhole(stream));
  949. this.log(err);
  950. ctx.body = { err: 1, msg: err.toString(), data: null };
  951. }
  952. }
  953. /**
  954. * 删除附件
  955. * @param {Ojbect} ctx 上下文
  956. */
  957. async payDeleteFile(ctx) {
  958. try {
  959. const { fpcid, id } = JSON.parse(ctx.request.body.data);
  960. const fileInfo = await ctx.service.financialPayAtt.getDataById(id);
  961. if (fileInfo || Object.keys(fileInfo).length) {
  962. // 先删除文件
  963. // await fs.unlinkSync(path.resolve(this.app.baseDir, './app', fileInfo.filepath));
  964. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
  965. // 再删除数据库
  966. await ctx.service.financialPayAtt.delete(id);
  967. } else {
  968. throw '不存在该文件';
  969. }
  970. const data = await ctx.service.financialPayAtt.getAtt(ctx.financialPay.id, fpcid ? fpcid : null);
  971. ctx.body = { err: 0, msg: '请求成功', data };
  972. } catch (err) {
  973. this.log(err);
  974. ctx.body = { err: 1, msg: err.toString(), data: null };
  975. }
  976. }
  977. /**
  978. * 下载附件
  979. * @param {Object} ctx - egg全局变量
  980. * @return {void}
  981. */
  982. async payDownloadFile(ctx) {
  983. const id = ctx.params.fid;
  984. if (id) {
  985. try {
  986. const fileInfo = await ctx.service.financialPayAtt.getDataById(id);
  987. if (fileInfo !== undefined && fileInfo !== '') {
  988. // const fileName = path.join(__dirname, '../', fileInfo.filepath);
  989. // 解决中文无法下载问题
  990. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  991. let disposition = '';
  992. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  993. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename);
  994. } else if (userAgent.indexOf('firefox') >= 0) {
  995. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename) + '"';
  996. } else {
  997. /* safari等其他非主流浏览器只能自求多福了 */
  998. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename).toString('binary');
  999. }
  1000. ctx.response.set({
  1001. 'Content-Type': 'application/octet-stream',
  1002. 'Content-Disposition': disposition,
  1003. 'Content-Length': fileInfo.filesize,
  1004. });
  1005. // ctx.body = await fs.createReadStream(fileName);
  1006. ctx.body = await ctx.helper.ossFileGet(fileInfo.filepath);
  1007. } else {
  1008. throw '不存在该文件';
  1009. }
  1010. } catch (err) {
  1011. this.log(err);
  1012. this.setMessage(err.toString(), this.messageType.ERROR);
  1013. }
  1014. }
  1015. }
  1016. async summary(ctx) {
  1017. try {
  1018. const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
  1019. if (!financialPermission.transfer_show && !financialPermission.pay_show) {
  1020. throw '没有查看权限';
  1021. }
  1022. const renderData = {
  1023. financialPermission,
  1024. usedList: financialConst.used,
  1025. // preUrl: '/financial',
  1026. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.summary),
  1027. };
  1028. await this.layout('financial/summary.ejs', renderData);
  1029. } catch (err) {
  1030. this.log(err);
  1031. ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
  1032. }
  1033. }
  1034. async summaryLoad(ctx) {
  1035. try {
  1036. const responseData = {
  1037. err: 0, msg: '', data: {},
  1038. };
  1039. const tid = parseInt(ctx.query.tid) || null;
  1040. const fptAudits = await ctx.service.financialPayTenderAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id, uid: ctx.session.sessionUser.accountId } });
  1041. const fptAuditTids = ctx.helper._.map(fptAudits, 'tid');
  1042. const filterTids = tid === null ? (ctx.session.sessionUser.is_admin ? null : fptAuditTids) : [tid];
  1043. const tenderCondition = { spid: ctx.subProject.id };
  1044. let hadTender = false;
  1045. if (ctx.session.sessionUser.is_admin) {
  1046. hadTender = true;
  1047. } else if (fptAuditTids.length !== 0) {
  1048. hadTender = true;
  1049. tenderCondition.id = fptAuditTids;
  1050. } else {
  1051. hadTender = false;
  1052. tenderCondition.id = -1;
  1053. }
  1054. responseData.data.tenders = hadTender ? await ctx.service.tender.getAllDataByCondition({ where: tenderCondition, columns: ['id', 'name'] }) : [];
  1055. responseData.data.transferList = tid === null ? await ctx.service.financialTransfer.getAllDataByCondition({ where: { spid: ctx.subProject.id } }) : [];
  1056. responseData.data.transferTenderList = tid === null ? await ctx.service.financialTransferTender.getAllDataByCondition({ where: { spid: ctx.subProject.id } }) : [];
  1057. responseData.data.payList = await ctx.service.financialPay.getListByStatus(ctx.subProject.id, 0, filterTids);
  1058. ctx.body = responseData;
  1059. } catch (err) {
  1060. this.log(err);
  1061. ctx.body = { err: 1, msg: err.toString(), data: {} };
  1062. }
  1063. }
  1064. }
  1065. return FinancialController;
  1066. };