advance_controller.js 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642
  1. 'use strict';
  2. const accountGroup = require('../const/account_group').group;
  3. const auditConst = require('../const/audit').advance;
  4. const shenpiConst = require('../const/shenpi');
  5. const typeConsts = require('../const/advance');
  6. const sendToWormhole = require('stream-wormhole');
  7. const path = require('path');
  8. const fs = require('fs');
  9. const auditType = require('../const/audit').auditType;
  10. module.exports = app => {
  11. class advanceController extends app.BaseController {
  12. constructor(ctx) {
  13. super(ctx);
  14. const { decimal } = ctx.tender.info;
  15. this.decimal = decimal.pay ? decimal.payTp : decimal.tp;
  16. }
  17. /**
  18. * 开工预付款页面(AJAX) GET
  19. * @param {Object} ctx 全局上下文
  20. */
  21. async index(ctx) {
  22. const advanceType = typeConsts.typeCol.find(item => item.key === ctx.params.type);
  23. const type = advanceType.type;
  24. const advancePayTotal = ctx.tender.info.deal_param[`${advanceType.key}Advance`];
  25. const advanceList = await ctx.service.advance.getAdvanceList(ctx.tender.id, type, this.decimal, advancePayTotal);
  26. const latestOrder = await ctx.service.advance.getLastestAdvance(ctx.tender.id, type, true);
  27. const progress = await ctx.service.advance.calcProgress(latestOrder, advancePayTotal);
  28. const showAddBtn = ctx.tender.data.user_id === ctx.session.sessionUser.accountId ? (!latestOrder || (latestOrder.status === auditConst.status.checked && latestOrder.prev_total_amount < advancePayTotal)) : false;
  29. const renderData = {
  30. type,
  31. decimal: this.decimal,
  32. showAddBtn,
  33. advanceList,
  34. latestOrder,
  35. auditConst,
  36. typeColMap: typeConsts.typeColMap,
  37. preUrl: `/tender/${ctx.tender.id}/advance/${type}/create`,
  38. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.advance.main),
  39. advancePayTotal,
  40. progress,
  41. };
  42. await this.layout('advance/index.ejs', renderData, 'advance/modal.ejs');
  43. }
  44. /**
  45. * 材料预付款页面(AJAX) GET
  46. * @param {Object} ctx 全局上下文
  47. */
  48. // async materialList(ctx) {
  49. // const type = auditConst.type.material;
  50. // const advancePayTotal = ctx.tender.info.deal_param.materialAdvance;
  51. // const advanceList = await ctx.service.advance.getAdvanceList(ctx.tender.id, type, this.decimal, advancePayTotal);
  52. // const latestOrder = await ctx.service.advance.getLastestAdvance(ctx.tender.id, type, true);
  53. // const progress = await ctx.service.advance.calcProgress(latestOrder, advancePayTotal);
  54. // const showAddBtn = ctx.tender.data.user_id === ctx.session.sessionUser.accountId ? !latestOrder || (latestOrder.status === auditConst.status.checked && latestOrder.prev_total_amount < advancePayTotal) : false;
  55. // const renderData = {
  56. // type,
  57. // decimal: this.decimal,
  58. // showAddBtn,
  59. // advanceList,
  60. // latestOrder,
  61. // auditConst,
  62. // preUrl: `/tender/${ctx.tender.id}/advance/${type}/create`,
  63. // jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.advance.main),
  64. // advancePayTotal,
  65. // progress,
  66. // };
  67. // await this.layout('advance/index.ejs', renderData, 'advance/modal.ejs');
  68. // }
  69. /**
  70. * 获取通用的renderData(用于layout, Menu, subMenu部分)
  71. * @param {Object} ctx 全局上下文
  72. * @return {{auditConst, jsFiles, accountGroup?, accountList?, auditors, auditHistory, preUrl}} 通用数据
  73. * @private
  74. */
  75. async _getDefaultRenderData(ctx) {
  76. const data = {
  77. auditConst,
  78. shenpiConst,
  79. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.advance.info),
  80. preUrl: `/tender/${ctx.tender.id}/advance/${ctx.advance.id}`,
  81. whiteList: ctx.app.config.multipart.whitelist,
  82. adminAuditors: [],
  83. };
  84. // 获取所有项目参与者
  85. if (((ctx.advance.status === auditConst.status.uncheck || ctx.advance.status === auditConst.status.checkNo) && ctx.session.sessionUser.accountId === ctx.advance.uid) ||
  86. (ctx.session.sessionUser.is_admin && ctx.advance.status !== auditConst.status.uncheck && ctx.advance.status !== auditConst.status.checked)) {
  87. // data.accountGroup = accountGroup;
  88. // 获取所有项目参与者
  89. const accountList = await ctx.service.projectAccount.getAllSubProjectAccount(ctx.subProject);
  90. data.accountList = accountList;
  91. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  92. data.accountGroup = unitList.map(item => {
  93. const groupList = accountList.filter(item1 => item1.company === item.name);
  94. return { groupName: item.name, groupList };
  95. }).filter(x => { return x.groupList.length > 0; });
  96. data.auditorList = await ctx.service.advanceAudit.getAuditors(ctx.advance.id, ctx.advance.times);
  97. if (ctx.session.sessionUser.is_admin) {
  98. data.adminAuditors = await ctx.service.advanceAudit.getAdminAuditGroups(ctx.advance.id, ctx.advance.times);
  99. }
  100. }
  101. // data.fileList = await ctx.service.advanceFile.getAdvanceFiles({ vid: ctx.advance.id });
  102. // 获取审批流程中右边列表
  103. const auditHistory = [];
  104. const times = ctx.advance.status === auditConst.status.checkNo ? ctx.advance.times - 1 : ctx.advance.times;
  105. // 获取审核人左边列表
  106. data.auditors = ctx.advance.status === auditConst.status.checkNo && ctx.session.sessionUser.accountId !== ctx.advance.uid ?
  107. await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, times) :
  108. await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, ctx.advance.times);
  109. if (times >= 1) {
  110. for (let i = 1; i <= times; i++) {
  111. auditHistory.push(await ctx.service.advanceAudit.getAuditors(ctx.advance.id, i));
  112. }
  113. }
  114. data.auditHistory = auditHistory;
  115. data.fileList = await ctx.service.advanceFile.getAdvanceFiles({ vid: ctx.advance.id }) || [];
  116. return data;
  117. }
  118. /**
  119. * 权限判断-进入详情页
  120. * @param {Object} ctx - 全局上下文
  121. * @return {void}
  122. * @private
  123. */
  124. async _checkCanEntry(ctx) {
  125. ctx.advance.filePermission = false;
  126. if (ctx.advance.status === auditConst.status.uncheck) {
  127. if (ctx.session.sessionUser.accountId !== ctx.advance.uid && !ctx.tender.isTourist && !ctx.session.sessionUser.is_admin) {
  128. throw '无权访问';
  129. } else if (ctx.session.sessionUser.accountId === ctx.advance.uid || ctx.tender.touristPermission.file) {
  130. ctx.advance.filePermission = true;
  131. }
  132. } else {
  133. const auditors = await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, ctx.advance.times);
  134. const cur_uid = ctx.session.sessionUser.accountId;
  135. if (auditors.findIndex(item => item.audit_id === cur_uid) === -1 && !ctx.tender.isTourist && !ctx.session.sessionUser.is_admin) {
  136. throw '无权访问';
  137. } else if (auditors.findIndex(item => item.audit_id === cur_uid) !== -1 || ctx.session.sessionUser.accountId === ctx.advance.uid || ctx.tender.touristPermission.file) {
  138. ctx.advance.filePermission = true;
  139. }
  140. }
  141. }
  142. /**
  143. * 预付款详情页(AJAX) GET
  144. * @param {Object} ctx 全局上下文
  145. */
  146. async detail(ctx) {
  147. const advancePayTotal = ctx.tender.info.deal_param[`${typeConsts.typeColMap[ctx.advance.type].value}Advance`];
  148. try {
  149. await this._checkCanEntry(ctx);
  150. const { uncheck, checkNo, checked } = auditConst.status;
  151. const { status } = ctx.advance;
  152. const isEdited = ctx.session.sessionUser.accountId === ctx.advance.uid && (status === uncheck || status === checkNo);
  153. const renderData = await this._getDefaultRenderData(ctx);
  154. // 获取上一期预付款记录
  155. const prevAdvance = await ctx.service.advance.getPreviousRecord(ctx.tender.id, ctx.advance.type);
  156. // 最大支付比例
  157. const max_pr = ctx.helper.mul(ctx.helper.div(ctx.helper.sub(advancePayTotal, (prevAdvance && prevAdvance.prev_total_amount || 0)), advancePayTotal, 10), 100);
  158. const isLimitMax = ctx.helper.round(max_pr, 2) === ctx.advance.pay_ratio;
  159. // 特殊处理金额的显示(formatMoney)
  160. let cur_amount,
  161. prev_total_amount;
  162. const s1 = parseFloat(ctx.advance.prev_amount).toString().split('.')[1] || '';
  163. const prev_amount = ctx.helper.formatMoney(ctx.advance.prev_amount, ',', isLimitMax ? s1.length : 2);
  164. if (status === uncheck || status === checkNo) {
  165. // cur_amount = parseFloat(ctx.helper.round(ctx.advance.cur_amount, 2)) || 0;
  166. cur_amount = ctx.advance.cur_amount || 0;
  167. const s2 = parseFloat(ctx.helper.add(cur_amount, ctx.advance.prev_amount)).toString().split('.')[1] || '';
  168. prev_total_amount = ctx.helper.formatMoney(ctx.helper.add(cur_amount, ctx.advance.prev_amount), ',', isLimitMax ? s2.length : 2);
  169. } else {
  170. cur_amount = ctx.advance.cur_amount;
  171. const s2 = parseFloat(ctx.advance.prev_total_amount).toString().split('.')[1] || '';
  172. prev_total_amount = ctx.helper.formatMoney(ctx.advance.prev_total_amount, ',', isLimitMax ? s2.length : 2);
  173. }
  174. ctx.advance.finalAuditorId = status === checked && ctx.advance.auditors && ctx.advance.auditors.length > 0 ? ctx.advance.auditors[ctx.advance.auditors.length - 1].audit_id : false;
  175. // 获取用户人验证手机号
  176. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  177. const auth_mobile = pa.auth_mobile;
  178. renderData.authMobile = auth_mobile;
  179. renderData.isEdited = isEdited;
  180. renderData.advance = ctx.advance;
  181. renderData.cur_amount = cur_amount;
  182. renderData.prev_amount = prev_amount;
  183. renderData.prev_total_amount = prev_total_amount;
  184. renderData.max_pr = max_pr;
  185. renderData.decimal = 2;
  186. renderData.typeColMap = typeConsts.typeColMap;
  187. renderData.advancePayTotal = advancePayTotal;
  188. renderData.prevAdvance = prevAdvance;
  189. renderData.auditType = auditType;
  190. await this.layout('advance/detail.ejs', renderData, 'advance/modal_audit.ejs');
  191. } catch (error) {
  192. this.log(error);
  193. ctx.redirect('/tender/' + ctx.tender.id + '/advance/' + typeConsts.typeColMap[ctx.advance.type].value);
  194. }
  195. }
  196. /**
  197. * 更新
  198. * @param {Object} ctx 全局上下文
  199. */
  200. async update(ctx) {
  201. const { id } = ctx.advance;
  202. const data = JSON.parse(ctx.request.body.data);
  203. try {
  204. const result = await ctx.service.advance.updateAdvance(data, id);
  205. if (result) {
  206. ctx.body = { err: 0, msg: '请求成功', data: null };
  207. } else {
  208. ctx.body = { err: 0, msg: '请求失败', data: null };
  209. }
  210. } catch (error) {
  211. this.log(error);
  212. ctx.body = { code: 1, msg: error.toString() };
  213. }
  214. }
  215. /**
  216. * 添加新一期
  217. * @param {Object} ctx 全局上下文
  218. */
  219. async create(ctx) {
  220. const type = parseInt(ctx.params.type);
  221. try {
  222. // 参考变更令的做法,在创建新一期预付款时,需要copy前一个预付款报表的签名信息
  223. const lastAdvance = await ctx.service.advance.getLastestAdvance(ctx.tender.id, type, true);
  224. const record = await ctx.service.advance.createRecord(type);
  225. if (lastAdvance && record) {
  226. // 这里advance list是所有类型的合在一起,不会有重复的id
  227. await ctx.service.roleRptRel.createRoleRelationshipFromOtherBz(ctx.tender.id, '-400', record.id, lastAdvance.id);
  228. }
  229. if (!record) {
  230. throw '数据错误';
  231. }
  232. ctx.redirect(`/tender/${ctx.tender.id}/advance/${record.id}/detail`);
  233. } catch (error) {
  234. this.log(error);
  235. ctx.redirect(`/tender/${ctx.tender.id}/advance/${typeConsts.typeColMap[ctx.advance.type].value}`);
  236. }
  237. }
  238. /**
  239. * 删除期
  240. * @param {*} ctx 全局上下文
  241. */
  242. async delete(ctx) {
  243. try {
  244. const data = JSON.parse(ctx.request.body.data);
  245. const id = data && this.app._.toInteger(data.id);
  246. if (isNaN(id) || id <= 0) {
  247. throw '参数错误';
  248. }
  249. const advance = await ctx.service.advance.getDataById(id);
  250. if (!advance) {
  251. throw '参数错误';
  252. }
  253. // 检查权限等
  254. if (!ctx.session.sessionUser.is_admin && advance.uid !== ctx.session.sessionUser.accountId) {
  255. throw '您无权删除';
  256. }
  257. if (!ctx.session.sessionUser.is_admin && advance.status !== auditConst.status.uncheck && advance.status !== auditConst.status.checkNo) {
  258. // console.log(advance.status !== auditConst.status.uncheck);
  259. // console.log(advance.status !== auditConst.status.checkNo);
  260. throw '当前不允许删除';
  261. }
  262. await ctx.service.advance.deleteAdvance(id, ctx.tender.id);
  263. ctx.body = { err: 0, msg: '' };
  264. } catch (error) {
  265. this.log(error);
  266. ctx.body = { err: 1, msg: error.toString(), data: null };
  267. }
  268. }
  269. /**
  270. * 添加审批人
  271. * @param {Object} ctx 全局上下文
  272. */
  273. async addAudit(ctx) {
  274. try {
  275. const data = JSON.parse(ctx.request.body.data);
  276. const audit_id = data && this.app._.toInteger(data.auditorId);
  277. if (isNaN(audit_id) || audit_id <= 0) {
  278. throw '参数错误';
  279. }
  280. // 检查权限等
  281. if (ctx.advance.uid !== ctx.session.sessionUser.accountId) {
  282. throw '您无权添加审核人';
  283. }
  284. if (ctx.advance.status === auditConst.status.checking || ctx.advance.status === auditConst.status.checked) {
  285. throw '当前不允许添加审核人';
  286. }
  287. // 检查审核人是否已存在
  288. const exist = this.app._.find(ctx.advance.auditors, { audit_id });
  289. if (exist) {
  290. throw '该审核人已存在,请勿重复添加';
  291. }
  292. const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.advance, sp_status: shenpiConst.sp_status.gdzs });
  293. const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.advance === shenpiConst.sp_status.gdzs ? 1 : 0;
  294. const result = await ctx.service.advanceAudit.addAuditor(ctx.tender.id, ctx.advance.id, audit_id, ctx.advance.times, ctx.advance.type, is_gdzs);
  295. if (!result) {
  296. throw '添加审核人失败';
  297. }
  298. const auditors = await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, ctx.advance.times);
  299. ctx.body = { err: 0, msg: '', data: auditors };
  300. } catch (err) {
  301. this.log(err);
  302. ctx.body = { err: 1, msg: err.toString(), data: null };
  303. }
  304. }
  305. /**
  306. * 移除审批人
  307. * @param {Object} ctx 全局上下文
  308. */
  309. async deleteAudit(ctx) {
  310. try {
  311. const data = JSON.parse(ctx.request.body.data);
  312. const id = data && data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  313. if (isNaN(id) || id <= 0) {
  314. throw '参数错误';
  315. }
  316. const result = await ctx.service.advanceAudit.deleteAuditor(ctx.advance.id, id, ctx.advance.times);
  317. if (!result) {
  318. throw '移除审核人失败';
  319. }
  320. const auditors = await ctx.service.advanceAudit.getAuditGroupByList(ctx.advance.id, ctx.advance.times);
  321. ctx.body = { err: 0, msg: '', data: auditors };
  322. } catch (err) {
  323. ctx.body = { err: 1, msg: err.toString(), data: null };
  324. }
  325. }
  326. /**
  327. * 上报审批
  328. * @param {Object} ctx 全局上下文
  329. */
  330. async start(ctx) {
  331. const data = JSON.parse(ctx.request.body.data);
  332. try {
  333. // 检查权限等
  334. if (!ctx.advance) {
  335. throw '数据错误';
  336. }
  337. if (ctx.advance.uid !== ctx.session.sessionUser.accountId) {
  338. throw '您无权上报该期数据';
  339. }
  340. if (ctx.advance.status === auditConst.status.checking || ctx.advance.status === auditConst.status.checked) {
  341. throw '该预付款期数据当前无法上报';
  342. }
  343. if (data.cur_amount === 0) {
  344. throw '本期金额不能为空';
  345. }
  346. await ctx.service.advanceAudit.start(ctx.advance.id, ctx.advance.times, data);
  347. ctx.body = { err: 0, msg: '' };
  348. } catch (error) {
  349. this.log(error);
  350. ctx.session.postError = error.toString();
  351. ctx.body = { err: 1, msg: error.toString() };
  352. }
  353. }
  354. /**
  355. * 审批
  356. * @param {Object} ctx 全局上下文
  357. */
  358. async checkAudit(ctx) {
  359. try {
  360. if (!ctx.advance || ctx.advance.status !== auditConst.status.checking) {
  361. throw '当前预付款数据有误';
  362. }
  363. if (!ctx.advance.curAuditor || ctx.advance.curAuditor.audit_id !== ctx.session.sessionUser.accountId) {
  364. throw '您无权进行该操作';
  365. }
  366. const data = {
  367. checkType: parseInt(ctx.request.body.checkType),
  368. opinion: ctx.request.body.opinion,
  369. };
  370. if (!data.checkType || isNaN(data.checkType)) {
  371. throw '提交数据错误';
  372. }
  373. if (data.checkType === auditConst.status.checkNo) {
  374. if (!data.checkType || isNaN(data.checkType)) {
  375. throw '提交数据错误';
  376. }
  377. }
  378. await ctx.service.advanceAudit.check(ctx.advance.id, data, ctx.advance.times, ctx.advance.type);
  379. ctx.redirect(ctx.request.header.referer);
  380. } catch (err) {
  381. this.log(err);
  382. ctx.session.postError = err.toString();
  383. ctx.redirect(ctx.request.header.referer);
  384. }
  385. }
  386. /**
  387. * 重新审批
  388. * @param {Object} ctx - egg全局变量
  389. * @return {void}
  390. */
  391. async checkAgain(ctx) {
  392. try {
  393. if (!ctx.advance || ctx.advance.status !== auditConst.status.checked) {
  394. throw '当前预付款数据有误';
  395. }
  396. const finalAuditorId = ctx.advance.auditors && ctx.advance.auditors.length > 0 ? ctx.advance.auditors[ctx.advance.auditors.length - 1].audit_id : false;
  397. if (!finalAuditorId || finalAuditorId !== ctx.session.sessionUser.accountId) {
  398. throw '您无权进行该操作';
  399. }
  400. if (ctx.session.sessionUser.loginStatus === 0) {
  401. const code = ctx.request.body.code;
  402. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  403. if (!pa.auth_mobile) {
  404. throw '未绑定手机号';
  405. }
  406. const cacheKey = 'smsCode:' + ctx.session.sessionUser.accountId;
  407. const cacheCode = await app.redis.get(cacheKey);
  408. // console.log(cacheCode);
  409. if (cacheCode === null || code === undefined || cacheCode !== (code + pa.auth_mobile)) {
  410. throw '验证码不正确!';
  411. }
  412. }
  413. // 重新审批
  414. const result = await ctx.service.advanceAudit.checkAgain(ctx.advance);
  415. if (!result) {
  416. throw '重新审批失败';
  417. }
  418. ctx.body = {
  419. err: 0,
  420. url: ctx.request.header.referer,
  421. msg: '',
  422. };
  423. } catch (err) {
  424. console.log(err);
  425. ctx.body = {
  426. err: 1,
  427. msg: err,
  428. };
  429. }
  430. }
  431. /**
  432. * 管理员修改当前预付款审批流程
  433. * @param {Object} ctx 全局上下文
  434. */
  435. async saveAudit(ctx) {
  436. try {
  437. if (!ctx.session.sessionUser.is_admin ||
  438. ctx.advance.status === auditConst.status.uncheck ||
  439. ctx.advance.status === auditConst.status.checked) {
  440. throw '您无权进行该操作';
  441. }
  442. const data = JSON.parse(ctx.request.body.data);
  443. await ctx.service.advanceAudit.saveAudit(ctx.advance, data);
  444. const auditors = await ctx.service.advanceAudit.getAdminAuditGroups(ctx.advance.id, ctx.advance.times);
  445. ctx.body = { err: 0, msg: '', data: auditors };
  446. } catch (err) {
  447. ctx.log(err);
  448. ctx.body = { err: 1, msg: err.toString(), data: null };
  449. }
  450. }
  451. _checkAdvanceFileCanModify(ctx) {
  452. // 检查登录用户,是否可操作
  453. const accountId = ctx.session.sessionUser.accountId;
  454. if (!ctx.advance.curAuditor) {
  455. if (ctx.advance.status === auditConst.status.uncheck || ctx.advance.status === auditConst.status.checkNo && accountId === ctx.advance.uid) {
  456. return;
  457. }
  458. throw '该预付款期当前您无权操作';
  459. } else {
  460. if (ctx.advance.curAuditor.audit_id === accountId) return;
  461. throw '该预付款期当前您无权操作';
  462. }
  463. }
  464. /**
  465. * 上传附件
  466. * @param {*} ctx 上下文
  467. */
  468. async upload(ctx) {
  469. let stream;
  470. try {
  471. // this._checkAdvanceFileCanModify(ctx);
  472. const parts = this.ctx.multipart({
  473. autoFields: true,
  474. });
  475. const files = [];
  476. const create_time = Date.parse(new Date()) / 1000;
  477. let idx = 0;
  478. const extra_upload = ctx.advance.status === auditConst.status.checked;
  479. while ((stream = await parts()) !== undefined) {
  480. if (!stream.filename) {
  481. // 如果没有传入直接返回
  482. return;
  483. }
  484. const fileInfo = path.parse(stream.filename);
  485. const filepath = `app/public/upload/${this.ctx.tender.id.toString()}/yfk/fujian_${create_time + idx.toString() + fileInfo.ext}`;
  486. // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, 'app', filepath));
  487. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  488. files.push({ filepath, name: stream.filename, ext: fileInfo.ext });
  489. ++idx;
  490. stream && (await sendToWormhole(stream));
  491. }
  492. const in_time = new Date();
  493. const payload = files.map(file => {
  494. let idx;
  495. if (Array.isArray(parts.field.name)) {
  496. idx = parts.field.name.findIndex(name => name === file.name);
  497. } else {
  498. idx = 'isString';
  499. }
  500. const newFile = {
  501. uid: ctx.session.sessionUser.accountId,
  502. vid: ctx.advance.id,
  503. tid: ctx.tender.id,
  504. create_time: in_time,
  505. filepath: file.filepath,
  506. filesize: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
  507. filename: file.name,
  508. fileext: file.ext,
  509. extra_upload,
  510. };
  511. return newFile;
  512. });
  513. // 执行文件信息写入数据库
  514. await ctx.service.advanceFile.saveFileMsgToDb(payload);
  515. // 将最新的当前标段的所有文件信息返回
  516. const data = await ctx.service.advanceFile.getAdvanceFiles({ vid: ctx.advance.id });
  517. ctx.body = { err: 0, msg: '', data };
  518. } catch (err) {
  519. stream && (await sendToWormhole(stream));
  520. this.log(err);
  521. ctx.body = { err: 1, msg: err.toString(), data: null };
  522. }
  523. }
  524. /**
  525. * 删除附件
  526. * @param {Ojbect} ctx 上下文
  527. */
  528. async deleteFile(ctx) {
  529. try {
  530. const { id } = JSON.parse(ctx.request.body.data);
  531. const fileInfo = await ctx.service.advanceFile.getDataById(id);
  532. if (fileInfo || Object.keys(fileInfo).length) {
  533. // 先删除文件
  534. // await fs.unlinkSync(path.resolve(this.app.baseDir, './app', fileInfo.filepath));
  535. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
  536. // 再删除数据库
  537. await ctx.service.advanceFile.delete(id);
  538. } else {
  539. throw '不存在该文件';
  540. }
  541. const data = await ctx.service.advanceFile.getAdvanceFiles({ vid: ctx.advance.id });
  542. ctx.body = { err: 0, msg: '请求成功', data };
  543. } catch (err) {
  544. this.log(err);
  545. ctx.body = { err: 1, msg: err.toString(), data: null };
  546. }
  547. }
  548. /**
  549. * 下载附件
  550. * @param {Object} ctx - egg全局变量
  551. * @return {void}
  552. */
  553. async downloadFile(ctx) {
  554. const id = ctx.params.fid;
  555. if (id) {
  556. try {
  557. const fileInfo = await ctx.service.advanceFile.getDataById(id);
  558. if (fileInfo !== undefined && fileInfo !== '') {
  559. // const fileName = path.join(__dirname, '../', fileInfo.filepath);
  560. // 解决中文无法下载问题
  561. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  562. let disposition = '';
  563. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  564. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename);
  565. } else if (userAgent.indexOf('firefox') >= 0) {
  566. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename) + '"';
  567. } else {
  568. /* safari等其他非主流浏览器只能自求多福了 */
  569. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename).toString('binary');
  570. }
  571. ctx.response.set({
  572. 'Content-Type': 'application/octet-stream',
  573. 'Content-Disposition': disposition,
  574. 'Content-Length': fileInfo.filesize,
  575. });
  576. // ctx.body = await fs.createReadStream(fileName);
  577. ctx.body = await ctx.helper.ossFileGet(fileInfo.filepath);
  578. } else {
  579. throw '不存在该文件';
  580. }
  581. } catch (err) {
  582. this.log(err);
  583. this.setMessage(err.toString(), this.messageType.ERROR);
  584. }
  585. }
  586. }
  587. /**
  588. * 获取列表页所需的审核弹窗列表
  589. * @param {object} ctx 全局上下文
  590. */
  591. async getAuditors(ctx) {
  592. try {
  593. const data = {};
  594. // 获取审核人左边列表
  595. data.auditors = await ctx.service.advanceAudit.getAuditorsWithOwner(ctx.advance.id, ctx.advance.times);
  596. // 获取审批流程中右边列表
  597. const auditHistory = [];
  598. const times = ctx.advance.status === auditConst.status.checkNo ? ctx.advance.times - 1 : ctx.advance.times;
  599. if (times >= 1) {
  600. for (let i = 1; i <= times; i++) {
  601. auditHistory.push(await ctx.service.advanceAudit.getAuditors(ctx.advance.id, i));
  602. }
  603. }
  604. data.auditHistory = auditHistory;
  605. data.user = ctx.advance.user;
  606. ctx.body = { err: 0, msg: '请求成功', data };
  607. } catch (error) {
  608. this.log(error);
  609. ctx.body = { err: 0, msg: error.toString() };
  610. }
  611. }
  612. }
  613. return advanceController;
  614. };