|
|
@@ -78,8 +78,11 @@ public class MqttInfoService {
|
|
|
GateWayUserInfo gateWayUserInfo = gateWayUserInfoService.gateWayBindMqttUser(gatewayInfo);
|
|
|
if (ObjectUtils.isNotEmpty(mqttInfo)) {
|
|
|
mqttInfoSimpleModel.setBrokerAddress(String.format("%s:%s", mqttInfo.getBrokerHost(), mqttInfo.getBrokerPort()));
|
|
|
- mqttInfoSimpleModel.setBrokerUsername(gateWayUserInfo.getUserName());
|
|
|
- mqttInfoSimpleModel.setBrokerPassword(gateWayUserInfo.getPassWord());
|
|
|
+// mqttInfoSimpleModel.setBrokerUsername(gateWayUserInfo.getUserName());
|
|
|
+// mqttInfoSimpleModel.setBrokerPassword(gateWayUserInfo.getPassWord());
|
|
|
+
|
|
|
+ mqttInfoSimpleModel.setBrokerUsername(mqttInfo.getUserName());
|
|
|
+ mqttInfoSimpleModel.setBrokerPassword(mqttInfo.getPassword());
|
|
|
}
|
|
|
// 只同步网关的 权限
|
|
|
gateWayUserInfoService.syncSecurityGateToMQTTService(gatewayInfo);
|