package com.zy.core.cache;
|
|
import com.zy.core.model.protocol.RgvProtocol;
|
import com.zy.core.model.protocol.RgvTaskProtocol;
|
|
import java.util.concurrent.ConcurrentHashMap;
|
|
/**
|
* Created by IX on 2025/02/21
|
*/
|
public class RgvTaskCache {
|
// 本地缓存,键为 currentPosition,值为 DeviceStatus
|
private static final ConcurrentHashMap<Integer, RgvTaskProtocol> cache = new ConcurrentHashMap<>();
|
|
/**
|
* 更新设备状态
|
*/
|
public static void updateRgvStatus(RgvTaskProtocol status) {
|
try {
|
cache.put(status.getRgvNo(), status);
|
} finally {
|
}
|
}
|
|
/**
|
* 获取设备状态
|
*/
|
public static RgvTaskProtocol getRgvStatus(Integer RgvNo) {
|
try {
|
return cache.get(RgvNo);
|
} finally {
|
}
|
}
|
|
/**
|
* 获取所有设备状态
|
*/
|
public static ConcurrentHashMap<Integer, RgvTaskProtocol> getAllRgvStatus() {
|
try {
|
return new ConcurrentHashMap<>(cache); // 返回副本
|
} finally {
|
}
|
}
|
|
}
|