Skip to content

Commit 202ecd3

Browse files
author
hezhuozhuo
committed
fix bug
1 parent 5996703 commit 202ecd3

File tree

1 file changed

+2
-2
lines changed

1 file changed

+2
-2
lines changed

service/telemetry_data.go

+2-2
Original file line numberDiff line numberDiff line change
@@ -730,7 +730,7 @@ func (t *TelemetryData) TelemetryPutMessage(ctx context.Context, userID string,
730730
// 根据设备信息获取要发送的控制主题(内置MQTT协议)
731731
func getTopicByDevice(deviceInfo *model.Device, deviceType string, param *model.PutMessage) (string, error) {
732732
if deviceType == "1" {
733-
return fmt.Sprintf("%s%s", config.MqttConfig.Telemetry.PublishTopic, deviceInfo.DeviceNumber), nil
733+
return fmt.Sprintf(config.MqttConfig.Telemetry.PublishTopic, deviceInfo.DeviceNumber), nil
734734
} else if deviceType == "2" || deviceType == "3" {
735735
gatewayInfo, err := initialize.GetDeviceById(deviceInfo.ID)
736736
if err != nil {
@@ -777,7 +777,7 @@ func getTopicByDevice(deviceInfo *model.Device, deviceType string, param *model.
777777
param.Value = string(output)
778778
}
779779

780-
return fmt.Sprintf("%s%s", config.MqttConfig.Telemetry.GatewayPublishTopic, gatewayInfo.DeviceNumber), nil
780+
return fmt.Sprintf(config.MqttConfig.Telemetry.GatewayPublishTopic, gatewayInfo.DeviceNumber), nil
781781
} else {
782782
return "", fmt.Errorf("unknown device type")
783783
}

0 commit comments

Comments
 (0)