diff --git a/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java b/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java
index 979c233..6a9da1f 100644
--- a/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java
+++ b/src/main/java/com/zsc/edu/gateway/modules/iot/device/service/impl/DeviceServiceImpl.java
@@ -229,9 +229,9 @@ public class DeviceServiceImpl extends ServiceImpl<DeviceRepository, Device> imp
         payloadJson.put("paras", paras);
         payloadJson.put("msgType", "cloudReq");
         String payload = payloadJson.toString();
-        //TODO 占位符用clientID拼接
+        String topic = "/r1/devices/" + device.getClientId() + "/datas";
         try {
-            mqttSender.sendMsg(mqttConfig.getTopic(), qos, payload);
+            mqttSender.sendMsg(topic, qos, payload);
         } catch (Exception e) {
             throw new JSONException("发送失败");
         }