open_pub/Uni-Lab-OS
1
0
Fork 0
mirror of https://github.com/dptech-corp/Uni-Lab-OS.git synced 2025-12-17 13:01:12 +00:00
Code Issues Packages Projects Releases Wiki Activity

Fix resource tree update

Browse Source
This commit is contained in:
Xuwznln
2025-10-14 01:53:04 +08:00
parent ca027bf0eb
commit 4e434eeb97
1 changed files with 19 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

31
unilabos/ros/nodes/presets/host_node.py
View File

@@ -932,18 +932,25 @@ class HostNode(BaseROS2DeviceNode):
from unilabos.app.web.client import http_client from unilabos.app.web.client import http_client
resource_start_time = time.time() uuid_to_trees = collections.defaultdict(list)
uuid_mapping = http_client.resource_tree_update(resource_tree_set, "", False) for root_node in resource_tree_set.root_nodes:
success = bool(uuid_mapping) uuid_to_trees[root_node.res_content.uuid].append(root_node)
resource_end_time = time.time()
self.lab_logger().info( for uuid, trees in uuid_to_trees.items():
f"[Host Node-Resource] 物料更新上传 {round(resource_end_time - resource_start_time, 5) * 1000} ms"
) new_tree_set = ResourceTreeSet(trees)
if uuid_mapping: resource_start_time = time.time()
self.lab_logger().info(f"[Host Node-Resource] UUID映射: {len(uuid_mapping)} 个节点") uuid_mapping = http_client.resource_tree_add(new_tree_set, uuid, False)
# 还需要加入到资源图中，暂不实现，考虑资源图新的获取方式 success = bool(uuid_mapping)
response.response = json.dumps(uuid_mapping) resource_end_time = time.time()
self.lab_logger().info(f"[Host Node-Resource] Resource tree add completed, success: {success}") self.lab_logger().info(
f"[Host Node-Resource] 挂载 {uuid} 物料更新上传 {round(resource_end_time - resource_start_time, 5) * 1000} ms"
)
if uuid_mapping:
self.lab_logger().info(f"[Host Node-Resource] UUID映射: {len(uuid_mapping)} 个节点")
# 还需要加入到资源图中，暂不实现，考虑资源图新的获取方式
response.response = json.dumps(uuid_mapping)
self.lab_logger().info(f"[Host Node-Resource] Resource tree add completed, success: {success}")
def _resource_tree_update_callback(self, request: SerialCommand_Request, response: SerialCommand_Response): def _resource_tree_update_callback(self, request: SerialCommand_Request, response: SerialCommand_Response):
""" """