GplotGraphParse.cs 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386
  1. /*-------------------------------------------------------------------------
  2. * 功能描述:GplotGraphParse
  3. * 作者:xulisong
  4. * 创建时间: 2019/2/14 17:51:58
  5. * 版本号:v1.0
  6. * -------------------------------------------------------------------------*/
  7. using System;
  8. using System.Collections.Generic;
  9. using System.Linq;
  10. using System.Text;
  11. using System.Threading.Tasks;
  12. using Autodesk.Revit.DB;
  13. using SAGA.DotNetUtils.Data;
  14. using SAGA.RevitUtils;
  15. using SAGA.RevitUtils.Data.Graph;
  16. using SAGA.RevitUtils.Extends;
  17. namespace SAGA.GplotRelationComputerManage
  18. {
  19. /// <summary>
  20. /// 拓扑图解析
  21. /// </summary>
  22. public class GplotGraphParse
  23. {
  24. public GplotGraphParse(GplotGraphSetting setting)
  25. {
  26. Setting = setting;
  27. }
  28. #region 属性相关
  29. /// <summary>
  30. /// 系统解析设置
  31. /// </summary>
  32. public GplotGraphSetting Setting { get; private set; }
  33. #endregion
  34. /// <summary>
  35. /// 创建拓扑结构图
  36. /// </summary>
  37. /// <param name="startElements"></param>
  38. /// <returns></returns>
  39. public List<SystemGraph> CreateGplotGraphs(List<Element> startElements)
  40. {
  41. List<SystemGraph> arrays = new List<SystemGraph>();
  42. var newStartElements = startElements.Distinct(new ElementEqualComparer()).ToList();
  43. while (newStartElements.Any())
  44. {
  45. var baseElement = newStartElements[0];
  46. var graph = CreateGplotGraph(baseElement);
  47. var containElements = graph.GetRefElements();
  48. newStartElements = newStartElements.Except(containElements, new ElementEqualComparer()).ToList();
  49. arrays.Add(graph);
  50. }
  51. return arrays;
  52. }
  53. /// <summary>
  54. /// 创建拓扑结构图
  55. /// </summary>
  56. /// <param name="element"></param>
  57. /// <returns></returns>
  58. public SystemGraph CreateGplotGraph(Element element)
  59. {
  60. SystemGraph graph = GetOriginGraph(element);
  61. //节点处理
  62. ArrangeVertex(graph);
  63. //边处理
  64. ArrangeEdge(graph);
  65. return graph;
  66. }
  67. #region 解析原始图
  68. /// <summary>
  69. /// 创建原始的节点图,以起点元素为首个节点
  70. /// </summary>
  71. /// <param name="element"></param>
  72. /// <returns></returns>
  73. public SystemGraph GetOriginGraph(Element element)
  74. {
  75. return SystemGraphUtil.CreateGraph(element, Setting.IgnoredConnector, Setting.BreakElement);
  76. }
  77. #endregion
  78. #region 相关子方法
  79. #region 节点处理
  80. /// <summary>
  81. /// 整理点
  82. /// </summary>
  83. /// <param name="graph"></param>
  84. private void ArrangeVertex(SystemGraph graph)
  85. {
  86. #region 分析
  87. /*
  88. * 1、如果节点元素是一个管道,则将管道没有连接的那一个点创建一个“空间”设备,标记不可合并
  89. * 2、如果节点是设备或者特殊阀门,则标记不能合并,并加载物理世界相关设备信息
  90. * 3、如果一个点只有两条边,且该点可以被合并,则创建新边,关联上述两条边和点信息;删除旧的信息
  91. * 4、如果一条边的两个点,都是可合并,并过滤所有以这两个点为顶点的边,将这些信息合并成新的点;
  92. * 处理这种点融合边的情况,有两种方案:1,创建新点,将旧的点设置为新点的子节点。2、修改所有边的相依的节点Id为新Id
  93. * 方案各有利弊,第一种保留了初始状态,第二种以后遍历时方便
  94. */
  95. #endregion
  96. AttachVertexInfo(graph);
  97. CombineVertex(graph);
  98. }
  99. /// <summary>
  100. /// 附加节点信息
  101. /// </summary>
  102. /// <param name="graph"></param>
  103. private void AttachVertexInfo(SystemGraph graph)
  104. {
  105. var useVertexes = graph.GetBootVertexs();
  106. #region
  107. foreach (var systemVertex in useVertexes)
  108. {
  109. var data = systemVertex.Data;
  110. if (data.Any())
  111. {
  112. continue;
  113. }
  114. //理论上此时场景,有且仅有一个关联元素
  115. var useElement = data[0];
  116. #region 虚拟设备处理
  117. EquipmentItem item = new EquipmentItem();
  118. if (useElement is MEPCurve)
  119. {
  120. item.IsVirtual = true;
  121. var edges = graph.GetOutEdges(systemVertex.Id);
  122. if (edges.Count == 1)
  123. {
  124. var currentEdge = edges[0];
  125. var joinItems = JoinItem.GetJoinItems(useElement);
  126. foreach (var joinItem in joinItems)
  127. {
  128. if (joinItem.RefElement != null && currentEdge.Data.All(e => e.Id != joinItem.RefElement.Id))
  129. {
  130. //处理点边关联信息
  131. currentEdge.Data.Add(useElement);
  132. systemVertex.Data.Remove(useElement);
  133. systemVertex.CanCombine = false;
  134. //找到断头点
  135. var location = joinItem.RefConnector.Origin;
  136. var space = useElement.Document.GetSpaceAtPoint(location);
  137. if (space != null)
  138. {
  139. item.Id = space.Id.ToString();
  140. item.BimId = space.GetBimId();
  141. }
  142. else
  143. {
  144. item.Name = string.Format("空间{0}", location.ToString());
  145. }
  146. systemVertex.SetEquipment(item);
  147. break;
  148. }
  149. }
  150. }
  151. continue;
  152. }
  153. #endregion
  154. #region 真实设备处理
  155. item.Id = useElement.Id.ToString();
  156. item.BimId = useElement.GetBimId();
  157. if (MBIInfoUtil.IsEquipment(useElement))
  158. {
  159. systemVertex.CanCombine = false;
  160. systemVertex.SetEquipment(item);
  161. continue;
  162. }
  163. if (SystemCalcUtil.IsStartValve(useElement))
  164. {
  165. systemVertex.CanCombine = false;
  166. item.IsVirtual = true;
  167. systemVertex.SetEquipment(item);
  168. item.Name = useElement.GetFamily()?.Name;
  169. continue;
  170. }
  171. #endregion
  172. }
  173. #endregion
  174. }
  175. /// <summary>
  176. /// 合并节点
  177. /// </summary>
  178. /// <param name="graph"></param>
  179. public void CombineVertex(SystemGraph graph)
  180. {
  181. #region 以点为基础处理
  182. var useVertexes = graph.GetBootVertexs();
  183. foreach (var systemVertex in useVertexes)
  184. {
  185. if (!systemVertex.CanCombine)
  186. {
  187. continue;
  188. }
  189. var edges = graph.GetInEdges(systemVertex.Id);
  190. if (edges.Count != 2)
  191. {
  192. continue;
  193. }
  194. string startId = edges[0].GetAnotherVertex(systemVertex.Id);
  195. string endId = edges[1].GetAnotherVertex(systemVertex.Id);
  196. edges.ForEach(e => graph.RemoveEdge(e.Id));
  197. graph.RemoveVertex(systemVertex.Id);
  198. var newEdge = new SystemEdge(startId, endId);
  199. newEdge.Data = new SystemData(edges[0].Data);
  200. newEdge.Data.ExtendRefElements(edges[1].Data);
  201. newEdge.Data.ExtendRefElements(systemVertex.Data);
  202. graph.AddEdge(newEdge);
  203. }
  204. #endregion
  205. #region 以边为基础处理
  206. HandledMap map = new HandledMap();
  207. var useEdges = graph.GetBootEdges();
  208. for (int i = 0; i < useEdges.Count; i++)
  209. {
  210. var baseEdge = useEdges[i];
  211. if (map.GetHandled(baseEdge))
  212. continue;
  213. var startVertex = graph.GetBootStartVertex(baseEdge);
  214. var endVertex = graph.GetBootEndVertex(baseEdge);
  215. if (startVertex == null || endVertex == null)
  216. {
  217. continue;
  218. }
  219. if (!startVertex.CanCombine || !endVertex.CanCombine)
  220. {
  221. continue;
  222. }
  223. // 如果两个节点之下还有一条其他的包含设备的边,则该边的两点不能合并
  224. var refEdges = graph.GetEdges(baseEdge.StartVertex, baseEdge.EndVertex);
  225. #region 创建新的点
  226. List<Element> elements = new List<Element>();
  227. elements.AddRange(startVertex.Data);
  228. elements.AddRange(endVertex.Data);
  229. foreach (var elementsEdge in refEdges)
  230. {
  231. elements.AddRange(elementsEdge.Data);
  232. graph.RemoveEdge(elementsEdge.Id);
  233. map.SetHandled(elementsEdge.Id, true);
  234. }
  235. graph.RemoveVertex(startVertex.Id);
  236. graph.RemoveVertex(endVertex.Id);
  237. elements = elements.Distinct(new ElementEqualComparer()).ToList();
  238. SystemVertex newVertex = new SystemVertex(new SystemData(elements));
  239. newVertex = graph.AddVertex(newVertex);
  240. #endregion
  241. #region 更新关联边的关联点
  242. var vertexIds = new List<string>() { startVertex.Id, endVertex.Id };
  243. foreach (var vertexId in vertexIds)
  244. {
  245. var edges = graph.GetInEdges(vertexId);
  246. foreach (var systemEdge in edges)
  247. {
  248. var flag = systemEdge.ContainVertex(vertexId);
  249. if (flag == 0)
  250. {
  251. systemEdge.StartVertex = newVertex.Id;
  252. }
  253. else if (flag == 1)
  254. {
  255. systemEdge.EndVertex = newVertex.Id;
  256. }
  257. }
  258. }
  259. #endregion
  260. }
  261. #endregion
  262. }
  263. #endregion
  264. #region 边处理
  265. /// <summary>
  266. /// 整理边
  267. /// </summary>
  268. /// <param name="graph"></param>
  269. private void ArrangeEdge(SystemGraph graph)
  270. {
  271. //有向化处理
  272. DirectedEdge(graph);
  273. graph.IsDirection = true;
  274. //串并联处理
  275. EdgesArrayGraphUtil.GplotAnalyse(graph);
  276. }
  277. /// <summary>
  278. /// 确定流向
  279. /// </summary>
  280. /// <param name="graph"></param>
  281. private void DirectedEdge(SystemGraph graph)
  282. {
  283. #region 加载边的系统信息
  284. var originEdges = graph.Edges.Where(e => !e.Children.Any()).ToList();
  285. foreach (var originEdge in originEdges)
  286. {
  287. var refElements = originEdge.Data;
  288. //获取边系统类型
  289. originEdge.SystemName = (refElements.FirstOrDefault(e => e is MEPCurve) as MEPCurve)?.GetSystemTypeName();
  290. //根据系统类型和特殊设备确定旁通和补水;未完,待续
  291. var systemItem = Setting.RelationTypeShell.GetFirstMatchSystem(originEdge.SystemName);
  292. if (systemItem != null)
  293. {
  294. originEdge.EdgeCategory = systemItem.ContainEdgeTypes.FirstOrDefault();
  295. originEdge.FlowType = systemItem.FlowType == FlowType.In ? 2 : 1;
  296. }
  297. }
  298. #endregion
  299. #region 描述
  300. /*
  301. * 1、查找遍历起点
  302. * 2、根据起点遍历所有的节点,并调整节点的顺序
  303. */
  304. #endregion
  305. #region 获取定义端点
  306. var vertexes = graph.GetBootVertexs().Where(v => SystemCalcUtil.IsStartValveName(v.GetEquipment()?.Name)).ToList();
  307. if (!vertexes.Any())
  308. return;
  309. foreach (var systemVertex in vertexes)
  310. {
  311. var tempEdges = graph.GetInEdges(systemVertex.Id);
  312. if (tempEdges.Any())
  313. {
  314. var item = systemVertex.GetEquipment();
  315. if (item == null)
  316. {
  317. continue;
  318. }
  319. if (tempEdges.Any(e => e.FlowType == 2))
  320. {
  321. item.Name = "出口" + item.Id;
  322. }
  323. else
  324. {
  325. item.Name = "入口" + item.Id;
  326. }
  327. }
  328. }
  329. #endregion
  330. #region 确定开始点
  331. List<string> edgeIds = new List<string>();
  332. List<string> vertexIds = new List<string>();
  333. Queue<SystemVertex> queueVertexes = new Queue<SystemVertex>();
  334. vertexes.ForEach(v => queueVertexes.Enqueue(v));
  335. bool isDeepSearch = false;
  336. bool isStart = true;
  337. while (queueVertexes.Any())
  338. {
  339. var currentVertex = queueVertexes.Dequeue();
  340. if (!isDeepSearch)
  341. {
  342. isStart = (currentVertex.GetEquipment()?.Name ?? string.Empty).Contains("入口");
  343. isDeepSearch = vertexes.LastOrDefault().Id == currentVertex.Id;
  344. }
  345. vertexIds.Add(currentVertex.Id);
  346. var edges = graph.GetInEdges(currentVertex.Id);
  347. foreach (var systemEdge in edges)
  348. {
  349. if (edgeIds.Contains(systemEdge.Id))
  350. {
  351. continue;
  352. }
  353. edgeIds.Add(systemEdge.Id);
  354. if ((isStart && systemEdge.ContainVertex(currentVertex.Id) == 1)||(!isStart&& systemEdge.ContainVertex(currentVertex.Id) == 0))
  355. {
  356. systemEdge.Reverse();
  357. }
  358. var otherId = systemEdge.GetAnotherVertex(currentVertex.Id);
  359. if (!vertexIds.Contains(otherId))
  360. {
  361. var nextVertex = graph.FindVertex(otherId);
  362. if (nextVertex != null)
  363. {
  364. queueVertexes.Enqueue(nextVertex);
  365. }
  366. }
  367. }
  368. }
  369. #endregion
  370. }
  371. #endregion
  372. #endregion
  373. }
  374. }