glj_controller.js 30 KB

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