diff --git a/frontend/src/lib/api.ts b/frontend/src/lib/api.ts
index de54b86..d38429b 100644
--- a/frontend/src/lib/api.ts
+++ b/frontend/src/lib/api.ts
@@ -1648,15 +1648,13 @@ export const api = {
}),
},
),
- updateMinuteSync: (enabled: boolean, days: number, segmentDays?: number, refresh?: { enabled?: boolean; interval?: number }) =>
+ updateMinuteSync: (enabled: boolean, days: number, segmentDays?: number) =>
request
('/api/settings/preferences/minute-sync', {
method: 'PUT',
body: JSON.stringify({
minute_sync_enabled: enabled,
minute_sync_days: days,
...(segmentDays != null ? { minute_sync_segment_days: segmentDays } : {}),
- ...(refresh?.enabled != null ? { minute_refresh_enabled: refresh.enabled } : {}),
- ...(refresh?.interval != null ? { minute_refresh_interval: refresh.interval } : {}),
}),
}),
diff --git a/frontend/src/pages/settings/Monitoring.tsx b/frontend/src/pages/settings/Monitoring.tsx
index 94607b1..f515151 100644
--- a/frontend/src/pages/settings/Monitoring.tsx
+++ b/frontend/src/pages/settings/Monitoring.tsx
@@ -54,9 +54,21 @@ export function SettingsMonitoringPanel({ highlight }: { highlight?: string } =
const intradayInterval = prefs?.minute_intraday_refresh_interval ?? 6
// 滑块本地草稿: 拖动时即时反馈, 停顿 2s 后落库 (与行情轮询滑块一致)
const [intradayIntervalDraft, setIntradayIntervalDraft] = useState(intradayInterval)
+ // 盘中分钟增量 (Expert 专有): 间隔 (秒), 与后端 [60,300] clamp 对齐; 默认 60
+ const minuteRefreshInterval = prefs?.minute_refresh_interval ?? 60
+ const [minuteRefreshIntervalDraft, setMinuteRefreshIntervalDraft] = useState(minuteRefreshInterval)
+ // 盘中增量服务状态 (15s 轮询; 无服务时 available=false)
+ const refreshStatus = useQuery({
+ queryKey: ['minute-refresh-status'],
+ queryFn: api.minuteRefreshStatus,
+ refetchInterval: 15000,
+ })
const refreshPages = prefs?.sse_refresh_pages ?? {}
const limitLadderMonitor = prefs?.limit_ladder_monitor_enabled ?? false
const hasDepth = !!caps?.capabilities?.['depth5.batch']
+ // 盘中分钟增量 = intraday.batch 独立能力 (Expert 专有), 与盘后同步的 minute.batch 分属不同限流池
+ const hasIntradayBatchCap = !!caps?.capabilities?.['intraday.batch']
+ const rs = refreshStatus.data
// 新建监控规则时默认勾选的推送渠道 (全局默认值数组, 单条规则可独立修改)
const webhookDefaultChannels = prefs?.webhook_default_channels ?? []
const sidebarIndexSymbols = prefs?.sidebar_index_symbols ?? SIDEBAR_INDEX_OPTIONS.map(i => i.symbol)
@@ -262,6 +274,20 @@ export function SettingsMonitoringPanel({ highlight }: { highlight?: string } =
return () => window.clearTimeout(t)
}, [intradayIntervalDraft, intradayInterval, save])
+ // 盘中增量间隔: 服务端值变化时同步本地草稿
+ useEffect(() => {
+ setMinuteRefreshIntervalDraft(minuteRefreshInterval)
+ }, [minuteRefreshInterval])
+
+ // 盘中增量间隔: 草稿与已保存值不同时, 2s 防抖落库
+ useEffect(() => {
+ if (minuteRefreshIntervalDraft === minuteRefreshInterval) return
+ const t = window.setTimeout(() => {
+ save({ minute_refresh_interval: minuteRefreshIntervalDraft })
+ }, 2000)
+ return () => window.clearTimeout(t)
+ }, [minuteRefreshIntervalDraft, minuteRefreshInterval, save])
+
// highlight=depth-fix 时闪烁高亮连板梯队修正卡片
const [flash, setFlash] = useState(false)
const flashedRef = useRef(false)
@@ -282,6 +308,57 @@ export function SettingsMonitoringPanel({ highlight }: { highlight?: string } =
{/* ========== 左列 ========== */}
{/* 行情状态 — 开关 + 间隔 */}
+ {/* 盘中分钟增量落盘 (Expert 专有): 交易时段常驻服务, intraday.batch 独立配额 */}
+
+ save({ minute_refresh_enabled: v })}
+ disabled={!hasIntradayBatchCap || !!rs?.custom_provider_active}
+ />
+
+
+
+
刷新间隔
+
+ 交易时段内全市场脉冲落盘一轮的间隔; 下限 60s 保证不超 intraday.batch 配额
+
+
+
+ {minuteRefreshIntervalDraft >= 60 && minuteRefreshIntervalDraft % 60 === 0 ? `${minuteRefreshIntervalDraft / 60}m` : `${minuteRefreshIntervalDraft}s`}
+
+
+
+ setMinuteRefreshIntervalDraft(parseInt(e.target.value, 10))}
+ className="flex-1 h-1 accent-accent cursor-pointer disabled:opacity-40 disabled:cursor-not-allowed"
+ />
+
+ {minuteRefreshIntervalDraft !== minuteRefreshInterval ? '2秒后保存' : '60s — 300s'}
+
+
+ {rs?.available && rs.rounds != null && rs.rounds > 0 && (
+
+ 已 {rs.rounds} 轮 · 最近 {rs.last_symbols} 标的 / {rs.last_rows} 行 / {rs.last_requests} 请求
+ {rs.last_round_ms != null ? ` · ${(rs.last_round_ms / 1000).toFixed(1)}s` : ''}
+ {rs.last_error ? ` · ${rs.last_error}` : ''}
+
+ )}
+
+