From c1ef2d1fc4c0dae2bc8452924dcd77a0ff3a1ef5 Mon Sep 17 00:00:00 2001
From: cpT <1@123>
Date: 星期四, 19 六月 2025 15:02:52 +0800
Subject: [PATCH] #改造
---
src/main/java/com/zy/core/cache/RgvStatusCache.java | 19 +++++++++++++++++++
1 files changed, 19 insertions(+), 0 deletions(-)
diff --git a/src/main/java/com/zy/core/cache/RgvStatusCache.java b/src/main/java/com/zy/core/cache/RgvStatusCache.java
index 73a8cb5..313b420 100644
--- a/src/main/java/com/zy/core/cache/RgvStatusCache.java
+++ b/src/main/java/com/zy/core/cache/RgvStatusCache.java
@@ -2,6 +2,7 @@
import com.zy.core.model.protocol.RgvProtocol;
+import java.util.Collection;
import java.util.concurrent.ConcurrentHashMap;
/**
@@ -16,6 +17,9 @@
*/
public static void updateRgvStatus(RgvProtocol status) {
try {
+ if (status.getRgvNo()!=1 && status.getRgvNo() != 2){
+ return;
+ }
cache.put(status.getRgvNo(), status);
} finally {
}
@@ -41,4 +45,19 @@
}
}
+ /**
+ * 鑾峰彇鎵�鏈夎澶囩姸鎬�
+ */
+ public static void removeAll() {
+ try {
+ ConcurrentHashMap<Integer, RgvProtocol> integerRgvProtocolConcurrentHashMap = new ConcurrentHashMap<>(cache);
+ if (integerRgvProtocolConcurrentHashMap.values().size()>2){
+ for (RgvProtocol rgvProtocol : integerRgvProtocolConcurrentHashMap.values()){
+ cache.remove(rgvProtocol.getRgvNo());
+ }
+ }
+ } finally {
+ }
+ }
+
}
--
Gitblit v1.9.1