|
|
@@ -363,7 +363,7 @@ func dustingPush(c MQTT.Client, pubTopic, date string) {
|
|
|
b, _ := json.Marshal(dataList)
|
|
|
pushStr = fmt.Sprintf(pushStr, setting.YynserverSetting.FarmId, len(dataList), string(b))
|
|
|
token := 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)
|
|
|
}
|
|
|
@@ -374,7 +374,7 @@ func deviceHeartbeat(c MQTT.Client, pubTopic string) {
|
|
|
pushStr := fmt.Sprintf(`{"data_collect_number":%s,"status":true,"model_type":"heartbeat"}`, setting.YynserverSetting.HeartBeat)
|
|
|
|
|
|
token := c.Publish(pubTopic, 2, false, pushStr)
|
|
|
- fmt.Println("publish msg: ", pushStr, token.Error())
|
|
|
+ // fmt.Println("publish msg: ", pushStr, token.Error())
|
|
|
// token.Wait()
|
|
|
// go func() {
|
|
|
duetimecst2, _ := time.ParseInLocation("15:04:05", "00:01:00", time.Local)
|
|
|
@@ -384,7 +384,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()
|
|
|
})
|
|
|
// }
|
|
|
@@ -429,7 +429,7 @@ GROUP BY
|
|
|
b, _ := json.Marshal(dataList)
|
|
|
pushStr = fmt.Sprintf(pushStr, string(b), setting.YynserverSetting.FarmId, len(dataList))
|
|
|
token := 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)
|
|
|
}
|
|
|
@@ -469,7 +469,7 @@ WHERE
|
|
|
b, _ := json.Marshal(dataList)
|
|
|
pushStr = fmt.Sprintf(pushStr, string(b), setting.YynserverSetting.FarmId)
|
|
|
token := 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)
|
|
|
}
|
|
|
@@ -504,7 +504,7 @@ func CompletedTrainNumberPush(c MQTT.Client, pubTopic, date string) {
|
|
|
b, _ := json.Marshal(dataList)
|
|
|
pushStr = fmt.Sprintf(pushStr, string(b), setting.YynserverSetting.FarmId)
|
|
|
token := 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)
|
|
|
}
|
|
|
@@ -706,7 +706,7 @@ func getBarDataFromApi() {
|
|
|
return
|
|
|
}
|
|
|
|
|
|
- fmt.Println(time.Now(), "牛舍接口返回：", reDataString)
|
|
|
+ // fmt.Println(time.Now(), "牛舍接口返回：", reDataString)
|
|
|
|
|
|
if reDataString != "" {
|
|
|
var resultMap map[string]interface{}
|
