project_facade.js 18 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503
  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. saveProperty: saveProperty,
  10. getDefaultColSetting: getDefaultColSetting,
  11. markProjectsToChange:markProjectsToChange,
  12. getSEIProjects:getSEIProjects,
  13. loadSEIProjectData:loadSEIProjectData,
  14. setSEILibData:setSEILibData,
  15. getIndexReportData:getIndexReportData
  16. };
  17. let mongoose = require('mongoose');
  18. let logger = require("../../../logs/log_helper").logger;
  19. let projectsModel = mongoose.model('projects');
  20. let async_n = require("async");
  21. let _ = require('lodash');
  22. let ration_model = require('../models/ration');
  23. let bill_model = require('../models/bills');
  24. let consts = require('../models/project_consts');
  25. let projectConsts = consts.projectConst;
  26. let ration_glj_model = mongoose.model('ration_glj');
  27. let rationTemplateModel = mongoose.model('ration_template');
  28. let project_glj_model = mongoose.model('glj_list');
  29. let ration_glj_facade = require("../../ration_glj/facade/ration_glj_facade");
  30. const uuidV1 = require('uuid/v1');
  31. const gljUtil = require('../../../public/gljUtil');
  32. let stdColSettingModel = mongoose.model('std_main_col_lib');
  33. import GLJListModel from "../../glj/models/glj_list_model";
  34. let economicLib = mongoose.model('std_economic_lib');
  35. let engineerFeatureLib = mongoose.model('std_engineer_feature_lib');
  36. let engineerInfoLib = mongoose.model('std_engineer_info_lib');
  37. let mainQuantityLib = mongoose.model('std_main_quantity_lib');
  38. let materialLib = mongoose.model('std_material_lib');
  39. import fixedFlag from '../../common/const/bills_fixed';
  40. const scMathUtil = require('../../../public/scMathUtil').getUtil();
  41. async function calcInstallationFee(data) {
  42. let result={};
  43. let billTasks = generateTasks(data.bills,data.useID);
  44. let rationTasks = generateTasks(data.ration,data.useID);
  45. if(billTasks.length>0){
  46. await bill_model.model.bulkWrite(billTasks);
  47. }
  48. console.log(rationTasks);
  49. if(rationTasks.length>0){
  50. await ration_model.model.bulkWrite(rationTasks);
  51. }
  52. //如果删除定额,需要删除对应的工料机
  53. if(data.ration.delete.length>0){
  54. let rationIDS = _.map(data.ration.delete,'ID');
  55. await ration_glj_model.deleteMany({projectID: data.ration.delete[0].projectID, rationID: {"$in": rationIDS}});//删除定额工料机
  56. }
  57. let rationGLJTasks = [];
  58. let updateList = [];
  59. if(data.ration.update.length>0){//如果有需要更新的定额工料机
  60. for(let ur of data.ration.update){
  61. for(let g of ur.glj){
  62. let gTasks = {
  63. updateOne:{
  64. filter:{
  65. ID:g.ID,
  66. projectID:g.projectID
  67. },
  68. update :{
  69. quantity:g.quantity,
  70. rationItemQuantity:g.rationItemQuantity
  71. }
  72. }
  73. };
  74. rationGLJTasks.push(gTasks);
  75. updateList.push(g);
  76. }
  77. }
  78. }
  79. if(rationGLJTasks.length>0){
  80. await ration_glj_model.bulkWrite(rationGLJTasks);
  81. }
  82. let newGljList = [];
  83. if(data.ration.add.length>0){//新增的安装子目要增加对应的工料机
  84. for(let nr of data.ration.add){
  85. for(let tkey in nr.glj){
  86. newGljList.push(await addInstallationGLJ(nr.glj[tkey]));
  87. }
  88. }
  89. }
  90. if(newGljList.length>0){
  91. await ration_glj_model.insertMany(newGljList);
  92. }
  93. result.update = updateList;
  94. result.add = newGljList;
  95. return result;
  96. }
  97. async function addInstallationGLJ(glj) {
  98. glj.ID = uuidV1();
  99. let info = await ration_glj_facade.getInfoFromProjectGLJ(glj);
  100. let newRecode = ration_glj_facade.createNewRecord(info);
  101. return newRecode;
  102. }
  103. function generateTasks(data,userID) {
  104. let tasks=[];
  105. let deleteInfo={deleted: true, deleteDateTime: new Date(), deleteBy: userID};
  106. if(data.delete && data.delete.length > 0){
  107. for(let bd of data.delete){
  108. //原先是假删除,现在改成真删除
  109. let task = {
  110. deleteOne:{
  111. filter:{
  112. ID:bd.ID,
  113. projectID:bd.projectID
  114. }
  115. }
  116. };
  117. /* let task={
  118. updateOne:{
  119. filter:{
  120. ID:bd.ID,
  121. projectID:bd.projectID
  122. },
  123. update :{
  124. deleteInfo:deleteInfo
  125. }
  126. }
  127. };*/
  128. tasks.push(task);
  129. }
  130. }
  131. if(data.add && data.add.length > 0){
  132. for(let n_data of data.add){
  133. let task = {
  134. insertOne :{
  135. document:n_data
  136. }
  137. };
  138. tasks.push(task);
  139. }
  140. }
  141. return tasks;
  142. }
  143. async function updateNodes(datas){
  144. let nodeGroups = _.groupBy(datas,'type');
  145. let rationTasks = [];
  146. let billTasks = [];
  147. let rationGLJTasks = [];
  148. let projectGLJTasks = [];
  149. let projectTasks = [];
  150. let rationTemplateTasks = [];
  151. let asyncTasks = [];
  152. for(let type in nodeGroups){
  153. for(let node of nodeGroups[type]){
  154. if(type == projectConsts.BILLS){
  155. billTasks.push(getTask(node));
  156. }else if(type == projectConsts.RATION){
  157. rationTasks.push(getTask(node));
  158. }else if(type == projectConsts.RATION_GLJ){
  159. rationGLJTasks.push(getTask(node));
  160. }else if(type == projectConsts.PROJECTGLJ){
  161. projectGLJTasks.push(getTask(node,'id'));
  162. }else if(type == projectConsts.PROJECT){
  163. projectTasks.push(getTask(node));
  164. }else if(type == projectConsts.RATION_TEMPLATE){
  165. rationTemplateTasks.push(getTask(node))
  166. }
  167. }
  168. }
  169. //test------------------------
  170. if (billTasks.length) {
  171. console.log(`billTasks===============================`);
  172. billTasks.forEach(task => {
  173. if (task.updateOne.update.name === '分部分项工程') {
  174. console.log(`task.updateOne.filter`);
  175. console.log(task.updateOne.filter);
  176. console.log(`task.updateOne.update`);
  177. console.log(task.updateOne.update);
  178. }
  179. /*console.log(`task.updateOne.filter`);
  180. console.log(task.updateOne.filter);
  181. console.log(`task.updateOne.update`);
  182. console.log(task.updateOne.update);*/
  183. });
  184. }
  185. //test------------------------
  186. rationTasks.length>0?asyncTasks.push(ration_model.model.bulkWrite(rationTasks)):'';
  187. billTasks.length>0?asyncTasks.push(bill_model.model.bulkWrite(billTasks)):"";
  188. rationGLJTasks.length>0?asyncTasks.push(ration_glj_model.bulkWrite(rationGLJTasks)):"";
  189. projectGLJTasks.length>0?asyncTasks.push(project_glj_model.bulkWrite(projectGLJTasks)):"";
  190. projectTasks.length>0?asyncTasks.push(projectsModel.bulkWrite(projectTasks)):"";
  191. rationTemplateTasks.length>0?asyncTasks.push(rationTemplateModel.bulkWrite(rationTemplateTasks)):"";
  192. return asyncTasks.length>0?await Promise.all(asyncTasks):"";
  193. function getTask(node,idFiled = 'ID') {
  194. let task={
  195. updateOne:{
  196. filter:{},
  197. update :_.cloneDeep(node.data)
  198. }
  199. };
  200. task.updateOne.filter[idFiled] = node.data[idFiled];//现在复制项目也重新生成一个新的ID了,所以ID是唯一的
  201. delete task.updateOne.update[idFiled];//防止误操作
  202. return task;
  203. }
  204. }
  205. /*function updateNodes(datas,callback) {
  206. let tasks = [];
  207. for(let node of datas){
  208. tasks.push(updateOne(node))
  209. }
  210. async_n.parallel(tasks, function(err, results) {
  211. if (!err){
  212. callback(0, '', results);
  213. }
  214. else{
  215. console.log(err);
  216. callback(1, 'save project failed'+err.message, null);
  217. }
  218. });
  219. function updateOne(node) {
  220. if(node.type == projectConsts.BILLS){
  221. return function (asCallback) {
  222. bill_model.model.findOneAndUpdate({projectID: node.data.projectID, ID: node.data.ID,deleteInfo: null}, node.data,{new: true}, asCallback);
  223. }
  224. }else if(node.type ==projectConsts.RATION){
  225. return function (asCallback) {
  226. ration_model.model.findOneAndUpdate({projectID: node.data.projectID, ID: node.data.ID,deleteInfo: null}, node.data,{new: true}, asCallback);
  227. }
  228. }
  229. }
  230. }*/
  231. //data = {feeRateID:111111,projectID:1245}; type = feeRate
  232. async function markUpdateProject(data,type) {
  233. let query = {deleteInfo:null};
  234. if(type=="feeRate"){//更改了费率
  235. query['property.feeFile.id'] = data.feeRateID;
  236. }
  237. if(type=="unitFile"){//更改了单价文件
  238. query['property.unitPriceFile.id'] = data.unitFileID;//unitPriceFile
  239. }
  240. let projects = await projectsModel.find(query);
  241. return await markProjectsToChange(projects,type,data.projectID);
  242. }
  243. async function markProjectsToChange(projects,type,extProjectID){
  244. let tasks=[];
  245. for(let p of projects){
  246. if(extProjectID && p.ID===extProjectID) continue;//排除当前项目
  247. tasks.push(generateMarkTask(type,p.ID));
  248. }
  249. return tasks.length>0 ? await projectsModel.bulkWrite(tasks):null;
  250. }
  251. async function removeProjectMark(projectID) {
  252. return await projectsModel.findOneAndUpdate({ID:projectID},{"$unset":{"changeMark":1}});
  253. }
  254. function generateMarkTask(value,projectID) {
  255. let task = {
  256. updateOne:{
  257. filter:{
  258. ID:projectID
  259. },
  260. update:{
  261. changeMark:value
  262. }
  263. }
  264. };
  265. return task
  266. }
  267. // {projectID: 5, propertyName: 'aaa', propertyValue: 1}
  268. function saveProperty(data, callback){
  269. let obj = {};
  270. let pn = 'property.' + data.propertyName;
  271. obj[pn] = data.propertyValue;
  272. projectsModel.update({"ID": data.projectID}, obj, function (err) {
  273. if (err) {
  274. logger.err(pn + ' save error: ' + err);
  275. callback(err, null)
  276. } else {
  277. logger.info(pn + ' saved.');
  278. callback('', null);
  279. }}
  280. );
  281. }
  282. async function getDefaultColSetting(libID){
  283. return await stdColSettingModel.findOne({ID: libID, deleted: false}, '-_id main_tree_col');
  284. }
  285. function sortChildren(lists) {
  286. let IDMap ={},nextMap = {}, firstNode = null,newList=[];
  287. for(let l of lists){
  288. if(l.children&&l.children.length > 0) l.children = sortChildren(l.children);//递规排序
  289. IDMap[l.ID] = l;
  290. if(l.NextSiblingID!=-1) nextMap[l.NextSiblingID] = l;
  291. }
  292. for(let t of lists){
  293. if(!nextMap[t.ID]){ //如果在下一节点映射没找到,则是第一个节点
  294. firstNode = t;
  295. break;
  296. }
  297. }
  298. if(firstNode){
  299. newList.push(firstNode);
  300. delete IDMap[firstNode.ID];
  301. setNext(firstNode,newList);
  302. }
  303. //容错处理,如果链断了的情况,直接添加到后面
  304. for(let key in IDMap){
  305. if(IDMap[key]) newList.push(IDMap[key])
  306. }
  307. return newList;
  308. function setNext(node,array) {
  309. if(node.NextSiblingID != -1){
  310. let next = IDMap[node.NextSiblingID];
  311. if(next){
  312. array.push(next);
  313. delete IDMap[next.ID];
  314. setNext(next,array);
  315. }
  316. }
  317. }
  318. }
  319. async function getSEIProjects(projectID) {
  320. let project = await projectsModel.findOne({ID:projectID});
  321. if(!project) throw new Error(`找不到建设项目:${projectID}`);
  322. let tem_e = await projectsModel.find({ParentID:project.ID});
  323. let engineers = [];
  324. for(let e of tem_e){
  325. if(!e.deleteInfo || !e.deleteInfo.deleted){
  326. let tenders = await projectsModel.find({ParentID:e.ID});
  327. let children = [];
  328. for(let t of tenders){
  329. if(!t.deleteInfo || !t.deleteInfo.deleted){
  330. children.push(t);
  331. }
  332. }
  333. e._doc.children = children;
  334. engineers.push(e);
  335. }
  336. }
  337. engineers = sortChildren(engineers);
  338. project._doc.children = engineers;
  339. return project;
  340. }
  341. async function loadSEIProjectData(projectID) {
  342. let gljListModel = new GLJListModel();
  343. let [gljList, mixRatioConnectData,mixRatioMap,unitPriceMap] = await gljListModel.getListByProjectId(projectID);
  344. let rations = await ration_model.getDataSync(projectID);
  345. let bills = await bill_model.getDataSync(projectID);
  346. let ration_gljs = await ration_glj_model.find({projectID:projectID});
  347. let projectGLJs = {
  348. gljList : gljList,
  349. mixRatioConnectData:mixRatioConnectData,
  350. mixRatioMap:mixRatioMap,
  351. unitPriceMap:unitPriceMap
  352. };
  353. return{bills:bills,rations:rations,ration_gljs:ration_gljs,projectGLJs:projectGLJs}
  354. }
  355. async function setSEILibData(property){
  356. if(property.engineerInfoLibID){//工程信息指标
  357. let engineerInfo = await engineerInfoLib.findOne({'ID':property.engineerInfoLibID});
  358. if(engineerInfo) property.engineerInfos = engineerInfo.info;
  359. }
  360. if(property.engineerFeatureLibID){//工程特征指标
  361. let engineerFeature = await engineerFeatureLib.findOne({'ID':property.engineerFeatureLibID});
  362. if(engineerFeature) property.engineerFeatures = engineerFeature.features;
  363. }
  364. if(property.materialLibID){//主要工料指标
  365. let material = await materialLib.findOne({'ID':property.materialLibID});
  366. if(material) property.materials = material.materials;
  367. }
  368. if(property.mainQuantityLibID){//主要工程量指标
  369. let mainQuantity = await mainQuantityLib.findOne({'ID':property.mainQuantityLibID});
  370. if(mainQuantity) property.mainQuantities = mainQuantity.index;
  371. }
  372. if(property.economicLibID){//主要工程量指标
  373. let economic = await economicLib.findOne({'ID':property.economicLibID});
  374. if(economic) property.economics = economic.index;
  375. }
  376. }
  377. async function getIndexReportData(projectID,keyArr) {
  378. let project = await projectsModel.findOne({ID:projectID});
  379. let bills = await bill_model.getDataSync(projectID);
  380. let result = {};
  381. for(let key of keyArr){
  382. switch (key) {
  383. case 'ProjectCostFields':
  384. result[key] =getEngineerCostData(project.property,bills);
  385. break;
  386. case 'ProjectEcoFields':
  387. result[key] = getEconomicDatas(project.property,bills);
  388. break;
  389. case 'ProjectLabMaterialFields':
  390. result[key] = await getMainMaterialDatas(projectID,project.property);
  391. break;
  392. case 'ProjectQtyFields':
  393. result[key] = await getQuantityDatas(project.property,bills);
  394. break;
  395. case 'ProjectInfoFields':
  396. result[key] = getEngineerInfoData(project.property.engineerInfos);
  397. break;
  398. case 'ProjectFeatureFields':
  399. result[key] = getEngineerFeaturesDatas(project.property.engineerFeatures);
  400. break;
  401. }
  402. }
  403. return result
  404. }
  405. function getEngineerInfoData(engineerInfos) {
  406. let datas = [];
  407. for(let info of engineerInfos){
  408. let d = {
  409. name:info.dispName,
  410. value:info.value
  411. };
  412. datas.push(d);
  413. }
  414. return datas;
  415. }
  416. function getEngineerFeaturesDatas(engineerFeatures) {
  417. let datas = [];
  418. if (engineerFeatures !== null && engineerFeatures !== undefined) {
  419. for(let f of engineerFeatures){
  420. let tem = {
  421. ID:f.ID,
  422. name:f.name,
  423. value:f.value,
  424. ParentID:f.ParentID
  425. }
  426. datas.push(tem);
  427. }
  428. }
  429. return datas;
  430. }
  431. function getQuantityDatas(property,bills) {
  432. return gljUtil.getQuantityDatas(property.engineerFeatures,property.mainQuantities,bills,fixedFlag,_,scMathUtil,property.decimal)
  433. }
  434. function getEconomicDatas(property,bills) {
  435. return gljUtil.getEconomicDatas(property.engineerFeatures,property.economics,bills,fixedFlag,_,scMathUtil,property.decimal)
  436. }
  437. function getEngineerCostData(property,bills){
  438. let datas = [];
  439. let priceIndex = gljUtil.getEngineerCostData(property,bills,fixedFlag,scMathUtil);
  440. for(let c of priceIndex.children){
  441. let tem = {
  442. name:c.name,
  443. cost:parseFloat(c.attrs[0].value),
  444. unitCost:parseFloat(c.attrs[1].value),
  445. per:parseFloat(c.attrs[2].value)
  446. };
  447. datas.push(tem);
  448. }
  449. return datas;
  450. }
  451. async function getMainMaterialDatas(projectID,property) {
  452. let gljListModel = new GLJListModel();
  453. let [gljList, mixRatioConnectData,mixRatioMap,unitPriceMap] = await gljListModel.getListByProjectId(projectID, property.unitPriceFile?property.unitPriceFile.id:null);
  454. gljList = JSON.parse(JSON.stringify(gljList));
  455. await calcProjectGLJQuantity(projectID,{gljList:gljList,mixRatioMap:mixRatioMap},property);
  456. return gljUtil.getMainMaterialDatas(property.engineerFeatures,property.materials,{gljList:gljList},property.calcOptions,property.decimal,false,_,scMathUtil)
  457. }
  458. async function calcProjectGLJQuantity(projectID,projectGLJDatas,property){
  459. let q_decimal = property.decimal.glj.quantity;
  460. let rationGLJDatas = await ration_glj_model.find({'projectID':projectID});
  461. let rationDatas = await ration_model.model.find({'projectID':projectID});
  462. gljUtil.calcProjectGLJQuantity(projectGLJDatas,rationGLJDatas,rationDatas,[],q_decimal)
  463. }