diff --git a/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardManagerServiceImpl.java b/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardManagerServiceImpl.java
index bfc423c84..cf4312028 100644
--- a/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardManagerServiceImpl.java
+++ b/pjcloud-hardware/pjcloud-hardware-biz/src/main/java/com/bsd/pjcloud/hard/service/impl/HardManagerServiceImpl.java
@@ -20,7 +20,6 @@ import com.bsd.pjcloud.hard.api.utils.HardUtil;
 import com.bsd.pjcloud.hard.api.vo.HardManagerVo;
 import com.bsd.pjcloud.hard.mapper.HardGroupMapper;
 import com.bsd.pjcloud.hard.mapper.HardManagerMapper;
-import com.bsd.pjcloud.hard.service.HardGroupService;
 import com.bsd.pjcloud.hard.service.HardManagerService;
 import com.bsd.pjcloud.hard.mqtt.config.MqttConfig;
 import com.bsd.pjcloud.hard.utils.MqTopicUtil;
@@ -127,13 +126,13 @@ public class HardManagerServiceImpl extends ServiceImpl<HardManagerMapper, HardM
         baseMapper.insert(dto);
         // topic
         HardManagerEntity updateObj = HardManagerEntity.builder().id(dto.getId()).build();
-        String topic = createMqConfigByAction(mchDeptId, null, 1) + "/#";
+        String topic = createMqConfigByAction(dto.getHardGroupId(), null, 1) + "/#";
         updateObj.setMainTopic(topic);
         // client id
-        String clientId = createMqConfigByAction(mchDeptId, dto.getId(), 2);
+        String clientId = createMqConfigByAction(dto.getHardGroupId(), dto.getId(), 2);
         updateObj.setMqClientId(clientId);
         // username TODO 密码9位随机数字加字母
-        String mqUsername = createMqConfigByAction(mchDeptId, dto.getId(), 3);
+        String mqUsername = createMqConfigByAction(dto.getHardGroupId(), dto.getId(), 3);
         updateObj.setMqUsername(mqUsername);
         updateObj.setMqPassword(RandomUtil.randomString(9));
         baseMapper.updateById(updateObj);