change_controller.js 37 KB

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