Cold_Api/controllers/DeviceReal.go

package controllers

import (
	"Cold_Api/Nats/NatsServer"
	"Cold_Api/conf"
	"Cold_Api/controllers/lib"
	"Cold_Api/models/Device"
	"fmt"
	"strings"
	"time"
)

// 循环刷新
//func DeviceRealTime() {
//	fmt.Println("=====================DeviceRealTime GO===============")
//	time.Sleep(time.Second * 3)
//	for true {
//		for k, v := range lib.DeviceRealSnMap {
//			fmt.Println("DeviceRealSnMap:", k, " num：", v)
//			NatsServer.Get_Device_Realtime(k)
//
//			v--
//			lib.DeviceRealSnMap[k] = v
//			if v == 0 {
//				delete(lib.DeviceRealSnMap, k)
//			}
//			time.Sleep(time.Millisecond * 100)
//		}
//		time.Sleep(time.Second * 10)
//
//	}
//}

//func DeviceRealTime() {
//	fmt.Println("=====================DeviceRealTime GO===============")
//	time.Sleep(time.Second * 3)
//	for true {
//		lib.DeviceRealSnMap.Range(func(k, v interface{}) bool {
//			fmt.Println("DeviceRealSnMap:", k, " num：", v)
//			NatsServer.Get_Device_Realtime(k.(string))
//
//			temp := v.(int)
//			temp--
//			lib.DeviceRealSnMap.Store(k, temp)
//			if temp == 0 {
//				lib.DeviceRealSnMap.Delete(k)
//			}
//			time.Sleep(time.Millisecond * 100)
//			return true
//		})
//		time.Sleep(time.Second * 10)
//	}
//}

//  DeviceRealSnMap[sn] = 3

func DeviceRealTime() {
	fmt.Println("=====================DeviceRealTime GO===============")
	time.Sleep(time.Second * 3)
	for true {
		// 如果能拿到key,10s等待时间还没结束，则不继续往下执行
		if Device.Redis_DeviceRealWait_IsExist("DeviceRealWait10Second" + conf.MqttServer_id) {
			time.Sleep(time.Second * 1)
			continue
		}

		lib.DeviceRealSnMap.Range(func(k, v interface{}) bool {

			//logs.Info("=================", k)
			sn := strings.Split(k.(string), "|")[0]
			mqttid := strings.Split(k.(string), "|")[1]

			//num, is := Device.Redis_DeviceReal_Get(sn)
			//if num >= 3 {
			//	lib.DeviceRealSnMap.Delete(k)
			//	Device.Redis_DeviceReal_DelK(sn)
			//	return true
			//}
			//if !is {
			//	Device.Redis_DeviceReal_Set(sn, 1)
			//} else {
			//	Device.Redis_DeviceReal_Set(sn, num+1)
			//}

			NatsServer.Get_Device_Realtime(sn, mqttid)
			lib.DeviceRealSnMap.Delete(k)
			time.Sleep(time.Millisecond * 100)
			return true
		})

		//lib.DeviceRealSnMap.Range(func(k, v interface{}) bool {
		//	sn := strings.Split(k.(string), "|")[0]
		//	mqttid := strings.Split(k.(string), "|")[1]
		//	num, is := Device.Redis_DeviceReal_Get(sn)
		//	if !is {
		//		Device.Redis_DeviceReal_Set(sn, 1)
		//	} else {
		//		Device.Redis_DeviceReal_Set(sn, num+1)
		//	}
		//	// 每次拿到Map的key后，删除该key，否则会造成死循环
		//	lib.DeviceRealSnMap.Delete(k)
		//	// 实时数据请求次数达到180次(30分钟*6次/分钟=180)
		//	// 更新实时请求为2分钟每次(2分钟*6次/分钟=12)
		//	if num > 180 && (num-180)%12 != 0 {
		//		return true
		//	}
		//
		//	logs.Debug("DeviceRealSnMap:", sn, " num：", num)
		//	NatsServer.Get_Device_Realtime(sn, mqttid)
		//
		//	time.Sleep(time.Millisecond * 100)
		//	return true
		//})

		Device.Redis_DeviceRealWait_Set("DeviceRealWait10Second" + conf.MqttServer_id)
		time.Sleep(time.Second * 10)
	}
}