change_controller.js 64 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365
  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. preUrl: '/tender/' + ctx.tender.id + '/change/' + ctx.change.cid + '/information',
  537. precision: ctx.tender.info.precision,
  538. };
  539. // 根据auditStatus状态获取的不同的数据
  540. if (auditStatus === 1 || auditStatus === 2) {
  541. renderData.changeUnits = changeConst.units;
  542. // renderData.accountGroup = accountGroup;
  543. // 获取所有项目参与者
  544. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  545. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  546. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
  547. });
  548. renderData.accountList = accountList;
  549. renderData.accountGroup = accountGroup.map((item, idx) => {
  550. const groupList = accountList.filter(item => item.account_group === idx);
  551. return { groupName: item, groupList };
  552. });
  553. // 重新上报获取审批流程
  554. if (auditStatus === 2) {
  555. const auditList2 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
  556. // 展示页右侧审批流程列表
  557. const auditList3 = [];
  558. for (let time = 1; time <= change.times - 1; time++) {
  559. const auditTimeList = [];
  560. let max_sort = 1;
  561. for (const al of auditList2) {
  562. if (al.times === time) {
  563. auditTimeList.push(al);
  564. if (al.usite > max_sort) {
  565. max_sort = al.usite;
  566. }
  567. }
  568. }
  569. for (const i in auditTimeList) {
  570. auditTimeList[i].max_sort = max_sort;
  571. }
  572. auditList3.push(auditTimeList);
  573. }
  574. renderData.auditList3 = auditList3;
  575. }
  576. // 获取公司列表
  577. const companyList = await ctx.service.changeCompany.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  578. renderData.companyList = companyList;
  579. } else if (auditStatus === 3 || auditStatus === 4 || auditStatus === 5 || auditStatus === 7) {
  580. // 展示页左侧审批流程列表和清单审批列表数据
  581. const times = change.status === audit.flow.status.back ?
  582. change.times - 1 : change.times;
  583. const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, times);
  584. // 展示页右侧审批流程列表
  585. const auditList3 = [];
  586. for (let time = 1; time <= times; time++) {
  587. const auditTimeList = [];
  588. let max_sort = 1;
  589. for (const al of auditList) {
  590. if (al.times === time) {
  591. auditTimeList.push(al);
  592. if (al.usite > max_sort) {
  593. max_sort = al.usite;
  594. }
  595. }
  596. }
  597. for (const i in auditTimeList) {
  598. auditTimeList[i].max_sort = max_sort;
  599. }
  600. auditList3.push(auditTimeList);
  601. }
  602. renderData.auditList3 = auditList3;
  603. changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
  604. for (const cl of changeList) {
  605. const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
  606. // 清单表页赋值
  607. for (const [index, au] of auditList2.entries()) {
  608. if (au.usite !== 0) {
  609. cl['audit_amount_' + au.uid] = audit_amount[index - 1] ? audit_amount[index - 1] : null;
  610. }
  611. }
  612. }
  613. renderData.changeList = changeList;
  614. renderData.auditList2 = auditList2;
  615. } else if (auditStatus === 6) {
  616. // 展示页左侧审批流程列表和清单审批列表数据
  617. const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(change.cid, change.times);
  618. renderData.auditList2 = auditList2;
  619. const auditList3 = await ctx.service.changeAudit.getListOrderByTimes(change.cid, change.times);
  620. for (const i in auditList3) {
  621. auditList3[i].max_sort = auditList2.length - 1;
  622. }
  623. renderData.auditList3 = auditList3;
  624. // 展示页右侧审批流程列表
  625. const auditList5 = await ctx.service.changeAudit.getListByBack(change.cid, change.times);
  626. const auditList4 = [];
  627. for (let time = 1; time <= change.times; time++) {
  628. const auditTimeList = [];
  629. let max_sort = 1;
  630. for (const al of auditList5) {
  631. if (al.times === time) {
  632. auditTimeList.push(al);
  633. if (al.usite > max_sort) {
  634. max_sort = al.usite;
  635. }
  636. }
  637. }
  638. for (const i in auditTimeList) {
  639. auditTimeList[i].max_sort = max_sort;
  640. }
  641. if (auditTimeList.length > 0) {
  642. auditList4.push(auditTimeList);
  643. }
  644. }
  645. renderData.auditList4 = auditList4;
  646. changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
  647. for (const cl of changeList) {
  648. const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
  649. // 清单表页赋值
  650. for (const [index, au] of auditList2.entries()) {
  651. if (au.usite !== 0) {
  652. cl['audit_amount_' + au.uid] = au.uid === ctx.session.sessionUser.accountId ? cl.spamount : (audit_amount[index - 1] ? audit_amount[index - 1] : null);
  653. }
  654. }
  655. }
  656. renderData.changeList = changeList;
  657. }
  658. renderData.auditList = auditList;
  659. // 获取是否已存在调用变更令
  660. const changeUsedData = await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, change.cid);
  661. renderData.stageChangeNum = this.ctx.helper.sum(changeUsedData.map(x => { return Math.abs(x.used_qty); }));
  662. await this.layout('change/information.ejs', renderData, 'change/information_modal.ejs');
  663. } catch (err) {
  664. this.log(err);
  665. ctx.redirect('/tender/' + ctx.params.id + '/change');
  666. }
  667. }
  668. /**
  669. * 变更清单 - 操作 (Ajax)
  670. * @param ctx
  671. * @return {Promise<void>}
  672. */
  673. async saveListsData(ctx) {
  674. try {
  675. const data = JSON.parse(ctx.request.body.data);
  676. const responseData = {
  677. err: 0,
  678. msg: '',
  679. data: {},
  680. };
  681. switch (data.type) {
  682. case 'add':
  683. responseData.data = await ctx.service.changeAuditList.add(data.postData);
  684. break;
  685. case 'del':
  686. await ctx.service.changeAuditList.del(data.id);
  687. break;
  688. case 'update':
  689. await ctx.service.changeAuditList.save(data.updateData);
  690. break;
  691. case 'paste':
  692. await ctx.service.changeAuditList.saveDatas(data.updateData);
  693. // 取所有工料表
  694. responseData.data = await ctx.service.changeAuditList.getAllDataByCondition({
  695. where: { cid: ctx.change.cid },
  696. orders: [['lid', 'desc'], ['id', 'asc']],
  697. });
  698. break;
  699. case 'ledger_list':
  700. await ctx.service.changeAuditList.saveLedgerListDatas(data.updateData);
  701. // 取所有工料表
  702. responseData.data = await ctx.service.changeAuditList.getAllDataByCondition({
  703. where: { cid: ctx.change.cid },
  704. orders: [['lid', 'desc'], ['id', 'asc']],
  705. });
  706. break;
  707. case 'info':
  708. await ctx.service.change.saveInfo(data.updateData);
  709. // 取所有工料表
  710. responseData.data = '保存成功';
  711. break;
  712. case 'paste_amount_rows':
  713. await ctx.service.changeAuditList.saveDatas(data.updateData);
  714. let changeList = await ctx.service.changeAuditList.getAllDataByCondition({
  715. where: { cid: ctx.change.cid },
  716. orders: [['lid', 'desc'], ['id', 'asc']],
  717. });
  718. const auditList2 = await ctx.service.changeAudit.getListGroupByTimes(ctx.change.cid, ctx.change.times);
  719. changeList = JSON.parse(JSON.stringify(changeList.sort())).sort().sort();
  720. for (const cl of changeList) {
  721. const audit_amount = cl.audit_amount !== null && cl.audit_amount !== '' ? cl.audit_amount.split(',') : '';
  722. // 清单表页赋值
  723. for (const [index, au] of auditList2.entries()) {
  724. if (au.usite !== 0) {
  725. cl['audit_amount_' + au.uid] = au.uid === ctx.session.sessionUser.accountId ? cl.spamount : (audit_amount[index - 1] ? audit_amount[index - 1] : null);
  726. }
  727. }
  728. }
  729. // 取所有工料表
  730. responseData.data = changeList;
  731. break;
  732. default: throw '参数有误';
  733. }
  734. ctx.body = responseData;
  735. } catch (err) {
  736. this.log(err);
  737. ctx.body = { err: 1, msg: err.toString(), data: null };
  738. }
  739. }
  740. /**
  741. * 上报和重新上报
  742. * @param ctx
  743. * @return {Promise<void>}
  744. */
  745. async startAudit(ctx) {
  746. try {
  747. // 检查权限等
  748. if (!ctx.change) {
  749. throw '数据错误';
  750. }
  751. if (ctx.change.uid !== ctx.session.sessionUser.accountId) {
  752. throw '您无权上报该变更令数据';
  753. }
  754. if (!(ctx.change.status === audit.flow.status.uncheck || ctx.change.status === audit.flow.status.back)) {
  755. throw '该变更令当前无法上报';
  756. }
  757. await ctx.service.changeAudit.start(ctx.change.cid, ctx.change.times);
  758. ctx.redirect(ctx.request.header.referer);
  759. } catch (err) {
  760. this.log(err);
  761. ctx.session.postError = err.toString();
  762. ctx.redirect(ctx.request.header.referer);
  763. }
  764. }
  765. // 审批相关
  766. /**
  767. * 添加审批人
  768. * @param ctx
  769. * @return {Promise<void>}
  770. */
  771. async addAudit(ctx) {
  772. try {
  773. const data = JSON.parse(ctx.request.body.data);
  774. const id = this.app._.toInteger(data.auditorId);
  775. if (isNaN(id) || id <= 0) {
  776. throw '参数错误';
  777. }
  778. // 检查权限等
  779. if (ctx.change.uid !== ctx.session.sessionUser.accountId) {
  780. throw '您无权添加审核人';
  781. }
  782. if (ctx.change.status === audit.flow.status.checking || ctx.change.status === audit.flow.status.checked) {
  783. throw '当前不允许添加审核人';
  784. }
  785. const auditorList = await ctx.service.changeAudit.getAuditors(ctx.change.cid, ctx.change.times);
  786. // 检查审核人是否已存在
  787. const exist = this.app._.find(auditorList, { uid: id });
  788. if (exist) {
  789. throw '该审核人已存在,请勿重复添加';
  790. }
  791. const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.change, sp_status: shenpiConst.sp_status.gdzs });
  792. const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.change === shenpiConst.sp_status.gdzs ? 1 : 0;
  793. const result = await ctx.service.changeAudit.addAuditor(ctx.change.cid, id, ctx.change.times, is_gdzs);
  794. if (!result) {
  795. throw '添加审核人失败';
  796. }
  797. // const auditors = await ctx.service.changeAudit.getAuditorsWithOwner(ctx.change.id, ctx.change.times);
  798. const auditors = null;
  799. ctx.body = { err: 0, msg: '', data: auditors };
  800. } catch (err) {
  801. this.log(err);
  802. ctx.body = { err: 1, msg: err.toString(), data: null };
  803. }
  804. }
  805. /**
  806. * 移除审批人
  807. * @param ctx
  808. * @return {Promise<void>}
  809. */
  810. async deleteAudit(ctx) {
  811. try {
  812. const data = JSON.parse(ctx.request.body.data);
  813. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  814. if (isNaN(id) || id <= 0) {
  815. throw '参数错误';
  816. }
  817. const result = await ctx.service.changeAudit.deleteAuditor(ctx.change.cid, id, ctx.change.times);
  818. if (!result) {
  819. throw '移除审核人失败';
  820. }
  821. const auditors = null;
  822. ctx.body = { err: 0, msg: '', data: auditors };
  823. } catch (err) {
  824. ctx.body = { err: 1, msg: err.toString(), data: null };
  825. }
  826. }
  827. async defaultBills(ctx) {
  828. try {
  829. const ledgerData = await ctx.service.ledger.getData(ctx.tender.id);
  830. const posData = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  831. const dealBills = await ctx.service.dealBills.getAllDataByCondition({ where: { tender_id: ctx.tender.id } });
  832. ctx.body = { err: 0, msg: '', data: { bills: ledgerData, pos: posData, dealBills } };
  833. } catch (err) {
  834. this.log(err);
  835. ctx.body = { err: 1, msg: err.toString(), data: [] };
  836. }
  837. }
  838. /**
  839. * 变更令上报和保存
  840. * @param {Object} ctx - egg全局变量
  841. * @return {void}
  842. */
  843. async save(ctx) {
  844. // 变更令信息
  845. const changeInfo = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.cid });
  846. try {
  847. const result = await ctx.service.change.save(ctx.request.body, changeInfo.tid);
  848. if (!result) {
  849. throw '上报失败';
  850. }
  851. if (ctx.request.body.changestatus !== undefined && parseInt(ctx.request.body.changestatus) === 2) {
  852. ctx.body = { err: 0, msg: '保存成功' };
  853. } else {
  854. ctx.redirect('/tender/' + changeInfo.tid + '/change');
  855. }
  856. } catch (err) {
  857. this.log(err);
  858. if (ctx.request.body.changestatus !== undefined && parseInt(ctx.request.body.changestatus) === 2) {
  859. ctx.body = { err: 1, msg: err.toString() };
  860. } else {
  861. ctx.redirect('/tender/' + changeInfo.tid + '/change/' + ctx.request.body.cid + '/info');
  862. }
  863. }
  864. }
  865. /**
  866. * 变更令审批
  867. * @param {Object} ctx - egg全局变量
  868. * @return {void}
  869. */
  870. async approval(ctx) {
  871. try {
  872. const changeData = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.change_id });
  873. if (!changeData) {
  874. throw '变更令数据错误';
  875. }
  876. const status = parseInt(ctx.request.body.status);
  877. let result = false;
  878. const pid = this.ctx.session.sessionProject.id;
  879. switch (status) {
  880. case 3:// 审批通过
  881. result = await ctx.service.change.approvalSuccess(pid, ctx.request.body, changeData);
  882. break;
  883. case 4:// 审批终止
  884. result = await ctx.service.change.approvalStop(ctx.request.body);
  885. break;
  886. case 5:// 审批退回到原报人
  887. result = await ctx.service.change.approvalBack(pid, ctx.request.body, changeData);
  888. break;
  889. case 6:// 审批退回到上一个审批人
  890. result = await ctx.service.change.approvalBackNew(pid, ctx.request.body, changeData);
  891. break;
  892. default:break;
  893. }
  894. if (!result) {
  895. throw '审批失败';
  896. }
  897. ctx.redirect(ctx.request.header.referer);
  898. } catch (err) {
  899. console.log(err);
  900. ctx.redirect(ctx.request.header.referer);
  901. }
  902. }
  903. /**
  904. * 变更公司管理
  905. * @param {Object} ctx - egg全局变量
  906. * @return {void}
  907. */
  908. async updateCompany(ctx) {
  909. const responseData = {
  910. err: 0,
  911. msg: '',
  912. data: '',
  913. };
  914. try {
  915. const data = JSON.parse(ctx.request.body.data);
  916. if (data.tid === undefined || data.uci === undefined || data.uc === undefined || data.ac === undefined) {
  917. throw '参数有误';
  918. }
  919. const [addCompany, selectCompany] = await ctx.service.changeCompany.setCompanyList(data);
  920. responseData.data = { add: addCompany, select: selectCompany };
  921. } catch (err) {
  922. responseData.err = 1;
  923. responseData.msg = err;
  924. }
  925. ctx.body = responseData;
  926. }
  927. /**
  928. * 上传附件
  929. * @param {Object} ctx - egg全局变量
  930. * @return {void}
  931. */
  932. async uploadFile(ctx) {
  933. const responseData = {
  934. err: 0,
  935. msg: '',
  936. data: [],
  937. };
  938. let stream;
  939. try {
  940. const parts = ctx.multipart({ autoFields: true });
  941. const files = [];
  942. let index = 0;
  943. const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });
  944. const extra_upload = change.status === audit.flow.status.checked;
  945. while ((stream = await parts()) !== undefined) {
  946. // 判断用户是否选择上传文件
  947. if (!stream.filename) {
  948. throw '请选择上传的文件!';
  949. }
  950. // const create_time = Date.parse(new Date()) / 1000;
  951. // const fileInfo = path.parse(stream.filename);
  952. // const dirName = 'app/public/upload/changes/' + moment().format('YYYYMMDD');
  953. // const fileName = 'changes' + create_time + '_' + index + fileInfo.ext;
  954. // // 判断文件夹是否存在,不存在则直接创建文件夹
  955. // if (!fs.existsSync(path.join(this.app.baseDir, dirName))) {
  956. // await fs.mkdirSync(path.join(this.app.baseDir, dirName));
  957. // }
  958. // // 保存文件
  959. // await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, dirName, fileName));
  960. const fileInfo = path.parse(stream.filename);
  961. const create_time = Date.parse(new Date()) / 1000;
  962. const filepath = `app/public/upload/change/fujian_${create_time + index.toString() + fileInfo.ext}`;
  963. await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, filepath));
  964. await sendToWormhole(stream);
  965. // 保存数据到att表
  966. const fileData = {
  967. in_time: create_time,
  968. filename: fileInfo.name,
  969. fileext: fileInfo.ext,
  970. filesize: Array.isArray(parts.field.size) ? parts.field.size[index] : parts.field.size,
  971. filepath,
  972. extra_upload,
  973. };
  974. const result = await ctx.service.changeAtt.save(parts.field, fileData, ctx.session.sessionUser.accountId);
  975. if (!result) {
  976. throw '导入数据库保存失败';
  977. }
  978. fileData.in_time = moment(create_time * 1000).format('YYYY-MM-DD');
  979. fileData.filesize = await ctx.helper.bytesToSize(fileData.filesize);
  980. fileData.id = result.insertId;
  981. delete fileData.filepath;
  982. files.push(fileData);
  983. ++index;
  984. }
  985. responseData.data = files;
  986. } catch (err) {
  987. this.log(err);
  988. // 失败需要消耗掉stream 以防卡死
  989. if (stream) {
  990. await sendToWormhole(stream);
  991. }
  992. this.setMessage(err.toString(), this.messageType.ERROR);
  993. }
  994. ctx.body = responseData;
  995. }
  996. /**
  997. * 下载附件
  998. * @param {Object} ctx - egg全局变量
  999. * @return {void}
  1000. */
  1001. async downloadFile(ctx) {
  1002. const id = ctx.params.id;
  1003. if (id) {
  1004. try {
  1005. const fileInfo = await ctx.service.changeAtt.getDataById(id);
  1006. if (fileInfo !== undefined && fileInfo !== '') {
  1007. const fileName = path.join(this.app.baseDir, fileInfo.filepath);
  1008. // 解决中文无法下载问题
  1009. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  1010. let disposition = '';
  1011. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  1012. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.filename + fileInfo.fileext);
  1013. } else if (userAgent.indexOf('firefox') >= 0) {
  1014. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.filename + fileInfo.fileext) + '"';
  1015. } else {
  1016. /* safari等其他非主流浏览器只能自求多福了 */
  1017. disposition = 'attachment; filename=' + new Buffer(fileInfo.filename + fileInfo.fileext).toString('binary');
  1018. }
  1019. ctx.response.set({
  1020. 'Content-Type': 'application/octet-stream',
  1021. 'Content-Disposition': disposition,
  1022. 'Content-Length': fileInfo.filesize,
  1023. });
  1024. ctx.body = await fs.createReadStream(fileName);
  1025. } else {
  1026. throw '不存在该文件';
  1027. }
  1028. } catch (err) {
  1029. this.log(err);
  1030. this.setMessage(err.toString(), this.messageType.ERROR);
  1031. }
  1032. }
  1033. }
  1034. /**
  1035. * 批量下载 - 压缩成zip文件返回
  1036. * @param {Oject} ctx - 全局上下文
  1037. */
  1038. async downloadZip(ctx) {
  1039. try {
  1040. const fileIds = JSON.parse(ctx.request.query.fileIds);
  1041. // const { fileIds } = JSON.parse(ctx.request.body.data);
  1042. // console.log('fileIds', fileIds);
  1043. const { name: changeName } = await ctx.service.changeAtt.getChangeName(ctx.params.cid);
  1044. const zipFilename = `${ctx.tender.data.name}-工程变更-${changeName}-附件.zip`;
  1045. const time = Date.now();
  1046. const zipPath = `app/public/upload/change/fu_jian_zip${time}.zip`;
  1047. const size = await ctx.service.changeAtt.compressedFile(fileIds, zipPath);
  1048. // 解决中文无法下载问题
  1049. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  1050. let disposition = '';
  1051. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  1052. disposition = 'attachment; filename=' + encodeURIComponent(zipFilename);
  1053. } else if (userAgent.indexOf('firefox') >= 0) {
  1054. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(zipFilename) + '"';
  1055. } else {
  1056. /* safari等其他非主流浏览器只能自求多福了 */
  1057. disposition = 'attachment; filename=' + new Buffer(zipFilename).toString('binary');
  1058. }
  1059. ctx.response.set({
  1060. 'Content-Type': 'application/octet-stream',
  1061. 'Content-Disposition': disposition,
  1062. 'Content-Length': size,
  1063. });
  1064. const readStream = fs.createReadStream(path.join(this.app.baseDir, zipPath));
  1065. ctx.body = readStream;
  1066. // ctx.body = fs.readFileSync(path.resolve(this.app.baseDir, zipPath));
  1067. readStream.on('close', () => {
  1068. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1069. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1070. }
  1071. });
  1072. } catch (error) {
  1073. this.log(error);
  1074. }
  1075. }
  1076. /**
  1077. * 删除附件
  1078. * @param {Object} ctx - egg全局变量
  1079. * @return {void}
  1080. */
  1081. async deleteFile(ctx) {
  1082. const responseData = {
  1083. err: 0,
  1084. msg: '',
  1085. data: '',
  1086. };
  1087. try {
  1088. const data = JSON.parse(ctx.request.body.data);
  1089. const change = await ctx.service.change.getDataByCondition({ cid: ctx.params.cid });
  1090. const fileInfo = await ctx.service.changeAtt.getDataById(data.id);
  1091. if (!fileInfo || !Object.keys(fileInfo).length) {
  1092. throw '该文件不存在';
  1093. }
  1094. if (!fileInfo.extra_upload && change.status === audit.flow.status.checked) {
  1095. throw '无权限删除';
  1096. }
  1097. if (fileInfo !== undefined && fileInfo !== '') {
  1098. // 先删除文件
  1099. await fs.unlinkSync(path.join(this.app.baseDir, fileInfo.filepath));
  1100. // 再删除数据库
  1101. await ctx.service.changeAtt.deleteById(data.id);
  1102. responseData.data = '';
  1103. } else {
  1104. throw '不存在该文件';
  1105. }
  1106. // if (data.tid === undefined || data.uci === undefined || data.uc === undefined || data.ac === undefined) {
  1107. // throw '参数有误';
  1108. // }
  1109. // const [addCompany, selectCompany] = await ctx.service.changeCompany.setCompanyList(data);
  1110. // responseData.data = { add: addCompany, select: selectCompany };
  1111. } catch (err) {
  1112. responseData.err = 1;
  1113. responseData.msg = err;
  1114. }
  1115. ctx.body = responseData;
  1116. }
  1117. /**
  1118. * 查看附件
  1119. * @param {Object} ctx - egg全局变量
  1120. * @return {void}
  1121. */
  1122. async checkFile(ctx) {
  1123. const responseData = { err: 0, msg: '' };
  1124. const id = parseInt(ctx.params.id);
  1125. if (id) {
  1126. try {
  1127. const fileInfo = await ctx.service.changeAtt.getDataById(id);
  1128. if (fileInfo && Object.keys(fileInfo).length) {
  1129. let filepath = fileInfo.filepath;
  1130. if (!ctx.helper.canPreview(fileInfo.fileext)) {
  1131. filepath = `/change/download/file/${fileInfo.id}`;
  1132. } else {
  1133. filepath = filepath.replace(/^app|\/app/, '');
  1134. }
  1135. fileInfo.filepath && (responseData.data = { filepath });
  1136. }
  1137. } catch (error) {
  1138. this.log(error);
  1139. this.setMessage(error.toString(), this.messageType.ERROR);
  1140. responseData.err = 1;
  1141. responseData.msg = error.toString();
  1142. }
  1143. }
  1144. ctx.body = responseData;
  1145. }
  1146. /**
  1147. * 删除变更令
  1148. * @param {Object} ctx - egg全局变量
  1149. * @return {void}
  1150. */
  1151. async delete(ctx) {
  1152. try {
  1153. const result = await ctx.service.change.delete(ctx.request.body.cid);
  1154. if (!result) {
  1155. throw '删除变更令失败';
  1156. }
  1157. ctx.redirect(ctx.request.header.referer);
  1158. } catch (err) {
  1159. console.log(err);
  1160. ctx.redirect(ctx.request.header.referer);
  1161. }
  1162. }
  1163. /**
  1164. * 变更令重新审批
  1165. * @param {Object} ctx - egg全局变量
  1166. * @return {void}
  1167. */
  1168. async checkAgain(ctx) {
  1169. try {
  1170. const changeData = await ctx.service.change.getDataByCondition({ cid: ctx.request.body.cid });
  1171. if (!changeData) {
  1172. throw '变更令数据错误';
  1173. }
  1174. // 获取终审
  1175. const auditInfo = (await this.ctx.service.changeAudit.getAllDataByCondition({ where: { cid: changeData.cid }, orders: [['usort', 'desc']], limit: 1, offset: 0 }))[0];
  1176. if (changeData.status !== audit.flow.status.checked || ctx.session.sessionUser.accountId !== auditInfo.uid) {
  1177. throw '您无权进行该操作';
  1178. }
  1179. if (ctx.session.sessionUser.loginStatus === 0) {
  1180. const code = ctx.request.body.code;
  1181. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  1182. if (!pa.auth_mobile) {
  1183. throw '未绑定手机号';
  1184. }
  1185. const cacheKey = 'smsCode:' + ctx.session.sessionUser.accountId;
  1186. const cacheCode = await app.redis.get(cacheKey);
  1187. // console.log(cacheCode);
  1188. if (cacheCode === null || code === undefined || cacheCode !== (code + pa.auth_mobile)) {
  1189. throw '验证码不正确!';
  1190. }
  1191. }
  1192. // 获取是否已存在调用变更令
  1193. const changeUsedData = await ctx.service.stageChange.getFinalUsedData(ctx.tender.id, changeData.cid);
  1194. const stageChangeNum = this.ctx.helper.sum(changeUsedData.map(x => { return Math.abs(x.used_qty); }));
  1195. if (stageChangeNum !== 0) {
  1196. throw '该变更令已被调用,无法重新审批';
  1197. }
  1198. // 重新审批
  1199. const result = await ctx.service.change.checkAgain(changeData.cid);
  1200. if (!result) {
  1201. throw '重新审批失败';
  1202. }
  1203. // ctx.redirect('/tender/' + changeData.tid + '/change/' + changeData.cid + '/info');
  1204. ctx.body = {
  1205. err: 0,
  1206. url: ctx.request.header.referer,
  1207. msg: '',
  1208. };
  1209. } catch (err) {
  1210. console.log(err);
  1211. // ctx.redirect(ctx.request.header.referer);
  1212. ctx.body = {
  1213. err: 1,
  1214. // url: ctx.request.header.referer,
  1215. msg: err,
  1216. };
  1217. }
  1218. }
  1219. /**
  1220. * 获取变更清单
  1221. * @param ctx
  1222. * @return {Promise<void>}
  1223. */
  1224. async bills(ctx) {
  1225. try {
  1226. const data = JSON.parse(ctx.request.body.data);
  1227. const responseData = { err: 0, msg: '', data: [] };
  1228. switch (data.type) {
  1229. case 'gather':
  1230. responseData.data = await ctx.service.changeAuditList.gatherBgBills(ctx.tender.id);
  1231. break;
  1232. default:
  1233. throw '查询的数据不存在';
  1234. }
  1235. ctx.body = responseData;
  1236. } catch (err) {
  1237. this.log(err);
  1238. this.ajaxErrorBody(err, '获取变更清单失败');
  1239. }
  1240. }
  1241. /**
  1242. * 最后审批人审批成功检查批复编号和其它变更令是否出现重名情况
  1243. * @param ctx
  1244. * @return {Promise<void>}
  1245. */
  1246. async checkCodeRepeat(ctx) {
  1247. const responseData = {
  1248. err: 0,
  1249. msg: '',
  1250. data: '',
  1251. };
  1252. try {
  1253. const tenderId = ctx.params.id;
  1254. const cid = ctx.params.cid;
  1255. const data = JSON.parse(ctx.request.body.data);
  1256. const result = await ctx.service.change.isRepeat(cid, data.p_code, tenderId);
  1257. if (result) {
  1258. throw '该变更令号(批复编号)已使用';
  1259. }
  1260. } catch (err) {
  1261. responseData.err = 1;
  1262. responseData.msg = err;
  1263. }
  1264. ctx.body = responseData;
  1265. }
  1266. /**
  1267. * 拷贝其他变更令
  1268. * @param {object} ctx - 全局上下文
  1269. */
  1270. async copyChange(ctx) {
  1271. const responseData = {
  1272. err: 0,
  1273. msg: '',
  1274. data: '',
  1275. };
  1276. try {
  1277. const cid = ctx.params.cid;
  1278. const copy_cid = JSON.parse(ctx.request.body.data);
  1279. const result = await ctx.service.change.handleCopyChange(cid, copy_cid);
  1280. if (!result) {
  1281. responseData.err = 1;
  1282. responseData.msg = '拷贝失败!';
  1283. }
  1284. } catch (error) {
  1285. responseData.err = 1;
  1286. responseData.msg = error;
  1287. }
  1288. ctx.body = responseData;
  1289. }
  1290. }
  1291. return ChangeController;
  1292. };