material_controller.js 66 KB

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