DeviceReal.go 587 B

12345678910111213141516171819202122232425262728293031
  1. package controllers
  2. import (
  3. "Cold_Api/Nats/NatsServer"
  4. "Cold_Api/controllers/lib"
  5. "fmt"
  6. "time"
  7. )
  8. // 循环刷新
  9. func DeviceRealTime() {
  10. fmt.Println("=====================DeviceRealTime GO===============")
  11. time.Sleep(time.Second * 3)
  12. for true {
  13. for k, v := range lib.DeviceRealSnMap {
  14. fmt.Println("DeviceRealSnMap:", k, " num:", v)
  15. NatsServer.Get_Device_Realtime(k)
  16. v--
  17. lib.DeviceRealSnMap[k] = v
  18. if v == 0 {
  19. delete(lib.DeviceRealSnMap, k)
  20. }
  21. time.Sleep(time.Millisecond * 100)
  22. }
  23. time.Sleep(time.Second * 10)
  24. }
  25. }
  26. // DeviceRealSnMap[sn] = 3