financial_controller.js 60 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190
  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. for (const t of tenders) {
  643. const info = await ctx.service.tenderInfo.getDataByCondition({ tid: t.id });
  644. t.pay_account = info && info.pay_account ? JSON.parse(info.pay_account).project : '';
  645. const pt = ctx.helper._.find(payTenders, { tid: t.id });
  646. t.pt = pt ? pt : { id: 0, tid: t.id, name: '', bank: '', bank_account: '', contact: '', phone: '' };
  647. if (ctx.session.sessionUser.is_admin || ctx.helper._.includes(fptReportTids, t.id)) {
  648. t.dealCode = info && info.deal_info ? JSON.parse(info.deal_info).dealCode : '';
  649. const lastPay = await ctx.service.financialPay.getAllDataByCondition({ where: { spid: ctx.subProject.id, tid: t.id }, columns: ['code'], orders: [['id', 'desc']], limit: 1 });
  650. t.startNum = 1;
  651. if (lastPay.length > 0) {
  652. const startArray = lastPay[0].code.split('-');
  653. t.startNum = parseInt(startArray[startArray.length - 1]) + 1;
  654. }
  655. }
  656. }
  657. for (const pay of payList) {
  658. const t = ctx.helper._.find(tenders, { id: pay.tid });
  659. pay.tenderName = t ? t.name : '';
  660. const userInfo = ctx.helper._.find(accountList, { id: pay.uid });
  661. pay.username = userInfo ? userInfo.name : '';
  662. if (pay.status !== auditConst.financial.status.checked || !pay.final_auditor_str) {
  663. pay.curAuditors = await ctx.service.financialPayAudit.getAuditorsByStatus(pay.id, pay.status, pay.times);
  664. if (pay.status === auditConst.financial.status.checked && pay.curAuditors.length > 0) {
  665. const final_auditor_str = pay.curAuditors[0].audit_type === auditConst.auditType.key.common
  666. ? pay.curAuditors[0].name + (pay.curAuditors[0].role ? '-' + pay.curAuditors[0].role : '')
  667. : ctx.helper.transFormToChinese(pay.curAuditors[0].audit_order) + '审';
  668. await ctx.service.financialPay.defaultUpdate({ final_auditor_str }, { where: { id: pay.id } });
  669. }
  670. }
  671. if (pay.status !== auditConst.financial.status.checked) {
  672. pay.entities = await ctx.service.financialPayContract.getEntities(pay.id);
  673. }
  674. }
  675. if (ctx.session.sessionUser.is_admin) {
  676. for (const t of tenders) {
  677. t.permissionList = await ctx.service.financialPayTenderAudit.getList(ctx.subProject.id, t.id, accountList);
  678. t.auditGroupList = await ctx.service.shenpiAudit.getAuditGroupList(t.id, shenpiConst.sp_other_type.financial, shenpiConst.sp_status.gdspl);
  679. }
  680. }
  681. const renderData = {
  682. tenders,
  683. financialPermission,
  684. usedList: financialConst.used,
  685. auditConst: auditConst.financial,
  686. filter,
  687. tid,
  688. status,
  689. used,
  690. payList,
  691. fptAuditTids,
  692. fptReportTids,
  693. moment,
  694. auditType: auditConst.auditType,
  695. // preUrl: '/financial',
  696. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.pay),
  697. pageInfo,
  698. };
  699. if (ctx.session.sessionUser.is_admin) {
  700. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  701. renderData.accountList = accountList;
  702. renderData.accountGroup = unitList.map(item => {
  703. const groupList = accountList.filter(item1 => item1.company === item.name);
  704. return { groupName: item.name, groupList };
  705. }).filter(x => { return x.groupList.length > 0; });
  706. renderData.auditType = auditConst.auditType;
  707. renderData.shenpi = shenpiConst;
  708. }
  709. await this.layout('financial/pay.ejs', renderData, 'financial/pay_modal.ejs');
  710. }
  711. async paySave(ctx) {
  712. try {
  713. const responseData = {
  714. err: 0, msg: '', data: {},
  715. };
  716. const data = JSON.parse(ctx.request.body.data);
  717. if (!data.type) {
  718. throw '提交数据错误';
  719. }
  720. let uids;
  721. let result = false;
  722. let auditList = [];
  723. switch (data.type) {
  724. case 'add-tender-audit':
  725. // 判断用户是单个还是数组
  726. if (!data.tid) throw '参数有误';
  727. uids = data.id instanceof Array ? data.id : [data.id];
  728. // 判断该用户的组是否已加入到表中,已加入则提示无需添加
  729. auditList = await ctx.service.financialPayTenderAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id, tid: data.tid } });
  730. const addAidList = ctx.helper._.difference(uids, ctx.helper._.map(auditList, 'uid'));
  731. if (addAidList.length === 0) {
  732. throw '用户已存在填报人列表中,无需重复添加';
  733. }
  734. const accountList = await ctx.service.projectAccount.getAllDataByCondition({ where: { id: addAidList } });
  735. await ctx.service.financialPayTenderAudit.saveAudits(ctx.subProject.id, data.tid, accountList);
  736. responseData.data = await ctx.service.financialPayTenderAudit.getList(ctx.subProject.id, data.tid);
  737. break;
  738. case 'del-tender-audit':
  739. if (!data.tid) throw '参数有误';
  740. uids = data.id instanceof Array ? data.id : [data.id];
  741. auditList = await ctx.service.financialPayTenderAudit.getAllDataByCondition({ where: { id: uids } });
  742. if (auditList.length !== uids.length) {
  743. throw '该用户已不存在填报人列表中,移除失败';
  744. }
  745. responseData.data = await ctx.service.financialPayTenderAudit.delAudits(ctx.subProject.id, data.tid, auditList);
  746. // responseData.data = await ctx.service.financialPayTenderAudit.getList(ctx.subProject.id, data.tid);
  747. break;
  748. case 'save-permission':
  749. result = await ctx.service.financialPayTenderAudit.updatePermission(data.updateData);
  750. if (!result) {
  751. throw '修改权限失败';
  752. }
  753. break;
  754. case 'copy-tender-audit':
  755. responseData.data = await ctx.service.financialPayTenderAudit.copyAudit2otherTender(ctx.subProject.id, data, data.this_tid);
  756. break;
  757. case 'add-shenpi-audit':
  758. responseData.data = await ctx.service.financialPayTenderAudit.addShenpiAudit(ctx.subProject.id, data.shenpi, data.tid);
  759. break;
  760. case 'copy-shenpi-audit':
  761. responseData.data = await ctx.service.financialPayTenderAudit.copyShenpi2otherTender(ctx.subProject.id, data, data.this_tid);
  762. break;
  763. case 'add-pay':
  764. responseData.data = await ctx.service.financialPay.addPay(ctx.subProject.id, data.updateData);
  765. break;
  766. case 'del-pay':
  767. responseData.data = await ctx.service.financialPay.delPay(data.postData.node);
  768. break;
  769. case 'set-pay-tender':
  770. responseData.data = await ctx.service.financialPayTender.savePayTender(ctx.subProject.id, data.updateData);
  771. break;
  772. case 'get-auditors':
  773. const fpInfo = await ctx.service.financialPay.getDataById(data.id);
  774. await ctx.service.financialPay.loadPayUser(fpInfo);
  775. await ctx.service.financialPay.loadFinancialPayAuditViewData(fpInfo);
  776. responseData.data = fpInfo;
  777. break;
  778. default: throw '参数有误';
  779. }
  780. ctx.body = responseData;
  781. } catch (err) {
  782. this.log(err);
  783. ctx.body = { err: 1, msg: err.toString(), data: {} };
  784. }
  785. }
  786. /**
  787. * 获取审批界面所需的 原报、审批人数据等
  788. * @param ctx
  789. * @return {Promise<void>}
  790. * @private
  791. */
  792. async _getFinancialAuditViewData(ctx) {
  793. await ctx.service.financialPay.loadFinancialPayAuditViewData(ctx.financialPay);
  794. }
  795. async payDetail(ctx) {
  796. try {
  797. if (!ctx.financialPay.permission.pay_show) {
  798. throw '没有查看权限';
  799. }
  800. await this._getFinancialAuditViewData(ctx);
  801. // 获取附件列表
  802. const fileList = await ctx.service.financialPayAtt.getAtt(ctx.financialPay.id);
  803. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  804. const auth_mobile = pa.auth_mobile;
  805. const renderData = {
  806. financialPermission: ctx.financialPay.permission,
  807. financialPay: ctx.financialPay,
  808. usedList: financialConst.used,
  809. payTypeList: financialConst.pay_type,
  810. auditConst: auditConst.financial,
  811. auditType: auditConst.auditType,
  812. whiteList: ctx.app.config.multipart.whitelist,
  813. moment,
  814. fileList,
  815. authMobile: auth_mobile,
  816. preUrl: `/sp/${ctx.subProject.id}/financial/pay`,
  817. preUrl2: `/sp/${ctx.subProject.id}/financial/pay/` + ctx.financialPay.id,
  818. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.payDetail),
  819. };
  820. await this.layout('financial/pay_detail.ejs', renderData, 'financial/pay_detail_modal.ejs');
  821. } catch (err) {
  822. this.log(err);
  823. ctx.redirect(`/sp/${ctx.subProject.id}/financial/pay`);
  824. }
  825. }
  826. /**
  827. * 上报和重新上报
  828. * @param ctx
  829. * @return {Promise<void>}
  830. */
  831. async startPayAudit(ctx) {
  832. try {
  833. // 检查权限等
  834. if (!ctx.financialPay) {
  835. throw '数据错误';
  836. }
  837. if (ctx.financialPay.uid !== ctx.session.sessionUser.accountId) {
  838. throw '您无权上报该资金支付数据';
  839. }
  840. if (ctx.financialPay.status === auditConst.financial.status.checking || ctx.financialPay.status === auditConst.financial.status.checked) {
  841. throw '该资金支付数据当前无法上报';
  842. }
  843. await ctx.service.financialPayAudit.start(ctx.financialPay.id, ctx.financialPay.times);
  844. ctx.redirect(ctx.request.header.referer);
  845. } catch (err) {
  846. this.log(err);
  847. ctx.session.postError = err.toString();
  848. ctx.redirect(ctx.request.header.referer);
  849. }
  850. }
  851. /**
  852. * 审批
  853. * @param ctx
  854. * @return {Promise<void>}
  855. */
  856. async checkPayAudit(ctx) {
  857. try {
  858. if (!ctx.financialPay || ctx.financialPay.status !== auditConst.financial.status.checking) {
  859. throw '当前资金支付数据有误';
  860. }
  861. if (ctx.financialPay.curAuditorIds.length === 0 || ctx.financialPay.curAuditorIds.indexOf(ctx.session.sessionUser.accountId) === -1) {
  862. throw '您无权进行该操作';
  863. }
  864. const data = {
  865. checkType: parseInt(ctx.request.body.checkType),
  866. opinion: ctx.request.body.opinion,
  867. };
  868. if (!data.checkType || isNaN(data.checkType)) {
  869. throw '提交数据错误';
  870. }
  871. await ctx.service.financialPayAudit.check(ctx.financialPay, data);
  872. ctx.redirect(ctx.request.header.referer);
  873. } catch (err) {
  874. this.log(err);
  875. ctx.session.postError = err.toString();
  876. ctx.redirect(ctx.request.header.referer);
  877. }
  878. }
  879. /**
  880. * 变更立项重新审批
  881. * @param {Object} ctx - egg全局变量
  882. * @return {void}
  883. */
  884. async checkPayAgain(ctx) {
  885. try {
  886. // 获取终审
  887. // const auditInfo = await this.ctx.service.changeProjectAudit.getAuditorByStatus(ctx.change.id, audit.changeProject.status.checked);
  888. // if (ctx.change.status !== audit.changeProject.status.checked || ctx.session.sessionUser.accountId !== auditInfo.aid) {
  889. if (ctx.financialPay.status !== auditConst.financial.status.checked) {
  890. throw '您无权进行该操作';
  891. }
  892. if (ctx.session.sessionUser.loginStatus === 0) {
  893. const code = ctx.request.body.code;
  894. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  895. if (!pa.auth_mobile) {
  896. throw '未绑定手机号';
  897. }
  898. const cacheKey = 'smsCode:' + ctx.session.sessionUser.accountId;
  899. const cacheCode = await app.redis.get(cacheKey);
  900. // console.log(cacheCode);
  901. if (cacheCode === null || code === undefined || cacheCode !== (code + pa.auth_mobile)) {
  902. throw '验证码不正确!';
  903. }
  904. }
  905. if ((ctx.financialPay.finalAuditorIds.indexOf(ctx.session.sessionUser.accountId) >= 0) && ctx.financialPay.status === auditConst.financial.status.checked) {
  906. // 重新审批
  907. const result = await ctx.service.financialPayAudit.checkAgain(ctx.financialPay);
  908. if (!result) {
  909. throw '重新审批失败';
  910. }
  911. } else {
  912. throw '您无权进行该操作';
  913. }
  914. ctx.body = {
  915. err: 0,
  916. url: ctx.request.header.referer,
  917. msg: '',
  918. };
  919. } catch (err) {
  920. console.log(err);
  921. ctx.body = {
  922. err: 1,
  923. // url: ctx.request.header.referer,
  924. msg: err,
  925. };
  926. }
  927. }
  928. async payDetailSave(ctx) {
  929. try {
  930. const responseData = {
  931. err: 0, msg: '', data: {},
  932. };
  933. const data = JSON.parse(ctx.request.body.data);
  934. if (!data.type) {
  935. throw '提交数据错误';
  936. }
  937. if (data.type !== 'pay_contract_list' && data.type !== 'file_bill') {
  938. if (ctx.financialPay.status !== auditConst.financial.status.uncheck && ctx.financialPay.status !== auditConst.financial.status.checkNo) {
  939. throw '该状态下不允许编辑';
  940. }
  941. if (ctx.financialPay.uid !== ctx.session.sessionUser.accountId) {
  942. throw '非该资金支付填报人无权限编辑';
  943. }
  944. }
  945. switch (data.type) {
  946. case 'pay_save':
  947. responseData.data = await ctx.service.financialPay.savePay(ctx.financialPay.id, data);
  948. break;
  949. case 'pay_contract_list':
  950. responseData.data = await ctx.service.financialPayContract.getContractList(ctx.financialPay.id, ctx.financialPay.status !== auditConst.financial.status.checked);
  951. break;
  952. case 'contract_list':
  953. responseData.data.contracts = await ctx.service.contract.getAllDataByCondition({ where: { tid: ctx.financialPay.tid, contract_type: 1 }, orders: [['level', 'asc'], ['order', 'asc']] });
  954. responseData.data.contractTrees = await ctx.service.contractTree.getAllDataByCondition({ where: { tid: ctx.financialPay.tid, contract_type: 1 } });
  955. break;
  956. case 'contract_white_add':
  957. responseData.data = await ctx.service.financialPayContract.addWhiteContract(ctx.financialPay);
  958. break;
  959. case 'contract_add':
  960. responseData.data = await ctx.service.financialPayContract.addContracts(ctx.financialPay, data.contract_ids);
  961. break;
  962. case 'contract_del':
  963. responseData.data = await ctx.service.financialPayContract.delContract(ctx.financialPay.id, data.ids);
  964. break;
  965. case 'contract_update':
  966. responseData.data = await ctx.service.financialPayContract.updateContract(ctx.financialPay.id, data.updateData);
  967. break;
  968. case 'contract_paste':
  969. responseData.data = await ctx.service.financialPayContract.updateContracts(ctx.financialPay.id, data.updateData);
  970. break;
  971. case 'file_bill':
  972. responseData.data = await ctx.service.financialPayAtt.updateBill(data.id, data.bill);
  973. break;
  974. default: throw '参数有误';
  975. }
  976. ctx.body = responseData;
  977. } catch (err) {
  978. this.log(err);
  979. ctx.body = { err: 1, msg: err.toString(), data: {} };
  980. }
  981. }
  982. /**
  983. * 上传附件
  984. * @param {*} ctx 上下文
  985. */
  986. async payUploadFile(ctx) {
  987. let stream;
  988. try {
  989. const parts = this.ctx.multipart({
  990. autoFields: true,
  991. });
  992. const files = [];
  993. const create_time = Date.parse(new Date()) / 1000;
  994. let idx = 0;
  995. // const extra_upload = ctx.financialPay.status === auditConst.status.checked;
  996. while ((stream = await parts()) !== undefined) {
  997. if (!stream.filename) {
  998. // 如果没有传入直接返回
  999. return;
  1000. }
  1001. const fileInfo = path.parse(stream.filename);
  1002. const filepath = `sp/financial/${ctx.subProject.id}/pay/${ctx.financialPay.id}/fujian_${create_time + idx.toString() + fileInfo.ext}`;
  1003. // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, 'app', filepath));
  1004. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  1005. files.push({ filepath, name: stream.filename, ext: fileInfo.ext });
  1006. ++idx;
  1007. stream && (await sendToWormhole(stream));
  1008. }
  1009. const in_time = new Date();
  1010. const type = parts.field.type ? parseInt(parts.field.type) : 0;
  1011. const fpcid = parts.field.fpcid ? parseInt(parts.field.fpcid) : null;
  1012. const payload = files.map(file => {
  1013. let idx;
  1014. if (Array.isArray(parts.field.name)) {
  1015. idx = parts.field.name.findIndex(name => name === file.name);
  1016. } else {
  1017. idx = 'isString';
  1018. }
  1019. const newFile = {
  1020. spid: ctx.subProject.id,
  1021. fpid: ctx.financialPay.id,
  1022. fpcid,
  1023. uid: ctx.session.sessionUser.accountId,
  1024. filename: file.name,
  1025. fileext: file.ext,
  1026. filesize: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
  1027. filepath: file.filepath,
  1028. upload_time: in_time,
  1029. type,
  1030. };
  1031. return newFile;
  1032. });
  1033. // 执行文件信息写入数据库
  1034. await ctx.service.financialPayAtt.saveFileMsgToDb(payload);
  1035. // 将最新的当前标段的所有文件信息返回
  1036. const data = await ctx.service.financialPayAtt.getAtt(ctx.financialPay.id, fpcid);
  1037. ctx.body = { err: 0, msg: '', data };
  1038. } catch (err) {
  1039. stream && (await sendToWormhole(stream));
  1040. this.log(err);
  1041. ctx.body = { err: 1, msg: err.toString(), data: null };
  1042. }
  1043. }
  1044. /**
  1045. * 删除附件
  1046. * @param {Ojbect} ctx 上下文
  1047. */
  1048. async payDeleteFile(ctx) {
  1049. try {
  1050. const { fpcid, id } = JSON.parse(ctx.request.body.data);
  1051. const fileInfo = await ctx.service.financialPayAtt.getDataById(id);
  1052. if (fileInfo || Object.keys(fileInfo).length) {
  1053. // 先删除文件
  1054. // await fs.unlinkSync(path.resolve(this.app.baseDir, './app', fileInfo.filepath));
  1055. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
  1056. // 再删除数据库
  1057. await ctx.service.financialPayAtt.delete(id);
  1058. } else {
  1059. throw '不存在该文件';
  1060. }
  1061. const data = await ctx.service.financialPayAtt.getAtt(ctx.financialPay.id, fpcid ? fpcid : null);
  1062. ctx.body = { err: 0, msg: '请求成功', data };
  1063. } catch (err) {
  1064. this.log(err);
  1065. ctx.body = { err: 1, msg: err.toString(), data: null };
  1066. }
  1067. }
  1068. /**
  1069. * 下载附件
  1070. * @param {Object} ctx - egg全局变量
  1071. * @return {void}
  1072. */
  1073. async payDownloadFile(ctx) {
  1074. const id = ctx.params.fid;
  1075. if (id) {
  1076. try {
  1077. const fileInfo = await ctx.service.financialPayAtt.getDataById(id);
  1078. if (fileInfo !== undefined && fileInfo !== '') {
  1079. // const fileName = path.join(__dirname, '../', fileInfo.filepath);
  1080. // 解决中文无法下载问题
  1081. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  1082. let disposition = '';
  1083. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  1084. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename);
  1085. } else if (userAgent.indexOf('firefox') >= 0) {
  1086. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename) + '"';
  1087. } else {
  1088. /* safari等其他非主流浏览器只能自求多福了 */
  1089. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename).toString('binary');
  1090. }
  1091. ctx.response.set({
  1092. 'Content-Type': 'application/octet-stream',
  1093. 'Content-Disposition': disposition,
  1094. 'Content-Length': fileInfo.filesize,
  1095. });
  1096. // ctx.body = await fs.createReadStream(fileName);
  1097. ctx.body = await ctx.helper.ossFileGet(fileInfo.filepath);
  1098. } else {
  1099. throw '不存在该文件';
  1100. }
  1101. } catch (err) {
  1102. this.log(err);
  1103. this.setMessage(err.toString(), this.messageType.ERROR);
  1104. }
  1105. }
  1106. }
  1107. async summary(ctx) {
  1108. try {
  1109. const financialPermission = await ctx.service.subProjPermission.getFinancailPermission(ctx.subProject.permission.fund_trans_permission, ctx.subProject.permission.fund_pay_permission);
  1110. if (!financialPermission.transfer_show && !financialPermission.pay_show) {
  1111. throw '没有查看权限';
  1112. }
  1113. const renderData = {
  1114. financialPermission,
  1115. usedList: financialConst.used,
  1116. // preUrl: '/financial',
  1117. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.financial.summary),
  1118. };
  1119. await this.layout('financial/summary.ejs', renderData);
  1120. } catch (err) {
  1121. this.log(err);
  1122. ctx.redirect(`/sp/${ctx.subProject.id}/dashboard`);
  1123. }
  1124. }
  1125. async summaryLoad(ctx) {
  1126. try {
  1127. const responseData = {
  1128. err: 0, msg: '', data: {},
  1129. };
  1130. const tid = parseInt(ctx.query.tid) || null;
  1131. const fptAudits = await ctx.service.financialPayTenderAudit.getAllDataByCondition({ where: { spid: ctx.subProject.id, uid: ctx.session.sessionUser.accountId } });
  1132. const fptAuditTids = ctx.helper._.map(fptAudits, 'tid');
  1133. const filterTids = tid === null ? (ctx.session.sessionUser.is_admin ? null : fptAuditTids) : [tid];
  1134. const tenderCondition = { spid: ctx.subProject.id };
  1135. let hadTender = false;
  1136. if (ctx.session.sessionUser.is_admin) {
  1137. hadTender = true;
  1138. } else if (fptAuditTids.length !== 0) {
  1139. hadTender = true;
  1140. tenderCondition.id = fptAuditTids;
  1141. } else {
  1142. hadTender = false;
  1143. tenderCondition.id = -1;
  1144. }
  1145. responseData.data.tenders = hadTender ? await ctx.service.tender.getAllDataByCondition({ where: tenderCondition, columns: ['id', 'name'] }) : [];
  1146. responseData.data.transferList = tid === null ? await ctx.service.financialTransfer.getAllDataByCondition({ where: { spid: ctx.subProject.id } }) : [];
  1147. responseData.data.transferTenderList = tid === null ? await ctx.service.financialTransferTender.getAllDataByCondition({ where: { spid: ctx.subProject.id } }) : [];
  1148. responseData.data.payList = await ctx.service.financialPay.getListByStatus(ctx.subProject.id, 0, filterTids);
  1149. ctx.body = responseData;
  1150. } catch (err) {
  1151. this.log(err);
  1152. ctx.body = { err: 1, msg: err.toString(), data: {} };
  1153. }
  1154. }
  1155. }
  1156. return FinancialController;
  1157. };