material_controller.js 90 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697989910010110210310410510610710810911011111211311411511611711811912012112212312412512612712812913013113213313413513613713813914014114214314414514614714814915015115215315415515615715815916016116216316416516616716816917017117217317417517617717817918018118218318418518618718818919019119219319419519619719819920020120220320420520620720820921021121221321421521621721821922022122222322422522622722822923023123223323423523623723823924024124224324424524624724824925025125225325425525625725825926026126226326426526626726826927027127227327427527627727827928028128228328428528628728828929029129229329429529629729829930030130230330430530630730830931031131231331431531631731831932032132232332432532632732832933033133233333433533633733833934034134234334434534634734834935035135235335435535635735835936036136236336436536636736836937037137237337437537637737837938038138238338438538638738838939039139239339439539639739839940040140240340440540640740840941041141241341441541641741841942042142242342442542642742842943043143243343443543643743843944044144244344444544644744844945045145245345445545645745845946046146246346446546646746846947047147247347447547647747847948048148248348448548648748848949049149249349449549649749849950050150250350450550650750850951051151251351451551651751851952052152252352452552652752852953053153253353453553653753853954054154254354454554654754854955055155255355455555655755855956056156256356456556656756856957057157257357457557657757857958058158258358458558658758858959059159259359459559659759859960060160260360460560660760860961061161261361461561661761861962062162262362462562662762862963063163263363463563663763863964064164264364464564664764864965065165265365465565665765865966066166266366466566666766866967067167267367467567667767867968068168268368468568668768868969069169269369469569669769869970070170270370470570670770870971071171271371471571671771871972072172272372472572672772872973073173273373473573673773873974074174274374474574674774874975075175275375475575675775875976076176276376476576676776876977077177277377477577677777877978078178278378478578678778878979079179279379479579679779879980080180280380480580680780880981081181281381481581681781881982082182282382482582682782882983083183283383483583683783883984084184284384484584684784884985085185285385485585685785885986086186286386486586686786886987087187287387487587687787887988088188288388488588688788888989089189289389489589689789889990090190290390490590690790890991091191291391491591691791891992092192292392492592692792892993093193293393493593693793893994094194294394494594694794894995095195295395495595695795895996096196296396496596696796896997097197297397497597697797897998098198298398498598698798898999099199299399499599699799899910001001100210031004100510061007100810091010101110121013101410151016101710181019102010211022102310241025102610271028102910301031103210331034103510361037103810391040104110421043104410451046104710481049105010511052105310541055105610571058105910601061106210631064106510661067106810691070107110721073107410751076107710781079108010811082108310841085108610871088108910901091109210931094109510961097109810991100110111021103110411051106110711081109111011111112111311141115111611171118111911201121112211231124112511261127112811291130113111321133113411351136113711381139114011411142114311441145114611471148114911501151115211531154115511561157115811591160116111621163116411651166116711681169117011711172117311741175117611771178117911801181118211831184118511861187118811891190119111921193119411951196119711981199120012011202120312041205120612071208120912101211121212131214121512161217121812191220122112221223122412251226122712281229123012311232123312341235123612371238123912401241124212431244124512461247124812491250125112521253125412551256125712581259126012611262126312641265126612671268126912701271127212731274127512761277127812791280128112821283128412851286128712881289129012911292129312941295129612971298129913001301130213031304130513061307130813091310131113121313131413151316131713181319132013211322132313241325132613271328132913301331133213331334133513361337133813391340134113421343134413451346134713481349135013511352135313541355135613571358135913601361136213631364136513661367136813691370137113721373137413751376137713781379138013811382138313841385138613871388138913901391139213931394139513961397139813991400140114021403140414051406140714081409141014111412141314141415141614171418141914201421142214231424142514261427142814291430143114321433143414351436143714381439144014411442144314441445144614471448144914501451145214531454145514561457145814591460146114621463146414651466146714681469147014711472147314741475147614771478147914801481148214831484148514861487148814891490149114921493149414951496149714981499150015011502150315041505150615071508150915101511151215131514151515161517151815191520152115221523152415251526152715281529153015311532153315341535153615371538153915401541154215431544154515461547154815491550155115521553155415551556155715581559156015611562156315641565156615671568156915701571157215731574157515761577157815791580158115821583158415851586158715881589159015911592159315941595159615971598159916001601160216031604160516061607160816091610161116121613161416151616161716181619162016211622162316241625162616271628162916301631163216331634163516361637163816391640164116421643164416451646164716481649165016511652165316541655165616571658165916601661166216631664166516661667166816691670167116721673167416751676167716781679168016811682168316841685168616871688168916901691169216931694169516961697169816991700170117021703170417051706170717081709171017111712171317141715171617171718171917201721172217231724172517261727172817291730173117321733173417351736173717381739174017411742174317441745174617471748174917501751
  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. if (!ctx.session.sessionProject.page_show.openMaterial) {
  45. throw '该功能已关闭';
  46. }
  47. // 列展示
  48. const tenderMsg = await ctx.service.tender.getTender(ctx.tender.id, ['material_col_show']);
  49. const material_col_show = tenderMsg.material_col_show ? JSON.parse(tenderMsg.material_col_show) : ctx.helper._.cloneDeep(tenderConst.materialColShow);
  50. const renderData = {
  51. tender: ctx.tender.data,
  52. tenderMenu: this.menu.tenderMenu,
  53. preUrl: '/tender/' + ctx.tender.id,
  54. auditConst,
  55. auditConst2: JSON.stringify(auditConst),
  56. materialColShow: material_col_show,
  57. qtySourceConst: materialConst.qty_source,
  58. qtySourceValueConst: materialConst.qty_source_value,
  59. };
  60. let openMaterialTax = ctx.session.sessionProject.page_show.openMaterialTax;
  61. let allMaterialTax = true;
  62. renderData.materials = await ctx.service.material.getValidMaterials(ctx.tender.id);
  63. const lastMaterial = renderData.materials.length > 0 ? renderData.materials[0] : null;
  64. if (lastMaterial && (lastMaterial.status === auditConst.status.uncheck || lastMaterial.status === auditConst.status.checkNo) && lastMaterial.material_tax !== openMaterialTax) {
  65. await ctx.service.material.updateMaterialTax(lastMaterial.id, openMaterialTax);
  66. lastMaterial.material_tax = openMaterialTax;
  67. }
  68. // 获取未选中和已完成的计量期
  69. const stages = await ctx.service.stage.getAllDataByCondition({ where: { tid: ctx.tender.id, status: auditStageConst.status.checked } });
  70. const materialTotalPrice = {
  71. m_tp: 0,
  72. tax_tp: 0,
  73. ex_tp: 0,
  74. ex_tax_tp: 0,
  75. m_tax_tp: 0,
  76. };
  77. for (const s of renderData.materials) {
  78. // s.curAuditor = null;
  79. // 根据期状态返回展示用户
  80. s.curAuditor = await ctx.service.materialAudit.getAuditorByStatus(s.id, s.status, s.times);
  81. if (!ctx.session.sessionProject.page_show.openMaterialStageRepeat) {
  82. const materialStageList = s.stage_id.split(',');
  83. for (const ms of materialStageList) {
  84. const index = stages.findIndex(function(item) {
  85. return item.id === parseInt(ms);
  86. });
  87. stages.splice(index, 1);
  88. }
  89. }
  90. if (allMaterialTax && s.material_tax === 0) {
  91. allMaterialTax = false;
  92. }
  93. if (!openMaterialTax && s.material_tax === 1) {
  94. openMaterialTax = 1;
  95. }
  96. s.decimal = s.decimal ? JSON.parse(s.decimal) : materialConst.decimal;
  97. materialTotalPrice.m_tp = ctx.helper.add(materialTotalPrice.m_tp, ctx.helper.round(s.m_tp, s.decimal.tp));
  98. materialTotalPrice.tax_tp = !s.material_tax ? ctx.helper.add(materialTotalPrice.tax_tp, ctx.helper.round(ctx.helper.mul(s.m_tp, 1 + s.rate / 100), s.decimal.tp)) : materialTotalPrice.tax_tp;
  99. materialTotalPrice.ex_tp = ctx.helper.add(materialTotalPrice.ex_tp, ctx.helper.round(s.ex_tp, s.decimal.tp));
  100. materialTotalPrice.ex_tax_tp = ctx.helper.add(materialTotalPrice.ex_tax_tp, ctx.helper.round(ctx.helper.mul(s.ex_tp, 1 + s.exponent_rate / 100), s.decimal.tp));
  101. materialTotalPrice.m_tax_tp = s.material_tax ? ctx.helper.add(materialTotalPrice.m_tax_tp, ctx.helper.round(s.m_tax_tp, s.decimal.tp)) : materialTotalPrice.m_tax_tp;
  102. }
  103. materialTotalPrice.total_tp = ctx.helper.add(materialTotalPrice.m_tp, materialTotalPrice.ex_tp);
  104. materialTotalPrice.total_tax_tp = ctx.helper.add(materialTotalPrice.tax_tp, materialTotalPrice.ex_tax_tp);
  105. if (lastMaterial && lastMaterial.status === auditConst.status.checked && ctx.session.sessionUser.accountId === ctx.tender.data.user_id && stages.length > 0) {
  106. renderData.lastMaterialList = lastMaterial.is_new ? await ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: ctx.tender.id } }) : await ctx.service.materialList.getMaterialData(ctx.tender.id, lastMaterial.id);
  107. } else {
  108. renderData.lastMaterialList = null;
  109. }
  110. renderData.stages = stages;
  111. renderData.openMaterialTax = openMaterialTax;
  112. renderData.allMaterialTax = allMaterialTax;
  113. renderData.materialTotalPrice = materialTotalPrice;
  114. await this.layout('material/index.ejs', renderData, 'material/modal.ejs');
  115. } catch (err) {
  116. this.log(err);
  117. ctx.session.postError = err.toString();
  118. ctx.redirect(this.menu.menu.dashboard.url);
  119. }
  120. }
  121. /**
  122. * 期审批流程(Get)
  123. * @param ctx
  124. * @return {Promise<void>}
  125. */
  126. async materialAuditors(ctx) {
  127. try {
  128. if (!ctx.session.sessionProject.page_show.openMaterial) {
  129. throw '该功能已关闭';
  130. }
  131. const responseData = {
  132. err: 0, msg: '', data: {},
  133. };
  134. const order = JSON.parse(ctx.request.body.data).order;
  135. const tenderId = ctx.params.id;
  136. const materialInfo = await ctx.service.material.getDataByCondition({ tid: tenderId, order });
  137. // 获取审批流程中右边列表
  138. const auditHistory = [];
  139. const times = materialInfo.status === auditConst.status.checkNo ? materialInfo.times - 1 : materialInfo.times;
  140. if (times >= 1) {
  141. for (let i = 1; i <= times; i++) {
  142. auditHistory.push(await ctx.service.materialAudit.getAuditors(materialInfo.id, i));
  143. }
  144. }
  145. responseData.data.auditHistory = auditHistory;
  146. // 获取审批流程中左边列表
  147. responseData.data.auditors = await ctx.service.materialAudit.getAuditorsWithOwner(materialInfo.id, times);
  148. responseData.data.user = await ctx.service.projectAccount.getAccountInfoById(materialInfo.user_id);
  149. // 获取原报信息
  150. // const materialAuditor = await ctx.service.projectAccount.getAccountInfoById(materialInfo.user_id);
  151. // responseData.data.materialAuditor = materialAuditor;
  152. ctx.body = responseData;
  153. } catch (error) {
  154. this.log(error);
  155. ctx.body = { err: 1, msg: error.toString(), data: null };
  156. }
  157. }
  158. /**
  159. * 编辑期(Post)
  160. * @param ctx
  161. * @return {Promise<void>}
  162. */
  163. async save(ctx) {
  164. try {
  165. if (!ctx.session.sessionProject.page_show.openMaterial) {
  166. throw '该功能已关闭';
  167. }
  168. const data = {
  169. mid: ctx.request.body.mid,
  170. period: ctx.request.body.period,
  171. };
  172. const material = await ctx.service.material.getDataById(data.mid);
  173. if (!material) {
  174. throw '提交数据错误';
  175. }
  176. // if (stage.status === auditConst.status.checked) {
  177. // throw '该计量期当前不可编辑';
  178. // }
  179. // if (ctx.session.sessionUser.accountId !== stage.user_id) {
  180. // throw '您无权修改该数据';
  181. // }
  182. await this.ctx.service.material.saveMaterial(data.mid, data.period);
  183. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  184. } catch (err) {
  185. this.log(err);
  186. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  187. }
  188. }
  189. /**
  190. * 编辑期数据(Post)
  191. * @param ctx
  192. * @return {Promise<void>}
  193. */
  194. async saveData(ctx) {
  195. try {
  196. if (!ctx.session.sessionProject.page_show.openMaterial) {
  197. throw '该功能已关闭';
  198. }
  199. const data = JSON.parse(ctx.request.body.data);
  200. const responseData = {
  201. err: 0,
  202. msg: '',
  203. data: {},
  204. };
  205. switch (data.type) {
  206. case 'material_col_set':
  207. responseData.data = await ctx.service.tender.saveTenderData(ctx.tender.id, { material_col_show: JSON.stringify(data.material_col_data) });
  208. break;
  209. default: throw '参数有误';
  210. }
  211. ctx.body = responseData;
  212. } catch (err) {
  213. this.log(err);
  214. ctx.body = { err: 1, msg: err.toString(), data: null };
  215. }
  216. }
  217. /**
  218. * 新增期(Post)
  219. * @param ctx
  220. * @return {Promise<void>}
  221. */
  222. async add(ctx) {
  223. try {
  224. if (!ctx.session.sessionProject.page_show.openMaterial) {
  225. throw '该功能已关闭';
  226. }
  227. if (ctx.session.sessionUser.accountId !== ctx.tender.data.user_id) {
  228. throw '您无权创建材料调差期';
  229. }
  230. const data = JSON.parse(ctx.request.body.data);
  231. if (data.s_order === '') {
  232. throw '没有选中计量期';
  233. }
  234. // 调差期是否存在审批或待上报,存在则无法重复添加
  235. const doingMaterial = await ctx.service.material.getDataByCondition({ tid: ctx.tender.id, status: [auditConst.status.uncheck, auditConst.status.checking, auditConst.status.checkNo] });
  236. if (doingMaterial) {
  237. throw '存在待上报或审批中的调差期,请勿重复生成';
  238. }
  239. // 参考变更令的做法,在创建新一期预付款时,需要copy前一个预付款报表的签名信息
  240. const lastMaterial = await ctx.service.material.getLastestMaterial(ctx.tender.id, true);
  241. const newMaterial = await ctx.service.material.addMaterial(ctx.tender.id, data);
  242. if (!newMaterial) {
  243. throw '新增材料调差期失败,请重试';
  244. }
  245. if (lastMaterial) {
  246. await ctx.service.roleRptRel.createRoleRelationshipFromOtherBz(ctx.tender.id, '-500', newMaterial.id, lastMaterial.id);
  247. }
  248. // ctx.redirect('/tender/' + ctx.tender.id + '/measure/material/' + newMaterial.order);
  249. ctx.body = { err: 0, msg: '', data: newMaterial };
  250. } catch (err) {
  251. this.log(err);
  252. // ctx.redirect(ctx.request.header.referer);
  253. ctx.body = { err: 1, msg: err.toString(), data: null };
  254. }
  255. }
  256. /**
  257. * 删除期(Post)
  258. * @param ctx
  259. * @return {Promise<void>}
  260. */
  261. async delete(ctx) {
  262. try {
  263. if (!ctx.session.sessionProject.page_show.openMaterial) {
  264. throw '该功能已关闭';
  265. }
  266. const material_id = ctx.request.body.material_id;
  267. const materialInfo = await ctx.service.material.getDataById(material_id);
  268. // 获取最新的期数
  269. const material_highOrder = await ctx.service.material.count({
  270. tid: ctx.tender.id,
  271. });
  272. 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) {
  273. throw '您无权删除材料调差期';
  274. }
  275. const result = await ctx.service.material.deleteMaterial(material_id);
  276. if (!result) {
  277. throw '删除材料调差期失败,请重试';
  278. }
  279. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material/');
  280. } catch (err) {
  281. this.log(err);
  282. ctx.redirect(ctx.request.header.referer);
  283. }
  284. }
  285. /**
  286. * 获取通用的renderData(用于layout, Menu, subMenu部分)
  287. * @param ctx
  288. * @return {{tender, tenderMenu, auditConst}}
  289. * @private
  290. */
  291. async _getDefaultRenderData(ctx) {
  292. const data = {
  293. tender: ctx.tender.data,
  294. tenderMenu: JSON.parse(JSON.stringify(this.menu.stageMenu)),
  295. auditConst,
  296. measureType,
  297. preUrl: '/tender/' + ctx.tender.id + '/measure/material/' + ctx.params.order,
  298. material: ctx.material,
  299. shenpiConst,
  300. qtySourceConst: materialConst.qty_source,
  301. qtySourceValueConst: materialConst.qty_source_value,
  302. };
  303. if ((ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo) && (ctx.session.sessionUser.accountId === ctx.material.user_id || ctx.tender.isTourist)) {
  304. // data.accountGroup = accountGroup;
  305. // 获取所有项目参与者
  306. const accountList = await ctx.service.projectAccount.getAllDataByCondition({
  307. where: { project_id: ctx.session.sessionProject.id, enable: 1 },
  308. columns: ['id', 'name', 'company', 'role', 'enable', 'is_admin', 'account_group', 'mobile'],
  309. });
  310. data.accountList = accountList;
  311. const unitList = await ctx.service.constructionUnit.getAllDataByCondition({ where: { pid: ctx.session.sessionProject.id } });
  312. data.accountGroup = unitList.map(item => {
  313. const groupList = accountList.filter(item1 => item1.company === item.name);
  314. return { groupName: item.name, groupList };
  315. });
  316. }
  317. data.tenderMenu.back.children[0].url = '/tender/' + ctx.tender.id + '/measure/material';
  318. return data;
  319. }
  320. _materialReadOnly(material) {
  321. return material.status === auditConst.status.checked;
  322. }
  323. /**
  324. * 获取审批界面所需的 原报、审批人数据等
  325. * @param ctx
  326. * @return {Promise<void>}
  327. * @private
  328. */
  329. async _getMaterialAuditViewData(ctx) {
  330. const times = ctx.material.status === auditConst.status.checkNo ? ctx.material.times - 1 : ctx.material.times;
  331. ctx.material.user = await ctx.service.projectAccount.getAccountInfoById(ctx.material.user_id);
  332. ctx.material.auditHistory = [];
  333. if (times >= 1) {
  334. for (let i = 1; i <= times; i++) {
  335. ctx.material.auditHistory.push(await ctx.service.materialAudit.getAuditors(ctx.material.id, i));
  336. }
  337. }
  338. // 获取审批流程中左边列表
  339. ctx.material.auditors2 = ctx.material.status === auditConst.status.checkNo && ctx.material.user_id !== ctx.session.sessionUser.accountId ?
  340. await ctx.service.materialAudit.getAuditorsWithOwner(ctx.material.id, times) :
  341. await ctx.service.materialAudit.getAuditorsWithOwner(ctx.material.id, ctx.material.times);
  342. if (ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo) {
  343. ctx.material.auditorList = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  344. }
  345. // 是否已验证手机短信
  346. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  347. ctx.material.authMobile = pa.auth_mobile;
  348. }
  349. /**
  350. * 获取当前期工料列表信息
  351. * @param ctx
  352. * @return {Promise<void>}
  353. * @private
  354. */
  355. async _getMaterialBillsData(ctx) {
  356. // 根据期判断需要获取的工料信息值
  357. const searchsql = { tid: ctx.tender.id };
  358. if (ctx.material.highOrder !== ctx.material.order) {
  359. const midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  360. searchsql.mid = midList;
  361. }
  362. // 取所有工料表
  363. return await ctx.service.materialBills.getAllDataByCondition({ where: searchsql, orders: [['order', 'asc']] });
  364. }
  365. /**
  366. * 获取当前月信息价列表信息
  367. * @param ctx
  368. * @return {Promise<void>}
  369. * @private
  370. */
  371. async _getMaterialMonthsData(ctx, materialBillsData) {
  372. return await ctx.service.materialMonth.getMonthList(materialBillsData);
  373. // // 取月信息价表
  374. // const monthsList = [];
  375. // if (ctx.material.months) {
  376. // const material_month = ctx.material.months.split(',');
  377. // material_month.sort();
  378. // const materialMonthList = await ctx.service.materialMonth.getListByMid(ctx.material.id);
  379. // for (const mbd of materialBillsData) {
  380. // const one_mb = {
  381. // code: mbd.code,
  382. // name: mbd.name,
  383. // unit: mbd.unit,
  384. // origin: mbd.origin,
  385. // mb_id: mbd.id,
  386. // order: mbd.order,
  387. // };
  388. // for (const m of material_month) {
  389. // const mb_id = ctx.material.highOrder !== ctx.material.order ? mbd.mb_id : mbd.id;
  390. // const one_mm = _.find(materialMonthList, { mb_id, yearmonth: m });
  391. // one_mb[m] = one_mm.msg_tp;
  392. // }
  393. // monthsList.push(one_mb);
  394. // }
  395. // }
  396. // return monthsList;
  397. }
  398. /**
  399. * 检查旧数据是否存在指数法调差数据,没有自动添加定值
  400. * @param ctx
  401. * @return {Promise<void>}
  402. * @private
  403. */
  404. async _checkExponentExist(ctx) {
  405. const material_exponent_constant = await ctx.service.materialExponent.getDataByCondition({
  406. tid: ctx.tender.id,
  407. type: materialConst.ex_type[0].value,
  408. });
  409. // 不存在则生成指数调差清单表定值和历史期定值(防止变更定值发生变化)
  410. if (!material_exponent_constant) {
  411. await ctx.service.materialExponent.addOldData();
  412. }
  413. }
  414. /**
  415. * 获取当前期指数列表信息
  416. * @param ctx
  417. * @return {Promise<void>}
  418. * @private
  419. */
  420. async _getMaterialExponentData(ctx) {
  421. // 根据期判断需要获取的工料信息值
  422. const searchsql = { tid: ctx.tender.id };
  423. if (ctx.material.highOrder !== ctx.material.order) {
  424. const midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  425. searchsql.mid = midList;
  426. }
  427. // 取所有工料表
  428. return await ctx.service.materialExponent.getAllDataByCondition({ where: searchsql });
  429. }
  430. /**
  431. * 调差工料页面 (Get)
  432. * @param {Object} ctx - egg全局变量
  433. * @return {Promise<void>}
  434. */
  435. async info(ctx) {
  436. try {
  437. await this._getMaterialAuditViewData(ctx);
  438. await this._setEditTaxPermission(ctx);
  439. const renderData = await this._getDefaultRenderData(ctx);
  440. renderData.materialBillsData = await this._getMaterialBillsData(ctx);
  441. // 判断order是否重复,重复则重新排版并更新数据库
  442. await this.checkBillsOrder(ctx, renderData.materialBillsData);
  443. // 取对应期的截取上期的调差金额和应耗数量
  444. if (ctx.material.highOrder !== ctx.material.order) {
  445. for (const [mindex, mb] of renderData.materialBillsData.entries()) {
  446. const result = await ctx.service.materialBillsHistory.getByMbId(ctx.material.id, ctx.material.order, mb.id);
  447. _.forEach(result, function(value, key) {
  448. renderData.materialBillsData[mindex][key] = result ? result[key] : null;
  449. });
  450. }
  451. }
  452. // 取所有已被调用的工料清单表
  453. const materialListData = await ctx.service.materialList.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } });
  454. renderData.materialListData = ctx.helper._.uniqBy(materialListData, 'mb_id');
  455. // 基数
  456. // if (!ctx.material.readOnly) {
  457. const stage_list = await ctx.service.stage.getStageMsgByStageId(ctx.material.stage_id);
  458. renderData.calcBase = await ctx.service.stage.getMaterialCalcBase(stage_list, ctx.tender.info);
  459. renderData.materialStageData = ctx.material.is_stage_self ? await ctx.service.materialStage.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } }) : [];
  460. renderData.materialStageBillsData = ctx.material.is_stage_self ? await ctx.service.materialStageBills.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } }) : [];
  461. if (ctx.material.is_stage_self) {
  462. const calcBaseList = [];
  463. for (const ms of renderData.materialStageData) {
  464. const stage_info = await ctx.service.stage.getStageMsgByStageId(ms.sid);
  465. calcBaseList.push({
  466. ms_id: ms.id,
  467. calcBase: await ctx.service.stage.getMaterialCalcBase(stage_info, ctx.tender.info),
  468. });
  469. }
  470. renderData.calcBase = calcBaseList;
  471. }
  472. // }
  473. const [stdBills, stdChapters, gljLists] = await this.ctx.service.valuation.getValuationStdList(
  474. ctx.tender.data.valuation, ctx.tender.data.measure_type);
  475. renderData.gljLists = gljLists;
  476. // 取当前期截止上期含税金额
  477. renderData.material.m_tax_tp = renderData.material.m_tax_tp ? renderData.material.m_tax_tp : renderData.material.m_tp;
  478. renderData.pre_tp_hs = await ctx.service.material.getPreTpHs(ctx.tender.id, ctx.material.order, ctx.material.decimal.tp);
  479. renderData.ex_pre_tp_hs = await ctx.service.material.getExPreTpHs(ctx.tender.id, ctx.material.order, ctx.material.decimal.tp);
  480. // renderData.tax_pre_tp_hs = await ctx.service.material.getTaxPreTpHs(ctx.tender.id, ctx.material.order);
  481. renderData.months = ctx.material.months ? ctx.material.months.split(',') : [];
  482. renderData.monthsList = await this._getMaterialMonthsData(ctx, renderData.materialBillsData);
  483. renderData.materialType = JSON.stringify(materialConst);
  484. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.info);
  485. // 判断之前期有无调用过材料税
  486. renderData.old_had_tax = await ctx.service.material.getOldMaterialTax(ctx.tender.id, ctx.params.order);
  487. await this.layout('material/info.ejs', renderData, 'material/info_modal.ejs');
  488. } catch (err) {
  489. this.log(err);
  490. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  491. }
  492. }
  493. // 判断order是否重复,重复则重新排版并更新数据库
  494. async checkBillsOrder(ctx, billsList) {
  495. if (billsList.length > 0) {
  496. const needSet = ctx.helper._.uniq(ctx.helper._.map(billsList, 'order')).length !== billsList.length;
  497. if (needSet) {
  498. let order = 1;
  499. const updateOrderList = [];
  500. for (const b of billsList) {
  501. if (b.order !== order) {
  502. b.order = order;
  503. updateOrderList.push({
  504. id: b.id,
  505. order,
  506. });
  507. }
  508. order = order + 1;
  509. }
  510. if (updateOrderList.length > 0) await ctx.service.materialBills.updateAllOrder(updateOrderList);
  511. }
  512. }
  513. }
  514. /**
  515. * 调差清单页面 (Get)
  516. * @param {Object} ctx - egg全局变量
  517. * @return {Promise<void>}
  518. */
  519. async list(ctx) {
  520. try {
  521. await this._getMaterialAuditViewData(ctx);
  522. await this._setEditListPermission(ctx);
  523. const renderData = await this._getDefaultRenderData(ctx);
  524. // 根据期判断需要获取的工料信息值表
  525. const searchsql = { tid: ctx.tender.id };
  526. let midList = [];
  527. if (ctx.material.highOrder !== ctx.material.order) {
  528. midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  529. searchsql.mid = midList;
  530. }
  531. searchsql.t_type = materialConst.t_type[0].value;
  532. renderData.materialBillsData = await ctx.service.materialBills.getAllDataByCondition({ where: searchsql, orders: [['order', 'asc']] });
  533. // 取对应期的截取上期的调差金额和应耗数量
  534. if (ctx.material.highOrder !== ctx.material.order) {
  535. for (const [mindex, mb] of renderData.materialBillsData.entries()) {
  536. const result = await ctx.service.materialBillsHistory.getByMbId(ctx.material.id, ctx.material.order, mb.id);
  537. _.forEach(result, function(value, key) {
  538. if (key === 'mb_id') {
  539. renderData.materialBillsData[mindex].id = result ? result[key] : null;
  540. } else {
  541. renderData.materialBillsData[mindex][key] = result ? result[key] : null;
  542. }
  543. });
  544. }
  545. }
  546. renderData.materialStageData = ctx.material.is_stage_self ? await ctx.service.materialStage.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } }) : [];
  547. renderData.materialStageBillsData = ctx.material.is_stage_self ? await ctx.service.materialStageBills.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } }) : [];
  548. // 取所有已被调用的工料清单表
  549. // renderData.materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
  550. // renderData.materialNotJoinListData = await ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } });
  551. renderData.materialType = JSON.stringify(materialConst);
  552. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.list);
  553. // 获取清单数据
  554. // renderData.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  555. // renderData.pos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  556. // 获取所选期数据并合并相加同类清单项
  557. // renderData.curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, ctx.material.stage_id);
  558. // renderData.curPosData = await ctx.service.stagePos.getStagesData(ctx.tender.id, ctx.material.stage_id, 'list');
  559. await this.layout('material/list.ejs', renderData, 'material/list_modal.ejs');
  560. } catch (err) {
  561. this.log(err);
  562. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  563. }
  564. }
  565. /**
  566. * 调差清单页面 (Get)
  567. * @param {Object} ctx - egg全局变量
  568. * @return {Promise<void>}
  569. */
  570. async loadListsData(ctx) {
  571. try {
  572. const data = JSON.parse(ctx.request.body.data);
  573. // const filter = data.filter.split(';');
  574. const responseData = { err: 0, msg: '', data: {} };
  575. // 取所有已被调用的工料清单表
  576. responseData.data.materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
  577. responseData.data.materialNotJoinListData = await ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id, type: 1 } });
  578. responseData.data.materialNotChangeListData = await ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id, type: 2 } });
  579. responseData.data.materialSelfListData = await ctx.service.materialListSelf.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } });
  580. // 获取清单数据
  581. responseData.data.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  582. responseData.data.pos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  583. // 获取所选期数据并合并相加同类清单项
  584. if (ctx.material.is_stage_self && data.sid) {
  585. const curLedgerPcData = await ctx.service.stageBillsPc.getStagesData(ctx.tender.id, data.sid.toString());
  586. const curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, data.sid.toString());
  587. for (const cl of curLedgerData) {
  588. const clpc = ctx.helper._.find(curLedgerPcData, { lid: cl.lid });
  589. ctx.helper._.assign(cl, clpc);
  590. }
  591. responseData.data.curLedgerData = curLedgerData;
  592. responseData.data.curPosData = await ctx.service.stagePos.getStagesData(ctx.tender.id, data.sid.toString(), 'list');
  593. const ledgerListData = [];
  594. const posListData = [];
  595. for (const s of ctx.material.stage_id.split(',')) {
  596. const curLedgerPcData = await ctx.service.stageBillsPc.getStagesData(ctx.tender.id, s.toString());
  597. const curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, s.toString());
  598. for (const cl of curLedgerData) {
  599. const clpc = ctx.helper._.find(curLedgerPcData, { lid: cl.lid });
  600. ctx.helper._.assign(cl, clpc);
  601. }
  602. ledgerListData.push(curLedgerData);
  603. posListData.push(await ctx.service.stagePos.getStagesData(ctx.tender.id, s.toString(), 'list'));
  604. }
  605. responseData.data.ledgerListData = ledgerListData;
  606. responseData.data.posListData = posListData;
  607. } else {
  608. const curLedgerPcData = await ctx.service.stageBillsPc.getStagesData(ctx.tender.id, ctx.material.stage_id);
  609. const curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, ctx.material.stage_id);
  610. for (const cl of curLedgerData) {
  611. const clpc = ctx.helper._.find(curLedgerPcData, { lid: cl.lid });
  612. ctx.helper._.assign(cl, clpc);
  613. }
  614. responseData.data.curLedgerData = curLedgerData;
  615. responseData.data.curPosData = await ctx.service.stagePos.getStagesData(ctx.tender.id, ctx.material.stage_id, 'list');
  616. }
  617. // 获取清单设置已选清单
  618. const materialChecklistData = await ctx.service.materialChecklist.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  619. responseData.data.materialChecklistData = materialChecklistData.sort(function(a, b) {
  620. return ctx.helper.compareCode(a.b_code, b.b_code);
  621. });
  622. const lastMaterial = await ctx.service.material.getLastestMaterial(ctx.tender.id, true);
  623. if (lastMaterial && !lastMaterial.is_new) {
  624. const materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, lastMaterial.id);
  625. const hadBillsList = [];
  626. for (const ml of materialListData) {
  627. const hb = _.find(hadBillsList, { gcl_id: ml.gcl_id, mb_id: ml.mb_id });
  628. if (!hb) {
  629. hadBillsList.push({
  630. gcl_id: ml.gcl_id,
  631. mb_id: ml.mb_id,
  632. order: ml.order,
  633. quantity: ml.quantity,
  634. expr: ml.expr,
  635. });
  636. }
  637. }
  638. // 批量插入并修改is_new值
  639. await ctx.service.materialListGcl.setData(lastMaterial.id, hadBillsList);
  640. // responseData.data.gclList = hadBillsList;
  641. }
  642. // } else {
  643. // 判断是否是最新期,不是则获取的gclList是由materialList拼接而成,
  644. if (lastMaterial.id === ctx.material.id) {
  645. const hadBillsList = await ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  646. responseData.data.gclList = hadBillsList;
  647. } else {
  648. const materialList = await this.ctx.service.materialList.getAllDataByCondition({ where: { mid: ctx.material.id, is_self: 0 } });
  649. const hadBillsList = ctx.app._.unionWith(materialList, function(item1, item2) {
  650. return item1.gcl_id === item2.gcl_id && item1.mb_id === item2.mb_id;
  651. });
  652. responseData.data.gclList = hadBillsList;
  653. }
  654. ctx.body = responseData;
  655. } catch (err) {
  656. this.log(err);
  657. ctx.body = { err: 1, msg: err.toString(), data: null };
  658. }
  659. }
  660. /**
  661. * 调差清单新建台账数据获取 (Post)
  662. * @param {Object} ctx - egg全局变量
  663. * @return {Promise<void>}
  664. */
  665. async loadGclData(ctx) {
  666. try {
  667. // const data = JSON.parse(ctx.request.body.data);
  668. // const filter = data.filter.split(';');
  669. const responseData = { err: 0, msg: '', data: {} };
  670. const data = JSON.parse(ctx.request.body.data);
  671. if (data.stage_id === '') {
  672. throw '没有选中计量期';
  673. }
  674. // 取所有已被调用的工料清单表
  675. // responseData.data.materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
  676. // responseData.data.materialNotJoinListData = await ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } });
  677. // 获取清单数据
  678. responseData.data.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  679. responseData.data.pos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  680. // 获取所选期数据并合并相加同类清单项
  681. if (data.is_stage_self) {
  682. const stage_id_list = data.stage_id;
  683. const curLedgerData = [];
  684. const curPosData = [];
  685. for (const sid of stage_id_list) {
  686. curLedgerData.push({ sid, ledgerData: await ctx.service.stageBills.getLastestStageData2(ctx.tender.id, sid) });
  687. curPosData.push({ sid, posData: await ctx.service.stagePos.getLastestStageData2(ctx.tender.id, sid) });
  688. }
  689. responseData.data.curLedgerData = curLedgerData;
  690. responseData.data.curPosData = curPosData;
  691. } else {
  692. responseData.data.curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, data.stage_id.join(','));
  693. responseData.data.curPosData = await ctx.service.stagePos.getStagesData(ctx.tender.id, data.stage_id.join(','), 'list');
  694. }
  695. // 获取gclidlist值
  696. const lastMaterial = await ctx.service.material.getLastestCompleteMaterial(ctx.tender.id);
  697. // responseData.data.materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, lastMaterial.id);
  698. if (lastMaterial && !lastMaterial.is_new) {
  699. const materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, lastMaterial.id);
  700. const hadBillsList = [];
  701. for (const ml of materialListData) {
  702. const hb = _.find(hadBillsList, { gcl_id: ml.gcl_id, mb_id: ml.mb_id });
  703. if (!hb) {
  704. hadBillsList.push({
  705. gcl_id: ml.gcl_id,
  706. mb_id: ml.mb_id,
  707. order: ml.order,
  708. quantity: ml.quantity,
  709. expr: ml.expr,
  710. });
  711. }
  712. }
  713. // 批量插入并修改is_new值
  714. await ctx.service.materialListGcl.setData(lastMaterial.id, hadBillsList);
  715. // responseData.data.gclList = hadBillsList;
  716. }
  717. const hadBillsList = await ctx.service.materialListGcl.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  718. responseData.data.gclList = hadBillsList;
  719. // 获取上一期的单独设置的清单明细
  720. responseData.data.materialListForSelf = lastMaterial ? await ctx.service.materialList.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: lastMaterial.id, is_self: 1 } }) : [];
  721. responseData.data.selfList = lastMaterial ? await ctx.service.materialListSelf.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: lastMaterial.id } }) : [];
  722. // 获取清单设置已选清单
  723. // const materialChecklistData = await ctx.service.materialChecklist.getAllDataByCondition({ where: { tid: ctx.tender.id } });
  724. // responseData.data.materialChecklistData = materialChecklistData.sort(function(a, b) {
  725. // return ctx.helper.compareCode(a.b_code, b.b_code);
  726. // });
  727. ctx.body = responseData;
  728. } catch (err) {
  729. this.log(err);
  730. ctx.body = { err: 1, msg: err.toString(), data: null };
  731. }
  732. }
  733. /**
  734. * 指数调差页面 (Get)
  735. * @param {Object} ctx - egg全局变量
  736. * @return {Promise<void>}
  737. */
  738. async exponent(ctx) {
  739. try {
  740. await this._checkExponentExist(ctx);
  741. await this._getMaterialAuditViewData(ctx);
  742. const renderData = await this._getDefaultRenderData(ctx);
  743. const stage_list = await ctx.service.stage.getStageMsgByStageId(ctx.material.stage_id);
  744. renderData.ex_calc = materialConst.ex_calc;
  745. if (!ctx.material.ex_calc) {
  746. const calcBase = await ctx.service.stage.getMaterialCalcBase(stage_list, ctx.tender.info);
  747. for (const bq of renderData.ex_calc) {
  748. const calc = _.find(calcBase, { code: bq.code }) || _.find(calcBase, { code: 'bqwc' });
  749. bq.value = calc.value;
  750. // if (calc.code === 'bqwc') {
  751. // ctx.material.ex_expr = calc.value.toString() + '*[0-1]';
  752. // ctx.material.ex_tp = this.ctx.helper.round(this.ctx.helper.mul(calc.value, -1), 2);
  753. // }
  754. }
  755. // 并更新至调差表中
  756. await ctx.service.material.update({ ex_calc: JSON.stringify(renderData.ex_calc) }, { id: ctx.material.id });
  757. } else {
  758. const ex_calc = JSON.parse(ctx.material.ex_calc);
  759. if (ctx.helper._.findIndex(ex_calc, { code: 'zdy' }) === -1) {
  760. ex_calc.push({
  761. code: 'zdy',
  762. text: '自定义金额',
  763. value: ctx.helper._.find(ex_calc, { code: 'bqwc' }).value,
  764. select: false,
  765. });
  766. // 并更新至调差表中
  767. await ctx.service.material.update({ ex_calc: JSON.stringify(ex_calc) }, { id: ctx.material.id });
  768. }
  769. renderData.ex_calc = ex_calc;
  770. }
  771. renderData.materialBillsData = await this._getMaterialBillsData(ctx);
  772. renderData.materialExponentData = await this._getMaterialExponentData(ctx);
  773. // 取对应期的截取上期的调差金额和应耗数量
  774. if (ctx.material.highOrder !== ctx.material.order) {
  775. for (const [mindex, me] of renderData.materialExponentData.entries()) {
  776. const result = await ctx.service.materialExponentHistory.getByMeId(ctx.material.id, ctx.material.order, me.id);
  777. _.forEach(result, function(value, key) {
  778. renderData.materialExponentData[mindex][key] = result ? result[key] : null;
  779. });
  780. }
  781. }
  782. // 取当前期截止上期含税金额
  783. renderData.pre_tp_hs = await ctx.service.material.getPreTpHs(ctx.tender.id, ctx.material.order, ctx.material.decimal.tp);
  784. renderData.ex_pre_tp_hs = await ctx.service.material.getExPreTpHs(ctx.tender.id, ctx.material.order, ctx.material.decimal.tp);
  785. renderData.materialType = materialConst;
  786. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.exponent);
  787. // 判断之前期有无调用过材料税
  788. renderData.old_had_tax = await ctx.service.material.getOldMaterialTax(ctx.tender.id, ctx.params.order);
  789. await this.layout('material/exponent.ejs', renderData, 'material/exponent_modal.ejs');
  790. } catch (err) {
  791. this.log(err);
  792. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  793. }
  794. }
  795. /**
  796. * 附件页面 (Get)
  797. * @param {Object} ctx - egg全局变量
  798. * @return {Promise<void>}
  799. */
  800. async file(ctx) {
  801. try {
  802. await this._getMaterialAuditViewData(ctx);
  803. const renderData = await this._getDefaultRenderData(ctx);
  804. renderData.materialBillsData = await this._getMaterialBillsData(ctx);
  805. const whiteList = this.ctx.app.config.multipart.whitelist;
  806. // 获取当前标段所有附件
  807. // const searchsql = { tid: ctx.tender.id };
  808. renderData.fileList = await ctx.service.materialFile.getAllMaterialFiles(ctx.tender.id);
  809. renderData.auditors = ctx.material.auditors.map(audit => audit.aid);
  810. // renderData.auditors = ctx.material.auditors2.map(audit => audit.aid);
  811. renderData.report_id = ctx.material.user_id;
  812. renderData.auditConst = auditConst;
  813. renderData.whiteList = whiteList;
  814. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.file);
  815. await this.layout('material/file.ejs', renderData, 'material/file_modal.ejs');
  816. } catch (err) {
  817. this.log(err);
  818. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  819. }
  820. }
  821. /**
  822. * 调差操作 (form)
  823. * @param ctx
  824. * @return {Promise<void>}
  825. */
  826. async saveDecimal(ctx) {
  827. try {
  828. const data = ctx.request.body;
  829. if (ctx.material.status !== auditConst.status.uncheck && ctx.material.status !== auditConst.status.checkNo) {
  830. throw '当前调差期无法调整小数位数';
  831. }
  832. const newDecimalUp = parseInt(data.up);
  833. const newDecimalTp = parseInt(data.tp);
  834. const newDecimalQty = parseInt(data.qty);
  835. const newQtySource = parseInt(data.qty_source);
  836. if (ctx.app._.isNaN(newDecimalUp) || newDecimalUp > 6 || newDecimalUp < 0) {
  837. throw '单价小数位数设置不能大于6或小于0';
  838. }
  839. if (ctx.app._.isNaN(newDecimalTp) || newDecimalTp > 6 || newDecimalTp < 0) {
  840. throw '金额小数位数设置不能大于6或小于0';
  841. }
  842. if (ctx.app._.isNaN(newDecimalQty) || newDecimalQty > 6 || newDecimalQty < 0) {
  843. throw '数量小数位数设置不能大于6或小于0';
  844. }
  845. if (ctx.material.decimal.up === newDecimalUp && ctx.material.decimal.tp === newDecimalTp && ctx.material.decimal.qty === newDecimalQty && newQtySource === ctx.material.qty_source) {
  846. throw '设置内容未发生变化';
  847. }
  848. if (ctx.material.decimal.up !== newDecimalUp || ctx.material.decimal.tp !== newDecimalTp || ctx.material.decimal.qty !== newDecimalQty) {
  849. const result = await ctx.service.material.saveDecimal(newDecimalUp, newDecimalTp, newDecimalQty);
  850. if (!result) {
  851. throw '小数位数设置失败';
  852. }
  853. }
  854. if (newQtySource !== ctx.material.qty_source) {
  855. const result = await ctx.service.material.saveQtySource(newQtySource);
  856. }
  857. this.setMessage('设置成功', this.messageType.SUCCESS);
  858. } catch (err) {
  859. console.log(err);
  860. this.log(err);
  861. ctx.session.postError = err.toString();
  862. }
  863. ctx.redirect(ctx.request.header.referer);
  864. }
  865. /**
  866. * 调差清单 - 工料操作 (Ajax)
  867. * @param ctx
  868. * @return {Promise<void>}
  869. */
  870. async saveListsData(ctx) {
  871. try {
  872. const data = JSON.parse(ctx.request.body.data);
  873. const responseData = {
  874. err: 0,
  875. msg: '',
  876. data: {},
  877. };
  878. const notControlList = ['join', 'notjoin', 'change', 'notchange', 'self', 'noself', 'useOther', 'add', 'del', 'update', 'paste'];
  879. if (ctx.session.sessionProject.page_show.openMaterialChecklist && ctx.app._.indexOf(notControlList, data.type) === -1) {
  880. throw '清单设置功能已启动,请前往清单设置页操作清单内容';
  881. }
  882. const selfControlList = ['self', 'noself', 'add', 'del', 'update', 'paste'];
  883. if (!ctx.session.sessionProject.page_show.openMaterialSelf && ctx.app._.indexOf(selfControlList, data.type) !== -1) {
  884. throw '单独设置工料功能已关闭,无法设置';
  885. }
  886. switch (data.type) {
  887. case 'add':
  888. responseData.data = await ctx.service.materialList.add(data.postData, data.ms_id);
  889. break;
  890. case 'del':
  891. await ctx.service.materialList.del(data.id, data.mb_id, data.ms_id);
  892. break;
  893. case 'update':
  894. if (data.updateData.quantity === '' || data.updateData.quantity === null) {
  895. throw '请输入数量';
  896. }
  897. // 判断数量是否为数字
  898. if (isNaN(data.updateData.quantity)) {
  899. throw '不能输入其它非数字类型字符';
  900. }
  901. await ctx.service.materialList.save(data.updateData, data.ms_id);
  902. break;
  903. case 'useOther':
  904. responseData.data = await ctx.service.materialList.addOther(data.postData);
  905. break;
  906. case 'change':
  907. case 'join':
  908. await ctx.service.materialListNotjoin.del(data.select.id, data.ms_id);
  909. break;
  910. case 'notjoin':
  911. responseData.data = await ctx.service.materialListNotjoin.add(data.select, data.ms_id);
  912. break;
  913. case 'notchange':
  914. responseData.data = await ctx.service.materialListNotjoin.addChange(data.select, data.ms_id);
  915. break;
  916. case 'self':
  917. responseData.data = await ctx.service.materialListSelf.add(data.select);
  918. break;
  919. case 'noself':
  920. responseData.data = await ctx.service.materialListSelf.del(data.select.id, data.ms_id, data.select);
  921. break;
  922. case 'paste':
  923. await ctx.service.materialList.saveDatas(data.updateData, data.ms_id);
  924. // 取所有工料表
  925. responseData.data = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
  926. break;
  927. case 'adds':
  928. responseData.data = await ctx.service.materialList.adds(data.postData);
  929. break;
  930. case 'dels':
  931. responseData.data = await ctx.service.materialList.dels(data.postData, false, false, data.ms_id);
  932. break;
  933. case 'updates':
  934. if (data.updateData.quantity === '' || data.updateData.quantity === null) {
  935. throw '请输入数量';
  936. }
  937. // 判断数量是否为数字
  938. if (isNaN(data.updateData.quantity)) {
  939. throw '不能输入其它非数字类型字符';
  940. }
  941. responseData.data = await ctx.service.materialList.saves(data.updateData, false, data.ms_id);
  942. break;
  943. case 'pastes':
  944. responseData.data = await ctx.service.materialList.savePastes(data.updateData, false, data.ms_id);
  945. // 取所有工料表
  946. break;
  947. default: throw '参数有误';
  948. }
  949. ctx.body = responseData;
  950. } catch (err) {
  951. this.log(err);
  952. ctx.body = { err: 1, msg: err.toString(), data: null };
  953. }
  954. }
  955. /**
  956. * 调差工料 - 编辑工料项 (Ajax)
  957. * @param ctx
  958. * @return {Promise<void>}
  959. */
  960. async saveBillsData(ctx) {
  961. try {
  962. const data = JSON.parse(ctx.request.body.data);
  963. const responseData = {
  964. err: 0,
  965. msg: '',
  966. data: {},
  967. };
  968. switch (data.type) {
  969. case 'add':
  970. responseData.data = await ctx.service.materialBills.add();
  971. break;
  972. case 'del':
  973. responseData.data = await ctx.service.materialBills.del(data.id);
  974. break;
  975. case 'changeOrder':
  976. await ctx.service.materialBills.changeOrder(data.postData);
  977. break;
  978. case 'update':
  979. if (data.updateData.code === '' || data.updateData.code === null) {
  980. throw '请先输入编号';
  981. }
  982. // 判断编号为纯数字时,不能为小数
  983. if (!isNaN(data.updateData.code) && data.updateData.code.toString().indexOf('.') !== -1) {
  984. throw '编号为纯数字时,不能为小数';
  985. }
  986. if (data.updateData.code.length > 15) {
  987. throw '长度不超过15个字符';
  988. }
  989. // 判断编号是否已存在
  990. const billData = await ctx.service.materialBills.getAllDataByCondition({ where: { tid: ctx.tender.id, code: data.updateData.code } });
  991. if (billData.length > 1 || (billData.length > 0 && billData[0].id !== data.updateData.id)) {
  992. throw '该编号已存在,请重新输入。';
  993. }
  994. responseData.data = await ctx.service.materialBills.save(data.updateData, data.ms_id);
  995. break;
  996. case 'rate':
  997. // 判断数量是否为数字
  998. if (isNaN(data.rate)) {
  999. throw '不能输入其它非数字类型字符';
  1000. }
  1001. if (ctx.material.readOnly) {
  1002. throw '无权操作';
  1003. }
  1004. await ctx.service.material.changeRate(data.rate);
  1005. break;
  1006. case 'expr':
  1007. responseData.data = await ctx.service.materialBills.updateFYQuantity(data);
  1008. break;
  1009. case 'paste':
  1010. responseData.data = await ctx.service.materialBills.saveDatas(data.updateData, data.ms_id);
  1011. // 根据期判断需要获取的工料信息值
  1012. // const searchsql = { tid: ctx.tender.id };
  1013. // if (ctx.material.highOrder !== ctx.material.order) {
  1014. // const midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  1015. // searchsql.mid = midList;
  1016. // }
  1017. // // 取所有工料表
  1018. // responseData.data.info = await ctx.service.materialBills.getAllDataByCondition({ where: searchsql, orders: [['order', 'asc']] });
  1019. responseData.data.info = await this._getMaterialBillsData(ctx);
  1020. break;
  1021. case 'add-glj':
  1022. responseData.data = await ctx.service.materialBills.addByGlj(data.postData, data.order);
  1023. break;
  1024. case 'export':
  1025. responseData.data = await ctx.service.materialBills.exportData(data.postData, data.includeSpec, data.ms_id);
  1026. break;
  1027. case 'qty_update':
  1028. responseData.data = await ctx.service.materialList.saveQtyHistory(data.needUpdateList);
  1029. break;
  1030. default: throw '参数有误';
  1031. }
  1032. if (ctx.material.material_tax) {
  1033. responseData.data.m_tax_tp = await ctx.service.material.getMaterialTaxTp(ctx.material.id);
  1034. }
  1035. ctx.body = responseData;
  1036. } catch (err) {
  1037. this.log(err);
  1038. ctx.body = { err: 1, msg: err.toString(), data: null };
  1039. }
  1040. }
  1041. /**
  1042. * 调差工料 - 编辑月信息价 (Ajax)
  1043. * @param ctx
  1044. * @return {Promise<void>}
  1045. */
  1046. async saveMonth(ctx) {
  1047. try {
  1048. const data = JSON.parse(ctx.request.body.data);
  1049. const responseData = {
  1050. err: 0,
  1051. msg: '',
  1052. data: {},
  1053. };
  1054. const monthList = await ctx.service.materialMonth.getListByMid(ctx.material.id);
  1055. const mbList = await this._getMaterialBillsData(ctx);
  1056. const material_month = this.ctx.material.months ? this.ctx.material.months.split(',') : [];
  1057. switch (data.type) {
  1058. case 'add':
  1059. // 判断是否已存在该月份
  1060. if (ctx.app._.indexOf(material_month, data.updateData.yearmonth) !== -1) {
  1061. throw '调差期已创建过本月的信息价,请刷新页面重新获取';
  1062. }
  1063. const tp = await ctx.service.materialMonth.add(data.updateData, monthList, mbList);
  1064. const materialBillsData = await this._getMaterialBillsData(ctx);
  1065. const monthsList = await this._getMaterialMonthsData(ctx, materialBillsData);
  1066. responseData.data = {
  1067. m_tp: tp,
  1068. monthsList,
  1069. };
  1070. break;
  1071. case 'del':
  1072. // 判断是否已不存在该月份
  1073. if (ctx.app._.intersection(data.updateData.del_yearmonth, material_month).length !== data.updateData.del_yearmonth.length) {
  1074. throw '调差期已删除本月的信息价,请刷新页面重新获取';
  1075. }
  1076. const tp2 = await ctx.service.materialMonth.del(data.updateData.del_yearmonth, monthList, mbList);
  1077. const materialBillsData2 = await this._getMaterialBillsData(ctx);
  1078. const monthsList2 = await this._getMaterialMonthsData(ctx, materialBillsData2);
  1079. responseData.data = {
  1080. m_tp: tp2,
  1081. monthsList: monthsList2,
  1082. };
  1083. break;
  1084. case 'update':
  1085. const tp3 = await ctx.service.materialMonth.save(data.updateData);
  1086. responseData.data = {
  1087. m_tp: tp3,
  1088. };
  1089. break;
  1090. case 'updateOrigin':
  1091. await ctx.service.materialBills.saveOrigin(data.updateData);
  1092. break;
  1093. case 'paste':
  1094. const tp4 = await ctx.service.materialMonth.saveDatas(data.updateData, mbList);
  1095. responseData.data = {
  1096. m_tp: tp4,
  1097. };
  1098. break;
  1099. case 'pasteOrigin':
  1100. await ctx.service.materialBills.saveOrigins(data.updateData);
  1101. break;
  1102. default: throw '参数有误';
  1103. }
  1104. if (ctx.material.material_tax) {
  1105. responseData.data.m_tax_tp = await ctx.service.material.getMaterialTaxTp(ctx.material.id);
  1106. }
  1107. responseData.data.materialBillsData = await this._getMaterialBillsData(ctx);
  1108. ctx.body = responseData;
  1109. } catch (err) {
  1110. this.log(err);
  1111. ctx.body = { err: 1, msg: err.toString(), data: null };
  1112. }
  1113. }
  1114. /**
  1115. * 指数调差 - 编辑指数清单项 (Ajax)
  1116. * @param ctx
  1117. * @return {Promise<void>}
  1118. */
  1119. async saveExponentData(ctx) {
  1120. try {
  1121. const data = JSON.parse(ctx.request.body.data);
  1122. const responseData = {
  1123. err: 0,
  1124. msg: '',
  1125. data: {},
  1126. };
  1127. let ex_tp = ctx.material.ex_tp;
  1128. let ex_expr = ctx.material.ex_expr;
  1129. switch (data.type) {
  1130. case 'add':
  1131. responseData.data = await ctx.service.materialExponent.add();
  1132. break;
  1133. case 'del':
  1134. [ex_tp, ex_expr] = await ctx.service.materialExponent.del(data.id);
  1135. responseData.data.ex_tp = ex_tp;
  1136. responseData.data.ex_expr = ex_expr;
  1137. break;
  1138. case 'update':
  1139. [ex_tp, ex_expr] = await ctx.service.materialExponent.save(data.updateData);
  1140. responseData.data.ex_tp = ex_tp;
  1141. responseData.data.ex_expr = ex_expr;
  1142. break;
  1143. case 'rate':
  1144. // 判断数量是否为数字
  1145. if (isNaN(data.rate)) {
  1146. throw '不能输入其它非数字类型字符';
  1147. }
  1148. if (ctx.material.readOnly) {
  1149. throw '无权操作';
  1150. }
  1151. await ctx.service.material.changeExponentRate(data.rate);
  1152. break;
  1153. case 'paste':
  1154. [ex_tp, ex_expr] = await ctx.service.materialExponent.saveDatas(data.updateData);
  1155. responseData.data.ex_tp = ex_tp;
  1156. responseData.data.ex_expr = ex_expr;
  1157. // 取所有指数清单
  1158. responseData.data.info = await this._getMaterialExponentData(ctx);
  1159. break;
  1160. case 'ex_calc':
  1161. // 判断数量是否为数字
  1162. [ex_tp, ex_expr] = await ctx.service.material.changeExCalc(data.updateData);
  1163. responseData.data.ex_tp = ex_tp;
  1164. responseData.data.ex_expr = ex_expr;
  1165. break;
  1166. default: throw '参数有误';
  1167. }
  1168. ctx.body = responseData;
  1169. } catch (err) {
  1170. this.log(err);
  1171. ctx.body = { err: 1, msg: err.toString(), data: null };
  1172. }
  1173. }
  1174. // 审批相关
  1175. /**
  1176. * 添加审批人
  1177. * @param ctx
  1178. * @return {Promise<void>}
  1179. */
  1180. async addAudit(ctx) {
  1181. try {
  1182. const data = JSON.parse(ctx.request.body.data);
  1183. const id = this.app._.toInteger(data.auditorId);
  1184. if (isNaN(id) || id <= 0) {
  1185. throw '参数错误';
  1186. }
  1187. // 检查权限等
  1188. if (ctx.material.user_id !== ctx.session.sessionUser.accountId) {
  1189. throw '您无权添加审核人';
  1190. }
  1191. if (ctx.material.status === auditConst.status.checking || ctx.material.status === auditConst.status.checked) {
  1192. throw '当前不允许添加审核人';
  1193. }
  1194. ctx.material.auditorList = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  1195. // 检查审核人是否已存在
  1196. const exist = this.app._.find(ctx.material.auditorList, { aid: id });
  1197. if (exist) {
  1198. throw '该审核人已存在,请勿重复添加';
  1199. }
  1200. const shenpiInfo = await ctx.service.shenpiAudit.getDataByCondition({ tid: ctx.tender.id, sp_type: shenpiConst.sp_type.material, sp_status: shenpiConst.sp_status.gdzs });
  1201. const is_gdzs = shenpiInfo && ctx.tender.info.shenpi.material === shenpiConst.sp_status.gdzs ? 1 : 0;
  1202. const result = await ctx.service.materialAudit.addAuditor(ctx.material.id, id, ctx.material.times, is_gdzs);
  1203. if (!result) {
  1204. throw '添加审核人失败';
  1205. }
  1206. const auditors = await ctx.service.materialAudit.getAuditorsWithOwner(ctx.material.id, ctx.material.times);
  1207. ctx.body = { err: 0, msg: '', data: auditors };
  1208. } catch (err) {
  1209. this.log(err);
  1210. ctx.body = { err: 1, msg: err.toString(), data: null };
  1211. }
  1212. }
  1213. /**
  1214. * 移除审批人
  1215. * @param ctx
  1216. * @return {Promise<void>}
  1217. */
  1218. async deleteAudit(ctx) {
  1219. try {
  1220. const data = JSON.parse(ctx.request.body.data);
  1221. const id = data.auditorId instanceof Number ? data.auditorId : this.app._.toNumber(data.auditorId);
  1222. if (isNaN(id) || id <= 0) {
  1223. throw '参数错误';
  1224. }
  1225. const result = await ctx.service.materialAudit.deleteAuditor(ctx.material.id, id, ctx.material.times);
  1226. if (!result) {
  1227. throw '移除审核人失败';
  1228. }
  1229. const auditors = await ctx.service.materialAudit.getAuditors(ctx.material.id, ctx.material.times);
  1230. ctx.body = { err: 0, msg: '', data: auditors };
  1231. } catch (err) {
  1232. ctx.body = { err: 1, msg: err.toString(), data: null };
  1233. }
  1234. }
  1235. /**
  1236. * 上报和重新上报
  1237. * @param ctx
  1238. * @return {Promise<void>}
  1239. */
  1240. async startAudit(ctx) {
  1241. try {
  1242. // 检查权限等
  1243. if (!ctx.material) {
  1244. throw '数据错误';
  1245. }
  1246. if (ctx.material.user_id !== ctx.session.sessionUser.accountId) {
  1247. throw '您无权上报该期数据';
  1248. }
  1249. if (ctx.material.status === auditConst.status.checking || ctx.material.status === auditConst.status.checked) {
  1250. throw '该材料调差期数据当前无法上报';
  1251. }
  1252. await ctx.service.materialAudit.start(ctx.material.id, ctx.material.times);
  1253. ctx.redirect(ctx.request.header.referer);
  1254. } catch (err) {
  1255. this.log(err);
  1256. ctx.session.postError = err.toString();
  1257. ctx.redirect(ctx.request.header.referer);
  1258. }
  1259. }
  1260. /**
  1261. * 审批
  1262. * @param ctx
  1263. * @return {Promise<void>}
  1264. */
  1265. async checkAudit(ctx) {
  1266. try {
  1267. if (!this.ctx.material || this.ctx.material.status !== auditConst.status.checking) {
  1268. throw '当前材料调差期数据有误';
  1269. }
  1270. if (!this.ctx.material.curAuditor || this.ctx.material.curAuditor.aid !== ctx.session.sessionUser.accountId) {
  1271. throw '您无权进行该操作';
  1272. }
  1273. const data = {
  1274. checkType: parseInt(ctx.request.body.checkType),
  1275. opinion: ctx.request.body.opinion,
  1276. };
  1277. if (!data.checkType || isNaN(data.checkType)) {
  1278. throw '提交数据错误';
  1279. }
  1280. if (data.checkType === auditConst.status.checkNo) {
  1281. if (!data.checkType || isNaN(data.checkType)) {
  1282. throw '提交数据错误';
  1283. }
  1284. }
  1285. await ctx.service.materialAudit.check(ctx.material.id, data, ctx.material.times);
  1286. ctx.redirect(ctx.request.header.referer);
  1287. } catch (err) {
  1288. this.log(err);
  1289. ctx.session.postError = err.toString();
  1290. ctx.redirect(ctx.request.header.referer);
  1291. }
  1292. }
  1293. async _checkMaterialFileCanModify(ctx) {
  1294. // 检查登录用户,是否可操作
  1295. const accountId = ctx.session.sessionUser.accountId;
  1296. const auditors = await ctx.service.materialAudit.getAuditorsWithOwner(ctx.material.id, ctx.material.times);
  1297. // console.log(auditors);
  1298. if (auditors.findIndex(item => item.aid === accountId) === -1 && !ctx.tender.touristPermission.file) {
  1299. throw '该调差期当前您无权操作';
  1300. }
  1301. // if (!ctx.material.curAuditor) {
  1302. // if (ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo && accountId === ctx.material.user_id) {
  1303. // return;
  1304. // }
  1305. // throw '该调差期当前您无权操作';
  1306. // } else {
  1307. // if (ctx.material.curAuditor.aid === accountId) return;
  1308. // throw '该调差期当前您无权操作';
  1309. // }
  1310. }
  1311. /**
  1312. * 上传附件
  1313. * @param {*} ctx 上下文
  1314. */
  1315. async upload(ctx) {
  1316. let stream;
  1317. try {
  1318. await this._checkMaterialFileCanModify(ctx);
  1319. const parts = this.ctx.multipart({
  1320. autoFields: true,
  1321. });
  1322. const files = [];
  1323. const create_time = Date.parse(new Date()) / 1000;
  1324. let idx = 0;
  1325. const extra_upload = ctx.material.status === auditConst.status.checked;
  1326. while ((stream = await parts()) !== undefined) {
  1327. if (!stream.filename) {
  1328. // 如果没有传入直接返回
  1329. return;
  1330. }
  1331. const fileInfo = path.parse(stream.filename);
  1332. // const filepath = path.join('public/upload', this.ctx.tender.id.toString(), 'tc', 'fujian_' + create_time + fileInfo.ext);
  1333. const filepath = `app/public/upload/${this.ctx.tender.id.toString()}/tc/fujian_${create_time + idx.toString() + fileInfo.ext}`;
  1334. // await ctx.helper.saveStreamFile(stream, path.resolve(this.app.baseDir, 'app', filepath));
  1335. await ctx.app.fujianOss.put(ctx.app.config.fujianOssFolder + filepath, stream);
  1336. files.push({ filepath, name: stream.filename, ext: fileInfo.ext });
  1337. ++idx;
  1338. }
  1339. const upload_time = this.ctx.helper.dateTran(new Date());
  1340. const payload = files.map(file => {
  1341. let idx;
  1342. if (Array.isArray(parts.field.name)) {
  1343. idx = parts.field.name.findIndex(name => name === file.name);
  1344. } else {
  1345. idx = 'isString';
  1346. }
  1347. const newFile = {
  1348. tid: ctx.tender.id,
  1349. user_id: ctx.session.sessionUser.accountId,
  1350. mid: ctx.material.id,
  1351. s_order: ctx.params.order,
  1352. upload_time,
  1353. filepath: file.filepath,
  1354. file_size: ctx.helper.bytesToSize(idx === 'isString' ? parts.field.size : parts.field.size[idx]),
  1355. file_name: file.name,
  1356. fileext: file.ext,
  1357. extra_upload,
  1358. };
  1359. return newFile;
  1360. });
  1361. // 执行文件信息写入数据库
  1362. await ctx.service.materialFile.saveFileMsgToDb(payload);
  1363. // 将最新的当前标段的所有文件信息返回
  1364. const data = await ctx.service.materialFile.getAllMaterialFiles(ctx.tender.id);
  1365. ctx.body = { err: 0, msg: '', data };
  1366. } catch (err) {
  1367. stream && (await sendToWormhole(stream));
  1368. this.log(err);
  1369. ctx.body = { err: 1, msg: err.toString(), data: null };
  1370. }
  1371. }
  1372. /**
  1373. * 下载附件
  1374. * @param {Object} ctx - egg全局变量
  1375. * @return {void}
  1376. */
  1377. async downloadFile(ctx) {
  1378. const id = ctx.params.fid;
  1379. if (id) {
  1380. try {
  1381. const fileInfo = await ctx.service.materialFile.getDataById(id);
  1382. if (fileInfo !== undefined && fileInfo !== '') {
  1383. // const fileName = path.join(__dirname, '../', fileInfo.filepath);
  1384. // 解决中文无法下载问题
  1385. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  1386. let disposition = '';
  1387. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  1388. disposition = 'attachment; filename=' + encodeURIComponent(fileInfo.file_name);
  1389. } else if (userAgent.indexOf('firefox') >= 0) {
  1390. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(fileInfo.file_name) + '"';
  1391. } else {
  1392. /* safari等其他非主流浏览器只能自求多福了 */
  1393. disposition = 'attachment; filename=' + new Buffer(fileInfo.file_name).toString('binary');
  1394. }
  1395. ctx.response.set({
  1396. 'Content-Type': 'application/octet-stream',
  1397. 'Content-Disposition': disposition,
  1398. 'Content-Length': fileInfo.file_size,
  1399. });
  1400. // ctx.body = await fs.createReadStream(fileName);
  1401. ctx.body = await ctx.helper.ossFileGet(fileInfo.filepath);
  1402. } else {
  1403. throw '不存在该文件';
  1404. }
  1405. } catch (err) {
  1406. this.log(err);
  1407. this.setMessage(err.toString(), this.messageType.ERROR);
  1408. }
  1409. }
  1410. }
  1411. /**
  1412. * 查看当前标段以往所有期的附件
  1413. * @param {Object} ctx 上下文
  1414. */
  1415. async getCurMatericalFiles(ctx) {
  1416. try {
  1417. // const { isCheck } = JSON.parse(ctx.request.body.data);
  1418. const data = await ctx.service.materialFile.getAllMaterialFiles(ctx.tender.id);
  1419. ctx.body = { err: 0, msg: '', data };
  1420. } catch (err) {
  1421. this.log(err);
  1422. ctx.body = { err: 1, msg: err.toString(), data: null };
  1423. }
  1424. }
  1425. /**
  1426. * 删除附件
  1427. * @param {Ojbect} ctx 上下文
  1428. */
  1429. async deleteFile(ctx) {
  1430. try {
  1431. const { data } = ctx.request.body;
  1432. const { id } = JSON.parse(data);
  1433. const fileInfo = await ctx.service.materialFile.getMaterialFileById(id);
  1434. if (!fileInfo || !Object.keys(fileInfo).length) {
  1435. throw '该文件不存在';
  1436. }
  1437. if (!fileInfo.extra_upload && ctx.material.status === auditConst.status.checked) {
  1438. throw '无权限删除';
  1439. }
  1440. if (fileInfo) {
  1441. // 先删除文件
  1442. // await fs.unlinkSync(path.resolve(this.app.baseDir, './app', fileInfo.filepath));
  1443. await ctx.app.fujianOss.delete(ctx.app.config.fujianOssFolder + fileInfo.filepath);
  1444. // 再删除数据库
  1445. await ctx.service.materialFile.delete(id);
  1446. } else {
  1447. throw '不存在该文件';
  1448. }
  1449. ctx.body = { err: 0, msg: '请求成功' };
  1450. } catch (err) {
  1451. this.log(err);
  1452. ctx.body = { err: 1, msg: err.toString(), data: null };
  1453. }
  1454. }
  1455. /**
  1456. * 批量下载 - 压缩成zip文件返回
  1457. * @param {Object} ctx - 全局上下文
  1458. */
  1459. async downloadZip(ctx) {
  1460. const zipFilename = `${ctx.tender.data.name}-材料调差-${ctx.params.order}-附件.zip`;
  1461. const time = Date.now();
  1462. const zipPath = `app/public/upload/${ctx.tender.id}/tc/fu_jian_zip${time}.zip`;
  1463. const responseData = {
  1464. err: 0,
  1465. msg: '',
  1466. };
  1467. try {
  1468. // const fileIds = JSON.parse(ctx.request.query.fileIds);
  1469. const { fileIds = [] } = JSON.parse(ctx.request.body.data);
  1470. const size = await ctx.service.materialFile.compressedFile(fileIds, zipPath);
  1471. // 解决中文无法下载问题
  1472. const userAgent = (ctx.request.header['user-agent'] || '').toLowerCase();
  1473. let disposition = '';
  1474. if (userAgent.indexOf('msie') >= 0 || userAgent.indexOf('chrome') >= 0) {
  1475. disposition = 'attachment; filename=' + encodeURIComponent(zipFilename);
  1476. } else if (userAgent.indexOf('firefox') >= 0) {
  1477. disposition = 'attachment; filename*="utf8\'\'' + encodeURIComponent(zipFilename) + '"';
  1478. } else {
  1479. /* safari等其他非主流浏览器只能自求多福了 */
  1480. disposition = 'attachment; filename=' + new Buffer(zipFilename).toString('binary');
  1481. }
  1482. ctx.response.set({
  1483. 'Content-Type': 'application/octet-stream',
  1484. 'Content-Disposition': disposition,
  1485. 'Content-Length': size,
  1486. });
  1487. const readStream = fs.createReadStream(path.join(this.app.baseDir, zipPath));
  1488. ctx.body = readStream;
  1489. readStream.on('close', () => {
  1490. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1491. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1492. }
  1493. });
  1494. // fs的错误不能被try catch捕捉
  1495. readStream.on('error', err => {
  1496. this.log(err);
  1497. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1498. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1499. }
  1500. responseData.err = 1;
  1501. responseData.msg = err.toString();
  1502. ctx.body = responseData;
  1503. });
  1504. } catch (err) {
  1505. this.log(err);
  1506. if (fs.existsSync(path.resolve(this.app.baseDir, zipPath))) {
  1507. fs.unlinkSync(path.resolve(this.app.baseDir, zipPath));
  1508. }
  1509. this.setMessage(err.toString(), this.messageType.ERROR);
  1510. responseData.err = 1;
  1511. responseData.msg = err.toString();
  1512. ctx.body = responseData;
  1513. }
  1514. }
  1515. async _setEditListPermission(ctx) {
  1516. const permission = ctx.session.sessionUser.permission;
  1517. ctx.material.editListPermission = permission && permission.material !== undefined && permission.material.indexOf('2') !== -1;
  1518. }
  1519. async _setEditTaxPermission(ctx) {
  1520. const permission = ctx.session.sessionUser.permission;
  1521. ctx.material.editTaxPermission = permission && permission.material !== undefined && permission.material.indexOf('3') !== -1;
  1522. }
  1523. async _setChecklistPermission(ctx) {
  1524. // 清单设置权限判断
  1525. ctx.material.checklistPermission = false;
  1526. if (ctx.session.sessionProject.page_show.openMaterialChecklist && ctx.material.highOrder === ctx.material.order && ctx.material.status !== auditConst.status.checked) {
  1527. const permission = ctx.session.sessionUser.permission;
  1528. if ((permission && ((permission.tender !== undefined && permission.tender.indexOf('4') !== -1) || (permission.material !== undefined && permission.material.indexOf('1') !== -1))) || (ctx.material.order === 1 && ctx.session.sessionUser.accountId === ctx.material.user_id && (ctx.material.status === auditConst.status.uncheck || ctx.material.status === auditConst.status.checkNo))) {
  1529. ctx.material.checklistPermission = true;
  1530. }
  1531. }
  1532. }
  1533. /**
  1534. * 清单设置页
  1535. * @param {Object} ctx - 全局上下文
  1536. */
  1537. async checklist(ctx) {
  1538. try {
  1539. await this._getMaterialAuditViewData(ctx);
  1540. await this._setChecklistPermission(ctx);
  1541. ctx.material.readOnly = !ctx.material.checklistPermission;
  1542. const renderData = await this._getDefaultRenderData(ctx);
  1543. // 根据期判断需要获取的工料信息值表
  1544. const searchsql = { tid: ctx.tender.id };
  1545. let midList = [];
  1546. if (ctx.material.highOrder !== ctx.material.order) {
  1547. midList = await ctx.service.material.getPreMidList(ctx.tender.id, ctx.material.order);
  1548. searchsql.mid = midList;
  1549. }
  1550. searchsql.t_type = materialConst.t_type[0].value;
  1551. renderData.materialBillsData = await ctx.service.materialBills.getAllDataByCondition({ where: searchsql, orders: [['order', 'asc']] });
  1552. // 取对应期的截取上期的调差金额和应耗数量
  1553. if (ctx.material.highOrder !== ctx.material.order) {
  1554. for (const [mindex, mb] of renderData.materialBillsData.entries()) {
  1555. const result = await ctx.service.materialBillsHistory.getByMbId(ctx.material.id, ctx.material.order, mb.id);
  1556. _.forEach(result, function(value, key) {
  1557. if (key === 'mb_id') {
  1558. renderData.materialBillsData[mindex].id = result ? result[key] : null;
  1559. } else {
  1560. renderData.materialBillsData[mindex][key] = result ? result[key] : null;
  1561. }
  1562. });
  1563. }
  1564. }
  1565. renderData.materialStageData = ctx.material.is_stage_self ? await ctx.service.materialStage.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } }) : [];
  1566. renderData.materialStageBillsData = ctx.material.is_stage_self ? await ctx.service.materialStageBills.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } }) : [];
  1567. // 取所有已被调用的工料清单表
  1568. // renderData.materialListData = await ctx.service.materialList.getMaterialData(ctx.tender.id, ctx.material.id);
  1569. // renderData.materialNotJoinListData = await ctx.service.materialListNotjoin.getAllDataByCondition({ where: { tid: ctx.tender.id, mid: ctx.material.id } });
  1570. renderData.materialType = JSON.stringify(materialConst);
  1571. renderData.jsFiles = this.app.jsFiles.common.concat(this.app.jsFiles.material.checklist);
  1572. // 获取清单数据
  1573. // renderData.ledger = await ctx.service.ledger.getData(ctx.tender.id);
  1574. // renderData.pos = await ctx.service.pos.getPosData({ tid: ctx.tender.id });
  1575. // 获取所选期数据并合并相加同类清单项
  1576. // renderData.curLedgerData = await ctx.service.stageBills.getStagesData(ctx.tender.id, ctx.material.stage_id);
  1577. // renderData.curPosData = await ctx.service.stagePos.getStagesData(ctx.tender.id, ctx.material.stage_id, 'list');
  1578. await this.layout('material/checklist.ejs', renderData, 'material/checklist_modal.ejs');
  1579. } catch (err) {
  1580. this.log(err);
  1581. ctx.redirect('/tender/' + ctx.tender.id + '/measure/material');
  1582. }
  1583. }
  1584. /**
  1585. * 清单设置 - 编辑指数清单项 (Ajax)
  1586. * @param ctx
  1587. * @return {Promise<void>}
  1588. */
  1589. async saveChecklistData(ctx) {
  1590. try {
  1591. const data = JSON.parse(ctx.request.body.data);
  1592. const responseData = {
  1593. err: 0,
  1594. msg: '',
  1595. data: {},
  1596. };
  1597. await this._setChecklistPermission(ctx);
  1598. if (ctx.material.order !== ctx.material.highOrder) {
  1599. throw '无法设置非最新期的清单设置数据';
  1600. }
  1601. // 权限控制
  1602. if (!ctx.material.checklistPermission && data.type !== 'resetChecklist') {
  1603. throw '本期已审批完成或权限不足,无法设置清单数据';
  1604. }
  1605. switch (data.type) {
  1606. case 'adds':
  1607. responseData.data = await ctx.service.materialList.adds(data.postData, data.checklist);
  1608. break;
  1609. case 'dels':
  1610. responseData.data = await ctx.service.materialList.dels(data.postData, data.checklist, true, data.ms_id);
  1611. break;
  1612. case 'updates':
  1613. if (data.updateData.quantity === '' || data.updateData.quantity === null) {
  1614. throw '请输入数量';
  1615. }
  1616. // 判断数量是否为数字
  1617. if (isNaN(data.updateData.quantity)) {
  1618. throw '不能输入其它非数字类型字符';
  1619. }
  1620. responseData.data = await ctx.service.materialList.saves(data.updateData, true, data.ms_id);
  1621. break;
  1622. case 'pastes':
  1623. responseData.data = await ctx.service.materialList.savePastes(data.updateData, true, data.ms_id);
  1624. // 取所有工料表
  1625. break;
  1626. case 'resetChecklist':
  1627. responseData.data = await ctx.service.materialChecklist.resetData(data.pushData, data.removeData, data.updateData);
  1628. break;
  1629. case 'exportCB':
  1630. responseData.data = await ctx.service.materialChecklist.addExportCB(data.addChecklist, data.addBillsList);
  1631. break;
  1632. default: throw '参数有误';
  1633. }
  1634. ctx.body = responseData;
  1635. } catch (err) {
  1636. this.log(err);
  1637. ctx.body = { err: 1, msg: err.toString(), data: null };
  1638. }
  1639. }
  1640. /**
  1641. * 重新审批
  1642. * @param ctx
  1643. * @return {Promise<void>}
  1644. */
  1645. async checkAuditAgain(ctx) {
  1646. try {
  1647. if (ctx.query.confirm !== undefined && ctx.query.confirm !== '确认设置终审审批') {
  1648. throw '请输入正确的文本信息';
  1649. }
  1650. if (ctx.session.sessionUser.loginStatus === 0) {
  1651. const code = ctx.query.code;
  1652. const pa = await ctx.service.projectAccount.getDataById(ctx.session.sessionUser.accountId);
  1653. if (!pa.auth_mobile) {
  1654. throw '未绑定手机号';
  1655. }
  1656. const cacheKey = 'smsCode:' + ctx.session.sessionUser.accountId;
  1657. const cacheCode = await app.redis.get(cacheKey);
  1658. if (cacheCode === null || code === undefined || cacheCode !== (code + pa.auth_mobile)) {
  1659. throw '验证码不正确!';
  1660. }
  1661. }
  1662. if ((ctx.material.auditors[ctx.material.auditors.length - 1].aid === ctx.session.sessionUser.accountId || (ctx.query.confirm === '确认设置终审审批' && ctx.session.sessionUser.is_admin)) && ctx.material.status === auditConst.status.checked && ctx.material.order === ctx.material.highOrder) {
  1663. await ctx.service.materialAudit.checkAgain(ctx.material.id, ctx.material.times);
  1664. // ctx.redirect(ctx.request.header.referer);
  1665. ctx.body = {
  1666. err: 0,
  1667. url: ctx.request.header.referer,
  1668. msg: '',
  1669. };
  1670. } else {
  1671. throw '您无权进行该操作';
  1672. }
  1673. } catch (err) {
  1674. this.log(err);
  1675. // ctx.session.postError = err.toString();
  1676. // ctx.redirect(ctx.request.header.referer);
  1677. ctx.body = {
  1678. err: 1,
  1679. // url: ctx.request.header.referer,
  1680. msg: err,
  1681. };
  1682. }
  1683. }
  1684. }
  1685. return MaterialController;
  1686. };