|
@@ -124,7 +124,7 @@ public class DeviceRegisterServiceImpl extends ServiceImpl<DeviceRegisterMapper,
|
|
|
mqttUserInfo.setUsername(deviceId);
|
|
|
mqttUserInfo.setPasswordHash(deviceId);
|
|
|
mqttUserInfo.setCreated(LocalDateTime.now());
|
|
|
- mqttUserInfo.setTopic(CommConsts.DEVICE_MQTT_TOPIC_SUFFIX);
|
|
|
+ mqttUserInfo.setTopic(deviceId + CommConsts.DEVICE_MQTT_TOPIC_SUFFIX);
|
|
|
mqttUserInfo.setSn(deviceRegister.getDeviceSn());
|
|
|
mqttUserInfo.setDeviceId(deviceRegister.getDeviceId());
|
|
|
mqttUserInfo.setIpAddress(mqttConfig.getUrl());
|