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)

	}
}

//  DeviceRealSnMap[sn] = 3