glj_controller.js 27 KB

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