glj_controller.js 32 KB

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