打包

http/handle/api/mqtt.go

@@ -366,7 +366,7 @@ func dustingPush(c MQTT.Client, pubTopic, date string) {
 		b, _ := json.Marshal(dataList)
 		pushStr = fmt.Sprintf(pushStr, setting.YynserverSetting.FarmId, len(dataList), string(b))
 		 c.Publish(pubTopic, 2, false, pushStr)
-		// fmt.Println("publish msg: ", pushStr, token.Error())
+		fmt.Println("publish msg: ", pushStr, token.Error())
 		// token.Wait()
 		// time.Sleep(2 * time.Second)
 	}
@@ -387,7 +387,7 @@ func deviceHeartbeat(c MQTT.Client, pubTopic string) {
 	device := cron.New()
 	device.AddFunc(spec1, func() {
 		token := c.Publish(pubTopic, 2, false, pushStr)
-		// fmt.Println("publish msg: ", pushStr, token.Error(), time.Now())
+		fmt.Println("publish msg: ", pushStr, token.Error(), time.Now())
 		token.Wait()
 	})
 	// }