Cold_Api/controllers/DeviceReal.go

package controllers

import (
	"Cold_Api/Nats/NatsServer"
	"Cold_Api/controllers/lib"
	"fmt"
	"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