deepmodeling · Xuwznln · May 29, 2025 · May 14, 2025 · May 14, 2025 · May 14, 2025
diff --git a/test/commands/resource_add.md b/test/commands/resource_add.md
@@ -1,5 +1,5 @@
 使用plr_test.json启动，将Well加入Plate中
 
 ```bash
-ros2 action send_goal /devices/host_node/add_resource_from_outer unilabos_msgs/action/_resource_create_from_outer/ResourceCreateFromOuter "{ resources: [ { 'category': '', 'children': [], 'config': { 'type': 'Well', 'size_x': 6.86, 'size_y': 6.86, 'size_z': 10.67, 'rotation': { 'x': 0, 'y': 0, 'z': 0, 'type': 'Rotation' }, 'category': 'well', 'model': null, 'max_volume': 360, 'material_z_thickness': 0.5, 'compute_volume_from_height': null, 'compute_height_from_volume': null, 'bottom_type': 'flat', 'cross_section_type': 'circle' }, 'data': { 'liquids': [], 'pending_liquids': [], 'liquid_history': [] }, 'id': 'plate_well_11_7', 'name': 'plate_well_11_7', 'pose': { 'orientation': { 'w': 1.0, 'x': 0.0, 'y': 0.0, 'z': 0.0 }, 'position': { 'x': 0.0, 'y': 0.0, 'z': 0.0 } }, 'sample_id': '', 'parent': 'plate', 'type': 'device' } ], device_ids: [ 'PLR_STATION' ], bind_parent_ids: [ 'plate' ], bind_locations: [ { 'x': 0.0, 'y': 0.0, 'z': 0.0 } ], other_calling_params: [ '{}' ] }"
+ros2 action send_goal /devices/host_node/create_resource_detailed unilabos_msgs/action/_resource_create_from_outer/ResourceCreateFromOuter "{ resources: [ { 'category': '', 'children': [], 'config': { 'type': 'Well', 'size_x': 6.86, 'size_y': 6.86, 'size_z': 10.67, 'rotation': { 'x': 0, 'y': 0, 'z': 0, 'type': 'Rotation' }, 'category': 'well', 'model': null, 'max_volume': 360, 'material_z_thickness': 0.5, 'compute_volume_from_height': null, 'compute_height_from_volume': null, 'bottom_type': 'flat', 'cross_section_type': 'circle' }, 'data': { 'liquids': [], 'pending_liquids': [], 'liquid_history': [] }, 'id': 'plate_well_11_7', 'name': 'plate_well_11_7', 'pose': { 'orientation': { 'w': 1.0, 'x': 0.0, 'y': 0.0, 'z': 0.0 }, 'position': { 'x': 0.0, 'y': 0.0, 'z': 0.0 } }, 'sample_id': '', 'parent': 'plate', 'type': 'device' } ], device_ids: [ 'PLR_STATION' ], bind_parent_ids: [ 'plate' ], bind_locations: [ { 'x': 0.0, 'y': 0.0, 'z': 0.0 } ], other_calling_params: [ '{}' ] }"
 ```
diff --git a/unilabos-linux-64.yaml b/unilabos-linux-64.yaml
@@ -56,6 +56,8 @@ dependencies:
   - ros-humble-moveit-servo
   # simulation
   - ros-humble-simulation
+  - ros-humble-tf-transformations
+  - transforms3d
   # ros-humble-gazebo-ros // ignored because of the conflict with ign-gazebo
   # ilab equipments
 #  - ros-humble-unilabos-msgs

diff --git a/unilabos-osx-64.yaml b/unilabos-osx-64.yaml
@@ -56,6 +56,8 @@ dependencies:
   # - ros-humble-moveit-servo
   # simulation
   - ros-humble-simulation
+  - ros-humble-tf-transformations
+  - transforms3d
   # ros-humble-gazebo-ros // ignored because of the conflict with ign-gazebo
   # ilab equipments
 #  - ros-humble-unilabos-msgs

diff --git a/unilabos-osx-arm64.yaml b/unilabos-osx-arm64.yaml
@@ -58,6 +58,8 @@ dependencies:
   - ros-humble-moveit-servo
   # simulation
   - ros-humble-simulation
+  - ros-humble-tf-transformations
+  - transforms3d
   # ros-humble-gazebo-ros // ignored because of the conflict with ign-gazebo
   # ilab equipments
 #  - ros-humble-unilabos-msgs

diff --git a/unilabos-win64.yaml b/unilabos-win64.yaml
@@ -56,6 +56,8 @@ dependencies:
   - ros-humble-moveit-servo
   # simulation
   - ros-humble-simulation # ignored because of NO python3.11 package in WIN64
+  - ros-humble-tf-transformations
+  - transforms3d
   # ros-humble-gazebo-ros // ignored because of the conflict with ign-gazebo
   # ilab equipments
   # ros-humble-unilabos-msgs

diff --git a/unilabos/app/main.py b/unilabos/app/main.py
@@ -18,7 +18,6 @@
 
 from unilabos.config.config import load_config, BasicConfig, _update_config_from_env
 from unilabos.utils.banner_print import print_status, print_unilab_banner
-from unilabos.device_mesh.resource_visalization import ResourceVisualization
 
 
 def parse_args():
@@ -188,11 +187,12 @@ def _exit(signum, frame):
     if args_dict["visual"] != "disable":
         enable_rviz = args_dict["visual"] == "rviz"
         if devices_and_resources is not None:
+            from unilabos.device_mesh.resource_visalization import ResourceVisualization  # 此处开启后，logger会变更为INFO，有需要请调整
             resource_visualization = ResourceVisualization(devices_and_resources, args_dict["resources_config"] ,enable_rviz=enable_rviz)
             args_dict["resources_mesh_config"] = resource_visualization.resource_model
             start_backend(**args_dict)
             server_thread = threading.Thread(target=start_server, kwargs=dict(
-                open_browser=not args_dict["disable_browser"]
+                open_browser=not args_dict["disable_browser"], port=args_dict["port"],
             ))
             server_thread.start()
             asyncio.set_event_loop(asyncio.new_event_loop())
@@ -201,10 +201,10 @@ def _exit(signum, frame):
                 time.sleep(1)
         else:
             start_backend(**args_dict)
-            start_server(open_browser=not args_dict["disable_browser"])
+            start_server(open_browser=not args_dict["disable_browser"], port=args_dict["port"],)
     else:
         start_backend(**args_dict)
-        start_server(open_browser=not args_dict["disable_browser"])
+        start_server(open_browser=not args_dict["disable_browser"], port=args_dict["port"],)
 
 
 if __name__ == "__main__":

diff --git a/unilabos/app/mq.py b/unilabos/app/mq.py
@@ -26,6 +26,7 @@ class MQTTClient:
     def __init__(self):
         self.mqtt_disable = not MQConfig.lab_id
         self.client_id = f"{MQConfig.group_id}@@@{MQConfig.lab_id}{uuid.uuid4()}"
+        logger.info("[MQTT] Client_id: " + self.client_id)
         self.client = mqtt.Client(CallbackAPIVersion.VERSION2, client_id=self.client_id, protocol=mqtt.MQTTv5)
         self._setup_callbacks()
 
@@ -52,10 +53,7 @@ def _on_message(self, client, userdata, msg) -> None:
         try:
             payload_str = msg.payload.decode("utf-8")
             payload_json = json.loads(payload_str)
-            logger.debug(f"Topic: {msg.topic}")
-            logger.debug("Payload:", json.dumps(payload_json, indent=2, ensure_ascii=False))
             if msg.topic == f"labs/{MQConfig.lab_id}/job/start/":
-                logger.debug("job_add", type(payload_json), payload_json)
                 if "data" not in payload_json:
                     payload_json["data"] = {}
                 if "action" in payload_json:

diff --git a/unilabos/devices/laiyu_add_solid/__init__.py b/unilabos/devices/laiyu_add_solid/__init__.py
diff --git a/...ices/liquid_handling/action_definition.py → ...iquid_handling/liquid_handler_abstract.py b/...ices/liquid_handling/action_definition.py → ...iquid_handling/liquid_handler_abstract.py
@@ -14,7 +14,7 @@
     Well
 )
 
-class DPLiquidHandler(LiquidHandler):
+class LiquidHandlerAbstract(LiquidHandler):
     """Extended LiquidHandler with additional operations."""
 
     # ---------------------------------------------------------------

diff --git a/unilabos/registry/devices/liquid_handler.yaml b/unilabos/registry/devices/liquid_handler.yaml
@@ -1,11 +1,96 @@
 liquid_handler:
   description: Liquid handler device controlled by pylabrobot
   class:
-    module: pylabrobot.liquid_handling:LiquidHandler
+    module: unilabos.devices.liquid_handling.liquid_handler_abstract:LiquidHandlerAbstract
     type: python
     status_types:
       name: String
     action_value_mappings:
+      remove:
+        type: LiquidHandlerRemove
+        goal:
+          vols: vols
+          sources: sources
+          waste_liquid: waste_liquid
+          use_channels: use_channels
+          flow_rates: flow_rates
+          offsets: offsets
+          liquid_height: liquid_height
+          blow_out_air_volume: blow_out_air_volume
+          spread: spread
+          delays: delays
+          is_96_well: is_96_well
+          top: top
+          none_keys: none_keys
+        feedback: { }
+        result: { }
+      add_liquid:
+        type: LiquidHandlerAdd
+        goal:
+          asp_vols: asp_vols
+          dis_vols: dis_vols
+          reagent_sources: reagent_sources
+          targets: targets
+          use_channels: use_channels
+          flow_rates: flow_rates
+          offsets: offsets
+          liquid_height: liquid_height
+          blow_out_air_volume: blow_out_air_volume
+          spread: spread
+          is_96_well: is_96_well
+          mix_time: mix_time
+          mix_vol: mix_vol
+          mix_rate: mix_rate
+          mix_liquid_height: mix_liquid_height
+          none_keys: none_keys
+        feedback: { }
+        result: { }
+      transfer_liquid:
+        type: LiquidHandlerTransfer
+        goal:
+          asp_vols: asp_vols
+          dis_vols: dis_vols
+          sources: sources
+          targets: targets
+          tip_racks: tip_racks
+          use_channels: use_channels
+          asp_flow_rates: asp_flow_rates
+          dis_flow_rates: dis_flow_rates
+          offsets: offsets
+          touch_tip: touch_tip
+          liquid_height: liquid_height
+          blow_out_air_volume: blow_out_air_volume
+          spread: spread
+          is_96_well: is_96_well
+          mix_stage: mix_stage
+          mix_times: mix_times
+          mix_vol: mix_vol
+          mix_rate: mix_rate
+          mix_liquid_height: mix_liquid_height
+          delays: delays
+          none_keys: none_keys
+        feedback: { }
+        result: { }
+      mix:
+        type: LiquidHandlerMix
+        goal:
+          targets: targets
+          mix_time: mix_time
+          mix_vol: mix_vol
+          height_to_bottom: height_to_bottom
+          offsets: offsets
+          mix_rate: mix_rate
+          none_keys: none_keys
+        feedback: { }
+        result: { }
+      move_to:
+        type: LiquidHandlerMoveTo
+        goal:
+          well: well
+          dis_to_top: dis_to_top
+          channel: channel
+        feedback: { }
+        result: { }
       aspirate:
         type: LiquidHandlerAspirate
         goal:
@@ -170,127 +255,6 @@ liquid_handler:
     - name
     additionalProperties: false
 
-dp_liquid_handler:
-  description: 通用液体处理
-  class:
-    module: unilabos.devices.liquid_handling.action_definition:DPLiquidHandler
-    type: python
-    status_types:
-      status: String
-    action_value_mappings:
-      remove_liquid:
-        type: DPLiquidHandlerRemoveLiquid
-        goal:
-          vols: vols
-          sources: sources
-          waste_liquid: waste_liquid
-          use_channels: use_channels
-          flow_rates: flow_rates
-          offsets: offsets
-          liquid_height: liquid_height
-          blow_out_air_volume: blow_out_air_volume
-          spread: spread
-          delays: delays
-          is_96_well: is_96_well
-          top: top
-          none_keys: none_keys
-        feedback: {}
-        result: {}
-      add_liquid:
-        type: DPLiquidHandlerAddLiquid
-        goal:
-          asp_vols: asp_vols
-          dis_vols: dis_vols
-          reagent_sources: reagent_sources
-          targets: targets
-          use_channels: use_channels
-          flow_rates: flow_rates
-          offsets: offsets
-          liquid_height: liquid_height
-          blow_out_air_volume: blow_out_air_volume
-          spread: spread
-          is_96_well: is_96_well
-          mix_time: mix_time
-          mix_vol: mix_vol
-          mix_rate: mix_rate
-          mix_liquid_height: mix_liquid_height
-          none_keys: none_keys
-        feedback: {}
-        result: {}
-      transfer_liquid:
-        type: DPLiquidHandlerTransferLiquid
-        goal:
-          asp_vols: asp_vols
-          dis_vols: dis_vols
-          sources: sources
-          targets: targets
-          tip_racks: tip_racks
-          use_channels: use_channels
-          asp_flow_rates: asp_flow_rates
-          dis_flow_rates: dis_flow_rates
-          offsets: offsets
-          touch_tip: touch_tip
-          liquid_height: liquid_height
-          blow_out_air_volume: blow_out_air_volume
-          spread: spread
-          is_96_well: is_96_well
-          mix_stage: mix_stage
-          mix_times: mix_times
-          mix_vol: mix_vol
-          mix_rate: mix_rate
-          mix_liquid_height: mix_liquid_height
-          delays: delays
-          none_keys: none_keys
-        feedback: {}
-        result: {}
-      custom_delay:
-        type: DPLiquidHandlerCustomDelay
-        goal:
-          seconds: seconds
-          msg: msg
-        feedback: {}
-        result: {}
-      touch_tip:
-        type: DPLiquidHandlerTouchTip
-        goal:
-          targets: targets
-        feedback: {}
-        result: {}
-      mix:
-        type: DPLiquidHandlerMix
-        goal:
-          targets: targets
-          mix_time: mix_time
-          mix_vol: mix_vol
-          height_to_bottom: height_to_bottom
-          offsets: offsets
-          mix_rate: mix_rate
-          none_keys: none_keys
-        feedback: {}
-        result: {}
-      set_tiprack:
-        type: DPLiquidHandlerSetTiprack
-        goal:
-          tip_racks: tip_racks
-        feedback: {}
-        result: {}
-      move_to:
-        type: DPLiquidHandlerMoveTo
-        goal:
-          well: well
-          dis_to_top: dis_to_top
-          channel: channel
-        feedback: {}
-        result: {}
-  schema:
-    type: object
-    properties:
-      name:
-        type: string
-        description: 物料名
-    required:
-    - name
-
 liquid_handler.revvity:
   class:
     module: unilabos.devices.liquid_handling.revvity:Revvity