material_controller.js 48 KB

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