glj_controller.js 32 KB

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