From 90ebf117a7e1ccf630361fe0f66289563b1eeb25 Mon Sep 17 00:00:00 2001
From: zhangzengfei <zhangzengfei@smartai.com>
Date: 星期六, 18 五月 2024 11:48:43 +0800
Subject: [PATCH] 修复设备类型缓存的使用
---
service/nvcs.go | 20 +++++++++-----------
1 files changed, 9 insertions(+), 11 deletions(-)
diff --git a/service/nvcs.go b/service/nvcs.go
index 6ada2b3..7af51b1 100644
--- a/service/nvcs.go
+++ b/service/nvcs.go
@@ -7,6 +7,7 @@
"io/ioutil"
"net"
"strings"
+ "time"
"gat1400Exchange/config"
"gat1400Exchange/models"
@@ -75,12 +76,12 @@
decodedBytes, err := ioutil.ReadAll(reader)
var data ElevatorData
- // Unmarshal JSON into the struct
err = json.Unmarshal(decodedBytes, &data)
if err != nil {
logger.Warn("ElevatorData unmarshal error:%s", err.Error())
continue
}
+ logger.Debug("Received %d bytes from %s, %+v", numBytes, clientAddr, data)
if len(data.Elevator) == 0 {
continue
@@ -100,20 +101,17 @@
}
}
- var d = models.Device{
- Id: elevator.Name,
- Floor: elevator.Status.FloorName,
- Ip: elevator.IP,
+ var d = models.Positions{
+ DeviceId: elevator.Name,
+ Pos: elevator.Status.FloorName,
+ CreateTime: time.Now().Unix(),
+ TimeString: time.Now().Format("2006-01-02 15:04:05"),
}
- err = d.Upsert()
+ err = d.Save()
if err != nil {
- logger.Warn("Device db update error:%s", err.Error())
+ logger.Warn("Device position update error:%s", err.Error())
}
-
- deviceAliveCache.Add(elevator.Name, true)
-
- logger.Debug("Received %d bytes from %s, %+v", numBytes, clientAddr, data)
}
}
--
Gitblit v1.8.0