glj_controller.js 31 KB

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