HStation/XHS.V1.0.git

			@@ -1,5 +1,4 @@
			using HStation.Model;
			using Microsoft.VisualBasic;

			namespace HStation.Service
			{
			@@ -9,129 +8,717 @@
			public static class RevitCorrectHelper
			{
			/// <summary>
			/// 修正(无法修正会抛出异常)
			/// 修正
			/// </summary>
			/// <param name="rhs">RevitModel</param>
			public static bool Correct(this Model.RevitModel rhs, out string msg)
			public static bool Correct(this Model.RevitModel rhs, ref List<string> msgList)
			{
			if (rhs == null)
			{
			msg = "数据为空";
			return false;
			}
			if (!Zero(rhs, out msg))
			if (msgList == null)
			{
			return false;
			msgList = new List<string>();
			}
			if (!First(rhs, out msg))
			{
			return false;
			var result = true;
			if (!CorrectCollection(rhs, ref msgList))
			{//修正集合
			result = false;
			}
			if (!Second(rhs, out msg))
			{
			return false;
			if (!CorrectName(rhs, ref msgList))
			{//修正名称
			result = false;
			}
			if (!Three(rhs, out msg))
			{
			return false;
			if (!CorrectExchanger(rhs, ref msgList))
			{//修正换热器
			result = false;
			}
			return true;
			if (!CorrectCompressor(rhs, ref msgList))
			{//修正空压机
			result = false;
			}
			if (!CorrectCode(rhs, ref msgList))
			{//修正编码
			result = false;
			}
			if (!CorrectLink(rhs, ref msgList))
			{//修正连接
			result = false;
			}

			return result;
			}

			//前提：验证合法性
			private static bool Zero(Model.RevitModel rhs, out string msg)
			//修正集合
			private static bool CorrectCollection(Model.RevitModel rhs, ref List<string> msgList)
			{
			msg = string.Empty;
			var allWaterSourceList = rhs.GetAllWaterSources();
			if (allWaterSourceList == null \|\| allWaterSourceList.Count < 1)
			if (rhs == null)
			{
			msg = "无水源";
			return false;
			}
			var allJunctionList = rhs.GetAllJunctions();
			if (allJunctionList == null \|\| allJunctionList.Count < 1)
			if (msgList == null)
			{
			msg = "无连接节点";
			return false;
			msgList = new List<string>();
			}
			return true;
			}

			//第一步：检查集合初始化
			private static bool First(Model.RevitModel rhs, out string msg)
			{
			msg = string.Empty;
			if (rhs.Reservoirs == null)
			{
			{//水库
			rhs.Reservoirs = new List<Model.RevitReservoir>();
			}
			if (rhs.Tanks == null)
			{
			{//水池
			rhs.Tanks = new List<Model.RevitTank>();
			}
			if (rhs.Waterboxs == null)
			{
			{//水箱
			rhs.Waterboxs = new List<Model.RevitWaterbox>();
			}
			if (rhs.Junctions == null)
			{
			rhs.Waterboxs = new List<Model.RevitWaterbox>();
			{//连接节点
			rhs.Junctions = new List<Model.RevitJunction>();
			}
			if (rhs.Bluntheads == null)
			{//闷头
			rhs.Bluntheads = new List<Model.RevitBlunthead>();
			}
			if (rhs.Elbows == null)
			{
			{//弯头
			rhs.Elbows = new List<Model.RevitElbow>();
			}
			if (rhs.Threelinks == null)
			{
			{//三通
			rhs.Threelinks = new List<Model.RevitThreelink>();
			}
			if (rhs.Fourlinks == null)
			{
			{//四通
			rhs.Fourlinks = new List<Model.RevitFourlink>();
			}
			if (rhs.Flowmeters == null)
			{
			rhs.Flowmeters = new List<Model.RevitFlowmeter>();
			}
			if (rhs.Pressmeters == null)
			{
			rhs.Pressmeters = new List<Model.RevitPressmeter>();
			}
			if (rhs.Nozzles == null)
			{
			{//喷头
			rhs.Nozzles = new List<Model.RevitNozzle>();
			}
			if (rhs.Hydrants == null)
			{
			{//消火栓
			rhs.Hydrants = new List<Model.RevitHydrant>();
			}
			if (rhs.Bluntheads == null)
			{
			rhs.Bluntheads = new List<Model.RevitBlunthead>();
			if (rhs.Meters == null)
			{//水表
			rhs.Meters = new List<RevitMeter>();
			}
			if (rhs.Flowmeters == null)
			{//流量计
			rhs.Flowmeters = new List<Model.RevitFlowmeter>();
			}
			if (rhs.Pressmeters == null)
			{//压力表
			rhs.Pressmeters = new List<Model.RevitPressmeter>();
			}

			if (rhs.Pipes == null)
			{
			{//管道
			rhs.Pipes = new List<Model.RevitPipe>();
			}
			if (rhs.Translations == null)
			{
			{//过渡件
			rhs.Translations = new List<Model.RevitTranslation>();
			}
			if (rhs.Pumps == null)
			{
			{//水泵
			rhs.Pumps = new List<Model.RevitPump>();
			}
			if (rhs.Valves == null)
			{
			{//阀门
			rhs.Valves = new List<Model.RevitValve>();
			}
			if (rhs.Exchangers == null)
			{//换热器
			rhs.Exchangers = new List<RevitExchanger>();
			}
			if (rhs.Compressors == null)
			{//空压机
			rhs.Compressors = new List<RevitCompressor>();
			}
			return true;
			}

			//第二步：检查上下游编码
			private static bool Second(Model.RevitModel rhs, out string msg)
			//修正名称
			private static bool CorrectName(Model.RevitModel rhs, ref List<string> msgList)
			{
			msg = string.Empty;
			if (rhs == null)
			{
			return false;
			}
			if (msgList == null)
			{
			msgList = new List<string>();
			}
			if (rhs.Reservoirs != null && rhs.Reservoirs.Count > 0)
			{//水库
			var reservoirNameList = rhs.Reservoirs.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var reservoir in rhs.Reservoirs)
			{
			if (string.IsNullOrEmpty(reservoir.Name))
			{
			var reservoirName = Yw.Untity.UniqueHelper.CreateFromFirst("水库", reservoirNameList);
			reservoir.Name = reservoirName;
			reservoirNameList.Add(reservoirName);
			}
			}
			}
			if (rhs.Tanks != null && rhs.Tanks.Count > 0)
			{//水池
			var tankNameList = rhs.Tanks.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var tank in rhs.Tanks)
			{
			if (string.IsNullOrEmpty(tank.Name))
			{
			var tankName = Yw.Untity.UniqueHelper.CreateFromFirst("水池", tankNameList);
			tank.Name = tankName;
			tankNameList.Add(tankName);
			}
			}
			}
			if (rhs.Waterboxs != null && rhs.Waterboxs.Count > 0)
			{//水箱
			var waterboxNameList = rhs.Waterboxs.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var waterbox in rhs.Waterboxs)
			{
			if (string.IsNullOrEmpty(waterbox.Name))
			{
			var waterboxName = Yw.Untity.UniqueHelper.CreateFromFirst("水箱", waterboxNameList);
			waterbox.Name = waterboxName;
			waterboxNameList.Add(waterboxName);
			}
			}
			}
			if (rhs.Junctions != null && rhs.Junctions.Count > 0)
			{//连接节点
			var junctionNameList = rhs.Junctions.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var junction in rhs.Junctions)
			{
			if (string.IsNullOrEmpty(junction.Name))
			{
			var junctionName = Yw.Untity.UniqueHelper.CreateFromFirst("连接节点", junctionNameList);
			junction.Name = junctionName;
			junctionNameList.Add(junctionName);
			}
			}
			}
			if (rhs.Bluntheads != null && rhs.Bluntheads.Count > 0)
			{//闷头
			var bluntheadNameList = rhs.Bluntheads.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var blunthead in rhs.Bluntheads)
			{
			if (string.IsNullOrEmpty(blunthead.Name))
			{
			var bluntheadName = Yw.Untity.UniqueHelper.CreateFromFirst("闷头", bluntheadNameList);
			blunthead.Name = bluntheadName;
			bluntheadNameList.Add(bluntheadName);
			}
			}
			}
			if (rhs.Elbows != null && rhs.Elbows.Count > 0)
			{//弯头
			var elbowNameList = rhs.Elbows.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var elbow in rhs.Elbows)
			{
			if (string.IsNullOrEmpty(elbow.Name))
			{
			var elbowName = Yw.Untity.UniqueHelper.CreateFromFirst("弯头", elbowNameList);
			elbow.Name = elbowName;
			elbowNameList.Add(elbowName);
			}
			}
			}
			if (rhs.Threelinks != null && rhs.Threelinks.Count > 0)
			{//三通
			var threelinkNameList = rhs.Threelinks.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var threelink in rhs.Threelinks)
			{
			if (string.IsNullOrEmpty(threelink.Name))
			{
			var threelinkName = Yw.Untity.UniqueHelper.CreateFromFirst("三通", threelinkNameList);
			threelink.Name = threelinkName;
			threelinkNameList.Add(threelinkName);
			}
			}
			}
			if (rhs.Fourlinks != null && rhs.Fourlinks.Count > 0)
			{//四通
			var fourlinkNameList = rhs.Fourlinks.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var fourlink in rhs.Fourlinks)
			{
			if (string.IsNullOrEmpty(fourlink.Name))
			{
			var fourlinkName = Yw.Untity.UniqueHelper.CreateFromFirst("四通", fourlinkNameList);
			fourlink.Name = fourlinkName;
			fourlinkNameList.Add(fourlinkName);
			}
			}
			}
			if (rhs.Nozzles != null && rhs.Nozzles.Count > 0)
			{//喷头
			var nozzleNameList = rhs.Nozzles.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var nozzle in rhs.Nozzles)
			{
			if (string.IsNullOrEmpty(nozzle.Name))
			{
			var nozzleName = Yw.Untity.UniqueHelper.CreateFromFirst("喷头", nozzleNameList);
			nozzle.Name = nozzleName;
			nozzleNameList.Add(nozzleName);
			}
			}
			}
			if (rhs.Hydrants != null && rhs.Hydrants.Count > 0)
			{//消火栓
			var hydrantNameList = rhs.Hydrants.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var hydrant in rhs.Hydrants)
			{
			if (string.IsNullOrEmpty(hydrant.Name))
			{
			var hydrantName = Yw.Untity.UniqueHelper.CreateFromFirst("消火栓", hydrantNameList);
			hydrant.Name = hydrantName;
			hydrantNameList.Add(hydrantName);
			}
			}
			}
			if (rhs.Meters != null && rhs.Meters.Count > 0)
			{//水表
			var meterNameList = rhs.Meters.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var meter in rhs.Meters)
			{
			if (string.IsNullOrEmpty(meter.Name))
			{
			var meterName = Yw.Untity.UniqueHelper.CreateFromFirst("水表", meterNameList);
			meter.Name = meterName;
			meterNameList.Add(meterName);
			}
			}
			}
			if (rhs.Flowmeters != null && rhs.Flowmeters.Count > 0)
			{//流量计
			var flowmeterNameList = rhs.Flowmeters.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var flowmeter in rhs.Flowmeters)
			{
			if (string.IsNullOrEmpty(flowmeter.Name))
			{
			var flowmeterName = Yw.Untity.UniqueHelper.CreateFromFirst("流量计", flowmeterNameList);
			flowmeter.Name = flowmeterName;
			flowmeterNameList.Add(flowmeterName);
			}
			}
			}
			if (rhs.Pressmeters != null && rhs.Pressmeters.Count > 0)
			{//压力表
			var pressmeterNameList = rhs.Pressmeters.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var pressmeter in rhs.Pressmeters)
			{
			if (string.IsNullOrEmpty(pressmeter.Name))
			{
			var pressmeterName = Yw.Untity.UniqueHelper.CreateFromFirst("压力表", pressmeterNameList);
			pressmeter.Name = pressmeterName;
			pressmeterNameList.Add(pressmeterName);
			}
			}
			}
			if (rhs.Pipes != null && rhs.Pipes.Count > 0)
			{//管道
			var pipeNameList = rhs.Pipes.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var pipe in rhs.Pipes)
			{
			if (string.IsNullOrEmpty(pipe.Name))
			{
			var pipeName = Yw.Untity.UniqueHelper.CreateFromFirst("管道", pipeNameList);
			pipe.Name = pipeName;
			pipeNameList.Add(pipeName);
			}
			}
			}
			if (rhs.Translations != null && rhs.Translations.Count > 0)
			{//过渡件
			var translationNameList = rhs.Translations.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var translation in rhs.Translations)
			{
			if (string.IsNullOrEmpty(translation.Name))
			{
			var translationName = Yw.Untity.UniqueHelper.CreateFromFirst("过渡件", translationNameList);
			translation.Name = translationName;
			translationNameList.Add(translationName);
			}
			}
			}
			if (rhs.Pumps != null && rhs.Pumps.Count > 0)
			{//水泵
			var pumpNameList = rhs.Pumps.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var pump in rhs.Pumps)
			{
			if (string.IsNullOrEmpty(pump.Name))
			{
			var pumpName = Yw.Untity.UniqueHelper.CreateFromFirst("水泵", pumpNameList);
			pump.Name = pumpName;
			pumpNameList.Add(pumpName);
			}
			}
			}
			if (rhs.Valves != null && rhs.Valves.Count > 0)
			{//阀门
			var valveNameList = rhs.Valves.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var valve in rhs.Valves)
			{
			if (string.IsNullOrEmpty(valve.Name))
			{
			var valveName = Yw.Untity.UniqueHelper.CreateFromFirst("阀门", valveNameList);
			valve.Name = valveName;
			valveNameList.Add(valveName);
			}
			}
			}
			if (rhs.Exchangers != null && rhs.Exchangers.Count > 0)
			{//换热器
			var exchangerNameList = rhs.Exchangers.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var exchanger in rhs.Exchangers)
			{
			if (string.IsNullOrEmpty(exchanger.Name))
			{
			var exchangerName = Yw.Untity.UniqueHelper.CreateFromFirst("换热器", exchangerNameList);
			exchanger.Name = exchangerName;
			exchangerNameList.Add(exchangerName);
			}
			}
			}
			if (rhs.Compressors != null && rhs.Compressors.Count > 0)
			{//空压机
			var compressorNameList = rhs.Compressors.Where(x => !string.IsNullOrEmpty(x.Name)).Select(x => x.Name).Distinct().ToList();
			foreach (var compressor in rhs.Compressors)
			{
			if (string.IsNullOrEmpty(compressor.Name))
			{
			var compressorName = Yw.Untity.UniqueHelper.CreateFromFirst("空压机", compressorNameList);
			compressor.Name = compressorName;
			compressorNameList.Add(compressorName);
			}
			}
			}
			return true;
			}

			//修复换热器
			private static bool CorrectExchanger(Model.RevitModel rhs, ref List<string> msgList)
			{
			if (rhs == null)
			{
			return false;
			}
			if (msgList == null)
			{
			msgList = new List<string>();
			}
			var result = true;
			if (rhs.Exchangers != null && rhs.Exchangers.Count > 0)
			{
			var allParterList = rhs.GetAllParters();
			foreach (var exchanger in rhs.Exchangers)
			{
			if (exchanger.ConnectList != null && exchanger.ConnectList.Count > 0)
			{
			#region 去除无效连接和闷头

			foreach (var connect in exchanger.ConnectList.ToList())
			{
			var connectParter = allParterList.Find(x => x.Id == connect.Id);
			if (connectParter == null)
			{
			exchanger.ConnectList.Remove(connect);
			}
			else
			{
			if (connectParter is RevitBlunthead blunthead)
			{
			var decorator = new Model.RevitDecorator();
			decorator.Id = blunthead.Id;
			decorator.Name = blunthead.Name;
			decorator.Category = RevitJsonCatalog.Blunthead;
			decorator.Decoration = null;
			decorator.Description = blunthead.Description;
			rhs.Decorators.Add(decorator);
			rhs.Bluntheads.Remove(blunthead);
			allParterList.Remove(connectParter);
			}
			}
			}

			#endregion

			#region 开始连接

			var startConnectList = exchanger.ConnectList.GetStartConnects();
			if (startConnectList.Count < 1)
			{
			var startConnect = exchanger.ConnectList.GetStartConnect();
			if (startConnect != null)
			{
			startConnectList.Add(startConnect);
			}
			}
			if (startConnectList.Count < 1)
			{
			msgList.Add($"换热器[{exchanger.Id}]上游连接组件不存在");
			result = false;
			continue;
			}
			var startJunction = new Model.RevitJunction();
			startJunction.Id = Yw.Untity.UniqueHelper.CreateFromFirst("junction", allParterList.Select(x => x.Id).ToList());
			startJunction.Name = UniqueHelper.CreateFromFirst("连接节点", allParterList.Select(x => x.Name).Distinct().ToList());
			startJunction.Flags = null;
			startJunction.ModelType = null;
			startJunction.Description = "换热器修正时，自动添加";
			startJunction.Position = startConnectList.GetCenterPosition();
			startJunction.Elev = exchanger.Elev;
			startJunction.Demand = null;
			startJunction.DemandPattern = null;
			rhs.Junctions.Add(startJunction);
			exchanger.StartCode = startJunction.Id;
			foreach (var startConnect in startConnectList)
			{
			var startConnectParter = allParterList.Find(x => x.Id == startConnect.Id);
			if (startConnectParter is RevitLink revitLink)
			{
			if (revitLink.StartCode == exchanger.Id)
			{
			revitLink.StartCode = startJunction.Id;
			}
			else if (revitLink.EndCode == exchanger.Id)
			{
			revitLink.EndCode = startJunction.Id;
			}
			}
			}
			allParterList.Add(startJunction);

			#endregion

			#region 结束连接

			var endConnectList = exchanger.ConnectList.GetEndConnects();
			if (endConnectList.Count < 1)
			{
			var endConnect = exchanger.ConnectList.GetEndConnect();
			if (endConnect != null)
			{
			endConnectList.Add(endConnect);
			}
			}
			if (endConnectList.Count < 1)
			{
			msgList.Add($"换热器[{exchanger.Id}]下游连接组件不存在");
			result = false;
			continue;
			}
			var endJunction = new Model.RevitJunction();
			endJunction.Id = Yw.Untity.UniqueHelper.CreateFromFirst("junction", allParterList.Select(x => x.Id).ToList());
			endJunction.Name = UniqueHelper.CreateFromFirst("连接节点", allParterList.Select(x => x.Name).Distinct().ToList());
			endJunction.Flags = null;
			endJunction.ModelType = null;
			endJunction.Description = "换热器修正时，自动添加";
			endJunction.Position = endConnectList.GetCenterPosition();
			endJunction.Elev = exchanger.Elev;
			endJunction.Demand = null;
			endJunction.DemandPattern = null;
			rhs.Junctions.Add(endJunction);
			exchanger.EndCode = endJunction.Id;
			foreach (var endConnect in endConnectList)
			{
			var endConnectParter = allParterList.Find(x => x.Id == endConnect.Id);
			if (endConnectParter is RevitLink revitLink)
			{
			if (revitLink.StartCode == exchanger.Id)
			{
			revitLink.StartCode = endJunction.Id;
			}
			else if (revitLink.EndCode == exchanger.Id)
			{
			revitLink.EndCode = endJunction.Id;
			}
			}
			}
			allParterList.Add(endJunction);

			#endregion
			}
			else
			{
			msgList.Add($"换热器[{exchanger.Id}]连接列表为空");
			result = false;
			}
			}
			}
			return result;
			}

			//修复空压机
			private static bool CorrectCompressor(Model.RevitModel rhs, ref List<string> msgList)
			{
			if (rhs == null)
			{
			return false;
			}
			if (msgList == null)
			{
			msgList = new List<string>();
			}
			var result = true;
			if (rhs.Compressors != null && rhs.Compressors.Count > 0)
			{
			var allParterList = rhs.GetAllParters();
			foreach (var compressor in rhs.Compressors)
			{
			if (compressor.ConnectList != null && compressor.ConnectList.Count > 0)
			{
			#region 去除无效连接和闷头

			foreach (var connect in compressor.ConnectList.ToList())
			{
			var connectParter = allParterList.Find(x => x.Id == connect.Id);
			if (connectParter == null)
			{
			compressor.ConnectList.Remove(connect);
			}
			else
			{
			if (connectParter is RevitBlunthead blunthead)
			{
			var decorator = new Model.RevitDecorator();
			decorator.Id = blunthead.Id;
			decorator.Name = blunthead.Name;
			decorator.Category = RevitJsonCatalog.Blunthead;
			decorator.Decoration = null;
			decorator.Description = blunthead.Description;
			rhs.Decorators.Add(decorator);
			rhs.Bluntheads.Remove(blunthead);
			allParterList.Remove(connectParter);
			}
			}
			}

			#endregion

			#region 开始连接

			var startConnectList = compressor.ConnectList.GetStartConnects();
			if (startConnectList.Count < 1)
			{
			var startConnect = compressor.ConnectList.GetStartConnect();
			if (startConnect != null)
			{
			startConnectList.Add(startConnect);
			}
			}
			if (startConnectList.Count < 1)
			{
			msgList.Add($"空压机[{compressor.Id}]上游连接组件不存在");
			result = false;
			continue;
			}
			var startJunction = new Model.RevitJunction();
			startJunction.Id = Yw.Untity.UniqueHelper.CreateFromFirst("junction", allParterList.Select(x => x.Id).ToList());
			startJunction.Name = UniqueHelper.CreateFromFirst("连接节点", allParterList.Select(x => x.Name).Distinct().ToList());
			startJunction.Flags = null;
			startJunction.ModelType = null;
			startJunction.Description = "空压机修正时，自动添加";
			startJunction.Position = startConnectList.GetCenterPosition();
			startJunction.Elev = compressor.Elev;
			startJunction.Demand = null;
			startJunction.DemandPattern = null;
			rhs.Junctions.Add(startJunction);
			compressor.StartCode = startJunction.Id;
			foreach (var startConnect in startConnectList)
			{
			var startConnectParter = allParterList.Find(x => x.Id == startConnect.Id);
			if (startConnectParter is RevitLink revitLink)
			{
			if (revitLink.StartCode == compressor.Id)
			{
			revitLink.StartCode = startJunction.Id;
			}
			else if (revitLink.EndCode == compressor.Id)
			{
			revitLink.EndCode = startJunction.Id;
			}
			}
			}
			allParterList.Add(startJunction);

			#endregion

			#region 结束连接

			var endConnectList = compressor.ConnectList.GetEndConnects();
			if (endConnectList.Count < 1)
			{
			var endConnect = compressor.ConnectList.GetEndConnect();
			if (endConnect != null)
			{
			endConnectList.Add(endConnect);
			}
			}
			if (endConnectList.Count < 1)
			{
			msgList.Add($"空压机[{compressor.Id}]下游连接组件不存在");
			result = false;
			continue;
			}
			var endJunction = new Model.RevitJunction();
			endJunction.Id = Yw.Untity.UniqueHelper.CreateFromFirst("junction", allParterList.Select(x => x.Id).ToList());
			endJunction.Name = UniqueHelper.CreateFromFirst("连接节点", allParterList.Select(x => x.Name).Distinct().ToList());
			endJunction.Flags = null;
			endJunction.ModelType = null;
			endJunction.Description = "空压机修正时，自动添加";
			endJunction.Position = endConnectList.GetCenterPosition();
			endJunction.Elev = compressor.Elev;
			endJunction.Demand = null;
			endJunction.DemandPattern = null;
			rhs.Junctions.Add(endJunction);
			compressor.EndCode = endJunction.Id;
			foreach (var endConnect in endConnectList)
			{
			var endConnectParter = allParterList.Find(x => x.Id == endConnect.Id);
			if (endConnectParter is RevitLink revitLink)
			{
			if (revitLink.StartCode == compressor.Id)
			{
			revitLink.StartCode = endJunction.Id;
			}
			else if (revitLink.EndCode == compressor.Id)
			{
			revitLink.EndCode = endJunction.Id;
			}
			}
			}
			allParterList.Add(endJunction);

			#endregion
			}
			else
			{
			msgList.Add($"空压机[{compressor.Id}]连接列表为空");
			result = false;
			}
			}
			}
			return result;
			}

			//修正编码
			private static bool CorrectCode(Model.RevitModel rhs, ref List<string> msgList)
			{
			if (rhs == null)
			{
			return false;
			}
			if (msgList == null)
			{
			msgList = new List<string>();
			}
			var result = true;
			var allParterList = rhs.GetAllParters();
			var allLinks = rhs.GetAllLinks();
			foreach (var link in allLinks)
			@@ -139,72 +726,101 @@
			var startLinkParter = allParterList.Find(x => x.Id == link.StartCode);
			if (startLinkParter == null)
			{
			msg = $"管段: {link.Id} 上游节点错误";
			return false;
			msgList.Add($"管段:[{link.Id}]上游节点[{link.StartCode}]错误");
			result = false;
			}
			link.StartCode = startLinkParter.Code;
			else
			{
			link.StartCode = startLinkParter.Id;
			}

			var endLinkParter = allParterList.Find(x => x.Id == link.EndCode);
			if (endLinkParter == null)
			{
			msg = $"管段: {link.Id} 下游节点错误";
			return false;
			msgList.Add($"管段:[{link.Id}]下游节点[{link.EndCode}]错误");
			result = false;
			}
			link.EndCode = endLinkParter.Code;
			else
			{
			link.EndCode = endLinkParter.Id;
			}

			}
			return true;
			return result;
			}

			//第三步：按照水力结构进行修正
			private static bool Three(Model.RevitModel rhs, out string msg)
			//修正连接
			private static bool CorrectLink(Model.RevitModel rhs, ref List<string> msgList)
			{
			msg = string.Empty;
			if (rhs == null)
			{
			return false;
			}
			if (msgList == null)
			{
			msgList = new List<string>();
			}
			var allParterList = rhs.GetAllParters();
			var allLinks = rhs.GetAllLinks();
			foreach (var link in allLinks)
			{
			var allParterList = rhs.GetAllParters();
			var startLinkParter = allParterList.Find(x => x.Code == link.StartCode);
			if (startLinkParter is IRevitLink)
			var startLinkParter = allParterList.Find(x => x.Id == link.StartCode);
			if (startLinkParter is RevitLink startLink)
			{
			var junction = new Model.RevitJunction();
			junction.Id = Yw.Untity.UniqueHelper.CreateFromFirst("junction", allParterList.Select(x => x.Code).ToList());
			junction.Code = junction.Id;
			junction.Id = Yw.Untity.UniqueHelper.CreateFromFirst("junction", allParterList.Select(x => x.Id).ToList());
			junction.Name = UniqueHelper.CreateFromFirst("连接节点", allParterList.Select(x => x.Name).Distinct().ToList());
			junction.Flags = null;
			junction.ModelType = null;
			junction.Description = "水力修正时，自动添加";
			junction.Quality = link.StartQuality;
			junction.Position = link.StartPosition;
			junction.Elev = link.StartElev;
			junction.Elev = link.StartPosition.Z;
			junction.Demand = null;
			junction.DemandPattern = null;
			rhs.Junctions.Add(junction);
			link.StartCode = junction.Code;
			(startLinkParter as IRevitLink).EndCode = junction.Code;
			link.StartCode = junction.Id;

			if (startLink.StartCode == link.Id)
			{
			startLink.StartCode = junction.Id;
			}
			else if (startLink.EndCode == link.Id)
			{
			startLink.EndCode = junction.Id;
			}
			allParterList.Add(junction);
			}

			allParterList = rhs.GetAllParters();
			var endLinkParter = allParterList.Find(x => x.Code == link.EndCode);
			if (endLinkParter is IRevitLink)
			var endLinkParter = allParterList.Find(x => x.Id == link.EndCode);
			if (endLinkParter is RevitLink endLink)
			{
			var junction = new Model.RevitJunction();
			junction.Id = Yw.Untity.UniqueHelper.CreateFromFirst("junction", allParterList.Select(x => x.Code).ToList());
			junction.Code = junction.Id;
			junction.Id = Yw.Untity.UniqueHelper.CreateFromFirst("junction", allParterList.Select(x => x.Id).ToList());
			junction.Name = UniqueHelper.CreateFromFirst("连接节点", allParterList.Select(x => x.Name).Distinct().ToList());
			junction.Flags = null;
			junction.ModelType = null;
			junction.Description = "水力修正时，自动添加";
			junction.Quality = link.EndQuality;
			junction.Position = link.EndPosition;
			junction.Elev = link.EndElev;
			junction.Elev = link.EndPosition.Z;
			junction.Demand = null;
			junction.DemandPattern = null;
			rhs.Junctions.Add(junction);
			link.EndCode = junction.Code;
			(endLinkParter as IRevitLink).StartCode = junction.Code;
			link.EndCode = junction.Id;
			if (endLink.StartCode == link.Id)
			{
			endLink.StartCode = junction.Id;
			}
			else if (endLink.EndCode == link.Id)
			{
			endLink.EndCode = junction.Id;
			}
			allParterList.Add(junction);
			}
			}
			return true;
			}



			}
			}