Compare commits
6 Commits
a00b3643dc
...
1c6cf6a2cc
| Author | SHA1 | Date |
|---|---|---|
|
|
1c6cf6a2cc | 2 weeks ago |
|
|
cc92ad5ef9 | 2 weeks ago |
|
|
1b67e09b0c | 2 weeks ago |
|
|
af29c062d3 | 2 weeks ago |
|
|
d198402f36 | 2 weeks ago |
|
|
c04c9119fa | 2 weeks ago |
5 changed files with 893 additions and 29 deletions
@ -0,0 +1,517 @@ |
|||||
|
# Monitor Device Polling Implementation Plan |
||||
|
|
||||
|
> **For agentic workers:** REQUIRED SUB-SKILL: Use superpowers:subagent-driven-development (recommended) or superpowers:executing-plans to implement this plan task-by-task. Steps use checkbox (`- [ ]`) syntax for tracking. |
||||
|
|
||||
|
**Goal:** Make Monitor and open DeviceDetail pages refresh device status about every 5s so “实时监控” actually stays live. |
||||
|
|
||||
|
**Architecture:** Page-local timers (no store-global poller). `MonitorView` reuses `devices.load()` every 5s with an in-flight gate + visibility pause. `DeviceDetailView` polls only the current route id via `GET /docks|:drones/:id` and merges through new `applyDockDetail` / `applyDroneDetail`. `DevicesView` stays manual-refresh only. |
||||
|
|
||||
|
**Tech Stack:** Vue 3, Pinia `devicesStore`, existing axios `request` + `urls.DOCK` / `urls.DRONE` |
||||
|
|
||||
|
**Spec:** `docs/superpowers/specs/2026-09-03-monitor-device-polling-design.md` |
||||
|
|
||||
|
--- |
||||
|
|
||||
|
### Task 1: Store incremental detail apply helpers |
||||
|
|
||||
|
**Files:** |
||||
|
- Modify: `src/stores/modules/devicesStore.js` |
||||
|
|
||||
|
- [ ] **Step 1: Add dock/drone status helpers used by both `load` and apply** |
||||
|
|
||||
|
Above `export const useDeviceStore`, add (keep existing `DOCK_STATUS` / `alarmCodes` / `environmentValues` / `modeText` / `controlModeText` / `coordinate` / `displayValue` / `gpsText` / `fmtTime`): |
||||
|
|
||||
|
```js |
||||
|
function dockStatusFromDetail(registerStatus, online, rt) { |
||||
|
const pending = registerStatus === 'pending' && !online |
||||
|
if (pending) return { status: '待连接', statusClass: 'pending' } |
||||
|
if (!online) return DOCK_STATUS.offline |
||||
|
if (alarmCodes(rt).length) return { status: '告警', statusClass: 'alarm' } |
||||
|
return DOCK_STATUS.online |
||||
|
} |
||||
|
|
||||
|
function droneStatusFromDetail(online, rt) { |
||||
|
const armed = ['1', 'true', 1, true].includes(rt.armed) |
||||
|
const altitude = coordinate(rt.altitude, -1000, 100000) |
||||
|
const flying = armed || (altitude != null && altitude > 0) |
||||
|
if (!online) return { status: '离线', statusClass: 'offline', altitude, flying } |
||||
|
if (flying) return { status: '飞行中', statusClass: 'mission', altitude, flying } |
||||
|
return { status: '在巢', statusClass: 'online', altitude, flying } |
||||
|
} |
||||
|
``` |
||||
|
|
||||
|
- [ ] **Step 2: Refactor `load()` dock/drone status blocks to call the helpers** |
||||
|
|
||||
|
In the dock `map` callback, replace the local `pending` / `st` computation with: |
||||
|
|
||||
|
```js |
||||
|
const st = dockStatusFromDetail(registerStatus, online, rt) |
||||
|
``` |
||||
|
|
||||
|
In the drone `map` callback, replace `armed` / `altitude` / `flying` / `st` with: |
||||
|
|
||||
|
```js |
||||
|
const st = droneStatusFromDetail(online, rt) |
||||
|
const altitude = st.altitude |
||||
|
``` |
||||
|
|
||||
|
(Keep the rest of each mapped object identical.) |
||||
|
|
||||
|
- [ ] **Step 3: Implement `applyDockDetail` / `applyDroneDetail`** |
||||
|
|
||||
|
Inside the store factory, before `return`, add: |
||||
|
|
||||
|
```js |
||||
|
function applyDockDetail(id, detail) { |
||||
|
const key = String(id) |
||||
|
const dock = docks.value.find((d) => d.id === key) |
||||
|
if (!dock) { |
||||
|
console.warn('[devices] applyDockDetail missing dock', key) |
||||
|
return false |
||||
|
} |
||||
|
const rt = detail?.realtime || {} |
||||
|
const online = Boolean(detail?.online) |
||||
|
const st = dockStatusFromDetail(dock.registerStatus || 'registered', online, rt) |
||||
|
const environment = environmentValues(rt) |
||||
|
const alarms = alarmCodes(rt) |
||||
|
Object.assign(dock, { |
||||
|
status: st.status, |
||||
|
statusClass: st.statusClass, |
||||
|
mode: controlModeText(rt.controlMode), |
||||
|
realtime: rt, |
||||
|
environment, |
||||
|
alarms, |
||||
|
online, |
||||
|
}) |
||||
|
const assetRow = assets[key] |
||||
|
if (assetRow) { |
||||
|
Object.assign(assetRow, { |
||||
|
status: dock.status, |
||||
|
statusClass: dock.statusClass, |
||||
|
realtime: rt, |
||||
|
environment, |
||||
|
alarms, |
||||
|
online, |
||||
|
}) |
||||
|
} |
||||
|
return true |
||||
|
} |
||||
|
|
||||
|
function applyDroneDetail(id, detail) { |
||||
|
const key = String(id) |
||||
|
const drone = drones.value.find((d) => d.id === key) |
||||
|
if (!drone) { |
||||
|
console.warn('[devices] applyDroneDetail missing drone', key) |
||||
|
return false |
||||
|
} |
||||
|
const rt = detail?.realtime || {} |
||||
|
const online = Boolean(detail?.online) |
||||
|
const st = droneStatusFromDetail(online, rt) |
||||
|
const altitude = st.altitude |
||||
|
const battery = rt.batteryPercent ?? rt.batteryPct |
||||
|
const alarms = alarmCodes(rt) |
||||
|
const dock = docks.value.find((d) => d.dockId === drone.dockId) |
||||
|
Object.assign(drone, { |
||||
|
status: st.status, |
||||
|
statusClass: st.statusClass, |
||||
|
battery: battery != null && battery !== '' ? `${battery}%` : drone.battery, |
||||
|
mode: modeText(rt.flightMode), |
||||
|
mission: displayValue(rt.missionName || rt.mission), |
||||
|
sysid: displayValue(rt.currentSysId), |
||||
|
gps: gpsText(rt.gpsQuality), |
||||
|
realtime: rt, |
||||
|
alarms, |
||||
|
online, |
||||
|
_lat: coordinate(rt.latitude, -90, 90), |
||||
|
_lon: coordinate(rt.longitude, -180, 180), |
||||
|
_alt: altitude, |
||||
|
_speed: coordinate(rt.groundSpeed, 0, 1000), |
||||
|
_sats: coordinate(rt.satellites, 0, 1000), |
||||
|
}) |
||||
|
const assetRow = assets[key] |
||||
|
if (assetRow) { |
||||
|
const lon = drone._lon != null ? drone._lon : dock?.longitude |
||||
|
const lat = drone._lat != null ? drone._lat : dock?.latitude |
||||
|
const hasCoordinates = lon != null && lat != null |
||||
|
Object.assign(assetRow, { |
||||
|
status: drone.status, |
||||
|
statusClass: drone.statusClass, |
||||
|
location: drone.statusClass === 'mission' |
||||
|
? `${dock?.location || '--'} · 飞行中` |
||||
|
: `停放于${dock?.name || '--'}`, |
||||
|
hasCoordinates, |
||||
|
longitude: hasCoordinates ? lon : null, |
||||
|
latitude: hasCoordinates ? lat : null, |
||||
|
inDock: drone.statusClass !== 'mission', |
||||
|
altitude: drone._alt, |
||||
|
speed: drone._speed, |
||||
|
satellites: drone._sats, |
||||
|
realtime: rt, |
||||
|
alarms, |
||||
|
online, |
||||
|
}) |
||||
|
} |
||||
|
return true |
||||
|
} |
||||
|
``` |
||||
|
|
||||
|
Export them on the store return: |
||||
|
|
||||
|
```js |
||||
|
return { |
||||
|
assets, docks, drones, loaded, |
||||
|
asset, record, commandType, sendCommand, load, |
||||
|
applyDockDetail, applyDroneDetail, |
||||
|
} |
||||
|
``` |
||||
|
|
||||
|
- [ ] **Step 4: Static check** |
||||
|
|
||||
|
Run: |
||||
|
|
||||
|
```bash |
||||
|
rg -n "dockStatusFromDetail|droneStatusFromDetail|applyDockDetail|applyDroneDetail" src/stores/modules/devicesStore.js |
||||
|
``` |
||||
|
|
||||
|
Expected: helpers defined; both apply functions present; `return` exports both apply methods. |
||||
|
|
||||
|
- [ ] **Step 5: Commit** |
||||
|
|
||||
|
```bash |
||||
|
git add src/stores/modules/devicesStore.js |
||||
|
git commit -m "feat: apply single dock/drone detail into devices store" |
||||
|
``` |
||||
|
|
||||
|
--- |
||||
|
|
||||
|
### Task 2: MonitorView 5s polling + visibility |
||||
|
|
||||
|
**Files:** |
||||
|
- Modify: `src/views/MonitorView/MonitorView.vue` |
||||
|
|
||||
|
- [ ] **Step 1: Add poll state near other page locals** |
||||
|
|
||||
|
Near `selectedId` / live setup (script top area after stores), add: |
||||
|
|
||||
|
```js |
||||
|
const DEVICE_POLL_MS = 5000 |
||||
|
let devicePollTimer = null |
||||
|
let devicePollInflight = null |
||||
|
let devicePollGen = 0 |
||||
|
let monitorDisposed = false |
||||
|
|
||||
|
function clearDevicePollTimer() { |
||||
|
window.clearInterval(devicePollTimer) |
||||
|
devicePollTimer = null |
||||
|
} |
||||
|
|
||||
|
async function pollDevices({ toastOnSuccess = false } = {}) { |
||||
|
if (monitorDisposed) return |
||||
|
if (devicePollInflight) return |
||||
|
const gen = devicePollGen |
||||
|
devicePollInflight = devices.load() |
||||
|
try { |
||||
|
await devicePollInflight |
||||
|
if (monitorDisposed || gen !== devicePollGen) return |
||||
|
if (selectedId.value && !devices.record(selectedId.value)) clearSelection() |
||||
|
selectedDockIds.forEach((id) => { |
||||
|
if (!devices.docks.some((dock) => dock.id === id)) selectedDockIds.delete(id) |
||||
|
}) |
||||
|
syncMarkers() |
||||
|
if (toastOnSuccess) ui.toast('设备状态已刷新') |
||||
|
} catch (e) { |
||||
|
if (monitorDisposed || gen !== devicePollGen) return |
||||
|
if (toastOnSuccess) ui.toast(e.message || '刷新设备状态失败') |
||||
|
else console.warn('[monitor] device poll failed', e) |
||||
|
} finally { |
||||
|
devicePollInflight = null |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
function startDevicePolling() { |
||||
|
clearDevicePollTimer() |
||||
|
if (monitorDisposed || document.visibilityState === 'hidden') return |
||||
|
devicePollTimer = window.setInterval(() => { |
||||
|
void pollDevices() |
||||
|
}, DEVICE_POLL_MS) |
||||
|
} |
||||
|
|
||||
|
function stopDevicePolling() { |
||||
|
clearDevicePollTimer() |
||||
|
} |
||||
|
|
||||
|
function onDevicePollVisibility() { |
||||
|
if (monitorDisposed) return |
||||
|
if (document.visibilityState === 'hidden') { |
||||
|
stopDevicePolling() |
||||
|
return |
||||
|
} |
||||
|
void pollDevices() |
||||
|
startDevicePolling() |
||||
|
} |
||||
|
``` |
||||
|
|
||||
|
- [ ] **Step 2: Wire lifecycle** |
||||
|
|
||||
|
Update `onMounted` so after the existing initial `devices.load()` try/catch (keep first-load toast on failure), **always** start polling if still mounted: |
||||
|
|
||||
|
```js |
||||
|
onMounted(async () => { |
||||
|
monitorDisposed = false |
||||
|
window.addEventListener('pagehide', onPageHide) |
||||
|
window.addEventListener('keydown', onGlobalKeydown) |
||||
|
document.addEventListener('visibilitychange', onDevicePollVisibility) |
||||
|
try { |
||||
|
await devices.load() |
||||
|
if (route.query.deviceId && devices.record(route.query.deviceId)) selectedId.value = String(route.query.deviceId) |
||||
|
const rec = selectedId.value ? devices.record(selectedId.value) : null |
||||
|
controlExpanded.value = route.query.control === '1' && rec?.kind === 'dock' |
||||
|
} catch (e) { |
||||
|
ui.toast(e.message || '加载设备失败') |
||||
|
} |
||||
|
startDevicePolling() |
||||
|
try { |
||||
|
await setupMap() |
||||
|
} catch (e) { |
||||
|
ui.toast(e.message || '地图初始化失败') |
||||
|
} |
||||
|
}) |
||||
|
``` |
||||
|
|
||||
|
Update `onUnmounted`: |
||||
|
|
||||
|
```js |
||||
|
onUnmounted(() => { |
||||
|
monitorDisposed = true |
||||
|
devicePollGen += 1 |
||||
|
stopDevicePolling() |
||||
|
document.removeEventListener('visibilitychange', onDevicePollVisibility) |
||||
|
window.removeEventListener('pagehide', onPageHide) |
||||
|
window.removeEventListener('keydown', onGlobalKeydown) |
||||
|
closeCommandProgress() |
||||
|
disposeLive() |
||||
|
teardownMap() |
||||
|
}) |
||||
|
``` |
||||
|
|
||||
|
Ensure `onPageHide` (existing) also stops device polling if it only handled live before — either call `stopDevicePolling()` inside `onPageHide`, or rely on unmount; **prefer also stopping in `onPageHide`** so bfcache hides don’t keep firing. |
||||
|
|
||||
|
- [ ] **Step 3: Point `reload()` through the same in-flight gate** |
||||
|
|
||||
|
Replace `reload` body with: |
||||
|
|
||||
|
```js |
||||
|
async function reload() { |
||||
|
await pollDevices({ toastOnSuccess: true }) |
||||
|
if (monitorDisposed) return |
||||
|
if (selectedId.value) flyToSelected() |
||||
|
else resetOverviewCamera() |
||||
|
} |
||||
|
``` |
||||
|
|
||||
|
(`pollDevices` already clears stale selection / selectedDockIds / syncMarkers.) |
||||
|
|
||||
|
- [ ] **Step 4: Static check** |
||||
|
|
||||
|
```bash |
||||
|
rg -n "DEVICE_POLL_MS|pollDevices|startDevicePolling|visibilitychange|toastOnSuccess" src/views/MonitorView/MonitorView.vue |
||||
|
``` |
||||
|
|
||||
|
Expected: 5000 interval, visibility handler, `reload` uses `pollDevices({ toastOnSuccess: true })`. |
||||
|
|
||||
|
- [ ] **Step 5: Commit** |
||||
|
|
||||
|
```bash |
||||
|
git add src/views/MonitorView/MonitorView.vue |
||||
|
git commit -m "feat: poll monitor device status every 5s" |
||||
|
``` |
||||
|
|
||||
|
--- |
||||
|
|
||||
|
### Task 3: DeviceDetailView current-id detail polling |
||||
|
|
||||
|
**Files:** |
||||
|
- Modify: `src/views/DeviceDetailView/DeviceDetailView.vue` |
||||
|
|
||||
|
- [ ] **Step 1: Extend imports** |
||||
|
|
||||
|
Change: |
||||
|
|
||||
|
```js |
||||
|
import { computed, onMounted, ref } from 'vue' |
||||
|
``` |
||||
|
|
||||
|
to: |
||||
|
|
||||
|
```js |
||||
|
import { computed, onMounted, onUnmounted, ref, watch } from 'vue' |
||||
|
``` |
||||
|
|
||||
|
- [ ] **Step 2: Add poll helpers after `record` / `isDrone` computeds** |
||||
|
|
||||
|
```js |
||||
|
const DETAIL_POLL_MS = 5000 |
||||
|
let detailPollTimer = null |
||||
|
let detailPollInflight = null |
||||
|
let detailPollGen = 0 |
||||
|
let detailDisposed = false |
||||
|
|
||||
|
function clearDetailPollTimer() { |
||||
|
window.clearInterval(detailPollTimer) |
||||
|
detailPollTimer = null |
||||
|
} |
||||
|
|
||||
|
async function pollCurrentDetail() { |
||||
|
if (detailDisposed) return |
||||
|
if (detailPollInflight) return |
||||
|
const id = String(route.params.id || '') |
||||
|
const rec = devices.record(id) |
||||
|
if (!id || !rec) return |
||||
|
const gen = detailPollGen |
||||
|
const url = rec.kind === 'drone' ? urls.DRONE(id) : urls.DOCK(id) |
||||
|
detailPollInflight = request.get(url) |
||||
|
try { |
||||
|
const detail = await detailPollInflight |
||||
|
if (detailDisposed || gen !== detailPollGen) return |
||||
|
if (String(route.params.id) !== id) return |
||||
|
if (rec.kind === 'drone') devices.applyDroneDetail(id, detail || {}) |
||||
|
else devices.applyDockDetail(id, detail || {}) |
||||
|
} catch (e) { |
||||
|
if (detailDisposed || gen !== detailPollGen) return |
||||
|
console.warn('[device-detail] poll failed', e) |
||||
|
} finally { |
||||
|
detailPollInflight = null |
||||
|
} |
||||
|
} |
||||
|
|
||||
|
function startDetailPolling() { |
||||
|
clearDetailPollTimer() |
||||
|
if (detailDisposed || document.visibilityState === 'hidden') return |
||||
|
detailPollTimer = window.setInterval(() => { |
||||
|
void pollCurrentDetail() |
||||
|
}, DETAIL_POLL_MS) |
||||
|
} |
||||
|
|
||||
|
function stopDetailPolling() { |
||||
|
clearDetailPollTimer() |
||||
|
} |
||||
|
|
||||
|
function restartDetailPolling() { |
||||
|
detailPollGen += 1 |
||||
|
stopDetailPolling() |
||||
|
void pollCurrentDetail() |
||||
|
startDetailPolling() |
||||
|
} |
||||
|
|
||||
|
function onDetailVisibility() { |
||||
|
if (detailDisposed) return |
||||
|
if (document.visibilityState === 'hidden') { |
||||
|
stopDetailPolling() |
||||
|
return |
||||
|
} |
||||
|
void pollCurrentDetail() |
||||
|
startDetailPolling() |
||||
|
} |
||||
|
``` |
||||
|
|
||||
|
- [ ] **Step 3: Lifecycle + id watch** |
||||
|
|
||||
|
Replace `onMounted` and add unmount/watch: |
||||
|
|
||||
|
```js |
||||
|
onMounted(async () => { |
||||
|
detailDisposed = false |
||||
|
document.addEventListener('visibilitychange', onDetailVisibility) |
||||
|
try { |
||||
|
await devices.load() |
||||
|
if (!isAdmin.value) { |
||||
|
await Promise.all([loadLogs(), loadAlarms()]) |
||||
|
} |
||||
|
} catch (e) { |
||||
|
ui.toast(e.message || '加载设备失败') |
||||
|
} |
||||
|
startDetailPolling() |
||||
|
}) |
||||
|
|
||||
|
onUnmounted(() => { |
||||
|
detailDisposed = true |
||||
|
detailPollGen += 1 |
||||
|
stopDetailPolling() |
||||
|
document.removeEventListener('visibilitychange', onDetailVisibility) |
||||
|
}) |
||||
|
|
||||
|
watch( |
||||
|
() => String(route.params.id || ''), |
||||
|
(next, prev) => { |
||||
|
if (!next || next === prev) return |
||||
|
restartDetailPolling() |
||||
|
} |
||||
|
) |
||||
|
``` |
||||
|
|
||||
|
Keep `handleDockSaved` full `devices.load()` as-is (edit path, not poll path). |
||||
|
|
||||
|
- [ ] **Step 4: Static check** |
||||
|
|
||||
|
```bash |
||||
|
rg -n "DETAIL_POLL_MS|pollCurrentDetail|applyDockDetail|applyDroneDetail|visibilitychange" src/views/DeviceDetailView/DeviceDetailView.vue |
||||
|
``` |
||||
|
|
||||
|
Expected: 5s timer; apply* calls; visibility + id watch; no DevicesView changes. |
||||
|
|
||||
|
- [ ] **Step 5: Commit** |
||||
|
|
||||
|
```bash |
||||
|
git add src/views/DeviceDetailView/DeviceDetailView.vue |
||||
|
git commit -m "feat: poll open device detail every 5s" |
||||
|
``` |
||||
|
|
||||
|
--- |
||||
|
|
||||
|
### Task 4: Build, deploy, smoke |
||||
|
|
||||
|
**Files:** none (verify only) |
||||
|
|
||||
|
- [ ] **Step 1: Build** |
||||
|
|
||||
|
```bash |
||||
|
npm run build |
||||
|
``` |
||||
|
|
||||
|
Expected: Vite build success. |
||||
|
|
||||
|
- [ ] **Step 2: Push + deploy** (same channel as recent frontend deploys) |
||||
|
|
||||
|
```bash |
||||
|
git push origin main |
||||
|
tar -C dist -czf - . | ssh -o BatchMode=yes jg-serv1 'rm -rf /usr/share/nginx/laic-frontend/dist/* && tar -C /usr/share/nginx/laic-frontend/dist -xzf -' |
||||
|
``` |
||||
|
|
||||
|
- [ ] **Step 3: Manual smoke** |
||||
|
|
||||
|
1. Open 实时监控 → DevTools Network:约每 5s 出现 `/v1/docks`、`/v1/drones` 及详情请求;列表/右侧状态会变。 |
||||
|
2. Open 某台设备详情 → 仅见该 id 的 `/v1/docks/:id` 或 `/v1/drones/:id` 约 5s 一次(在首次 load 之后)。 |
||||
|
3. Open 设备管理 → **无**定时详情轮询。 |
||||
|
4. 切到其它浏览器标签再回来:监控/详情应先补一次请求再继续 interval。 |
||||
|
5. 开播/停播/指令浮层仍可用。 |
||||
|
|
||||
|
- [ ] **Step 4: Final commit only if smoke required doc tweak; otherwise done** |
||||
|
|
||||
|
No code commit required if Steps 1–3 pass. |
||||
|
|
||||
|
--- |
||||
|
|
||||
|
## Self-review vs spec |
||||
|
|
||||
|
| Spec requirement | Task | |
||||
|
|------------------|------| |
||||
|
| Monitor 5s `devices.load` | Task 2 | |
||||
|
| in-flight skip + silent fail | Task 2 `pollDevices` | |
||||
|
| visibility pause / resume + immediate refresh | Task 2 | |
||||
|
| unmount / pagehide stop | Task 2 | |
||||
|
| `reload` shares in-flight | Task 2 Step 3 | |
||||
|
| DeviceDetail current-id only | Task 3 | |
||||
|
| apply* merge + assets sync; missing id no-op | Task 1 | |
||||
|
| DevicesView no auto poll | no task touches it | |
||||
|
| live / command progress unchanged | Tasks avoid those modules | |
||||
|
| build/deploy/smoke | Task 4 | |
||||
@ -0,0 +1,112 @@ |
|||||
|
# 实时监控 / 设备详情状态轮询 |
||||
|
|
||||
|
日期:2026-09-03 |
||||
|
状态:已确认(待写实现计划) |
||||
|
范围:仅前端 `laic-frontend` |
||||
|
|
||||
|
## 1. 背景 |
||||
|
|
||||
|
「实时监控」页当前只在 `onMounted`(以及指令成功后的 `reload`)调用一次 `devices.load()`。左侧设备列表、右侧详情面板、地图 marker 都读同一份 Pinia `devicesStore`;store 不刷新,UI 就不更新。 |
||||
|
|
||||
|
直播会话(`useMonitorLive`)与指令进度(`useCommandProgress`)已有各自定时器,但**设备状态本身没有轮询**,与「实时监控」语义不符。 |
||||
|
|
||||
|
现有 `devices.load()` 契约: |
||||
|
|
||||
|
1. `GET /v1/docks` + `GET /v1/drones`(近全量 pageSize=100) |
||||
|
2. 再对每条 `GET /v1/docks/:id` / `GET /v1/drones/:id` 取 `online` + `realtime` |
||||
|
3. 映射 status / environment / alarms / 地图坐标后写入 `docks` / `drones` / `assets` |
||||
|
|
||||
|
设备详情页 `DeviceDetailView` 同样只在挂载时 `devices.load()` 一次,无持续刷新。 |
||||
|
|
||||
|
## 2. 目标 |
||||
|
|
||||
|
1. **实时监控页**停在页面上时,设备列表 / 选中详情 / 地图状态约每 **5 秒**自动更新。 |
||||
|
2. **设备详情页**只刷新**当前路由打开的那一台**设备详情,约每 **5 秒**一次。 |
||||
|
3. 离开页面或标签页隐藏时停止轮询;回到前台立即补刷一次再恢复。 |
||||
|
4. 不改变直播 heartbeat / phase / play-url,也不改变指令进度轮询。 |
||||
|
|
||||
|
## 3. 非目标 |
||||
|
|
||||
|
- **设备管理列表页(`DevicesView`)不自动刷新**(仍手动刷新按钮)。 |
||||
|
- 不新增后端批量快照 / WebSocket / SSE。 |
||||
|
- 不在本轮优化掉 Monitor 的 N+1 详情请求(已知成本,后续可换批量 API)。 |
||||
|
- 不改 `DevicesView` 分页本地 `tableRecords` 数据源。 |
||||
|
|
||||
|
## 4. 方案(页面各自定时器) |
||||
|
|
||||
|
采用页面级 `setInterval`,不引入 store 全局轮询器。 |
||||
|
|
||||
|
### 4.1 `MonitorView` |
||||
|
|
||||
|
1. `onMounted`:先做现有首次 `devices.load()`(失败仍 toast 一次,与现状一致);无论首次成败,只要仍挂在本页就启动 `setInterval(() => void pollDevices(), 5000)`。 |
||||
|
2. `pollDevices`: |
||||
|
- 若上一轮 `load` 仍 in-flight → **跳过本轮**(防请求堆积)。 |
||||
|
- 否则 `await devices.load()`。 |
||||
|
- 单次失败:静默(`console.warn` 即可),**不 toast**,下一轮继续。 |
||||
|
- `401` 仍走现有 `http` 拦截器(登出 / 跳转)。 |
||||
|
3. `onUnmounted` / `pagehide`:`clearInterval`;用页面级 `disposed`/`generation` 忽略卸载后才返回的轮询结果(避免卸载后无意义的续跑逻辑;store 已被 `load()` 写入可保留,不必回滚)。 |
||||
|
4. `document.visibilitychange`: |
||||
|
- `hidden` → 暂停(clearInterval) |
||||
|
- `visible` → 立即 `pollDevices()` 一次,再重新 `setInterval` |
||||
|
5. 指令路径现有 `reload()` 继续直接 `devices.load()`;与轮询共享同一 in-flight 闸门更佳(同一 `loading`/`inflight` 标志),避免指令 reload 与定时器重叠打双份。 |
||||
|
|
||||
|
### 4.2 `DeviceDetailView` |
||||
|
|
||||
|
1. 保留挂载时一次 `devices.load()`(以及非 admin 的 logs/alarms)。 |
||||
|
2. 另启 **当前 `route.params.id`** 的详情轮询,间隔 5000ms: |
||||
|
- dock → `GET /v1/docks/:id` |
||||
|
- drone → `GET /v1/drones/:id` |
||||
|
3. 响应经 store 新方法合并进**对应一条**记录(见 4.3),驱动本页与若仍挂着的 Monitor 共享状态。 |
||||
|
4. `watch(() => route.params.id)`:停旧定时器,按新 id 立即拉一次并重启 interval。 |
||||
|
5. 生命周期 / visibility / in-flight 跳过 / 失败静默:与 Monitor 同规则。 |
||||
|
6. 离开页:清除定时器。 |
||||
|
|
||||
|
### 4.3 `devicesStore` 增量回写 |
||||
|
|
||||
|
新增(命名可微调,语义固定): |
||||
|
|
||||
|
- `applyDockDetail(id, detail)` |
||||
|
- `applyDroneDetail(id, detail)` |
||||
|
|
||||
|
行为: |
||||
|
|
||||
|
1. 找到 `docks` / `drones` 中对应 `id`;找不到则 **no-op + `console.warn`**(不触发全量 `load`,避免详情页单独制造全表风暴)。 |
||||
|
2. 用与 `load()` 相同的映射规则更新该条:`online`、`realtime`、`status` / `statusClass`、`environment`、`alarms`、`mode`、无人机 `battery` / `_lat` `_lon` `_alt` 等派生字段。 |
||||
|
3. 同步更新 `assets[id]` 上用于地图的 status / 坐标 / realtime 相关字段,避免 Monitor 与详情不一致。 |
||||
|
4. **不**重拉列表,**不**重建无关条目。 |
||||
|
|
||||
|
`load()` 本身可抽一小段「detail → record 字段」纯函数供全量与增量共用,避免两套映射分叉;若改动面过大,允许增量路径先复制必要映射,但字段语义必须与 `load()` 一致。 |
||||
|
|
||||
|
## 5. 错误与并发 |
||||
|
|
||||
|
| 场景 | 行为 | |
||||
|
|------|------| |
||||
|
| 轮询 HTTP 业务/网络失败 | 静默,保留旧数据,下轮再试 | |
||||
|
| 401 | 现有拦截器登出 | |
||||
|
| 上轮未完成 | 跳过本轮 | |
||||
|
| 页面 hidden | 暂停 timer | |
||||
|
| 页面 visible | 立即补一次 + 重启 timer | |
||||
|
| 详情 id 切换 | 取消旧轮询,新 id 立即请求 | |
||||
|
|
||||
|
## 6. 验收 |
||||
|
|
||||
|
1. 停留在实时监控:约 5s 内列表状态 / 右侧详情(电量、舱门、环境、在线等)/ 地图 marker 会随后端变化更新。 |
||||
|
2. 打开设备详情 A:网络面板仅见对 A 的详情轮询;切换到 B 后改为 B。 |
||||
|
3. 设备管理列表页打开时**无**定时 `/docks/:id` `/drones/:id` 轮询(仅用户点击刷新或进入时的请求)。 |
||||
|
4. 从监控/详情路由离开,或切到其它浏览器标签:轮询停止;切回后先补刷再按 5s 继续。 |
||||
|
5. 开播、停播、指令进度浮层行为与改前一致。 |
||||
|
|
||||
|
## 7. 风险 |
||||
|
|
||||
|
- Monitor 每 5s 全量 `load()` 仍是列表 + N 次详情;设备数量上来后 QPS 偏高。本轮按产品选择接受;后续应用批量状态接口替换 `pollDevices` 内部实现,页面契约可不变。 |
||||
|
- 详情增量映射若与 `load()` 分叉,会出现「详情页字段」与「监控全量刷新后字段」不一致;优先抽共享映射。 |
||||
|
|
||||
|
## 8. 实现落点(预告) |
||||
|
|
||||
|
| 文件 | 变更 | |
||||
|
|------|------| |
||||
|
| `src/stores/modules/devicesStore.js` | 抽共享映射;新增 `applyDockDetail` / `applyDroneDetail` | |
||||
|
| `src/views/MonitorView/MonitorView.vue` | 5s 轮询 + visibility + 与 `reload` 共用 in-flight | |
||||
|
| `src/views/DeviceDetailView/DeviceDetailView.vue` | 当前 id 详情轮询 + id watch + visibility | |
||||
|
|
||||
|
完成后:实现计划 → 编码 → 构建部署 → 人工看监控与详情是否按 5s 变。 |
||||
Loading…
Reference in new issue