material_controller.js 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737
  1. 'use strict';
  2. /**
  3. *
  4. *
  5. * @author EllisRan
  6. * @date 2018/6/20
  7. * @version
  8. */
  9. const moment = require('moment');
  10. const auditConst = require('../const/audit').material;
  11. const auditStageConst = require('../const/audit').stage;
  12. const tenderConst = require('../const/tender');
  13. const measureType = tenderConst.measureType;
  14. const accountGroup = require('../const/account_group').group;
  15. const materialConst = require('../const/material');
  16. const MaterialCalculator = require('../lib/material_calc');
  17. const sendToWormhole = require('stream-wormhole');
  18. const fs = require('fs');
  19. const path = require('path');
  20. const _ = require('lodash');
  21. const { typeOf } = require('mathjs');
  22. module.exports = app => {
  23. class MaterialController extends app.BaseController {
  24. /**
  25. * 构造函数
  26. *
  27. * @param {Object} ctx - egg全局变量
  28. * @return {void}
  29. */
  30. constructor(ctx) {
  31. super(ctx);
  32. ctx.showProject = true;
  33. ctx.showTender = true;
  34. ctx.showTitle = true;
  35. }
  36. /**
  37. * 期列表(Get)
  38. * @param ctx
  39. * @return {Promise<void>}
  40. */
  41. async index(ctx) {
  42. try {
  43. const renderData = {
  44. tender: ctx.tender.data,
  45. tenderMenu: this.menu.tenderMenu,
  46. preUrl: '/tender/' + ctx.tender.id,
  47. auditConst,
  48. auditConst2: JSON.stringify(auditConst),
  49. };
  50. renderData.materials = await ctx.service.material.getValidMaterials(ctx.tender.id);
  51. // 获取未选中和已完成的计量期
  52. const stages = await ctx.service.stage.getAllDataByCondition({ where: { tid: ctx.tender.id, status: auditStageConst.status.checked } });
  53. for (const s of renderData.materials) {
  54. // s.curAuditor = null;
  55. // 根据期状态返回展示用户
  56. s.curAuditor = await ctx.service.materialAudit.getAuditorByStatus(s.id, s.status, s.times);
  57. const materialStageList = s.stage_id.split(',');
  58. for (const ms of materialStageList) {
  59. const index = stages.findIndex(function(item) {
  60. return item.id === parseInt(ms);
  61. });
  62. stages.splice(index, 1);
  63. }
  64. }
  65. renderData.stages = stages;
  66. await this.layout('material/index.ejs', renderData, 'material/modal.ejs');
  67. } catch (err) {
  68. this.log(err);
  69. ctx.redirect(this.menu.menu.dashboard.url);
  70. }
  71. }
  72. /**
  73. * 期审批流程(Get)
  74. * @param ctx
  75. * @return {Promise<void>}
  76. */
  77. async materialAuditors(ctx) {
  78. try {
  79. const responseData = {
  80. err: 0, msg: '', data: {},
  81. };
  82. const order = JSON.parse(ctx.request.body.data).order;
  83. const tenderId = ctx.params.id;
  84. const materialInfo = await ctx.service.material.getDataByCondition({ tid: tenderId, order });
  85. // 获取审批流程中右边列表
  86. const auditHistory = [];
  87. const times = materialInfo.status === auditConst.status.checkNo ? materialInfo.times - 1 : materialInfo.times;
  88. if (times >= 1) {
  89. for (let i = 1; i <= times; i++) {
  90. auditHistory.push(await ctx.service.materialAudit.getAuditors(materialInfo.id, i));
  91. }
  92. }
  93. responseData.data.auditHistory = auditHistory;
  94. // 获取审批流程中左边列表
  95. responseData.data.auditors = await ctx.service.materialAudit.getAuditGroupByList(materialInfo.id, times);
  96. // 获取原报信息
  97. const materialAuditor = await ctx.service.projectAccount.getAccountInfoById(materialInfo.user_id);
  98. responseData.data.materialAuditor = materialAuditor;
  99. ctx.body = responseData;
  100. } catch (error) {
  101. this.log(error);
  102. ctx.body = { err: 1, msg: error.toString(), data: null };
  103. }
  104. }
  105. /**
  106. * 新增期(Post)
  107. * @param ctx
  108. * @return {Promise<void>}
  109. */
  110. async add(ctx) {
  111. try {
  112. if (ctx.session.sessionUser.accountId !== ctx.tender.data.user_id) {
  113. throw '您无权创建材料调差期';
  114. }
  115. const data = ctx.request.body;
  116. if (data.s_order === '') {
  117. throw '没有选中计量期';
  118. }
  119. const newMaterial = await ctx.service.material.addMaterial(ctx.tender.id, data);
  120. if (!newMaterial) {
  121. throw '新增材料调差期失败,请重试';
  122. }
  123. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material/' + newMaterial.order);
  124. } catch (err) {
  125. this.log(err);
  126. ctx.redirect(ctx.request.header.referer);
  127. }
  128. }
  129. /**
  130. * 删除期(Post)
  131. * @param ctx
  132. * @return {Promise<void>}
  133. */
  134. async delete(ctx) {
  135. try {
  136. const material_id = ctx.request.body.material_id;
  137. const materialInfo = await ctx.service.material.getDataById(material_id);
  138. // 获取最新的期数
  139. const material_highOrder = await ctx.service.material.count({
  140. tid: ctx.tender.id,
  141. });
  142. if (materialInfo === undefined || ctx.session.sessionUser.accountId !== materialInfo.user_id || material_highOrder !== materialInfo.order) {
  143. throw '您无权删除材料调差期';
  144. }
  145. const result = await ctx.service.material.deleteMaterial(material_id);
  146. if (!result) {
  147. throw '删除材料调差期失败,请重试';
  148. }
  149. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material/');
  150. } catch (err) {
  151. this.log(err);
  152. console.log(err);
  153. ctx.redirect(ctx.request.header.referer);
  154. }
  155. }
  156. /**
  157. * 获取通用的renderData(用于layout, Menu, subMenu部分)
  158. * @param ctx
  159. * @return {{tender, tenderMenu, auditConst}}
  160. * @private
  161. */
  162. async _getDefaultRenderData(ctx) {
  163. const data = {
  164. tender: ctx.tender.data,
  165. tenderMenu: JSON.parse(JSON.stringify(this.menu.stageMenu)),
  166. auditConst,
  167. measureType,
  168. preUrl: '/tender/' + ctx.tender.id + '/measure/material/' + ctx.params.order,
  169. material: ctx.material,
  170. };
  171. if ((ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo) && ctx.session.sessionUser.accountId === ctx.material.user_id) {
  172. data.accountGroup = accountGroup;
  173. // 获取所有项目参与者
  174. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  175. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  176. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group'],
  177. });
  178. data.accountList = accountList;
  179. }
  180. data.tenderMenu.back.children[0].url = '/tender/' + ctx.tender.id + '/measure/material';
  181. return data;
  182. }
  183. _materialReadOnly(material) {
  184. return material.status === auditConst.status.checked;
  185. }
  186. /**
  187. * 获取审批界面所需的 原报、审批人数据等
  188. * @param ctx
  189. * @return {Promise<void>}
  190. * @private
  191. */
  192. async _getMaterialAuditViewData(ctx) {
  193. const times = ctx.material.status === auditConst.status.checkNo ? ctx.material.times - 1 : ctx.material.times;
  194. ctx.material.user = await ctx.service.projectAccount.getAccountInfoById(ctx.material.user_id);
  195. ctx.material.auditHistory = [];
  196. if (ctx.material.times >= 1) {
  197. for (let i = 1; i <= times; i++) {
  198. ctx.material.auditHistory.push(await ctx.service.materialAudit.getAuditors(ctx.material.id, i));
  199. }
  200. }
  201. // 获取审批流程中左边列表
  202. ctx.material.auditors2 = await ctx.service.materialAudit.getAuditGroupByList(ctx.material.id, times);
  203. if (ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo) {
  204. ctx.material.auditorList = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  205. }
  206. }
  207. /**
  208. * 调差工料页面 (Get)
  209. * @param {Object} ctx - egg全局变量
  210. * @return {Promise<void>}
  211. */
  212. async info(ctx) {
  213. try {
  214. await this._getMaterialAuditViewData(ctx);
  215. const renderData = await this._getDefaultRenderData(ctx);
  216. // 根据期判断需要获取的工料信息值
  217. const searchsql = { tid: ctx.tender.id };
  218. if (ctx.material.highOrder !== ctx.material.order) {
  219. const midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  220. searchsql.mid = midList;
  221. }
  222. // 取所有工料表
  223. renderData.materialBillsData = await ctx.service.materialBills.getAllDataByCondition({ where: searchsql });
  224. // 取对应期的截取上期的调差金额和应耗数量
  225. if (ctx.material.highOrder !== ctx.material.order) {
  226. for (const [mindex, mb] of renderData.materialBillsData.entries()) {
  227. const result = await ctx.service.materialBillsHistory.getByMbId(ctx.material.id, ctx.material.order, mb.id);
  228. _.forEach(result, function(value, key) {
  229. renderData.materialBillsData[mindex][key] = result ? result[key] : null;
  230. });
  231. // if (result) {
  232. // renderData.materialBillsData[mindex].quantity = result.quantity;
  233. // renderData.materialBillsData[mindex].expr = result.expr;
  234. // renderData.materialBillsData[mindex].msg_tp = result.msg_tp;
  235. // renderData.materialBillsData[mindex].msg_times = result.msg_times;
  236. // renderData.materialBillsData[mindex].msg_spread = result.msg_spread;
  237. // renderData.materialBillsData[mindex].m_up_risk = result.m_up_risk;
  238. // renderData.materialBillsData[mindex].m_down_risk = result.m_down_risk;
  239. // renderData.materialBillsData[mindex].m_spread = result.m_spread;
  240. // renderData.materialBillsData[mindex].pre_tp = result.pre_tp;
  241. // } else {
  242. // this._.forEach(renderData.materialBillsData[mindex], function(value, key) {
  243. // renderData.materialBillsData[mindex][key] = null;
  244. // });
  245. // }
  246. }
  247. }
  248. // 取所有已被调用的工料清单表
  249. renderData.materialListData = await ctx.service.materialList.getAllDataByCondition({ tid: ctx.tender.id, mid: ctx.material.id });
  250. // 基数
  251. // if (!ctx.material.readOnly) {
  252. const stage_list = await ctx.service.stage.getStageMsgByStageId(ctx.material.stage_id);
  253. renderData.calcBase = await ctx.service.stage.getMaterialCalcBase(stage_list, ctx.tender.info);
  254. // }
  255. // 取当前期截止上期含税金额
  256. renderData.pre_tp_hs = await ctx.service.material.getPreTpHs(ctx.tender.id, ctx.material.order);
  257. renderData.materialType = JSON.stringify(materialConst);
  258. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.info);
  259. await this.layout('material/info.ejs', renderData, 'material/info_modal.ejs');
  260. } catch (err) {
  261. this.log(err);
  262. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  263. }
  264. }
  265. /**
  266. * 调差清单页面 (Get)
  267. * @param {Object} ctx - egg全局变量
  268. * @return {Promise<void>}
  269. */
  270. async list(ctx) {
  271. try {
  272. await this._getMaterialAuditViewData(ctx);
  273. const renderData = await this._getDefaultRenderData(ctx);
  274. // 根据期判断需要获取的工料信息值表
  275. const searchsql = { tid: ctx.tender.id };
  276. let midList = [];
  277. if (ctx.material.highOrder !== ctx.material.order) {
  278. midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  279. searchsql.mid = midList;
  280. }
  281. searchsql.t_type = materialConst.t_type[0].value;
  282. renderData.materialBillsData = await ctx.service.materialBills.getAllDataByCondition({ where: searchsql });
  283. // 取所有已被调用的工料清单表
  284. renderData.materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
  285. renderData.materialNotJoinListData = await ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } });
  286. renderData.materialType = JSON.stringify(materialConst);
  287. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.list);
  288. // 获取清单数据
  289. renderData.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  290. renderData.pos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  291. // 获取所选期数据并合并相加同类清单项
  292. renderData.curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, ctx.material.stage_id);
  293. renderData.curPosData = await ctx.service.stagePos.getStagesData(ctx.tender.id, ctx.material.stage_id);
  294. await this.layout('material/list.ejs', renderData, 'material/list_modal.ejs');
  295. } catch (err) {
  296. this.log(err);
  297. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  298. }
  299. }
  300. /**
  301. * 附件页面 (Get)
  302. * @param {Object} ctx - egg全局变量
  303. * @return {Promise<void>}
  304. */
  305. async file(ctx) {
  306. try {
  307. await this._getMaterialAuditViewData(ctx);
  308. const renderData = await this._getDefaultRenderData(ctx);
  309. // 获取当前标段所有附件
  310. // const searchsql = { tid: ctx.tender.id };
  311. renderData.fileList = await ctx.service.materialFile.getAllMaterialFiles(ctx.tender.id, ctx.material.id);
  312. renderData.auditors = ctx.material.auditors.map(audit => audit.aid);
  313. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.file);
  314. await this.layout('material/file.ejs', renderData, 'material/file_modal.ejs');
  315. } catch (err) {
  316. this.log(err);
  317. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  318. }
  319. }
  320. /**
  321. * 调差清单 - 工料操作 (Ajax)
  322. * @param ctx
  323. * @return {Promise<void>}
  324. */
  325. async saveListsData(ctx) {
  326. try {
  327. const data = JSON.parse(ctx.request.body.data);
  328. const responseData = {
  329. err: 0,
  330. msg: '',
  331. data: {},
  332. };
  333. switch (data.type) {
  334. case 'add':
  335. responseData.data = await ctx.service.materialList.add(data.postData);
  336. break;
  337. case 'del':
  338. await ctx.service.materialList.del(data.id, data.mb_id);
  339. break;
  340. case 'update':
  341. if (data.updateData.quantity === '' || data.updateData.quantity === null) {
  342. throw '请输入数量';
  343. }
  344. // 判断数量是否为数字
  345. if (isNaN(data.updateData.quantity)) {
  346. throw '不能输入其它非数字类型字符';
  347. }
  348. await ctx.service.materialList.save(data.updateData);
  349. break;
  350. case 'useOther':
  351. responseData.data = await ctx.service.materialList.addOther(data.postData);
  352. break;
  353. case 'join':
  354. await ctx.service.materialListNotjoin.del(data.select.id);
  355. break;
  356. case 'notjoin':
  357. responseData.data = await ctx.service.materialListNotjoin.add(data.select);
  358. break;
  359. case 'paste':
  360. await ctx.service.materialList.saveDatas(data.updateData);
  361. // 取所有工料表
  362. responseData.data = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
  363. break;
  364. default: throw '参数有误';
  365. }
  366. ctx.body = responseData;
  367. } catch (err) {
  368. this.log(err);
  369. ctx.body = { err: 1, msg: err.toString(), data: null };
  370. }
  371. }
  372. /**
  373. * 调差工料 - 编辑工料项 (Ajax)
  374. * @param ctx
  375. * @return {Promise<void>}
  376. */
  377. async saveBillsData(ctx) {
  378. try {
  379. const data = JSON.parse(ctx.request.body.data);
  380. const responseData = {
  381. err: 0,
  382. msg: '',
  383. data: {},
  384. };
  385. switch (data.type) {
  386. case 'add':
  387. responseData.data = await ctx.service.materialBills.add();
  388. break;
  389. case 'del':
  390. responseData.data.m_tp = await ctx.service.materialBills.del(data.id);
  391. break;
  392. case 'update':
  393. if (data.updateData.code === '' || data.updateData.code === null) {
  394. throw '请先输入编号';
  395. }
  396. // 判断编号为纯数字时,不能为小数
  397. if (!isNaN(data.updateData.code) && data.updateData.code.toString().indexOf('.') !== -1) {
  398. throw '编号为纯数字时,不能为小数';
  399. }
  400. if (data.updateData.code.length > 15) {
  401. throw '长度不超过15个字符';
  402. }
  403. // 判断编号是否已存在
  404. const billData = await ctx.service.materialBills.getAllDataByCondition({ where: { tid: ctx.tender.id, code: data.updateData.code } });
  405. if (billData.length > 1 || (billData.length > 0 && billData[0].id !== data.updateData.id)) {
  406. throw '该编号已存在,请重新输入。';
  407. }
  408. responseData.data.m_tp = await ctx.service.materialBills.save(data.updateData);
  409. break;
  410. case 'rate':
  411. // 判断数量是否为数字
  412. if (isNaN(data.rate)) {
  413. throw '不能输入其它非数字类型字符';
  414. }
  415. if (ctx.material.readOnly) {
  416. throw '无权操作';
  417. }
  418. await ctx.service.material.changeRate(data.rate);
  419. break;
  420. case 'expr':
  421. const materialCalculator = new MaterialCalculator(ctx, ctx.material.stage_id, ctx.tender.info);
  422. const quantity = await materialCalculator.calculateExpr(data.expr);
  423. // 更新quantity值并重新返回计算本期金额,截止本期金额
  424. const updateData = {
  425. id: data.id,
  426. quantity: quantity !== 0 ? this.ctx.helper.round(quantity, 3) : null,
  427. expr: data.expr,
  428. };
  429. responseData.data = await ctx.service.materialBills.updateFYQuantity(updateData);
  430. break;
  431. case 'paste':
  432. responseData.data.m_tp = await ctx.service.materialBills.saveDatas(data.updateData);
  433. // 根据期判断需要获取的工料信息值
  434. const searchsql = { tid: ctx.tender.id };
  435. if (ctx.material.highOrder !== ctx.material.order) {
  436. const midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  437. searchsql.mid = midList;
  438. }
  439. // 取所有工料表
  440. responseData.data.info = await ctx.service.materialBills.getAllDataByCondition({ where: searchsql });
  441. break;
  442. default: throw '参数有误';
  443. }
  444. ctx.body = responseData;
  445. } catch (err) {
  446. this.log(err);
  447. ctx.body = { err: 1, msg: err.toString(), data: null };
  448. }
  449. }
  450. // 审批相关
  451. /**
  452. * 添加审批人
  453. * @param ctx
  454. * @return {Promise<void>}
  455. */
  456. async addAudit(ctx) {
  457. try {
  458. const data = JSON.parse(ctx.request.body.data);
  459. const id = this.app._.toInteger(data.auditorId);
  460. if (isNaN(id) || id <= 0) {
  461. throw '参数错误';
  462. }
  463. // 检查权限等
  464. if (ctx.material.user_id !== ctx.session.sessionUser.accountId) {
  465. throw '您无权添加审核人';
  466. }
  467. if (ctx.material.status === auditConst.status.checking || ctx.material.status === auditConst.status.checked) {
  468. throw '当前不允许添加审核人';
  469. }
  470. ctx.material.auditorList = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  471. // 检查审核人是否已存在
  472. const exist = this.app._.find(ctx.material.auditorList, { aid: id });
  473. if (exist) {
  474. throw '该审核人已存在,请勿重复添加';
  475. }
  476. const result = await ctx.service.materialAudit.addAuditor(ctx.material.id, id, ctx.material.times);
  477. if (!result) {
  478. throw '添加审核人失败';
  479. }
  480. const audit = await ctx.service.materialAudit.getAuditor(ctx.material.id, id, ctx.material.times);
  481. ctx.body = { err: 0, msg: '', data: audit };
  482. } catch (err) {
  483. this.log(err);
  484. ctx.body = { err: 1, msg: err.toString(), data: null };
  485. }
  486. }
  487. /**
  488. * 移除审批人
  489. * @param ctx
  490. * @return {Promise<void>}
  491. */
  492. async deleteAudit(ctx) {
  493. try {
  494. const data = JSON.parse(ctx.request.body.data);
  495. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  496. if (isNaN(id) || id <= 0) {
  497. throw '参数错误';
  498. }
  499. const result = await ctx.service.materialAudit.deleteAuditor(ctx.material.id, id, ctx.material.times);
  500. if (!result) {
  501. throw '移除审核人失败';
  502. }
  503. const auditors = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  504. ctx.body = { err: 0, msg: '', data: auditors };
  505. } catch (err) {
  506. ctx.body = { err: 1, msg: err.toString(), data: null };
  507. }
  508. }
  509. /**
  510. * 上报和重新上报
  511. * @param ctx
  512. * @return {Promise<void>}
  513. */
  514. async startAudit(ctx) {
  515. try {
  516. // 检查权限等
  517. if (!ctx.material) {
  518. throw '数据错误';
  519. }
  520. if (ctx.material.user_id !== ctx.session.sessionUser.accountId) {
  521. throw '您无权上报该期数据';
  522. }
  523. if (ctx.material.status === auditConst.status.checking || ctx.material.status === auditConst.status.checked) {
  524. throw '该材料调差期数据当前无法上报';
  525. }
  526. await ctx.service.materialAudit.start(ctx.material.id, ctx.material.times);
  527. ctx.redirect(ctx.request.header.referer);
  528. } catch (err) {
  529. this.log(err);
  530. ctx.session.postError = err.toString();
  531. ctx.redirect(ctx.request.header.referer);
  532. }
  533. }
  534. /**
  535. * 审批
  536. * @param ctx
  537. * @return {Promise<void>}
  538. */
  539. async checkAudit(ctx) {
  540. try {
  541. if (!this.ctx.material || this.ctx.material.status !== auditConst.status.checking) {
  542. throw '当前材料调差期数据有误';
  543. }
  544. if (!this.ctx.material.curAuditor || this.ctx.material.curAuditor.aid !== ctx.session.sessionUser.accountId) {
  545. throw '您无权进行该操作';
  546. }
  547. const data = {
  548. checkType: parseInt(ctx.request.body.checkType),
  549. opinion: ctx.request.body.opinion,
  550. };
  551. if (!data.checkType || isNaN(data.checkType)) {
  552. throw '提交数据错误';
  553. }
  554. if (data.checkType === auditConst.status.checkNo) {
  555. if (!data.checkType || isNaN(data.checkType)) {
  556. throw '提交数据错误';
  557. }
  558. }
  559. await ctx.service.materialAudit.check(ctx.material.id, data, ctx.material.times);
  560. ctx.redirect(ctx.request.header.referer);
  561. } catch (err) {
  562. this.log(err);
  563. ctx.session.postError = err.toString();
  564. ctx.redirect(ctx.request.header.referer);
  565. }
  566. }
  567. /**
  568. * 上传附件
  569. * @param {*} ctx 上下文
  570. */
  571. async upload(ctx) {
  572. let stream;
  573. try {
  574. const parts = this.ctx.multipart({
  575. autoFields: true,
  576. });
  577. const files = [];
  578. const create_time = Date.parse(new Date()) / 1000;
  579. while ((stream = await parts()) != null) {
  580. if (!stream.filename) {
  581. // 如果没有传入直接返回
  582. return;
  583. }
  584. const fileInfo = path.parse(stream.filename);
  585. const filepath = path.join('public/upload', this.ctx.tender.id.toString(), 'tc', 'fujian_' + create_time + fileInfo.ext);
  586. await ctx.helper.saveStreamFile(stream, path.join(this.app.baseDir, 'app', filepath));
  587. files.push({ filepath, name: stream.filename });
  588. // 将上传的文件流消费掉,防止浏览器卡死
  589. stream && (await sendToWormhole(stream));
  590. }
  591. const upload_time = this.ctx.helper.dateTran(new Date());
  592. const payload = files.map(file => {
  593. let idx;
  594. if (Array.isArray(parts.field.name)) {
  595. idx = parts.field.name.findIndex(name => name === file.name);
  596. } else {
  597. idx = 'isString';
  598. }
  599. const newFile = {
  600. tid: ctx.tender.id,
  601. user_id: ctx.session.sessionUser.accountId,
  602. mid: ctx.material.id,
  603. upload_time,
  604. file_path: file.filepath,
  605. file_size: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
  606. file_name: file.name,
  607. };
  608. return newFile;
  609. });
  610. // 执行文件信息写入数据库
  611. await ctx.service.materialFile.saveFileMsgToDb(payload);
  612. // 将最新的当前标段的所有文件信息返回
  613. const data = await ctx.service.materialFile.getAllMaterialFiles(ctx.tender.id, ctx.material.id);
  614. ctx.body = { err: 0, msg: '', data };
  615. } catch (err) {
  616. stream && (await sendToWormhole(stream));
  617. this.log(err);
  618. ctx.body = { err: 1, msg: err.toString(), data: null };
  619. }
  620. }
  621. /**
  622. * 查看当前标段以往所有期的附件
  623. * @param {Object} ctx 上下文
  624. */
  625. async getCurMatericalFiles(ctx) {
  626. try {
  627. const { isCheck } = JSON.parse(ctx.request.body.data);
  628. let data;
  629. if (isCheck) {
  630. data = await ctx.service.materialFile.getAllMaterialFiles(ctx.tender.id);
  631. } else {
  632. data = await ctx.service.materialFile.getAllMaterialFiles(ctx.tender.id, ctx.material.id);
  633. }
  634. ctx.body = { err: 0, msg: '', data };
  635. } catch (err) {
  636. this.log(err);
  637. ctx.body = { err: 1, msg: err.toString(), data: null };
  638. }
  639. }
  640. /**
  641. * 下载附件
  642. * @param {Object} ctx - egg全局变量
  643. * @return {void}
  644. */
  645. async downloadFile(ctx) {
  646. const id = ctx.params.fid;
  647. if (id) {
  648. try {
  649. const fileInfo = await ctx.service.materialFile.getMaterialFileById(id);
  650. if (fileInfo) {
  651. const fileName = path.join(this.app.baseDir, './app', fileInfo.file_path);
  652. console.log(fileName);
  653. // 解决中文无法下载问题
  654. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  655. let disposition = '';
  656. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  657. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.file_name);
  658. } else if (userAgent.indexOf('firefox') >= 0) {
  659. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.file_name) + '"';
  660. } else {
  661. /* safari等其他非主流浏览器只能自求多福了 */
  662. disposition = 'attachment; filename=' + new Buffer(fileInfo.file_name).toString('binary');
  663. }
  664. ctx.response.set({
  665. 'Content-Type': 'application/octet-stream',
  666. 'Content-Disposition': disposition,
  667. 'Content-Length': fileInfo.file_size,
  668. });
  669. ctx.body = await fs.createReadStream(fileName);
  670. } else {
  671. throw '不存在该文件';
  672. }
  673. } catch (err) {
  674. this.log(err);
  675. this.setMessage(err.toString(), this.messageType.ERROR);
  676. }
  677. }
  678. }
  679. /**
  680. * 删除附件
  681. * @param {Ojbect} ctx 上下文
  682. */
  683. async deleteFile(ctx) {
  684. try {
  685. const { data } = ctx.request.body;
  686. const { id } = JSON.parse(data);
  687. const fileInfo = await ctx.service.materialFile.getMaterialFileById(id);
  688. if (fileInfo) {
  689. // 先删除文件
  690. await fs.unlinkSync(path.join(this.app.baseDir, './app', fileInfo.file_path));
  691. // 再删除数据库
  692. await ctx.service.materialFile.delete(id);
  693. } else {
  694. throw '不存在该文件';
  695. }
  696. ctx.body = { err: 0, msg: '请求成功' };
  697. } catch (err) {
  698. this.log(err);
  699. ctx.body = { err: 1, msg: err.toString(), data: null };
  700. }
  701. }
  702. }
  703. return MaterialController;
  704. };