调整楼层获取方式

zhangzengfei

2024-10-20 5ddd4f4ba6aaf1fe52f93c0966315d0424bd2a5f

 nvcs/nvcs.go

@@ -13,7 +13,7 @@
)

// 数据结构
type elevatorRunData struct {
type ElevatorRunData struct {
   Device    string
   Timestamp int64
   Floor     string
@@ -50,14 +50,26 @@
      return "", 0
   }

   return runState.(elevatorRunData).Floor, runState.(elevatorRunData).RunState
   return runState.(ElevatorRunData).Floor, runState.(ElevatorRunData).RunState
}

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()
   }