pm_facade.js 50 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146
  1. /**
  2. * Created by zhang on 2018/4/17.
  3. */
  4. const projectType = {
  5. folder: 'Folder',
  6. tender: 'Tender',
  7. project: 'Project',
  8. engineering: 'Engineering',
  9. };
  10. //先导出后require可以解决循环引用问题
  11. module.exports={
  12. moveProject:moveProject,
  13. copyProject:copyProject,
  14. copyExample: copyExample,
  15. getSummaryInfo: getSummaryInfo,
  16. getSummaryInfoByTender: getSummaryInfoByTender,
  17. getTendersFeeInfo: getTendersFeeInfo,
  18. getConstructionProject: getConstructionProject,
  19. getFullPath: getFullPath,
  20. projectType: projectType,
  21. getPosterityProjects: getPosterityProjects,
  22. isShare: isShare,
  23. isFirst: isFirst,
  24. getShareInfo: getShareInfo,
  25. prepareInitialData: prepareInitialData,
  26. changeFile:changeFile,
  27. getBasicInfo: getBasicInfo,
  28. getProjectFeature: getProjectFeature,
  29. getProjectByGranularity: getProjectByGranularity
  30. };
  31. let mongoose = require('mongoose');
  32. let _ = require("lodash");
  33. let feeRate_facade = require('../../fee_rates/facade/fee_rates_facade');
  34. let glj_facade = require('../../glj/facade/glj_facade');
  35. let project_facade = require('../../main/facade/project_facade');
  36. let logger = require("../../../logs/log_helper").logger;
  37. const uuidV1 = require('uuid/v1');
  38. let projectModel = mongoose.model('projects');
  39. let projectSettingModel = mongoose.model('proj_setting');
  40. let billsModel = mongoose.model('bills');
  41. let rationModel = mongoose.model('ration');
  42. let gljListModel = mongoose.model("glj_list");
  43. let calcProgramsModel = mongoose.model('calc_programs');
  44. let labourCoesModel = mongoose.model('labour_coes');
  45. let feeRateModel = mongoose.model('fee_rates');
  46. let feeRateFileModel = mongoose.model('fee_rate_file');
  47. let unitPriceFileModel = mongoose.model("unit_price_file");
  48. let mixRatioModel = mongoose.model("mix_ratio");
  49. let unitPriceModel = mongoose.model("unit_price");
  50. let installationFeeModel = mongoose.model("installation_fee");
  51. let rationGLJModel = mongoose.model('ration_glj');
  52. let rationCoeModel = mongoose.model('ration_coe');
  53. let rationInstallationModel = mongoose.model('ration_installation');
  54. let quantityDetailModel = mongoose.model('quantity_detail');
  55. let rationTemplateModel = mongoose.model('ration_template');
  56. let userModel = mongoose.model('user');
  57. let compleGljSectionModel = mongoose.model('complementary_glj_section');
  58. let compleGljSectionTModel = mongoose.model('complementary_glj_section_templates');
  59. let compilationModel = mongoose.model('compilation');
  60. let engineeringModel = mongoose.model('engineering_lib');
  61. let basicInfoModel = mongoose.model('std_basic_info_lib');
  62. let projectFeatureModel = mongoose.model('std_project_feature_lib');
  63. let productModel = mongoose.model('product');
  64. let featureLibModel = mongoose.model("std_project_feature_lib");
  65. let scMathUtil = require('../../../public/scMathUtil').getUtil();
  66. let counter = require('../../../public/counter/counter');
  67. import SectionTreeDao from '../../complementary_ration_lib/models/sectionTreeModel';
  68. let sectionTreeDao = new SectionTreeDao();
  69. import CounterModel from "../../glj/models/counter_model";
  70. import moment from 'moment';
  71. import billsFlags from '../../common/const/bills_fixed';
  72. const notDeleted = [{deleteInfo: null}, {'deleteInfo.deleted': false}];
  73. //拷贝例题项目
  74. //@param {String}userID {Array}projIDs拷贝的例题项目ID(建设项目、文件夹)@return {Boolean}
  75. async function copyExample(userID, compilation, projIDs){
  76. let allProjs = [],
  77. IDMapping = {},
  78. projMapping = {};
  79. //例题项目不可为单项工程、单位工程、只能是建设项目、文件夹,否则不自动新建例题项目(这里不报错,让用户没有感觉)
  80. let parentExample = await projectModel.find({ID: {$in: projIDs}, $or: notDeleted});
  81. if (parentExample.length === 0) {
  82. return false;
  83. }
  84. allProjs = allProjs.concat(parentExample);
  85. for (let i = 0; i < parentExample.length; i++) {
  86. let data = parentExample[i];
  87. if (data.projType === projectType.tender || data.projType === projectType.engineering) {
  88. return false;
  89. }
  90. //设置成顶节点,最后一个节点设置成末节
  91. data.ParentID = -1;
  92. if (i === parentExample.length - 1) {
  93. data.NextSiblingID = -1;
  94. }
  95. }
  96. //获取所有的子项目
  97. let posterityProjs = await getPosterityProjects(projIDs);
  98. allProjs = allProjs.concat(posterityProjs);
  99. let projCounter = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.project, allProjs.length);
  100. //旧ID与新ID映射
  101. for (let i = 0; i < allProjs.length; i++) {
  102. let data = allProjs[i];
  103. let newID = projCounter.sequence_value - (allProjs.length - 1) + i;
  104. IDMapping[data.ID] = newID;
  105. projMapping[newID] = data;
  106. }
  107. //return;
  108. //设置新的树结构数据
  109. let newDate = new Date(),
  110. parentBulks = [];
  111. for (let data of allProjs) {
  112. let orgID = data.ID;
  113. data.ID = IDMapping[data.ID];
  114. data.ParentID = IDMapping[data.ParentID] ? IDMapping[data.ParentID] : -1;
  115. data.NextSiblingID = IDMapping[data.NextSiblingID] ? IDMapping[data.NextSiblingID] : -1;
  116. data.createDateTime = newDate;
  117. data.userID = userID;
  118. data.compilation = compilation;
  119. data.shareInfo = [];
  120. if (data.projType !== projectType.tender) {
  121. let newData = _.cloneDeep(data._doc);
  122. delete newData._id;
  123. // await projectModel.create(newData);
  124. parentBulks.push({insertOne: {document: newData}});
  125. } else {
  126. //拷贝单位工程
  127. let rootProjectID = projMapping[data.ParentID].ParentID;
  128. let projectMap = {
  129. copy: {
  130. document: {userID: userID, ID: orgID, NextSiblingID: data.NextSiblingID, ParentID: data.ParentID, name: data.name, shareInfo: [],
  131. compilation: compilation, fileVer: data.fileVer, projType: data.projType, property: {rootProjectID: rootProjectID}}
  132. }
  133. };
  134. await copyProject(userID, compilation, {projectMap}, data.ID);
  135. }
  136. }
  137. //最末顶层项目(兼容测试时已存在有项目,正常用户第一次进费用定额,该费用定额不存在项目)
  138. let lastProj = await projectModel.findOne({userID: userID, compilation: compilation, ParentID: -1, NextSiblingID: -1, $or: notDeleted});
  139. if (lastProj) {
  140. parentBulks.push({updateOne: {filter: {ID: lastProj.ID}, update: {$set: {NextSiblingID: parentExample[0].ID}}}});
  141. }
  142. //拷贝父级文件
  143. await projectModel.bulkWrite(parentBulks);
  144. return true;
  145. }
  146. async function copyProject(userID, compilationID,data,newProjectID = null) {
  147. let projectMap = data.projectMap;
  148. let originalID = projectMap['copy'].document.ID;
  149. if (!newProjectID) {
  150. newProjectID = await getCounterID("projects");
  151. }
  152. let newFeeName = null,newUnitName = null;
  153. let calcProgramFileID = uuidV1();//新的计算程序文件ID
  154. let labourCoeFileID = uuidV1();//新的人工调整系数文件ID
  155. let feeRateFileID = uuidV1();//新的费率文件ID
  156. let unitPriceFileID = await getCounterID("unit_price_file");//新的单价文件ID
  157. let originalProject = await projectModel.findOne({'ID':originalID});//查找最新的那项目信息,前端缓存的数据有可能不是最新的
  158. if(!originalProject){
  159. throw new Error('没有找到对应的项目,复制失败!');
  160. }
  161. let property = originalProject.property;
  162. if(projectMap['copy'].document.property){//更新项目属性信息
  163. setProperty(property,projectMap['copy'].document.property);
  164. }
  165. let originalProperty = _.cloneDeep(property);
  166. projectMap['copy'].document.property = property;
  167. logger.info("复制项目: 旧项目ID: "+originalID+ " ------- 新项目ID: "+newProjectID);
  168. //费率文件、单价文件重名检查
  169. let feeRate = await feeRateFileModel.findOne({rootProjectID:originalProperty.rootProjectID,name:originalProperty.feeFile.name,deleteInfo:null});
  170. if(feeRate){//存在重名的文件
  171. newFeeName = originalProperty.feeFile.name + '(' + moment(Date.now()).format('MM-DD HH:mm:ss') + '复制)';
  172. projectMap['copy'].document.property.feeFile.name = newFeeName;
  173. }
  174. let unitPriceFile = await unitPriceFileModel.findOne({root_project_id: originalProperty.rootProjectID,name:originalProperty.unitPriceFile.name,deleteInfo: null});
  175. if(unitPriceFile){//存在重名的文件
  176. newUnitName = originalProperty.unitPriceFile.name + '(' + moment(Date.now()).format('MM-DD HH:mm:ss') + '复制)';
  177. projectMap['copy'].document.property.unitPriceFile.name = newUnitName;
  178. }
  179. //更新项目的属性;
  180. projectMap['copy'].document.ID = newProjectID;
  181. if(projectMap['copy'].document.property.calcProgramFile){
  182. projectMap['copy'].document.property.calcProgramFile.ID = calcProgramFileID;
  183. }
  184. if(projectMap['copy'].document.property.labourCoeFile){
  185. projectMap['copy'].document.property.labourCoeFile.ID = labourCoeFileID;
  186. }
  187. if(projectMap['copy'].document.property.feeFile){
  188. projectMap['copy'].document.property.feeFile.id = feeRateFileID;
  189. }
  190. if(projectMap['copy'].document.property.unitPriceFile){
  191. projectMap['copy'].document.property.unitPriceFile.id = unitPriceFileID;
  192. }
  193. projectMap['copy'].document.userID = userID;
  194. projectMap['copy'].document.compilation = compilationID;
  195. projectMap['copy'].document.createDateTime = new Date();
  196. //清单、定额ID生成任务
  197. let IDtasks = [
  198. createIDsAndReturn(originalID,billsModel),
  199. createIDsAndReturn(originalID,rationModel),
  200. getProjectGLJIDAndReturn(originalID,newProjectID)
  201. ];
  202. let [billMap,rationMap,projectGLJMap] = await Promise.all(IDtasks);
  203. //所有复制任务异步处理,提升效率 复制清单,定额,4个文件,项目工料机, 定额工料机,人工系数,工程量明细,定额安装增加费,安装增加费
  204. let copyTasks = [
  205. createProject(projectMap),
  206. copyProjectSetting(originalID,newProjectID),
  207. copyBills(newProjectID,billMap),
  208. copyRations(newProjectID,billMap.uuidMaping,rationMap,projectGLJMap.IDMap),
  209. copyProjectGLJ(projectGLJMap.datas),
  210. copyInstallFee(originalID,newProjectID),
  211. copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationGLJModel),
  212. copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationCoeModel),
  213. copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,quantityDetailModel),
  214. copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationInstallationModel),
  215. copyRationSubList(originalID,newProjectID,billMap.uuidMaping,rationMap.uuidMaping,projectGLJMap.IDMap,rationTemplateModel)
  216. ];
  217. if(originalProperty.calcProgramFile){
  218. copyTasks.push(commonCopy(newProjectID,originalProperty.calcProgramFile.ID,calcProgramFileID,calcProgramsModel));
  219. }
  220. if(originalProperty.labourCoeFile){
  221. copyTasks.push(commonCopy(newProjectID,originalProperty.labourCoeFile.ID,labourCoeFileID,labourCoesModel));
  222. }
  223. if(originalProperty.feeFile){
  224. copyTasks.push(copyFeeRate(originalProperty.rootProjectID,userID,originalProperty.feeFile.id,feeRateFileID,newFeeName));
  225. }
  226. if(originalProperty.unitPriceFile){
  227. copyTasks.push(copyUnitPriceFile(newProjectID,originalProperty.rootProjectID,userID,originalProperty.unitPriceFile.id,unitPriceFileID,newUnitName));
  228. }
  229. let p = await Promise.all(copyTasks);
  230. return p[0];
  231. }
  232. async function createIDsAndReturn(originalID,model) {
  233. let uuidMaping = {};//做ID映射
  234. let datas = [];
  235. let result = await model.find({"projectID": originalID}, '-_id');
  236. uuidMaping['-1'] = -1;
  237. //建立uuid-ID映射
  238. for(let d of result){
  239. uuidMaping[d.ID] = uuidV1();
  240. datas.push(d._doc);
  241. }
  242. return{uuidMaping:uuidMaping,datas:datas};
  243. }
  244. async function getProjectGLJIDAndReturn(originalID,newProjectID) {
  245. let IDMap = {};
  246. let datas = [];
  247. let result = await gljListModel.find({project_id:originalID}, '-_id');
  248. let gljCount = await counter.counterDAO.getIDAfterCountSync(counter.moduleName.glj_list, result.length);
  249. for(let i = 0; i < result.length; i++){
  250. let d = result[i];
  251. let newID = gljCount.sequence_value - (result.length - 1) + i;
  252. //let newID = await getCounterID("glj_list");
  253. IDMap[d.id] = newID;
  254. d._doc.project_id = newProjectID;
  255. d._doc.id = newID;
  256. datas.push(d._doc);
  257. }
  258. return{IDMap:IDMap,datas:datas};
  259. }
  260. async function createProject(projectMap) {//复制项目
  261. let tasks = [];
  262. if(projectMap['update']){//如果复制后存在前一个节点,则更新其NextSiblingID
  263. tasks.push({updateOne:{filter : projectMap['update'].query, update : {NextSiblingID:projectMap['copy'].document.ID}}});
  264. }
  265. tasks.push({insertOne: {document: projectMap['copy'].document}});//复制任务
  266. await projectModel.bulkWrite(tasks);
  267. return projectMap;
  268. }
  269. async function copyProjectSetting(originalID,newProjectID) {
  270. let result = null;
  271. let setting = await projectSettingModel.findOne({"projectID": originalID}, '-_id');
  272. if(setting){
  273. setting._doc.projectID =newProjectID;
  274. result = await projectSettingModel.create(setting._doc);
  275. }
  276. return result;
  277. }
  278. async function copyBills(newProjectID,billMap) {
  279. let uuidMaping = billMap.uuidMaping;//做ID映射
  280. for(let doc of billMap.datas){
  281. doc.projectID = newProjectID;
  282. doc.ID = uuidMaping[doc.ID] ? uuidMaping[doc.ID] : -1;
  283. doc.ParentID = uuidMaping[doc.ParentID] ? uuidMaping[doc.ParentID] : -1;
  284. doc.NextSiblingID = uuidMaping[doc.NextSiblingID] ? uuidMaping[doc.NextSiblingID] : -1;
  285. }
  286. await insertMany(billMap.datas,billsModel);
  287. return billMap.datas;
  288. }
  289. async function copyRations(newProjectID,billsIDMap,rationMap,projectGLJIDMap) {
  290. let uuidMaping = rationMap.uuidMaping;
  291. for(let doc of rationMap.datas){
  292. doc.projectID = newProjectID;
  293. doc.ID = uuidMaping[doc.ID] ? uuidMaping[doc.ID] : -1;
  294. if(doc.billsItemID){
  295. doc.billsItemID = billsIDMap[doc.billsItemID]?billsIDMap[doc.billsItemID]:-1;
  296. }
  297. if(doc.referenceRationID) doc.referenceRationID = uuidMaping[doc.referenceRationID]?uuidMaping[doc.referenceRationID]:undefined;
  298. //绑定定类型的工料机 项目工料机ID
  299. doc.type==3&&doc.projectGLJID&&projectGLJIDMap[doc.projectGLJID]?doc.projectGLJID = projectGLJIDMap[doc.projectGLJID]:'';
  300. }
  301. if(rationMap.datas.length > 0){
  302. await insertMany(rationMap.datas,rationModel);
  303. }
  304. return rationMap.datas;
  305. }
  306. async function copyProjectGLJ(gljList) {
  307. await insertMany(gljList,gljListModel);
  308. }
  309. async function commonCopy(newProjectID,oldID,newID,model) { //对于只需更新ID和projectID的文件的复制
  310. let result = null;
  311. let file = await model.findOne({"ID": oldID}, '-_id');
  312. if(file){
  313. file._doc.ID = newID;
  314. file._doc.projectID =newProjectID;
  315. result = await model.create(file._doc);
  316. }
  317. return result;
  318. }
  319. async function copyFeeRate(rootProjectID,userID,originalFeeRateFileID,feeRateFileID,newName) {//复制费率和费率文件
  320. let [feeRateFile,feeRate] =await feeRate_facade.getFeeRateByID(originalFeeRateFileID);
  321. let newFeeRateID = uuidV1();
  322. if(feeRate){
  323. feeRate._doc.ID = newFeeRateID;
  324. await feeRateModel.create(feeRate._doc);
  325. }
  326. if(feeRateFile){
  327. feeRateFile._doc.ID = feeRateFileID;
  328. newName?feeRateFile._doc.name = newName:'';
  329. feeRateFile._doc.userID = userID;
  330. feeRateFile._doc.rootProjectID = rootProjectID;
  331. feeRateFile._doc.feeRateID = newFeeRateID;
  332. await feeRateFileModel.create(feeRateFile._doc);
  333. }
  334. }
  335. async function copyUnitPriceFile(newProjectID,rootProjectID,userID,originaluUnitPriceFileID,unitPriceFileID,newName) {//复制单价文件、组成物
  336. let taskList = [
  337. copyFile(newProjectID,rootProjectID,userID,originaluUnitPriceFileID,unitPriceFileID,newName),
  338. copySubList(originaluUnitPriceFileID,unitPriceFileID,mixRatioModel),
  339. copySubList(originaluUnitPriceFileID,unitPriceFileID,unitPriceModel)
  340. ];
  341. return await Promise.all(taskList);
  342. async function copyFile(newProjectID,rootProjectID,userID,originaluUnitPriceFileID,unitPriceFileID,newName){
  343. let unitPriceFile = await unitPriceFileModel.findOne({id:originaluUnitPriceFileID}, '-_id');
  344. if(unitPriceFile){
  345. unitPriceFile._doc.id = unitPriceFileID;
  346. newName?unitPriceFile._doc.name = newName:'';
  347. unitPriceFile._doc.project_id = newProjectID;
  348. unitPriceFile._doc.user_id = userID;
  349. unitPriceFile._doc.root_project_id = rootProjectID
  350. }
  351. await unitPriceFileModel.create(unitPriceFile._doc);
  352. }
  353. async function copySubList(srcFID,newFID,model) {
  354. let mList = await model.find({unit_price_file_id: srcFID}, '-_id');
  355. let rList = [];
  356. for(let m of mList){
  357. m._doc.unit_price_file_id = newFID;
  358. m._doc.id = await getCounterID(model.modelName);
  359. rList.push(m._doc);
  360. }
  361. await insertMany(rList,model)
  362. }
  363. }
  364. async function copyInstallFee(originalPID,newProjectID) {
  365. let result = null;
  366. let installationFee = await installationFeeModel.find({projectID:originalPID}, '-_id');
  367. let newList = [];
  368. for(let i of installationFee ){
  369. i._doc.ID = uuidV1();
  370. i._doc.projectID = newProjectID;
  371. newList.push(i._doc);
  372. }
  373. if(newList.length >0){
  374. result = await installationFeeModel.insertMany(newList);
  375. }
  376. return result;
  377. }
  378. async function copyRationSubList(originalPID,newProjectID,billIDMap,rationIDMap,projectGLJIDMap,model) {// 定额工料机,附注条件,工程量明细,定额安装增加费,模板子目
  379. let subList = await model.find({projectID:originalPID}, '-_id');
  380. let newList =[];
  381. for(let s of subList){
  382. s._doc.ID = uuidV1();
  383. s._doc.projectID = newProjectID;
  384. s._doc.rationID&&rationIDMap[s._doc.rationID]?s._doc.rationID = rationIDMap[s._doc.rationID]:'';
  385. s._doc.billID&&billIDMap[s._doc.billID]?s._doc.billID = billIDMap[s._doc.billID]:'';
  386. s._doc.billsItemID&&billIDMap[s._doc.billsItemID]?s._doc.billsItemID = billIDMap[s._doc.billsItemID]:'';
  387. s._doc.projectGLJID&&projectGLJIDMap[s._doc.projectGLJID]?s._doc.projectGLJID = projectGLJIDMap[s._doc.projectGLJID]:'';
  388. if(s._doc.templateList && s._doc.templateList.length > 0 ){
  389. for(let t of s._doc.templateList){
  390. if(t.billID && billIDMap[t.billID]) t.billID = billIDMap[t.billID];
  391. if(t.fxID && billIDMap[t.fxID]) t.fxID = billIDMap[t.fxID];
  392. }
  393. }
  394. newList.push(s._doc);
  395. }
  396. await insertMany(newList,model);
  397. }
  398. async function moveProject(data) {
  399. data = JSON.parse(data);
  400. let projectMap = data.projectMap,feeRateMap = data.feeRateMap,unitPriceMap = data.unitPriceMap;
  401. let projectTasks = [],feeRateTask=[],feeRateFileTask=[],unitPriceTask=[],unitPriceFileTask=[],mixRatioTask=[];
  402. let feeUniqMap=[],priceUniqMap={};//费率、单价文件唯一映射表当移动多个项目时,任务有可能出现重复的情况
  403. if(!_.isEmpty(feeRateMap)&&data.rootProjectID){//如果费率有修改
  404. let feeRates =await feeRate_facade.getFeeRatesByProject(data.rootProjectID);//取目标建设项目的所有费率文件,重名检查
  405. for(let projectID in feeRateMap){
  406. let rename = feeRateMap[projectID].name;
  407. let feeRateID = feeRateMap[projectID].query.ID;
  408. let checkFee = _.find(feeRates,{'name':rename});
  409. let newID = feeRateID;
  410. if(checkFee){//说明费率名字已存在,需要重命名
  411. rename = feeUniqMap[feeRateID]?feeUniqMap[feeRateID].name:rename + '(' + new Date().Format('MM-dd hh:mm:ss') + '移动)';
  412. projectMap[projectID]['update']['property.feeFile.name'] = rename;
  413. if(feeRateMap[projectID].action == 'move'){
  414. feeRateMap[projectID].update.name = rename;
  415. }
  416. }
  417. if(feeRateMap[projectID].action == 'copy'){
  418. newID = feeUniqMap[feeRateID]?feeUniqMap[feeRateID].ID:uuidV1();
  419. feeRateMap[projectID].name = rename;
  420. feeRateMap[projectID].ID = newID;
  421. projectMap[projectID]['update']['property.feeFile.id'] = newID;
  422. }
  423. if(!feeUniqMap[feeRateID]){
  424. await generateFeeRateTask(feeRateMap[projectID],feeRateTask,feeRateFileTask);
  425. feeUniqMap[feeRateID] = {name:rename,ID:newID};
  426. }
  427. }
  428. }
  429. if(!_.isEmpty(unitPriceMap)&&data.rootProjectID) {//如果单价文件有修改
  430. let unitPriceFiles = await unitPriceFileModel.find({root_project_id: data.rootProjectID, deleteInfo: null});
  431. for(let projectID in unitPriceMap){
  432. let checkUn = _.find(unitPriceFiles,{'name':unitPriceMap[projectID].name});
  433. let rename = unitPriceMap[projectID].name;
  434. let unitPriceID = unitPriceMap[projectID].query.id;
  435. let newID = unitPriceID;
  436. if(checkUn){//重名检查
  437. rename = priceUniqMap[unitPriceID]?priceUniqMap[unitPriceID].name:rename + '(' + new Date().Format('MM-dd hh:mm:ss') + '移动)';
  438. projectMap[projectID]['update']['property.unitPriceFile.name'] = rename;
  439. if(unitPriceMap[projectID].action =='move'){
  440. unitPriceMap[projectID].update.name = rename;
  441. }
  442. }
  443. if(unitPriceMap[projectID].action =='copy'){
  444. newID = priceUniqMap[unitPriceID]?priceUniqMap[unitPriceID].id: await getCounterID("unit_price_file");
  445. unitPriceMap[projectID].name = rename;
  446. unitPriceMap[projectID].id = newID;
  447. projectMap[projectID]['update']['property.unitPriceFile.id'] = newID;
  448. }
  449. if(!priceUniqMap[unitPriceID]){
  450. await generateUnitPriceTask(unitPriceMap[projectID],projectID,data.user_id,unitPriceTask,unitPriceFileTask,mixRatioTask);
  451. priceUniqMap[unitPriceID] = {name:rename,id:newID};
  452. }
  453. }
  454. }
  455. if(!_.isEmpty(projectMap)){
  456. for(let projectID in projectMap){
  457. projectTasks.push({updateOne:{filter : projectMap[projectID].query, update : projectMap[projectID].update}});
  458. }
  459. }
  460. projectTasks.length>0?await projectModel.bulkWrite(projectTasks):'';
  461. feeRateTask.length>0?await feeRateModel.bulkWrite(feeRateTask):'';
  462. feeRateFileTask.length>0?await feeRateFileModel.bulkWrite(feeRateFileTask):'';
  463. unitPriceFileTask.length>0?await unitPriceFileModel.bulkWrite(unitPriceFileTask):'';
  464. unitPriceTask.length>0?await insertMany(unitPriceTask,unitPriceModel):'';
  465. mixRatioTask.length>0?await insertMany(mixRatioTask,mixRatioModel):'';
  466. return projectMap;
  467. }
  468. async function generateFeeRateTask(data,feeRateTask,feeRateFileTask) {
  469. if(data.action == 'move'){
  470. let task = {
  471. updateOne:{
  472. filter : data.query,
  473. update : data.update
  474. }
  475. };
  476. feeRateFileTask.push(task);
  477. }
  478. if(data.action == 'copy'){//copy 费率的时候用insertOne方法
  479. let [feeRateFile,feeRate] =await feeRate_facade.getFeeRateByID(data.query.ID);
  480. let newFeeRateID = uuidV1();
  481. let newFeeRate = {
  482. ID:newFeeRateID,
  483. rates:feeRate.rates
  484. };
  485. let newFeeRateFile = {
  486. ID:data.ID,
  487. rootProjectID:data.rootProjectID,
  488. userID:feeRateFile.userID,
  489. name:data.name,
  490. libID:feeRateFile.libID,
  491. libName:feeRateFile.libName,
  492. feeRateID:newFeeRateID
  493. };
  494. feeRateTask.push({insertOne :{document:newFeeRate}});
  495. feeRateFileTask.push({insertOne :{document:newFeeRateFile}});
  496. }
  497. }
  498. async function generateUnitPriceTask(data,projectID,user_id,unitPriceTask,unitPriceFileTask,mixRatioTask){
  499. if(data.action == 'move'){
  500. let task = {
  501. updateOne:{
  502. filter : data.query,
  503. update : data.update
  504. }
  505. };
  506. unitPriceFileTask.push(task);
  507. }
  508. if(data.action == 'copy'){
  509. let newUnitFile = {
  510. id:data.id,
  511. name: data.name,
  512. project_id:projectID,
  513. user_id:user_id,
  514. root_project_id: data.rootProjectID
  515. };
  516. unitPriceFileTask.push({insertOne :{document:newUnitFile}});
  517. let mixRatios = await mixRatioModel.find({unit_price_file_id: data.query.id});
  518. mixRatios = JSON.stringify(mixRatios);
  519. mixRatios = JSON.parse(mixRatios);
  520. for(let m of mixRatios){
  521. delete m._id; // 删除原有id信息
  522. delete m.id;
  523. m.unit_price_file_id = data.id;
  524. m.id = await getCounterID('mix_ratio');
  525. mixRatioTask.push(m);
  526. }
  527. let unitPrices = await unitPriceModel.find({unit_price_file_id: data.query.id});//unit_price_file_id
  528. unitPrices = JSON.stringify(unitPrices);
  529. unitPrices = JSON.parse(unitPrices);
  530. for(let u of unitPrices){
  531. delete u._id; // 删除原有id信息
  532. delete u.id;
  533. u.unit_price_file_id = data.id;
  534. u.id = await getCounterID('unit_price');
  535. unitPriceTask.push(u);
  536. }
  537. }
  538. }
  539. async function getCounterID(collectionName){
  540. let counterModel = new CounterModel();
  541. return await counterModel.getId(collectionName);
  542. }
  543. async function insertMany(datas,model) {
  544. while (datas.length>1000){//因为mongoose限制了批量插入的条数为1000.所以超出限制后需要分批插入
  545. let newList = datas.splice(0,1000);//一次插入1000条
  546. await model.insertMany(newList);
  547. }
  548. await model.insertMany(datas);
  549. }
  550. function setProperty(Obj,updateData) {
  551. for(let ukey in updateData){
  552. if(_.isObject(updateData[ukey]) && _.isObject(Obj[ukey])){
  553. setProperty(Obj[ukey],updateData[ukey]);
  554. }else {
  555. Obj[ukey] = updateData[ukey];
  556. }
  557. }
  558. }
  559. function isDef(v){
  560. return typeof v !== 'undefined' && v !== null;
  561. }
  562. function getTotalFee(bills, feeName) {
  563. if(!isDef(bills)){
  564. return 0;
  565. }
  566. if(!isDef(bills.fees) || bills.fees.length <= 0){
  567. return 0;
  568. }
  569. for(let fee of bills.fees){
  570. if(isDef(fee.fieldName) && fee.fieldName === feeName){
  571. return isDef(fee.totalFee) ? fee.totalFee : 0;
  572. }
  573. }
  574. return 0;
  575. }
  576. function summarizeToParent(parent, child, fields = null) {
  577. const decimal = -2;
  578. if (!fields) {
  579. fields = ['engineeringCost', 'subEngineering', 'measure', 'safetyConstruction', 'other', 'charge', 'tax', 'estimate'];
  580. }
  581. for (let field of fields) {
  582. parent[field] = scMathUtil.roundTo(parseFloat(parent[field]) + parseFloat(child[field]), decimal);
  583. }
  584. /* const decimal = -2;
  585. parent.engineeringCost = scMathUtil.roundTo(parseFloat(parent.engineeringCost) + parseFloat(child.engineeringCost), decimal);
  586. parent.subEngineering = scMathUtil.roundTo(parseFloat(parent.subEngineering) + parseFloat(child.subEngineering), decimal);
  587. parent.measure = scMathUtil.roundTo(parseFloat(parent.measure) + parseFloat(child.measure), decimal);
  588. parent.safetyConstruction = scMathUtil.roundTo(parseFloat(parent.safetyConstruction) + parseFloat(child.safetyConstruction), decimal);
  589. parent.other = scMathUtil.roundTo(parseFloat(parent.other) + parseFloat(child.other), decimal);
  590. parent.charge = scMathUtil.roundTo(parseFloat(parent.charge) + parseFloat(child.charge), decimal);
  591. parent.tax = scMathUtil.roundTo(parseFloat(parent.tax) + parseFloat(child.tax), decimal);*/
  592. }
  593. function getBuildingArea(projFeature){
  594. if(!projFeature || projFeature.length === 0){
  595. return null;
  596. }
  597. for(let f of projFeature){
  598. if(f.key === 'buildingArea'){
  599. return f.value;
  600. }
  601. }
  602. return null;
  603. }
  604. //根据单位工程ID获取汇总信息
  605. //@param {Number}tenderID {String}summaryType @return {Object}
  606. async function getSummaryInfoByTender(tenderID, summaryType) {
  607. const notDeleted = [{deleteInfo: null}, {'deleteInfo.deleted': false}];
  608. let tender = await projectModel.findOne({ID: tenderID, $or: notDeleted});
  609. let parentName;
  610. let summaryList = [];
  611. if(!tender){
  612. return null;
  613. }
  614. let engineering = await projectModel.findOne({ID: tender.ParentID, $or: notDeleted});
  615. if(!engineering){
  616. return null;
  617. }
  618. let project = await projectModel.findOne({ID: engineering.ParentID, $or: notDeleted});
  619. if(!project){
  620. return null;
  621. }
  622. let summaryInfo = await getSummaryInfo([project.ID]);
  623. if(summaryType === projectType.engineering){
  624. parentName = engineering.name ? engineering.name : '';
  625. let tenders = await projectModel.find({ParentID: engineering.ID, $or: notDeleted});
  626. for(let t of tenders){
  627. if(summaryInfo[t.ID]){
  628. summaryInfo[t.ID]['name'] = t.name ? t.name : '';
  629. summaryList.push(summaryInfo[t.ID]);
  630. }
  631. }
  632. }
  633. else {
  634. parentName = project.name ? project.name : '';
  635. let engs = await projectModel.find({ParentID: project.ID, $or: notDeleted});
  636. for(let e of engs){
  637. if(summaryInfo[e.ID]){
  638. summaryInfo[e.ID]['name'] = e.name ? e.name : '';
  639. summaryList.push(summaryInfo[e.ID]);
  640. }
  641. }
  642. }
  643. return {parent: {name: parentName}, subList: summaryList};
  644. }
  645. //获取单位工程的各标段费用信息(不进行汇总)
  646. async function getTendersFeeInfo(tenders) {
  647. let IDMapping = {};
  648. //固定清单类别与汇总金额字段映射
  649. let flagFieldMapping = {};
  650. flagFieldMapping[billsFlags.ENGINEERINGCOST] = 'engineeringCost';
  651. flagFieldMapping[billsFlags.SUB_ENGINERRING] = 'subEngineering';
  652. flagFieldMapping[billsFlags.MEASURE] = 'measure';
  653. flagFieldMapping[billsFlags.SAFETY_CONSTRUCTION] = 'safetyConstruction';
  654. flagFieldMapping[billsFlags.OTHER] = 'other';
  655. flagFieldMapping[billsFlags.CHARGE] = 'charge';
  656. flagFieldMapping[billsFlags.TAX] = 'tax';
  657. let tenderIDs = [];
  658. if(tenders.length > 0){
  659. for(let tender of tenders){
  660. tenderIDs.push(tender.ID);
  661. IDMapping[tender.ID] = {engineeringCost: 0, subEngineering: 0, measure: 0, safetyConstruction: 0, other: 0, charge: 0, tax: 0, estimate: 0, rate: 0, buildingArea: '', perCost: ''};
  662. IDMapping[tender.ID]['buildingArea'] = '';
  663. }
  664. //需要获取的清单固定类别综合合价:工程造价、分部分项、措施项目、安全文明施工专项、规费、其他项目、税金
  665. let needFlags = [billsFlags.ENGINEERINGCOST, billsFlags.SUB_ENGINERRING, billsFlags.MEASURE,
  666. billsFlags.SAFETY_CONSTRUCTION, billsFlags.CHARGE, billsFlags.OTHER, billsFlags.TAX];
  667. //获取单位工程汇总金额需要用到的所有清单
  668. let allBills = await billsModel.find({projectID: {$in: tenderIDs}, 'flags.flag': {$in: needFlags}, $or: notDeleted},
  669. '-_id projectID fees flags');
  670. //进行单位工程级别的汇总
  671. for(let bills of allBills){
  672. let billsFlag = bills.flags[0]['flag'];
  673. let costField = flagFieldMapping[billsFlag];
  674. IDMapping[bills.projectID][costField] = getTotalFee(bills, 'common');
  675. //暂估合价(工程造价暂估合价)
  676. if (billsFlag === billsFlags.ENGINEERINGCOST){
  677. IDMapping[bills.projectID]['estimate'] = getTotalFee(bills, 'estimate');
  678. }
  679. }
  680. //占造价比例、单方造价
  681. for(let tender of tenders){
  682. let tenderInfo = IDMapping[tender.ID];
  683. tenderInfo.rate = '';
  684. //单方造价
  685. tenderInfo.perCost = '';
  686. }
  687. }
  688. return IDMapping;
  689. }
  690. async function getSummaryInfo(projectIDs, feeFields = null){
  691. function initFees(obj, feeFields) {
  692. for (let data of feeFields) {
  693. obj[data.v] = 0;
  694. }
  695. }
  696. if (!feeFields) {
  697. feeFields = [
  698. {k: billsFlags.ENGINEERINGCOST, v: 'engineeringCost'},
  699. {k: billsFlags.SUB_ENGINERRING, v: 'subEngineering'},
  700. {k: billsFlags.MEASURE, v: 'measure'},
  701. {k: billsFlags.SAFETY_CONSTRUCTION, v: 'safetyConstruction'},
  702. {k: billsFlags.OTHER, v: 'other'},
  703. {k: billsFlags.CHARGE, v: 'charge'},
  704. {k: billsFlags.TAX, v: 'tax'}
  705. ];
  706. }
  707. //ID与汇总信息映射
  708. let IDMapping = {};
  709. //固定清单类别与汇总金额字段映射
  710. let flagFieldMapping = {};
  711. for (let data of feeFields) {
  712. flagFieldMapping[data.k] = data.v;
  713. }
  714. /*flagFieldMapping[billsFlags.ENGINEERINGCOST] = 'engineeringCost';
  715. flagFieldMapping[billsFlags.SUB_ENGINERRING] = 'subEngineering';
  716. flagFieldMapping[billsFlags.MEASURE] = 'measure';
  717. flagFieldMapping[billsFlags.SAFETY_CONSTRUCTION] = 'safetyConstruction';
  718. flagFieldMapping[billsFlags.OTHER] = 'other';
  719. flagFieldMapping[billsFlags.CHARGE] = 'charge';
  720. flagFieldMapping[billsFlags.TAX] = 'tax';*/
  721. let projects = await projectModel.find({ID: {$in : projectIDs}, projType: projectType.project, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]});
  722. //设置建设项目的总建筑面积
  723. for(let project of projects){
  724. let grossArea = '';
  725. if(project.property && project.property.basicInformation){
  726. for(let basicInfo of project.property.basicInformation){
  727. if(basicInfo.key === 'basicInfo'){
  728. for(let k of basicInfo.items){
  729. if(k.key === 'grossArea'){
  730. grossArea = k.value;
  731. }
  732. }
  733. }
  734. }
  735. }
  736. //IDMapping[project.ID] = {engineeringCost: 0, subEngineering: 0, measure: 0, safetyConstruction: 0, other: 0, charge: 0, tax: 0, estimate: 0, rate: 0, buildingArea: grossArea, perCost: ''};
  737. IDMapping[project.ID] = {estimate: 0, rate: 0, buildingArea: grossArea, perCost: ''};
  738. initFees(IDMapping[project.ID], feeFields);
  739. console.log(IDMapping[project.ID]);
  740. }
  741. //单项工程
  742. let engineerings = await projectModel.find({ParentID: {$in : projectIDs}, projType: projectType.engineering, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]});
  743. //单位工程
  744. let tenders = [];
  745. let engIDs = [];
  746. for(let eng of engineerings){
  747. engIDs.push(eng.ID);
  748. //IDMapping[eng.ID] = {engineeringCost: 0, subEngineering: 0, measure: 0, safetyConstruction: 0, other: 0, charge: 0, tax: 0, estimate: 0, rate: 0, buildingArea: '', perCost: ''};
  749. IDMapping[eng.ID] = {estimate: 0, rate: 0, buildingArea: '', perCost: ''};
  750. initFees(IDMapping[eng.ID], feeFields);
  751. }
  752. if(engIDs.length > 0){
  753. tenders = await projectModel.find({ParentID: {$in : engIDs}, projType: projectType.tender, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]});
  754. }
  755. let tenderIDs = [];
  756. if(tenders.length > 0){
  757. for(let tender of tenders){
  758. tenderIDs.push(tender.ID);
  759. /*IDMapping[tender.ID] = {engineeringCost: 0, subEngineering: 0, measure: 0, safetyConstruction: 0, other: 0, charge: 0, tax: 0, rate: 0, estimate: 0,
  760. buildingArea: '', perCost: '',changeMark:tender.changeMark,property:tender.property};*/
  761. IDMapping[tender.ID] = {rate: 0, estimate: 0, buildingArea: '', perCost: '', changeMark:tender.changeMark,property:tender.property};
  762. initFees(IDMapping[tender.ID], feeFields);
  763. let buildingArea = getBuildingArea(tender.property.projectFeature);
  764. if(buildingArea){
  765. IDMapping[tender.ID]['buildingArea'] = buildingArea;
  766. }
  767. }
  768. //需要获取的清单固定类别综合合价:工程造价、分部分项、措施项目、安全文明施工专项、规费、其他项目、税金...
  769. /*let needFlags = [billsFlags.ENGINEERINGCOST, billsFlags.SUB_ENGINERRING, billsFlags.MEASURE,
  770. billsFlags.SAFETY_CONSTRUCTION, billsFlags.CHARGE, billsFlags.OTHER, billsFlags.TAX];*/
  771. let needFlags = feeFields.map(data => data.k);
  772. //获取单位工程汇总金额需要用到的所有清单
  773. let allBills = await billsModel.find({projectID: {$in: tenderIDs}, 'flags.flag': {$in: needFlags}, $or: [{deleteInfo: null}, {'deleteInfo.deleted': false}]},
  774. '-_id projectID fees flags');
  775. //进行单位工程级别的汇总
  776. for(let bills of allBills){
  777. let billsFlag = bills.flags[0]['flag'];
  778. let costField = flagFieldMapping[billsFlag];
  779. IDMapping[bills.projectID][costField] = getTotalFee(bills, 'common');
  780. //暂估合价(工程造价暂估合价)
  781. if (billsFlag === billsFlags.ENGINEERINGCOST){
  782. IDMapping[bills.projectID]['estimate'] = getTotalFee(bills, 'estimate');
  783. }
  784. }
  785. let summaryFields = feeFields.map(data => data.v);
  786. summaryFields.push('estimate');
  787. //进行单项工程级别的汇总
  788. for(let tender of tenders){
  789. summarizeToParent(IDMapping[tender.ParentID], IDMapping[tender.ID], summaryFields);
  790. }
  791. //进行建设项目级别的汇总
  792. for(let eng of engineerings){
  793. summarizeToParent(IDMapping[eng.ParentID], IDMapping[eng.ID], summaryFields);
  794. }
  795. //占造价比例、单方造价
  796. const rateDecimal = -2;
  797. const perCostDecimal = -2;
  798. for(let tender of tenders){
  799. let tenderInfo = IDMapping[tender.ID];
  800. let engInfo = IDMapping[tender.ParentID];
  801. tenderInfo.rate = engInfo.engineeringCost == 0 ? 0 : scMathUtil.roundTo(tenderInfo.engineeringCost * 100 / engInfo.engineeringCost, rateDecimal);
  802. //单方造价
  803. tenderInfo.perCost = tenderInfo.buildingArea.toString().trim() === '' || tenderInfo.buildingArea == 0 ?
  804. tenderInfo.buildingArea.toString().trim() : scMathUtil.roundTo(tenderInfo.engineeringCost / tenderInfo.buildingArea, perCostDecimal);
  805. }
  806. for(let eng of engineerings){
  807. let engInfo = IDMapping[eng.ID];
  808. let projInfo = IDMapping[eng.ParentID];
  809. engInfo.rate = !isDef(projInfo) || projInfo.engineeringCost == 0 ? 0 : scMathUtil.roundTo(engInfo.engineeringCost * 100 / projInfo.engineeringCost, rateDecimal);
  810. }
  811. //建设项目占造价比例及单方造价
  812. for(let project of projects){
  813. let projectInfo = IDMapping[project.ID];
  814. projectInfo.rate = 100;
  815. projectInfo.perCost = projectInfo.buildingArea.toString().trim() === '' || projectInfo.buildingArea == 0 ?
  816. projectInfo.buildingArea.toString().trim() : scMathUtil.roundTo(projectInfo.engineeringCost / projectInfo.buildingArea, perCostDecimal);
  817. }
  818. }
  819. return IDMapping;
  820. }
  821. //根据项目ID获取所属建设项目
  822. //@param {Number}projectID @return {Object}
  823. async function getConstructionProject(projectID){
  824. function returnProject(project){
  825. if(!project || project.projType === projectType.folder){
  826. return null;
  827. }
  828. if(project.projType === projectType.project){
  829. return project;
  830. }
  831. }
  832. let project = await projectModel.findOne({ID: projectID, $or: notDeleted});
  833. let returnV = returnProject(project);
  834. if(returnV !== undefined){
  835. return returnV;
  836. }
  837. let parent = await projectModel.findOne({ID: project.ParentID, $or: notDeleted});
  838. returnV = returnProject(parent);
  839. if(returnV !== undefined){
  840. return returnV;
  841. }
  842. let grandParent = await projectModel.findOne({ID: parent.ParentID, $or: notDeleted});
  843. returnV = returnProject(grandParent);
  844. return returnV !== undefined ? returnV : null;
  845. }
  846. //获取单位工程完整目录结构
  847. //@param {Number}projectID @return {Arry}
  848. async function getFullPath(projectID) {
  849. let fullPath = [];
  850. let project = await projectModel.findOne({ID: projectID, $or: notDeleted}, '-_id ParentID name');
  851. if(project){
  852. fullPath.push(project.name);
  853. await getParent(project.ParentID);
  854. }
  855. fullPath = fullPath.reverse();
  856. return fullPath;
  857. async function getParent(ParentID) {
  858. if(ParentID != -1){
  859. let parent = await projectModel.findOne({ID: ParentID, $or: notDeleted}, '-_id ParentID name');
  860. if(parent){
  861. fullPath.push(parent.name);
  862. await getParent(parent.ParentID);
  863. }
  864. }
  865. }
  866. }
  867. //获取projectIDs文件下所有子项目(不包括projectIDs本身)
  868. async function getPosterityProjects(projectIDs) {
  869. let rst = [];
  870. async function getProjects(IDs) {
  871. if (IDs.length > 0) {
  872. let newIDs = [];
  873. let projs = await projectModel.find({ParentID: {$in: IDs}, $or: notDeleted}, '-_id');
  874. for (let proj of projs) {
  875. rst.push(proj);
  876. newIDs.push(proj.ID);
  877. }
  878. await getProjects(newIDs);
  879. }
  880. }
  881. await getProjects(projectIDs);
  882. return rst;
  883. }
  884. //根据项目获得分享信息(分享层级不一定在项目级)(以最新为准)
  885. //@param {String}userId {Object}tender @return {Object} || {null}
  886. async function getShareInfo(userId, project) {
  887. //与该用户相关的分享
  888. let shareList = [];
  889. while (project) {
  890. for(let shareData of project.shareInfo){
  891. if(shareData.userID === userId){
  892. shareList.push(shareData);
  893. break;
  894. }
  895. }
  896. project = await projectModel.findOne({ID: project.ParentID}, '-_id shareInfo ID ParentID');
  897. }
  898. //获取最新分享
  899. shareList.sort(function (a, b) {
  900. let aV = Date.parse(a.shareDate),
  901. bV = Date.parse(b.shareDate);
  902. if (aV > bV) {
  903. return -1;
  904. } else if (aV < bV) {
  905. return 1;
  906. }
  907. return 0;
  908. });
  909. return shareList[0] || null;
  910. }
  911. //打开的单位工程是否是被分享的.
  912. async function isShare(userId, project){
  913. //判断是否是打开分享的项目,属于分享文件的子项也算
  914. while (project) {
  915. for(let shareData of project.shareInfo){
  916. if(shareData.userID === userId){
  917. return true;
  918. }
  919. }
  920. project = await projectModel.findOne({ID: project.ParentID}, '-_id shareInfo ID ParentID');
  921. }
  922. return false;
  923. }
  924. //用户是否第一次进入费用定额
  925. async function isFirst(userId, compilationId) {
  926. let userData = await userModel.findOne({_id: mongoose.Types.ObjectId(userId)}, '-_id used_list');
  927. let first = false;
  928. if (userData) {
  929. first = !_.find(userData.used_list, function (o) {
  930. return o.compilationId === compilationId;
  931. });;
  932. }
  933. return first;
  934. }
  935. //用户第一次进入费用定额的数据准备
  936. async function prepareInitialData(userId, compilation, example) {
  937. let first = await isFirst(userId, compilation);
  938. if (first) {
  939. await updateUsedList(userId, compilation);
  940. let prepareTask = [
  941. copyCompleRationSection(userId, compilation),
  942. copyCompleGljSection(userId, compilation)
  943. ];
  944. if (example && example.length > 0) {
  945. prepareTask.push(copyExample(userId, compilation, example));
  946. }
  947. await Promise.all(prepareTask);
  948. }
  949. }
  950. async function updateUsedList(userId, compilation) {
  951. await userModel.update({_id: mongoose.Types.ObjectId(userId)}, {$push: {used_list: {compilationId: compilation}}});
  952. }
  953. //拷贝补充定额章节树
  954. async function copyCompleRationSection(userId, compilationId) {
  955. await sectionTreeDao.copyDataFromTemplate(userId, compilationId);
  956. }
  957. //拷贝补充人材机分类树
  958. async function copyCompleGljSection(userId, compilationId) {
  959. let templateData = await compleGljSectionTModel.find({compilationId: compilationId});
  960. if (templateData.length > 0) {
  961. let insertDatas = [],
  962. uuidMapping = {};
  963. //将ID替换成UUID
  964. for (let temData of templateData) {
  965. uuidMapping[temData.ID] = uuidV1();
  966. }
  967. for(let temData of templateData) {
  968. let insertD = {
  969. userId: userId,
  970. compilationId: compilationId,
  971. Name: temData.Name,
  972. ID: uuidMapping[temData.ID],
  973. ParentID: uuidMapping[temData.ParentID] || -1,
  974. NextSiblingID: uuidMapping[temData.NextSiblingID] || -1,
  975. };
  976. insertDatas.push(insertD);
  977. }
  978. //插入数据
  979. await compleGljSectionModel.insertMany(insertDatas);
  980. }
  981. }
  982. async function changeFile(datas,userID,fileID,name,from,type){//from 费率或单价文件,type从单前建设项目还是从其它建设项目中复制
  983. let projectIDs = [],newFile = {id:fileID,name:name};//计录从其它项目中复制的文件,选中多个的时候只需复制一次
  984. let projectUpdateType = from == "feeRateFile"?"feeRate":"unitFile";
  985. for(let d of datas){
  986. let tem_file = from == "feeRateFile"? await feeRate_facade.changeFeeRateFile(d, newFile,type,userID):await glj_facade.changeUnitFile(d, newFile,type,userID);
  987. if(type == 1 && tem_file){//从建设项目复制时,只有第一次需要复制,剩下的就相当于使用同个建设项目的情况了
  988. let newID = from == "feeRateFile"?tem_file.ID:tem_file.id;
  989. newFile = {id:newID,name:tem_file.name};
  990. type = 0;
  991. }
  992. projectIDs.push({ID:d.projectID})
  993. }
  994. await project_facade.markProjectsToChange(projectIDs,projectUpdateType)//项目标记为待刷新状态
  995. }
  996. async function getBasicInfo(compilationID) {
  997. let compilation = await compilationModel.findOne({_id: mongoose.Types.ObjectId(compilationID)});
  998. if (!compilation) {
  999. return null;
  1000. }
  1001. let billValuation = compilation.bill_valuation.find(function (data) {
  1002. return data.enable;
  1003. });
  1004. if (!billValuation) {
  1005. return null;
  1006. }
  1007. let engineerings = await engineeringModel.find({valuationID: billValuation.id});
  1008. let engineering = engineerings.find(function (data) {
  1009. return data.info_lib && data.info_lib.length > 0;
  1010. });
  1011. if (!engineering || !engineering.info_lib || !engineering.info_lib[0]) {
  1012. return null;
  1013. }
  1014. let infoLib = await basicInfoModel.findOne({ID: engineering.info_lib[0].id});
  1015. return infoLib;
  1016. }
  1017. async function getProjectFeature(valuationID, engineeringName, feeName) {
  1018. let engineering = await engineeringModel.findOne({valuationID: valuationID, name: engineeringName, feeName: feeName});
  1019. if (!engineering || !engineering.feature_lib || !engineering.feature_lib[0]) {
  1020. return null;
  1021. }
  1022. let featureLib = await projectFeatureModel.findOne({ID: engineering.feature_lib[0].id});
  1023. return featureLib;
  1024. }
  1025. //根据单位工程,获取建设项目-单项工程-单位工程,不包含无单位工程的单项工程
  1026. //@param {Number}tenderID(单位工程ID) {Number}granularity(颗粒度 1:建设项目 2:单项工程 3:单位工程)
  1027. async function getProjectByGranularity(tenderID, granularity, userID, versionName) {
  1028. const GRANULARITY = {
  1029. PROJECT: 1,
  1030. ENGINEERING: 2,
  1031. TENDER: 3
  1032. };
  1033. let theTender = await projectModel.findOne({userID: userID, ID: tenderID}); //加上session的userID,防止tenderID被篡改过
  1034. if (!theTender) {
  1035. return null;
  1036. }
  1037. let theEngineering = await projectModel.findOne({ID: theTender.ParentID});
  1038. if (!theEngineering) {
  1039. return null;
  1040. }
  1041. let constructionProject = await projectModel.findOne({ID: theEngineering.ParentID});
  1042. if (!constructionProject) {
  1043. return null;
  1044. }
  1045. let engineerings;
  1046. if (granularity === GRANULARITY.PROJECT) {
  1047. engineerings = await projectModel.find({ParentID: constructionProject.ID, $or: notDeleted});
  1048. for (let eng of engineerings) {
  1049. eng._doc.children = await projectModel.find({ParentID: eng.ID, $or: notDeleted});
  1050. }
  1051. } else {
  1052. engineerings = [theEngineering];
  1053. if (granularity === GRANULARITY.ENGINEERING) {
  1054. theEngineering._doc.children = await projectModel.find({ParentID: theEngineering.ID, $or: notDeleted});
  1055. } else {
  1056. theEngineering._doc.children = [theTender];
  1057. }
  1058. }
  1059. constructionProject._doc.children = engineerings;
  1060. //获取汇总信息
  1061. let feeFields = [
  1062. {k: billsFlags.ENGINEERINGCOST, v: 'engineeringCost'},
  1063. {k: billsFlags.SUB_ENGINERRING, v: 'subEngineering'},
  1064. {k: billsFlags.MEASURE, v: 'measure'},
  1065. {k: billsFlags.SAFETY_CONSTRUCTION, v: 'safetyConstruction'},
  1066. {k: billsFlags.OTHER, v: 'other'},
  1067. {k: billsFlags.CHARGE, v: 'charge'},
  1068. {k: billsFlags.PROVISIONAL, v: 'provisional'},
  1069. {k: billsFlags.MATERIAL_PROVISIONAL, v: 'materialProvisional'},
  1070. {k: billsFlags.ENGINEERING_ESITIMATE, v: 'engineeringEstimate'},
  1071. {k: billsFlags.DAYWORK, v: 'daywork'},
  1072. {k: billsFlags.TURN_KEY_CONTRACT, v: 'turnKeyContract'},
  1073. {k: billsFlags.CLAIM_VISA, v: 'claimVisa'},
  1074. {k: billsFlags.TAX, v: 'tax'}
  1075. ];
  1076. constructionProject._doc.summaryInfo = await getSummaryInfo([constructionProject.ID], feeFields);
  1077. //获取编制软件信息: 软件公司;软件名;版本号;授权信息; base64
  1078. let product = await productModel.findOne({});
  1079. let company = product.company || '珠海纵横创新软件有限公司',
  1080. version = product.version || '';
  1081. constructionProject._doc.softInfo = new Buffer(`${company};${versionName};${version};${userID}`).toString('base64');
  1082. return constructionProject;
  1083. }