package nvcs

import (
	"context"
	"gat1400Exchange/config"
	"time"
)

const (
	RunStop = iota
	RunUp
	RunDown
)

// 数据结构
type ElevatorRunData struct {
	Device    string
	Timestamp int64
	Floor     string
	RunState  int
}

var queue = newChQueue(100)
var cache = newCache(5 * time.Minute)

func StartNVCSServer(ctx context.Context) {

	go listenQueue()

	if config.RFIDConf.ReadFloor {
		go readRFID(ctx)
	}

	if config.NVCSConf.Model == "A1" {
		go a1UDPServer()
	}

	if config.NVCSConf.Model == "A2" {
		go a2WebServer()
	}

	if config.NVCSConf.Model == "A3" {
		go a3WebServer()
	}
}

func CurrentRunState() (runState ElevatorRunData) {
	node := cache.data.Back()
	if node == nil {
		return
	}

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