RelationDataUtil.cs 9.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252
  1. 
  2. using System;
  3. using System.Collections.Generic;
  4. using System.Linq;
  5. using System.Text;
  6. using System.Threading.Tasks;
  7. using SAGA.DotNetUtils.Data;
  8. using SAGA.GplotRelationComputerManage;
  9. namespace SAGA.GplotManage
  10. {
  11. /// <summary>
  12. /// 关系数据处理
  13. /// </summary>
  14. public class RelationDataUtil
  15. {
  16. /// <summary>
  17. /// 上传关系数据
  18. /// </summary>
  19. /// <param name="relationData"></param>
  20. /// <returns></returns>
  21. public static List<ReleateData> BuildRelations(LoadRelationData relationData)
  22. {
  23. #region 说明
  24. /*
  25. * 数据关联项:
  26. * 机房设备---特殊阀门
  27. * 特殊阀门---立管
  28. * 立管--立管
  29. * 立管---平面设备;由此=》机房设备---平面设备
  30. */
  31. #endregion
  32. List<ReleateData> result = new List<ReleateData>();
  33. List<BinaryRelationItem> roomRelations = new List<BinaryRelationItem>();
  34. List<BinaryRelationItem> floorRelations = new List<BinaryRelationItem>();
  35. #region 机房关系数据
  36. var machineRoomData = relationData.MachineRoomRelationRecords;
  37. foreach (var machineRelation in machineRoomData)
  38. {
  39. foreach (var item in machineRelation.RelationItems)
  40. {
  41. if (item.IsEquipmentLink())
  42. {
  43. result.Add(CreateRelationData(item));
  44. }
  45. else
  46. {
  47. roomRelations.Add(item);
  48. }
  49. }
  50. }
  51. #endregion
  52. #region 平面关系数据
  53. foreach (var floorRelation in relationData.FloorRelationRecords)
  54. {
  55. foreach (var item in floorRelation.RelationItems)
  56. {
  57. if (item.IsEquipmentLink())
  58. {
  59. result.Add(CreateRelationData(item));
  60. }
  61. else
  62. {
  63. floorRelations.Add(item);
  64. }
  65. }
  66. }
  67. #endregion
  68. var verticalSets = relationData.VerticalRelationRecords;
  69. var cacheFloorDatas = new List<BinaryRelationItem>(floorRelations);
  70. List < StringFlag <VerticalRelationRecord>> verticalNodes = new List<StringFlag<VerticalRelationRecord>>();
  71. #region 初始化立管节点
  72. foreach (var verticalRelationRecord in verticalSets)
  73. {
  74. var newId = Guid.NewGuid().ToString();
  75. verticalNodes.Add(new StringFlag<VerticalRelationRecord>()
  76. { Flag = newId, Instance = verticalRelationRecord });
  77. }
  78. #endregion
  79. #region 构建端部临时边集
  80. var endGraph = CreateGraph(verticalNodes, cacheFloorDatas);
  81. #endregion
  82. var roomItems = machineRoomData.SelectMany(c => c.RelationItems).ToList();
  83. var sourceGraph = CreateGraph(verticalNodes, roomItems);
  84. //连接类型,以机房端类型为基准;
  85. #region 描述
  86. /*
  87. * 处理数据结构两种:
  88. * 源----》特殊阀门(断开点)---》端
  89. * 源----》特殊阀门(断开点)---》立管----》端
  90. * 根据立管数据,在机房里找到机房设备数据,在平面找到平面数据
  91. */
  92. #endregion
  93. #region 机房和平面关联
  94. foreach (var verticalNode in verticalNodes)
  95. {
  96. var startNode = sourceGraph.FindVertex(verticalNode.Flag);
  97. #region 源路径
  98. var sourcePathNodes = sourceGraph.GetPaths2(startNode, end =>
  99. {
  100. if (end.Data is EquipmentNode eqNode)
  101. {
  102. return eqNode.IsRealEquipment;
  103. }
  104. return false;
  105. });
  106. #endregion
  107. #region 端路径
  108. var endPathNodes = endGraph.GetPaths2(startNode, end =>
  109. {
  110. if (end.Data is EquipmentNode eqNode)
  111. {
  112. return eqNode.IsRealEquipment;
  113. }
  114. return false;
  115. });
  116. #endregion
  117. List<EquipmentNode> endNodes = new List<EquipmentNode>();
  118. foreach (var endPathNode in endPathNodes)
  119. {
  120. var useEdge = endPathNode.LastOrDefault();
  121. if (useEdge == null)
  122. continue;
  123. if (useEdge.NextNode.Data is EquipmentNode node)
  124. {
  125. endNodes.Add(node);
  126. }
  127. }
  128. foreach (var sourcePathNode in sourcePathNodes)
  129. {
  130. var useEdge = sourcePathNode.LastOrDefault();
  131. if (useEdge == null)
  132. continue;
  133. EquipmentNode useNode = null;
  134. if (useEdge.NextNode.Data is EquipmentNode node)
  135. {
  136. useNode=node;
  137. }
  138. else
  139. {
  140. continue;
  141. }
  142. foreach (var equipmentNode in endNodes)
  143. {
  144. BinaryRelationItem item = new BinaryRelationItem();
  145. item.RelationType = (useEdge.Path.Data as string) ?? string.Empty;
  146. if (useEdge.Path.ContainVertex(useEdge.NextNode.Id) == 0)
  147. {
  148. item.From = useNode;
  149. item.To = equipmentNode;
  150. }
  151. else
  152. {
  153. item.From = equipmentNode;
  154. item.To = useNode;
  155. }
  156. result.Add(CreateRelationData(item));
  157. }
  158. }
  159. }
  160. return result;
  161. #endregion
  162. }
  163. private static SimpleObjectGraph CreateGraph(List<StringFlag<VerticalRelationRecord>> verticalNodes, List<BinaryRelationItem> sourceRelations)
  164. {
  165. SimpleObjectGraph graph = new SimpleObjectGraph();
  166. #region 构建临时边集
  167. for (int i = sourceRelations.Count - 1; i >= 0; i--)
  168. {
  169. var currentRecord = sourceRelations[i];
  170. var startId = currentRecord.From.BimId;
  171. var endId = currentRecord.To.BimId;
  172. graph.AddVertex(new SimpleVertex<object>(currentRecord.From) {Id = startId});
  173. graph.AddVertex(new SimpleVertex<object>(currentRecord.To) { Id = endId });
  174. string replaceStart = null;
  175. string replaceEnd = null;
  176. for (int j = 0; j < verticalNodes.Count; j++)
  177. {
  178. if (replaceStart != null && replaceEnd != null)
  179. break;
  180. var currentVertical = verticalNodes[j];
  181. if (currentVertical.Instance.RelationItems.Contains(startId))
  182. {
  183. replaceStart = currentVertical.Flag;
  184. }
  185. if (currentVertical.Instance.RelationItems.Contains(endId))
  186. {
  187. replaceEnd = currentVertical.Flag;
  188. }
  189. graph.AddVertex(new SimpleVertex<object>(currentVertical.Instance) { Id = currentVertical.Flag });
  190. }
  191. replaceStart = replaceStart ?? startId;
  192. replaceEnd = replaceEnd ?? endId;
  193. if (!string.IsNullOrWhiteSpace(replaceStart) && !string.IsNullOrWhiteSpace(replaceEnd))
  194. {
  195. SimpleEdge<object> edge = new SimpleEdge<object>(replaceStart, replaceEnd);
  196. edge.Data = currentRecord.RelationType;
  197. graph.AddEdge(edge);
  198. }
  199. }
  200. #endregion
  201. return graph;
  202. }
  203. /// <summary>
  204. /// 创建上传关系数据
  205. /// </summary>
  206. /// <param name="relationType"></param>
  207. /// <returns></returns>
  208. public static List<ReleateData> BuildRelations(string relationType)
  209. {
  210. LoadRelationData data = new LoadRelationData(relationType);
  211. data.LoadData();
  212. return BuildRelations(data);
  213. }
  214. #region 私有方法
  215. /// <summary>
  216. /// 创建上传关系数据
  217. /// </summary>
  218. /// <param name="relationItem"></param>
  219. /// <returns></returns>
  220. private static ReleateData CreateRelationData(BinaryRelationItem relationItem)
  221. {
  222. ReleateData relation = new ReleateData();
  223. relation.from_id = relationItem.From.MbiId;
  224. relation.to_id = relationItem.To.MbiId;
  225. relation.rel_type = relationItem.RelationType;
  226. relation.infos = new Info() {info1 = relationItem.From.BimId, info2 = relationItem.To.BimId};
  227. return relation;
  228. }
  229. #endregion
  230. }
  231. }