material_controller.js 54 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153
  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 shenpiConst = require('../const/shenpi');
  17. const MaterialCalculator = require('../lib/material_calc');
  18. const sendToWormhole = require('stream-wormhole');
  19. const fs = require('fs');
  20. const path = require('path');
  21. const _ = require('lodash');
  22. const { typeOf } = require('mathjs');
  23. module.exports = app => {
  24. class MaterialController extends app.BaseController {
  25. /**
  26. * 构造函数
  27. *
  28. * @param {Object} ctx - egg全局变量
  29. * @return {void}
  30. */
  31. constructor(ctx) {
  32. super(ctx);
  33. ctx.showProject = true;
  34. ctx.showTender = true;
  35. ctx.showTitle = true;
  36. }
  37. /**
  38. * 期列表(Get)
  39. * @param ctx
  40. * @return {Promise<void>}
  41. */
  42. async index(ctx) {
  43. try {
  44. const renderData = {
  45. tender: ctx.tender.data,
  46. tenderMenu: this.menu.tenderMenu,
  47. preUrl: '/tender/' + ctx.tender.id,
  48. auditConst,
  49. auditConst2: JSON.stringify(auditConst),
  50. };
  51. renderData.materials = await ctx.service.material.getValidMaterials(ctx.tender.id);
  52. // 获取未选中和已完成的计量期
  53. const stages = await ctx.service.stage.getAllDataByCondition({ where: { tid: ctx.tender.id, status: auditStageConst.status.checked } });
  54. for (const s of renderData.materials) {
  55. // s.curAuditor = null;
  56. // 根据期状态返回展示用户
  57. s.curAuditor = await ctx.service.materialAudit.getAuditorByStatus(s.id, s.status, s.times);
  58. const materialStageList = s.stage_id.split(',');
  59. for (const ms of materialStageList) {
  60. const index = stages.findIndex(function(item) {
  61. return item.id === parseInt(ms);
  62. });
  63. stages.splice(index, 1);
  64. }
  65. }
  66. renderData.stages = stages;
  67. await this.layout('material/index.ejs', renderData, 'material/modal.ejs');
  68. } catch (err) {
  69. this.log(err);
  70. ctx.redirect(this.menu.menu.dashboard.url);
  71. }
  72. }
  73. /**
  74. * 期审批流程(Get)
  75. * @param ctx
  76. * @return {Promise<void>}
  77. */
  78. async materialAuditors(ctx) {
  79. try {
  80. const responseData = {
  81. err: 0, msg: '', data: {},
  82. };
  83. const order = JSON.parse(ctx.request.body.data).order;
  84. const tenderId = ctx.params.id;
  85. const materialInfo = await ctx.service.material.getDataByCondition({ tid: tenderId, order });
  86. // 获取审批流程中右边列表
  87. const auditHistory = [];
  88. const times = materialInfo.status === auditConst.status.checkNo ? materialInfo.times - 1 : materialInfo.times;
  89. if (times >= 1) {
  90. for (let i = 1; i <= times; i++) {
  91. auditHistory.push(await ctx.service.materialAudit.getAuditors(materialInfo.id, i));
  92. }
  93. }
  94. responseData.data.auditHistory = auditHistory;
  95. // 获取审批流程中左边列表
  96. responseData.data.auditors = await ctx.service.materialAudit.getAuditorsWithOwner(materialInfo.id, times);
  97. responseData.data.user = await ctx.service.projectAccount.getAccountInfoById(materialInfo.user_id);
  98. // 获取原报信息
  99. // const materialAuditor = await ctx.service.projectAccount.getAccountInfoById(materialInfo.user_id);
  100. // responseData.data.materialAuditor = materialAuditor;
  101. ctx.body = responseData;
  102. } catch (error) {
  103. this.log(error);
  104. ctx.body = { err: 1, msg: error.toString(), data: null };
  105. }
  106. }
  107. /**
  108. * 新增期(Post)
  109. * @param ctx
  110. * @return {Promise<void>}
  111. */
  112. async add(ctx) {
  113. try {
  114. if (ctx.session.sessionUser.accountId !== ctx.tender.data.user_id) {
  115. throw '您无权创建材料调差期';
  116. }
  117. const data = ctx.request.body;
  118. if (data.s_order === '') {
  119. throw '没有选中计量期';
  120. }
  121. // 调差期是否存在审批或待上报,存在则无法重复添加
  122. const doingMaterial = await ctx.service.material.getDataByCondition({ tid: ctx.tender.id, status: [auditConst.status.uncheck, auditConst.status.checking, auditConst.status.checkNo] });
  123. if (doingMaterial) {
  124. throw '存在待上报或审批中的调差期,请勿重复生成';
  125. }
  126. const newMaterial = await ctx.service.material.addMaterial(ctx.tender.id, data);
  127. if (!newMaterial) {
  128. throw '新增材料调差期失败,请重试';
  129. }
  130. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material/' + newMaterial.order);
  131. } catch (err) {
  132. this.log(err);
  133. ctx.redirect(ctx.request.header.referer);
  134. }
  135. }
  136. /**
  137. * 删除期(Post)
  138. * @param ctx
  139. * @return {Promise<void>}
  140. */
  141. async delete(ctx) {
  142. try {
  143. const material_id = ctx.request.body.material_id;
  144. const materialInfo = await ctx.service.material.getDataById(material_id);
  145. // 获取最新的期数
  146. const material_highOrder = await ctx.service.material.count({
  147. tid: ctx.tender.id,
  148. });
  149. if (materialInfo === undefined || ctx.session.sessionUser.accountId !== materialInfo.user_id || material_highOrder !== materialInfo.order) {
  150. throw '您无权删除材料调差期';
  151. }
  152. const result = await ctx.service.material.deleteMaterial(material_id);
  153. if (!result) {
  154. throw '删除材料调差期失败,请重试';
  155. }
  156. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material/');
  157. } catch (err) {
  158. this.log(err);
  159. ctx.redirect(ctx.request.header.referer);
  160. }
  161. }
  162. /**
  163. * 获取通用的renderData(用于layout, Menu, subMenu部分)
  164. * @param ctx
  165. * @return {{tender, tenderMenu, auditConst}}
  166. * @private
  167. */
  168. async _getDefaultRenderData(ctx) {
  169. const data = {
  170. tender: ctx.tender.data,
  171. tenderMenu: JSON.parse(JSON.stringify(this.menu.stageMenu)),
  172. auditConst,
  173. measureType,
  174. preUrl: '/tender/' + ctx.tender.id + '/measure/material/' + ctx.params.order,
  175. material: ctx.material,
  176. shenpiConst,
  177. };
  178. if ((ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo) && ctx.session.sessionUser.accountId === ctx.material.user_id) {
  179. // data.accountGroup = accountGroup;
  180. // 获取所有项目参与者
  181. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  182. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  183. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  184. });
  185. data.accountList = accountList;
  186. data.accountGroup = accountGroup.map((item, idx) => {
  187. const groupList = accountList.filter(item => item.account_group === idx);
  188. return { groupName: item, groupList };
  189. });
  190. }
  191. data.tenderMenu.back.children[0].url = '/tender/' + ctx.tender.id + '/measure/material';
  192. return data;
  193. }
  194. _materialReadOnly(material) {
  195. return material.status === auditConst.status.checked;
  196. }
  197. /**
  198. * 获取审批界面所需的 原报、审批人数据等
  199. * @param ctx
  200. * @return {Promise<void>}
  201. * @private
  202. */
  203. async _getMaterialAuditViewData(ctx) {
  204. const times = ctx.material.status === auditConst.status.checkNo ? ctx.material.times - 1 : ctx.material.times;
  205. ctx.material.user = await ctx.service.projectAccount.getAccountInfoById(ctx.material.user_id);
  206. ctx.material.auditHistory = [];
  207. if (times >= 1) {
  208. for (let i = 1; i <= times; i++) {
  209. ctx.material.auditHistory.push(await ctx.service.materialAudit.getAuditors(ctx.material.id, i));
  210. }
  211. }
  212. // 获取审批流程中左边列表
  213. ctx.material.auditors2 = ctx.material.status === auditConst.status.checkNo && ctx.material.user_id !== ctx.session.sessionUser.accountId ?
  214. await ctx.service.materialAudit.getAuditorsWithOwner(ctx.material.id, times) :
  215. await ctx.service.materialAudit.getAuditorsWithOwner(ctx.material.id, ctx.material.times);
  216. if (ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo) {
  217. ctx.material.auditorList = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  218. }
  219. }
  220. /**
  221. * 获取当前期工料列表信息
  222. * @param ctx
  223. * @return {Promise<void>}
  224. * @private
  225. */
  226. async _getMaterialBillsData(ctx) {
  227. // 根据期判断需要获取的工料信息值
  228. const searchsql = { tid: ctx.tender.id };
  229. if (ctx.material.highOrder !== ctx.material.order) {
  230. const midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  231. searchsql.mid = midList;
  232. }
  233. // 取所有工料表
  234. return await ctx.service.materialBills.getAllDataByCondition({ where: searchsql, orders: [['order', 'asc']] });
  235. }
  236. /**
  237. * 获取当前月信息价列表信息
  238. * @param ctx
  239. * @return {Promise<void>}
  240. * @private
  241. */
  242. async _getMaterialMonthsData(ctx, materialBillsData) {
  243. // 取月信息价表
  244. const monthsList = [];
  245. if (ctx.material.months) {
  246. const material_month = ctx.material.months.split(',');
  247. material_month.sort();
  248. const materialMonthList = await ctx.service.materialMonth.getListByMid(ctx.material.id);
  249. for (const mbd of materialBillsData) {
  250. const one_mb = {
  251. code: mbd.code,
  252. name: mbd.name,
  253. unit: mbd.unit,
  254. origin: mbd.origin,
  255. mb_id: mbd.id,
  256. order: mbd.order,
  257. };
  258. for (const m of material_month) {
  259. const mb_id = ctx.material.highOrder !== ctx.material.order ? mbd.mb_id : mbd.id;
  260. const one_mm = _.find(materialMonthList, { mb_id, yearmonth: m });
  261. one_mb[m] = one_mm.msg_tp;
  262. }
  263. monthsList.push(one_mb);
  264. }
  265. }
  266. return monthsList;
  267. }
  268. /**
  269. * 检查旧数据是否存在指数法调差数据,没有自动添加定值
  270. * @param ctx
  271. * @return {Promise<void>}
  272. * @private
  273. */
  274. async _checkExponentExist(ctx) {
  275. const material_exponent_constant = await ctx.service.materialExponent.getDataByCondition({
  276. tid: ctx.tender.id,
  277. type: materialConst.ex_type[0].value,
  278. });
  279. // 不存在则生成指数调差清单表定值和历史期定值(防止变更定值发生变化)
  280. if (!material_exponent_constant) {
  281. await ctx.service.materialExponent.addOldData();
  282. }
  283. }
  284. /**
  285. * 获取当前期指数列表信息
  286. * @param ctx
  287. * @return {Promise<void>}
  288. * @private
  289. */
  290. async _getMaterialExponentData(ctx) {
  291. // 根据期判断需要获取的工料信息值
  292. const searchsql = { tid: ctx.tender.id };
  293. if (ctx.material.highOrder !== ctx.material.order) {
  294. const midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  295. searchsql.mid = midList;
  296. }
  297. // 取所有工料表
  298. return await ctx.service.materialExponent.getAllDataByCondition({ where: searchsql });
  299. }
  300. /**
  301. * 调差工料页面 (Get)
  302. * @param {Object} ctx - egg全局变量
  303. * @return {Promise<void>}
  304. */
  305. async info(ctx) {
  306. try {
  307. await this._getMaterialAuditViewData(ctx);
  308. const renderData = await this._getDefaultRenderData(ctx);
  309. renderData.materialBillsData = await this._getMaterialBillsData(ctx);
  310. // 取对应期的截取上期的调差金额和应耗数量
  311. if (ctx.material.highOrder !== ctx.material.order) {
  312. for (const [mindex, mb] of renderData.materialBillsData.entries()) {
  313. const result = await ctx.service.materialBillsHistory.getByMbId(ctx.material.id, ctx.material.order, mb.id);
  314. _.forEach(result, function(value, key) {
  315. renderData.materialBillsData[mindex][key] = result ? result[key] : null;
  316. });
  317. }
  318. }
  319. // 取所有已被调用的工料清单表
  320. renderData.materialListData = await ctx.service.materialList.getAllDataByCondition({ tid: ctx.tender.id, mid: ctx.material.id });
  321. // 基数
  322. // if (!ctx.material.readOnly) {
  323. const stage_list = await ctx.service.stage.getStageMsgByStageId(ctx.material.stage_id);
  324. renderData.calcBase = await ctx.service.stage.getMaterialCalcBase(stage_list, ctx.tender.info);
  325. // }
  326. // 取当前期截止上期含税金额
  327. renderData.pre_tp_hs = await ctx.service.material.getPreTpHs(ctx.tender.id, ctx.material.order);
  328. renderData.ex_pre_tp_hs = await ctx.service.material.getExPreTpHs(ctx.tender.id, ctx.material.order);
  329. renderData.months = ctx.material.months ? ctx.material.months.split(',') : [];
  330. renderData.monthsList = await this._getMaterialMonthsData(ctx, renderData.materialBillsData);
  331. renderData.materialType = JSON.stringify(materialConst);
  332. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.info);
  333. await this.layout('material/info.ejs', renderData, 'material/info_modal.ejs');
  334. } catch (err) {
  335. this.log(err);
  336. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  337. }
  338. }
  339. /**
  340. * 调差清单页面 (Get)
  341. * @param {Object} ctx - egg全局变量
  342. * @return {Promise<void>}
  343. */
  344. async list(ctx) {
  345. try {
  346. await this._getMaterialAuditViewData(ctx);
  347. const renderData = await this._getDefaultRenderData(ctx);
  348. // 根据期判断需要获取的工料信息值表
  349. const searchsql = { tid: ctx.tender.id };
  350. let midList = [];
  351. if (ctx.material.highOrder !== ctx.material.order) {
  352. midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  353. searchsql.mid = midList;
  354. }
  355. searchsql.t_type = materialConst.t_type[0].value;
  356. renderData.materialBillsData = await ctx.service.materialBills.getAllDataByCondition({ where: searchsql, orders: [['order', 'asc']] });
  357. // 取对应期的截取上期的调差金额和应耗数量
  358. if (ctx.material.highOrder !== ctx.material.order) {
  359. for (const [mindex, mb] of renderData.materialBillsData.entries()) {
  360. const result = await ctx.service.materialBillsHistory.getByMbId(ctx.material.id, ctx.material.order, mb.id);
  361. _.forEach(result, function(value, key) {
  362. if (key === 'mb_id') {
  363. renderData.materialBillsData[mindex].id = result ? result[key] : null;
  364. } else {
  365. renderData.materialBillsData[mindex][key] = result ? result[key] : null;
  366. }
  367. });
  368. }
  369. }
  370. // 取所有已被调用的工料清单表
  371. // renderData.materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
  372. // renderData.materialNotJoinListData = await ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } });
  373. renderData.materialType = JSON.stringify(materialConst);
  374. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.list);
  375. // 获取清单数据
  376. // renderData.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  377. // renderData.pos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  378. // 获取所选期数据并合并相加同类清单项
  379. // renderData.curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, ctx.material.stage_id);
  380. // renderData.curPosData = await ctx.service.stagePos.getStagesData(ctx.tender.id, ctx.material.stage_id, 'list');
  381. await this.layout('material/list.ejs', renderData, 'material/list_modal.ejs');
  382. } catch (err) {
  383. this.log(err);
  384. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  385. }
  386. }
  387. /**
  388. * 调差清单页面 (Get)
  389. * @param {Object} ctx - egg全局变量
  390. * @return {Promise<void>}
  391. */
  392. async loadListsData(ctx) {
  393. try {
  394. // const data = JSON.parse(ctx.request.body.data);
  395. // const filter = data.filter.split(';');
  396. const responseData = { err: 0, msg: '', data: {} };
  397. // 取所有已被调用的工料清单表
  398. responseData.data.materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
  399. responseData.data.materialNotJoinListData = await ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } });
  400. // 获取清单数据
  401. responseData.data.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  402. responseData.data.pos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  403. // 获取所选期数据并合并相加同类清单项
  404. responseData.data.curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, ctx.material.stage_id);
  405. responseData.data.curPosData = await ctx.service.stagePos.getStagesData(ctx.tender.id, ctx.material.stage_id, 'list');
  406. ctx.body = responseData;
  407. } catch (err) {
  408. this.log(err);
  409. ctx.body = { err: 1, msg: err.toString(), data: null };
  410. }
  411. }
  412. /**
  413. * 指数调差页面 (Get)
  414. * @param {Object} ctx - egg全局变量
  415. * @return {Promise<void>}
  416. */
  417. async exponent(ctx) {
  418. try {
  419. await this._checkExponentExist(ctx);
  420. await this._getMaterialAuditViewData(ctx);
  421. const renderData = await this._getDefaultRenderData(ctx);
  422. const stage_list = await ctx.service.stage.getStageMsgByStageId(ctx.material.stage_id);
  423. renderData.ex_calc = materialConst.ex_calc;
  424. if (!ctx.material.ex_calc) {
  425. const calcBase = await ctx.service.stage.getMaterialCalcBase(stage_list, ctx.tender.info);
  426. for (const bq of renderData.ex_calc) {
  427. const calc = _.find(calcBase, function(item) {
  428. return bq.code === item.code;
  429. });
  430. bq.value = calc.value;
  431. // if (calc.code === 'bqwc') {
  432. // ctx.material.ex_expr = calc.value.toString() + '*[0-1]';
  433. // ctx.material.ex_tp = this.ctx.helper.round(this.ctx.helper.mul(calc.value, -1), 2);
  434. // }
  435. }
  436. // 并更新至调差表中
  437. await ctx.service.material.update({ ex_calc: JSON.stringify(renderData.ex_calc) }, { id: ctx.material.id });
  438. } else {
  439. renderData.ex_calc = JSON.parse(ctx.material.ex_calc);
  440. }
  441. renderData.materialExponentData = await this._getMaterialExponentData(ctx);
  442. // 取对应期的截取上期的调差金额和应耗数量
  443. if (ctx.material.highOrder !== ctx.material.order) {
  444. for (const [mindex, me] of renderData.materialExponentData.entries()) {
  445. const result = await ctx.service.materialExponentHistory.getByMeId(ctx.material.id, ctx.material.order, me.id);
  446. _.forEach(result, function(value, key) {
  447. renderData.materialExponentData[mindex][key] = result ? result[key] : null;
  448. });
  449. }
  450. }
  451. // 取当前期截止上期含税金额
  452. renderData.pre_tp_hs = await ctx.service.material.getPreTpHs(ctx.tender.id, ctx.material.order);
  453. renderData.ex_pre_tp_hs = await ctx.service.material.getExPreTpHs(ctx.tender.id, ctx.material.order);
  454. renderData.materialType = materialConst;
  455. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.exponent);
  456. await this.layout('material/exponent.ejs', renderData, 'material/exponent_modal.ejs');
  457. } catch (err) {
  458. this.log(err);
  459. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  460. }
  461. }
  462. /**
  463. * 附件页面 (Get)
  464. * @param {Object} ctx - egg全局变量
  465. * @return {Promise<void>}
  466. */
  467. async file(ctx) {
  468. try {
  469. await this._getMaterialAuditViewData(ctx);
  470. const renderData = await this._getDefaultRenderData(ctx);
  471. const whiteList = this.ctx.app.config.multipart.whitelist;
  472. // 获取当前标段所有附件
  473. // const searchsql = { tid: ctx.tender.id };
  474. renderData.fileList = await ctx.service.materialFile.getAllMaterialFiles(ctx.tender.id);
  475. renderData.auditors = ctx.material.auditors.map(audit => audit.aid);
  476. // renderData.auditors = ctx.material.auditors2.map(audit => audit.aid);
  477. renderData.report_id = ctx.material.user_id;
  478. renderData.auditConst = auditConst;
  479. renderData.whiteList = whiteList;
  480. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.file);
  481. await this.layout('material/file.ejs', renderData, 'material/file_modal.ejs');
  482. } catch (err) {
  483. this.log(err);
  484. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  485. }
  486. }
  487. /**
  488. * 调差清单 - 工料操作 (Ajax)
  489. * @param ctx
  490. * @return {Promise<void>}
  491. */
  492. async saveListsData(ctx) {
  493. try {
  494. const data = JSON.parse(ctx.request.body.data);
  495. const responseData = {
  496. err: 0,
  497. msg: '',
  498. data: {},
  499. };
  500. switch (data.type) {
  501. case 'add':
  502. responseData.data = await ctx.service.materialList.add(data.postData);
  503. break;
  504. case 'del':
  505. await ctx.service.materialList.del(data.id, data.mb_id);
  506. break;
  507. case 'update':
  508. if (data.updateData.quantity === '' || data.updateData.quantity === null) {
  509. throw '请输入数量';
  510. }
  511. // 判断数量是否为数字
  512. if (isNaN(data.updateData.quantity)) {
  513. throw '不能输入其它非数字类型字符';
  514. }
  515. await ctx.service.materialList.save(data.updateData);
  516. break;
  517. case 'useOther':
  518. responseData.data = await ctx.service.materialList.addOther(data.postData);
  519. break;
  520. case 'join':
  521. await ctx.service.materialListNotjoin.del(data.select.id);
  522. break;
  523. case 'notjoin':
  524. responseData.data = await ctx.service.materialListNotjoin.add(data.select);
  525. break;
  526. case 'paste':
  527. await ctx.service.materialList.saveDatas(data.updateData);
  528. // 取所有工料表
  529. responseData.data = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
  530. break;
  531. case 'adds':
  532. responseData.data = await ctx.service.materialList.adds(data.postData);
  533. break;
  534. case 'dels':
  535. responseData.data = await ctx.service.materialList.dels(data.postData);
  536. break;
  537. case 'updates':
  538. if (data.updateData.quantity === '' || data.updateData.quantity === null) {
  539. throw '请输入数量';
  540. }
  541. // 判断数量是否为数字
  542. if (isNaN(data.updateData.quantity)) {
  543. throw '不能输入其它非数字类型字符';
  544. }
  545. responseData.data = await ctx.service.materialList.saves(data.updateData);
  546. break;
  547. case 'pastes':
  548. responseData.data = await ctx.service.materialList.savePastes(data.updateData);
  549. // 取所有工料表
  550. break;
  551. default: throw '参数有误';
  552. }
  553. ctx.body = responseData;
  554. } catch (err) {
  555. this.log(err);
  556. ctx.body = { err: 1, msg: err.toString(), data: null };
  557. }
  558. }
  559. /**
  560. * 调差工料 - 编辑工料项 (Ajax)
  561. * @param ctx
  562. * @return {Promise<void>}
  563. */
  564. async saveBillsData(ctx) {
  565. try {
  566. const data = JSON.parse(ctx.request.body.data);
  567. const responseData = {
  568. err: 0,
  569. msg: '',
  570. data: {},
  571. };
  572. switch (data.type) {
  573. case 'add':
  574. responseData.data = await ctx.service.materialBills.add();
  575. break;
  576. case 'del':
  577. responseData.data.m_tp = await ctx.service.materialBills.del(data.id);
  578. break;
  579. case 'changeOrder':
  580. responseData.data = await ctx.service.materialBills.changeOrder(data.id1, data.id2);
  581. break;
  582. case 'update':
  583. if (data.updateData.code === '' || data.updateData.code === null) {
  584. throw '请先输入编号';
  585. }
  586. // 判断编号为纯数字时,不能为小数
  587. if (!isNaN(data.updateData.code) && data.updateData.code.toString().indexOf('.') !== -1) {
  588. throw '编号为纯数字时,不能为小数';
  589. }
  590. if (data.updateData.code.length > 15) {
  591. throw '长度不超过15个字符';
  592. }
  593. // 判断编号是否已存在
  594. const billData = await ctx.service.materialBills.getAllDataByCondition({ where: { tid: ctx.tender.id, code: data.updateData.code } });
  595. if (billData.length > 1 || (billData.length > 0 && billData[0].id !== data.updateData.id)) {
  596. throw '该编号已存在,请重新输入。';
  597. }
  598. responseData.data.m_tp = await ctx.service.materialBills.save(data.updateData);
  599. break;
  600. case 'rate':
  601. // 判断数量是否为数字
  602. if (isNaN(data.rate)) {
  603. throw '不能输入其它非数字类型字符';
  604. }
  605. if (ctx.material.readOnly) {
  606. throw '无权操作';
  607. }
  608. await ctx.service.material.changeRate(data.rate);
  609. break;
  610. case 'expr':
  611. const materialCalculator = new MaterialCalculator(ctx, ctx.material.stage_id, ctx.tender.info);
  612. const quantity = await materialCalculator.calculateExpr(data.expr);
  613. // 更新quantity值并重新返回计算本期金额,截止本期金额
  614. const updateData = {
  615. id: data.id,
  616. quantity: quantity !== 0 ? this.ctx.helper.round(quantity, 3) : null,
  617. expr: data.expr,
  618. };
  619. responseData.data = await ctx.service.materialBills.updateFYQuantity(updateData);
  620. break;
  621. case 'paste':
  622. responseData.data.m_tp = await ctx.service.materialBills.saveDatas(data.updateData);
  623. // 根据期判断需要获取的工料信息值
  624. // const searchsql = { tid: ctx.tender.id };
  625. // if (ctx.material.highOrder !== ctx.material.order) {
  626. // const midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  627. // searchsql.mid = midList;
  628. // }
  629. // // 取所有工料表
  630. // responseData.data.info = await ctx.service.materialBills.getAllDataByCondition({ where: searchsql, orders: [['order', 'asc']] });
  631. responseData.data.info = await this._getMaterialBillsData(ctx);
  632. break;
  633. default: throw '参数有误';
  634. }
  635. ctx.body = responseData;
  636. } catch (err) {
  637. this.log(err);
  638. ctx.body = { err: 1, msg: err.toString(), data: null };
  639. }
  640. }
  641. /**
  642. * 调差工料 - 编辑月信息价 (Ajax)
  643. * @param ctx
  644. * @return {Promise<void>}
  645. */
  646. async saveMonth(ctx) {
  647. try {
  648. const data = JSON.parse(ctx.request.body.data);
  649. const responseData = {
  650. err: 0,
  651. msg: '',
  652. data: {},
  653. };
  654. const monthList = await ctx.service.materialMonth.getListByMid(ctx.material.id);
  655. const mbList = await this._getMaterialBillsData(ctx);
  656. switch (data.type) {
  657. case 'add':
  658. const tp = await ctx.service.materialMonth.add(data.updateData, monthList, mbList);
  659. const materialBillsData = await this._getMaterialBillsData(ctx);
  660. const monthsList = await this._getMaterialMonthsData(ctx, materialBillsData);
  661. responseData.data = {
  662. m_tp: tp,
  663. monthsList,
  664. };
  665. break;
  666. case 'del':
  667. const tp2 = await ctx.service.materialMonth.del(data.updateData.del_yearmonth, monthList, mbList);
  668. const materialBillsData2 = await this._getMaterialBillsData(ctx);
  669. const monthsList2 = await this._getMaterialMonthsData(ctx, materialBillsData2);
  670. responseData.data = {
  671. m_tp: tp2,
  672. monthsList: monthsList2,
  673. };
  674. break;
  675. case 'update':
  676. const tp3 = await ctx.service.materialMonth.save(data.updateData);
  677. responseData.data = {
  678. m_tp: tp3,
  679. };
  680. break;
  681. case 'updateOrigin':
  682. await ctx.service.materialBills.saveOrigin(data.updateData);
  683. break;
  684. case 'paste':
  685. const tp4 = await ctx.service.materialMonth.saveDatas(data.updateData, mbList);
  686. responseData.data = {
  687. m_tp: tp4,
  688. };
  689. break;
  690. case 'pasteOrigin':
  691. await ctx.service.materialBills.saveOrigins(data.updateData);
  692. break;
  693. default: throw '参数有误';
  694. }
  695. responseData.data.materialBillsData = await this._getMaterialBillsData(ctx);
  696. ctx.body = responseData;
  697. } catch (err) {
  698. this.log(err);
  699. ctx.body = { err: 1, msg: err.toString(), data: null };
  700. }
  701. }
  702. /**
  703. * 指数调差 - 编辑指数清单项 (Ajax)
  704. * @param ctx
  705. * @return {Promise<void>}
  706. */
  707. async saveExponentData(ctx) {
  708. try {
  709. const data = JSON.parse(ctx.request.body.data);
  710. const responseData = {
  711. err: 0,
  712. msg: '',
  713. data: {},
  714. };
  715. let ex_tp = ctx.material.ex_tp;
  716. let ex_expr = ctx.material.ex_expr;
  717. switch (data.type) {
  718. case 'add':
  719. responseData.data = await ctx.service.materialExponent.add();
  720. break;
  721. case 'del':
  722. [ex_tp, ex_expr] = await ctx.service.materialExponent.del(data.id);
  723. responseData.data.ex_tp = ex_tp;
  724. responseData.data.ex_expr = ex_expr;
  725. break;
  726. case 'update':
  727. [ex_tp, ex_expr] = await ctx.service.materialExponent.save(data.updateData);
  728. responseData.data.ex_tp = ex_tp;
  729. responseData.data.ex_expr = ex_expr;
  730. break;
  731. case 'rate':
  732. // 判断数量是否为数字
  733. if (isNaN(data.rate)) {
  734. throw '不能输入其它非数字类型字符';
  735. }
  736. if (ctx.material.readOnly) {
  737. throw '无权操作';
  738. }
  739. await ctx.service.material.changeRate(data.rate);
  740. break;
  741. case 'paste':
  742. [ex_tp, ex_expr] = await ctx.service.materialExponent.saveDatas(data.updateData);
  743. responseData.data.ex_tp = ex_tp;
  744. responseData.data.ex_expr = ex_expr;
  745. // 取所有指数清单
  746. responseData.data.info = await this._getMaterialExponentData(ctx);
  747. break;
  748. case 'ex_calc':
  749. // 判断数量是否为数字
  750. [ex_tp, ex_expr] = await ctx.service.material.changeExCalc(data.updateData);
  751. responseData.data.ex_tp = ex_tp;
  752. responseData.data.ex_expr = ex_expr;
  753. break;
  754. default: throw '参数有误';
  755. }
  756. ctx.body = responseData;
  757. } catch (err) {
  758. this.log(err);
  759. ctx.body = { err: 1, msg: err.toString(), data: null };
  760. }
  761. }
  762. // 审批相关
  763. /**
  764. * 添加审批人
  765. * @param ctx
  766. * @return {Promise<void>}
  767. */
  768. async addAudit(ctx) {
  769. try {
  770. const data = JSON.parse(ctx.request.body.data);
  771. const id = this.app._.toInteger(data.auditorId);
  772. if (isNaN(id) || id <= 0) {
  773. throw '参数错误';
  774. }
  775. // 检查权限等
  776. if (ctx.material.user_id !== ctx.session.sessionUser.accountId) {
  777. throw '您无权添加审核人';
  778. }
  779. if (ctx.material.status === auditConst.status.checking || ctx.material.status === auditConst.status.checked) {
  780. throw '当前不允许添加审核人';
  781. }
  782. ctx.material.auditorList = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  783. // 检查审核人是否已存在
  784. const exist = this.app._.find(ctx.material.auditorList, { aid: id });
  785. if (exist) {
  786. throw '该审核人已存在,请勿重复添加';
  787. }
  788. const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.material, sp_status: shenpiConst.sp_status.gdzs });
  789. const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.material === shenpiConst.sp_status.gdzs ? 1 : 0;
  790. const result = await ctx.service.materialAudit.addAuditor(ctx.material.id, id, ctx.material.times, is_gdzs);
  791. if (!result) {
  792. throw '添加审核人失败';
  793. }
  794. const auditors = await ctx.service.materialAudit.getAuditorsWithOwner(ctx.material.id, ctx.material.times);
  795. ctx.body = { err: 0, msg: '', data: auditors };
  796. } catch (err) {
  797. this.log(err);
  798. ctx.body = { err: 1, msg: err.toString(), data: null };
  799. }
  800. }
  801. /**
  802. * 移除审批人
  803. * @param ctx
  804. * @return {Promise<void>}
  805. */
  806. async deleteAudit(ctx) {
  807. try {
  808. const data = JSON.parse(ctx.request.body.data);
  809. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  810. if (isNaN(id) || id <= 0) {
  811. throw '参数错误';
  812. }
  813. const result = await ctx.service.materialAudit.deleteAuditor(ctx.material.id, id, ctx.material.times);
  814. if (!result) {
  815. throw '移除审核人失败';
  816. }
  817. const auditors = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  818. ctx.body = { err: 0, msg: '', data: auditors };
  819. } catch (err) {
  820. ctx.body = { err: 1, msg: err.toString(), data: null };
  821. }
  822. }
  823. /**
  824. * 上报和重新上报
  825. * @param ctx
  826. * @return {Promise<void>}
  827. */
  828. async startAudit(ctx) {
  829. try {
  830. // 检查权限等
  831. if (!ctx.material) {
  832. throw '数据错误';
  833. }
  834. if (ctx.material.user_id !== ctx.session.sessionUser.accountId) {
  835. throw '您无权上报该期数据';
  836. }
  837. if (ctx.material.status === auditConst.status.checking || ctx.material.status === auditConst.status.checked) {
  838. throw '该材料调差期数据当前无法上报';
  839. }
  840. await ctx.service.materialAudit.start(ctx.material.id, ctx.material.times);
  841. ctx.redirect(ctx.request.header.referer);
  842. } catch (err) {
  843. this.log(err);
  844. ctx.session.postError = err.toString();
  845. ctx.redirect(ctx.request.header.referer);
  846. }
  847. }
  848. /**
  849. * 审批
  850. * @param ctx
  851. * @return {Promise<void>}
  852. */
  853. async checkAudit(ctx) {
  854. try {
  855. if (!this.ctx.material || this.ctx.material.status !== auditConst.status.checking) {
  856. throw '当前材料调差期数据有误';
  857. }
  858. if (!this.ctx.material.curAuditor || this.ctx.material.curAuditor.aid !== ctx.session.sessionUser.accountId) {
  859. throw '您无权进行该操作';
  860. }
  861. const data = {
  862. checkType: parseInt(ctx.request.body.checkType),
  863. opinion: ctx.request.body.opinion,
  864. };
  865. if (!data.checkType || isNaN(data.checkType)) {
  866. throw '提交数据错误';
  867. }
  868. if (data.checkType === auditConst.status.checkNo) {
  869. if (!data.checkType || isNaN(data.checkType)) {
  870. throw '提交数据错误';
  871. }
  872. }
  873. await ctx.service.materialAudit.check(ctx.material.id, data, ctx.material.times);
  874. ctx.redirect(ctx.request.header.referer);
  875. } catch (err) {
  876. this.log(err);
  877. ctx.session.postError = err.toString();
  878. ctx.redirect(ctx.request.header.referer);
  879. }
  880. }
  881. async _checkMaterialFileCanModify(ctx) {
  882. // 检查登录用户,是否可操作
  883. const accountId = ctx.session.sessionUser.accountId;
  884. const auditors = await ctx.service.materialAudit.getAuditorsWithOwner(ctx.material.id, ctx.material.times);
  885. // console.log(auditors);
  886. if (auditors.findIndex(item => item.aid === accountId) === -1 && !ctx.tender.touristPermission.file) {
  887. throw '该调差期当前您无权操作';
  888. }
  889. // if (!ctx.material.curAuditor) {
  890. // if (ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo && accountId === ctx.material.user_id) {
  891. // return;
  892. // }
  893. // throw '该调差期当前您无权操作';
  894. // } else {
  895. // if (ctx.material.curAuditor.aid === accountId) return;
  896. // throw '该调差期当前您无权操作';
  897. // }
  898. }
  899. /**
  900. * 上传附件
  901. * @param {*} ctx 上下文
  902. */
  903. async upload(ctx) {
  904. let stream;
  905. try {
  906. await this._checkMaterialFileCanModify(ctx);
  907. const parts = this.ctx.multipart({
  908. autoFields: true,
  909. });
  910. const files = [];
  911. const create_time = Date.parse(new Date()) / 1000;
  912. let idx = 0;
  913. const extra_upload = ctx.material.status === auditConst.status.checked;
  914. while ((stream = await parts()) !== undefined) {
  915. if (!stream.filename) {
  916. // 如果没有传入直接返回
  917. return;
  918. }
  919. const fileInfo = path.parse(stream.filename);
  920. // const filepath = path.join('public/upload', this.ctx.tender.id.toString(), 'tc', 'fujian_' + create_time + fileInfo.ext);
  921. const filepath = `public/upload/${this.ctx.tender.id.toString()}/tc/fujian_${create_time + idx.toString() + fileInfo.ext}`;
  922. await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, 'app', filepath));
  923. files.push({ filepath, name: stream.filename, ext: fileInfo.ext });
  924. ++idx;
  925. }
  926. const upload_time = this.ctx.helper.dateTran(new Date());
  927. const payload = files.map(file => {
  928. let idx;
  929. if (Array.isArray(parts.field.name)) {
  930. idx = parts.field.name.findIndex(name => name === file.name);
  931. } else {
  932. idx = 'isString';
  933. }
  934. const newFile = {
  935. tid: ctx.tender.id,
  936. user_id: ctx.session.sessionUser.accountId,
  937. mid: ctx.material.id,
  938. s_order: ctx.params.order,
  939. upload_time,
  940. filepath: file.filepath,
  941. file_size: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
  942. file_name: file.name,
  943. fileext: file.ext,
  944. extra_upload,
  945. };
  946. return newFile;
  947. });
  948. // 执行文件信息写入数据库
  949. await ctx.service.materialFile.saveFileMsgToDb(payload);
  950. // 将最新的当前标段的所有文件信息返回
  951. const data = await ctx.service.materialFile.getAllMaterialFiles(ctx.tender.id);
  952. ctx.body = { err: 0, msg: '', data };
  953. } catch (err) {
  954. stream && (await sendToWormhole(stream));
  955. this.log(err);
  956. ctx.body = { err: 1, msg: err.toString(), data: null };
  957. }
  958. }
  959. /**
  960. * 下载附件
  961. * @param {Object} ctx - egg全局变量
  962. * @return {void}
  963. */
  964. async downloadFile(ctx) {
  965. const id = ctx.params.fid;
  966. if (id) {
  967. try {
  968. const fileInfo = await ctx.service.materialFile.getDataById(id);
  969. if (fileInfo !== undefined && fileInfo !== '') {
  970. const fileName = path.join(__dirname, '../', fileInfo.filepath);
  971. // 解决中文无法下载问题
  972. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  973. let disposition = '';
  974. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  975. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.file_name);
  976. } else if (userAgent.indexOf('firefox') >= 0) {
  977. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.file_name) + '"';
  978. } else {
  979. /* safari等其他非主流浏览器只能自求多福了 */
  980. disposition = 'attachment; filename=' + new Buffer(fileInfo.file_name).toString('binary');
  981. }
  982. ctx.response.set({
  983. 'Content-Type': 'application/octet-stream',
  984. 'Content-Disposition': disposition,
  985. 'Content-Length': fileInfo.file_size,
  986. });
  987. ctx.body = await fs.createReadStream(fileName);
  988. } else {
  989. throw '不存在该文件';
  990. }
  991. } catch (err) {
  992. this.log(err);
  993. this.setMessage(err.toString(), this.messageType.ERROR);
  994. }
  995. }
  996. }
  997. /**
  998. * 查看当前标段以往所有期的附件
  999. * @param {Object} ctx 上下文
  1000. */
  1001. async getCurMatericalFiles(ctx) {
  1002. try {
  1003. // const { isCheck } = JSON.parse(ctx.request.body.data);
  1004. const data = await ctx.service.materialFile.getAllMaterialFiles(ctx.tender.id);
  1005. ctx.body = { err: 0, msg: '', data };
  1006. } catch (err) {
  1007. this.log(err);
  1008. ctx.body = { err: 1, msg: err.toString(), data: null };
  1009. }
  1010. }
  1011. /**
  1012. * 删除附件
  1013. * @param {Ojbect} ctx 上下文
  1014. */
  1015. async deleteFile(ctx) {
  1016. try {
  1017. const { data } = ctx.request.body;
  1018. const { id } = JSON.parse(data);
  1019. const fileInfo = await ctx.service.materialFile.getMaterialFileById(id);
  1020. if (!fileInfo || !Object.keys(fileInfo).length) {
  1021. throw '该文件不存在';
  1022. }
  1023. if (!fileInfo.extra_upload && ctx.material.status === auditConst.status.checked) {
  1024. throw '无权限删除';
  1025. }
  1026. if (fileInfo) {
  1027. // 先删除文件
  1028. await fs.unlinkSync(path.resolve(this.app.baseDir, './app', fileInfo.filepath));
  1029. // 再删除数据库
  1030. await ctx.service.materialFile.delete(id);
  1031. } else {
  1032. throw '不存在该文件';
  1033. }
  1034. ctx.body = { err: 0, msg: '请求成功' };
  1035. } catch (err) {
  1036. this.log(err);
  1037. ctx.body = { err: 1, msg: err.toString(), data: null };
  1038. }
  1039. }
  1040. /**
  1041. * 批量下载 - 压缩成zip文件返回
  1042. * @param {Object} ctx - 全局上下文
  1043. */
  1044. async downloadZip(ctx) {
  1045. const zipFilename = `${ctx.tender.data.name}-材料调差-${ctx.params.order}-附件.zip`;
  1046. const time = Date.now();
  1047. const zipPath = `app/public/upload/${ctx.tender.id}/tc/fu_jian_zip${time}.zip`;
  1048. const responseData = {
  1049. err: 0,
  1050. msg: '',
  1051. };
  1052. try {
  1053. // const fileIds = JSON.parse(ctx.request.query.fileIds);
  1054. const { fileIds = [] } = JSON.parse(ctx.request.body.data);
  1055. const size = await ctx.service.materialFile.compressedFile(fileIds, zipPath);
  1056. // 解决中文无法下载问题
  1057. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  1058. let disposition = '';
  1059. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  1060. disposition = 'attachment; filename=' + encodeURIComponent(zipFilename);
  1061. } else if (userAgent.indexOf('firefox') >= 0) {
  1062. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(zipFilename) + '"';
  1063. } else {
  1064. /* safari等其他非主流浏览器只能自求多福了 */
  1065. disposition = 'attachment; filename=' + new Buffer(zipFilename).toString('binary');
  1066. }
  1067. ctx.response.set({
  1068. 'Content-Type': 'application/octet-stream',
  1069. 'Content-Disposition': disposition,
  1070. 'Content-Length': size,
  1071. });
  1072. const readStream = fs.createReadStream(path.join(this.app.baseDir, zipPath));
  1073. ctx.body = readStream;
  1074. readStream.on('close', () => {
  1075. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1076. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1077. }
  1078. });
  1079. // fs的错误不能被try catch捕捉
  1080. readStream.on('error', err => {
  1081. this.log(err);
  1082. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1083. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1084. }
  1085. responseData.err = 1;
  1086. responseData.msg = err.toString();
  1087. ctx.body = responseData;
  1088. });
  1089. } catch (err) {
  1090. this.log(err);
  1091. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1092. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1093. }
  1094. this.setMessage(err.toString(), this.messageType.ERROR);
  1095. responseData.err = 1;
  1096. responseData.msg = err.toString();
  1097. ctx.body = responseData;
  1098. }
  1099. }
  1100. }
  1101. return MaterialController;
  1102. };