Skip to content

Commit 754b1f9

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

File tree

1 file changed

+4
-1
lines changed

1 file changed

+4
-1
lines changed

service/telemetry_data.go

+4-1
Original file line numberDiff line numberDiff line change
@@ -732,7 +732,10 @@ func getTopicByDevice(deviceInfo *model.Device, deviceType string, param *model.
732732
if deviceType == "1" {
733733
return fmt.Sprintf(config.MqttConfig.Telemetry.PublishTopic, deviceInfo.DeviceNumber), nil
734734
} else if deviceType == "2" || deviceType == "3" {
735-
gatewayInfo, err := initialize.GetDeviceById(deviceInfo.ID)
735+
if deviceInfo.ParentID == nil {
736+
return "", fmt.Errorf("parentID is nil")
737+
}
738+
gatewayInfo, err := initialize.GetDeviceById(*deviceInfo.ParentID)
736739
if err != nil {
737740
logrus.Error(err)
738741
return "", err

0 commit comments

Comments
 (0)