FloorSystemItem.cs 21 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560
  1. /*-------------------------------------------------------------------------
  2. * 功能描述:FloorSystemItems
  3. * 作者:xulisong
  4. * 创建时间: 2019/1/4 17:50:04
  5. * 版本号:v1.0
  6. * -------------------------------------------------------------------------*/
  7. using System.Collections.Generic;
  8. using System.Linq;
  9. using System.Text.RegularExpressions;
  10. using System.Windows.Media;
  11. using Autodesk.Revit.DB;
  12. using Autodesk.Revit.DB.Mechanical;
  13. using Autodesk.Revit.DB.Plumbing;
  14. using SAGA.DotNetUtils.Data;
  15. using SAGA.GplotRelationComputerManage.ColdRoom;
  16. using SAGA.Models;
  17. using SAGA.Models.GplotElement;
  18. using SAGA.Models.Graphs;
  19. using SAGA.RevitUtils;
  20. using SAGA.RevitUtils.Extends;
  21. using SAGA.RevitUtils.MEP;
  22. namespace SAGA.GplotRelationComputerManage
  23. {
  24. public class FloorSystemItem
  25. {
  26. #region 构造函数
  27. /// <summary>
  28. /// 初始化解析类
  29. /// </summary>
  30. /// <param name="doc"></param>
  31. public FloorSystemItem(Document doc)
  32. {
  33. Document = doc;
  34. InitData();
  35. }
  36. #endregion
  37. #region 属性相关
  38. /// <summary>
  39. /// 关联模型信息
  40. /// </summary>
  41. public Document Document { get; private set; }
  42. /// <summary>
  43. /// 使用关联标高
  44. /// </summary>
  45. public Level UseLevel { get; private set; }
  46. private bool m_IsInited;
  47. /// <summary>
  48. /// 初始化数据
  49. /// </summary>
  50. private void InitData()
  51. {
  52. if (m_IsInited)
  53. return;
  54. UseLevel = Document.GetUseView()?.GenLevel;
  55. m_IsInited = true;
  56. }
  57. #endregion
  58. #region 开始节点获取
  59. /// <summary>
  60. /// 缓存信息
  61. /// </summary>
  62. private List<StringFlag<ElementTreeNode>> m_StartNodes;
  63. /// <summary>
  64. /// 按系统获取开始节点
  65. /// </summary>
  66. /// <returns></returns>
  67. private List<StringFlag<ElementTreeNode>> GetStartNodes()
  68. {
  69. if (m_StartNodes != null)
  70. {
  71. //返回没有处理过的节点信息
  72. return m_StartNodes.Where(s => !s.Handled).ToList();
  73. }
  74. List<StringFlag<ElementTreeNode>> startNodes = new List<StringFlag<ElementTreeNode>>();
  75. var doc = Document;
  76. #region 立管处理
  77. /*
  78. * 暂时认定,一个立管之关联一个系统
  79. */
  80. var verticalPipes = doc.GetElements<MEPCurve>().Where(p => SystemCalcUtil.IsStart(p) && p.IsVerticalPipe());
  81. foreach (var verticalPipe in verticalPipes)
  82. {
  83. ElementTreeNode node = new ElementTreeNode();
  84. node.Current = verticalPipe;
  85. var systemTypeName = verticalPipe.GetSystemTypeName();
  86. startNodes.Add(new StringFlag<ElementTreeNode>(systemTypeName, node));
  87. }
  88. #endregion
  89. #region 特殊阀门处理
  90. ElementCategoryFilter pipeFilter = new ElementCategoryFilter(BuiltInCategory.OST_PipeAccessory);
  91. ElementCategoryFilter ductFilter = new ElementCategoryFilter(BuiltInCategory.OST_DuctAccessory);
  92. ElementFilter filter = new LogicalOrFilter(pipeFilter, ductFilter);
  93. var specialValves = doc.FilterElements(filter).Where(f => SystemCalcUtil.IsStart(f));
  94. foreach (var familyInstance in specialValves)
  95. {
  96. var connector = familyInstance.GetAllConnectors()
  97. .FirstOrDefault(c => Regex.IsMatch(c.Description, AppSetting.EndFlag));
  98. if (connector == null)
  99. continue;
  100. var node = SystemParseManager.CreateTreeNode(familyInstance, connector, e => e is MEPCurve);
  101. var useMepCurve = node.GetLeaves().FirstOrDefault()?.Current as MEPCurve;
  102. if (useMepCurve == null)
  103. continue;
  104. var systemTypeName = useMepCurve.GetSystemTypeName();
  105. startNodes.Add(new StringFlag<ElementTreeNode>(systemTypeName, node));
  106. }
  107. #endregion
  108. return m_StartNodes = startNodes;
  109. }
  110. #endregion
  111. #region 设备节点获取
  112. /// <summary>
  113. /// 模型中包含的设备
  114. /// </summary>
  115. public Dictionary<string, List<FamilyInstance>> RevitEquipments { get; private set; }
  116. /// <summary>
  117. /// 通过设备类型获取相关设备
  118. /// </summary>
  119. /// <returns></returns>
  120. private List<FamilyInstance> GetEquipments(string category)
  121. {
  122. if (RevitEquipments == null)
  123. {
  124. var doc = Document;
  125. var fies = doc.FilterElements<FamilyInstance>();
  126. List<StringFlag<FamilyInstance>> original = new List<StringFlag<FamilyInstance>>();
  127. foreach (var familyInstance in fies)
  128. {
  129. var familyName = familyInstance.GetFamily().Name;
  130. if (string.IsNullOrEmpty(familyName))
  131. continue;
  132. var match = Regex.Match(familyName, @"^(?:((?:[A-Z][A-Z]){2,3})\s*-\s*\S*)");
  133. if (match.Success)
  134. {
  135. original.Add(new StringFlag<FamilyInstance>(match.Groups[1].ToString(), familyInstance));
  136. }
  137. }
  138. RevitEquipments = original.GroupBy(f => f.Flag)
  139. .ToDictionary(g => g.Key, g => g.ToList().Select(f => f.Instance).ToList());
  140. }
  141. RevitEquipments.TryGetValue(category, out List<FamilyInstance> result);
  142. return result ?? new List<FamilyInstance>();
  143. }
  144. #endregion
  145. #region 数据解析方法
  146. /// <summary>
  147. /// 解析当前楼层系统数据
  148. /// </summary>
  149. /// <param name="context"></param>
  150. public void Parse(SystemComputerContext context)
  151. {
  152. if (UseLevel == null)
  153. return;
  154. var doc = Document;
  155. var relations = context.Relations;
  156. foreach (var relation in relations)
  157. {
  158. var shell = context.RelationShells.GetItem(relation);
  159. if (shell.IsPipeSystem())
  160. {
  161. ParsePipe(context, shell);
  162. }
  163. else
  164. {
  165. ParseDuct(context, shell);
  166. }
  167. }
  168. }
  169. #region 水系统解析
  170. public void ParsePipe(SystemComputerContext context, RelationTypeShell relationSetting)
  171. {
  172. Domain useDomain = Domain.DomainPiping;
  173. var relationType = relationSetting.RelationItem.Type;
  174. List<FloorDrawRecord> drawRecords = new List<FloorDrawRecord>();
  175. List<FloorRelationRecord> relationRecords = new List<FloorRelationRecord>();
  176. List<Element> roomStartElements = new List<Element>();
  177. #region 计算拓扑树形结构
  178. /*
  179. * 1、遍历开始点的限制:特殊阀门,指定标注的Connector;立管,已连接连接件;空间,相交风管元素;
  180. * 2、根据拓扑图关联的对象信息,找到系统关联的设备生成节点。如果没有遍历到要独立生成
  181. * 3、要不要显示端头管所在空间的位置
  182. */
  183. var startNodes = GetStartNodes();
  184. List<int> useIds = new List<int>();
  185. List<MEPCurve> verticalMepCurves = new List<MEPCurve>();
  186. for (int i = 0; i < startNodes.Count; i++)
  187. {
  188. var startNode = startNodes[i];
  189. var useRelation = relationSetting.GetFirstMatchSystem(startNode.Flag);
  190. if (useRelation == null)
  191. continue;
  192. if (startNode.Instance.Current is FamilyInstance)
  193. {
  194. roomStartElements.Add(startNode.Instance.Current);
  195. }
  196. if (useIds.Any(id => id == startNode.Instance.Current.Id.IntegerValue))
  197. {
  198. continue;
  199. }
  200. if (startNode.Instance.Current is MEPCurve mepCurve)
  201. {
  202. verticalMepCurves.Add(mepCurve);
  203. }
  204. var tempIds = SystemParseManager.BuildSystemNode(startNode.Instance, useDomain,
  205. (m => !startNode.Flag.Equals(m.GetSystemTypeName())));
  206. startNode.Instance.PipeSystemTypeName = startNode.Flag;
  207. BuildElementNodeData(context, startNode.Instance);
  208. useIds.AddRange(tempIds);
  209. startNode.Handled = true;
  210. //可以清空Leaves的子节点
  211. #region 整理原始数据
  212. //判断是否有设备节点,不进行数据处理
  213. var useNode = startNode.Instance;
  214. //var firstEquipment = useNode.FirstOrDefault(t => MBIInfoUtil.IsEquipment(t.Current));
  215. //要不要以这个为判定条件,图形可以画出,关系肯定是没有的
  216. //if (firstEquipment != null)
  217. if (useNode.Nodes.Any())
  218. {
  219. //存在设备则保存信息
  220. var drawRecord = BuildFloorDrawRecord(relationSetting, useNode);
  221. drawRecord.SystemName = startNode.Flag;
  222. drawRecords.Add(drawRecord);
  223. var relationRecord = BuildFloorRelationRecord(relationSetting, useNode);
  224. relationRecords.Add(relationRecord);
  225. }
  226. #endregion
  227. }
  228. #region 解析机房数据
  229. var useEquipments = ParseMachineRoomData(context, relationSetting, roomStartElements);
  230. useEquipments = useEquipments.Distinct().ToList();
  231. #endregion
  232. //获取没有使用过的对象节点
  233. List<FamilyInstance> singleInstances =
  234. relationSetting.RelationItem.Objects.SelectMany(o => GetEquipments(o.Type)).ToList();
  235. for (int i = 0; i < singleInstances.Count; i++)
  236. {
  237. var useInstance = singleInstances[i];
  238. if (useIds.Any(id => id == useInstance.Id.IntegerValue) || useEquipments.Any(id => id == useInstance.Id.ToString()))
  239. {
  240. continue;
  241. }
  242. var connectors = useInstance.GetAllConnectors();
  243. foreach (var connector in connectors)
  244. {
  245. if (connector.Domain != useDomain)
  246. {
  247. continue;
  248. }
  249. var startNode = SystemParseManager.CreateTreeNode(useInstance, connector, e => e is MEPCurve);
  250. var useMepCurve = startNode.GetLeaves().FirstOrDefault()?.Current as MEPCurve;
  251. if (useMepCurve == null)
  252. continue;
  253. var systemTypeName = useMepCurve.GetSystemTypeName();
  254. if (!relationSetting.IsMatchSystem(systemTypeName))
  255. {
  256. continue;
  257. }
  258. //var startNode = new ElementTreeNode() { Current = useInstance };
  259. var tempIds = SystemParseManager.BuildSystemNode(startNode, useDomain,
  260. (m => !systemTypeName.Equals(m.GetSystemTypeName())));
  261. startNode.PipeSystemTypeName = systemTypeName;
  262. BuildElementNodeData(context, startNode);
  263. useIds.AddRange(tempIds);
  264. #region 生成绘图,计算数据
  265. //解析数据,找管道定系统,管道找不到,系统名为"关联类型-未知"
  266. var drawRecord = BuildFloorDrawRecord(relationSetting, startNode);
  267. drawRecord.SystemName = systemTypeName;
  268. drawRecords.Add(drawRecord);
  269. var relationRecord = BuildFloorRelationRecord(relationSetting, startNode);
  270. relationRecords.Add(relationRecord);
  271. #endregion
  272. }
  273. }
  274. #endregion
  275. //增加立管数据
  276. ComputerVerticalPipes(UseLevel, verticalMepCurves, context, relationSetting);
  277. context[relationType].FloorDrawRecords.AddRange(drawRecords);
  278. context[relationType].FloorRelationRecords.AddRange(relationRecords);
  279. }
  280. #endregion
  281. #region 风系统解析
  282. public void ParseDuct(SystemComputerContext context, RelationTypeShell relationSetting)
  283. {
  284. }
  285. #endregion
  286. #endregion
  287. #region 解析立管
  288. /*
  289. * 1、解析立管需要考虑,竖直风管,水管,空间的情况;
  290. *2、将各层数据汇总,才能统一计算立管的相关关系数据
  291. */
  292. private void ComputerVerticalPipes(Level refLevel, List<MEPCurve> mepCurves, SystemComputerContext context, RelationTypeShell relationSetting)
  293. {
  294. var result = new List<VerticalPipe>();
  295. var spaces = Document.GetElements<SpatialElement>(BuiltInCategory.OST_MEPSpaces).OfType<Space>();
  296. var level = refLevel;
  297. var relationType = relationSetting.RelationItem.Type;
  298. var currentLevelName = MBIInfoUtil.GetFloorNameByLevel(level.Name);
  299. foreach (var pipe in mepCurves)
  300. {
  301. if (pipe == null)
  302. continue;
  303. var vp = new VerticalPipe
  304. {
  305. Id = pipe.Id.IntegerValue.ToString(),
  306. LevelName = currentLevelName,
  307. LevelElevation = level.Elevation,
  308. UpPoint3D = PointConverter.XYZToPoint3D(pipe.GetVerticalTopPoint()),
  309. DownPoint3D = PointConverter.XYZToPoint3D(pipe.GetVerticalBottomPoint()),
  310. PipeSytemType = pipe.GetSystemTypeName()
  311. };
  312. #region 获取立管关联空间
  313. var locationCurve = pipe.GetLocationCurve();
  314. var midPoint = (locationCurve.StartPoint() + locationCurve.EndPoint()) / 2;
  315. Space refSpace = spaces.FirstOrDefault(s => s.IsPointInSpace(midPoint)); //关联
  316. var display = context.GetSpaceDisplay(refSpace, out string tip);
  317. vp.Display = $"{display}:{pipe.Id.IntegerValue.ToString()}";
  318. vp.DisplayTip = tip ?? string.Empty;
  319. #endregion
  320. result.Add(vp);
  321. }
  322. LevelData levelData = new LevelData()
  323. {
  324. Id = refLevel.Id.ToString(),
  325. Name = MBIInfoUtil.GetFloorNameByLevel(refLevel.Name)
  326. };
  327. context[relationType].VerticalPipes.AddRange(result);
  328. context[relationType].Levels.Add(levelData);
  329. }
  330. #endregion
  331. #region 保存数据类对象创建
  332. private string GetUnknownSystemName(RelationTypeShell relationShell)
  333. {
  334. return relationShell.RelationItem?.Name + "---未知";
  335. }
  336. private FloorDrawRecord BuildFloorDrawRecord(RelationTypeShell relationShell, ElementTreeNode node)
  337. {
  338. var floorDraw = new FloorDrawRecord();
  339. floorDraw.SetFloorLevel(UseLevel);
  340. floorDraw.RelationType = relationShell.RelationItem.Type;
  341. floorDraw.DrawIems = SystemParseManager.CreateDrawing(node) ?? new SystemDrawItems();
  342. return floorDraw;
  343. }
  344. private FloorRelationRecord BuildFloorRelationRecord(RelationTypeShell relationShell, ElementTreeNode node)
  345. {
  346. var floorRelation = new FloorRelationRecord();
  347. floorRelation.SetFloorLevel(UseLevel);
  348. floorRelation.RelationType = relationShell.RelationItem.Type;
  349. floorRelation.RelationItems = SystemParseManager.CreateRelation(node) ?? new List<BinaryRelationItem>();
  350. return floorRelation;
  351. }
  352. #endregion
  353. #region 初始化名称,分类
  354. /// <summary>
  355. /// 初始化节点扩展数据
  356. /// </summary>
  357. /// <param name="context"></param>
  358. /// <param name="node"></param>
  359. private void BuildElementNodeData(SystemComputerContext context, ElementTreeNode node)
  360. {
  361. Queue<ElementTreeNode> nodeQueue = new Queue<ElementTreeNode>();
  362. nodeQueue.Enqueue(node);
  363. while (nodeQueue.Any())
  364. {
  365. #region 控制验证
  366. var currentNode = nodeQueue.Dequeue();
  367. if (currentNode == null)
  368. continue;
  369. var element = currentNode.Current;
  370. if (element == null)
  371. continue;
  372. #endregion
  373. if (element is FamilyInstance fiEq)
  374. {
  375. #region 判断是否是设备
  376. if (MBIInfoUtil.IsEquipment(fiEq))
  377. {
  378. var equipItem = context.EquipmentItems.GetItem(fiEq.GetBimId());
  379. NodeExtendData data = new NodeExtendData();
  380. if (equipItem != null)
  381. {
  382. data.Name = equipItem.GetDisplay();
  383. data.Category = equipItem.Category;
  384. }
  385. else
  386. {
  387. data.Name = fiEq.GetFamily()?.Name;
  388. }
  389. data.SystemType = node.PipeSystemTypeName;
  390. currentNode.Tag = data;
  391. }
  392. #endregion
  393. }
  394. else if (element is Space revitSpace)
  395. {
  396. var space = context.Rooms.GetItem(element.GetBimId());
  397. NodeExtendData data = new NodeExtendData();
  398. if (space != null)
  399. {
  400. data.Name = space.GetDisplay();
  401. }
  402. else
  403. {
  404. data.Name = revitSpace.Name;
  405. }
  406. data.SystemType = node.PipeSystemTypeName;
  407. currentNode.Tag = data;
  408. }
  409. currentNode.Nodes.ForEach(e => nodeQueue.Enqueue(e));
  410. }
  411. }
  412. #endregion
  413. #region 解析机房数据
  414. /// <summary>
  415. /// 解析机房数据
  416. /// </summary>
  417. /// <param name="context"></param>
  418. /// <param name="relationSetting"></param>
  419. /// <param name="startElements"></param>
  420. private List<string> ParseMachineRoomData(SystemComputerContext context, RelationTypeShell relationSetting,
  421. List<Element> startElements)
  422. {
  423. /*
  424. *1、解析过程中尽量少处理和后续相关的数据
  425. * 2、设备整理,带缓存的设备信息读取
  426. */
  427. List<string> useEquipments = new List<string>();
  428. var relationType = relationSetting.RelationItem.Type;
  429. SystemParse parse = new SystemParse(new SystemParseSetting(relationSetting));
  430. List<Element> useStartElements = new List<Element>(startElements);
  431. var arrays = parse.Execute(useStartElements);
  432. arrays.RemoveAll(c => c.GetAvailableVertexes(null).All(v => !v.IsRealEquipment()));
  433. #region 生成图形数据
  434. ColdRoomManager manager = new ColdRoomManager();
  435. var doc = manager.CreateDocument(new List<ElementEdgesArray>(arrays));
  436. var drawData = SystemParseManager.CreateRoomDrawing(doc);
  437. MachineRoomDrawRecord record = new MachineRoomDrawRecord();
  438. record.RelationName = relationSetting.RelationItem.Name;
  439. record.DrawIems = drawData;
  440. context[relationType].MachineRoomDrawRecords.Add(record);
  441. #endregion
  442. #region 生成关系数据
  443. var relations = manager.CreateRelation(arrays);
  444. MachineRoomRelationRecord relationRecord = new MachineRoomRelationRecord();
  445. relationRecord.RelationName = relationSetting.RelationItem.Name;
  446. foreach (var item in relations)
  447. {
  448. var node = new BinaryRelationItem();
  449. node.From = new EquipmentNode() { RevitId = item.EquipmentItem1.Id };
  450. node.To = new EquipmentNode() { RevitId = item.EquipmentItem2.Id };
  451. node.RelationType = item.LinkType;
  452. relationRecord.RelationItems.Add(node);
  453. var newIds = new List<string>() {item.EquipmentItem1.Id, item.EquipmentItem2.Id};
  454. useEquipments.AddRange(newIds);
  455. }
  456. context[relationType].MachineRoomRelationRecords.Add(relationRecord);
  457. #endregion
  458. return useEquipments;
  459. }
  460. #endregion 解析机房数据
  461. }
  462. }