|
|
@@ -316,7 +316,12 @@ func createCallback(mqttClient *mqttcli.Client) monitor.EventCallback {
|
|
|
}
|
|
|
|
|
|
if status != "" && msg != "" {
|
|
|
- if err := mqttClient.PublishRaw(mqttClient.GetTopic(), msg); err != nil {
|
|
|
+ payload := map[string]interface{}{
|
|
|
+ "port": port,
|
|
|
+ "status": status,
|
|
|
+ "timestamp": time.Now().Format(time.RFC3339),
|
|
|
+ }
|
|
|
+ if err := mqttClient.PublishRaw(mqttClient.GetTopic(), payload); err != nil {
|
|
|
fmt.Printf("MQTT 发送失败: %v\n", err)
|
|
|
}
|
|
|
}
|