From 9c0fd80309b277420c492180ae9f98f779f0f5c8 Mon Sep 17 00:00:00 2001
From: yeg <1347747024@qq.com>
Date: 星期日, 30 八月 2026 23:29:33 +0800
Subject: [PATCH] 实现设备自然结束与区间补采恢复
---
ruoyi-device/src/main/java/com/ruoyi/device/simulator/InMemoryBtsSimulatorStateStore.java | 23 +++++++++++++++++++++++
1 files changed, 23 insertions(+), 0 deletions(-)
diff --git a/ruoyi-device/src/main/java/com/ruoyi/device/simulator/InMemoryBtsSimulatorStateStore.java b/ruoyi-device/src/main/java/com/ruoyi/device/simulator/InMemoryBtsSimulatorStateStore.java
index 2656282..ac03f84 100644
--- a/ruoyi-device/src/main/java/com/ruoyi/device/simulator/InMemoryBtsSimulatorStateStore.java
+++ b/ruoyi-device/src/main/java/com/ruoyi/device/simulator/InMemoryBtsSimulatorStateStore.java
@@ -7,6 +7,8 @@
import com.ruoyi.device.simulator.BtsSimulatorStateStore.CollectorHistoryAppend;
import com.ruoyi.device.simulator.BtsSimulatorStateStore.CollectorHistoryBatch;
import com.ruoyi.device.simulator.BtsSimulatorStateStore.CollectorMeasurementRecord;
+import com.ruoyi.device.simulator.BtsSimulatorStateStore.BtsHistoryRecord;
+import com.ruoyi.device.simulator.BtsSimulatorStateStore.BtsHistoryBatch;
import com.ruoyi.device.simulator.BtsSimulatorStateStore.RecentRequest;
import com.ruoyi.device.simulator.BtsSimulatorStateStore.SimulatorState;
@@ -16,6 +18,7 @@
private SimulatorState state;
private List<RecentRequest> recentRequests = List.of();
private final Map<String, ArrayList<CollectorMeasurementRecord>> collectorHistory = new LinkedHashMap<>();
+ private final Map<String, ArrayList<BtsHistoryRecord>> btsHistory = new LinkedHashMap<>();
public InMemoryBtsSimulatorStateStore() { }
@@ -85,6 +88,25 @@
}
@Override
+ public synchronized BtsHistoryBatch loadBtsHistoryPage(String historyKey, long offset, int limit)
+ {
+ List<BtsHistoryRecord> history = btsHistory.getOrDefault(historyKey, new ArrayList<>());
+ int from = (int) Math.min(offset, history.size());
+ int count = Math.min(limit, history.size() - from);
+ List<BtsHistoryRecord> records = new ArrayList<>(history.subList(from, from + count));
+ long next = from + records.size();
+ return new BtsHistoryBatch(offset, next, next < history.size(), history.size(), records);
+ }
+
+ @Override
+ public synchronized void appendBtsHistory(String historyKey, BtsHistoryRecord record)
+ {
+ ArrayList<BtsHistoryRecord> history = btsHistory.computeIfAbsent(historyKey, key -> new ArrayList<>());
+ history.add(record);
+ if (history.size() > MAX_HISTORY_RECORDS) history.remove(0);
+ }
+
+ @Override
public synchronized List<RecentRequest> loadRecentRequests()
{
return recentRequests;
@@ -102,5 +124,6 @@
state = defaultState;
recentRequests = List.of();
collectorHistory.clear();
+ btsHistory.clear();
}
}
--
Gitblit v1.7.1