glj_controller.js 31 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932
  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 addOriginalCalc(request, response){
  364. let result={error:0};
  365. try {
  366. let data = JSON.parse(request.body.data);
  367. result.data = await glj_facade.addOriginalCalc(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 addFreightCalc(request, response){
  376. let result={error:0};
  377. try {
  378. let data = JSON.parse(request.body.data);
  379. result.data = await glj_facade.addFreightCalc(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 deletePriceCalc(request, response){
  388. let result={error:0};
  389. try {
  390. let data = JSON.parse(request.body.data);
  391. result.data = await glj_facade.deletePriceCalc(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 updateOriginalCalc(request, response){
  400. let result={error:0};
  401. try {
  402. let data = JSON.parse(request.body.data);
  403. result.data = await glj_facade.updateOriginalCalc(data);
  404. }catch (err){
  405. logger.err(err);
  406. result.error=1;
  407. result.message = err.message;
  408. }
  409. response.json(result);
  410. }
  411. async updateMaterialCalc(request, response){
  412. let result={error:0};
  413. try {
  414. let data = JSON.parse(request.body.data);
  415. result.data = await glj_facade.updateMaterialCalc(data);
  416. }catch (err){
  417. logger.err(err);
  418. result.error=1;
  419. result.message = err.message;
  420. }
  421. response.json(result);
  422. }
  423. async updateFreightCalc(request, response){
  424. let result={error:0};
  425. try {
  426. let data = JSON.parse(request.body.data);
  427. result.data = await glj_facade.updateFreightCalc(data);
  428. }catch (err){
  429. logger.err(err);
  430. result.error=1;
  431. result.message = err.message;
  432. }
  433. response.json(result);
  434. }
  435. async deleteFreightCalc(request, response){
  436. let result={error:0};
  437. try {
  438. let data = JSON.parse(request.body.data);
  439. result.data = await glj_facade.deleteFreightCalc(data);
  440. }catch (err){
  441. logger.err(err);
  442. result.error=1;
  443. result.message = err.message;
  444. }
  445. response.json(result);
  446. }
  447. async checkUnitFileName(request, response){
  448. let result={
  449. error:0
  450. }
  451. try {
  452. let data = request.body.data;
  453. let nameExist = false;
  454. data = JSON.parse(data);
  455. let unitPriceFileModel = new UnitPriceFileModel();
  456. let count = await unitPriceFileModel.model.count({root_project_id:data.rootProjectID,name:data.name,deleteInfo:null});
  457. if(count>0){
  458. nameExist = true;
  459. }else {
  460. nameExist = false;
  461. }
  462. result.data= nameExist;
  463. }catch (err){
  464. console.log(err);
  465. result.error=1;
  466. result.message = err.message;
  467. }
  468. response.json(result);
  469. }
  470. /**
  471. * 单价文件另存为
  472. *
  473. * @param {object} request
  474. * @param {object} response
  475. * @return {void}
  476. */
  477. async unitPriceSaveAs(request, response) {
  478. let responseData = {
  479. err: 0,
  480. msg: ''
  481. };
  482. let projectId = request.body.project_id;
  483. let name = request.body.name;
  484. try {
  485. // 当前单价文件id
  486. let currentUnitPriceId = await ProjectModel.getUnitPriceFileId(projectId);
  487. // 获取当前项目的rootProjectId
  488. let projectData = await ProjectModel.getProject(projectId);
  489. let rootProjectId = projectData.property.rootProjectID !== undefined ? projectData.property.rootProjectID : 0;
  490. // 新增单价文件信息
  491. let unitPriceFileModel = new UnitPriceFileModel();
  492. let insertData = {
  493. name: name,
  494. project_id: projectId,
  495. user_id: request.session.sessionUser.id,
  496. root_project_id: rootProjectId
  497. };
  498. let addResult = await unitPriceFileModel.add(insertData);
  499. if (!addResult) {
  500. throw '单价文件另存为失败';
  501. }
  502. // 查找对应单价文件的项目工料机数据
  503. let unitPriceModel = new UnitPriceModel();
  504. let copyResult = await unitPriceModel.copyNotExist(currentUnitPriceId, addResult.id,projectId);
  505. // 复制成功后更改project数据
  506. if (!copyResult) {
  507. throw '复制数据失败';
  508. }
  509. await ProjectModel.updateUnitFileToProject(projectId,{id:addResult.id,name:addResult.name});
  510. responseData.data = addResult;
  511. } catch (error) {
  512. responseData.err = 1;
  513. responseData.msg = error;
  514. }
  515. response.json(responseData);
  516. }
  517. /**
  518. * 获取项目中所有组成物数据(用户缓存到前端变量)
  519. *
  520. * @param {object} request
  521. * @param {object} response
  522. * @return {void}
  523. */
  524. async getComposition(request, response) {
  525. let projectId = request.body.project_id;
  526. projectId = parseInt(projectId);
  527. let responseData = {
  528. err: 0,
  529. data: null
  530. };
  531. try {
  532. // 当前单价文件id
  533. let currentUnitPriceId = await ProjectModel.getUnitPriceFileId(projectId);
  534. if (currentUnitPriceId <= 0) {
  535. throw '没有找到对应的单价文件';
  536. }
  537. // 获取组成物数据
  538. let mixRatioModel = new MixRatioModel();
  539. let compositionData = await mixRatioModel.findDataByCondition({unit_price_file_id: currentUnitPriceId}, null, false);
  540. if (compositionData === null) {
  541. throw '没有找到组成物数据';
  542. }
  543. compositionData = JSON.parse(JSON.stringify(compositionData));
  544. // 查找对应的单价数据
  545. let unitPriceModel = new UnitPriceModel();
  546. let unitPriceData = await unitPriceModel.findDataByCondition({unit_price_file_id: currentUnitPriceId}, null, false, 'glj_id');
  547. // 整理数据
  548. let result = {};
  549. for(let composition of compositionData) {
  550. let tmpId = composition.glj_id !== undefined ? composition.glj_id : -1;
  551. let tmpData = {
  552. market_price: unitPriceData[tmpId] !== undefined ?
  553. unitPriceData[tmpId].market_price : 0,
  554. base_price: unitPriceData[tmpId] !== undefined ?
  555. unitPriceData[tmpId].base_price : 0,
  556. consumption: composition.consumption,
  557. glj_type: composition.glj_type,
  558. connect_code: composition.connect_code
  559. };
  560. if (result[tmpId] === undefined) {
  561. result[tmpId] = [];
  562. }
  563. result[tmpId].push(tmpData);
  564. }
  565. responseData.data = result;
  566. } catch (error) {
  567. responseData.err = 1;
  568. responseData.data = null;
  569. }
  570. response.json(responseData);
  571. }
  572. /**
  573. * 模拟定额插入
  574. *
  575. * @param {object} request
  576. * @param {object} response
  577. * @return {void}
  578. */
  579. async test(request, response) {
  580. // 从定额库获取的数据
  581. let data = {
  582. glj_id: 17,
  583. project_id: 1,
  584. code: '00010201',
  585. name: '土石方综合工日',
  586. specs: '',
  587. unit: '工日',
  588. type: GLJTypeConst.LABOUR,
  589. base_price: 50,
  590. market_price: 50
  591. };
  592. try {
  593. let gljListModel = new GLJListModel();
  594. let result = await gljListModel.addList(data);
  595. } catch (error) {
  596. console.log(error);
  597. }
  598. response.end('success');
  599. }
  600. /**
  601. * 模拟定额修改单价
  602. *
  603. * @param {object} request
  604. * @param {object} response
  605. * @return {void}
  606. */
  607. async testModify(request, response) {
  608. let projectId = request.query.project;
  609. // 修改数据
  610. let updateData = {
  611. code: '36290101',
  612. market_price: '13',
  613. name: '水(10)',
  614. project_id: projectId
  615. };
  616. try {
  617. let gljListModel = new GLJListModel();
  618. let result = await gljListModel.modifyMarketPrice(updateData);
  619. console.log(result);
  620. } catch (error) {
  621. console.log(error);
  622. }
  623. response.end('success');
  624. }
  625. /**
  626. * 测试删除
  627. *
  628. * @param {object} request
  629. * @param {object} response
  630. * @return {void}
  631. */
  632. async delete(request, response) {
  633. try {
  634. let gljListModel = new GLJListModel();
  635. let result = await gljListModel.deleteById(63);
  636. console.log(result);
  637. } catch (error) {
  638. console.log(error);
  639. }
  640. response.end('success');
  641. }
  642. async updateUnitPrice(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.updateUnitPrice(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 updateCalcMaterial(req, res){
  661. let result={
  662. error:0
  663. }
  664. try {
  665. let data = req.body.data;
  666. data = JSON.parse(data);
  667. let unitPriceModel = new UnitPriceModel();
  668. // 更新数据
  669. let datas = await unitPriceModel.updateCalcMaterial(data);
  670. result.data=datas;
  671. }catch (err){
  672. logger.err(err);
  673. result.error=1;
  674. result.message = err.message;
  675. }
  676. res.json(result);
  677. }
  678. async batchUpdatePrices(req, res){
  679. let result={
  680. error:0
  681. }
  682. try {
  683. let data = req.body.data;
  684. data = JSON.parse(data);
  685. let unitPriceModel = new UnitPriceModel();
  686. // 更新数据
  687. let datas = await unitPriceModel.batchUpdatePrices(data);
  688. result.data=datas;
  689. }catch (err){
  690. logger.err(err);
  691. result.error=1;
  692. result.message = err.message;
  693. }
  694. res.json(result);
  695. }
  696. async batchUpdateGLJProperty(req, res){
  697. let result={
  698. error:0
  699. };
  700. try {
  701. let data = req.body.data;
  702. data = JSON.parse(data);
  703. let tasks = [];
  704. for(let key in data){
  705. let doc = data[key];
  706. let query = {id:parseInt(key)};
  707. let task = {updateOne:{filter:query, update :doc}};
  708. tasks.push(task);
  709. }
  710. if(tasks.length > 0){
  711. let gljModel = new GLJListModel().model;
  712. await gljModel.bulkWrite(tasks);
  713. }
  714. result.data=data;
  715. }catch (err){
  716. logger.err(err);
  717. result.error=1;
  718. result.message = err.message;
  719. }
  720. res.json(result);
  721. }
  722. async batchUpdateConsumption(req,res){
  723. let result={
  724. error:0
  725. };
  726. try {
  727. let data = req.body.data;
  728. data = JSON.parse(data);
  729. let mixTasks = [],parent = null;
  730. for(let d of data){
  731. if(d.type == 'mix_ratio'){
  732. let task = {updateOne:{filter:d.query, update :d.doc}};
  733. mixTasks.push(task);
  734. }else if(d.type =='parent'){
  735. parent = d;
  736. }
  737. }
  738. if(mixTasks.length > 0){
  739. let mixRatioModel = new MixRatioModel().model;
  740. await mixRatioModel.bulkWrite(mixTasks);
  741. }
  742. if(parent){
  743. let indexList = ['code','name','specs','unit','type'];
  744. let keyList = parent.connect_key.split("|-|");
  745. let condition = {unit_price_file_id: parent.unit_price_file_id};
  746. for(let i = 1;i<keyList.length;i++){
  747. if(keyList[i]!='null'){
  748. condition[indexList[i]]=keyList[i];
  749. }
  750. }
  751. let unitPriceUpdate = {
  752. base_price: parent.base_price,
  753. market_price: parent.market_price
  754. };
  755. let unitPriceModel = new UnitPriceModel();
  756. let unitPriceResult = await unitPriceModel.updatePrice(condition, unitPriceUpdate);
  757. if (!unitPriceResult) {
  758. throw '更新单价数据失败';
  759. }
  760. }
  761. result.data = "ok";
  762. }catch (err){
  763. logger.err(err);
  764. result.error=1;
  765. result.message = err.message;
  766. }
  767. res.json(result);
  768. }
  769. async modifyKeyValue(req,res){//修改工料机关键的属性:名称、类型、规格、型号等
  770. let result={
  771. error:0
  772. }
  773. try {
  774. let data = req.body.data;
  775. data = JSON.parse(data);
  776. let gljListModel = new GLJListModel();
  777. let ration_data = await ration.findOne(data.ration);
  778. // 修改项目工料机
  779. let projcetGLJ = await gljListModel.modifyGLJ(data.updateData,ration_data);
  780. // let datas = await gljListModel.addList(data);
  781. result.data=projcetGLJ;
  782. }catch (err){
  783. logger.err(err);
  784. result.error=1;
  785. result.message = err.message;
  786. }
  787. res.json(result);
  788. }
  789. async getVvTaxList(req,res){
  790. let vvTxtList = [];
  791. try {
  792. let egnrModel = new EngineeringLibModel();
  793. let egnr = await egnrModel.getEngineering(req.query.engineeringID);
  794. vvTxtList = egnr.vvTax_lib;
  795. }catch (err){
  796. logger.err(err);
  797. }
  798. res.json(vvTxtList);
  799. }
  800. async getProjectGLJsByProjectID(projectId){
  801. return await getGLJListByProjectID(projectId)
  802. }
  803. }
  804. /**
  805. * 取项目工料机列表
  806. * @param projectId
  807. * @returns {Promise.<void>}
  808. */
  809. async function getGLJListByProjectID(projectId){
  810. let responseData = {
  811. err: 0,
  812. msg: '',
  813. data: {}
  814. };
  815. try {
  816. if (isNaN(projectId) || projectId <= 0) {
  817. throw '标段id有误';
  818. }
  819. // 获取标段对应的单价文件id
  820. let unitPriceFileId = await ProjectModel.getUnitPriceFileId(projectId);
  821. if (unitPriceFileId <= 0) {
  822. throw '没有对应的单价文件';
  823. }
  824. // 获取使用该单价文件的项目数据
  825. let tenderData = await ProjectModel.getTenderByUnitPriceFileId(unitPriceFileId);
  826. let usedTenderList = [];
  827. let usedUnitPriceInfo = {};
  828. if (tenderData !== null) {
  829. for (let tmp of tenderData) {
  830. usedTenderList.push(tmp.name);
  831. usedUnitPriceInfo.name = tmp.property.unitPriceFile.name;
  832. usedUnitPriceInfo.id = tmp.property.unitPriceFile.id;
  833. }
  834. }
  835. responseData.data.gljList = gljList;
  836. // 先获取对应标段的项目工料机数据
  837. let gljListModel = new GLJListModel();
  838. let [gljList, mixRatioConnectData,mixRationMap,unitPriceMap] = await gljListModel.getListByProjectId(projectId, unitPriceFileId);
  839. responseData.data.gljList = gljList;
  840. responseData.data.mixRatioConnectData = mixRatioConnectData;
  841. responseData.data.mixRatioMap = mixRationMap;
  842. responseData.data.usedTenderList = usedTenderList;
  843. responseData.data.unitPriceMap = unitPriceMap;
  844. responseData.data.originalList = await original_calc_model.find({"unit_price_file_id":unitPriceFileId});
  845. responseData.data.freightList = await freight_calc_model .find({"unit_price_file_id":unitPriceFileId});
  846. let gljTypeMap = glj_type_util.getStdGljTypeCacheObj().innerGljTypeObj;
  847. let unitPriceFileModel = new UnitPriceFileModel();
  848. let unitFileInfo = await unitPriceFileModel.findDataByCondition({id: unitPriceFileId});
  849. responseData.data.constData = {
  850. materialIdList: gljListModel.materialIdList,
  851. ownCompositionTypes: gljListModel.ownCompositionTypes,
  852. roomId: unitPriceFileId,
  853. GLJTypeConst: JSON.stringify(GLJTypeConst),
  854. usedUnitPriceInfo: usedUnitPriceInfo,
  855. gljTypeMap:gljTypeMap,
  856. vvTaxFileID:unitFileInfo.vvTaxFileID
  857. };
  858. } catch (error) {
  859. console.log(error);
  860. responseData.err = 1;
  861. responseData.msg = error;
  862. }
  863. return responseData;
  864. }
  865. export default GLJController;