change_controller.js 34 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author Mai
  6. * @date 2018/8/14
  7. * @version
  8. */
  9. const moment = require('moment');
  10. const sendToWormhole = require('stream-wormhole');
  11. const fs = require('fs');
  12. const path = require('path');
  13. const audit = require('../const/audit');
  14. const codeRuleConst = require('../const/code_rule');
  15. const changeConst = require('../const/change');
  16. const accountGroup = require('../const/account_group').group;
  17. // const tenderMenu = require('../../config/menu').tenderMenu;
  18. module.exports = app => {
  19. class ChangeController extends app.BaseController {
  20. /**
  21. * 构造函数
  22. *
  23. * @param {Object} ctx - egg全局变量
  24. * @return {void}
  25. */
  26. constructor(ctx) {
  27. super(ctx);
  28. ctx.showProject = true;
  29. ctx.showTender = true;
  30. ctx.showTitle = true;
  31. }
  32. async _filterChanges(ctx, status = 0) {
  33. const tenderId = ctx.params.id;
  34. ctx.session.sessionUser.tenderId = tenderId;
  35. const tender = await this.service.tender.getDataById(tenderId);
  36. const tenderList = await this.service.tender.getList();
  37. const page = ctx.page;
  38. const changes = await ctx.service.change.getListByStatus(tender.id, status);
  39. const total = await ctx.service.change.getCountByStatus(tender.id, status);
  40. if (changes !== null) {
  41. let i = 0;
  42. for (const c of changes) {
  43. const status = c.status === audit.flow.status.uncheck ? 0 : 1;
  44. // 根据审批人对当前变更令的状态取不同的展示方式。
  45. let changeAudit = '';
  46. let auditStatus = 0;
  47. switch (c.status) {
  48. case 1:
  49. auditStatus = 1;
  50. break;
  51. case 2:
  52. changeAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times, status);
  53. auditStatus = changeAudit.uid === ctx.session.sessionUser.accountId ? 1 : 0;
  54. break;
  55. case 3:
  56. case 4:
  57. auditStatus = 0;
  58. changeAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times, status);
  59. break;
  60. case 5:
  61. changeAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times - 1, status);
  62. auditStatus = c.uid === ctx.session.sessionUser.accountId ? 1 : 0;
  63. break;
  64. case 6:
  65. changeAudit = await ctx.service.changeAudit.getLastBackUser(c.cid, c.times);
  66. const checkingAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times, status);
  67. auditStatus = checkingAudit.uid === ctx.session.sessionUser.accountId ? 1 : 0;
  68. break;
  69. default:
  70. break;
  71. }
  72. changes[i].changeAudit = changeAudit;
  73. changes[i].auditStatus = auditStatus;
  74. i++;
  75. }
  76. }
  77. // 分页相关
  78. const pageInfo = {
  79. page,
  80. total: parseInt(total / app.config.pageSize),
  81. queryData: JSON.stringify(ctx.urlInfo.query),
  82. };
  83. const filter = JSON.parse(JSON.stringify(audit.filter));
  84. filter.count = [];
  85. filter.count[filter.status.pending] = await ctx.service.change.getCountByStatus(tender.id, filter.status.pending);// await ctx.service.change.pendingDatas(tender.id, ctx.session.sessionUser.accountId);
  86. filter.count[filter.status.uncheck] = await ctx.service.change.getCountByStatus(tender.id, filter.status.uncheck);// await ctx.service.change.checkingDatas(tender.id, ctx.session.sessionUser.accountId);
  87. filter.count[filter.status.checking] = await ctx.service.change.getCountByStatus(tender.id, filter.status.checking);// await ctx.service.change.checkedDatas(tender.id, ctx.session.sessionUser.accountId);
  88. filter.count[filter.status.checked] = await ctx.service.change.getCountByStatus(tender.id, filter.status.checked);// await ctx.service.change.pendingDatas(tender.id, ctx.session.sessionUser.accountId);
  89. filter.count[filter.status.checkNo] = await ctx.service.change.getCountByStatus(tender.id, filter.status.checkNo);// await ctx.service.change.pendingDatas(tender.id, ctx.session.sessionUser.accountId);
  90. const codeRule = tender.c_rule ? JSON.parse(tender.c_rule) : [];
  91. for (const rule of codeRule) {
  92. switch (rule.rule_type) {
  93. case codeRuleConst.measure.ruleType.tenderName:
  94. rule.preview = tender.name;
  95. break;
  96. case codeRuleConst.measure.ruleType.inDate:
  97. rule.preview = moment().format('YYYY');
  98. break;
  99. case codeRuleConst.measure.ruleType.text:
  100. rule.preview = rule.text;
  101. break;
  102. case codeRuleConst.measure.ruleType.addNo:
  103. const s = '0000000000';
  104. rule.preview = s.substr(s.length - rule.format);
  105. break;
  106. default: break;
  107. }
  108. }
  109. const renderData = {
  110. uid: ctx.session.sessionUser.accountId,
  111. moment,
  112. tender,
  113. tenderList,
  114. pageInfo,
  115. changes,
  116. filter,
  117. status,
  118. codeRule,
  119. auditConst: audit.flow,
  120. changeConst,
  121. ruleType: codeRuleConst.ruleType.change,
  122. ruleConst: codeRuleConst.measure,
  123. tenderMenu: this.menu.tenderMenu,
  124. preUrl: '/tender/' + tenderId,
  125. };
  126. await this.layout('change/index.ejs', renderData, 'change/modal.ejs');
  127. }
  128. /**
  129. * 变更管理 页面 (Get)
  130. *
  131. * @param {Object} ctx - egg全局变量
  132. * @return {void}
  133. */
  134. async index(ctx) {
  135. try {
  136. await this._filterChanges(ctx);
  137. } catch (err) {
  138. this.log(err);
  139. ctx.redirect('/dashboard');
  140. }
  141. }
  142. /**
  143. *
  144. * @param {Object} ctx - egg全局变量
  145. * @return {void}
  146. */
  147. async newCode(ctx) {
  148. const responseData = {
  149. err: 0,
  150. msg: '',
  151. data: '',
  152. };
  153. try {
  154. const tenderId = ctx.params.id;
  155. if (!tenderId) {
  156. throw '当前未打开标段';
  157. }
  158. const tenderData = await ctx.service.tender.getDataById(tenderId);
  159. const cCodeRule = tenderData.c_rule !== null ? JSON.parse(tenderData.c_rule) : [];
  160. const code = [];
  161. for (const rule of cCodeRule) {
  162. switch (rule.rule_type) {
  163. case codeRuleConst.measure.ruleType.tenderName:
  164. code.push(tenderData.name);
  165. break;
  166. case codeRuleConst.measure.ruleType.text:
  167. code.push(rule.text);
  168. break;
  169. case codeRuleConst.measure.ruleType.inDate:
  170. code.push(moment().format('YYYY'));
  171. break;
  172. case codeRuleConst.measure.ruleType.addNo:
  173. let s = '0000000000';
  174. const count = rule.start + await ctx.service.change.count({ tid: tenderId });
  175. s = s + count;
  176. code.push(s.substr(s.length - rule.format));
  177. break;
  178. default: break;
  179. }
  180. }
  181. responseData.data = code.join(tenderData.c_connector !== null && tenderData.c_connector !== 3 ? codeRuleConst.measure.connectorString[tenderData.c_connector] : '');
  182. } catch (err) {
  183. responseData.err = 1;
  184. responseData.msg = err;
  185. }
  186. ctx.body = responseData;
  187. }
  188. /**
  189. * 新增变更 (Post)
  190. *
  191. * @param {Object} ctx - egg全局变量
  192. * @return {void}
  193. */
  194. async add(ctx) {
  195. try {
  196. const tenderId = ctx.params.id;
  197. if (!tenderId) {
  198. throw '当前未打开标段';
  199. }
  200. const data = JSON.parse(ctx.request.body.data);
  201. if (!data.code || data.code === '' || !data.name || data.name === '') {
  202. throw '变更令号不能为空';
  203. }
  204. const change = await ctx.service.change.add(tenderId, ctx.session.sessionUser.accountId, data.code, data.name);
  205. ctx.body = { err: 0, msg: '', data: change };
  206. } catch (err) {
  207. this.log(err);
  208. ctx.body = { err: 1, msg: err.toString() };
  209. }
  210. }
  211. /**
  212. * 变更管理 状态筛选 页面 (Get)
  213. * @param {Object} ctx - egg全局变量
  214. * @return {void}
  215. */
  216. async status(ctx) {
  217. try {
  218. const status = parseInt(ctx.params.status);
  219. await this._filterChanges(ctx, status);
  220. } catch (err) {
  221. this.logger.error(err);
  222. ctx.redirect('/tender/' + ctx.params.id + '/change');
  223. }
  224. }
  225. /**
  226. * 变更信息 页面 (Get)
  227. *
  228. * @param {Object} ctx - egg全局变量
  229. * @return {void}
  230. */
  231. async info(ctx) {
  232. try {
  233. const whiteList = this.ctx.app.config.multipart.whitelist;
  234. const tenderid = ctx.params.id !== undefined ? ctx.params.id : ctx.session.sessionUser.tenderId;
  235. ctx.session.sessionUser.tenderId = tenderid;
  236. const tender = await this.service.tender.getDataById(tenderid);
  237. const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });
  238. // 后台判断当前人查看info状态
  239. const auditStatus = await ctx.service.changeAudit.getStatusByChange(change);
  240. // 获取附件列表
  241. const attList = await ctx.service.changeAtt.getAllDataByCondition({ where: { cid: ctx.params.cid } });
  242. // 根据auditStatus获取审批人列表
  243. const auditList = await ctx.service.changeAudit.getListByStatus(change, auditStatus);
  244. // 获取已选清单
  245. const changeList = await ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: ctx.params.cid } });
  246. const renderData = {
  247. uid: ctx.session.sessionUser.accountId,
  248. tender,
  249. change,
  250. changeConst,
  251. auditStatus,
  252. auditConst: audit.flow,
  253. attList,
  254. whiteList,
  255. auditList,
  256. changeList,
  257. tpUnit: ctx.tender.info.decimal.tp,
  258. upUnit: ctx.tender.info.decimal.up,
  259. };
  260. // 根据auditStatus状态获取的不同的数据
  261. if (auditStatus === 1 || auditStatus === 2) {
  262. // 获取标准清单列表
  263. const dealBillList = await ctx.service.dealBills.getAllDataByCondition({ where: { tender_id: tenderid } });
  264. // 获取清单列表和台账清单列表
  265. const ledger = await ctx.service.ledger.getData(tenderid);
  266. const pos = await ctx.service.pos.getPosData({ tid: tenderid });
  267. renderData.ledger = ledger;
  268. renderData.pos = pos;
  269. renderData.dealBillList = dealBillList;
  270. renderData.changeUnits = changeConst.units;
  271. renderData.precision = ctx.tender.info.precision;
  272. renderData.accountGroup = accountGroup;
  273. // 获取所有项目参与者
  274. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  275. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  276. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
  277. });
  278. renderData.accountList = accountList;
  279. // 重新上报获取审批流程
  280. if (auditStatus === 2) {
  281. const auditList2 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
  282. // 展示页右侧审批流程列表
  283. const auditList3 = [];
  284. for (let time = 1; time <= change.times; time++) {
  285. const auditTimeList = [];
  286. let max_sort = 1;
  287. for (const al of auditList2) {
  288. if (al.times === time) {
  289. auditTimeList.push(al);
  290. if (al.usite > max_sort) {
  291. max_sort = al.usite;
  292. }
  293. }
  294. }
  295. for (const i in auditTimeList) {
  296. auditTimeList[i].max_sort = max_sort;
  297. }
  298. auditList3.push(auditTimeList);
  299. }
  300. renderData.auditList3 = auditList3;
  301. }
  302. // 根据清单获取提交数据和计算总金额
  303. const changeListData = [];
  304. const changeWhiteListData = [];
  305. let ototalCost = 0;
  306. let ctotalCost = 0;
  307. for (const cl of changeList) {
  308. const cLArray = [
  309. cl.code,
  310. cl.name,
  311. cl.bwmx,
  312. cl.unit,
  313. cl.unit_price,
  314. cl.oamount,
  315. cl.camount,
  316. cl.detail,
  317. cl.lid,
  318. ];
  319. ototalCost += ctx.helper.accMul(cl.unit_price, cl.oamount);
  320. ctotalCost += ctx.helper.accMul(cl.unit_price, cl.camount);
  321. if (cl.lid !== 0) {
  322. changeListData.push(cLArray.join(';'));
  323. } else {
  324. changeWhiteListData.push(cLArray.join(';'));
  325. }
  326. }
  327. renderData.changeListData = changeListData.join('^_^');
  328. renderData.changeWhiteListData = changeWhiteListData.join('^_^');
  329. renderData.ototalCost = ototalCost;
  330. renderData.ctotalCost = ctotalCost;
  331. // 获取公司列表
  332. const companyList = await ctx.service.changeCompany.getAllDataByCondition({ where: { tid: tenderid } });
  333. renderData.companyList = companyList;
  334. } else if (auditStatus === 3 || auditStatus === 4 || auditStatus === 5 || auditStatus === 7) {
  335. // 展示页左侧审批流程列表和清单审批列表数据
  336. const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, change.times);
  337. // 展示页右侧审批流程列表
  338. const auditList3 = [];
  339. for (let time = 1; time <= change.times; time++) {
  340. const auditTimeList = [];
  341. let max_sort = 1;
  342. for (const al of auditList) {
  343. if (al.times === time) {
  344. auditTimeList.push(al);
  345. if (al.usite > max_sort) {
  346. max_sort = al.usite;
  347. }
  348. }
  349. }
  350. for (const i in auditTimeList) {
  351. auditTimeList[i].max_sort = max_sort;
  352. }
  353. auditList3.push(auditTimeList);
  354. }
  355. renderData.auditList3 = auditList3;
  356. renderData.changeList = changeList.sort();
  357. let ototalCost = 0;
  358. let ctotalCost = 0;
  359. let stotalCost = 0;
  360. const auditTotalCost = [];
  361. for (const cl of changeList) {
  362. ototalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.oamount), renderData.tpUnit));
  363. ctotalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.camount), renderData.tpUnit));
  364. stotalCost += cl.samount !== '' ? parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.samount), renderData.tpUnit)) : 0;
  365. const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
  366. auditTotalCost.push(audit_amount);
  367. }
  368. renderData.ototalCost = ototalCost;
  369. renderData.ctotalCost = ctotalCost;
  370. renderData.stotalCost = stotalCost;
  371. // 清单表页赋值
  372. for (const [index, au] of auditList2.entries()) {
  373. if (au.usite !== 0) {
  374. au.list_amount = [];
  375. au.totalCost = 0;
  376. for (const [auindex, at] of auditTotalCost.entries()) {
  377. au.list_amount.push(at[index - 1]);
  378. au.totalCost += at[index - 1] !== undefined ? parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, at[index - 1]), renderData.tpUnit)) : 0;
  379. }
  380. }
  381. }
  382. renderData.auditList2 = auditList2;
  383. } else if (auditStatus === 6) {
  384. renderData.changeList = changeList.sort();
  385. let ototalCost = 0;
  386. let ctotalCost = 0;
  387. const auditTotalCost = [];
  388. const auditUnit = [];
  389. for (const cl of changeList) {
  390. ototalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.oamount), renderData.tpUnit));
  391. ctotalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.camount), renderData.tpUnit));
  392. const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
  393. auditTotalCost.push(audit_amount);
  394. }
  395. renderData.ototalCost = ototalCost;
  396. renderData.ctotalCost = ctotalCost;
  397. // 清单表页赋值
  398. for (const [index, au] of auditList.entries()) {
  399. if (au.usite !== 0) {
  400. au.list_amount = [];
  401. au.totalCost = 0;
  402. if (au.uid === renderData.uid) {
  403. for (const [auindex, at] of auditTotalCost.entries()) {
  404. // if (at[index - 2] !== undefined) {
  405. // au.list_amount.push(at[index - 2]);
  406. // au.totalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, at[index - 2]), renderData.tpUnit));
  407. // } else if (at[index - 2] === undefined) {
  408. // au.list_amount.push(changeList[auindex].camount);
  409. // au.totalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, changeList[auindex].camount), renderData.tpUnit));
  410. // }
  411. au.list_amount.push(changeList[auindex].spamount);
  412. au.totalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, changeList[auindex].spamount), renderData.tpUnit));
  413. }
  414. } else {
  415. for (const [auindex, at] of auditTotalCost.entries()) {
  416. au.list_amount.push(at[index - 1]);
  417. au.totalCost += at[index - 1] !== undefined ? parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, at[index - 1]), renderData.tpUnit)) : 0;
  418. }
  419. }
  420. }
  421. }
  422. }
  423. renderData.auditList = auditList;
  424. // 获取是否已存在调用变更令
  425. const stageChangeNum = await ctx.service.stageChange.count({ cid: change.cid });
  426. const stageChangeNum2 = await ctx.service.stageChange.count({ cid: change.cid, qty: null });
  427. renderData.stageChangeNum = stageChangeNum - stageChangeNum2;
  428. await this.layout('change/info.ejs', renderData, 'change/info_modal.ejs');
  429. } catch (err) {
  430. this.log(err);
  431. ctx.redirect('/tender/' + ctx.params.id + '/change');
  432. }
  433. }
  434. /**
  435. * 变更令上报和保存
  436. * @param {Object} ctx - egg全局变量
  437. * @return {void}
  438. */
  439. async save(ctx) {
  440. try {
  441. const result = await ctx.service.change.save(ctx.request.body, ctx.session.sessionUser.tenderId);
  442. if (!result) {
  443. throw '上报失败';
  444. }
  445. if (ctx.request.body.changestatus !== undefined && parseInt(ctx.request.body.changestatus) === 2) {
  446. ctx.body = { err: 0, msg: '保存成功' };
  447. } else {
  448. ctx.redirect('/tender/' + ctx.session.sessionUser.tenderId + '/change');
  449. }
  450. } catch (err) {
  451. this.log(err);
  452. if (ctx.request.body.changestatus !== undefined && parseInt(ctx.request.body.changestatus) === 2) {
  453. ctx.body = { err: 1, msg: err.toString() };
  454. } else {
  455. ctx.redirect('/tender/' + ctx.session.sessionUser.tenderId + '/change/' + ctx.request.body.cid + '/info');
  456. }
  457. }
  458. }
  459. /**
  460. * 变更令审批
  461. * @param {Object} ctx - egg全局变量
  462. * @return {void}
  463. */
  464. async approval(ctx) {
  465. try {
  466. const changeData = await ctx.service.change.getDataByCondition({cid: ctx.request.body.change_id});
  467. if (!changeData) {
  468. throw '变更令数据错误';
  469. }
  470. const status = parseInt(ctx.request.body.status);
  471. let result = false;
  472. switch (status) {
  473. case 3:// 审批通过
  474. result = await ctx.service.change.approvalSuccess(ctx.request.body, changeData);
  475. break;
  476. case 4:// 审批终止
  477. result = await ctx.service.change.approvalStop(ctx.request.body);
  478. break;
  479. case 5:// 审批退回到原报人
  480. result = await ctx.service.change.approvalBack(ctx.request.body, changeData);
  481. break;
  482. case 6:// 审批退回到上一个审批人
  483. result = await ctx.service.change.approvalBackNew(ctx.request.body, changeData);
  484. break;
  485. default:break;
  486. }
  487. if (!result) {
  488. throw '审批失败';
  489. }
  490. ctx.redirect('/tender/' + changeData.tid + '/change');
  491. } catch (err) {
  492. console.log(err);
  493. ctx.redirect(ctx.request.header.referer);
  494. }
  495. }
  496. /**
  497. * 变更公司管理
  498. * @param {Object} ctx - egg全局变量
  499. * @return {void}
  500. */
  501. async updateCompany(ctx) {
  502. const responseData = {
  503. err: 0,
  504. msg: '',
  505. data: '',
  506. };
  507. try {
  508. const data = JSON.parse(ctx.request.body.data);
  509. if (data.tid === undefined || data.uci === undefined || data.uc === undefined || data.ac === undefined) {
  510. throw '参数有误';
  511. }
  512. const [addCompany, selectCompany] = await ctx.service.changeCompany.setCompanyList(data);
  513. responseData.data = { add: addCompany, select: selectCompany };
  514. } catch (err) {
  515. responseData.err = 1;
  516. responseData.msg = err;
  517. }
  518. ctx.body = responseData;
  519. }
  520. /**
  521. * 上传附件
  522. * @param {Object} ctx - egg全局变量
  523. * @return {void}
  524. */
  525. async uploadFile(ctx) {
  526. const responseData = {
  527. err: 0,
  528. msg: '',
  529. data: [],
  530. };
  531. let stream;
  532. try {
  533. const parts = ctx.multipart({ autoFields: true });
  534. const files = [];
  535. let index = 0;
  536. while ((stream = await parts()) !== undefined) {
  537. // 判断用户是否选择上传文件
  538. if (!stream.filename) {
  539. throw '请选择上传的文件!';
  540. }
  541. const create_time = Date.parse(new Date()) / 1000;
  542. const fileInfo = path.parse(stream.filename);
  543. const dirName = 'app/public/upload/changes/' + moment().format('YYYYMMDD');
  544. const fileName = 'changes' + create_time + '_' + index + fileInfo.ext;
  545. // 判断文件夹是否存在,不存在则直接创建文件夹
  546. if (!fs.existsSync(path.join(this.app.baseDir, dirName))) {
  547. await fs.mkdirSync(path.join(this.app.baseDir, dirName));
  548. }
  549. // 保存文件
  550. await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, dirName, fileName));
  551. await sendToWormhole(stream);
  552. // 保存数据到att表
  553. const fileData = {
  554. in_time: create_time,
  555. filename: fileInfo.name,
  556. fileext: fileInfo.ext,
  557. filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
  558. filepath: path.join(dirName, fileName),
  559. };
  560. const result = await ctx.service.changeAtt.save(parts.field, fileData, ctx.session.sessionUser.accountId);
  561. if (!result) {
  562. throw '导入数据库保存失败';
  563. }
  564. fileData.in_time = moment(create_time * 1000).format('YYYY-MM-DD');
  565. fileData.filesize = await ctx.helper.bytesToSize(fileData.filesize);
  566. fileData.id = result.insertId;
  567. delete fileData.filepath;
  568. files.push(fileData);
  569. ++index;
  570. }
  571. responseData.data = files;
  572. } catch (err) {
  573. this.log(err);
  574. // 失败需要消耗掉stream 以防卡死
  575. if (stream) {
  576. await sendToWormhole(stream);
  577. }
  578. this.setMessage(err.toString(), this.messageType.ERROR);
  579. }
  580. ctx.body = responseData;
  581. }
  582. /**
  583. * 下载附件
  584. * @param {Object} ctx - egg全局变量
  585. * @return {void}
  586. */
  587. async downloadFile(ctx) {
  588. const id = ctx.params.id;
  589. if (id) {
  590. try {
  591. const fileInfo = await ctx.service.changeAtt.getDataById(id);
  592. if (fileInfo !== undefined && fileInfo !== '') {
  593. const fileName = path.join(this.app.baseDir, fileInfo.filepath);
  594. // 解决中文无法下载问题
  595. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  596. let disposition = '';
  597. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  598. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename + fileInfo.fileext);
  599. } else if (userAgent.indexOf('firefox') >= 0) {
  600. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename + fileInfo.fileext) + '"';
  601. } else {
  602. /* safari等其他非主流浏览器只能自求多福了 */
  603. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename + fileInfo.fileext).toString('binary');
  604. }
  605. ctx.response.set({
  606. 'Content-Type': 'application/octet-stream',
  607. 'Content-Disposition': disposition,
  608. 'Content-Length': fileInfo.filesize,
  609. });
  610. ctx.body = await fs.createReadStream(fileName);
  611. } else {
  612. throw '不存在该文件';
  613. }
  614. } catch (err) {
  615. this.log(err);
  616. this.setMessage(err.toString(), this.messageType.ERROR);
  617. }
  618. }
  619. }
  620. /**
  621. * 删除附件
  622. * @param {Object} ctx - egg全局变量
  623. * @return {void}
  624. */
  625. async deleteFile(ctx) {
  626. const responseData = {
  627. err: 0,
  628. msg: '',
  629. data: '',
  630. };
  631. try {
  632. const data = JSON.parse(ctx.request.body.data);
  633. const fileInfo = await ctx.service.changeAtt.getDataById(data.id);
  634. if (fileInfo !== undefined && fileInfo !== '') {
  635. // 先删除文件
  636. await fs.unlinkSync(path.join(this.app.baseDir, fileInfo.filepath));
  637. // 再删除数据库
  638. await ctx.service.changeAtt.deleteById(data.id);
  639. responseData.data = '';
  640. } else {
  641. throw '不存在该文件';
  642. }
  643. // if (data.tid === undefined || data.uci === undefined || data.uc === undefined || data.ac === undefined) {
  644. // throw '参数有误';
  645. // }
  646. // const [addCompany, selectCompany] = await ctx.service.changeCompany.setCompanyList(data);
  647. // responseData.data = { add: addCompany, select: selectCompany };
  648. } catch (err) {
  649. responseData.err = 1;
  650. responseData.msg = err;
  651. }
  652. ctx.body = responseData;
  653. }
  654. /**
  655. * 删除变更令
  656. * @param {Object} ctx - egg全局变量
  657. * @return {void}
  658. */
  659. async delete(ctx) {
  660. try {
  661. const result = await ctx.service.change.delete(ctx.request.body.cid);
  662. if (!result) {
  663. throw '删除变更令失败';
  664. }
  665. ctx.redirect(ctx.request.header.referer);
  666. } catch (err) {
  667. console.log(err);
  668. ctx.redirect(ctx.request.header.referer);
  669. }
  670. }
  671. /**
  672. * 变更令重新审批
  673. * @param {Object} ctx - egg全局变量
  674. * @return {void}
  675. */
  676. async checkAgain(ctx) {
  677. try {
  678. const changeData = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.cid });
  679. if (!changeData) {
  680. throw '变更令数据错误';
  681. }
  682. // 获取终审
  683. const auditInfo = (await this.ctx.service.changeAudit.getAllDataByCondition({ where: { cid: changeData.cid }, orders: [['usort', 'desc']], limit: 1, offset: 0 }))[0];
  684. if (changeData.status !== audit.flow.status.checked || ctx.session.sessionUser.accountId !== auditInfo.uid) {
  685. throw '您无权进行该操作';
  686. }
  687. // 重新审批
  688. const result = await ctx.service.change.checkAgain(changeData.cid);
  689. if (!result) {
  690. throw '重新审批失败';
  691. }
  692. ctx.redirect('/tender/' + changeData.tid + '/change/' + changeData.cid + '/info');
  693. } catch (err) {
  694. console.log(err);
  695. ctx.redirect(ctx.request.header.referer);
  696. }
  697. }
  698. }
  699. return ChangeController;
  700. };