/** * Created by zhang on 2018/4/17. */ const projectType = { folder: 'Folder', tender: 'Tender', project: 'Project', engineering: 'Engineering', }; //先导出后require可以解决循环引用问题 module.exports={ moveProject:moveProject, copyProject:copyProject, copyExample: copyExample, getSummaryInfo: getSummaryInfo, getSummaryInfoByTender: getSummaryInfoByTender, getIndexReportData: getIndexReportData, getTendersFeeInfo: getTendersFeeInfo, getConstructionProject: getConstructionProject, getFullPath: getFullPath, projectType: projectType, getPosterityProjects: getPosterityProjects, isShare: isShare, isFirst: isFirst, getShareInfo: getShareInfo, prepareInitialData: prepareInitialData, changeFile:changeFile, getBasicInfo: getBasicInfo, getProjectFeature: getProjectFeature, getProjectByGranularity: getProjectByGranularity, importProject: importProject, getProjectPlaceholder: getProjectPlaceholder, exportProject:exportProject, importProjects:importProjects,//建筑这里重名了,这比养护加多了个s initOverHeightItems: initOverHeightItems, uploadToken:uploadToken, downLoadProjectFile:downLoadProjectFile, importProcessChecking:importProcessChecking, importInterface, }; let mongoose = require('mongoose'); let _ = require("lodash"); let feeRate_facade = require('../../fee_rates/facade/fee_rates_facade'); let glj_facade = require('../../glj/facade/glj_facade'); let project_facade = require('../../main/facade/project_facade'); let logger = require("../../../logs/log_helper").logger; const uuidV1 = require('uuid/v1'); let projectModel = mongoose.model('projects'); let projectSettingModel = mongoose.model('proj_setting'); let billsModel = mongoose.model('bills'); let rationModel = mongoose.model('ration'); let gljListModel = mongoose.model("glj_list"); let calcProgramsModel = mongoose.model('calc_programs'); let labourCoesModel = mongoose.model('labour_coes'); let feeRateModel = mongoose.model('fee_rates'); let feeRateFileModel = mongoose.model('fee_rate_file'); let unitPriceFileModel = mongoose.model("unit_price_file"); let mixRatioModel = mongoose.model("mix_ratio"); let unitPriceModel = mongoose.model("unit_price"); let installationFeeModel = mongoose.model("installation_fee"); let rationGLJModel = mongoose.model('ration_glj'); let rationCoeModel = mongoose.model('ration_coe'); let rationInstallationModel = mongoose.model('ration_installation'); let quantityDetailModel = mongoose.model('quantity_detail'); let rationTemplateModel = mongoose.model('ration_template'); let userModel = mongoose.model('user'); let compleGljSectionModel = mongoose.model('complementary_glj_section'); let compleGljSectionTModel = mongoose.model('complementary_glj_section_templates'); let compilationModel = mongoose.model('compilation'); let engineeringModel = mongoose.model('engineering_lib'); let basicInfoModel = mongoose.model('std_basic_info_lib'); let projectFeatureModel = mongoose.model('std_project_feature_lib'); let productModel = mongoose.model('product'); let stdRationItemModel = mongoose.model('std_ration_lib_ration_items'); let stdGljItemModel = mongoose.model('std_glj_lib_gljList'); import BillsTemplateModel from "../models/templates/bills_template_model"; let evaluateListModel = mongoose.model("evaluate_list"); let bidListModel = mongoose.model("bid_evaluation_list"); let contractorListModel = mongoose.model("contractor_list"); let featureLibModel = mongoose.model("std_project_feature_lib"); let importLogsModel = mongoose.model("import_logs"); const overHeightLibModel = mongoose.model('std_over_height_lib'); let scMathUtil = require('../../../public/scMathUtil').getUtil(); let counter = require('../../../public/counter/counter'); import SectionTreeDao from '../../complementary_ration_lib/models/sectionTreeModel'; let sectionTreeDao = new SectionTreeDao(); import CounterModel from "../../glj/models/counter_model"; import moment from 'moment-timezone'; import billsFlags from '../../common/const/bills_fixed'; const notDeleted = [{deleteInfo: null}, {'deleteInfo.deleted': false}]; import { defaultDecimal, billsQuantityDecimal, displaySetting, calcOptions, tenderSetting, G_FILE_VER } from '../models/project_property_template'; let labourCoeFacade = require('../../main/facade/labour_coe_facade'); let calcProgramFacade = require('../../main/facade/calc_program_facade'); let mainColLibModel = mongoose.model('std_main_col_lib'); import EngineeringLibModel from "../../users/models/engineering_lib_model"; let installationFacade = require('../../main/facade/installation_facade'); let cipher = require('../../../public/cipher'); let qiniu = require("qiniu"); let fs = require("fs"); let path = require("path"); let request = require("request"); let qiniu_config = { "AccessKey": "_gR1ed4vi1vT2G2YITGSf4_H0fJu_nRS9Tzk3T4z", "SecretKey": "ty4zd0FHqgEDaiVzSLC8DfHlai99aS7bspLkw6s6", "Bucket": "yun-update", "Domain": "http://serverupdate.smartcost.com.cn" }; let mac = new qiniu.auth.digest.Mac(qiniu_config.AccessKey, qiniu_config.SecretKey); //拷贝例题项目 //@param {String}userID {Array}projIDs拷贝的例题项目ID(建设项目、文件夹)@return {Boolean} async function copyExample(userID, compilation, projIDs){ let allProjs = [], IDMapping = {}, projMapping = {}; //例题项目不可为单项工程、单位工程、只能是建设项目、文件夹,否则不自动新建例题项目(这里不报错,让用户没有感觉) let parentExample = await projectModel.find({ID: {$in: projIDs}, $or: notDeleted}); if (parentExample.length === 0) { return false; } allProjs = allProjs.concat(parentExample); for (let i = 0; i < parentExample.length; i++) { let data = parentExample[i]; if (data.projType === projectType.tender || data.projType === projectType.engineering) { return false; } //设置成顶节点,最后一个节点设置成末节 data.ParentID = -1; if (i === parentExample.length - 1) { data.NextSiblingID = -1; } } //获取所有的子项目 let posterityProjs = await getPosterityProjects(projIDs); allProjs = allProjs.concat(posterityProjs); let projCounter = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.project, allProjs.length); //旧ID与新ID映射 for (let i = 0; i < allProjs.length; i++) { let data = allProjs[i]; let newID = projCounter.sequence_value - (allProjs.length - 1) + i; IDMapping[data.ID] = newID; projMapping[newID] = data; } //return; //设置新的树结构数据 let newDate = new Date(), parentBulks = []; for (let data of allProjs) { let orgID = data.ID; data.ID = IDMapping[data.ID]; data.ParentID = IDMapping[data.ParentID] ? IDMapping[data.ParentID] : -1; data.NextSiblingID = IDMapping[data.NextSiblingID] ? IDMapping[data.NextSiblingID] : -1; data.createDateTime = newDate; data.userID = userID; data.compilation = compilation; data.shareInfo = []; if (data.projType !== projectType.tender) { let newData = _.cloneDeep(data._doc); delete newData._id; // await projectModel.create(newData); parentBulks.push({insertOne: {document: newData}}); } else { //拷贝单位工程 let rootProjectID = projMapping[data.ParentID].ParentID; let projectMap = { copy: { document: {userID: userID, ID: orgID, NextSiblingID: data.NextSiblingID, ParentID: data.ParentID, name: data.name, shareInfo: [], compilation: compilation, fileVer: data.fileVer, projType: data.projType, property: {rootProjectID: rootProjectID}} } }; await copyProject(userID, compilation, {projectMap}, data.ID); } } //最末顶层项目(兼容测试时已存在有项目,正常用户第一次进费用定额,该费用定额不存在项目) let lastProj = await projectModel.findOne({userID: userID, compilation: compilation, ParentID: -1, NextSiblingID: -1, $or: notDeleted}); if (lastProj) { parentBulks.push({updateOne: {filter: {ID: lastProj.ID}, update: {$set: {NextSiblingID: parentExample[0].ID}}}}); } //拷贝父级文件 await projectModel.bulkWrite(parentBulks); return true; } async function copyProject(userID, compilationID,data,newProjectID = null) { let projectMap = data.projectMap; let originalID = projectMap['copy'].document.ID; if (!newProjectID) { newProjectID = await getCounterID("projects"); } let newFeeName = null,newUnitName = null; let calcProgramFileID = uuidV1();//新的计算程序文件ID let labourCoeFileID = uuidV1();//新的人工调整系数文件ID let feeRateFileID = uuidV1();//新的费率文件ID let unitPriceFileID = await getCounterID("unit_price_file");//新的单价文件ID let originalProject = await projectModel.findOne({'ID':originalID});//查找最新的那项目信息,前端缓存的数据有可能不是最新的 if(!originalProject){ throw new Error('没有找到对应的项目,复制失败!'); } let property = originalProject.property; if(projectMap['copy'].document.property){//更新项目属性信息 setProperty(property,projectMap['copy'].document.property); } let originalProperty = _.cloneDeep(property); projectMap['copy'].document.property = property; logger.info("复制项目: 旧项目ID: "+originalID+ " ------- 新项目ID: "+newProjectID); //费率文件、单价文件重名检查 let feeRate = await feeRateFileModel.findOne({rootProjectID:originalProperty.rootProjectID,name:originalProperty.feeFile.name,deleteInfo:null}); if(feeRate){//存在重名的文件 newFeeName = originalProperty.feeFile.name + '(' + moment(Date.now()).tz("Asia/Shanghai").format('MM-DD HH:mm:ss') + '复制)'; projectMap['copy'].document.property.feeFile.name = newFeeName; } let unitPriceFile = await unitPriceFileModel.findOne({root_project_id: originalProperty.rootProjectID,name:originalProperty.unitPriceFile.name,deleteInfo: null}); if(unitPriceFile){//存在重名的文件 newUnitName = originalProperty.unitPriceFile.name + '(' + moment(Date.now()).tz("Asia/Shanghai").format('MM-DD HH:mm:ss') + '复制)'; projectMap['copy'].document.property.unitPriceFile.name = newUnitName; } //更新项目的属性; projectMap['copy'].document.ID = newProjectID; if(projectMap['copy'].document.property.calcProgramFile){ projectMap['copy'].document.property.calcProgramFile.ID = calcProgramFileID; } if(projectMap['copy'].document.property.labourCoeFile){ projectMap['copy'].document.property.labourCoeFile.ID = labourCoeFileID; } if(projectMap['copy'].document.property.feeFile){ projectMap['copy'].document.property.feeFile.id = feeRateFileID; } if(projectMap['copy'].document.property.unitPriceFile){ projectMap['copy'].document.property.unitPriceFile.id = unitPriceFileID; } projectMap['copy'].document.userID = userID; projectMap['copy'].document.compilation = compilationID; projectMap['copy'].document.createDateTime = new Date(); //清单、定额ID生成任务 let IDtasks = [ createIDsAndReturn(originalID,billsModel), createIDsAndReturn(originalID,rationModel), getProjectGLJIDAndReturn(originalID,newProjectID) ]; let [billMap,rationMap,projectGLJMap] = await Promise.all(IDtasks); //所有复制任务异步处理,提升效率 复制清单,定额,4个文件,项目工料机, 定额工料机,人工系数,工程量明细,定额安装增加费,安装增加费 let copyTasks = [ createProject(projectMap), copyProjectSetting(originalID,newProjectID), copyBills(newProjectID,billMap), copyRations(newProjectID,billMap.uuidMaping,rationMap,projectGLJMap.IDMap), copyProjectGLJ(projectGLJMap.datas), copyInstallFee(originalID,newProjectID), copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationGLJModel), copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationCoeModel), copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,quantityDetailModel), copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationInstallationModel), copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationTemplateModel), copyMaterialList(originalID,newProjectID,projectGLJMap.IDMap,evaluateListModel), copyMaterialList(originalID,newProjectID,projectGLJMap.IDMap,bidListModel), copyMaterialList(originalID,newProjectID,projectGLJMap.IDMap,contractorListModel), ]; if(originalProperty.calcProgramFile){ copyTasks.push(commonCopy(newProjectID,originalProperty.calcProgramFile.ID,calcProgramFileID,calcProgramsModel)); } if(originalProperty.labourCoeFile){ copyTasks.push(commonCopy(newProjectID,originalProperty.labourCoeFile.ID,labourCoeFileID,labourCoesModel)); } if(originalProperty.feeFile){ copyTasks.push(copyFeeRate(originalProperty.rootProjectID,userID,originalProperty.feeFile.id,feeRateFileID,newFeeName)); } if(originalProperty.unitPriceFile){ copyTasks.push(copyUnitPriceFile(newProjectID,originalProperty.rootProjectID,userID,originalProperty.unitPriceFile.id,unitPriceFileID,newUnitName)); } let p = await Promise.all(copyTasks); return p[0]; } async function createIDsAndReturn(originalID,model) { let uuidMaping = {};//做ID映射 let datas = []; let result = await model.find({"projectID": originalID}, '-_id'); uuidMaping['-1'] = -1; //建立uuid-ID映射 for(let d of result){ uuidMaping[d.ID] = uuidV1(); datas.push(d._doc); } return{uuidMaping:uuidMaping,datas:datas}; } async function getProjectGLJIDAndReturn(originalID,newProjectID) { let IDMap = {}; let datas = []; let result = await gljListModel.find({project_id:originalID}, '-_id'); let gljCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.glj_list, result.length); for(let i = 0; i < result.length; i++){ let d = result[i]; let newID = gljCount.sequence_value - (result.length - 1) + i; //let newID = await getCounterID("glj_list"); IDMap[d.id] = newID; d._doc.project_id = newProjectID; d._doc.id = newID; datas.push(d._doc); } return{IDMap:IDMap,datas:datas}; } async function createProject(projectMap) {//复制项目 let tasks = []; if(projectMap['update']){//如果复制后存在前一个节点,则更新其NextSiblingID tasks.push({updateOne:{filter : projectMap['update'].query, update : {NextSiblingID:projectMap['copy'].document.ID}}}); } tasks.push({insertOne: {document: projectMap['copy'].document}});//复制任务 await projectModel.bulkWrite(tasks); return projectMap; } async function copyProjectSetting(originalID,newProjectID) { let result = null; let setting = await projectSettingModel.findOne({"projectID": originalID}, '-_id'); if(setting){ setting._doc.projectID =newProjectID; result = await projectSettingModel.create(setting._doc); } return result; } async function copyBills(newProjectID,billMap) { let uuidMaping = billMap.uuidMaping;//做ID映射 for(let doc of billMap.datas){ doc = getCopyBillDatas(doc,newProjectID,uuidMaping); } await insertMany(billMap.datas,billsModel); return billMap.datas; } function getCopyBillDatas(doc,newProjectID,uuidMaping) { doc.projectID = newProjectID; doc.ID = uuidMaping[doc.ID] ? uuidMaping[doc.ID] : -1; doc.ParentID = uuidMaping[doc.ParentID] ? uuidMaping[doc.ParentID] : -1; doc.NextSiblingID = uuidMaping[doc.NextSiblingID] ? uuidMaping[doc.NextSiblingID] : -1; //对于有基数计算的节点,需要替换计算基数中引用的ID为新的ID if(doc.calcBase && doc.calcBase != ""){ let idArr = scMathUtil.getFIDArr(doc.calcBase); for(let re of idArr){ let oID = re.substr(1);//去掉开头的@字符 if(!uuidMaping[oID]) continue; doc.calcBase = doc.calcBase.replace(new RegExp(oID, "g"),uuidMaping[oID]); } } return doc; } async function copyRations(newProjectID,billsIDMap,rationMap,projectGLJIDMap) { let uuidMaping = rationMap.uuidMaping; for(let doc of rationMap.datas){ doc = getCopyRationData(doc,newProjectID,billsIDMap,uuidMaping,projectGLJIDMap); } if(rationMap.datas.length > 0){ await insertMany(rationMap.datas,rationModel); } return rationMap.datas; } function getCopyRationData(doc,newProjectID,billsIDMap,uuidMaping,projectGLJIDMap){ doc.projectID = newProjectID; doc.ID = uuidMaping[doc.ID] ? uuidMaping[doc.ID] : -1; if(doc.billsItemID){ doc.billsItemID = billsIDMap[doc.billsItemID]?billsIDMap[doc.billsItemID]:-1; } if(doc.referenceRationID) doc.referenceRationID = uuidMaping[doc.referenceRationID]?uuidMaping[doc.referenceRationID]:undefined; //绑定定类型的工料机 项目工料机ID doc.type==3&&doc.projectGLJID&&projectGLJIDMap[doc.projectGLJID]?doc.projectGLJID = projectGLJIDMap[doc.projectGLJID]:''; return doc; } async function copyProjectGLJ(gljList) { await insertMany(gljList,gljListModel); } async function commonCopy(newProjectID,oldID,newID,model) { //对于只需更新ID和projectID的文件的复制 let result = null; let file = await model.findOne({"ID": oldID}, '-_id'); if(file){ file._doc.ID = newID; file._doc.projectID =newProjectID; result = await model.create(file._doc); } return result; } async function copyFeeRate(rootProjectID,userID,originalFeeRateFileID,feeRateFileID,newName) {//复制费率和费率文件 let [feeRateFile,feeRate] =await feeRate_facade.getFeeRateByID(originalFeeRateFileID); let newFeeRateID = uuidV1(); if(feeRate){ feeRate._doc.ID = newFeeRateID; await feeRateModel.create(feeRate._doc); } if(feeRateFile){ feeRateFile._doc.ID = feeRateFileID; newName?feeRateFile._doc.name = newName:''; feeRateFile._doc.userID = userID; feeRateFile._doc.rootProjectID = rootProjectID; feeRateFile._doc.feeRateID = newFeeRateID; await feeRateFileModel.create(feeRateFile._doc); } } async function copyUnitPriceFile(newProjectID,rootProjectID,userID,originaluUnitPriceFileID,unitPriceFileID,newName) {//复制单价文件、组成物 let taskList = [ copyFile(newProjectID,rootProjectID,userID,originaluUnitPriceFileID,unitPriceFileID,newName), copySubList(originaluUnitPriceFileID,unitPriceFileID,mixRatioModel), copySubList(originaluUnitPriceFileID,unitPriceFileID,unitPriceModel) ]; return await Promise.all(taskList); async function copyFile(newProjectID,rootProjectID,userID,originaluUnitPriceFileID,unitPriceFileID,newName){ let unitPriceFile = await unitPriceFileModel.findOne({id:originaluUnitPriceFileID}, '-_id'); if(unitPriceFile){ unitPriceFile._doc.id = unitPriceFileID; newName?unitPriceFile._doc.name = newName:''; unitPriceFile._doc.project_id = newProjectID; unitPriceFile._doc.user_id = userID; unitPriceFile._doc.root_project_id = rootProjectID } await unitPriceFileModel.create(unitPriceFile._doc); } async function copySubList(srcFID,newFID,model) { let mList = await model.find({unit_price_file_id: srcFID}, '-_id'); let rList = []; for(let m of mList){ m._doc.unit_price_file_id = newFID; m._doc.id = await getCounterID(model.modelName); rList.push(m._doc); } await insertMany(rList,model) } } async function copyInstallFee(originalPID,newProjectID) { let result = null; let installationFee = await installationFeeModel.find({projectID:originalPID}, '-_id'); let newList = []; for(let i of installationFee ){ i._doc.ID = uuidV1(); i._doc.projectID = newProjectID; newList.push(i._doc); } if(newList.length >0){ result = await installationFeeModel.insertMany(newList); } return result; } async function copyRationSubList(originalPID,newProjectID,billIDMap,rationIDMap,projectGLJIDMap,model) {// 定额工料机,附注条件,工程量明细,定额安装增加费,模板子目 let subList = await model.find({projectID:originalPID}, '-_id'); let newList =[]; for(let s of subList){ s._doc = getCopyRationSubData(s._doc,newProjectID,billIDMap,rationIDMap,projectGLJIDMap); /* s._doc.ID = uuidV1(); s._doc.projectID = newProjectID; s._doc.rationID&&rationIDMap[s._doc.rationID]?s._doc.rationID = rationIDMap[s._doc.rationID]:''; s._doc.billID&&billIDMap[s._doc.billID]?s._doc.billID = billIDMap[s._doc.billID]:''; s._doc.billsItemID&&billIDMap[s._doc.billsItemID]?s._doc.billsItemID = billIDMap[s._doc.billsItemID]:''; s._doc.projectGLJID&&projectGLJIDMap[s._doc.projectGLJID]?s._doc.projectGLJID = projectGLJIDMap[s._doc.projectGLJID]:''; if(s._doc.templateList && s._doc.templateList.length > 0 ){ for(let t of s._doc.templateList){ if(t.billID && billIDMap[t.billID]) t.billID = billIDMap[t.billID]; if(t.fxID && billIDMap[t.fxID]) t.fxID = billIDMap[t.fxID]; } }*/ newList.push(s._doc); } await insertMany(newList,model); } async function copyMaterialList(originalPID,newProjectID,projectGLJIDMap,model) {//暂估材料等信息 let materialList = await model.find({projectID:originalPID}, '-_id').lean(); let newList = []; for(let m of materialList){ newList.push(getNewMaterial(m,newProjectID,projectGLJIDMap)) } await insertMany(newList,model); } function getNewMaterial(m,newProjectID,projectGLJIDMap) { m.ID = uuidV1(); m.projectID = newProjectID; if(projectGLJIDMap[m.projectGLJID]) m.projectGLJID = projectGLJIDMap[m.projectGLJID]; return m; } function getCopyRationSubData(doc,newProjectID,billIDMap,rationIDMap,projectGLJIDMap){ doc.ID = uuidV1(); doc.projectID = newProjectID; doc.rationID&&rationIDMap[doc.rationID]?doc.rationID = rationIDMap[doc.rationID]:''; doc.billID&&billIDMap[doc.billID]?doc.billID = billIDMap[doc.billID]:''; doc.billsItemID&&billIDMap[doc.billsItemID]?doc.billsItemID = billIDMap[doc.billsItemID]:''; doc.projectGLJID&&projectGLJIDMap[doc.projectGLJID]?doc.projectGLJID = projectGLJIDMap[doc.projectGLJID]:''; if(doc.templateList && doc.templateList.length > 0 ){ for(let t of doc.templateList){ if(t.billID && billIDMap[t.billID]) t.billID = billIDMap[t.billID]; if(t.fxID && billIDMap[t.fxID]) t.fxID = billIDMap[t.fxID]; } } return doc; } async function moveProject(data) { data = JSON.parse(data); let projectMap = data.projectMap,feeRateMap = data.feeRateMap,unitPriceMap = data.unitPriceMap; let projectTasks = [],feeRateTask=[],feeRateFileTask=[],unitPriceTask=[],unitPriceFileTask=[],mixRatioTask=[]; let feeUniqMap=[],priceUniqMap={};//费率、单价文件唯一映射表当移动多个项目时,任务有可能出现重复的情况 if(!_.isEmpty(feeRateMap)&&data.rootProjectID){//如果费率有修改 let feeRates =await feeRate_facade.getFeeRatesByProject(data.rootProjectID);//取目标建设项目的所有费率文件,重名检查 for(let projectID in feeRateMap){ let rename = feeRateMap[projectID].name; let feeRateID = feeRateMap[projectID].query.ID; let checkFee = _.find(feeRates,{'name':rename}); let newID = feeRateID; if(checkFee){//说明费率名字已存在,需要重命名 rename = feeUniqMap[feeRateID]?feeUniqMap[feeRateID].name:rename + '(' + new Date().Format('MM-dd hh:mm:ss') + '移动)'; projectMap[projectID]['update']['property.feeFile.name'] = rename; if(feeRateMap[projectID].action == 'move'){ feeRateMap[projectID].update.name = rename; } } if(feeRateMap[projectID].action == 'copy'){ newID = feeUniqMap[feeRateID]?feeUniqMap[feeRateID].ID:uuidV1(); feeRateMap[projectID].name = rename; feeRateMap[projectID].ID = newID; projectMap[projectID]['update']['property.feeFile.id'] = newID; } if(!feeUniqMap[feeRateID]){ await generateFeeRateTask(feeRateMap[projectID],feeRateTask,feeRateFileTask); feeUniqMap[feeRateID] = {name:rename,ID:newID}; } } } if(!_.isEmpty(unitPriceMap)&&data.rootProjectID) {//如果单价文件有修改 let unitPriceFiles = await unitPriceFileModel.find({root_project_id: data.rootProjectID, deleteInfo: null}); for(let projectID in unitPriceMap){ let checkUn = _.find(unitPriceFiles,{'name':unitPriceMap[projectID].name}); let rename = unitPriceMap[projectID].name; let unitPriceID = unitPriceMap[projectID].query.id; let newID = unitPriceID; if(checkUn){//重名检查 rename = priceUniqMap[unitPriceID]?priceUniqMap[unitPriceID].name:rename + '(' + new Date().Format('MM-dd hh:mm:ss') + '移动)'; projectMap[projectID]['update']['property.unitPriceFile.name'] = rename; if(unitPriceMap[projectID].action =='move'){ unitPriceMap[projectID].update.name = rename; } } if(unitPriceMap[projectID].action =='copy'){ newID = priceUniqMap[unitPriceID]?priceUniqMap[unitPriceID].id: await getCounterID("unit_price_file"); unitPriceMap[projectID].name = rename; unitPriceMap[projectID].id = newID; projectMap[projectID]['update']['property.unitPriceFile.id'] = newID; } if(!priceUniqMap[unitPriceID]){ await generateUnitPriceTask(unitPriceMap[projectID],projectID,data.user_id,unitPriceTask,unitPriceFileTask,mixRatioTask); priceUniqMap[unitPriceID] = {name:rename,id:newID}; } } } if(!_.isEmpty(projectMap)){ for(let projectID in projectMap){ projectTasks.push({updateOne:{filter : projectMap[projectID].query, update : projectMap[projectID].update}}); } } projectTasks.length>0?await projectModel.bulkWrite(projectTasks):''; feeRateTask.length>0?await feeRateModel.bulkWrite(feeRateTask):''; feeRateFileTask.length>0?await feeRateFileModel.bulkWrite(feeRateFileTask):''; unitPriceFileTask.length>0?await unitPriceFileModel.bulkWrite(unitPriceFileTask):''; unitPriceTask.length>0?await insertMany(unitPriceTask,unitPriceModel):''; mixRatioTask.length>0?await insertMany(mixRatioTask,mixRatioModel):''; return projectMap; } async function generateFeeRateTask(data,feeRateTask,feeRateFileTask) { if(data.action == 'move'){ let task = { updateOne:{ filter : data.query, update : data.update } }; feeRateFileTask.push(task); } if(data.action == 'copy'){//copy 费率的时候用insertOne方法 let [feeRateFile,feeRate] =await feeRate_facade.getFeeRateByID(data.query.ID); let newFeeRateID = uuidV1(); let newFeeRate = { ID:newFeeRateID, rates:feeRate.rates }; let newFeeRateFile = { ID:data.ID, rootProjectID:data.rootProjectID, userID:feeRateFile.userID, name:data.name, libID:feeRateFile.libID, libName:feeRateFile.libName, feeRateID:newFeeRateID }; feeRateTask.push({insertOne :{document:newFeeRate}}); feeRateFileTask.push({insertOne :{document:newFeeRateFile}}); } } async function generateUnitPriceTask(data,projectID,user_id,unitPriceTask,unitPriceFileTask,mixRatioTask){ if(data.action == 'move'){ let task = { updateOne:{ filter : data.query, update : data.update } }; unitPriceFileTask.push(task); } if(data.action == 'copy'){ let newUnitFile = { id:data.id, name: data.name, project_id:projectID, user_id:user_id, root_project_id: data.rootProjectID }; unitPriceFileTask.push({insertOne :{document:newUnitFile}}); let mixRatios = await mixRatioModel.find({unit_price_file_id: data.query.id}); mixRatios = JSON.stringify(mixRatios); mixRatios = JSON.parse(mixRatios); for(let m of mixRatios){ delete m._id; // 删除原有id信息 delete m.id; m.unit_price_file_id = data.id; m.id = await getCounterID('mix_ratio'); mixRatioTask.push(m); } let unitPrices = await unitPriceModel.find({unit_price_file_id: data.query.id});//unit_price_file_id unitPrices = JSON.stringify(unitPrices); unitPrices = JSON.parse(unitPrices); for(let u of unitPrices){ delete u._id; // 删除原有id信息 delete u.id; u.unit_price_file_id = data.id; u.id = await getCounterID('unit_price'); unitPriceTask.push(u); } } } async function getCounterID(collectionName){ let counterModel = new CounterModel(); return await counterModel.getId(collectionName); } async function insertMany(datas,model) { while (datas.length>1000){//因为mongoose限制了批量插入的条数为1000.所以超出限制后需要分批插入 let newList = datas.splice(0,1000);//一次插入1000条 await model.insertMany(newList); } await model.insertMany(datas); } function setProperty(Obj,updateData) { for(let ukey in updateData){ if(_.isObject(updateData[ukey]) && _.isObject(Obj[ukey])){ setProperty(Obj[ukey],updateData[ukey]); }else { Obj[ukey] = updateData[ukey]; } } } function isDef(v){ return typeof v !== 'undefined' && v !== null; } function getTotalFee(bills, feeName) { if(!isDef(bills)){ return 0; } if(!isDef(bills.fees) || bills.fees.length <= 0){ return 0; } for(let fee of bills.fees){ if(isDef(fee.fieldName) && fee.fieldName === feeName){ return isDef(fee.totalFee) ? fee.totalFee : 0; } } return 0; } function summarizeToParent(parent, child, fields = null) { const decimal = -2; if (!fields) { fields = ['engineeringCost', 'subEngineering', 'measure', 'safetyConstruction', 'other', 'charge', 'tax', 'estimate']; } for (let field of fields) { parent[field] = scMathUtil.roundTo(parseFloat(parent[field]) + parseFloat(child[field]), decimal); } /* const decimal = -2; parent.engineeringCost = scMathUtil.roundTo(parseFloat(parent.engineeringCost) + parseFloat(child.engineeringCost), decimal); parent.subEngineering = scMathUtil.roundTo(parseFloat(parent.subEngineering) + parseFloat(child.subEngineering), decimal); parent.measure = scMathUtil.roundTo(parseFloat(parent.measure) + parseFloat(child.measure), decimal); parent.safetyConstruction = scMathUtil.roundTo(parseFloat(parent.safetyConstruction) + parseFloat(child.safetyConstruction), decimal); parent.other = scMathUtil.roundTo(parseFloat(parent.other) + parseFloat(child.other), decimal); parent.charge = scMathUtil.roundTo(parseFloat(parent.charge) + parseFloat(child.charge), decimal); parent.tax = scMathUtil.roundTo(parseFloat(parent.tax) + parseFloat(child.tax), decimal);*/ } function getBuildingArea(projFeature){ if(!projFeature || projFeature.length === 0){ return null; } for(let f of projFeature){ if(f.key === 'buildingArea'){ return f.value; } } return null; } //根据单位工程ID获取经济指标信息 //@param {Number}prj_id @return {Object} async function getIndexReportData(prj_id, filters) { return await project_facade.getIndexReportData(prj_id, filters); } // 根据树结构数据排序 function getSortedDataByTree(data) { // NextSiblingID-数据映射 const mapping = {}; data.forEach(item => { // 错误数据兼容处理 // 由于之前的导入建设项目,会导致最后的一个项目的NextSiblingID为空,为非正确的-1 // 因此把项目中NextSibling为空的数据设置为NextSiblingID为-1 if (!item.NextSiblingID) { item.NextSiblingID = -1; } mapping[item.NextSiblingID] = item; }); let lastItem = data.find(item => +item.NextSiblingID === -1); if (!lastItem) { return data; } const rst = [lastItem]; let preItem = mapping[lastItem.ID]; while (preItem) { rst.unshift(preItem); preItem = mapping[preItem.ID]; } // 根据树结构排序形成的新数组与旧数组项数不同,说明树结构数据有问题(断链),则返回原本数据。 return rst.length === data.length ? rst : data; } //根据单位工程ID获取汇总信息 //@param {Number}tenderID {String}summaryType @return {Object} async function getSummaryInfoByTender(tenderID, summaryType) { const notDeleted = [{deleteInfo: null}, {'deleteInfo.deleted': false}]; let tender = await projectModel.findOne({ID: tenderID, $or: notDeleted}); let parent, parentName, compilationIllustration; let summaryList = []; if(!tender){ return null; } let engineering = await projectModel.findOne({ID: tender.ParentID, $or: notDeleted}); if(!engineering){ return null; } let project = await projectModel.findOne({ID: engineering.ParentID, $or: notDeleted}); if(!project){ return null; } let summaryInfo = await getSummaryInfo([project.ID]); if(summaryType === projectType.engineering){ // 汇总到单项工程级别 parent = engineering; let tenders = await projectModel.find({ParentID: engineering.ID, $or: notDeleted}).lean(); tenders = getSortedDataByTree(tenders); for(let t of tenders){ if(summaryInfo[t.ID]){ summaryInfo[t.ID]['name'] = t.name ? t.name : ''; summaryList.push(summaryInfo[t.ID]); } } } else { // 汇总到建设项目级别 parent = project; let engs = await projectModel.find({ParentID: project.ID, $or: notDeleted}).lean(); engs = getSortedDataByTree(engs); for(let e of engs){ if(summaryInfo[e.ID]){ summaryInfo[e.ID]['name'] = e.name ? e.name : ''; summaryList.push(summaryInfo[e.ID]); } } } // 项目名称 parentName = parent && parent.name ? parent.name : ''; // 编制说明 compilationIllustration = parent && parent.property && parent.property.compilationIllustration ? parent.property.compilationIllustration : ''; return { parent: { name: parentName, compilationIllustration: compilationIllustration}, subList: summaryList }; } //获取单位工程的各标段费用信息(不进行汇总) async function getTendersFeeInfo(tenders) { let IDMapping = {}; //固定清单类别与汇总金额字段映射 let flagFieldMapping = {}; flagFieldMapping[billsFlags.ENGINEERINGCOST] = 'engineeringCost'; flagFieldMapping[billsFlags.SUB_ENGINERRING] = 'subEngineering'; flagFieldMapping[billsFlags.MEASURE] = 'measure'; flagFieldMapping[billsFlags.SAFETY_CONSTRUCTION] = 'safetyConstruction'; flagFieldMapping[billsFlags.OTHER] = 'other'; flagFieldMapping[billsFlags.CHARGE] = 'charge'; flagFieldMapping[billsFlags.TAX] = 'tax'; let tenderIDs = []; if(tenders.length > 0){ for(let tender of tenders){ tenderIDs.push(tender.ID); IDMapping[tender.ID] = {engineeringCost: 0, subEngineering: 0, measure: 0, safetyConstruction: 0, other: 0, charge: 0, tax: 0, estimate: 0, rate: 0, buildingArea: '', perCost: ''}; IDMapping[tender.ID]['buildingArea'] = ''; } //需要获取的清单固定类别综合合价:工程造价、分部分项、措施项目、安全文明施工专项、规费、其他项目、税金 let needFlags = [billsFlags.ENGINEERINGCOST, billsFlags.SUB_ENGINERRING, billsFlags.MEASURE, billsFlags.SAFETY_CONSTRUCTION, billsFlags.CHARGE, billsFlags.OTHER, billsFlags.TAX]; //获取单位工程汇总金额需要用到的所有清单 let allBills = await billsModel.find({projectID: {$in: tenderIDs}, 'flags.flag': {$in: needFlags}, $or: notDeleted}, '-_id projectID fees flags'); //进行单位工程级别的汇总 for(let bills of allBills){ let billsFlag = bills.flags[0]['flag']; let costField = flagFieldMapping[billsFlag]; IDMapping[bills.projectID][costField] = getTotalFee(bills, 'common'); //暂估合价(工程造价暂估合价) if (billsFlag === billsFlags.ENGINEERINGCOST){ IDMapping[bills.projectID]['estimate'] = getTotalFee(bills, 'estimate'); } } //占造价比例、单方造价 for(let tender of tenders){ let tenderInfo = IDMapping[tender.ID]; tenderInfo.rate = ''; //单方造价 tenderInfo.perCost = ''; } } return IDMapping; } async function getSummaryInfo(projectIDs, feeFields = null){ function initFees(obj, feeFields) { for (let data of feeFields) { obj[data.v] = 0; } } if (!feeFields) { feeFields = [ {k: billsFlags.ENGINEERINGCOST, v: 'engineeringCost'}, {k: billsFlags.SUB_ENGINERRING, v: 'subEngineering'}, {k: billsFlags.MEASURE, v: 'measure'}, {k: billsFlags.SAFETY_CONSTRUCTION, v: 'safetyConstruction'}, {k: billsFlags.OTHER, v: 'other'}, {k: billsFlags.CHARGE, v: 'charge'}, {k: billsFlags.TAX, v: 'tax'} ]; } //ID与汇总信息映射 let IDMapping = {}; //固定清单类别与汇总金额字段映射 let flagFieldMapping = {}; for (let data of feeFields) { flagFieldMapping[data.k] = data.v; } /*flagFieldMapping[billsFlags.ENGINEERINGCOST] = 'engineeringCost'; flagFieldMapping[billsFlags.SUB_ENGINERRING] = 'subEngineering'; flagFieldMapping[billsFlags.MEASURE] = 'measure'; flagFieldMapping[billsFlags.SAFETY_CONSTRUCTION] = 'safetyConstruction'; flagFieldMapping[billsFlags.OTHER] = 'other'; flagFieldMapping[billsFlags.CHARGE] = 'charge'; flagFieldMapping[billsFlags.TAX] = 'tax';*/ let projects = await projectModel.find({ID: {$in : projectIDs}, projType: projectType.project, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]}); //设置建设项目的总建筑面积 for(let project of projects){ let grossArea = ''; if(project.property && project.property.basicInformation){ for(let basicInfo of project.property.basicInformation){ if(basicInfo.key === 'basicInfo'){ for(let k of basicInfo.items){ if(k.key === 'grossArea'){ grossArea = k.value; } } } } } //IDMapping[project.ID] = {engineeringCost: 0, subEngineering: 0, measure: 0, safetyConstruction: 0, other: 0, charge: 0, tax: 0, estimate: 0, rate: 0, buildingArea: grossArea, perCost: ''}; IDMapping[project.ID] = {estimate: 0, rate: 0, buildingArea: grossArea, perCost: ''}; initFees(IDMapping[project.ID], feeFields); console.log(IDMapping[project.ID]); } //单项工程 let engineerings = await projectModel.find({ParentID: {$in : projectIDs}, projType: projectType.engineering, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]}); //单位工程 let tenders = []; let engIDs = []; for(let eng of engineerings){ engIDs.push(eng.ID); //IDMapping[eng.ID] = {engineeringCost: 0, subEngineering: 0, measure: 0, safetyConstruction: 0, other: 0, charge: 0, tax: 0, estimate: 0, rate: 0, buildingArea: '', perCost: ''}; IDMapping[eng.ID] = {estimate: 0, rate: 0, buildingArea: '', perCost: ''}; initFees(IDMapping[eng.ID], feeFields); } if(engIDs.length > 0){ tenders = await projectModel.find({ParentID: {$in : engIDs}, projType: projectType.tender, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]}); } let tenderIDs = []; if(tenders.length > 0){ for(let tender of tenders){ tenderIDs.push(tender.ID); /*IDMapping[tender.ID] = {engineeringCost: 0, subEngineering: 0, measure: 0, safetyConstruction: 0, other: 0, charge: 0, tax: 0, rate: 0, estimate: 0, buildingArea: '', perCost: '',changeMark:tender.changeMark,property:tender.property};*/ IDMapping[tender.ID] = {rate: 0, estimate: 0, buildingArea: '', perCost: '', changeMark:tender.changeMark,property:tender.property}; initFees(IDMapping[tender.ID], feeFields); let buildingArea = getBuildingArea(tender.property.projectFeature); if(buildingArea){ IDMapping[tender.ID]['buildingArea'] = buildingArea; } } //需要获取的清单固定类别综合合价:工程造价、分部分项、措施项目、安全文明施工专项、规费、其他项目、税金... /*let needFlags = [billsFlags.ENGINEERINGCOST, billsFlags.SUB_ENGINERRING, billsFlags.MEASURE, billsFlags.SAFETY_CONSTRUCTION, billsFlags.CHARGE, billsFlags.OTHER, billsFlags.TAX];*/ let needFlags = feeFields.map(data => data.k); //获取单位工程汇总金额需要用到的所有清单 let allBills = await billsModel.find({projectID: {$in: tenderIDs}, 'flags.flag': {$in: needFlags}, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]}, '-_id projectID fees flags'); //进行单位工程级别的汇总 for(let bills of allBills){ let billsFlag = bills.flags[0]['flag']; let costField = flagFieldMapping[billsFlag]; IDMapping[bills.projectID][costField] = getTotalFee(bills, 'common'); //暂估合价(工程造价暂估合价) if (billsFlag === billsFlags.ENGINEERINGCOST){ IDMapping[bills.projectID]['estimate'] = getTotalFee(bills, 'estimate'); } } let summaryFields = feeFields.map(data => data.v); summaryFields.push('estimate'); //进行单项工程级别的汇总 for(let tender of tenders){ summarizeToParent(IDMapping[tender.ParentID], IDMapping[tender.ID], summaryFields); } //进行建设项目级别的汇总 for(let eng of engineerings){ summarizeToParent(IDMapping[eng.ParentID], IDMapping[eng.ID], summaryFields); } //占造价比例、单方造价 const rateDecimal = -2; const perCostDecimal = -2; for(let tender of tenders){ let tenderInfo = IDMapping[tender.ID]; let engInfo = IDMapping[tender.ParentID]; tenderInfo.rate = engInfo.engineeringCost == 0 ? 0 : scMathUtil.roundTo(tenderInfo.engineeringCost * 100 / engInfo.engineeringCost, rateDecimal); //单方造价 tenderInfo.perCost = tenderInfo.buildingArea.toString().trim() === '' || tenderInfo.buildingArea == 0 ? tenderInfo.buildingArea.toString().trim() : scMathUtil.roundTo(tenderInfo.engineeringCost / tenderInfo.buildingArea, perCostDecimal); } for(let eng of engineerings){ let engInfo = IDMapping[eng.ID]; let projInfo = IDMapping[eng.ParentID]; engInfo.rate = !isDef(projInfo) || projInfo.engineeringCost == 0 ? 0 : scMathUtil.roundTo(engInfo.engineeringCost * 100 / projInfo.engineeringCost, rateDecimal); } //建设项目占造价比例及单方造价 for(let project of projects){ let projectInfo = IDMapping[project.ID]; projectInfo.rate = 100; projectInfo.perCost = projectInfo.buildingArea.toString().trim() === '' || projectInfo.buildingArea == 0 ? projectInfo.buildingArea.toString().trim() : scMathUtil.roundTo(projectInfo.engineeringCost / projectInfo.buildingArea, perCostDecimal); } } return IDMapping; } //根据项目ID获取所属建设项目 //@param {Number}projectID @return {Object} async function getConstructionProject(projectID){ function returnProject(project){ if(!project || project.projType === projectType.folder){ return null; } if(project.projType === projectType.project){ return project; } } let project = await projectModel.findOne({ID: projectID, $or: notDeleted}); let returnV = returnProject(project); if(returnV !== undefined){ return returnV; } let parent = await projectModel.findOne({ID: project.ParentID, $or: notDeleted}); returnV = returnProject(parent); if(returnV !== undefined){ return returnV; } let grandParent = await projectModel.findOne({ID: parent.ParentID, $or: notDeleted}); returnV = returnProject(grandParent); return returnV !== undefined ? returnV : null; } //获取单位工程完整目录结构 //@param {Number}projectID @return {Arry} async function getFullPath(projectID) { let fullPath = []; let project = await projectModel.findOne({ID: projectID, $or: notDeleted}, '-_id ParentID name'); if(project){ fullPath.push(project.name); await getParent(project.ParentID); } fullPath = fullPath.reverse(); return fullPath; async function getParent(ParentID) { if(ParentID != -1){ let parent = await projectModel.findOne({ID: ParentID, $or: notDeleted}, '-_id ParentID name'); if(parent){ fullPath.push(parent.name); await getParent(parent.ParentID); } } } } //获取projectIDs文件下所有子项目(不包括projectIDs本身) async function getPosterityProjects(projectIDs) { let rst = []; async function getProjects(parentIDs) { if (parentIDs.length > 0) { let newIDs = []; let projs = await projectModel.find({ParentID: {$in: parentIDs}, $or: notDeleted}, '-_id'); for (let proj of projs) { // 兼容旧的错误数据,可能ParentID和ID相同 if (parentIDs.includes(proj.ID)) { continue; } rst.push(proj); newIDs.push(proj.ID); } await getProjects(newIDs); } } await getProjects(projectIDs); return rst; } //根据项目获得分享信息(分享层级不一定在项目级)(以最新为准) //@param {String}userId {Object}tender @return {Object} || {null} async function getShareInfo(userId, project) { //与该用户相关的分享 let shareList = []; while (project) { for(let shareData of project.shareInfo){ if(shareData.userID === userId){ shareList.push(shareData); break; } } project = await projectModel.findOne({ID: project.ParentID}, '-_id shareInfo ID ParentID'); } //获取最新分享 shareList.sort(function (a, b) { let aV = Date.parse(a.shareDate), bV = Date.parse(b.shareDate); if (aV > bV) { return -1; } else if (aV < bV) { return 1; } return 0; }); return shareList[0] || null; } //打开的单位工程是否是被分享的. async function isShare(userId, project){ //判断是否是打开分享的项目,属于分享文件的子项也算 while (project) { for(let shareData of project.shareInfo){ if(shareData.userID === userId){ return true; } } project = await projectModel.findOne({ID: project.ParentID}, '-_id shareInfo ID ParentID'); } return false; } //用户是否第一次进入费用定额 async function isFirst(userId, compilationId) { let userData = await userModel.findOne({_id: mongoose.Types.ObjectId(userId)}, '-_id used_list'); let first = false; if (userData) { first = !_.find(userData.used_list, function (o) { return o.compilationId === compilationId; });; } return first; } //用户第一次进入费用定额的数据准备 async function prepareInitialData(userId, compilation, example) { let first = await isFirst(userId, compilation); if (first) { await updateUsedList(userId, compilation); let prepareTask = [ copyCompleRationSection(userId, compilation), copyCompleGljSection(userId, compilation) ]; if (example && example.length > 0) { prepareTask.push(copyExample(userId, compilation, example)); } await Promise.all(prepareTask); } } async function updateUsedList(userId, compilation) { await userModel.update({_id: mongoose.Types.ObjectId(userId)}, {$push: {used_list: {compilationId: compilation}}}); } //拷贝补充定额章节树 async function copyCompleRationSection(userId, compilationId) { await sectionTreeDao.copyDataFromTemplate(userId, compilationId); } //拷贝补充人材机分类树 async function copyCompleGljSection(userId, compilationId) { let templateData = await compleGljSectionTModel.find({compilationId: compilationId}); if (templateData.length > 0) { let insertDatas = [], uuidMapping = {}; //将ID替换成UUID for (let temData of templateData) { uuidMapping[temData.ID] = uuidV1(); } for(let temData of templateData) { let insertD = { userId: userId, compilationId: compilationId, Name: temData.Name, ID: uuidMapping[temData.ID], ParentID: uuidMapping[temData.ParentID] || -1, NextSiblingID: uuidMapping[temData.NextSiblingID] || -1, }; insertDatas.push(insertD); } //插入数据 await compleGljSectionModel.insertMany(insertDatas); } } async function changeFile(datas,userID,fileID,name,from,type){//from 费率或单价文件,type从单前建设项目还是从其它建设项目中复制 let projectIDs = [],newFile = {id:fileID,name:name};//计录从其它项目中复制的文件,选中多个的时候只需复制一次 let projectUpdateType = from == "feeRateFile"?"feeRate":"unitFile"; for(let d of datas){ let tem_file = from == "feeRateFile"? await feeRate_facade.changeFeeRateFile(d, newFile,type,userID):await glj_facade.changeUnitFile(d, newFile,type,userID); if(type == 1 && tem_file){//从建设项目复制时,只有第一次需要复制,剩下的就相当于使用同个建设项目的情况了 let newID = from == "feeRateFile"?tem_file.ID:tem_file.id; newFile = {id:newID,name:tem_file.name}; type = 0; } projectIDs.push({ID:d.projectID}) } await project_facade.markProjectsToChange(projectIDs,projectUpdateType)//项目标记为待刷新状态 } //获取费用定额绑定的基本信息库数据 async function getBasicInfo(compilationID, fileKind = null) { let compilation = await compilationModel.findOne({_id: mongoose.Types.ObjectId(compilationID)}); if (!compilation) { return null; } let billValuation = compilation.bill_valuation.find(function (data) { return data.enable; }); if (!billValuation) { return null; } let engineerings = await engineeringModel.find({valuationID: billValuation.id}); let engineering = engineerings.find(function (data) { return data.info_lib && data.info_lib.length > 0; }); if (!engineering || !engineering.info_lib || !engineering.info_lib[0]) { return null; } let infoLib = await basicInfoModel.findOne({ID: engineering.info_lib[0].id}); //提取文件类型中需要的数据 (投标项目可能不需要招标的一些信息) if (fileKind && infoLib && infoLib.info && infoLib.info.length) { let strMap = { 1: 'tender', //投标 2: 'bid', //招标 3: 'control' //控制价 }; let needfulData = infoLib.info.filter(data => !data.fileKind || data.fileKind === strMap[fileKind]); needfulData.forEach(nData => { let needfulSub = nData.items.filter(sData => !sData.fileKind || sData.fileKind === strMap[fileKind]); nData.items = needfulSub; }); infoLib.info = needfulData; } return infoLib; } async function getProjectFeature(valuationID, engineeringName, feeName) { let engineering = await engineeringModel.findOne({valuationID: valuationID, name: engineeringName, feeName: feeName}); if (!engineering || !engineering.feature_lib || !engineering.feature_lib[0]) { return null; } let featureLib = await projectFeatureModel.findOne({ID: engineering.feature_lib[0].id}); return featureLib; } //根据单位工程,获取建设项目-单项工程-单位工程,不包含无单位工程的单项工程 //@param {Number}tenderID(单位工程ID) {Number}granularity(颗粒度 1:建设项目 2:单项工程 3:单位工程) async function getProjectByGranularity(tenderID, granularity, userID, versionName) { const GRANULARITY = { PROJECT: 1, ENGINEERING: 2, TENDER: 3 }; let theTender = await projectModel.findOne({userID: userID, ID: tenderID}); //加上session的userID,防止tenderID被篡改过 if (!theTender) { return null; } let theEngineering = await projectModel.findOne({ID: theTender.ParentID}); if (!theEngineering) { return null; } let constructionProject = await projectModel.findOne({ID: theEngineering.ParentID}); if (!constructionProject) { return null; } let engineerings; if (granularity === GRANULARITY.PROJECT) { engineerings = await projectModel.find({ParentID: constructionProject.ID, $or: notDeleted}); for (let eng of engineerings) { eng._doc.children = await projectModel.find({ParentID: eng.ID, $or: notDeleted}); } } else { engineerings = [theEngineering]; if (granularity === GRANULARITY.ENGINEERING) { theEngineering._doc.children = await projectModel.find({ParentID: theEngineering.ID, $or: notDeleted}); } else { theEngineering._doc.children = [theTender]; } } constructionProject._doc.children = engineerings; //获取汇总信息 let feeFields = [ {k: billsFlags.ENGINEERINGCOST, v: 'engineeringCost'}, {k: billsFlags.SUB_ENGINERRING, v: 'subEngineering'}, {k: billsFlags.MEASURE, v: 'measure'}, {k: billsFlags.SAFETY_CONSTRUCTION, v: 'safetyConstruction'}, {k: billsFlags.OTHER, v: 'other'}, {k: billsFlags.CHARGE, v: 'charge'}, {k: billsFlags.PROVISIONAL, v: 'provisional'}, {k: billsFlags.MATERIAL_PROVISIONAL, v: 'materialProvisional'}, {k: billsFlags.ENGINEERING_ESITIMATE, v: 'engineeringEstimate'}, {k: billsFlags.DAYWORK, v: 'daywork'}, {k: billsFlags.TURN_KEY_CONTRACT, v: 'turnKeyContract'}, {k: billsFlags.CLAIM_VISA, v: 'claimVisa'}, {k: billsFlags.TAX, v: 'tax'} ]; constructionProject._doc.summaryInfo = await getSummaryInfo([constructionProject.ID], feeFields); //获取编制软件信息: 软件公司;软件名;版本号;授权信息; base64 let product = await productModel.findOne({}); let company = product.company || '珠海纵横创新软件有限公司', version = product.version || ''; constructionProject._doc.softInfo = `${company};${versionName};${version};${userID}`; return constructionProject; } //获取项目数据占位ID async function getProjectPlaceholder(data) { let rst = {}; //项目本身数据 if (data.projectCount) { let projectCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.project, data.projectCount); rst.project = projectCount.sequence_value - data.projectCount + 1; } //项目人材机数据 if (data.projectGLJCount) { let projectGLJCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.glj_list, data.projectGLJCount); rst.projectGLJ = projectGLJCount.sequence_value - data.projectGLJCount + 1; } //组成物数据 if (data.ratioCount) { let ratioCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.mix_ratio, data.ratioCount); rst.ratio = ratioCount.sequence_value - data.ratioCount + 1; } //单价文件数据 if (data.unitPriceFileCount) { let unitPriceFileCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.unit_price_file, data.unitPriceFileCount); rst.unitPriceFile = unitPriceFileCount.sequence_value - data.unitPriceFileCount + 1; } //单价数据 if (data.unitPriceCount) { let unitPriceCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.unit_price, data.unitPriceCount); rst.unitPrice = unitPriceCount.sequence_value - data.unitPriceCount + 1; } return rst; } /* * 接口导入 项目详细数据都导入完成了,再生成项目数据(项目管理界面数据) * */ async function importProject(importObj, userID, compilationID) { let toInsertProjects = [importObj]; //待新增项目数据 await setupProject(importObj); //设置项目ID及相关数据 for (let curEng of importObj.engs) { await setupProject(curEng); toInsertProjects.push(curEng); for (let curTender of curEng.tenders) { await setupProject(curTender.tender); //插入单位工程的详细数据 await importTenderDetail(curTender); toInsertProjects.push(curTender.tender); } delete curEng.tenders; } delete importObj.engs; //项目内部数据设置、新增完毕后,插入项目本身的数据,更新前节点数据 let bulks = []; //如果有前节点,更新前节点 if (importObj.preID !== -1) { bulks.push({ updateOne: {filter: {ID: importObj.preID}, update: {$set: {NextSiblingID: importObj.ID}}} }); } for (let insertP of toInsertProjects) { bulks.push({ insertOne: {document: insertP} }); } if (bulks.length > 0) { await projectModel.bulkWrite(bulks); } let summaryInfo = await getSummaryInfo([importObj.ID]); //设置汇总字段 for(let proj of toInsertProjects){ let summaryProj = summaryInfo[proj.ID]; if(summaryProj){ proj.engineeringCost = summaryProj.engineeringCost; proj.subEngineering = summaryProj.subEngineering; proj.measure = summaryProj.measure; proj.safetyConstruction = summaryProj.safetyConstruction; proj.other = summaryProj.other; proj.charge = summaryProj.charge; proj.tax = summaryProj.tax; proj.rate = summaryProj.rate; proj.buildingArea = summaryProj.buildingArea; proj.perCost = summaryProj.perCost; } } return toInsertProjects; //给项目数据设置一些需要的数据 async function setupProject(data) { data.userID = userID; data.compilation = compilationID; data.fileVer = G_FILE_VER; data.createDateTime = new Date(); if (data.projType === 'Project') { await setupConstruct(data); } else if (data.projType === 'Tender') { await setupTender(data); } } //给建设项目设置一些数据 async function setupConstruct(data) { //更新基本信息, 按照key匹配 let infoLib = await getBasicInfo(data.compilation, data.property.fileKind); if (infoLib) { //标准基本信息库的数据打平 let flatDatas = []; infoLib.info.forEach(ifData => flatDatas.push(...ifData.items)); data.basicInformation.forEach(importI => { flatDatas.forEach(item => { if (item.key === 'engineeringName') { item.value = data.name; } else if (item.key === 'fileKind') { item.value = {'1': '投标', '2': '招标'}[data.property.fileKind] } else if (item.key === 'taxModel') { item.value = {'1': '一般计税法', '2': '简易计税法'}[data.property.taxType] } if (item.key === importI.key) { item.value = importI.value; } }); }); } data.property.basicInformation = infoLib ? infoLib.info : []; } //给单位工程设置一些数据 async function setupTender(data) { //小数位数 需要修改,所以深拷贝 data.property.decimal = JSON.parse(JSON.stringify(defaultDecimal)); // 定额工程量、人材机消耗量精度设为最大6 data.property.decimal.ration.quantity = 6; data.property.decimal.glj.quantity = 6; //清单工程量精度 需要修改,所以深拷贝 data.property.billsQuantityDecimal = JSON.parse(JSON.stringify(billsQuantityDecimal)); // 清单工程量精度设置最大4 data.property.billsQuantityDecimal.forEach(data => data.decimal = 4); //呈现选项 data.property.displaySetting = displaySetting; data.property.billsCalcMode = 0; data.property.zanguCalcMode = 0; //计算选项 data.property.calcOptions = calcOptions; //安装增加费 if(data.property.isInstall === true || data.property.isInstall === 'true'){//判断是否安装工程 await installationFacade.copyInstallationFeeFromLib(data.ID, data.property.engineering_id); } //锁定清单 data.property.lockBills = true; //工料机单价调整系数 data.property.tenderSetting = tenderSetting; //工程特征相关更新 let featureLib = await getProjectFeature(data.property.valuation, data.property.engineeringName, data.property.feeStandardName); if (featureLib) { //把导入的数据设置到默认生成的数据中,按名称匹配 (导入项不确定,因此无法确定获取项的key) data.projectFeature.forEach(importF => { let matchData = featureLib.feature.find(f => f.dispName === importF.name); if (matchData) { matchData.value = importF.value; } }); //设置工程专业的值为费用标准的值.. featureLib.feature.forEach(f => { if (f.key === 'engineering') { f.value = data.property.feeStandardName; } }); } data.property.projectFeature = featureLib ? featureLib.feature : []; // 指标信息相关设置 await project_facade.setSEILibData(data.property); } } //插入单位工程内部详细数据 async function importTenderDetail(tenderData) { //单价文件 let upFile = { id: tenderData.tender.property.unitPriceFile.id, name: tenderData.tender.name, project_id: tenderData.tender.ID, user_id: tenderData.tender.userID, root_project_id: tenderData.tender.property.rootProjectID }; await unitPriceFileModel.create(upFile); //费率文件 let feeRateFileID = await feeRate_facade.newFeeRateFile(tenderData.tender.userID, tenderData.tender); tenderData.tender.property.feeFile = feeRateFileID ? feeRateFileID : -1; //人工系数文件 let lcFile = await labourCoeFacade.newProjectLabourCoe(tenderData.tender); tenderData.tender.property.labourCoeFile = lcFile ? lcFile : null; let cpFile = await calcProgramFacade.newProjectCalcProgramFile(tenderData.tender); tenderData.tender.property.calcProgramFile = cpFile ? cpFile : null; //列设置 let engineeringModel = new EngineeringLibModel(); let engineering = await engineeringModel.getEngineering(tenderData.tender.property.engineering_id); let mainTreeCol = await mainColLibModel.findOne({ID: tenderData.tender.property.colLibID}); await projectSettingModel.create({projectID: tenderData.tender.ID, main_tree_col: mainTreeCol.main_tree_col, glj_col: engineering.glj_col}); //清单 if (tenderData.bills.length) { await billsModel.insertMany(tenderData.bills); } //投标文件中,才会有下面这些数据 if (enterDetail(tenderData)) { //匹配标准数据,更新一些标准数据 await setupStdData(tenderData); let task = []; //定额 if (tenderData.ration.length) { task.push(rationModel.insertMany(tenderData.ration)) } //定额人材机 if (tenderData.rationGLJ.length) { task.push(rationGLJModel.insertMany(tenderData.rationGLJ)); } //定额调整系数 if (tenderData.rationCoe.length) { task.push(rationCoeModel.insertMany(tenderData.rationCoe)); } //项目人材机 if (tenderData.projectGLJ.length) { task.push(gljListModel.insertMany(tenderData.projectGLJ)); } // 承包人材料 if (tenderData.contractorList.length) { task.push(contractorListModel.insertMany(tenderData.contractorList)); } // 评标材料表 if (tenderData.bidEvaluationList.length) { task.push(bidListModel.insertMany(tenderData.bidEvaluationList)); } // 暂估价材料表 if (tenderData.evaluationList.length) { task.push(evaluateListModel.insertMany(tenderData.evaluationList)); } //组成物 if (tenderData.mixRatio.length) { task.push(mixRatioModel.insertMany(tenderData.mixRatio)); } //单价文件 if (tenderData.unitPrice.length) { task.push(unitPriceModel.insertMany(tenderData.unitPrice)); } await Promise.all(task); } //继续处理定额等数据 function enterDetail(tenderData) { return tenderData.ration.length || tenderData.rationGLJ.length || tenderData.projectGLJ.length || tenderData.mixRatio.length || tenderData.unitPrice.length; } } //匹配标准数据,需要匹配标准定额,更新导入的定额人材机的定额消耗量等数据 async function setupStdData(tenderData) { //获取标准定额数据 (定额子目的编码查找) let matchRationCodes = [...new Set(tenderData.ration.map(ration => ration.code))]; if (!matchRationCodes.length) { return; } //限制在当前费用定额可用的定额库里查找 let stdRations = await stdRationItemModel.find({code: {$in: matchRationCodes}, rationRepId: {$in: tenderData.tender.rationLibIDs}}, '-_id -rationAssList -rationCoeList -rationInstList'); //标准定额code - 映射 let stdRationCodeMap = {}; stdRations.forEach(stdRation => stdRationCodeMap[stdRation.code] = stdRation); //获取标准人材机数据 (人材机汇总的编码查找) let matchGLJCodes = [...new Set(tenderData.projectGLJ.map(pGLJ => pGLJ.original_code))]; if (!matchGLJCodes.length) { return; } //限制在当前费用定额可用的人材机库里查找 let stdGLJs = await stdGljItemModel.find({code: {$in: matchGLJCodes}, repositoryId: {$in: tenderData.tender.gljLibIDs}}, '-_id -component -priceProperty'); //标准人材机code - 映射 let stdGLJCodeMap = {}; stdGLJs.forEach(stdGLJ => stdGLJCodeMap[stdGLJ.code] = stdGLJ); //更新定额数据 tenderData.ration.forEach(r => { let stdRation = stdRationCodeMap[r.code]; if (stdRation) { r.caption = stdRation.caption; r.from = 'std'; r.libID = stdRation.rationRepId; r.stdID = stdRation.ID; r.prefix = stdRation.rationRepId == tenderData.tender.defaultRationLib ? '' : '借'; r.content = stdRation.jobContent; if (stdRation.feeType) { r.programID = stdRation.feeType; } else { // 是标准定额,但是该标准定额取费专业为空,取定额取费专业(后台配置项) r.programID = tenderData.tender.property.engineering; } } else { r.from = 'cpt'; r.prefix = '补'; } }); //更新定额人材机数据 tenderData.rationGLJ.forEach(rGLJ => { rGLJ.from = 'cpt'; //匹配定额 let stdRation = stdRationCodeMap[rGLJ.rationCode]; if (stdRation) { //根据导入数据的定额人材机编码匹配人材机 let stdGLJ = stdGLJCodeMap[rGLJ.original_code]; if (stdGLJ) { rGLJ.from = 'std'; rGLJ.GLJID = stdGLJ.ID; rGLJ.type = stdGLJ.gljType; rGLJ.shortName = stdGLJ.shortName; rGLJ.repositoryId = stdGLJ.repositoryId; rGLJ.model = stdGLJ.model; rGLJ.adjCoe = stdGLJ.adjCoe; //找匹配到的标准定额中定额人材机的相应人材机,更新定额消耗 let stdRationGLJ = stdRation.rationGljList.find(data => data.gljId === stdGLJ.ID); if (stdRationGLJ) { rGLJ.rationItemQuantity = stdRationGLJ.consumeAmt; } } } }); //更新人材机汇总数据 tenderData.projectGLJ.forEach(pGLJ => { if (!pGLJ.specs) { pGLJ.specs = null; } let stdGLJ = stdGLJCodeMap[pGLJ.original_code]; if (stdGLJ) { pGLJ.glj_id = stdGLJ.ID; pGLJ.model = stdGLJ.model; if (pGLJ.type !== stdGLJ.gljType) { //更新组成物connect_key let keyStr = [pGLJ.code || 'null', pGLJ.name || 'null', pGLJ.specs || 'null', pGLJ.unit || 'null', pGLJ.type].join('|-|'); let ratios = tenderData.mixRatio.filter(ratio => ratio.connect_key === keyStr); let newKeyStr = [pGLJ.code || 'null', pGLJ.name || 'null', pGLJ.specs || 'null', pGLJ.unit || 'null', stdGLJ.gljType || 'null'].join('|-|'); ratios.forEach(ratio => ratio.connect_key = newKeyStr); } pGLJ.type = stdGLJ.gljType; //更新类型,标准的数据类型更准确,导入的类型数据有细分识别不了 } }); //更新单价文件数据 tenderData.unitPrice.forEach(up => { let stdGLJ = stdGLJCodeMap[up.original_code]; if (stdGLJ) { up.glj_id = stdGLJ.ID; up.type = stdGLJ.gljType; up.short_name = stdGLJ.shortName; } }); //更新组成物数据 tenderData.mixRatio.forEach(ratio => { let stdGLJ = stdGLJCodeMap[ratio.code]; if (stdGLJ) { ratio.glj_id = stdGLJ.ID; ratio.type = stdGLJ.gljType; } }); } async function exportProject(userID,data){//导出建设项目 if(data.type == 'main'){ return await exportMainData(userID,data.projectID); }else { return await exportTenderData(data); } } async function exportMainData(userID,projectID) { let result = {userID:userID,projects:[],type:'Project'};//type 备用属性,表示导出的类型,目前导出的都是整个建设项目 let tenderIDs = []; let project = await projectModel.findOne({ID:projectID}); if(!project) throw new Error("没有找到该建设项目:"+projectID); result['compilationID'] = project.compilation; result['from'] = "construction"; result.projects.push(project); let subProjects = await projectModel.find({"$or": [{'ParentID':projectID}, {"property.rootProjectID": projectID}]}); for(let s of subProjects){ if(!s.deleteInfo || !s.deleteInfo.deleted){ result.projects.push(s); if(s.projType =="Tender") tenderIDs.push(s.ID); } } let files = {unitFiles:await exportUnitFiles(projectID),feeRateFiles:await exportFeeRateFiles(projectID)}; result.files = files; result = cipher.aesEncrypt(JSON.stringify(result)); result +="|----|" +JSON.stringify(tenderIDs); return result; } async function exportUnitFiles(rootProjectID){ let unitFiles = []; let files = await unitPriceFileModel.find({root_project_id:rootProjectID}); for(let f of files){ if(f.deleteInfo && f.deleteInfo.deleted == true) continue; let tem = {unitFile:f}; tem.unitPrices = await unitPriceModel.find({unit_price_file_id:f.id}); tem.mixRatios = await mixRatioModel.find({unit_price_file_id:f.id}); unitFiles.push(tem); } return unitFiles; } async function exportFeeRateFiles(rootProjectID) { let feeRateFiles = []; let files = await feeRateFileModel.find({rootProjectID:rootProjectID}); for(let f of files){ if(f.deleteInfo && f.deleteInfo.deleted == true) continue; let tem = {feeRateFile:f}; tem.feeRate = await feeRateModel.findOne({ID:f.feeRateID}); feeRateFiles.push(tem); } return feeRateFiles; } async function exportTenderData(data){ let result = {}; let projectSetting = await projectSettingModel.findOne({"projectID": data.projectID}, '-_id'); if(projectSetting) result['projSetting'] = projectSetting; result.bills = await billsModel.find({"projectID": data.projectID}); result.rations = await rationModel.find({'$or': [{projectID: data.projectID, deleteInfo: null}, {projectID: data.projectID, 'deleteInfo.deleted': {$in: [null, false]}}]}); result.projectGLJs = await gljListModel.find({'project_id':data.projectID}); result.installationFees = await installationFeeModel.find({projectID:data.projectID}); result.rationGLJs = await rationGLJModel.find({projectID:data.projectID}); result.rationCoes = await rationCoeModel.find({projectID:data.projectID}); result.quantityDetails = await quantityDetailModel.find({projectID:data.projectID}); result.rationInstallations = await rationInstallationModel.find({projectID:data.projectID}); result.rationTemplates = await rationTemplateModel.find({projectID:data.projectID}); result.calcProgramsFile = await calcProgramsModel.findOne({projectID:data.projectID}); result.labourCoes = await labourCoesModel.findOne({projectID:data.projectID}); result.evaluateList = await evaluateListModel.find({projectID:data.projectID}, '-_id').lean(); result.bidList = await bidListModel.find({projectID:data.projectID}, '-_id').lean(); result.contractorList = await contractorListModel.find({projectID:data.projectID}, '-_id').lean(); return cipher.aesEncrypt(JSON.stringify(result)); } async function downLoadProjectFile(info) { let result = {error:0}; let bucketManager2 = new qiniu.rs.BucketManager(mac, null); let publicBucketDomain = qiniu_config.Domain;// "http://serverupdate.smartcost.com.cn";//这里不支持https let deadline = parseInt(Date.now() / 1000) + 3600; // 1小时过期 let privateDownloadUrl = bucketManager2.privateDownloadUrl(publicBucketDomain, info.key, deadline); console.log(privateDownloadUrl); let data = { key:info.key, userID:info.session.sessionUser.id, status:"start", create_time:+new Date() }; await importLogsModel.create(data); doDownLoadAndImport(privateDownloadUrl,info); return result; } async function doDownLoadAndImport(privateDownloadUrl,info) { let stream = fs.createWriteStream(path.join(__dirname, "../../../tmp/"+info.key));// request(privateDownloadUrl).pipe(stream).on("close", async function (err) { console.log("文件[" + info.key + "]下载完毕"); let doc = {status:"finish"}; try { let data = fs.readFileSync(stream.path,'utf-8'); let result = await importProjects(data,{session:info.session},info.updateData); if(result.error == 1){ doc.errorMsg = result.msg; doc.status = "error"; } }catch (error){ console.log(error); doc.errorMsg = "导入失败,请检查文件!"; doc.status = "error"; }finally { await importLogsModel.update({key:info.key},doc); fs.unlinkSync(stream.path); } }); } async function importProcessChecking(data){ let result = {error:0}; let log = await importLogsModel.findOne({key:data.key}); if(log){ if(log.status == "finish"){ result.status = "complete"; await importLogsModel.remove({key:data.key}); }else if(log.status == "start"){ result.status = "processing"; }else if(log.status == "error"){ result.error = 1; result.msg = log.errorMsg; await importLogsModel.remove({key:data.key}); } }else { result.error = 1; result.msg = `导入过程中发生错误!`; } return result; } // 从cdn服务器下载文件,key就是文件名 async function downloadFileSync(key) { const filePath = path.join(__dirname, '../../../tmp/', key); const bucketManager2 = new qiniu.rs.BucketManager(mac, null); const publicBucketDomain = qiniu_config.Domain; // "http://serverupdate.smartcost.com.cn";//这里不支持https const deadline = parseInt(Date.now() / 1000) + 3600; // 1小时过期 const privateDownloadUrl = bucketManager2.privateDownloadUrl(publicBucketDomain, key, deadline); const stream = fs.createWriteStream(filePath); return new Promise((resolve, reject) => { request(privateDownloadUrl) .pipe(stream) .on('close', () => { // 读取文件返回字符串 const srcData = fs.readFileSync(stream.path,'utf-8'); resolve({ path: stream.path, srcData: srcData }); }) .on('error', reject); }); } // 导入接口 async function importInterface(key, userID, compilationID) { // 源文件内容文本 let downloadFilePath = ''; try { const { path, srcData } = await downloadFileSync(key); downloadFilePath = path; if (!srcData) { throw '无有效数据'; } const importData = JSON.parse(srcData); const projectData = await importProject(importData, userID, compilationID); return projectData; } catch (err) { throw err; } finally { fs.unlinkSync(downloadFilePath); } } async function importProjects(data,req,updateData) { let result = {error:0}; let stringArr = data.split("|----|"); let datas = []; for(let s of stringArr){ datas.push(JSON.parse(cipher.aesDecrypt(s))); } let mainData = datas.length > 0 ?datas[0]:null; if(mainData){ if(mainData.from && mainData.from != "construction"){ result.error = 1; result.msg = "导入失败:您要导入的文件是由“纵横公路养护云版”导出,当前软件是“大司空云计价”,请选择正确的软件再进行操作!"; }else if(mainData.compilationID != req.session.sessionCompilation._id){ const fileCompilation = await compilationModel.findOne({_id: mongoose.Types.ObjectId(mainData.compilationID)}, 'name'); const fileCompilationName = fileCompilation ? fileCompilation.name : '未知的费用定额'; const curCompilationName = req.session.sessionCompilation.name; result.error = 1; result.msg = `导入失败:您要导入的文件是由“${fileCompilationName}”导出,当前软件是“${curCompilationName}”,请选择正确的费用定额再进行操作!`; }else { let [projectIDMap,labourCoeFileIDMap,calcProgramFileIDMap] = await handleMainProjectDatas(mainData,updateData,req.session.sessionUser.id); if(datas.length > 1 ){ for(let i = 1;i 0){ for(let b of data.bills){ billsIDMap[b.ID] = uuidV1(); } for(let b of data.bills){ delete b._id; b = getCopyBillDatas(b,newProjectID,billsIDMap); bills.push(b); } } //生成项目工料机数据 if(data.projectGLJs && data.projectGLJs.length > 0){ let gljCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.glj_list, data.projectGLJs.length); for(let i = 0; i < data.projectGLJs.length; i++){ let d = data.projectGLJs[i]; delete d._id; let newID = gljCount.sequence_value - (data.projectGLJs.length - 1) + i; projectGLJIDMap[d.id] = newID; d.project_id = newProjectID; d.id = newID; projectGLJs.push(d); } } //生成新的定额 if(data.rations && data.rations.length > 0){ for(let r of data.rations){ rationIDMap[r.ID] = uuidV1(); } for(let r of data.rations){ delete r._id; r = getCopyRationData(r,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap); rations.push(r); } } //生成定额下挂的定额工料机等等数据 if(data.rationGLJs && data.rationGLJs.length > 0) rationGLJs = setRationSubList(data.rationGLJs,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap); if(data.rationCoes && data.rationCoes.length > 0) rationCoes = setRationSubList(data.rationCoes,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap); if(data.quantityDetails && data.quantityDetails.length > 0) quantityDetails = setRationSubList(data.quantityDetails,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap); if(data.rationInstallations && data.rationInstallations.length > 0) rationInstallations = setRationSubList(data.rationInstallations,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap); if(data.rationTemplates && data.rationTemplates.length > 0) rationTemplates = setRationSubList(data.rationTemplates,newProjectID,billsIDMap,rationIDMap,projectGLJIDMap); if(data.evaluateList && data.evaluateList.length > 0) evaluateList = setMaterialList(data.evaluateList,newProjectID,projectGLJIDMap); if(data.bidList && data.bidList.length > 0) bidList = setMaterialList(data.bidList,newProjectID,projectGLJIDMap); if(data.contractorList && data.contractorList.length > 0) contractorList = setMaterialList(data.contractorList,newProjectID,projectGLJIDMap); //生成projectSetting 文件 if(data.projSetting){ data.projSetting.projectID =newProjectID; newProjectSetting = data.projSetting; delete newProjectSetting._id; } //生成计算程序文件,系数文件 if(data.calcProgramsFile && calcProgramFileIDMap[data.calcProgramsFile.ID]){ data.calcProgramsFile.ID = calcProgramFileIDMap[data.calcProgramsFile.ID]; data.calcProgramsFile.projectID = newProjectID; newCalcProgramsFile = data.calcProgramsFile; delete newCalcProgramsFile._id; } if(data.labourCoes && labourCoeFileIDMap[data.labourCoes.ID]){ data.labourCoes.ID = labourCoeFileIDMap[data.labourCoes.ID]; data.labourCoes.projectID = newProjectID; newLabourCoe = data.labourCoes; delete newLabourCoe._id; } if(newProjectSetting) await projectSettingModel.create(newProjectSetting); if(bills.length > 0) await insertMany(bills,billsModel); if(rations.length > 0) await insertMany(rations,rationModel); if(projectGLJs.length > 0) await insertMany(projectGLJs,gljListModel); if(rationGLJs.length > 0) await insertMany(rationGLJs,rationGLJModel); if(rationCoes.length > 0) await insertMany(rationCoes,rationCoeModel); if(quantityDetails.length > 0) await insertMany(quantityDetails,quantityDetailModel); if(rationInstallations.length > 0) await insertMany(rationInstallations,rationInstallationModel); if(rationTemplates.length > 0) await insertMany(rationTemplates,rationTemplateModel); if(evaluateList.length > 0) await insertMany(evaluateList,evaluateListModel); if(bidList.length > 0) await insertMany(bidList,bidListModel); if(contractorList.length > 0) await insertMany(contractorList,contractorListModel); if(newCalcProgramsFile) await calcProgramsModel.create(newCalcProgramsFile); if(newLabourCoe) await labourCoesModel.create(newLabourCoe); } function setMaterialList(datas,newProjectID,projectGLJIDMap){ let arrs = []; for(let d of datas){ arrs.push(getNewMaterial(d,newProjectID,projectGLJIDMap)) } return arrs } function setRationSubList(datas,newProjectID,billIDMap,rationIDMap,projectGLJIDMap) { let arrs = []; for(let d of datas){ delete d._id; d = getCopyRationSubData(d,newProjectID,billIDMap,rationIDMap,projectGLJIDMap); arrs.push(d); } return arrs; } async function handleMainProjectDatas(mainData,updateData,userID) { let mainProjectID = -1; let projectIDMap = {},feeRateFileIDMap={},unitPriceFileIDMap={},labourCoeFileIDMap={},calcProgramFileIDMap={}; let tasks = []; projectIDMap[-1] = -1;//最后一个项目的nextID为-1的情况 //生成新的projectID for(let p of mainData.projects){ let newProjectID = await getCounterID("projects"); projectIDMap[p.ID] = newProjectID; if(p.projType == "Project") mainProjectID = newProjectID; if(p.projType == "Tender"){ if(p.property.calcProgramFile) calcProgramFileIDMap[p.property.calcProgramFile.ID] = uuidV1();//新的计算程序文件ID if(p.property.labourCoeFile) labourCoeFileIDMap[p.property.labourCoeFile.ID] = uuidV1();//新的人工调整系数文件ID if(p.property.feeFile) feeRateFileIDMap[p.property.feeFile.id] = uuidV1();//新的费率文件ID if(p.property.unitPriceFile) unitPriceFileIDMap[p.property.unitPriceFile.id] = await getCounterID("unit_price_file");//新的单价文件ID } } if(mainProjectID == -1) throw new Error("文件里面没包含建设项目信息!"); //处理项目信息 ----- 费率文件,单价文件ID信息要重新生成----to do for(let p of mainData.projects){ delete p._id; delete p.__v; p.ID = projectIDMap[p.ID]; if(p.ID == mainProjectID){//对于建设项目,要父和下一节点ID要使用前端传入的位置ID p.ParentID = updateData.self.ParentID; p.NextSiblingID = updateData.self.NextSiblingID; if(updateData.update){//树节构中的上一节点的下一节点设置为本建设项目ID; tasks.push({updateOne:{filter : updateData.update.query, update : {NextSiblingID:mainProjectID}}}); } //查看是否重名; let temp = await projectModel.findOne({userID:userID,ParentID:p.ParentID,name:p.name}); if(temp) p.name = p.name + '(' + moment(Date.now()).tz("Asia/Shanghai").format('MM-DD HH:mm:ss') + '导入)'; }else { p.ParentID = projectIDMap[p.ParentID]; p.NextSiblingID = projectIDMap[p.NextSiblingID]; } p.userID =userID; p.shareInfo=[]; if(p.projType == "Tender"){ if(p.property.calcProgramFile) p.property.calcProgramFile.ID = calcProgramFileIDMap[p.property.calcProgramFile.ID]; if(p.property.labourCoeFile) p.property.labourCoeFile.ID = labourCoeFileIDMap[p.property.labourCoeFile.ID]; if(p.property.feeFile) p.property.feeFile.id = feeRateFileIDMap[p.property.feeFile.id]; if(p.property.unitPriceFile) p.property.unitPriceFile.id = unitPriceFileIDMap[p.property.unitPriceFile.id]; p.property.rootProjectID = mainProjectID } tasks.push({insertOne: {document: p}}) } //项目树节构数据生成: await projectModel.bulkWrite(tasks); //生成所有的费率文件 await importFeeRateFiles(mainData,projectIDMap,feeRateFileIDMap,userID); //生成所有的单价文件 await importUnitPriceFiles(mainData,projectIDMap,unitPriceFileIDMap,userID); return [projectIDMap,labourCoeFileIDMap,calcProgramFileIDMap] } async function importUnitPriceFiles(mainData,projectIDMap,unitPriceFileIDMap,userID) { if(!mainData.files.unitFiles) return; let unitFiles = [],unitPrices =[],mixRatios=[],freights=[],originals=[]; for(let f of mainData.files.unitFiles){ let file = f.unitFile,prices = f.unitPrices,mixs = f.mixRatios,fres = f.freights,ors = f.originals; //生成单价文件 delete file._id; file.id = unitPriceFileIDMap[file.id]?unitPriceFileIDMap[file.id]:await getCounterID("unit_price_file"); file.project_id = projectIDMap[file.project_id]; file.root_project_id = projectIDMap[file.root_project_id]; file.user_id = userID; unitFiles.push(file); //生成子数据 if(prices) await setSubList(prices,unitPrices,file.id,unitPriceModel); if(mixs) await setSubList(mixs,mixRatios,file.id,mixRatioModel); } if(unitFiles.length > 0) await insertMany(unitFiles,unitPriceFileModel); if(unitPrices.length > 0) await insertMany(unitPrices,unitPriceModel); if(mixRatios.length > 0) await insertMany(mixRatios,mixRatioModel); async function setSubList(oList,nList,fileID,model,UUID=false) { for(let o of oList){ delete o._id; o.unit_price_file_id = fileID; UUID == true?o.ID = uuidV1():o.id = await getCounterID(model.modelName); nList.push(o) } } } async function importFeeRateFiles(mainData,projectIDMap,feeRateFileIDMap,userID) { let feeRateFiles = [], feeRates = []; if(!mainData.files.feeRateFiles) return; for(let f of mainData.files.feeRateFiles){ //生成费率记录 let rate = f.feeRate; delete rate._id; rate.ID = uuidV1(); feeRates.push(rate); //生成费率文件记录 let file = f.feeRateFile; delete file._id; file.ID = feeRateFileIDMap[file.ID]?feeRateFileIDMap[file.ID]:uuidV1(); file.userID = userID; file.rootProjectID = projectIDMap[file.rootProjectID]; file.feeRateID = rate.ID; feeRateFiles.push(file); } if(feeRateFiles.length > 0) await insertMany(feeRateFiles,feeRateFileModel); if(feeRates.length > 0) await insertMany(feeRates,feeRateModel); } // 初始化 async function initOverHeightItems(engineeringID) { const defaultData = []; const engineering = await engineeringModel.findById(engineeringID); const overHeightLibs = engineering.over_height_lib; if (!overHeightLibs || !overHeightLibs.length) { return defaultData; } const overHeightLibID = overHeightLibs[0].id; const overHeightLib = await overHeightLibModel.findOne({ID: overHeightLibID}); return overHeightLib ? overHeightLib.list : defaultData; } function uploadToken() { let options = { scope: qiniu_config.Bucket, deleteAfterDays: 1, returnBody: '{"key":"$(key)","hash":"$(etag)","fsize":$(fsize),"bucket":"$(bucket)","name":"$(x:name)"}' }; let putPolicy = new qiniu.rs.PutPolicy(options); let token = putPolicy.uploadToken(mac); let result = { uptoken: token, domain: qiniu_config.Domain } return result }