diff --git a/viewsh-module-iot/viewsh-module-iot-core/src/main/java/com/viewsh/module/iot/core/integration/constants/CleanOrderTopics.java b/viewsh-module-iot/viewsh-module-iot-core/src/main/java/com/viewsh/module/iot/core/integration/constants/CleanOrderTopics.java
index b0e53fa..09636c7 100644
--- a/viewsh-module-iot/viewsh-module-iot-core/src/main/java/com/viewsh/module/iot/core/integration/constants/CleanOrderTopics.java
+++ b/viewsh-module-iot/viewsh-module-iot-core/src/main/java/com/viewsh/module/iot/core/integration/constants/CleanOrderTopics.java
@@ -12,26 +12,26 @@ public interface CleanOrderTopics {
     /**
      * 保洁工单创建事件
      */
-    String ORDER_CREATE = "ops.order.create";
+    String ORDER_CREATE = "ops-order-create";
 
     /**
      * 保洁工单到岗事件
      */
-    String ORDER_ARRIVE = "ops.order.arrive";
+    String ORDER_ARRIVE = "ops-order-arrive";
 
     /**
      * 保洁工单完成事件
      */
-    String ORDER_COMPLETE = "ops.order.complete";
+    String ORDER_COMPLETE = "ops-order-complete";
 
     /**
      * 保洁工单审计事件
      */
-    String ORDER_AUDIT = "ops.order.audit";
+    String ORDER_AUDIT = "ops-order-audit";
 
     /**
      * 保洁工单确认事件（按键确认）
      */
-    String ORDER_CONFIRM = "ops.order.confirm";
+    String ORDER_CONFIRM = "ops-order-confirm";
 
 }
diff --git a/viewsh-module-iot/viewsh-module-iot-core/src/main/java/com/viewsh/module/iot/core/integration/constants/IntegrationTopics.java b/viewsh-module-iot/viewsh-module-iot-core/src/main/java/com/viewsh/module/iot/core/integration/constants/IntegrationTopics.java
index a6e0b60..c26b20d 100644
--- a/viewsh-module-iot/viewsh-module-iot-core/src/main/java/com/viewsh/module/iot/core/integration/constants/IntegrationTopics.java
+++ b/viewsh-module-iot/viewsh-module-iot-core/src/main/java/com/viewsh/module/iot/core/integration/constants/IntegrationTopics.java
@@ -14,21 +14,21 @@ public class IntegrationTopics {
      * <p>
      * 用于发布设备上线/离线状态变更事件
      */
-    public static final String DEVICE_STATUS = "integration.device.status";
+    public static final String DEVICE_STATUS = "integration-device-status";
 
     /**
      * 设备属性变更 Topic
      * <p>
      * 用于发布设备属性变更事件
      */
-    public static final String DEVICE_PROPERTY = "integration.device.property";
+    public static final String DEVICE_PROPERTY = "integration-device-property";
 
     /**
      * 设备事件上报 Topic
      * <p>
      * 用于发布设备事件（SOS、按键等）
      */
-    public static final String DEVICE_EVENT = "integration.device.event";
+    public static final String DEVICE_EVENT = "integration-device-event";
 
     private IntegrationTopics() {
     }
diff --git a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderArriveEventHandler.java b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderArriveEventHandler.java
index 123e6cc..dbdc49c 100644
--- a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderArriveEventHandler.java
+++ b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderArriveEventHandler.java
@@ -26,7 +26,7 @@ import java.util.concurrent.TimeUnit;
  * 订阅 IoT 模块发布的保洁工单到岗事件
  * <p>
  * RocketMQ 配置：
- * - Topic: ops.order.arrive
+ * - Topic: ops-order-arrive
  * - ConsumerGroup: ops-clean-order-arrive-group
  *
  * @author AI
@@ -34,7 +34,7 @@ import java.util.concurrent.TimeUnit;
 @Slf4j
 @Component
 @RocketMQMessageListener(
-        topic = "ops.order.arrive",
+        topic = "ops-order-arrive",
         consumerGroup = "ops-clean-order-arrive-group",
         consumeMode = ConsumeMode.CONCURRENTLY,
         selectorExpression = "*"
diff --git a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderAuditEventHandler.java b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderAuditEventHandler.java
index 5cfae23..9ba3937 100644
--- a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderAuditEventHandler.java
+++ b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderAuditEventHandler.java
@@ -29,7 +29,7 @@ import java.util.concurrent.TimeUnit;
  * 用于记录非状态变更的业务审计日志（如警告发送、抑制操作等）
  * <p>
  * RocketMQ 配置：
- * - Topic: ops.order.audit
+ * - Topic: ops-order-audit
  * - ConsumerGroup: ops-clean-order-audit-group
  *
  * @author AI
@@ -37,7 +37,7 @@ import java.util.concurrent.TimeUnit;
 @Slf4j
 @Component
 @RocketMQMessageListener(
-        topic = "ops.order.audit",
+        topic = "ops-order-audit",
         consumerGroup = "ops-clean-order-audit-group",
         consumeMode = ConsumeMode.CONCURRENTLY,
         selectorExpression = "*"
diff --git a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderCompleteEventHandler.java b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderCompleteEventHandler.java
index 0d5308f..16fc7ca 100644
--- a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderCompleteEventHandler.java
+++ b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderCompleteEventHandler.java
@@ -27,7 +27,7 @@ import java.util.concurrent.TimeUnit;
  * 订阅 IoT 模块发布的保洁工单完成事件
  * <p>
  * RocketMQ 配置：
- * - Topic: ops.order.complete
+ * - Topic: ops-order-complete
  * - ConsumerGroup: ops-clean-order-complete-group
  *
  * @author AI
@@ -35,7 +35,7 @@ import java.util.concurrent.TimeUnit;
 @Slf4j
 @Component
 @RocketMQMessageListener(
-        topic = "ops.order.complete",
+        topic = "ops-order-complete",
         consumerGroup = "ops-clean-order-complete-group",
         consumeMode = ConsumeMode.CONCURRENTLY,
         selectorExpression = "*"
diff --git a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderConfirmEventHandler.java b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderConfirmEventHandler.java
index f75c475..108747d 100644
--- a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderConfirmEventHandler.java
+++ b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderConfirmEventHandler.java
@@ -31,7 +31,7 @@ import java.util.concurrent.TimeUnit;
 @Slf4j
 @Component
 @RocketMQMessageListener(
-        topic = "ops.order.confirm",
+        topic = "ops-order-confirm",
         consumerGroup = "ops-clean-order-confirm-group",
         consumeMode = ConsumeMode.CONCURRENTLY
 )
diff --git a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderCreateEventHandler.java b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderCreateEventHandler.java
index f9c51f3..5ffcdf6 100644
--- a/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderCreateEventHandler.java
+++ b/viewsh-module-ops/viewsh-module-environment-biz/src/main/java/com/viewsh/module/ops/environment/integration/consumer/CleanOrderCreateEventHandler.java
@@ -23,7 +23,7 @@ import java.util.concurrent.TimeUnit;
  * 订阅 IoT 模块发布的保洁工单创建事件
  * <p>
  * RocketMQ 配置：
- * - Topic: ops.order.create
+ * - Topic: ops-order-create
  * - ConsumerGroup: ops-clean-order-create-group
  *
  * @author AI
@@ -31,7 +31,7 @@ import java.util.concurrent.TimeUnit;
 @Slf4j
 @Component
 @RocketMQMessageListener(
-        topic = "ops.order.create",
+        topic = "ops-order-create",
         consumerGroup = "ops-clean-order-create-group",
         consumeMode = ConsumeMode.CONCURRENTLY,
         selectorExpression = "*"