change_controller.js 64 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303
  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 shenpiConst = require('../const/shenpi');
  18. // const tenderMenu = require('../../config/menu').tenderMenu;
  19. module.exports = app => {
  20. class ChangeController extends app.BaseController {
  21. /**
  22. * 构造函数
  23. *
  24. * @param {Object} ctx - egg全局变量
  25. * @return {void}
  26. */
  27. constructor(ctx) {
  28. super(ctx);
  29. ctx.showProject = true;
  30. ctx.showTender = true;
  31. ctx.showTitle = true;
  32. }
  33. async _filterChanges(ctx, status = 0) {
  34. const tenderId = ctx.params.id;
  35. ctx.session.sessionUser.tenderId = tenderId;
  36. const tender = await this.service.tender.getDataById(tenderId);
  37. // const tenderList = await this.service.tender.getList();
  38. const page = ctx.page;
  39. const changes = await ctx.service.change.getListByStatus(tender.id, status);
  40. const total = await ctx.service.change.getCountByStatus(tender.id, status);
  41. if (changes !== null) {
  42. let i = 0;
  43. for (const c of changes) {
  44. const status = c.status === audit.flow.status.uncheck ? 0 : 1;
  45. // 根据审批人对当前变更令的状态取不同的展示方式。
  46. let changeAudit = '';
  47. let auditStatus = 0;
  48. switch (c.status) {
  49. case 1:
  50. auditStatus = 1;
  51. break;
  52. case 2:
  53. changeAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times, status);
  54. auditStatus = changeAudit.uid === ctx.session.sessionUser.accountId ? 1 : 0;
  55. break;
  56. case 3:
  57. case 4:
  58. auditStatus = 0;
  59. changeAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times, status);
  60. break;
  61. case 5:
  62. changeAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times - 1, status);
  63. auditStatus = c.uid === ctx.session.sessionUser.accountId ? 1 : 0;
  64. break;
  65. case 6:
  66. changeAudit = await ctx.service.changeAudit.getLastBackUser(c.cid, c.times);
  67. const checkingAudit = await ctx.service.changeAudit.getLastUser(c.cid, c.times, status);
  68. auditStatus = checkingAudit.uid === ctx.session.sessionUser.accountId ? 1 : 0;
  69. break;
  70. default:
  71. break;
  72. }
  73. changes[i].changeAudit = changeAudit;
  74. changes[i].auditStatus = auditStatus;
  75. i++;
  76. }
  77. }
  78. // 分页相关
  79. const pageInfo = {
  80. page,
  81. total: Math.ceil(total / app.config.pageSize),
  82. queryData: JSON.stringify(ctx.urlInfo.query),
  83. };
  84. const filter = JSON.parse(JSON.stringify(audit.filter));
  85. filter.count = [];
  86. 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);
  87. 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);
  88. 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);
  89. 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);
  90. 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);
  91. const codeRule = tender.c_rule ? JSON.parse(tender.c_rule) : [];
  92. for (const rule of codeRule) {
  93. switch (rule.rule_type) {
  94. case codeRuleConst.measure.ruleType.dealCode:
  95. rule.preview = ctx.tender.info.deal_info.dealCode;
  96. break;
  97. case codeRuleConst.measure.ruleType.tenderName:
  98. rule.preview = tender.name;
  99. break;
  100. case codeRuleConst.measure.ruleType.inDate:
  101. rule.preview = moment().format('YYYY');
  102. break;
  103. case codeRuleConst.measure.ruleType.text:
  104. rule.preview = rule.text;
  105. break;
  106. case codeRuleConst.measure.ruleType.addNo:
  107. const s = '0000000000';
  108. rule.preview = s.substr(s.length - rule.format);
  109. break;
  110. default: break;
  111. }
  112. }
  113. const renderData = {
  114. uid: ctx.session.sessionUser.accountId,
  115. moment,
  116. tender,
  117. // tenderList,
  118. pageInfo,
  119. changes,
  120. filter,
  121. status,
  122. codeRule,
  123. dealCode: ctx.tender.info.deal_info.dealCode,
  124. auditConst: audit.flow,
  125. changeConst,
  126. ruleType: codeRuleConst.ruleType.change,
  127. ruleConst: codeRuleConst.measure,
  128. tenderMenu: this.menu.tenderMenu,
  129. preUrl: '/tender/' + tenderId,
  130. tpUnit: ctx.tender.info.decimal.tp,
  131. };
  132. await this.layout('change/index.ejs', renderData, 'change/modal.ejs');
  133. }
  134. /**
  135. * 变更管理 页面 (Get)
  136. *
  137. * @param {Object} ctx - egg全局变量
  138. * @return {void}
  139. */
  140. async index(ctx) {
  141. try {
  142. await this._filterChanges(ctx);
  143. } catch (err) {
  144. this.log(err);
  145. ctx.redirect('/dashboard');
  146. }
  147. }
  148. /**
  149. *
  150. * @param {Object} ctx - egg全局变量
  151. * @return {void}
  152. */
  153. async newCode(ctx) {
  154. const responseData = {
  155. err: 0,
  156. msg: '',
  157. data: '',
  158. };
  159. try {
  160. const tenderId = ctx.params.id;
  161. if (!tenderId) {
  162. throw '当前未打开标段';
  163. }
  164. const tenderData = await ctx.service.tender.getDataById(tenderId);
  165. const cCodeRule = tenderData.c_rule !== null ? JSON.parse(tenderData.c_rule) : [];
  166. const code = [];
  167. for (const rule of cCodeRule) {
  168. switch (rule.rule_type) {
  169. case codeRuleConst.measure.ruleType.dealCode:
  170. code.push(ctx.tender.info.deal_info.dealCode);
  171. break;
  172. case codeRuleConst.measure.ruleType.tenderName:
  173. code.push(tenderData.name);
  174. break;
  175. case codeRuleConst.measure.ruleType.text:
  176. code.push(rule.text);
  177. break;
  178. case codeRuleConst.measure.ruleType.inDate:
  179. code.push(moment().format('YYYY'));
  180. break;
  181. case codeRuleConst.measure.ruleType.addNo:
  182. let s = '0000000000';
  183. const count = rule.start + await ctx.service.change.count({ tid: tenderId });
  184. s = s + count;
  185. code.push(s.substr(s.length - rule.format));
  186. break;
  187. default: break;
  188. }
  189. }
  190. responseData.data = code.join(tenderData.c_connector !== null && tenderData.c_connector !== 3 ? codeRuleConst.measure.connectorString[tenderData.c_connector] : '');
  191. } catch (err) {
  192. responseData.err = 1;
  193. responseData.msg = err;
  194. }
  195. ctx.body = responseData;
  196. }
  197. /**
  198. * 新增变更 (Post)
  199. *
  200. * @param {Object} ctx - egg全局变量
  201. * @return {void}
  202. */
  203. async add(ctx) {
  204. try {
  205. const tenderId = ctx.params.id;
  206. if (!tenderId) {
  207. throw '当前未打开标段';
  208. }
  209. const data = JSON.parse(ctx.request.body.data);
  210. if (!data.code || data.code === '' || !data.name || data.name === '') {
  211. throw '变更令号不能为空';
  212. }
  213. const change = await ctx.service.change.add(tenderId, ctx.session.sessionUser.accountId, data.code, data.name);
  214. ctx.body = { err: 0, msg: '', data: change };
  215. } catch (err) {
  216. this.log(err);
  217. ctx.body = { err: 1, msg: err.toString() };
  218. }
  219. }
  220. /**
  221. * 变更管理 状态筛选 页面 (Get)
  222. * @param {Object} ctx - egg全局变量
  223. * @return {void}
  224. */
  225. async status(ctx) {
  226. try {
  227. const status = parseInt(ctx.params.status);
  228. await this._filterChanges(ctx, status);
  229. } catch (err) {
  230. this.logger.error(err);
  231. ctx.redirect('/tender/' + ctx.params.id + '/change');
  232. }
  233. }
  234. /**
  235. * 变更信息 页面 (Get)
  236. *
  237. * @param {Object} ctx - egg全局变量
  238. * @return {void}
  239. */
  240. async info(ctx) {
  241. try {
  242. const whiteList = this.ctx.app.config.multipart.whitelist;
  243. const tenderid = ctx.params.id !== undefined ? ctx.params.id : ctx.session.sessionUser.tenderId;
  244. ctx.session.sessionUser.tenderId = tenderid;
  245. const tender = await ctx.service.tender.getDataById(tenderid);
  246. const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });
  247. // 后台判断当前人查看info状态
  248. const auditStatus = await ctx.service.changeAudit.getStatusByChange(change);
  249. // 获取附件列表
  250. const attList = await ctx.service.changeAtt.getChangeAttachment(ctx.params.cid);
  251. // 获取其他变更令数据
  252. const othersChange = await ctx.service.change.getOthersChange(ctx.params.id, ctx.params.cid);
  253. // 根据auditStatus获取审批人列表
  254. const auditList = await ctx.service.changeAudit.getListByStatus(change, auditStatus);
  255. // 获取已选清单
  256. let changeList = await ctx.service.changeAuditList.getAllDataByCondition({ where: { cid: ctx.params.cid } });
  257. // 获取用户人验证手机号
  258. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  259. const auth_mobile = pa.auth_mobile;
  260. const renderData = {
  261. uid: ctx.session.sessionUser.accountId,
  262. tender,
  263. change,
  264. othersChange,
  265. changeConst,
  266. auditStatus,
  267. auditConst: audit.flow,
  268. ledgerConsts: audit.ledger.status,
  269. attList,
  270. whiteList,
  271. auditList,
  272. changeList,
  273. tpUnit: ctx.tender.info.decimal.tp,
  274. upUnit: ctx.tender.info.decimal.up,
  275. authMobile: auth_mobile,
  276. shenpiConst,
  277. };
  278. // 根据auditStatus状态获取的不同的数据
  279. if (auditStatus === 1 || auditStatus === 2) {
  280. renderData.changeUnits = changeConst.units;
  281. renderData.precision = ctx.tender.info.precision;
  282. // renderData.accountGroup = accountGroup;
  283. // 获取所有项目参与者
  284. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  285. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  286. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
  287. });
  288. renderData.accountList = accountList;
  289. renderData.accountGroup = accountGroup.map((item, idx) => {
  290. const groupList = accountList.filter(item => item.account_group === idx);
  291. return { groupName: item, groupList };
  292. });
  293. // 重新上报获取审批流程
  294. if (auditStatus === 2) {
  295. const auditList2 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
  296. // 展示页右侧审批流程列表
  297. const auditList3 = [];
  298. for (let time = 1; time <= change.times - 1; time++) {
  299. const auditTimeList = [];
  300. let max_sort = 1;
  301. for (const al of auditList2) {
  302. if (al.times === time) {
  303. auditTimeList.push(al);
  304. if (al.usite > max_sort) {
  305. max_sort = al.usite;
  306. }
  307. }
  308. }
  309. for (const i in auditTimeList) {
  310. auditTimeList[i].max_sort = max_sort;
  311. }
  312. auditList3.push(auditTimeList);
  313. }
  314. renderData.auditList3 = auditList3;
  315. }
  316. // 根据清单获取提交数据和计算总金额
  317. const changeListData = [];
  318. const changeWhiteListData = [];
  319. let ototalCost = 0;
  320. let ctotalCost = 0;
  321. for (const cl of changeList) {
  322. const cLArray = [
  323. cl.code,
  324. cl.name,
  325. cl.bwmx,
  326. cl.unit,
  327. cl.unit_price,
  328. cl.oamount,
  329. cl.camount,
  330. cl.detail,
  331. cl.lid,
  332. cl.xmj_code,
  333. cl.xmj_jldy,
  334. cl.gcl_id,
  335. ];
  336. ototalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.oamount, ctx.tender.info.decimal.tp);
  337. ctotalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.camount, ctx.tender.info.decimal.tp);
  338. if (cl.lid !== '0') {
  339. changeListData.push(cLArray.join('*;*'));
  340. } else {
  341. changeWhiteListData.push(cLArray.join('*;*'));
  342. }
  343. }
  344. renderData.changeListData = changeListData.join('^_^');
  345. renderData.changeWhiteListData = changeWhiteListData.join('^_^');
  346. renderData.ototalCost = ototalCost;
  347. renderData.ctotalCost = ctotalCost;
  348. // 获取公司列表
  349. const companyList = await ctx.service.changeCompany.getAllDataByCondition({ where: { tid: tenderid } });
  350. renderData.companyList = companyList;
  351. } else if (auditStatus === 3 || auditStatus === 4 || auditStatus === 5 || auditStatus === 7) {
  352. // 展示页左侧审批流程列表和清单审批列表数据
  353. const times = change.status === audit.flow.status.back ?
  354. change.times - 1 : change.times;
  355. const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, times);
  356. // 展示页右侧审批流程列表
  357. const auditList3 = [];
  358. for (let time = 1; time <= times; time++) {
  359. const auditTimeList = [];
  360. let max_sort = 1;
  361. for (const al of auditList) {
  362. if (al.times === time) {
  363. auditTimeList.push(al);
  364. if (al.usite > max_sort) {
  365. max_sort = al.usite;
  366. }
  367. }
  368. }
  369. for (const i in auditTimeList) {
  370. auditTimeList[i].max_sort = max_sort;
  371. }
  372. auditList3.push(auditTimeList);
  373. }
  374. renderData.auditList3 = auditList3;
  375. changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
  376. renderData.changeList = changeList;
  377. let ototalCost = 0;
  378. let ctotalCost = 0;
  379. let stotalCost = 0;
  380. const auditTotalCost = [];
  381. for (const cl of changeList) {
  382. // ototalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.oamount), renderData.tpUnit));
  383. ototalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.oamount, renderData.tpUnit);
  384. // ctotalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.camount), renderData.tpUnit));
  385. ctotalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.camount, renderData.tpUnit);
  386. // stotalCost += cl.samount !== '' && cl.unit_price !== null ? parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.samount), renderData.tpUnit)) : 0;
  387. stotalCost += cl.samount !== '' && cl.unit_price !== null ? ctx.helper.mul(cl.unit_price, cl.samount, renderData.tpUnit) : 0;
  388. const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
  389. auditTotalCost.push(audit_amount);
  390. }
  391. renderData.ototalCost = ototalCost;
  392. renderData.ctotalCost = ctotalCost;
  393. renderData.stotalCost = stotalCost;
  394. // 清单表页赋值
  395. for (const [index, au] of auditList2.entries()) {
  396. if (au.usite !== 0) {
  397. au.list_amount = [];
  398. au.totalCost = 0;
  399. for (const [auindex, at] of auditTotalCost.entries()) {
  400. au.list_amount.push(at[index - 1]);
  401. // 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;
  402. au.totalCost += at[index - 1] !== undefined && changeList[auindex].unit_price !== null ? ctx.helper.mul(changeList[auindex].unit_price, at[index - 1], renderData.tpUnit) : 0;
  403. }
  404. }
  405. }
  406. renderData.auditList2 = auditList2;
  407. } else if (auditStatus === 6) {
  408. // 展示页左侧审批流程列表和清单审批列表数据
  409. const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, change.times);
  410. renderData.auditList2 = auditList2;
  411. const auditList3 = await ctx.service.changeAudit.getListOrderByTimes(change.cid, change.times);
  412. for (const i in auditList3) {
  413. auditList3[i].max_sort = auditList2.length - 1;
  414. }
  415. renderData.auditList3 = auditList3;
  416. // 展示页右侧审批流程列表
  417. const auditList5 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
  418. const auditList4 = [];
  419. for (let time = 1; time <= change.times; time++) {
  420. const auditTimeList = [];
  421. let max_sort = 1;
  422. for (const al of auditList5) {
  423. if (al.times === time) {
  424. auditTimeList.push(al);
  425. if (al.usite > max_sort) {
  426. max_sort = al.usite;
  427. }
  428. }
  429. }
  430. for (const i in auditTimeList) {
  431. auditTimeList[i].max_sort = max_sort;
  432. }
  433. if (auditTimeList.length > 0) {
  434. auditList4.push(auditTimeList);
  435. }
  436. }
  437. renderData.auditList4 = auditList4;
  438. changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
  439. renderData.changeList = changeList;
  440. let ototalCost = 0;
  441. let ctotalCost = 0;
  442. const auditTotalCost = [];
  443. const auditUnit = [];
  444. for (const cl of changeList) {
  445. // ototalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.oamount), renderData.tpUnit));
  446. ototalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.oamount, renderData.tpUnit);
  447. // ctotalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.camount), renderData.tpUnit));
  448. ctotalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.camount, renderData.tpUnit);
  449. const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
  450. auditTotalCost.push(audit_amount);
  451. }
  452. renderData.ototalCost = ototalCost;
  453. renderData.ctotalCost = ctotalCost;
  454. // 清单表页赋值
  455. for (const [index, au] of auditList.entries()) {
  456. if (au.usite !== 0) {
  457. au.list_amount = [];
  458. au.totalCost = 0;
  459. if (au.uid === renderData.uid) {
  460. for (const [auindex, at] of auditTotalCost.entries()) {
  461. // if (at[index - 2] !== undefined) {
  462. // au.list_amount.push(at[index - 2]);
  463. // au.totalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, at[index - 2]), renderData.tpUnit));
  464. // } else if (at[index - 2] === undefined) {
  465. // au.list_amount.push(changeList[auindex].camount);
  466. // au.totalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, changeList[auindex].camount), renderData.tpUnit));
  467. // }
  468. au.list_amount.push(changeList[auindex].spamount);
  469. // au.totalCost += changeList[auindex].unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, changeList[auindex].spamount), renderData.tpUnit));
  470. au.totalCost += changeList[auindex].unit_price === null ? 0 : ctx.helper.mul(changeList[auindex].unit_price, changeList[auindex].spamount, renderData.tpUnit);
  471. }
  472. } else {
  473. for (const [auindex, at] of auditTotalCost.entries()) {
  474. au.list_amount.push(at[index - 1]);
  475. // 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;
  476. au.totalCost += at[index - 1] !== undefined && changeList[auindex].unit_price !== null ? ctx.helper.mul(changeList[auindex].unit_price, at[index - 1], renderData.tpUnit) : 0;
  477. }
  478. }
  479. }
  480. }
  481. }
  482. renderData.auditList = auditList;
  483. // 获取是否已存在调用变更令
  484. const changeUsedData = await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, change.cid);
  485. renderData.stageChangeNum = this.ctx.helper.sum(changeUsedData.map(x => { return Math.abs(x.used_qty); }));
  486. await this.layout('change/info.ejs', renderData, 'change/info_modal.ejs');
  487. } catch (err) {
  488. this.log(err);
  489. ctx.redirect('/tender/' + ctx.params.id + '/change');
  490. }
  491. }
  492. /**
  493. * 变更信息 新版本页面 (Get)
  494. *
  495. * @param {Object} ctx - egg全局变量
  496. * @return {void}
  497. */
  498. async information(ctx) {
  499. try {
  500. const whiteList = this.ctx.app.config.multipart.whitelist;
  501. const tender = await ctx.service.tender.getDataById(ctx.tender.id);
  502. const change = ctx.change;
  503. // 后台判断当前人查看info状态
  504. const auditStatus = await ctx.service.changeAudit.getStatusByChange(change);
  505. // 获取附件列表
  506. const attList = await ctx.service.changeAtt.getChangeAttachment(change.cid);
  507. // 获取其他变更令数据
  508. const othersChange = await ctx.service.change.getOthersChange(ctx.tender.id, change.cid);
  509. // 根据auditStatus获取审批人列表
  510. const auditList = await ctx.service.changeAudit.getListByStatus(change, auditStatus);
  511. // 获取已选清单
  512. let changeList = await ctx.service.changeAuditList.getAllDataByCondition({
  513. where: { cid: change.cid },
  514. orders: [['lid', 'desc'], ['id', 'asc']],
  515. });
  516. // 获取用户人验证手机号
  517. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  518. const auth_mobile = pa.auth_mobile;
  519. const renderData = {
  520. tender,
  521. change,
  522. othersChange,
  523. changeConst,
  524. auditStatus,
  525. auditConst: audit.flow,
  526. ledgerConsts: audit.ledger.status,
  527. attList,
  528. whiteList,
  529. auditList,
  530. changeList,
  531. tpUnit: ctx.tender.info.decimal.tp,
  532. upUnit: ctx.tender.info.decimal.up,
  533. authMobile: auth_mobile,
  534. shenpiConst,
  535. jsFiles: this.app.jsFiles.common.concat(this.app.jsFiles.change.information),
  536. };
  537. // 根据auditStatus状态获取的不同的数据
  538. if (auditStatus === 1 || auditStatus === 2) {
  539. renderData.changeUnits = changeConst.units;
  540. renderData.precision = ctx.tender.info.precision;
  541. // renderData.accountGroup = accountGroup;
  542. // 获取所有项目参与者
  543. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  544. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  545. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
  546. });
  547. renderData.accountList = accountList;
  548. renderData.accountGroup = accountGroup.map((item, idx) => {
  549. const groupList = accountList.filter(item => item.account_group === idx);
  550. return { groupName: item, groupList };
  551. });
  552. // 重新上报获取审批流程
  553. if (auditStatus === 2) {
  554. const auditList2 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
  555. // 展示页右侧审批流程列表
  556. const auditList3 = [];
  557. for (let time = 1; time <= change.times - 1; time++) {
  558. const auditTimeList = [];
  559. let max_sort = 1;
  560. for (const al of auditList2) {
  561. if (al.times === time) {
  562. auditTimeList.push(al);
  563. if (al.usite > max_sort) {
  564. max_sort = al.usite;
  565. }
  566. }
  567. }
  568. for (const i in auditTimeList) {
  569. auditTimeList[i].max_sort = max_sort;
  570. }
  571. auditList3.push(auditTimeList);
  572. }
  573. renderData.auditList3 = auditList3;
  574. }
  575. // 根据清单获取提交数据和计算总金额
  576. let ototalCost = 0;
  577. let ctotalCost = 0;
  578. for (const cl of changeList) {
  579. ototalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.oamount, ctx.tender.info.decimal.tp);
  580. ctotalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.camount, ctx.tender.info.decimal.tp);
  581. }
  582. renderData.ototalCost = ototalCost;
  583. renderData.ctotalCost = ctotalCost;
  584. // 获取公司列表
  585. const companyList = await ctx.service.changeCompany.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  586. renderData.companyList = companyList;
  587. } else if (auditStatus === 3 || auditStatus === 4 || auditStatus === 5 || auditStatus === 7) {
  588. // 展示页左侧审批流程列表和清单审批列表数据
  589. const times = change.status === audit.flow.status.back ?
  590. change.times - 1 : change.times;
  591. const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, times);
  592. // 展示页右侧审批流程列表
  593. const auditList3 = [];
  594. for (let time = 1; time <= times; time++) {
  595. const auditTimeList = [];
  596. let max_sort = 1;
  597. for (const al of auditList) {
  598. if (al.times === time) {
  599. auditTimeList.push(al);
  600. if (al.usite > max_sort) {
  601. max_sort = al.usite;
  602. }
  603. }
  604. }
  605. for (const i in auditTimeList) {
  606. auditTimeList[i].max_sort = max_sort;
  607. }
  608. auditList3.push(auditTimeList);
  609. }
  610. renderData.auditList3 = auditList3;
  611. changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
  612. renderData.changeList = changeList;
  613. let ototalCost = 0;
  614. let ctotalCost = 0;
  615. let stotalCost = 0;
  616. const auditTotalCost = [];
  617. for (const cl of changeList) {
  618. // ototalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.oamount), renderData.tpUnit));
  619. ototalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.oamount, renderData.tpUnit);
  620. // ctotalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.camount), renderData.tpUnit));
  621. ctotalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.camount, renderData.tpUnit);
  622. // stotalCost += cl.samount !== '' && cl.unit_price !== null ? parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.samount), renderData.tpUnit)) : 0;
  623. stotalCost += cl.samount !== '' && cl.unit_price !== null ? ctx.helper.mul(cl.unit_price, cl.samount, renderData.tpUnit) : 0;
  624. const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
  625. auditTotalCost.push(audit_amount);
  626. }
  627. renderData.ototalCost = ototalCost;
  628. renderData.ctotalCost = ctotalCost;
  629. renderData.stotalCost = stotalCost;
  630. // 清单表页赋值
  631. for (const [index, au] of auditList2.entries()) {
  632. if (au.usite !== 0) {
  633. au.list_amount = [];
  634. au.totalCost = 0;
  635. for (const [auindex, at] of auditTotalCost.entries()) {
  636. au.list_amount.push(at[index - 1]);
  637. // 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;
  638. au.totalCost += at[index - 1] !== undefined && changeList[auindex].unit_price !== null ? ctx.helper.mul(changeList[auindex].unit_price, at[index - 1], renderData.tpUnit) : 0;
  639. }
  640. }
  641. }
  642. renderData.auditList2 = auditList2;
  643. } else if (auditStatus === 6) {
  644. // 展示页左侧审批流程列表和清单审批列表数据
  645. const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, change.times);
  646. renderData.auditList2 = auditList2;
  647. const auditList3 = await ctx.service.changeAudit.getListOrderByTimes(change.cid, change.times);
  648. for (const i in auditList3) {
  649. auditList3[i].max_sort = auditList2.length - 1;
  650. }
  651. renderData.auditList3 = auditList3;
  652. // 展示页右侧审批流程列表
  653. const auditList5 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
  654. const auditList4 = [];
  655. for (let time = 1; time <= change.times; time++) {
  656. const auditTimeList = [];
  657. let max_sort = 1;
  658. for (const al of auditList5) {
  659. if (al.times === time) {
  660. auditTimeList.push(al);
  661. if (al.usite > max_sort) {
  662. max_sort = al.usite;
  663. }
  664. }
  665. }
  666. for (const i in auditTimeList) {
  667. auditTimeList[i].max_sort = max_sort;
  668. }
  669. if (auditTimeList.length > 0) {
  670. auditList4.push(auditTimeList);
  671. }
  672. }
  673. renderData.auditList4 = auditList4;
  674. changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
  675. renderData.changeList = changeList;
  676. let ototalCost = 0;
  677. let ctotalCost = 0;
  678. const auditTotalCost = [];
  679. const auditUnit = [];
  680. for (const cl of changeList) {
  681. // ototalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.oamount), renderData.tpUnit));
  682. ototalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.oamount, renderData.tpUnit);
  683. // ctotalCost += cl.unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(cl.unit_price, cl.camount), renderData.tpUnit));
  684. ctotalCost += cl.unit_price === null ? 0 : ctx.helper.mul(cl.unit_price, cl.camount, renderData.tpUnit);
  685. const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
  686. auditTotalCost.push(audit_amount);
  687. }
  688. renderData.ototalCost = ototalCost;
  689. renderData.ctotalCost = ctotalCost;
  690. // 清单表页赋值
  691. for (const [index, au] of auditList.entries()) {
  692. if (au.usite !== 0) {
  693. au.list_amount = [];
  694. au.totalCost = 0;
  695. if (au.uid === renderData.uid) {
  696. for (const [auindex, at] of auditTotalCost.entries()) {
  697. // if (at[index - 2] !== undefined) {
  698. // au.list_amount.push(at[index - 2]);
  699. // au.totalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, at[index - 2]), renderData.tpUnit));
  700. // } else if (at[index - 2] === undefined) {
  701. // au.list_amount.push(changeList[auindex].camount);
  702. // au.totalCost += parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, changeList[auindex].camount), renderData.tpUnit));
  703. // }
  704. au.list_amount.push(changeList[auindex].spamount);
  705. // au.totalCost += changeList[auindex].unit_price === null ? 0 : parseFloat(ctx.helper.roundNum(ctx.helper.accMul(changeList[auindex].unit_price, changeList[auindex].spamount), renderData.tpUnit));
  706. au.totalCost += changeList[auindex].unit_price === null ? 0 : ctx.helper.mul(changeList[auindex].unit_price, changeList[auindex].spamount, renderData.tpUnit);
  707. }
  708. } else {
  709. for (const [auindex, at] of auditTotalCost.entries()) {
  710. au.list_amount.push(at[index - 1]);
  711. // 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;
  712. au.totalCost += at[index - 1] !== undefined && changeList[auindex].unit_price !== null ? ctx.helper.mul(changeList[auindex].unit_price, at[index - 1], renderData.tpUnit) : 0;
  713. }
  714. }
  715. }
  716. }
  717. }
  718. renderData.auditList = auditList;
  719. // 获取是否已存在调用变更令
  720. const changeUsedData = await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, change.cid);
  721. renderData.stageChangeNum = this.ctx.helper.sum(changeUsedData.map(x => { return Math.abs(x.used_qty); }));
  722. await this.layout('change/information.ejs', renderData, 'change/information_modal.ejs');
  723. } catch (err) {
  724. this.log(err);
  725. ctx.redirect('/tender/' + ctx.params.id + '/change');
  726. }
  727. }
  728. /**
  729. * 变更清单 - 操作 (Ajax)
  730. * @param ctx
  731. * @return {Promise<void>}
  732. */
  733. async saveListsData(ctx) {
  734. try {
  735. const data = JSON.parse(ctx.request.body.data);
  736. const responseData = {
  737. err: 0,
  738. msg: '',
  739. data: {},
  740. };
  741. switch (data.type) {
  742. case 'add':
  743. responseData.data = await ctx.service.changeAuditList.add(data.postData);
  744. break;
  745. case 'del':
  746. await ctx.service.changeAuditList.del(data.id);
  747. break;
  748. case 'update':
  749. await ctx.service.changeAuditList.save(data.updateData);
  750. break;
  751. case 'paste':
  752. await ctx.service.changeAuditList.saveDatas(data.updateData);
  753. // 取所有工料表
  754. responseData.data = await ctx.service.changeAuditList.getAllDataByCondition({
  755. where: { cid: ctx.change.cid },
  756. orders: [['lid', 'desc'], ['id', 'asc']],
  757. });
  758. break;
  759. case 'ledger_list':
  760. await ctx.service.changeAuditList.saveLedgerListDatas(data.updateData);
  761. // 取所有工料表
  762. responseData.data = await ctx.service.changeAuditList.getAllDataByCondition({
  763. where: { cid: ctx.change.cid },
  764. orders: [['lid', 'desc'], ['id', 'asc']],
  765. });
  766. break;
  767. default: throw '参数有误';
  768. }
  769. ctx.body = responseData;
  770. } catch (err) {
  771. this.log(err);
  772. ctx.body = { err: 1, msg: err.toString(), data: null };
  773. }
  774. }
  775. async defaultBills(ctx) {
  776. try {
  777. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  778. const posData = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  779. const dealBills = await ctx.service.dealBills.getAllDataByCondition({ where: { tender_id: ctx.tender.id } });
  780. ctx.body = { err: 0, msg: '', data: { bills: ledgerData, pos: posData, dealBills } };
  781. } catch (err) {
  782. this.log(err);
  783. ctx.body = { err: 1, msg: err.toString(), data: [] };
  784. }
  785. }
  786. /**
  787. * 变更令上报和保存
  788. * @param {Object} ctx - egg全局变量
  789. * @return {void}
  790. */
  791. async save(ctx) {
  792. // 变更令信息
  793. const changeInfo = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.cid });
  794. try {
  795. const result = await ctx.service.change.save(ctx.request.body, changeInfo.tid);
  796. if (!result) {
  797. throw '上报失败';
  798. }
  799. if (ctx.request.body.changestatus !== undefined && parseInt(ctx.request.body.changestatus) === 2) {
  800. ctx.body = { err: 0, msg: '保存成功' };
  801. } else {
  802. ctx.redirect('/tender/' + changeInfo.tid + '/change');
  803. }
  804. } catch (err) {
  805. this.log(err);
  806. if (ctx.request.body.changestatus !== undefined && parseInt(ctx.request.body.changestatus) === 2) {
  807. ctx.body = { err: 1, msg: err.toString() };
  808. } else {
  809. ctx.redirect('/tender/' + changeInfo.tid + '/change/' + ctx.request.body.cid + '/info');
  810. }
  811. }
  812. }
  813. /**
  814. * 变更令审批
  815. * @param {Object} ctx - egg全局变量
  816. * @return {void}
  817. */
  818. async approval(ctx) {
  819. try {
  820. const changeData = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.change_id });
  821. if (!changeData) {
  822. throw '变更令数据错误';
  823. }
  824. const status = parseInt(ctx.request.body.status);
  825. let result = false;
  826. const pid = this.ctx.session.sessionProject.id;
  827. switch (status) {
  828. case 3:// 审批通过
  829. result = await ctx.service.change.approvalSuccess(pid, ctx.request.body, changeData);
  830. break;
  831. case 4:// 审批终止
  832. result = await ctx.service.change.approvalStop(ctx.request.body);
  833. break;
  834. case 5:// 审批退回到原报人
  835. result = await ctx.service.change.approvalBack(pid, ctx.request.body, changeData);
  836. break;
  837. case 6:// 审批退回到上一个审批人
  838. result = await ctx.service.change.approvalBackNew(pid, ctx.request.body, changeData);
  839. break;
  840. default:break;
  841. }
  842. if (!result) {
  843. throw '审批失败';
  844. }
  845. ctx.redirect(ctx.request.header.referer);
  846. } catch (err) {
  847. console.log(err);
  848. ctx.redirect(ctx.request.header.referer);
  849. }
  850. }
  851. /**
  852. * 变更公司管理
  853. * @param {Object} ctx - egg全局变量
  854. * @return {void}
  855. */
  856. async updateCompany(ctx) {
  857. const responseData = {
  858. err: 0,
  859. msg: '',
  860. data: '',
  861. };
  862. try {
  863. const data = JSON.parse(ctx.request.body.data);
  864. if (data.tid === undefined || data.uci === undefined || data.uc === undefined || data.ac === undefined) {
  865. throw '参数有误';
  866. }
  867. const [addCompany, selectCompany] = await ctx.service.changeCompany.setCompanyList(data);
  868. responseData.data = { add: addCompany, select: selectCompany };
  869. } catch (err) {
  870. responseData.err = 1;
  871. responseData.msg = err;
  872. }
  873. ctx.body = responseData;
  874. }
  875. /**
  876. * 上传附件
  877. * @param {Object} ctx - egg全局变量
  878. * @return {void}
  879. */
  880. async uploadFile(ctx) {
  881. const responseData = {
  882. err: 0,
  883. msg: '',
  884. data: [],
  885. };
  886. let stream;
  887. try {
  888. const parts = ctx.multipart({ autoFields: true });
  889. const files = [];
  890. let index = 0;
  891. const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });
  892. const extra_upload = change.status === audit.flow.status.checked;
  893. while ((stream = await parts()) !== undefined) {
  894. // 判断用户是否选择上传文件
  895. if (!stream.filename) {
  896. throw '请选择上传的文件!';
  897. }
  898. // const create_time = Date.parse(new Date()) / 1000;
  899. // const fileInfo = path.parse(stream.filename);
  900. // const dirName = 'app/public/upload/changes/' + moment().format('YYYYMMDD');
  901. // const fileName = 'changes' + create_time + '_' + index + fileInfo.ext;
  902. // // 判断文件夹是否存在,不存在则直接创建文件夹
  903. // if (!fs.existsSync(path.join(this.app.baseDir, dirName))) {
  904. // await fs.mkdirSync(path.join(this.app.baseDir, dirName));
  905. // }
  906. // // 保存文件
  907. // await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, dirName, fileName));
  908. const fileInfo = path.parse(stream.filename);
  909. const create_time = Date.parse(new Date()) / 1000;
  910. const filepath = `app/public/upload/change/fujian_${create_time + index.toString() + fileInfo.ext}`;
  911. await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, filepath));
  912. await sendToWormhole(stream);
  913. // 保存数据到att表
  914. const fileData = {
  915. in_time: create_time,
  916. filename: fileInfo.name,
  917. fileext: fileInfo.ext,
  918. filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
  919. filepath,
  920. extra_upload,
  921. };
  922. const result = await ctx.service.changeAtt.save(parts.field, fileData, ctx.session.sessionUser.accountId);
  923. if (!result) {
  924. throw '导入数据库保存失败';
  925. }
  926. fileData.in_time = moment(create_time * 1000).format('YYYY-MM-DD');
  927. fileData.filesize = await ctx.helper.bytesToSize(fileData.filesize);
  928. fileData.id = result.insertId;
  929. delete fileData.filepath;
  930. files.push(fileData);
  931. ++index;
  932. }
  933. responseData.data = files;
  934. } catch (err) {
  935. this.log(err);
  936. // 失败需要消耗掉stream 以防卡死
  937. if (stream) {
  938. await sendToWormhole(stream);
  939. }
  940. this.setMessage(err.toString(), this.messageType.ERROR);
  941. }
  942. ctx.body = responseData;
  943. }
  944. /**
  945. * 下载附件
  946. * @param {Object} ctx - egg全局变量
  947. * @return {void}
  948. */
  949. async downloadFile(ctx) {
  950. const id = ctx.params.id;
  951. if (id) {
  952. try {
  953. const fileInfo = await ctx.service.changeAtt.getDataById(id);
  954. if (fileInfo !== undefined && fileInfo !== '') {
  955. const fileName = path.join(this.app.baseDir, fileInfo.filepath);
  956. // 解决中文无法下载问题
  957. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  958. let disposition = '';
  959. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  960. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename + fileInfo.fileext);
  961. } else if (userAgent.indexOf('firefox') >= 0) {
  962. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename + fileInfo.fileext) + '"';
  963. } else {
  964. /* safari等其他非主流浏览器只能自求多福了 */
  965. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename + fileInfo.fileext).toString('binary');
  966. }
  967. ctx.response.set({
  968. 'Content-Type': 'application/octet-stream',
  969. 'Content-Disposition': disposition,
  970. 'Content-Length': fileInfo.filesize,
  971. });
  972. ctx.body = await fs.createReadStream(fileName);
  973. } else {
  974. throw '不存在该文件';
  975. }
  976. } catch (err) {
  977. this.log(err);
  978. this.setMessage(err.toString(), this.messageType.ERROR);
  979. }
  980. }
  981. }
  982. /**
  983. * 批量下载 - 压缩成zip文件返回
  984. * @param {Oject} ctx - 全局上下文
  985. */
  986. async downloadZip(ctx) {
  987. try {
  988. const fileIds = JSON.parse(ctx.request.query.fileIds);
  989. // const { fileIds } = JSON.parse(ctx.request.body.data);
  990. // console.log('fileIds', fileIds);
  991. const { name: changeName } = await ctx.service.changeAtt.getChangeName(ctx.params.cid);
  992. const zipFilename = `${ctx.tender.data.name}-工程变更-${changeName}-附件.zip`;
  993. const time = Date.now();
  994. const zipPath = `app/public/upload/change/fu_jian_zip${time}.zip`;
  995. const size = await ctx.service.changeAtt.compressedFile(fileIds, zipPath);
  996. // 解决中文无法下载问题
  997. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  998. let disposition = '';
  999. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  1000. disposition = 'attachment; filename=' + encodeURIComponent(zipFilename);
  1001. } else if (userAgent.indexOf('firefox') >= 0) {
  1002. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(zipFilename) + '"';
  1003. } else {
  1004. /* safari等其他非主流浏览器只能自求多福了 */
  1005. disposition = 'attachment; filename=' + new Buffer(zipFilename).toString('binary');
  1006. }
  1007. ctx.response.set({
  1008. 'Content-Type': 'application/octet-stream',
  1009. 'Content-Disposition': disposition,
  1010. 'Content-Length': size,
  1011. });
  1012. const readStream = fs.createReadStream(path.join(this.app.baseDir, zipPath));
  1013. ctx.body = readStream;
  1014. // ctx.body = fs.readFileSync(path.resolve(this.app.baseDir, zipPath));
  1015. readStream.on('close', () => {
  1016. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1017. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1018. }
  1019. });
  1020. } catch (error) {
  1021. this.log(error);
  1022. }
  1023. }
  1024. /**
  1025. * 删除附件
  1026. * @param {Object} ctx - egg全局变量
  1027. * @return {void}
  1028. */
  1029. async deleteFile(ctx) {
  1030. const responseData = {
  1031. err: 0,
  1032. msg: '',
  1033. data: '',
  1034. };
  1035. try {
  1036. const data = JSON.parse(ctx.request.body.data);
  1037. const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });
  1038. const fileInfo = await ctx.service.changeAtt.getDataById(data.id);
  1039. if (!fileInfo || !Object.keys(fileInfo).length) {
  1040. throw '该文件不存在';
  1041. }
  1042. if (!fileInfo.extra_upload && change.status === audit.flow.status.checked) {
  1043. throw '无权限删除';
  1044. }
  1045. if (fileInfo !== undefined && fileInfo !== '') {
  1046. // 先删除文件
  1047. await fs.unlinkSync(path.join(this.app.baseDir, fileInfo.filepath));
  1048. // 再删除数据库
  1049. await ctx.service.changeAtt.deleteById(data.id);
  1050. responseData.data = '';
  1051. } else {
  1052. throw '不存在该文件';
  1053. }
  1054. // if (data.tid === undefined || data.uci === undefined || data.uc === undefined || data.ac === undefined) {
  1055. // throw '参数有误';
  1056. // }
  1057. // const [addCompany, selectCompany] = await ctx.service.changeCompany.setCompanyList(data);
  1058. // responseData.data = { add: addCompany, select: selectCompany };
  1059. } catch (err) {
  1060. responseData.err = 1;
  1061. responseData.msg = err;
  1062. }
  1063. ctx.body = responseData;
  1064. }
  1065. /**
  1066. * 查看附件
  1067. * @param {Object} ctx - egg全局变量
  1068. * @return {void}
  1069. */
  1070. async checkFile(ctx) {
  1071. const responseData = { err: 0, msg: '' };
  1072. const id = parseInt(ctx.params.id);
  1073. if (id) {
  1074. try {
  1075. const fileInfo = await ctx.service.changeAtt.getDataById(id);
  1076. if (fileInfo && Object.keys(fileInfo).length) {
  1077. let filepath = fileInfo.filepath;
  1078. if (!ctx.helper.canPreview(fileInfo.fileext)) {
  1079. filepath = `/change/download/file/${fileInfo.id}`;
  1080. } else {
  1081. filepath = filepath.replace(/^app|\/app/, '');
  1082. }
  1083. fileInfo.filepath && (responseData.data = { filepath });
  1084. }
  1085. } catch (error) {
  1086. this.log(error);
  1087. this.setMessage(error.toString(), this.messageType.ERROR);
  1088. responseData.err = 1;
  1089. responseData.msg = error.toString();
  1090. }
  1091. }
  1092. ctx.body = responseData;
  1093. }
  1094. /**
  1095. * 删除变更令
  1096. * @param {Object} ctx - egg全局变量
  1097. * @return {void}
  1098. */
  1099. async delete(ctx) {
  1100. try {
  1101. const result = await ctx.service.change.delete(ctx.request.body.cid);
  1102. if (!result) {
  1103. throw '删除变更令失败';
  1104. }
  1105. ctx.redirect(ctx.request.header.referer);
  1106. } catch (err) {
  1107. console.log(err);
  1108. ctx.redirect(ctx.request.header.referer);
  1109. }
  1110. }
  1111. /**
  1112. * 变更令重新审批
  1113. * @param {Object} ctx - egg全局变量
  1114. * @return {void}
  1115. */
  1116. async checkAgain(ctx) {
  1117. try {
  1118. const changeData = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.cid });
  1119. if (!changeData) {
  1120. throw '变更令数据错误';
  1121. }
  1122. // 获取终审
  1123. const auditInfo = (await this.ctx.service.changeAudit.getAllDataByCondition({ where: { cid: changeData.cid }, orders: [['usort', 'desc']], limit: 1, offset: 0 }))[0];
  1124. if (changeData.status !== audit.flow.status.checked || ctx.session.sessionUser.accountId !== auditInfo.uid) {
  1125. throw '您无权进行该操作';
  1126. }
  1127. if (ctx.session.sessionUser.loginStatus === 0) {
  1128. const code = ctx.request.body.code;
  1129. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  1130. if (!pa.auth_mobile) {
  1131. throw '未绑定手机号';
  1132. }
  1133. const cacheKey = 'smsCode:' + ctx.session.sessionUser.accountId;
  1134. const cacheCode = await app.redis.get(cacheKey);
  1135. // console.log(cacheCode);
  1136. if (cacheCode === null || code === undefined || cacheCode !== (code + pa.auth_mobile)) {
  1137. throw '验证码不正确!';
  1138. }
  1139. }
  1140. // 重新审批
  1141. const result = await ctx.service.change.checkAgain(changeData.cid);
  1142. if (!result) {
  1143. throw '重新审批失败';
  1144. }
  1145. // ctx.redirect('/tender/' + changeData.tid + '/change/' + changeData.cid + '/info');
  1146. ctx.body = {
  1147. err: 0,
  1148. url: ctx.request.header.referer,
  1149. msg: '',
  1150. };
  1151. } catch (err) {
  1152. console.log(err);
  1153. // ctx.redirect(ctx.request.header.referer);
  1154. ctx.body = {
  1155. err: 1,
  1156. // url: ctx.request.header.referer,
  1157. msg: err,
  1158. };
  1159. }
  1160. }
  1161. /**
  1162. * 获取变更清单
  1163. * @param ctx
  1164. * @return {Promise<void>}
  1165. */
  1166. async bills(ctx) {
  1167. try {
  1168. const data = JSON.parse(ctx.request.body.data);
  1169. const responseData = { err: 0, msg: '', data: [] };
  1170. switch (data.type) {
  1171. case 'gather':
  1172. responseData.data = await ctx.service.changeAuditList.gatherBgBills(ctx.tender.id);
  1173. break;
  1174. default:
  1175. throw '查询的数据不存在';
  1176. }
  1177. ctx.body = responseData;
  1178. } catch (err) {
  1179. this.log(err);
  1180. this.ajaxErrorBody(err, '获取变更清单失败');
  1181. }
  1182. }
  1183. /**
  1184. * 最后审批人审批成功检查批复编号和其它变更令是否出现重名情况
  1185. * @param ctx
  1186. * @return {Promise<void>}
  1187. */
  1188. async checkCodeRepeat(ctx) {
  1189. const responseData = {
  1190. err: 0,
  1191. msg: '',
  1192. data: '',
  1193. };
  1194. try {
  1195. const tenderId = ctx.params.id;
  1196. const cid = ctx.params.cid;
  1197. const data = JSON.parse(ctx.request.body.data);
  1198. const result = await ctx.service.change.isRepeat(cid, data.p_code, tenderId);
  1199. if (result) {
  1200. throw '该变更令号(批复编号)已使用';
  1201. }
  1202. } catch (err) {
  1203. responseData.err = 1;
  1204. responseData.msg = err;
  1205. }
  1206. ctx.body = responseData;
  1207. }
  1208. /**
  1209. * 拷贝其他变更令
  1210. * @param {object} ctx - 全局上下文
  1211. */
  1212. async copyChange(ctx) {
  1213. const responseData = {
  1214. err: 0,
  1215. msg: '',
  1216. data: '',
  1217. };
  1218. try {
  1219. const cid = ctx.params.cid;
  1220. const copy_cid = JSON.parse(ctx.request.body.data);
  1221. const result = await ctx.service.change.handleCopyChange(cid, copy_cid);
  1222. if (!result) {
  1223. responseData.err = 1;
  1224. responseData.msg = '拷贝失败!';
  1225. }
  1226. } catch (error) {
  1227. responseData.err = 1;
  1228. responseData.msg = error;
  1229. }
  1230. ctx.body = responseData;
  1231. }
  1232. }
  1233. return ChangeController;
  1234. };