-
{label}
-
{value}
+
+
+
+ {engaged ? (
+
+ ● 已熔断
+
+ ) : (
+
+ ● 未熔断
+
+ )}
+
+ 生效来源
+ {source}
+
+
+
+ {engaged ? (
+
+ ) : (
+
+ )}
+
+
+ {engaged ? (
+
+ 所有 automatic 模式的 Control Cycle 执行将在下一次 tick 被无条件短路。
+ 运行期覆盖在进程重启后被清除，恢复为配置默认值。
+
+ ) : (
+
+ 熔断关闭不代表自动模式已开启——仍需 CONTROL_MODE=automatic 及全部门禁通过才会执行。
+
+ )}
)
}
-function OdpSection({
+/* ────────────────────────────────────────────────────────────────
+ * ODP data plane — Monitor layer, compact. Five small cells, each
+ * degrades independently with the backend's reason surfaced.
+ * ──────────────────────────────────────────────────────────────── */
+
+function OdpCell({
title,
state,
children,
@@ -76,114 +161,133 @@ function OdpSection({
children: React.ReactNode
}) {
return (
-
+
- {title}
+ {title}
{state.available ? (
-
+
) : (
-
+
)}
{state.available ? (
-
{children}
+
{children}
) : (
-
- {state.error || '当前不可用（依赖的 Redis / 数据面未部署）'}
+
+ {state.error || '不可用'}
)}
)
}
-function OdpPanels({ state }: { state: OdpSystemState }) {
+function OdpGrid({ state }: { state: OdpSystemState }) {
+ const availableCount = [
+ state.ingest.available,
+ state.stream.available,
+ state.dlq.available,
+ state.store.available,
+ state.outbox.available,
+ ].filter(Boolean).length
return (
-
-
-
-
-
-
-
-
-
+
+
+
+ {state.ingest.healthy === true ? '健康' : state.ingest.healthy === false ? '异常' : '未知'}
+
+
+
+ {state.stream.group || '—'}
+
+ lag {state.stream.lag == null ? '—' : formatNum(state.stream.lag)}
+
+
+ pend {state.stream.pending == null ? '—' : formatNum(state.stream.pending)}
+
+
+ idle{' '}
+ {state.stream.oldest_pending_idle_ms == null
? '—'
- : formatMs(state.stream.oldest_pending_idle_ms)
- }
- />
-
-
-
-
-
-
-
+
+
+ {state.dlq.total == null ? '—' : formatNum(state.dlq.total)}
+
+ 24h {state.dlq.last_24h == null ? '—' : formatNum(state.dlq.last_24h)}
+
+
+
+
+ {state.store.heartbeat_age_seconds == null
? '—'
- : `${state.store.heartbeat_age_seconds}s`
- }
- />
- {state.store.note ? (
- {state.store.note}
- ) : null}
-
-
-
- {state.outbox.note ? (
- {state.outbox.note}
- ) : null}
-
+ : `${state.store.heartbeat_age_seconds}s`}
+
+ {state.store.note ? (
+
+ {state.store.note}
+
+ ) : null}
+
+
+
+ {state.outbox.unpublished == null ? '—' : formatNum(state.outbox.unpublished)}
+
+ {state.outbox.note ? (
+
+ {state.outbox.note}
+
+ ) : null}
+
+
+
+ 可用区块 {availableCount}/5 · 采集于 {formatRelative(state.collected_at)}
+
)
}
+/* ────────────────────────────────────────────────────────────────
+ * Advisory report — the automation-gate data. Buckets carry a gate
+ * badge: mostly-recovered buckets must NOT be automated, mostly-
+ * persisted ones qualify.
+ * ──────────────────────────────────────────────────────────────── */
+
+function gateEligible(bucket: AdvisoryReport['buckets'][number]): boolean {
+ if (bucket.recovery_rate == null) return false
+ return bucket.recovery_rate < 0.8 && bucket.persisted > 0
+}
+
function AdvisoryTotalsRow({ report }: { report: AdvisoryReport }) {
const t = report.totals
return (
-
-
-
-
-
-
-
= 0.8 ? 'bad' : 'muted'}
- />
+
+
+ 总数
+ {formatNum(t.total)}
+
+
+ 待评估
+ {formatNum(t.pending)}
+
+
+ 已恢复
+ {formatNum(t.recovered)}
+
+
+ 已固化
+ {formatNum(t.persisted)}
+
+
+ 恢复率
+ {t.recovery_rate == null ? '—' : `${(t.recovery_rate * 100).toFixed(1)}%`}
+
+ {Object.entries(report.mode_breakdown).map(([mode, count]) => (
+
+ {mode === 'automatic' ? '自动' : '建议'} × {formatNum(count)}
+
+ ))}
)
}
@@ -201,18 +305,14 @@ function AuditLedger() {
return (
-
-
-
- 审计台账（控制动作）
-
- 控制器的完整证据账本——每一次建议与执行，按状态类别 / 模式 / 结果过滤。
-
-
-
+
+
+ 审计台账（控制动作）
+ 每一次建议与执行的证据账本。
+
{isLoading ? (
@@ -279,7 +379,7 @@ function AuditLedger() {
{meta && meta.pages > 1 ? (
- 共 {meta.total} 条 · 第 {meta.page}/{meta.pages} 页
+ 共 {formatNum(meta.total)} 条 · 第 {meta.page}/{meta.pages} 页