From c9d334e61ff33aa2f90b71e34d5a7a0340765bfe Mon Sep 17 00:00:00 2001
From: 野心家 <1051256694@qq.com>
Date: 星期二, 27 五月 2025 18:44:37 +0800
Subject: [PATCH] #ZH
---
src/main/java/com/zy/core/cache/RgvRunCache.java | 60 ++++++++++++++++++++++++++++++++++++++++++++++++++++++++++++
1 files changed, 60 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/cache/RgvRunCache.java b/src/main/java/com/zy/core/cache/RgvRunCache.java
new file mode 100644
index 0000000..a16500d
--- /dev/null
+++ b/src/main/java/com/zy/core/cache/RgvRunCache.java
@@ -0,0 +1,60 @@
+package com.zy.core.cache;
+
+import com.core.common.Cools;
+import com.zy.core.model.protocol.RgvRunProtocol;
+import com.zy.core.model.protocol.RgvTaskProtocol;
+
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * Created by IX on 2025/02/21
+ */
+public class RgvRunCache {
+ // 鏈湴缂撳瓨锛岄敭涓� currentPosition锛屽�间负 DeviceStatus
+ private static final ConcurrentHashMap<String, RgvRunProtocol> cache = new ConcurrentHashMap<>();
+
+ /**
+ * 鏇存柊璁惧鐘舵��
+ */
+ public static void updateRgvStatus(RgvRunProtocol status) {
+ try {
+ cache.put(status.getDev(), status);
+ } finally {
+ }
+ }
+
+ /**
+ * 鑾峰彇璁惧鐘舵��
+ */
+ public static RgvRunProtocol getRgvRun() {
+ try {
+ RgvRunProtocol rgv = cache.get("RGV");
+ if (Cools.isEmpty(rgv)){
+ rgv = new RgvRunProtocol();
+ }
+ return rgv;
+ } finally {
+ }
+ }
+
+ /**
+ * 鑾峰彇璁惧鐘舵��
+ */
+ public static RgvRunProtocol getRgvStatus(String dev) {
+ try {
+ return cache.get(dev);
+ } finally {
+ }
+ }
+
+ /**
+ * 鑾峰彇鎵�鏈夎澶囩姸鎬�
+ */
+ public static ConcurrentHashMap<String, RgvRunProtocol> getAllRgvStatus() {
+ try {
+ return new ConcurrentHashMap<>(cache); // 杩斿洖鍓湰
+ } finally {
+ }
+ }
+
+}
--
Gitblit v1.9.1