glj_controller.js 28 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822
  1. /**
  2. * 工料机相关控制器
  3. *
  4. * @author CaiAoLin
  5. * @date 2017/6/22
  6. * @version
  7. */
  8. const BaseController = require("../../common/base/base_controller");
  9. const GLJTypeConst = require("../../common/const/glj_type_const");
  10. const GLJListModel = require("../models/glj_list_model");
  11. const UnitPriceModel = require("../models/unit_price_model");
  12. const MixRatioModel = require("../models/mix_ratio_model");
  13. const UnitPriceFileModel = require("../models/unit_price_file_model");
  14. let logger = require("../../../logs/log_helper").logger;
  15. let consts = require('../../main/models/project_consts');
  16. let glj_type_util = require('../../../public/cache/std_glj_type_util');
  17. let ration_glj_facade = require('../../ration_glj/facade/ration_glj_facade');
  18. let mongoose = require('mongoose');
  19. let ration = mongoose.model('ration');
  20. let projectModel = mongoose.model('projects');
  21. let _ = require('lodash');
  22. let glj_facade = require('../facade/glj_facade');
  23. const ProjectModel = require('../../pm/models/project_model').project;
  24. class GLJController extends BaseController {
  25. /**
  26. * 构造函数
  27. *
  28. * @return {void}
  29. */
  30. constructor() {
  31. let parent = super();
  32. parent.title = '工料机';
  33. }
  34. /**
  35. * 获取工料机相关数据
  36. *
  37. * @param {object} request
  38. * @param {object} response
  39. * @return {void}
  40. */
  41. async getGljList(request, response) {
  42. // 标段id
  43. let projectId = request.body.project_id;
  44. projectId = parseInt(projectId);
  45. let responseData = await getGLJListByProjectID(projectId);
  46. responseData.hostname = request.hostname;
  47. response.json(responseData);
  48. }
  49. /**
  50. * project getData 接口
  51. * @param projectID
  52. * @param callback
  53. */
  54. getData(projectID, callback){
  55. let start = +new Date();
  56. getGLJListByProjectID(projectID).then(function(result){
  57. let end = +new Date();
  58. console.log("项目工料机模块取数据总时间-----"+(end - start));
  59. // 项目工料机数据,这里只有最基础数据,调价后数据在 rpt_construct_data_util.js 的 assembleData() 方法中专门封装(在这里处理不了)。
  60. callback(result.err,consts.projectConst.PROJECTGLJ,result.data);
  61. })
  62. }
  63. async updateRatio(request, response) {
  64. let data = JSON.parse(request.body.data);
  65. let model = new MixRatioModel();
  66. if(data.type == 'delete'){
  67. await model.deleteById(data.id);
  68. }else{
  69. await model.updateById(data.id, data.doc);
  70. }
  71. let unitPriceUpdate = {
  72. base_price: data.base_price,
  73. market_price: data.market_price
  74. };
  75. let unitPriceModel = new UnitPriceModel();
  76. let unitPriceResult = await unitPriceModel.updatePrice({id:data.pid}, unitPriceUpdate);
  77. response.json(unitPriceResult);
  78. }
  79. /**
  80. * 更新数据
  81. *
  82. * @param {object} request
  83. * @param {object} response
  84. * @return {void}
  85. */
  86. async updateData(request, response) {
  87. let field = request.body.field;
  88. let value = request.body.value;
  89. let extend = request.body.extend;
  90. value = value === 'true' ? 1 : value;
  91. value = value === 'false' ? 0 : value;
  92. let id = request.body.id;
  93. let responseData = {
  94. err: 0,
  95. msg: ''
  96. };
  97. try {
  98. // 可编辑的字段
  99. let editableField = ['is_evaluate','unit_price.taxRate', 'unit_price.market_price', 'is_adjust_price', 'mix_ratio.consumption','is_eval_material','no_tax_eqp','is_coe_adjust','is_info_adjust','FI','FO','standardPrice','riskCoe',
  100. 'supply', 'supply_quantity','delivery_address','delivery','materialType','materialCoe','is_main_material','originPlace','vender','qualityGrace','brand','remark'];
  101. if (editableField.indexOf(field) < 0) {
  102. throw '对应字段不能编辑';
  103. }
  104. let modelString = 'glj';
  105. // 切割字段
  106. let fieldArray = field.split('.');
  107. modelString = fieldArray.length > 1 ? fieldArray[0] : modelString;
  108. field = fieldArray.length > 1 ? fieldArray[1] : field;
  109. // 组合数据
  110. let updateData = new Object();
  111. updateData[field] = value;
  112. let result = false;
  113. let model = null;
  114. switch (modelString) {
  115. case 'glj':
  116. if (extend&&extend !== '') {
  117. extend = JSON.parse(extend);
  118. for (let code in extend) {
  119. updateData[code] = extend[code];
  120. }
  121. }
  122. console.log(updateData);
  123. model = new GLJListModel();
  124. // 更新数据
  125. result = await model.updateById(id, updateData);
  126. break;
  127. case 'unit_price':
  128. model = new UnitPriceModel();
  129. // 更新数据
  130. result = await model.updatePrice({id: id}, updateData, extend);
  131. break;
  132. case 'mix_ratio':
  133. let marketPrice = request.body.market_price;
  134. let basePrice = request.body.base_price;
  135. model = new MixRatioModel();
  136. result = await model.updateById(id, updateData);
  137. if (result && marketPrice && basePrice) {
  138. // 修改后更新父节点的项目工料机市场单价
  139. let mixRatioData = await model.findDataByCondition({id: id});
  140. if (mixRatioData.length <= 0) {
  141. break;
  142. }
  143. let indexList = ['code','name','specs','unit','type'];
  144. let keyList = mixRatioData.connect_key.split("|-|");
  145. // 更新市场单价和基价单价
  146. let condition = {unit_price_file_id: mixRatioData.unit_price_file_id};
  147. for(let i = 1;i<keyList.length;i++){
  148. if(keyList[i]!='null'){
  149. condition[indexList[i]]=keyList[i];
  150. }
  151. }
  152. let unitPriceUpdate = {
  153. base_price: basePrice,
  154. market_price: marketPrice
  155. };
  156. let unitPriceModel = new UnitPriceModel();
  157. let unitPriceResult = await unitPriceModel.updatePrice(condition, unitPriceUpdate);
  158. if (!unitPriceResult) {
  159. throw '更新单价数据失败';
  160. }
  161. }
  162. break;
  163. }
  164. if (!result) {
  165. throw '更新失败';
  166. }
  167. } catch (error) {
  168. console.log('error:' + error);
  169. responseData.err = 1;
  170. }
  171. response.json(responseData);
  172. }
  173. /**
  174. * 加载配合比相关数据
  175. *
  176. * @return {void}
  177. */
  178. async getRatio(request, response) {
  179. let projectGLJId = request.body.id;
  180. let projectId = request.body.project_id;
  181. let responseData = {
  182. err: 0,
  183. data: null
  184. };
  185. try {
  186. // 获取标段对应的单价文件id
  187. let unitPriceFileId = await ProjectModel.getUnitPriceFileId(projectId);
  188. if (unitPriceFileId <= 0) {
  189. throw '没有对应的单价文件';
  190. }
  191. let gljListModel = new GLJListModel();
  192. let result = await gljListModel.getCompositionList(projectGLJId, unitPriceFileId);
  193. if (result.length <= 0) {
  194. throw '没有找到数据';
  195. }
  196. responseData.data = JSON.stringify(result);
  197. } catch (error) {
  198. console.log(error);
  199. responseData.err = 1;
  200. }
  201. response.json(responseData);
  202. }
  203. /**
  204. * 删除配合比数据
  205. *
  206. * @param {object} request
  207. * @param {object} response
  208. * @return {void}
  209. */
  210. async deleteMixRatio(request, response) {
  211. if(request.body.data){
  212. let data = request.body.data;
  213. request.body = JSON.parse(data);
  214. }
  215. let id = request.body.id;
  216. id = parseInt(id);
  217. let responseData = {
  218. err: 0,
  219. msg: ''
  220. };
  221. try {
  222. if (isNaN(id) || id <= 0) {
  223. throw '参数错误';
  224. }
  225. let mixRatioModel = new MixRatioModel();
  226. let result = await mixRatioModel.deleteById(id);
  227. if (!result) {
  228. throw '删除失败';
  229. }
  230. } catch (error) {
  231. responseData.err = 1;
  232. responseData.msg = error;
  233. }
  234. response.json(responseData);
  235. }
  236. //添加组成物
  237. async addMixRatio(request,response){
  238. let result={
  239. error:0
  240. };
  241. try {
  242. let data = request.body.data;
  243. data = JSON.parse(data);
  244. let gljList = data.gljList, parentInfo = data.parentInfo,mixRatios = [];
  245. let projectGljModel = new GLJListModel();
  246. let mixRatioModel = new MixRatioModel();
  247. if(gljList.length > 0){
  248. let [unitFileId,ext] = await ration_glj_facade.prepareExtData(gljList[0].project_id,request.session.sessionCompilation);
  249. console.log(ext);
  250. for(let g of gljList){
  251. let newProjectGLJ = await projectGljModel.addList(g,unitFileId,ext);
  252. let mixRatio = {
  253. glj_id:newProjectGLJ.glj_id,
  254. consumption:0,
  255. unit_price_file_id:unitFileId,
  256. connect_key:parentInfo.connect_key,
  257. type: newProjectGLJ.type,
  258. code: newProjectGLJ.code,
  259. specs:newProjectGLJ.specs,
  260. name:newProjectGLJ.name,
  261. unit:newProjectGLJ.unit,
  262. model:newProjectGLJ.model
  263. };
  264. newProjectGLJ.ratio_data = await mixRatioModel.add(mixRatio);
  265. mixRatios.push(newProjectGLJ);
  266. }
  267. }
  268. result.data = mixRatios;
  269. }catch (err){
  270. logger.err(err);
  271. result.error=1;
  272. result.message = err.message;
  273. }
  274. response.json(result);
  275. }
  276. /**
  277. * 获取项目与单价文件对应的数据
  278. *
  279. * @param {object} request
  280. * @param {object} response
  281. * @return {void}
  282. */
  283. async getProjectInfo(request, response) {
  284. if(typeof request.body.data == "string"){
  285. request.body = JSON.parse(request.body.data)
  286. }
  287. let projectId = request.body.project_id;
  288. let rootProjectID = request.body.rootProjectID;
  289. projectId = parseInt(projectId);
  290. const notDeleted = [{deleteInfo: null}, {'deleteInfo.deleted': false}];
  291. let responseData = {
  292. err: 0,
  293. data: null
  294. };
  295. try {
  296. let sessionUserData = request.session.sessionUser;
  297. //获取当前单位工程
  298. let currentTender = await projectModel.findOne({ID: projectId, $or: notDeleted});
  299. // 获取对应用户所有的建设项目数据
  300. let projectList = await ProjectModel.getUserProjectData(sessionUserData.id,request.session.sessionCompilation._id);
  301. //获取对应用户所有文件夹
  302. let folders = await projectModel.find({userID: sessionUserData.id, $or: notDeleted, projType: 'Folder'}, {_id: 0, name: 1, ID: 1, NextSiblingID: 1, ParentID: 1});
  303. if(currentTender === null){
  304. throw '当前单位工程不存在';
  305. }
  306. if (projectList === null) {
  307. throw '没有找到对应的项目数据';
  308. }
  309. // 转换mongoose数据
  310. projectList = JSON.stringify(projectList);
  311. projectList = JSON.parse(projectList);
  312. let result = {
  313. self: [],
  314. other: [],
  315. treeData: []
  316. };
  317. for (let index in projectList) {
  318. // 获取对应的单价文件
  319. let unitPriceFileModel = new UnitPriceFileModel();
  320. let unitPriceFileData = await unitPriceFileModel.getDataByRootProject(projectList[index].ID);
  321. projectList[index].unitPriceList = unitPriceFileData;
  322. // 归类
  323. if (rootProjectID == projectList[index].ID) {
  324. //剔除自身
  325. let currentUsedUF = currentTender.property.unitPriceFile.id;
  326. result.self = _.filter(unitPriceFileData, function (uf) {
  327. return uf.id !== currentUsedUF;
  328. });
  329. result.currentProjectName = projectList[index].name;
  330. } else {
  331. result.other.push(projectList[index]);
  332. }
  333. result.treeData.push({name: projectList[index].name, ID: projectList[index].ID, NextSiblingID: projectList[index].NextSiblingID, ParentID: projectList[index].ParentID});
  334. }
  335. result.treeData = result.treeData.concat(folders);
  336. responseData.data = result;
  337. response.json(responseData);
  338. } catch (error) {
  339. responseData.err = 1;
  340. response.json(responseData);
  341. }
  342. }
  343. /**
  344. * 更改单价文件
  345. *
  346. * @param {object} request
  347. * @param {object} response
  348. * @return {void}
  349. */
  350. async changeUnitPriceFile(request, response) {
  351. let projectId = request.body.project_id;
  352. let changeUnitPriceId = request.body.change_id;
  353. let newName = request.body.newName;
  354. let type = request.body.type;
  355. type = parseInt(type);
  356. let responseData = {
  357. err: 0,
  358. msg: ''
  359. };
  360. try {
  361. responseData.unitFile = await glj_facade.changeUnitFile({projectID:projectId}, {id:changeUnitPriceId,name:newName},type,request.session.sessionUser.id);
  362. } catch (error) {
  363. console.log(error);
  364. responseData.err = 1;
  365. responseData.msg = error;
  366. }
  367. response.json(responseData);
  368. }
  369. async checkUnitFileName(request, response){
  370. let result={
  371. error:0
  372. }
  373. try {
  374. let data = request.body.data;
  375. let nameExist = false;
  376. data = JSON.parse(data);
  377. let unitPriceFileModel = new UnitPriceFileModel();
  378. let count = await unitPriceFileModel.model.count({root_project_id:data.rootProjectID,name:data.name,deleteInfo:null});
  379. if(count>0){
  380. nameExist = true;
  381. }else {
  382. nameExist = false;
  383. }
  384. result.data= nameExist;
  385. }catch (err){
  386. console.log(err);
  387. result.error=1;
  388. result.message = err.message;
  389. }
  390. response.json(result);
  391. }
  392. /**
  393. * 单价文件另存为
  394. *
  395. * @param {object} request
  396. * @param {object} response
  397. * @return {void}
  398. */
  399. async unitPriceSaveAs(request, response) {
  400. let responseData = {
  401. err: 0,
  402. msg: ''
  403. };
  404. let projectId = request.body.project_id;
  405. let name = request.body.name;
  406. try {
  407. // 当前单价文件id
  408. let currentUnitPriceId = await ProjectModel.getUnitPriceFileId(projectId);
  409. // 获取当前项目的rootProjectId
  410. let projectData = await ProjectModel.getProject(projectId);
  411. let rootProjectId = projectData.property.rootProjectID !== undefined ? projectData.property.rootProjectID : 0;
  412. // 新增单价文件信息
  413. let unitPriceFileModel = new UnitPriceFileModel();
  414. let insertData = {
  415. name: name,
  416. project_id: projectId,
  417. user_id: request.session.sessionUser.id,
  418. root_project_id: rootProjectId
  419. };
  420. let addResult = await unitPriceFileModel.add(insertData);
  421. if (!addResult) {
  422. throw '单价文件另存为失败';
  423. }
  424. // 查找对应单价文件的项目工料机数据
  425. let unitPriceModel = new UnitPriceModel();
  426. let copyResult = await unitPriceModel.copyNotExist(currentUnitPriceId, addResult.id,projectId);
  427. // 复制成功后更改project数据
  428. if (!copyResult) {
  429. throw '复制数据失败';
  430. }
  431. await ProjectModel.updateUnitFileToProject(projectId,{id:addResult.id,name:addResult.name});
  432. responseData.data = addResult;
  433. } catch (error) {
  434. responseData.err = 1;
  435. responseData.msg = error;
  436. }
  437. response.json(responseData);
  438. }
  439. /**
  440. * 获取项目中所有组成物数据(用户缓存到前端变量)
  441. *
  442. * @param {object} request
  443. * @param {object} response
  444. * @return {void}
  445. */
  446. async getComposition(request, response) {
  447. let projectId = request.body.project_id;
  448. projectId = parseInt(projectId);
  449. let responseData = {
  450. err: 0,
  451. data: null
  452. };
  453. try {
  454. // 当前单价文件id
  455. let currentUnitPriceId = await ProjectModel.getUnitPriceFileId(projectId);
  456. if (currentUnitPriceId <= 0) {
  457. throw '没有找到对应的单价文件';
  458. }
  459. // 获取组成物数据
  460. let mixRatioModel = new MixRatioModel();
  461. let compositionData = await mixRatioModel.findDataByCondition({unit_price_file_id: currentUnitPriceId}, null, false);
  462. if (compositionData === null) {
  463. throw '没有找到组成物数据';
  464. }
  465. compositionData = JSON.parse(JSON.stringify(compositionData));
  466. // 查找对应的单价数据
  467. let unitPriceModel = new UnitPriceModel();
  468. let unitPriceData = await unitPriceModel.findDataByCondition({unit_price_file_id: currentUnitPriceId}, null, false, 'glj_id');
  469. // 整理数据
  470. let result = {};
  471. for(let composition of compositionData) {
  472. let tmpId = composition.glj_id !== undefined ? composition.glj_id : -1;
  473. let tmpData = {
  474. market_price: unitPriceData[tmpId] !== undefined ?
  475. unitPriceData[tmpId].market_price : 0,
  476. base_price: unitPriceData[tmpId] !== undefined ?
  477. unitPriceData[tmpId].base_price : 0,
  478. consumption: composition.consumption,
  479. glj_type: composition.glj_type,
  480. connect_code: composition.connect_code
  481. };
  482. if (result[tmpId] === undefined) {
  483. result[tmpId] = [];
  484. }
  485. result[tmpId].push(tmpData);
  486. }
  487. responseData.data = result;
  488. } catch (error) {
  489. responseData.err = 1;
  490. responseData.data = null;
  491. }
  492. response.json(responseData);
  493. }
  494. /**
  495. * 模拟定额插入
  496. *
  497. * @param {object} request
  498. * @param {object} response
  499. * @return {void}
  500. */
  501. async test(request, response) {
  502. // 从定额库获取的数据
  503. let data = {
  504. glj_id: 17,
  505. project_id: 1,
  506. code: '00010201',
  507. name: '土石方综合工日',
  508. specs: '',
  509. unit: '工日',
  510. type: GLJTypeConst.LABOUR,
  511. base_price: 50,
  512. market_price: 50
  513. };
  514. try {
  515. let gljListModel = new GLJListModel();
  516. let result = await gljListModel.addList(data);
  517. } catch (error) {
  518. console.log(error);
  519. }
  520. response.end('success');
  521. }
  522. /**
  523. * 模拟定额修改单价
  524. *
  525. * @param {object} request
  526. * @param {object} response
  527. * @return {void}
  528. */
  529. async testModify(request, response) {
  530. let projectId = request.query.project;
  531. // 修改数据
  532. let updateData = {
  533. code: '36290101',
  534. market_price: '13',
  535. name: '水(10)',
  536. project_id: projectId
  537. };
  538. try {
  539. let gljListModel = new GLJListModel();
  540. let result = await gljListModel.modifyMarketPrice(updateData);
  541. console.log(result);
  542. } catch (error) {
  543. console.log(error);
  544. }
  545. response.end('success');
  546. }
  547. /**
  548. * 测试删除
  549. *
  550. * @param {object} request
  551. * @param {object} response
  552. * @return {void}
  553. */
  554. async delete(request, response) {
  555. try {
  556. let gljListModel = new GLJListModel();
  557. let result = await gljListModel.deleteById(63);
  558. console.log(result);
  559. } catch (error) {
  560. console.log(error);
  561. }
  562. response.end('success');
  563. }
  564. async updateUnitPrice(req, res){
  565. let result={
  566. error:0
  567. }
  568. try {
  569. let data = req.body.data;
  570. data = JSON.parse(data);
  571. let unitPriceModel = new UnitPriceModel();
  572. // 更新数据
  573. let datas = await unitPriceModel.updateUnitPrice(data);
  574. result.data=datas;
  575. }catch (err){
  576. logger.err(err);
  577. result.error=1;
  578. result.message = err.message;
  579. }
  580. res.json(result);
  581. }
  582. async batchUpdatePrices(req, res){
  583. let result={
  584. error:0
  585. }
  586. try {
  587. let data = req.body.data;
  588. data = JSON.parse(data);
  589. let unitPriceModel = new UnitPriceModel();
  590. // 更新数据
  591. let datas = await unitPriceModel.batchUpdatePrices(data);
  592. result.data=datas;
  593. }catch (err){
  594. logger.err(err);
  595. result.error=1;
  596. result.message = err.message;
  597. }
  598. res.json(result);
  599. }
  600. async batchUpdateGLJProperty(req, res){
  601. let result={
  602. error:0
  603. };
  604. try {
  605. let data = req.body.data;
  606. data = JSON.parse(data);
  607. let tasks = [];
  608. for(let key in data){
  609. let doc = data[key];
  610. let query = {id:parseInt(key)};
  611. let task = {updateOne:{filter:query, update :doc}};
  612. tasks.push(task);
  613. }
  614. if(tasks.length > 0){
  615. let gljModel = new GLJListModel().model;
  616. await gljModel.bulkWrite(tasks);
  617. }
  618. result.data=data;
  619. }catch (err){
  620. logger.err(err);
  621. result.error=1;
  622. result.message = err.message;
  623. }
  624. res.json(result);
  625. }
  626. async batchUpdateConsumption(req,res){
  627. let result={
  628. error:0
  629. };
  630. try {
  631. let data = req.body.data;
  632. data = JSON.parse(data);
  633. let mixTasks = [],parent = null;
  634. for(let d of data){
  635. if(d.type == 'mix_ratio'){
  636. let task = {updateOne:{filter:d.query, update :d.doc}};
  637. mixTasks.push(task);
  638. }else if(d.type =='parent'){
  639. parent = d;
  640. }
  641. }
  642. if(mixTasks.length > 0){
  643. let mixRatioModel = new MixRatioModel().model;
  644. await mixRatioModel.bulkWrite(mixTasks);
  645. }
  646. if(parent){
  647. let indexList = ['code','name','specs','unit','type'];
  648. let keyList = parent.connect_key.split("|-|");
  649. let condition = {unit_price_file_id: parent.unit_price_file_id};
  650. for(let i = 1;i<keyList.length;i++){
  651. if(keyList[i]!='null'){
  652. condition[indexList[i]]=keyList[i];
  653. }
  654. }
  655. let unitPriceUpdate = {
  656. base_price: parent.base_price,
  657. market_price: parent.market_price
  658. };
  659. let unitPriceModel = new UnitPriceModel();
  660. let unitPriceResult = await unitPriceModel.updatePrice(condition, unitPriceUpdate);
  661. if (!unitPriceResult) {
  662. throw '更新单价数据失败';
  663. }
  664. }
  665. result.data = "ok";
  666. }catch (err){
  667. logger.err(err);
  668. result.error=1;
  669. result.message = err.message;
  670. }
  671. res.json(result);
  672. }
  673. async updateEvaluateMaterial(request, response){
  674. let result={error:0};
  675. try {
  676. let data = JSON.parse(request.body.data);
  677. result.data = await glj_facade.updateEvaluateMaterial(data);
  678. }catch (err){
  679. logger.err(err);
  680. result.error=1;
  681. result.message = err.message;
  682. }
  683. response.json(result);
  684. }
  685. async modifyKeyValue(req,res){//修改工料机关键的属性:名称、类型、规格、型号等
  686. let result={
  687. error:0
  688. }
  689. try {
  690. let data = req.body.data;
  691. data = JSON.parse(data);
  692. let gljListModel = new GLJListModel();
  693. let ration_data = await ration.findOne(data.ration);
  694. // 修改项目工料机
  695. let projcetGLJ = await gljListModel.modifyGLJ(data.updateData,ration_data);
  696. // let datas = await gljListModel.addList(data);
  697. result.data=projcetGLJ;
  698. }catch (err){
  699. logger.err(err);
  700. result.error=1;
  701. result.message = err.message;
  702. }
  703. res.json(result);
  704. }
  705. async getProjectGLJsByProjectID(projectId){
  706. return await getGLJListByProjectID(projectId)
  707. }
  708. }
  709. /**
  710. * 取项目工料机列表
  711. * @param projectId
  712. * @returns {Promise.<void>}
  713. */
  714. async function getGLJListByProjectID(projectId){
  715. let responseData = {
  716. err: 0,
  717. msg: '',
  718. data: {}
  719. };
  720. try {
  721. if (isNaN(projectId) || projectId <= 0) {
  722. throw '标段id有误';
  723. }
  724. // 获取标段对应的单价文件id
  725. let unitPriceFileId = await ProjectModel.getUnitPriceFileId(projectId);
  726. if (unitPriceFileId <= 0) {
  727. throw '没有对应的单价文件';
  728. }
  729. // 获取使用该单价文件的项目数据
  730. let tenderData = await ProjectModel.getTenderByUnitPriceFileId(unitPriceFileId);
  731. let usedTenderList = [];
  732. let usedUnitPriceInfo = {};
  733. if (tenderData !== null) {
  734. for (let tmp of tenderData) {
  735. usedTenderList.push(tmp.name);
  736. usedUnitPriceInfo.name = tmp.property.unitPriceFile.name;
  737. usedUnitPriceInfo.id = tmp.property.unitPriceFile.id;
  738. }
  739. }
  740. // 先获取对应标段的项目工料机数据
  741. let gljListModel = new GLJListModel();
  742. let [gljList, mixRatioConnectData,mixRationMap,unitPriceMap] = await gljListModel.getListByProjectId(projectId, unitPriceFileId);
  743. responseData.data.gljList = gljList;
  744. responseData.data.mixRatioConnectData = mixRatioConnectData;
  745. responseData.data.mixRatioMap = mixRationMap;
  746. responseData.data.usedTenderList = usedTenderList;
  747. responseData.data.unitPriceMap = unitPriceMap;
  748. let gljTypeMap = glj_type_util.getStdGljTypeCacheObj().innerGljTypeObj;
  749. responseData.data.constData = {
  750. materialIdList: gljListModel.materialIdList,
  751. ownCompositionTypes: gljListModel.ownCompositionTypes,
  752. roomId: unitPriceFileId,
  753. GLJTypeConst: JSON.stringify(GLJTypeConst),
  754. usedUnitPriceInfo: usedUnitPriceInfo,
  755. gljTypeMap:gljTypeMap
  756. };
  757. } catch (error) {
  758. console.log(error);
  759. responseData.err = 1;
  760. responseData.msg = error;
  761. }
  762. return responseData;
  763. }
  764. module.exports = GLJController;