financial_controller.js 61 KB

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