123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503 |
- /**
- * 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)
- }
|