Upload 10 files

core/config.py

@@ -52,6 +52,7 @@ class RetryConfig(BaseModel):
     account_failure_threshold: int = Field(default=3, ge=1, le=10, description="账户失败阈值")
     rate_limit_cooldown_seconds: int = Field(default=600, ge=60, le=3600, description="429冷却时间（秒）")
     session_cache_ttl_seconds: int = Field(default=3600, ge=300, le=86400, description="会话缓存时间（秒）")
+    auto_refresh_accounts_seconds: int = Field(default=60, ge=0, le=600, description="自动刷新账号间隔（秒，0禁用）")
 
 
 class PublicDisplayConfig(BaseModel):
@@ -282,6 +283,11 @@ class ConfigManager:
         """会话缓存时间（秒）"""
         return self._config.retry.session_cache_ttl_seconds
 
+    @property
+    def auto_refresh_accounts_seconds(self) -> int:
+        """自动刷新账号间隔（秒，0禁用）"""
+        return self._config.retry.auto_refresh_accounts_seconds
+
 
 # ==================== 全局配置管理器 ====================
 

core/storage.py

@@ -159,6 +159,33 @@ async def load_accounts() -> Optional[list]:
     return None
 
 
+async def get_accounts_updated_at() -> Optional[float]:
+    """
+    Get the accounts updated_at timestamp (epoch seconds).
+    Return None if database is not enabled or failed.
+    """
+    if not is_database_enabled():
+        return None
+    try:
+        pool = await _get_pool()
+        async with pool.acquire() as conn:
+            row = await conn.fetchrow(
+                "SELECT EXTRACT(EPOCH FROM updated_at) AS ts FROM kv_store WHERE key = $1",
+                "accounts",
+            )
+            if not row or row["ts"] is None:
+                return None
+            return float(row["ts"])
+    except Exception as e:
+        logger.error(f"[STORAGE] Database accounts updated_at failed: {e}")
+    return None
+
+
+def get_accounts_updated_at_sync() -> Optional[float]:
+    """Sync wrapper for get_accounts_updated_at."""
+    return _run_in_db_loop(get_accounts_updated_at())
+
+
 async def save_accounts(accounts: list) -> bool:
     """Save account configuration to database when enabled."""
     if not is_database_enabled():