fix(reaction_station): 清空工作流序列和参数避免重复执行 (#113)

在创建任务后清空工作流序列和参数，防止下次执行时累积重复

unilabos/devices/workstation/bioyond_studio/reaction_station.py

@@ -543,7 +543,9 @@ class BioyondReactionStation(BioyondWorkstation):
         if not result:
             return self._create_error_result("创建任务失败", "create_order")
         
+        # 清空工作流序列和参数，防止下次执行时累积重复
         self.pending_task_params = []
+        self.clear_workflows()  
         
         # print(f"\n✅ 任务创建成功: {result}")
         # print(f"\n✅ 任务创建成功")

unilabos/ros/nodes/base_device_node.py

@@ -943,7 +943,7 @@ class BaseROS2DeviceNode(Node, Generic[T]):
                             queried_resources = []
                             for resource_data in resource_inputs:
                                 r = SerialCommand.Request()
-                                r.command = json.dumps({"id": resource_data["id"], "with_children": True})
+                                r.command = json.dumps({"id": resource_data["id"], "uuid": resource_data.get("uuid", None), "with_children": True})
                                 # 发送请求并等待响应
                                 response: SerialCommand_Response = await self._resource_clients[
                                     "resource_get"

unilabos/ros/nodes/presets/host_node.py

@@ -1070,7 +1070,12 @@ class HostNode(BaseROS2DeviceNode):
         """
         try:
             data = json.loads(request.command)
-            http_req = self.bridges[-1].resource_get(data["id"], data["with_children"])
+            if "uuid" in data and data["uuid"] is not None:
+                http_req = self.bridges[-1].resource_tree_get([data["uuid"]], data["with_children"])
+            elif "id" in data and data["id"].startswith("/"):
+                http_req = self.bridges[-1].resource_get(data["id"], data["with_children"])
+            else:
+                raise ValueError("没有使用正确的物料 id 或 uuid")
             response.response = json.dumps(http_req["data"])
             return response
         except Exception as e:

unilabos/ros/nodes/presets/workstation.py

@@ -232,8 +232,9 @@ class ROS2WorkstationNode(BaseROS2DeviceNode):
                             resource_id = (
                                 protocol_kwargs[k]["id"] if v == "unilabos_msgs/Resource" else protocol_kwargs[k][0]["id"]
                             )
+                            resource_uuid = protocol_kwargs[k].get("uuid", None)
                             r = SerialCommand_Request()
-                            r.command = json.dumps({"id": resource_id, "with_children": True})
+                            r.command = json.dumps({"id": resource_id, "uuid": resource_uuid, "with_children": True})
                             # 发送请求并等待响应
                             response: SerialCommand_Response = await self._resource_clients[
                                 "resource_get"