SystemParseManager.cs 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370
  1. /*-------------------------------------------------------------------------
  2. * 功能描述:SystemParseManager
  3. * 作者:xulisong
  4. * 创建时间: 2019/1/10 14:34:23
  5. * 版本号:v1.0
  6. * -------------------------------------------------------------------------*/
  7. using System;
  8. using System.Collections.Generic;
  9. using System.Linq;
  10. using Autodesk.Revit.DB;
  11. using Autodesk.Revit.DB.Mechanical;
  12. using Autodesk.Revit.DB.Plumbing;
  13. using SAGA.RevitUtils;
  14. using SAGA.RevitUtils.Extends;
  15. using SAGA.RevitUtils.MEP;
  16. namespace SAGA.GplotRelationComputerManage
  17. {
  18. /// <summary>
  19. /// 系统解析管理
  20. /// </summary>
  21. public class SystemParseManager
  22. {
  23. #region 解析管路系统数据
  24. #region 通用基础方法
  25. /// <summary>
  26. /// 创建树节点
  27. /// </summary>
  28. /// <param name="startElement"></param>
  29. /// <param name="startConnector"></param>
  30. /// <param name="predicateEnd"></param>
  31. /// <returns></returns>
  32. public static ElementTreeNode CreateTreeNode(Element startElement, Connector startConnector,
  33. Predicate<Element> predicateEnd)
  34. {
  35. ElementTreeNode node = new ElementTreeNode();
  36. node.Current = startElement;
  37. List<ElementTreeNode> reference = new List<ElementTreeNode>();
  38. reference.Add(node);
  39. for (int i = 0; i < reference.Count; i++)
  40. {
  41. var baseNode = reference[i];
  42. List<Connector> connectors;
  43. if (i == 0 && startConnector != null)
  44. {
  45. connectors = new List<Connector> { startConnector };
  46. }
  47. else
  48. {
  49. connectors = baseNode.Current.GetAllConnectors().ToList();
  50. }
  51. foreach (var connector in connectors)
  52. {
  53. if (connector.Searchable())
  54. {
  55. var refConnectors = connector.GetReferenceConnectors()
  56. .Where(c => ConnectorType.Physical.HasFlag(c.ConnectorType)).ToList();
  57. foreach (var refConnector in refConnectors)
  58. {
  59. var refElement = refConnector.Owner;
  60. ElementTreeNode refNode = new ElementTreeNode();
  61. refNode.Current = refElement;
  62. refNode.StartLocation = refConnector.Origin;
  63. baseNode.Nodes.Add(refNode);
  64. if (predicateEnd != null && predicateEnd(refElement))
  65. {
  66. continue;
  67. }
  68. if (reference.All(e => e.Current.Id.IntegerValue != refElement.Id.IntegerValue))
  69. {
  70. reference.Add(refNode);
  71. }
  72. }
  73. }
  74. }
  75. }
  76. return node;
  77. }
  78. #endregion
  79. /// <summary>
  80. /// 构件系统连接节点
  81. /// </summary>
  82. /// <param name="etn">开始元素</param>
  83. /// <param name="domain"></param>
  84. /// <param name="endConditon">遍历中断条件,遇到指定条件的管道则停止遍历</param>
  85. /// <returns>树形节点中包好的Id信息</returns>
  86. public static List<int> BuildSystemNode(ElementTreeNode etn, Domain domain, Func<MEPCurve, bool> endConditon)
  87. {
  88. List<int> useIds = new List<int>();
  89. etn.GetAllNodes().ForEach(n =>
  90. {
  91. if (!n.IsLeaf&&n.Current != null)
  92. {
  93. useIds.Add(n.Current.Id.IntegerValue);
  94. }
  95. });
  96. var leaves = etn.GetLeaves();
  97. foreach (var elementTreeNode in leaves)
  98. {
  99. BuildSystemNode(elementTreeNode, domain, useIds, endConditon);
  100. }
  101. return useIds;
  102. }
  103. private static void BuildSystemNode(ElementTreeNode etn, Domain domain, List<int> useIds, Func<MEPCurve, bool> endConditon)
  104. {
  105. var useElement = etn.Current;
  106. #region 预判退出
  107. if (useElement == null)
  108. {
  109. return;
  110. }
  111. if (useIds.Any(id => id == useElement.Id.IntegerValue))
  112. {
  113. return;
  114. }
  115. #endregion
  116. useIds.Add(useElement.Id.IntegerValue);
  117. var connectors = useElement.GetConnectors(domain);
  118. foreach (var baseConnector in connectors)
  119. {
  120. if (!baseConnector.Searchable())
  121. continue;
  122. var refConnectors = baseConnector.GetReferenceConnectors()
  123. .Where(c => ConnectorType.Physical.HasFlag(c.ConnectorType)).ToList();
  124. foreach (var refConnector in refConnectors)
  125. {
  126. var refElement = refConnector.Owner;
  127. if (useIds.Any(id => id == refElement.Id.IntegerValue))
  128. {
  129. continue;
  130. }
  131. //初始化当前节点,未必一定加入集合,为了下面代码书写方便,先进性初始化
  132. ElementTreeNode currentNode = new ElementTreeNode()
  133. {
  134. Current = refElement,
  135. StartLocation = refConnector.Origin
  136. };
  137. if (refElement is MEPCurve mepCurve)
  138. {
  139. //优先判定系统,再进行立管相关逻辑的处理;如果系统不兼容则直接退出遍历
  140. //var systemName=mepCurve.GetSystemTypeName();
  141. if (endConditon != null && endConditon(mepCurve))
  142. {
  143. continue;
  144. }
  145. if (SystemCalcUtil.IsStart(mepCurve))
  146. {
  147. currentNode.ElementTypeName = AcType.MarkStandPipe;
  148. etn.AddChild(currentNode);
  149. useIds.Add(refElement.Id.IntegerValue);
  150. continue;
  151. }
  152. }
  153. else if (refElement is FamilyInstance fi)
  154. {
  155. //非管线,遇到结束标志,加入当前子节点,但不在进行递归;
  156. if (SystemCalcUtil.IsStart(fi))
  157. {
  158. currentNode.ElementTypeName = AcType.Valve;
  159. etn.AddChild(currentNode);
  160. useIds.Add(refElement.Id.IntegerValue);
  161. continue;
  162. }
  163. }
  164. //useIds的控制:跳出时,直接加入UseIds。继续遍历的,在遍历函数中加入
  165. etn.AddChild(currentNode);
  166. BuildSystemNode(currentNode, domain, useIds, endConditon);
  167. }
  168. }
  169. }
  170. #endregion
  171. #region 创建绘图数据相关
  172. /// <summary>
  173. /// 构件绘图数据
  174. /// </summary>
  175. /// <param name="etn"></param>
  176. /// <returns></returns>
  177. public static SystemDrawItems CreateDrawing(ElementTreeNode etn)
  178. {
  179. #region 描述
  180. /*
  181. *读取几何信息
  182. * 1、管道,管件直接按connector连线获取。
  183. * 2、设备,可能出现多个connector,确定有效的连线;
  184. * 最终:如果是管道,通过本身的connector生成线。如果是familyInstance通过定位点连接,父节点和子节点
  185. * 3、具体名字相关内容,后续操作中添加
  186. */
  187. #endregion
  188. List<SystemCurveItem> curveItems = new List<SystemCurveItem>();
  189. List<SystemPointItem> pointItems = new List<SystemPointItem>();
  190. Queue<ElementTreeNode> nodeQueue = new Queue<ElementTreeNode>() ;
  191. nodeQueue.Enqueue(etn);
  192. while (nodeQueue.Any())
  193. {
  194. #region 控制验证
  195. var currentNode = nodeQueue.Dequeue();
  196. if (currentNode == null)
  197. continue;
  198. var element = currentNode.Current;
  199. if (element == null)
  200. continue;
  201. #endregion
  202. if (element is MEPCurve mepCurve)
  203. {
  204. #region 联通线处理
  205. Curve curve = mepCurve.GetCurve();
  206. var xyzs = curve.Tessellate().Select(xyz => xyz.XYZToPoint());
  207. SystemCurveItem curveItem = new SystemCurveItem();
  208. curveItem.Points.AddRange(xyzs.ToList());
  209. curveItem.RefId = element.Id.IntegerValue;
  210. curveItems.Add(curveItem);
  211. #endregion
  212. #region 点信息处理
  213. if (SystemCalcUtil.IsStart(mepCurve))
  214. {
  215. SystemPointItem point = new SystemPointItem();
  216. point.Point = mepCurve.GetCurve().StartPoint().XYZToPoint();
  217. point.RefId = mepCurve.Id.IntegerValue;
  218. point.IsVirtual = true;
  219. point.EquipmentType = PointItemType.StandPipe.ToString();
  220. pointItems.Add(point);
  221. }
  222. #endregion
  223. }
  224. else if (element is FamilyInstance fiEq)
  225. {
  226. #region 获取引用点
  227. List<XYZ> usePoints = new List<XYZ>();
  228. if (currentNode.StartLocation != null)
  229. {
  230. usePoints.Add(currentNode.StartLocation);
  231. }
  232. foreach (ElementTreeNode childNode in currentNode.Nodes)
  233. {
  234. var usePoint = childNode.StartLocation;
  235. if (usePoint != null)
  236. {
  237. usePoints.Add(usePoint);
  238. }
  239. }
  240. #endregion
  241. var location = element.GetBoxCenter().XYZToPoint();
  242. #region 根据定位点并创建线条
  243. foreach (var usePoint in usePoints)
  244. {
  245. SystemCurveItem curveItem = new SystemCurveItem();
  246. curveItem.Points.Add(location);
  247. curveItem.Points.Add(usePoint.XYZToPoint());
  248. curveItem.RefId = element.Id.IntegerValue;
  249. curveItems.Add(curveItem);
  250. }
  251. #endregion
  252. #region 判断是否是设备
  253. //先初始化不一定加入
  254. SystemPointItem point = new SystemPointItem();
  255. point.Point = location;
  256. point.RefId = fiEq.Id.IntegerValue;
  257. point.BimId = element.GetBimId();
  258. if (MBIInfoUtil.IsEquipment(fiEq))
  259. {
  260. point.Name = string.Empty;
  261. point.EquipmentType = PointItemType.Equipment.ToString();
  262. pointItems.Add(point);
  263. }
  264. else if (SystemCalcUtil.IsStart(fiEq))
  265. {
  266. point.Name = string.Empty;
  267. point.EquipmentType = PointItemType.StartValve.ToString(); ;
  268. point.IsVirtual = true;
  269. pointItems.Add(point);
  270. }
  271. #endregion
  272. }
  273. else if (element is Space)
  274. {
  275. SystemPointItem point = new SystemPointItem();
  276. point.Point = element.GetLocationPoint().XYZToPoint();
  277. point.RefId = element.Id.IntegerValue;
  278. point.EquipmentType = PointItemType.Space.ToString();
  279. point.IsVirtual = true;
  280. pointItems.Add(point);
  281. }
  282. currentNode.Nodes.ForEach(e => nodeQueue.Enqueue(e));
  283. }
  284. SystemDrawItems drawItems = new SystemDrawItems();
  285. drawItems.Curves = curveItems;
  286. drawItems.Points = pointItems;
  287. return drawItems;
  288. }
  289. #endregion
  290. #region 创建关系数据相关
  291. public static List<EquipmentNode> CreateRelation(ElementTreeNode etn)
  292. {
  293. #region 描述
  294. /*
  295. * 1、将树形结构初步处理,修剪成存留设备之间的关系
  296. */
  297. #endregion
  298. return ConvertEquipmentNodes(etn);
  299. }
  300. /// <summary>
  301. /// 将elment树转换成设备节点类
  302. /// </summary>
  303. /// <param name="etn"></param>
  304. /// <returns></returns>
  305. private static List<EquipmentNode> ConvertEquipmentNodes(ElementTreeNode etn)
  306. {
  307. List<EquipmentNode> nodes = new List<EquipmentNode>();
  308. if (TryGetNode(etn.Current,out EquipmentNode outNode))
  309. {
  310. nodes.Add(outNode);
  311. return nodes;
  312. }
  313. foreach (var elementTreeNode in etn.Nodes)
  314. {
  315. nodes.AddRange(ConvertEquipmentNodes(elementTreeNode));
  316. }
  317. return nodes;
  318. }
  319. /// <summary>
  320. /// 获取element对应节点
  321. /// </summary>
  322. /// <param name="element">输入element</param>
  323. /// <param name="outNode">成功获取时,node真实值</param>
  324. /// <returns>成功获取</returns>
  325. private static bool TryGetNode(Element element,out EquipmentNode outNode)
  326. {
  327. bool flag = false;
  328. EquipmentNode node = new EquipmentNode();
  329. node.RevitId = element.Id.IntegerValue;
  330. node.BimId = element.GetBimId();
  331. if (element is Space space)
  332. {
  333. node.Category = PointItemType.Space.ToString();
  334. }
  335. else if (element is Pipe&& SystemCalcUtil.IsStart(element))
  336. {
  337. node.Category = PointItemType.StandPipe.ToString();
  338. }
  339. else if (element is FamilyInstance)
  340. {
  341. if (MBIInfoUtil.IsEquipment(element))
  342. {
  343. node.Category = PointItemType.Equipment.ToString();
  344. }
  345. else if (SystemCalcUtil.IsStart(element))
  346. {
  347. node.Category = PointItemType.StartValve.ToString();
  348. }
  349. }
  350. flag = !string.IsNullOrEmpty(node.Category);
  351. outNode = flag ? node : null;
  352. return flag;
  353. }
  354. #endregion
  355. }
  356. }