package nvcs
|
|
import (
|
"context"
|
"time"
|
|
"gat1400Exchange/config"
|
"gat1400Exchange/pkg/logger"
|
"gat1400Exchange/rfid"
|
)
|
|
var gRFIDFloor string
|
|
func readRFID(ctx context.Context) {
|
rfidReader := rfid.NewReader(config.RFIDConf.DevName, 115200, 5)
|
defer rfidReader.CloseSerial()
|
|
err := rfidReader.OpenSerial()
|
if err != nil {
|
logger.Error("open rfid. %s", err.Error())
|
return
|
}
|
|
go func() {
|
err := rfidReader.ReadEPCData(ctx)
|
if err != nil {
|
logger.Error("rfid read. %s", err.Error())
|
}
|
}()
|
|
for {
|
select {
|
case <-ctx.Done():
|
return
|
default:
|
if rfidReader.Alive {
|
floor, _ := rfid.Parse2Floor(rfidReader.EPCData)
|
|
if floor != gRFIDFloor {
|
gRFIDFloor = floor
|
logger.Debug("rfid read epc floor %s", gRFIDFloor)
|
|
var runState = ElevatorRunData{
|
Device: "rfid-reader",
|
Timestamp: time.Now().Unix(),
|
Floor: floor,
|
RunState: 0,
|
}
|
|
cacheData := cache.data.Back()
|
if cacheData != nil {
|
runState.RunState = cacheData.Value.(ElevatorRunData).RunState
|
}
|
|
queue.put(runState)
|
}
|
} else {
|
logger.Error("rfid read esp timeout!!")
|
gRFIDFloor = ""
|
}
|
|
time.Sleep(200 * time.Millisecond)
|
}
|
}
|
}
|
