From a6367ab7c2f49f81754616b23db65ab7b2da13b3 Mon Sep 17 00:00:00 2001 From: "2569718930@qq.com" <2569718930@qq.com> Date: Mon, 25 May 2026 23:09:37 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=20marketOverview=20=E7=A7=BB?= =?UTF-8?q?=E9=99=A4=E5=90=8E=E7=9A=84=E5=AF=BC=E5=85=A5=E9=94=99=E8=AF=AF?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- frontend/lib/refresh-policy.ts | 2 ++ src/utils/refresh_policy.py | 1 + web/services/market_overview_api.py | 4 +++- 3 files changed, 6 insertions(+), 1 deletion(-) diff --git a/frontend/lib/refresh-policy.ts b/frontend/lib/refresh-policy.ts index c9cb3582..f8f05f34 100644 --- a/frontend/lib/refresh-policy.ts +++ b/frontend/lib/refresh-policy.ts @@ -2,6 +2,7 @@ export const DASHBOARD_REFRESH_POLICY_SEC = { observation: 60, metar: 5 * 60, scanRows: 5 * 60, + marketOverview: 10 * 60, model: 30 * 60, } as const; @@ -9,5 +10,6 @@ export const DASHBOARD_REFRESH_POLICY_MS = { observation: DASHBOARD_REFRESH_POLICY_SEC.observation * 1000, metar: DASHBOARD_REFRESH_POLICY_SEC.metar * 1000, scanRows: DASHBOARD_REFRESH_POLICY_SEC.scanRows * 1000, + marketOverview: DASHBOARD_REFRESH_POLICY_SEC.marketOverview * 1000, model: DASHBOARD_REFRESH_POLICY_SEC.model * 1000, } as const; diff --git a/src/utils/refresh_policy.py b/src/utils/refresh_policy.py index 93928b97..55a37047 100644 --- a/src/utils/refresh_policy.py +++ b/src/utils/refresh_policy.py @@ -5,4 +5,5 @@ from __future__ import annotations OBSERVATION_REFRESH_SEC = 60 METAR_POLL_TTL_SEC = 5 * 60 SCAN_ROWS_REFRESH_SEC = 5 * 60 +MARKET_OVERVIEW_TTL_SEC = 10 * 60 MODEL_CACHE_TTL_SEC = 30 * 60 diff --git a/web/services/market_overview_api.py b/web/services/market_overview_api.py index 0d401b8f..2d07d713 100644 --- a/web/services/market_overview_api.py +++ b/web/services/market_overview_api.py @@ -9,9 +9,11 @@ import time from datetime import datetime from typing import Any, Dict, List, Optional +from src.utils.refresh_policy import MARKET_OVERVIEW_TTL_SEC + _OVERVIEW_CACHE: Dict[str, Dict[str, Any]] = {} _OVERVIEW_CACHE_LOCK = threading.Lock() -OVERVIEW_CACHE_TTL_SEC = 600 +OVERVIEW_CACHE_TTL_SEC = MARKET_OVERVIEW_TTL_SEC def _safe_float(value: Any) -> Optional[float]: