zhangzengfei
2024-10-22 4ca3791590a7bf50222aa5f80e53edf04739108a
nvcs/nvcs.go
@@ -13,7 +13,7 @@
)
// 数据结构
type elevatorRunData struct {
type ElevatorRunData struct {
   Device    string
   Timestamp int64
   Floor     string
@@ -44,20 +44,32 @@
   }
}
func CurrentRunState() (string, int) {
   runState := cache.data.Back().Value
   if runState == nil {
      return "", 0
func CurrentRunState() (runState ElevatorRunData) {
   node := cache.data.Back()
   if node == nil {
      return
   }
   return runState.(elevatorRunData).Floor, runState.(elevatorRunData).RunState
   return node.Value.(ElevatorRunData)
}
func FindPositionByTime(timestamp int64) ElevatorRunData {
   return cache.getPositionByTime(timestamp)
}
func FindMovePosition(timestamp int64, floor string) ElevatorRunData {
   return cache.getMovePosition(timestamp, floor)
}
func listenQueue() {
   for {
      data := queue.get()
      //t := time.Now()
      cache.store(data)
      //logger.Debug("process queue data %+v, use time %v", data, time.Since(t))
      // 清理过期数据
      cache.cleanExpired()
   }