/** * Created by zhang on 2018/1/26. */ module.exports = { markUpdateProject:markUpdateProject, removeProjectMark:removeProjectMark, updateNodes:updateNodes, calcInstallationFee:calcInstallationFee, saveProperty: saveProperty, getDefaultColSetting: getDefaultColSetting, markProjectsToChange:markProjectsToChange, getSEIProjects:getSEIProjects, loadSEIProjectData:loadSEIProjectData, setSEILibData:setSEILibData, getIndexReportData:getIndexReportData }; let mongoose = require('mongoose'); let logger = require("../../../logs/log_helper").logger; let projectsModel = mongoose.model('projects'); let async_n = require("async"); let _ = require('lodash'); let ration_model = require('../models/ration'); let bill_model = require('../models/bills'); let consts = require('../models/project_consts'); let projectConsts = consts.projectConst; let ration_glj_model = mongoose.model('ration_glj'); let rationTemplateModel = mongoose.model('ration_template'); let project_glj_model = mongoose.model('glj_list'); let ration_glj_facade = require("../../ration_glj/facade/ration_glj_facade"); const uuidV1 = require('uuid/v1'); const gljUtil = require('../../../public/gljUtil'); let stdColSettingModel = mongoose.model('std_main_col_lib'); import GLJListModel from "../../glj/models/glj_list_model"; let economicLib = mongoose.model('std_economic_lib'); let engineerFeatureLib = mongoose.model('std_engineer_feature_lib'); let engineerInfoLib = mongoose.model('std_engineer_info_lib'); let mainQuantityLib = mongoose.model('std_main_quantity_lib'); let materialLib = mongoose.model('std_material_lib'); import fixedFlag from '../../common/const/bills_fixed'; const scMathUtil = require('../../../public/scMathUtil').getUtil(); async function calcInstallationFee(data) { let result={}; let billTasks = generateTasks(data.bills,data.useID); let rationTasks = generateTasks(data.ration,data.useID); if(billTasks.length>0){ await bill_model.model.bulkWrite(billTasks); } console.log(rationTasks); if(rationTasks.length>0){ await ration_model.model.bulkWrite(rationTasks); } //如果删除定额,需要删除对应的工料机 if(data.ration.delete.length>0){ let rationIDS = _.map(data.ration.delete,'ID'); await ration_glj_model.deleteMany({projectID: data.ration.delete[0].projectID, rationID: {"$in": rationIDS}});//删除定额工料机 } let rationGLJTasks = []; let updateList = []; if(data.ration.update.length>0){//如果有需要更新的定额工料机 for(let ur of data.ration.update){ for(let g of ur.glj){ let gTasks = { updateOne:{ filter:{ ID:g.ID, projectID:g.projectID }, update :{ quantity:g.quantity, rationItemQuantity:g.rationItemQuantity } } }; rationGLJTasks.push(gTasks); updateList.push(g); } } } if(rationGLJTasks.length>0){ await ration_glj_model.bulkWrite(rationGLJTasks); } let newGljList = []; if(data.ration.add.length>0){//新增的安装子目要增加对应的工料机 for(let nr of data.ration.add){ for(let tkey in nr.glj){ newGljList.push(await addInstallationGLJ(nr.glj[tkey])); } } } if(newGljList.length>0){ await ration_glj_model.insertMany(newGljList); } result.update = updateList; result.add = newGljList; return result; } async function addInstallationGLJ(glj) { glj.ID = uuidV1(); let info = await ration_glj_facade.getInfoFromProjectGLJ(glj); let newRecode = ration_glj_facade.createNewRecord(info); return newRecode; } function generateTasks(data,userID) { let tasks=[]; let deleteInfo={deleted: true, deleteDateTime: new Date(), deleteBy: userID}; if(data.delete && data.delete.length > 0){ for(let bd of data.delete){ //原先是假删除,现在改成真删除 let task = { deleteOne:{ filter:{ ID:bd.ID, projectID:bd.projectID } } }; /* let task={ updateOne:{ filter:{ ID:bd.ID, projectID:bd.projectID }, update :{ deleteInfo:deleteInfo } } };*/ tasks.push(task); } } if(data.add && data.add.length > 0){ for(let n_data of data.add){ let task = { insertOne :{ document:n_data } }; tasks.push(task); } } return tasks; } async function updateNodes(datas){ let nodeGroups = _.groupBy(datas,'type'); let rationTasks = []; let billTasks = []; let rationGLJTasks = []; let projectGLJTasks = []; let projectTasks = []; let rationTemplateTasks = []; let asyncTasks = []; for(let type in nodeGroups){ for(let node of nodeGroups[type]){ if(type == projectConsts.BILLS){ billTasks.push(getTask(node)); }else if(type == projectConsts.RATION){ rationTasks.push(getTask(node)); }else if(type == projectConsts.RATION_GLJ){ rationGLJTasks.push(getTask(node)); }else if(type == projectConsts.PROJECTGLJ){ projectGLJTasks.push(getTask(node,'id')); }else if(type == projectConsts.PROJECT){ projectTasks.push(getTask(node)); }else if(type == projectConsts.RATION_TEMPLATE){ rationTemplateTasks.push(getTask(node)) } } } //test------------------------ if (billTasks.length) { console.log(`billTasks===============================`); billTasks.forEach(task => { if (task.updateOne.update.name === '分部分项工程') { console.log(`task.updateOne.filter`); console.log(task.updateOne.filter); console.log(`task.updateOne.update`); console.log(task.updateOne.update); } /*console.log(`task.updateOne.filter`); console.log(task.updateOne.filter); console.log(`task.updateOne.update`); console.log(task.updateOne.update);*/ }); } //test------------------------ rationTasks.length>0?asyncTasks.push(ration_model.model.bulkWrite(rationTasks)):''; billTasks.length>0?asyncTasks.push(bill_model.model.bulkWrite(billTasks)):""; rationGLJTasks.length>0?asyncTasks.push(ration_glj_model.bulkWrite(rationGLJTasks)):""; projectGLJTasks.length>0?asyncTasks.push(project_glj_model.bulkWrite(projectGLJTasks)):""; projectTasks.length>0?asyncTasks.push(projectsModel.bulkWrite(projectTasks)):""; rationTemplateTasks.length>0?asyncTasks.push(rationTemplateModel.bulkWrite(rationTemplateTasks)):""; return asyncTasks.length>0?await Promise.all(asyncTasks):""; function getTask(node,idFiled = 'ID') { let task={ updateOne:{ filter:{}, update :_.cloneDeep(node.data) } }; task.updateOne.filter[idFiled] = node.data[idFiled];//现在复制项目也重新生成一个新的ID了,所以ID是唯一的 delete task.updateOne.update[idFiled];//防止误操作 return task; } } /*function updateNodes(datas,callback) { let tasks = []; for(let node of datas){ tasks.push(updateOne(node)) } async_n.parallel(tasks, function(err, results) { if (!err){ callback(0, '', results); } else{ console.log(err); callback(1, 'save project failed'+err.message, null); } }); function updateOne(node) { if(node.type == projectConsts.BILLS){ return function (asCallback) { bill_model.model.findOneAndUpdate({projectID: node.data.projectID, ID: node.data.ID,deleteInfo: null}, node.data,{new: true}, asCallback); } }else if(node.type ==projectConsts.RATION){ return function (asCallback) { ration_model.model.findOneAndUpdate({projectID: node.data.projectID, ID: node.data.ID,deleteInfo: null}, node.data,{new: true}, asCallback); } } } }*/ //data = {feeRateID:111111,projectID:1245}; type = feeRate async function markUpdateProject(data,type) { let query = {deleteInfo:null}; if(type=="feeRate"){//更改了费率 query['property.feeFile.id'] = data.feeRateID; } if(type=="unitFile"){//更改了单价文件 query['property.unitPriceFile.id'] = data.unitFileID;//unitPriceFile } let projects = await projectsModel.find(query); return await markProjectsToChange(projects,type,data.projectID); } async function markProjectsToChange(projects,type,extProjectID){ let tasks=[]; for(let p of projects){ if(extProjectID && p.ID===extProjectID) continue;//排除当前项目 tasks.push(generateMarkTask(type,p.ID)); } return tasks.length>0 ? await projectsModel.bulkWrite(tasks):null; } async function removeProjectMark(projectID) { return await projectsModel.findOneAndUpdate({ID:projectID},{"$unset":{"changeMark":1}}); } function generateMarkTask(value,projectID) { let task = { updateOne:{ filter:{ ID:projectID }, update:{ changeMark:value } } }; return task } // {projectID: 5, propertyName: 'aaa', propertyValue: 1} function saveProperty(data, callback){ let obj = {}; let pn = 'property.' + data.propertyName; obj[pn] = data.propertyValue; projectsModel.update({"ID": data.projectID}, obj, function (err) { if (err) { logger.err(pn + ' save error: ' + err); callback(err, null) } else { logger.info(pn + ' saved.'); callback('', null); }} ); } async function getDefaultColSetting(libID){ return await stdColSettingModel.findOne({ID: libID, deleted: false}, '-_id main_tree_col'); } function sortChildren(lists) { let IDMap ={},nextMap = {}, firstNode = null,newList=[]; for(let l of lists){ if(l.children&&l.children.length > 0) l.children = sortChildren(l.children);//递规排序 IDMap[l.ID] = l; if(l.NextSiblingID!=-1) nextMap[l.NextSiblingID] = l; } for(let t of lists){ if(!nextMap[t.ID]){ //如果在下一节点映射没找到,则是第一个节点 firstNode = t; break; } } if(firstNode){ newList.push(firstNode); delete IDMap[firstNode.ID]; setNext(firstNode,newList); } //容错处理,如果链断了的情况,直接添加到后面 for(let key in IDMap){ if(IDMap[key]) newList.push(IDMap[key]) } return newList; function setNext(node,array) { if(node.NextSiblingID != -1){ let next = IDMap[node.NextSiblingID]; if(next){ array.push(next); delete IDMap[next.ID]; setNext(next,array); } } } } async function getSEIProjects(projectID) { let project = await projectsModel.findOne({ID:projectID}); if(!project) throw new Error(`找不到建设项目:${projectID}`); let tem_e = await projectsModel.find({ParentID:project.ID}); let engineers = []; for(let e of tem_e){ if(!e.deleteInfo || !e.deleteInfo.deleted){ let tenders = await projectsModel.find({ParentID:e.ID}); let children = []; for(let t of tenders){ if(!t.deleteInfo || !t.deleteInfo.deleted){ children.push(t); } } e._doc.children = children; engineers.push(e); } } engineers = sortChildren(engineers); project._doc.children = engineers; return project; } async function loadSEIProjectData(projectID) { let gljListModel = new GLJListModel(); let [gljList, mixRatioConnectData,mixRatioMap,unitPriceMap] = await gljListModel.getListByProjectId(projectID); let rations = await ration_model.getDataSync(projectID); let bills = await bill_model.getDataSync(projectID); let ration_gljs = await ration_glj_model.find({projectID:projectID}); let projectGLJs = { gljList : gljList, mixRatioConnectData:mixRatioConnectData, mixRatioMap:mixRatioMap, unitPriceMap:unitPriceMap }; return{bills:bills,rations:rations,ration_gljs:ration_gljs,projectGLJs:projectGLJs} } async function setSEILibData(property){ if(property.engineerInfoLibID){//工程信息指标 let engineerInfo = await engineerInfoLib.findOne({'ID':property.engineerInfoLibID}); if(engineerInfo) property.engineerInfos = engineerInfo.info; } if(property.engineerFeatureLibID){//工程特征指标 let engineerFeature = await engineerFeatureLib.findOne({'ID':property.engineerFeatureLibID}); if(engineerFeature) property.engineerFeatures = engineerFeature.features; } if(property.materialLibID){//主要工料指标 let material = await materialLib.findOne({'ID':property.materialLibID}); if(material) property.materials = material.materials; } if(property.mainQuantityLibID){//主要工程量指标 let mainQuantity = await mainQuantityLib.findOne({'ID':property.mainQuantityLibID}); if(mainQuantity) property.mainQuantities = mainQuantity.index; } if(property.economicLibID){//主要工程量指标 let economic = await economicLib.findOne({'ID':property.economicLibID}); if(economic) property.economics = economic.index; } } async function getIndexReportData(projectID,keyArr) { let project = await projectsModel.findOne({ID:projectID}); let bills = await bill_model.getDataSync(projectID); let result = {}; for(let key of keyArr){ switch (key) { case 'ProjectCostFields': result[key] =getEngineerCostData(project.property,bills); break; case 'ProjectEcoFields': result[key] = getEconomicDatas(project.property,bills); break; case 'ProjectLabMaterialFields': result[key] = await getMainMaterialDatas(projectID,project.property); break; case 'ProjectQtyFields': result[key] = await getQuantityDatas(project.property,bills); break; case 'ProjectInfoFields': result[key] = getEngineerInfoData(project.property.engineerInfos); break; case 'ProjectFeatureFields': result[key] = getEngineerFeaturesDatas(project.property.engineerFeatures); break; } } return result } function getEngineerInfoData(engineerInfos) { let datas = []; for(let info of engineerInfos){ let d = { name:info.dispName, value:info.value }; datas.push(d); } return datas; } function getEngineerFeaturesDatas(engineerFeatures) { let datas = []; if (engineerFeatures !== null && engineerFeatures !== undefined) { for(let f of engineerFeatures){ let tem = { ID:f.ID, name:f.name, value:f.value, ParentID:f.ParentID } datas.push(tem); } } return datas; } function getQuantityDatas(property,bills) { return gljUtil.getQuantityDatas(property.engineerFeatures,property.mainQuantities,bills,fixedFlag,_,scMathUtil,property.decimal) } function getEconomicDatas(property,bills) { return gljUtil.getEconomicDatas(property.engineerFeatures,property.economics,bills,fixedFlag,_,scMathUtil,property.decimal) } function getEngineerCostData(property,bills){ let datas = []; let priceIndex = gljUtil.getEngineerCostData(property,bills,fixedFlag,scMathUtil); for(let c of priceIndex.children){ let tem = { name:c.name, cost:parseFloat(c.attrs[0].value), unitCost:parseFloat(c.attrs[1].value), per:parseFloat(c.attrs[2].value) }; datas.push(tem); } return datas; } async function getMainMaterialDatas(projectID,property) { let gljListModel = new GLJListModel(); let [gljList, mixRatioConnectData,mixRatioMap,unitPriceMap] = await gljListModel.getListByProjectId(projectID, property.unitPriceFile?property.unitPriceFile.id:null); gljList = JSON.parse(JSON.stringify(gljList)); await calcProjectGLJQuantity(projectID,{gljList:gljList,mixRatioMap:mixRatioMap},property); return gljUtil.getMainMaterialDatas(property.engineerFeatures,property.materials,{gljList:gljList},property.calcOptions,property.decimal,false,_,scMathUtil) } async function calcProjectGLJQuantity(projectID,projectGLJDatas,property){ let q_decimal = property.decimal.glj.quantity; let rationGLJDatas = await ration_glj_model.find({'projectID':projectID}); let rationDatas = await ration_model.model.find({'projectID':projectID}); gljUtil.calcProjectGLJQuantity(projectGLJDatas,rationGLJDatas,rationDatas,[],q_decimal) }