glj_controller.js 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907
  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. let id = request.body.id;
  200. id = parseInt(id);
  201. let responseData = {
  202. err: 0,
  203. msg: ''
  204. };
  205. try {
  206. if (isNaN(id) || id <= 0) {
  207. throw '参数错误';
  208. }
  209. let mixRatioModel = new MixRatioModel();
  210. let result = await mixRatioModel.deleteById(id);
  211. if (!result) {
  212. throw '删除失败';
  213. }
  214. } catch (error) {
  215. responseData.err = 1;
  216. responseData.msg = error;
  217. }
  218. response.json(responseData);
  219. }
  220. //添加组成物
  221. async addMixRatio(request,response){
  222. let result={
  223. error:0
  224. };
  225. try {
  226. let data = request.body.data;
  227. data = JSON.parse(data);
  228. let gljList = data.gljList, parentInfo = data.parentInfo,mixRatios = [];
  229. let projectGljModel = new GLJListModel();
  230. let mixRatioModel = new MixRatioModel();
  231. if(gljList.length > 0){
  232. let [unitFileId,ext] = await ration_glj_facade.prepareExtData(gljList[0].project_id,request.session.sessionCompilation);
  233. for(let g of gljList){
  234. let newProjectGLJ = await projectGljModel.addList(g,unitFileId,ext);
  235. let mixRatio = {
  236. glj_id:newProjectGLJ.glj_id,
  237. consumption:0,
  238. unit_price_file_id:unitFileId,
  239. connect_key:parentInfo.connect_key,
  240. type: newProjectGLJ.type,
  241. code: newProjectGLJ.code,
  242. specs:newProjectGLJ.specs,
  243. name:newProjectGLJ.name,
  244. unit:newProjectGLJ.unit,
  245. model:newProjectGLJ.model
  246. };
  247. newProjectGLJ.ratio_data = await mixRatioModel.add(mixRatio);
  248. mixRatios.push(newProjectGLJ);
  249. }
  250. }
  251. result.data = mixRatios;
  252. }catch (err){
  253. logger.err(err);
  254. result.error=1;
  255. result.message = err.message;
  256. }
  257. response.json(result);
  258. }
  259. /**
  260. * 获取项目与单价文件对应的数据
  261. *
  262. * @param {object} request
  263. * @param {object} response
  264. * @return {void}
  265. */
  266. async getProjectInfo(request, response) {
  267. if(typeof request.body.data == "string"){
  268. request.body = JSON.parse(request.body.data)
  269. }
  270. let projectId = request.body.project_id;
  271. let rootProjectID = request.body.rootProjectID;
  272. projectId = parseInt(projectId);
  273. const notDeleted = [{deleteInfo: null}, {'deleteInfo.deleted': false}];
  274. let responseData = {
  275. err: 0,
  276. data: null
  277. };
  278. try {
  279. let sessionUserData = request.session.sessionUser;
  280. //获取当前单位工程
  281. let currentTender = await projectModel.findOne({ID: projectId, $or: notDeleted});
  282. // 获取对应用户所有的建设项目数据
  283. let projectList = await ProjectModel.getUserProjectData(sessionUserData.id,request.session.sessionCompilation._id);
  284. //获取对应用户所有文件夹
  285. let folders = await projectModel.find({userID: sessionUserData.id, $or: notDeleted, projType: 'Folder'}, {_id: 0, name: 1, ID: 1, NextSiblingID: 1, ParentID: 1});
  286. if(currentTender === null){
  287. throw '当前单位工程不存在';
  288. }
  289. if (projectList === null) {
  290. throw '没有找到对应的项目数据';
  291. }
  292. // 转换mongoose数据
  293. projectList = JSON.stringify(projectList);
  294. projectList = JSON.parse(projectList);
  295. let result = {
  296. self: [],
  297. other: [],
  298. treeData: []
  299. };
  300. for (let index in projectList) {
  301. // 获取对应的单价文件
  302. let unitPriceFileModel = new UnitPriceFileModel();
  303. let unitPriceFileData = await unitPriceFileModel.getDataByRootProject(projectList[index].ID);
  304. projectList[index].unitPriceList = unitPriceFileData;
  305. // 归类
  306. if (rootProjectID == projectList[index].ID) {
  307. //剔除自身
  308. let currentUsedUF = currentTender.property.unitPriceFile.id;
  309. result.self = _.filter(unitPriceFileData, function (uf) {
  310. return uf.id !== currentUsedUF;
  311. });
  312. result.currentProjectName = projectList[index].name;
  313. } else {
  314. result.other.push(projectList[index]);
  315. }
  316. result.treeData.push({name: projectList[index].name, ID: projectList[index].ID, NextSiblingID: projectList[index].NextSiblingID, ParentID: projectList[index].ParentID});
  317. }
  318. result.treeData = result.treeData.concat(folders);
  319. responseData.data = result;
  320. response.json(responseData);
  321. } catch (error) {
  322. responseData.err = 1;
  323. response.json(responseData);
  324. }
  325. }
  326. /**
  327. * 更改单价文件
  328. *
  329. * @param {object} request
  330. * @param {object} response
  331. * @return {void}
  332. */
  333. async changeUnitPriceFile(request, response) {
  334. let projectId = request.body.project_id;
  335. let changeUnitPriceId = request.body.change_id;
  336. let newName = request.body.newName;
  337. let type = request.body.type;
  338. type = parseInt(type);
  339. let responseData = {
  340. err: 0,
  341. msg: ''
  342. };
  343. try {
  344. responseData.unitFile = await glj_facade.changeUnitFile({projectID:projectId}, {id:changeUnitPriceId,name:newName},type,request.session.sessionUser.id);
  345. } catch (error) {
  346. console.log(error);
  347. responseData.err = 1;
  348. responseData.msg = error;
  349. }
  350. response.json(responseData);
  351. }
  352. async changeVvTaxFile(request, response){
  353. let result={error:0};
  354. try {
  355. let data = JSON.parse(request.body.data);
  356. await glj_facade.changeVvTaxFile(data);
  357. }catch (err){
  358. logger.err(err);
  359. result.error=1;
  360. result.message = err.message;
  361. }
  362. response.json(result);
  363. }
  364. async changeAssistProductionFeeRate(request, response){
  365. let result={error:0};
  366. try {
  367. let data = JSON.parse(request.body.data);
  368. await glj_facade.changeAssistProductionFeeRate(data);
  369. }catch (err){
  370. logger.err(err);
  371. result.error=1;
  372. result.message = err.message;
  373. }
  374. response.json(result);
  375. }
  376. async updateMaterialCalc(request, response){
  377. let result={error:0};
  378. try {
  379. let data = JSON.parse(request.body.data);
  380. result.data = await glj_facade.updateMaterialCalc(data);
  381. }catch (err){
  382. logger.err(err);
  383. result.error=1;
  384. result.message = err.message;
  385. }
  386. response.json(result);
  387. }
  388. async updateMaterialCalcTasks(request, response){
  389. let result={error:0};
  390. try {
  391. let data = JSON.parse(request.body.data);
  392. result.data = await glj_facade.updateMaterialCalcTasks(data);
  393. }catch (err){
  394. logger.err(err);
  395. result.error=1;
  396. result.message = err.message;
  397. }
  398. response.json(result);
  399. }
  400. async updateUserFreight(request, response){
  401. let result={error:0};
  402. try {
  403. let data = JSON.parse(request.body.data);
  404. result.data = await glj_facade.updateUserFreight(data,request);
  405. }catch (err){
  406. logger.err(err);
  407. result.error=1;
  408. result.message = err.message;
  409. }
  410. response.json(result);
  411. }
  412. async checkUnitFileName(request, response){
  413. let result={
  414. error:0
  415. }
  416. try {
  417. let data = request.body.data;
  418. let nameExist = false;
  419. data = JSON.parse(data);
  420. let unitPriceFileModel = new UnitPriceFileModel();
  421. let count = await unitPriceFileModel.model.count({root_project_id:data.rootProjectID,name:data.name,deleteInfo:null});
  422. if(count>0){
  423. nameExist = true;
  424. }else {
  425. nameExist = false;
  426. }
  427. result.data= nameExist;
  428. }catch (err){
  429. console.log(err);
  430. result.error=1;
  431. result.message = err.message;
  432. }
  433. response.json(result);
  434. }
  435. /**
  436. * 单价文件另存为
  437. *
  438. * @param {object} request
  439. * @param {object} response
  440. * @return {void}
  441. */
  442. async unitPriceSaveAs(request, response) {
  443. let responseData = {
  444. err: 0,
  445. msg: ''
  446. };
  447. let projectId = request.body.project_id;
  448. let name = request.body.name;
  449. try {
  450. // 当前单价文件id
  451. let currentUnitPriceId = await ProjectModel.getUnitPriceFileId(projectId);
  452. // 获取当前项目的rootProjectId
  453. let projectData = await ProjectModel.getProject(projectId);
  454. let rootProjectId = projectData.property.rootProjectID !== undefined ? projectData.property.rootProjectID : 0;
  455. // 新增单价文件信息
  456. let unitPriceFileModel = new UnitPriceFileModel();
  457. let insertData = {
  458. name: name,
  459. project_id: projectId,
  460. user_id: request.session.sessionUser.id,
  461. root_project_id: rootProjectId
  462. };
  463. let addResult = await unitPriceFileModel.add(insertData);
  464. if (!addResult) {
  465. throw '单价文件另存为失败';
  466. }
  467. // 查找对应单价文件的项目工料机数据
  468. let unitPriceModel = new UnitPriceModel();
  469. let copyResult = await unitPriceModel.copyNotExist(currentUnitPriceId, addResult.id,projectId);
  470. // 复制成功后更改project数据
  471. if (!copyResult) {
  472. throw '复制数据失败';
  473. }
  474. await ProjectModel.updateUnitFileToProject(projectId,{id:addResult.id,name:addResult.name});
  475. responseData.data = addResult;
  476. } catch (error) {
  477. responseData.err = 1;
  478. responseData.msg = error;
  479. }
  480. response.json(responseData);
  481. }
  482. /**
  483. * 获取项目中所有组成物数据(用户缓存到前端变量)
  484. *
  485. * @param {object} request
  486. * @param {object} response
  487. * @return {void}
  488. */
  489. async getComposition(request, response) {
  490. let projectId = request.body.project_id;
  491. projectId = parseInt(projectId);
  492. let responseData = {
  493. err: 0,
  494. data: null
  495. };
  496. try {
  497. // 当前单价文件id
  498. let currentUnitPriceId = await ProjectModel.getUnitPriceFileId(projectId);
  499. if (currentUnitPriceId <= 0) {
  500. throw '没有找到对应的单价文件';
  501. }
  502. // 获取组成物数据
  503. let mixRatioModel = new MixRatioModel();
  504. let compositionData = await mixRatioModel.findDataByCondition({unit_price_file_id: currentUnitPriceId}, null, false);
  505. if (compositionData === null) {
  506. throw '没有找到组成物数据';
  507. }
  508. compositionData = JSON.parse(JSON.stringify(compositionData));
  509. // 查找对应的单价数据
  510. let unitPriceModel = new UnitPriceModel();
  511. let unitPriceData = await unitPriceModel.findDataByCondition({unit_price_file_id: currentUnitPriceId}, null, false, 'glj_id');
  512. // 整理数据
  513. let result = {};
  514. for(let composition of compositionData) {
  515. let tmpId = composition.glj_id !== undefined ? composition.glj_id : -1;
  516. let tmpData = {
  517. market_price: unitPriceData[tmpId] !== undefined ?
  518. unitPriceData[tmpId].market_price : 0,
  519. base_price: unitPriceData[tmpId] !== undefined ?
  520. unitPriceData[tmpId].base_price : 0,
  521. consumption: composition.consumption,
  522. glj_type: composition.glj_type,
  523. connect_code: composition.connect_code
  524. };
  525. if (result[tmpId] === undefined) {
  526. result[tmpId] = [];
  527. }
  528. result[tmpId].push(tmpData);
  529. }
  530. responseData.data = result;
  531. } catch (error) {
  532. responseData.err = 1;
  533. responseData.data = null;
  534. }
  535. response.json(responseData);
  536. }
  537. /**
  538. * 模拟定额插入
  539. *
  540. * @param {object} request
  541. * @param {object} response
  542. * @return {void}
  543. */
  544. async test(request, response) {
  545. // 从定额库获取的数据
  546. let data = {
  547. glj_id: 17,
  548. project_id: 1,
  549. code: '00010201',
  550. name: '土石方综合工日',
  551. specs: '',
  552. unit: '工日',
  553. type: GLJTypeConst.LABOUR,
  554. base_price: 50,
  555. market_price: 50
  556. };
  557. try {
  558. let gljListModel = new GLJListModel();
  559. let result = await gljListModel.addList(data);
  560. } catch (error) {
  561. console.log(error);
  562. }
  563. response.end('success');
  564. }
  565. /**
  566. * 模拟定额修改单价
  567. *
  568. * @param {object} request
  569. * @param {object} response
  570. * @return {void}
  571. */
  572. async testModify(request, response) {
  573. let projectId = request.query.project;
  574. // 修改数据
  575. let updateData = {
  576. code: '36290101',
  577. market_price: '13',
  578. name: '水(10)',
  579. project_id: projectId
  580. };
  581. try {
  582. let gljListModel = new GLJListModel();
  583. let result = await gljListModel.modifyMarketPrice(updateData);
  584. console.log(result);
  585. } catch (error) {
  586. console.log(error);
  587. }
  588. response.end('success');
  589. }
  590. /**
  591. * 测试删除
  592. *
  593. * @param {object} request
  594. * @param {object} response
  595. * @return {void}
  596. */
  597. async delete(request, response) {
  598. try {
  599. let gljListModel = new GLJListModel();
  600. let result = await gljListModel.deleteById(63);
  601. console.log(result);
  602. } catch (error) {
  603. console.log(error);
  604. }
  605. response.end('success');
  606. }
  607. async updateUnitPrice(req, res){
  608. let result={
  609. error:0
  610. }
  611. try {
  612. let data = req.body.data;
  613. data = JSON.parse(data);
  614. let unitPriceModel = new UnitPriceModel();
  615. // 更新数据
  616. let datas = await unitPriceModel.updateUnitPrice(data);
  617. result.data=datas;
  618. }catch (err){
  619. logger.err(err);
  620. result.error=1;
  621. result.message = err.message;
  622. }
  623. res.json(result);
  624. }
  625. async updateCalcMaterial(req, res){
  626. let result={
  627. error:0
  628. }
  629. try {
  630. let data = req.body.data;
  631. data = JSON.parse(data);
  632. let unitPriceModel = new UnitPriceModel();
  633. // 更新数据
  634. let datas = await unitPriceModel.updateCalcMaterial(data);
  635. result.data=datas;
  636. }catch (err){
  637. logger.err(err);
  638. result.error=1;
  639. result.message = err.message;
  640. }
  641. res.json(result);
  642. }
  643. async batchUpdatePrices(req, res){
  644. let result={
  645. error:0
  646. }
  647. try {
  648. let data = req.body.data;
  649. data = JSON.parse(data);
  650. let unitPriceModel = new UnitPriceModel();
  651. // 更新数据
  652. let datas = await unitPriceModel.batchUpdatePrices(data);
  653. result.data=datas;
  654. }catch (err){
  655. logger.err(err);
  656. result.error=1;
  657. result.message = err.message;
  658. }
  659. res.json(result);
  660. }
  661. async batchUpdateGLJProperty(req, res){
  662. let result={
  663. error:0
  664. };
  665. try {
  666. let data = req.body.data;
  667. data = JSON.parse(data);
  668. let tasks = [];
  669. for(let key in data){
  670. let doc = data[key];
  671. let query = {id:parseInt(key)};
  672. let task = {updateOne:{filter:query, update :doc}};
  673. tasks.push(task);
  674. }
  675. if(tasks.length > 0){
  676. let gljModel = new GLJListModel().model;
  677. await gljModel.bulkWrite(tasks);
  678. }
  679. result.data=data;
  680. }catch (err){
  681. logger.err(err);
  682. result.error=1;
  683. result.message = err.message;
  684. }
  685. res.json(result);
  686. }
  687. async batchUpdateConsumption(req,res){
  688. let result={
  689. error:0
  690. };
  691. try {
  692. let data = req.body.data;
  693. data = JSON.parse(data);
  694. let mixTasks = [],parent = null;
  695. for(let d of data){
  696. if(d.type == 'mix_ratio'){
  697. let task = {updateOne:{filter:d.query, update :d.doc}};
  698. mixTasks.push(task);
  699. }else if(d.type =='parent'){
  700. parent = d;
  701. }
  702. }
  703. if(mixTasks.length > 0){
  704. let mixRatioModel = new MixRatioModel().model;
  705. await mixRatioModel.bulkWrite(mixTasks);
  706. }
  707. if(parent){
  708. let indexList = ['code','name','specs','unit','type'];
  709. let keyList = parent.connect_key.split("|-|");
  710. let condition = {unit_price_file_id: parent.unit_price_file_id};
  711. for(let i = 1;i<keyList.length;i++){
  712. if(keyList[i]!='null'){
  713. condition[indexList[i]]=keyList[i];
  714. }
  715. }
  716. let unitPriceUpdate = {
  717. base_price: parent.base_price,
  718. market_price: parent.market_price
  719. };
  720. let unitPriceModel = new UnitPriceModel();
  721. let unitPriceResult = await unitPriceModel.updatePrice(condition, unitPriceUpdate);
  722. if (!unitPriceResult) {
  723. throw '更新单价数据失败';
  724. }
  725. }
  726. result.data = "ok";
  727. }catch (err){
  728. logger.err(err);
  729. result.error=1;
  730. result.message = err.message;
  731. }
  732. res.json(result);
  733. }
  734. async modifyKeyValue(req,res){//修改工料机关键的属性:名称、类型、规格、型号等
  735. let result={
  736. error:0
  737. }
  738. try {
  739. let data = req.body.data;
  740. data = JSON.parse(data);
  741. let gljListModel = new GLJListModel();
  742. let ration_data = await ration.findOne(data.ration);
  743. // 修改项目工料机
  744. let projcetGLJ = await gljListModel.modifyGLJ(data.updateData,ration_data);
  745. // let datas = await gljListModel.addList(data);
  746. result.data=projcetGLJ;
  747. }catch (err){
  748. logger.err(err);
  749. result.error=1;
  750. result.message = err.message;
  751. }
  752. res.json(result);
  753. }
  754. async getVvTaxList(req,res){
  755. let vvTxtList = [];
  756. try {
  757. let egnrModel = new EngineeringLibModel();
  758. let egnr = await egnrModel.getEngineering(req.query.engineeringID);
  759. vvTxtList = egnr.vvTax_lib;
  760. }catch (err){
  761. logger.err(err);
  762. }
  763. res.json(vvTxtList);
  764. }
  765. async getUserFreights(req,res){
  766. let userFreights = [];
  767. try {
  768. userFreights = await await glj_facade.getUserFreights(req);
  769. }catch (err){
  770. logger.err(err);
  771. }
  772. res.json(userFreights);
  773. }
  774. async getProjectGLJsByProjectID(projectId){
  775. return await getGLJListByProjectID(projectId)
  776. }
  777. }
  778. /**
  779. * 取项目工料机列表
  780. * @param projectId
  781. * @returns {Promise.<void>}
  782. */
  783. async function getGLJListByProjectID(projectId){
  784. let responseData = {
  785. err: 0,
  786. msg: '',
  787. data: {}
  788. };
  789. try {
  790. if (isNaN(projectId) || projectId <= 0) {
  791. throw '标段id有误';
  792. }
  793. // 获取标段对应的单价文件id
  794. let unitPriceFileId = await ProjectModel.getUnitPriceFileId(projectId);
  795. if (unitPriceFileId <= 0) {
  796. throw '没有对应的单价文件';
  797. }
  798. // 获取使用该单价文件的项目数据
  799. let tenderData = await ProjectModel.getTenderByUnitPriceFileId(unitPriceFileId);
  800. let usedTenderList = [];
  801. let usedUnitPriceInfo = {};
  802. if (tenderData !== null) {
  803. for (let tmp of tenderData) {
  804. usedTenderList.push(tmp.name);
  805. usedUnitPriceInfo.name = tmp.property.unitPriceFile.name;
  806. usedUnitPriceInfo.id = tmp.property.unitPriceFile.id;
  807. }
  808. }
  809. responseData.data.originalList = await original_calc_model.find({"unit_price_file_id":unitPriceFileId}).lean();
  810. responseData.data.freightList = await freight_calc_model .find({"unit_price_file_id":unitPriceFileId}).lean();
  811. responseData.data.com_electrovalence = await com_electrovalence_model.findOne({"unit_price_file_id":unitPriceFileId}).lean();
  812. //if(!responseData.data.com_electrovalence) responseData.data.com_electrovalence = {};
  813. // 先获取对应标段的项目工料机数据
  814. let gljListModel = new GLJListModel();
  815. let [gljList, mixRatioConnectData,mixRatioMap,unitPriceMap] = await gljListModel.getListByProjectId(projectId, unitPriceFileId,responseData.data.freightList,responseData.data.originalList);
  816. responseData.data.gljList = gljList;
  817. responseData.data.mixRatioConnectData = mixRatioConnectData;
  818. responseData.data.mixRatioMap = mixRatioMap;
  819. responseData.data.usedTenderList = usedTenderList;
  820. responseData.data.unitPriceMap = unitPriceMap;
  821. let gljTypeMap = glj_type_util.getStdGljTypeCacheObj().innerGljTypeObj;
  822. let unitPriceFileModel = new UnitPriceFileModel();
  823. let unitFileInfo = await unitPriceFileModel.findDataByCondition({id: unitPriceFileId});
  824. responseData.data.constData = {
  825. materialIdList: gljListModel.materialIdList,
  826. ownCompositionTypes: gljListModel.ownCompositionTypes,
  827. roomId: unitPriceFileId,
  828. GLJTypeConst: JSON.stringify(GLJTypeConst),
  829. usedUnitPriceInfo: usedUnitPriceInfo,
  830. gljTypeMap:gljTypeMap,
  831. vvTaxFileID:unitFileInfo.vvTaxFileID,
  832. assistProductionFeeRate:unitFileInfo.assistProductionFeeRate?unitFileInfo.assistProductionFeeRate:3
  833. };
  834. } catch (error) {
  835. console.log(error);
  836. responseData.err = 1;
  837. responseData.msg = error;
  838. }
  839. return responseData;
  840. }
  841. export default GLJController;