advance_controller.js 29 KB

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