project_facade.js 25 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694
  1. /**
  2. * Created by zhang on 2018/1/26.
  3. */
  4. module.exports = {
  5. markUpdateProject:markUpdateProject,
  6. removeProjectMark:removeProjectMark,
  7. updateNodes:updateNodes,
  8. calcInstallationFee:calcInstallationFee,
  9. calcOverHeightFee: calcOverHeightFee,
  10. saveProperty: saveProperty,
  11. getDefaultColSetting: getDefaultColSetting,
  12. markProjectsToChange:markProjectsToChange,
  13. getSEIProjects:getSEIProjects,
  14. loadSEIProjectData:loadSEIProjectData,
  15. setSEILibData:setSEILibData,
  16. getIndexReportData:getIndexReportData,
  17. setDefaultItemIncrease:setDefaultItemIncrease
  18. };
  19. let mongoose = require('mongoose');
  20. let logger = require("../../../logs/log_helper").logger;
  21. let projectsModel = mongoose.model('projects');
  22. let async_n = require("async");
  23. let _ = require('lodash');
  24. let ration_model = require('../models/ration');
  25. let bill_model = require('../models/bills');
  26. let consts = require('../models/project_consts');
  27. let projectConsts = consts.projectConst;
  28. let ration_glj_model = mongoose.model('ration_glj');
  29. let rationTemplateModel = mongoose.model('ration_template');
  30. let project_glj_model = mongoose.model('glj_list');
  31. let ration_glj_facade = require("../../ration_glj/facade/ration_glj_facade");
  32. let glj_calculate_facade = require("../../ration_glj/facade/glj_calculate_facade");
  33. const uuidV1 = require('uuid/v1');
  34. const gljUtil = require('../../../public/gljUtil');
  35. let stdColSettingModel = mongoose.model('std_main_col_lib');
  36. const GLJListModel = require("../../glj/models/glj_list_model");
  37. let economicLib = mongoose.model('std_economic_lib');
  38. let engineerFeatureLib = mongoose.model('std_engineer_feature_lib');
  39. let engineerInfoLib = mongoose.model('std_engineer_info_lib');
  40. let mainQuantityLib = mongoose.model('std_main_quantity_lib');
  41. let materialLib = mongoose.model('std_material_lib');
  42. const { fixedFlag } = require('../../../public/common_constants');
  43. const scMathUtil = require('../../../public/scMathUtil').getUtil();
  44. const billsLibDao = require("../../bills_lib/models/bills_lib_interfaces");
  45. async function calcInstallationFee(data) {
  46. let result={};
  47. let projectGLJList = [];
  48. let billTasks = await generateTasks(data.bills,data.useID,true);
  49. let rationTasks =await generateTasks(data.ration,data.useID);
  50. if(billTasks.length>0){
  51. await bill_model.model.bulkWrite(billTasks);
  52. }
  53. if(rationTasks.length>0){
  54. await ration_model.model.bulkWrite(rationTasks);
  55. }
  56. //如果删除定额,需要删除对应的工料机
  57. if(data.ration.delete.length>0){
  58. let rationIDS = _.map(data.ration.delete,'ID');
  59. await ration_glj_model.deleteMany({projectID: data.ration.delete[0].projectID, rationID: {"$in": rationIDS}});//删除定额工料机
  60. }
  61. let rationGLJTasks = [];
  62. let updateList = [];
  63. if(data.ration.update.length>0){//如果有需要更新的定额工料机
  64. for(let ur of data.ration.update){
  65. for(let g of ur.glj){
  66. let gTasks = {
  67. updateOne:{
  68. filter:{
  69. ID:g.ID,
  70. projectID:g.projectID
  71. },
  72. update :{
  73. quantity:g.quantity,
  74. rationItemQuantity:g.rationItemQuantity
  75. }
  76. }
  77. };
  78. rationGLJTasks.push(gTasks);
  79. updateList.push(g);
  80. }
  81. }
  82. }
  83. if(rationGLJTasks.length>0){
  84. await ration_glj_model.bulkWrite(rationGLJTasks);
  85. }
  86. let newGljList = [];
  87. if(data.ration.add.length>0){//新增的安装子目要增加对应的工料机
  88. for(let nr of data.ration.add){
  89. for(let tkey in nr.glj){
  90. let [newRecode,projectGLJ] = await createRationGLJData(nr.glj[tkey])
  91. newGljList.push(newRecode);
  92. projectGLJList.push(projectGLJ);
  93. }
  94. }
  95. }
  96. if(newGljList.length>0){
  97. await ration_glj_model.insertMany(newGljList);
  98. }
  99. result.update = updateList;
  100. result.add = newGljList;
  101. result.projectGLJList = projectGLJList;
  102. result.updateData = data;
  103. return result;
  104. }
  105. async function createRationGLJData(glj) {
  106. glj.ID = uuidV1();
  107. let [info,projectGLJ ] = await ration_glj_facade.getInfoFromProjectGLJ(glj);
  108. let newRecode = ration_glj_facade.createNewRecord(info);
  109. return [newRecode,projectGLJ];
  110. }
  111. async function generateTasks(data,userID,isBills=false) {
  112. let tasks=[];
  113. let deleteInfo={deleted: true, deleteDateTime: new Date(), deleteBy: userID};
  114. if(data.delete && data.delete.length > 0){
  115. for(let bd of data.delete){
  116. //原先是假删除,现在改成真删除
  117. let task = {
  118. deleteOne:{
  119. filter:{
  120. ID:bd.ID,
  121. projectID:bd.projectID
  122. }
  123. }
  124. };
  125. /* let task={
  126. updateOne:{
  127. filter:{
  128. ID:bd.ID,
  129. projectID:bd.projectID
  130. },
  131. update :{
  132. deleteInfo:deleteInfo
  133. }
  134. }
  135. };*/
  136. tasks.push(task);
  137. }
  138. }
  139. if(data.add && data.add.length > 0){
  140. for(let n_data of data.add){
  141. if(isBills == true){
  142. let stdBills = await billsLibDao.getStdBillsByCode({userId: n_data.userID, billsLibId: n_data.billsLibId, code: n_data.stdCode});
  143. stdBills = stdBills ? stdBills._doc : null;
  144. if (stdBills) {
  145. // 获取项目清单所需要的数据
  146. const projectBillsData = billsLibDao.getDataToProjectBills(stdBills);
  147. n_data.jobContent = projectBillsData.jobContent;
  148. n_data.itemCharacter = projectBillsData.itemCharacter;
  149. n_data.itemCharacterText = projectBillsData.itemCharacterText;
  150. n_data.jobContentText = projectBillsData.ijobContentText;
  151. } else {
  152. delete n_data.billsLibId;
  153. }
  154. delete n_data.userID;
  155. delete n_data.stdCode;
  156. }
  157. let task = {
  158. insertOne :{
  159. document:n_data
  160. }
  161. };
  162. tasks.push(task);
  163. }
  164. }
  165. return tasks;
  166. }
  167. /**
  168. * 计取超高降效费,可能包含更新清单、更新定额、新增清单、新增定额及其子数据、删除定额及其子数据
  169. * @param {Object} data - {updateData: {ration: [],..}, addData: {ration: [],...}, deleteData: {ration: [],...}}
  170. * @return {Object} - {bills: Array, rationGLJ: Array}
  171. */
  172. async function calcOverHeightFee(data) {
  173. // 更新数据
  174. async function update({ project, bills, ration }) {
  175. const tasks = [];
  176. // 更新项目
  177. if (project && project.ID) {
  178. const projectTask = projectsModel.update({ ID: project.ID },
  179. { 'property.overHeightOption': project.overHeightOption, 'property.overHeightSpecificID': project.overHeightSpecificID });
  180. tasks.push(projectTask);
  181. }
  182. // 更新清单和定额的超高降效列
  183. const models = [];
  184. if (bills.length) {
  185. models.push({ model: bill_model.model, items: bills });
  186. }
  187. if (ration.length) {
  188. models.push({ model: ration_model.model, items: ration });
  189. }
  190. models.forEach(modelData => {
  191. const bulkTask = modelData.items.map(item => (
  192. {
  193. updateOne: {
  194. filter: { ID: item.ID },
  195. update: { overHeight: item.overHeight }
  196. }
  197. }));
  198. const task = modelData.model.bulkWrite(bulkTask);
  199. tasks.push(task);;
  200. });
  201. if (!tasks.length) {
  202. return;
  203. }
  204. await Promise.all(tasks);
  205. }
  206. // 插入数据
  207. async function add({ bills, ration, rationGLJ}) {
  208. const tasks = [];
  209. // 匹配标准清单,加上工作内容等数据
  210. for (const billsItem of bills) {
  211. let stdBills = await billsLibDao.getStdBillsByCode(billsItem);
  212. stdBills = stdBills ? stdBills._doc : null;
  213. if (stdBills) {
  214. // 获取项目清单所需要的数据
  215. const projectBillsData = billsLibDao.getDataToProjectBills(stdBills);
  216. Object.assign(billsItem, projectBillsData);
  217. } else {
  218. delete billsItem.billsLibId;
  219. }
  220. billsItem.code += '001';
  221. }
  222. // 新增清单
  223. if (bills.length) {
  224. tasks.push(bill_model.model.insertMany(bills));
  225. }
  226. // 新增定额
  227. if (ration.length) {
  228. tasks.push(ration_model.model.insertMany(ration));
  229. }
  230. // 完整的定额人材机数据
  231. const completeRationGLJList = [];
  232. // 完整的项目人材机数据
  233. const completeProjectGLJList = [];
  234. // createRationGLJData方法不能并行,涉及到项目人材机的新增,如果并行可能会重复插入数据
  235. for (const rGLJ of rationGLJ) {
  236. const [completeRGLJ, completePGLJ] = await createRationGLJData(rGLJ);
  237. completeRationGLJList.push(completeRGLJ);
  238. completeProjectGLJList.push(completePGLJ);
  239. }
  240. if (completeRationGLJList.length) {
  241. tasks.push(ration_glj_model.insertMany(completeRationGLJList))
  242. }
  243. // 返回新的清单、定额人材机、项目人材机数据数据
  244. const rst = {
  245. bills,
  246. rationGLJ: completeRationGLJList,
  247. projectGLJ: completeProjectGLJList,
  248. }
  249. if (!tasks.length) {
  250. return rst;
  251. }
  252. await Promise.all(tasks);
  253. return rst;
  254. }
  255. // 删除数据
  256. async function del({ ration }) {
  257. const tasks = [];
  258. const rationIDList = ration.map(item => item.ID);
  259. if (!rationIDList.length) {
  260. return;
  261. }
  262. // 删除定额数据
  263. const rationTask = ration_model.model.deleteMany({ ID: {$in: rationIDList} });
  264. tasks.push(rationTask);
  265. // 删除定额人材机数据
  266. const rationGLJTask = ration_glj_model.deleteMany({ rationID: {$in: rationIDList} });
  267. tasks.push(rationGLJTask);
  268. await Promise.all(tasks);
  269. }
  270. // 处理任务
  271. const { updateData, addData, deleteData } = data;
  272. const updateTask = update(updateData);
  273. const addTask = add(addData);
  274. const delTask = del(deleteData);
  275. const [updateRst, addRst, delRst] = await Promise.all([updateTask, addTask, delTask]);
  276. return addRst;
  277. }
  278. async function updateNodes(datas){
  279. let nodeGroups = _.groupBy(datas,'type');
  280. let asyncTasks = [];
  281. let deleteRationIDs=[];
  282. let taskMap = {};
  283. taskMap[projectConsts.BILLS] = {tasks:[],model:bill_model.model};
  284. taskMap[projectConsts.RATION] = {tasks:[],model:ration_model.model};
  285. taskMap[projectConsts.RATION_GLJ] = {tasks:[],model:ration_glj_model};
  286. taskMap[projectConsts.PROJECTGLJ] = {tasks:[],model:project_glj_model};
  287. taskMap[projectConsts.PROJECT] = {tasks:[],model:projectsModel};
  288. taskMap[projectConsts.RATION_TEMPLATE] = {tasks:[],model:rationTemplateModel};
  289. for(let type in nodeGroups){
  290. for(let node of nodeGroups[type]){
  291. if(taskMap[type]){
  292. if(type == projectConsts.RATION){
  293. //处理面积增加费的数据
  294. if(node.data.hasOwnProperty("areaIncreaseFee")){
  295. let areaSetting = null;
  296. if(nodeGroups[projectConsts.PROJECT]){
  297. for(let pn of nodeGroups[projectConsts.PROJECT]){
  298. if(pn.data['property.areaSetting']) areaSetting = pn.data['property.areaSetting'];
  299. }
  300. }
  301. let t = await glj_calculate_facade.calculateQuantity({rationID:node.data.ID},null,false,node.data.areaIncreaseFee,areaSetting);
  302. if(t.glj_result && t.glj_result.length > 0){//这里要更新工料机的消耗量,修改数据库的操作已经在上一步中完成了,现在只需刷新前端即可
  303. for(let gr of t.glj_result){
  304. let tdata = gr.doc;
  305. tdata.ID = gr.query.ID;
  306. datas.push({type:projectConsts.RATION_GLJ,data:tdata});
  307. }
  308. }
  309. node.data.adjustState = t.adjustState;
  310. }
  311. if(node.action == "delete") deleteRationIDs.push(node.data.ID);
  312. }
  313. if(type == projectConsts.RATION_GLJ){
  314. if(node.action == "add"){//添加定額工料机的時候,要先走项目工料机的逻辑
  315. let [newRecode,projectGLJ] = await createRationGLJData(node.data);
  316. node.data =newRecode;
  317. node.projectGLJ = projectGLJ;
  318. }
  319. }
  320. taskMap[type].tasks.push(getTask(node));
  321. }
  322. }
  323. }
  324. for(let key in taskMap){
  325. if(taskMap[key].tasks.length> 0) asyncTasks.push(taskMap[key].model.bulkWrite(taskMap[key].tasks))
  326. }
  327. if(asyncTasks.length>0) await Promise.all(asyncTasks);
  328. if(deleteRationIDs.length > 0) await ration_glj_model.deleteMany({rationID: {$in: deleteRationIDs}});
  329. return datas;
  330. function getTask(node,idFiled = 'ID') {
  331. let task={};
  332. if(node.action == "add"){
  333. task.insertOne ={
  334. document:node.data
  335. }
  336. }else if(node.action =="delete"){
  337. task.deleteOne ={
  338. filter:{}
  339. };
  340. task.deleteOne.filter[idFiled] = node.data[idFiled];
  341. }else {
  342. task.updateOne = {
  343. filter:{},
  344. update :_.cloneDeep(node.data)
  345. };
  346. task.updateOne.filter[idFiled] = node.data[idFiled];//现在复制项目也重新生成一个新的ID了,所以ID是唯一的
  347. delete task.updateOne.update[idFiled];//防止误操作
  348. }
  349. return task;
  350. }
  351. }
  352. /*function updateNodes(datas,callback) {
  353. let tasks = [];
  354. for(let node of datas){
  355. tasks.push(updateOne(node))
  356. }
  357. async_n.parallel(tasks, function(err, results) {
  358. if (!err){
  359. callback(0, '', results);
  360. }
  361. else{
  362. console.log(err);
  363. callback(1, 'save project failed'+err.message, null);
  364. }
  365. });
  366. function updateOne(node) {
  367. if(node.type == projectConsts.BILLS){
  368. return function (asCallback) {
  369. bill_model.model.findOneAndUpdate({projectID: node.data.projectID, ID: node.data.ID,deleteInfo: null}, node.data,{new: true}, asCallback);
  370. }
  371. }else if(node.type ==projectConsts.RATION){
  372. return function (asCallback) {
  373. ration_model.model.findOneAndUpdate({projectID: node.data.projectID, ID: node.data.ID,deleteInfo: null}, node.data,{new: true}, asCallback);
  374. }
  375. }
  376. }
  377. }*/
  378. //data = {feeRateID:111111,projectID:1245}; type = feeRate
  379. async function markUpdateProject(data,type) {
  380. let query = {deleteInfo:null};
  381. if(type=="feeRate"){//更改了费率
  382. query['property.feeFile.id'] = data.feeRateID;
  383. }
  384. if(type=="unitFile"){//更改了单价文件
  385. query['property.unitPriceFile.id'] = data.unitFileID;//unitPriceFile
  386. }
  387. let projects = await projectsModel.find(query);
  388. return await markProjectsToChange(projects,type,data.projectID);
  389. }
  390. async function markProjectsToChange(projects,type,extProjectID){
  391. let tasks=[];
  392. for(let p of projects){
  393. if(extProjectID && p.ID===extProjectID) continue;//排除当前项目
  394. tasks.push(generateMarkTask(type,p.ID));
  395. }
  396. return tasks.length>0 ? await projectsModel.bulkWrite(tasks):null;
  397. }
  398. async function removeProjectMark(projectID) {
  399. return await projectsModel.findOneAndUpdate({ID:projectID},{"$unset":{"changeMark":1}});
  400. }
  401. function generateMarkTask(value,projectID) {
  402. let task = {
  403. updateOne:{
  404. filter:{
  405. ID:projectID
  406. },
  407. update:{
  408. changeMark:value
  409. }
  410. }
  411. };
  412. return task
  413. }
  414. // {projectID: 5, propertyName: 'aaa', propertyValue: 1}
  415. function saveProperty(data, callback){
  416. let obj = {};
  417. let pn = 'property.' + data.propertyName;
  418. obj[pn] = data.propertyValue;
  419. projectsModel.update({"ID": data.projectID}, obj, function (err) {
  420. if (err) {
  421. logger.err(pn + ' save error: ' + err);
  422. callback(err, null)
  423. } else {
  424. // logger.info(pn + ' saved.');
  425. callback('', null);
  426. }}
  427. );
  428. }
  429. async function getDefaultColSetting(libID){
  430. return await stdColSettingModel.findOne({ID: libID, deleted: false}, '-_id main_tree_col');
  431. }
  432. function sortChildren(lists) {
  433. let IDMap ={},nextMap = {}, firstNode = null,newList=[];
  434. for(let l of lists){
  435. if(l.children&&l.children.length > 0) l.children = sortChildren(l.children);//递规排序
  436. IDMap[l.ID] = l;
  437. if(l.NextSiblingID!=-1) nextMap[l.NextSiblingID] = l;
  438. }
  439. for(let t of lists){
  440. if(!nextMap[t.ID]){ //如果在下一节点映射没找到,则是第一个节点
  441. firstNode = t;
  442. break;
  443. }
  444. }
  445. if(firstNode){
  446. newList.push(firstNode);
  447. delete IDMap[firstNode.ID];
  448. setNext(firstNode,newList);
  449. }
  450. //容错处理,如果链断了的情况,直接添加到后面
  451. for(let key in IDMap){
  452. if(IDMap[key]) newList.push(IDMap[key])
  453. }
  454. return newList;
  455. function setNext(node,array) {
  456. if(node.NextSiblingID != -1){
  457. let next = IDMap[node.NextSiblingID];
  458. if(next){
  459. array.push(next);
  460. delete IDMap[next.ID];
  461. setNext(next,array);
  462. }
  463. }
  464. }
  465. }
  466. async function getSEIProjects(projectID) {
  467. let project = await projectsModel.findOne({ID:projectID});
  468. if(!project) throw new Error(`找不到建设项目:${projectID}`);
  469. let tem_e = await projectsModel.find({ParentID:project.ID});
  470. let engineers = [];
  471. for(let e of tem_e){
  472. if(!e.deleteInfo || !e.deleteInfo.deleted){
  473. let tenders = await projectsModel.find({ParentID:e.ID});
  474. let children = [];
  475. for(let t of tenders){
  476. if(!t.deleteInfo || !t.deleteInfo.deleted){
  477. children.push(t);
  478. }
  479. }
  480. e._doc.children = children;
  481. engineers.push(e);
  482. }
  483. }
  484. engineers = sortChildren(engineers);
  485. project._doc.children = engineers;
  486. return project;
  487. }
  488. async function loadSEIProjectData(projectID) {
  489. let gljListModel = new GLJListModel();
  490. let [gljList, mixRatioConnectData,mixRatioMap,unitPriceMap] = await gljListModel.getListByProjectId(projectID);
  491. let rations = await ration_model.getDataSync(projectID);
  492. let bills = await bill_model.getDataSync(projectID);
  493. let ration_gljs = await ration_glj_model.find({projectID:projectID});
  494. let projectGLJs = {
  495. gljList : gljList,
  496. mixRatioConnectData:mixRatioConnectData,
  497. mixRatioMap:mixRatioMap,
  498. unitPriceMap:unitPriceMap
  499. };
  500. return{bills:bills,rations:rations,ration_gljs:ration_gljs,projectGLJs:projectGLJs}
  501. }
  502. //从建设项目中取工程信息默认值
  503. async function setDefaultInfo(rootProjectID,engineerInfos){
  504. let rootProject = await projectsModel.findOne({ID:rootProjectID}).lean();
  505. if(rootProject){
  506. let baseInfo = _.find(rootProject.property.basicInformation,{key:"basicInfo"});
  507. if(!baseInfo) return;
  508. let baseMap = {};
  509. let attrs = ["工程地点","开工日期","竣工日期","编制日期"];
  510. for(let item of baseInfo.items){
  511. baseMap[item.dispName] = item;
  512. }
  513. for(let en of engineerInfos){
  514. if(attrs.indexOf(en.dispName) != -1){
  515. let key = en.dispName;
  516. if(key == "工程地点") key = "工程所在地";
  517. en.value = baseMap[key] && baseMap[key].value || '';
  518. }
  519. }
  520. }
  521. }
  522. async function setSEILibData(property){
  523. if(property.engineerInfoLibID){//工程信息指标
  524. let engineerInfo = await engineerInfoLib.findOne({'ID':property.engineerInfoLibID}).lean();
  525. if(engineerInfo){
  526. property.engineerInfos = engineerInfo.info;
  527. await setDefaultInfo(property.rootProjectID,property.engineerInfos);
  528. }
  529. }
  530. if(property.engineerFeatureLibID){//工程特征指标
  531. let engineerFeature = await engineerFeatureLib.findOne({'ID':property.engineerFeatureLibID});
  532. if(engineerFeature) property.engineerFeatures = engineerFeature.features;
  533. }
  534. if(property.materialLibID){//主要工料指标
  535. let material = await materialLib.findOne({'ID':property.materialLibID});
  536. if(material) property.materials = material.materials;
  537. }
  538. if(property.mainQuantityLibID){//主要工程量指标
  539. let mainQuantity = await mainQuantityLib.findOne({'ID':property.mainQuantityLibID});
  540. if(mainQuantity) property.mainQuantities = mainQuantity.index;
  541. }
  542. if(property.economicLibID){//主要工程量指标
  543. let economic = await economicLib.findOne({'ID':property.economicLibID});
  544. if(economic) property.economics = economic.index;
  545. }
  546. }
  547. function setDefaultItemIncrease(property) {
  548. property.itemIncreaseSetting = {
  549. isCalc : false,
  550. setting:[
  551. {"name":"在生产车间边生产边施工","base":"人工费","coe":10,"scope":{}},
  552. {"name":"在有害身体健康的场所内施工","base":"人工费","coe":10,"scope":{}},
  553. {"name":"在洞内、地下室内、库内或暗室内进行施工","base":"人工费","coe":40,"scope":{}},
  554. {"name":"在洞内、地下室内、库内或暗室内进行施工(模板拆除)","base":"人工费","coe":10,"scope":{}}
  555. ]
  556. }
  557. }
  558. async function getIndexReportData(projectID,keyArr) {
  559. let project = await projectsModel.findOne({ID:projectID});
  560. let bills = await bill_model.getDataSync(projectID);
  561. let result = {};
  562. for(let key of keyArr){
  563. switch (key) {
  564. case 'ProjectCostFields':
  565. result[key] =getEngineerCostData(project.property,bills);
  566. break;
  567. case 'ProjectEcoFields':
  568. result[key] = getEconomicDatas(project.property,bills);
  569. break;
  570. case 'ProjectLabMaterialFields':
  571. result[key] = await getMainMaterialDatas(projectID,project.property);
  572. break;
  573. case 'ProjectQtyFields':
  574. result[key] = await getQuantityDatas(project.property,bills);
  575. break;
  576. case 'ProjectInfoFields':
  577. result[key] = getEngineerInfoData(project.property.engineerInfos);
  578. break;
  579. case 'ProjectFeatureFields':
  580. result[key] = getEngineerFeaturesDatas(project.property.engineerFeatures);
  581. break;
  582. }
  583. }
  584. return result
  585. }
  586. function getEngineerInfoData(engineerInfos) {
  587. let datas = [];
  588. for(let info of engineerInfos){
  589. let d = {
  590. name:info.dispName,
  591. value:info.value
  592. };
  593. datas.push(d);
  594. }
  595. return datas;
  596. }
  597. function getEngineerFeaturesDatas(engineerFeatures) {
  598. let datas = [];
  599. if (engineerFeatures !== null && engineerFeatures !== undefined) {
  600. for(let f of engineerFeatures){
  601. let tem = {
  602. ID:f.ID,
  603. name:f.name,
  604. value:f.value,
  605. ParentID:f.ParentID
  606. }
  607. datas.push(tem);
  608. }
  609. }
  610. return datas;
  611. }
  612. function getQuantityDatas(property,bills) {
  613. return gljUtil.getQuantityDatas(property.engineerFeatures,property.mainQuantities,bills,fixedFlag,_,scMathUtil,property.decimal)
  614. }
  615. function getEconomicDatas(property,bills) {
  616. return gljUtil.getEconomicDatas(property.engineerFeatures,property.economics,bills,fixedFlag,_,scMathUtil,property.decimal)
  617. }
  618. function getEngineerCostData(property,bills){
  619. let datas = [];
  620. let priceIndex = gljUtil.getEngineerCostData(property,bills,fixedFlag,scMathUtil);
  621. for(let c of priceIndex.children){
  622. let tem = {
  623. name:c.name,
  624. cost:parseFloat(c.attrs[0].value),
  625. unitCost:parseFloat(c.attrs[1].value),
  626. per:parseFloat(c.attrs[2].value)
  627. };
  628. datas.push(tem);
  629. }
  630. return datas;
  631. }
  632. async function getMainMaterialDatas(projectID,property) {
  633. let gljListModel = new GLJListModel();
  634. let [gljList, mixRatioConnectData,mixRatioMap,unitPriceMap] = await gljListModel.getListByProjectId(projectID, property.unitPriceFile?property.unitPriceFile.id:null);
  635. gljList = JSON.parse(JSON.stringify(gljList));
  636. await calcProjectGLJQuantity(projectID,{gljList:gljList,mixRatioMap:mixRatioMap},property);
  637. return gljUtil.getMainMaterialDatas(property,property.engineerFeatures,property.materials,{gljList:gljList},property.calcOptions,property.decimal,false,_,scMathUtil)
  638. }
  639. async function calcProjectGLJQuantity(projectID,projectGLJDatas,property){
  640. let q_decimal = property.decimal.glj.quantity;
  641. let rationGLJDatas = await ration_glj_model.find({'projectID':projectID});
  642. let rationDatas = await ration_model.model.find({'projectID':projectID});
  643. gljUtil.calcProjectGLJQuantity(projectGLJDatas,rationGLJDatas,rationDatas,[],q_decimal)
  644. }