material_controller.js 58 KB

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