Refresh device detail screen in realtime

android/app/src/main/java/com/hyzq/boss/DeviceDetailActivity.java

@@ -10,12 +10,18 @@ import androidx.appcompat.app.AlertDialog;
 import org.json.JSONArray;
 import org.json.JSONObject;
 
+import java.util.LinkedHashMap;
+import java.util.Map;
+
 public class DeviceDetailActivity extends BossScreenActivity {
     public static final String EXTRA_DEVICE_ID = "device_id";
     public static final String EXTRA_DEVICE_NAME = "device_name";
+    private static final long REALTIME_RELOAD_THROTTLE_MS = 900L;
 
     private String deviceId;
     private String deviceName;
+    private @Nullable BossRealtimeClient realtimeClient;
+    private final Map<String, Long> recentRealtimeEventTimestamps = new LinkedHashMap<>();
 
     @Override
     protected void onCreate(@Nullable Bundle savedInstanceState) {
@@ -24,9 +30,28 @@ public class DeviceDetailActivity extends BossScreenActivity {
         deviceName = getIntent().getStringExtra(EXTRA_DEVICE_NAME);
         configureScreen(deviceName == null ? "设备详情" : deviceName, "设备状态、GUI/CLI 能力与默认执行模式");
         setHeaderAction("编辑", v -> openEditDialog());
+        realtimeClient = new BossRealtimeClient(apiClient, this::handleRealtimeEvent);
         reload();
     }
 
+    @Override
+    protected void onResume() {
+        super.onResume();
+        updateRealtimeSubscription();
+    }
+
+    @Override
+    protected void onPause() {
+        stopRealtimeUpdates();
+        super.onPause();
+    }
+
+    @Override
+    protected void onDestroy() {
+        stopRealtimeUpdates();
+        super.onDestroy();
+    }
+
     @Override
     protected void reload() {
         setRefreshing(true);
@@ -44,6 +69,68 @@ public class DeviceDetailActivity extends BossScreenActivity {
         });
     }
 
+    private void updateRealtimeSubscription() {
+        if (apiClient != null && apiClient.hasSessionHints() && realtimeClient != null) {
+            realtimeClient.start();
+            return;
+        }
+        stopRealtimeUpdates();
+    }
+
+    private void stopRealtimeUpdates() {
+        if (realtimeClient != null) {
+            realtimeClient.stop();
+        }
+    }
+
+    void handleRealtimeEvent(BossRealtimeEvent event) {
+        if (event == null || event.eventName.isEmpty() || deviceId == null || deviceId.isEmpty()) {
+            return;
+        }
+        if (!shouldReloadForRealtimeEvent(event)) {
+            return;
+        }
+        String eventFingerprint = BossRealtimeClient.buildEventFingerprint(event);
+        if (eventFingerprint.isEmpty()) {
+            return;
+        }
+        long now = System.currentTimeMillis();
+        if (isDuplicateRealtimeEvent(eventFingerprint, now)) {
+            return;
+        }
+        runOnUiThread(this::reload);
+    }
+
+    private boolean shouldReloadForRealtimeEvent(BossRealtimeEvent event) {
+        String payloadDeviceId = event.payload.optString("deviceId", "").trim();
+        if (payloadDeviceId.isEmpty() || !payloadDeviceId.equals(deviceId)) {
+            return false;
+        }
+        return "devices.updated".equals(event.eventName)
+                || "devices.skills.updated".equals(event.eventName)
+                || "project.context_risk.updated".equals(event.eventName);
+    }
+
+    private boolean isDuplicateRealtimeEvent(String eventFingerprint, long now) {
+        pruneRecentRealtimeEvents(now);
+        Long previousEventAt = recentRealtimeEventTimestamps.get(eventFingerprint);
+        if (previousEventAt != null && now - previousEventAt < REALTIME_RELOAD_THROTTLE_MS) {
+            return true;
+        }
+        recentRealtimeEventTimestamps.put(eventFingerprint, now);
+        return false;
+    }
+
+    private void pruneRecentRealtimeEvents(long now) {
+        java.util.Iterator<Map.Entry<String, Long>> iterator = recentRealtimeEventTimestamps.entrySet().iterator();
+        while (iterator.hasNext()) {
+            Map.Entry<String, Long> entry = iterator.next();
+            if (now - entry.getValue() >= REALTIME_RELOAD_THROTTLE_MS) {
+                iterator.remove();
+            }
+        }
+    }
+
     private void renderDevice(JSONObject payload) {
         JSONObject workspace = payload.optJSONObject("workspace");
         JSONObject device = workspace == null ? null : workspace.optJSONObject("selectedDevice");