refactor: remove obsolete backend code paths

Author: tianhe

backend_api_python/app/commands/strategy_capacity_probe.py

@@ -15,7 +15,7 @@
 
 from app.events.dispatcher import StrategyDueDispatcher
 from app.events.evaluator import StrategyEvaluationBatchHandler
-from app.events.protocol import MarketBarClosedV1, StrategyEvaluationBatchV1
+from app.events.protocol import MarketBarClosedV1
 from app.services.event_inbox import InboxClaim
 from app.services.strategy_event_subscriptions import strategy_shard
 from app.services.strategy_runtime.scheduler import CooperativeRuntimeScheduler

backend_api_python/app/data/market_symbols_seed.py

@@ -271,43 +271,3 @@ def get_symbol_name(market: str, symbol: str) -> Optional[str]:
         logger.debug(f"get_symbol_name from DB failed: {e}")
 
     return None
-
-
-def get_all_symbols(market: str = None) -> List[Dict]:
-    """
-    Get all active symbols, optionally filtered by market.
-    
-    Args:
-        market: Optional market filter
-        
-    Returns:
-        List of symbol records
-    """
-    try:
-        with _get_db_connection() as db:
-            cur = db.cursor()
-            if market:
-                cur.execute(
-                    """
-                    SELECT market, symbol, name, exchange, currency, is_hot, sort_order
-                    FROM qd_market_symbols
-                    WHERE market = ? AND is_active = 1
-                    ORDER BY sort_order DESC
-                    """,
-                    (market.strip(),)
-                )
-            else:
-                cur.execute(
-                    """
-                    SELECT market, symbol, name, exchange, currency, is_hot, sort_order
-                    FROM qd_market_symbols
-                    WHERE is_active = 1
-                    ORDER BY market, sort_order DESC
-                    """
-                )
-            rows = cur.fetchall() or []
-            cur.close()
-            return [dict(r) for r in rows]
-    except Exception as e:
-        logger.debug(f"get_all_symbols from DB failed: {e}")
-        return []

backend_api_python/app/data_sources/base.py

@@ -5,7 +5,7 @@
 """
 from abc import ABC, abstractmethod
 from typing import Dict, List, Any, Optional
-from datetime import datetime, timedelta, timezone
+from datetime import datetime, timezone
 
 from app.utils.logger import get_logger
 

backend_api_python/app/data_sources/cache_manager.py

@@ -14,10 +14,9 @@
 
 import time
 import logging
-from typing import Dict, Any, Optional, List
+from typing import Dict, Any, Optional
 from collections import OrderedDict
-from dataclasses import dataclass, field
-from datetime import datetime
+from dataclasses import dataclass
 import threading
 
 logger = logging.getLogger(__name__)
@@ -204,20 +203,3 @@ def get_kline_cache() -> DataCache:
 def get_stock_info_cache() -> DataCache:
     """Return the stock info cache."""
     return _stock_info_cache
-
-
-def generate_kline_cache_key(
-    symbol: str,
-    timeframe: str,
-    limit: int,
-    before_time: Optional[int] = None
-) -> str:
-    """
-    Generate a K-line cache key.
-    
-    Format: symbol:timeframe:limit[:before_time]
-    """
-    key = f"{symbol}:{timeframe}:{limit}"
-    if before_time:
-        key += f":{before_time}"
-    return key

backend_api_python/app/data_sources/crypto.py

@@ -14,7 +14,7 @@
     normalize_market_type,
 )
 from app.utils.logger import get_logger
-from app.config import CryptoPublicConfig, APIKeys
+from app.config import CryptoPublicConfig
 
 logger = get_logger(__name__)
 
@@ -394,8 +394,6 @@ def _normalize_symbol_for_exchange(self, symbol: str) -> str:
         if not normalized or not base:
             return symbol
 
-        exchange_id = getattr(self.exchange, 'id', '').lower()
-        
         if self._ensure_markets_loaded():
             valid_symbol = self._find_valid_symbol(base, normalized.split('/')[1] if '/' in normalized else 'USDT')
             if valid_symbol:
@@ -451,7 +449,6 @@ def get_ticker(self, symbol: str) -> Dict[str, Any]:
             if ticker and isinstance(ticker, dict):
                 return ticker
         except Exception as e:
-            error_msg = str(e).lower()
             is_symbol_error = _is_symbol_not_found_error(e)
 
             if is_symbol_error:

backend_api_python/app/data_sources/futures.py

@@ -7,7 +7,6 @@
 from typing import Dict, List, Any, Optional
 from datetime import datetime, timedelta
 import os
-import time
 import requests
 import yfinance as yf
 

backend_api_python/app/data_sources/rate_limiter.py

@@ -177,21 +177,9 @@ def wrapper(*args, **kwargs) -> Any:
     return decorator
 
 
-_eastmoney_limiter = RateLimiter(min_interval=2.0, jitter_min=1.0, jitter_max=3.0)
 _tencent_limiter = RateLimiter(min_interval=1.0, jitter_min=0.5, jitter_max=1.5)
-_akshare_limiter = RateLimiter(min_interval=2.0, jitter_min=1.5, jitter_max=3.5)
-
-
-def get_eastmoney_limiter() -> RateLimiter:
-    """Return the Eastmoney rate limiter."""
-    return _eastmoney_limiter
 
 
 def get_tencent_limiter() -> RateLimiter:
     """Return the Tencent rate limiter."""
     return _tencent_limiter
-
-
-def get_akshare_limiter() -> RateLimiter:
-    """Return the AkShare rate limiter."""
-    return _akshare_limiter

backend_api_python/app/data_sources/tencent.py

@@ -11,7 +11,7 @@
 from __future__ import annotations
 
 from datetime import datetime
-from typing import Any, Dict, List, Optional, Tuple
+from typing import Any, Dict, List, Optional
 
 import requests
 

backend_api_python/app/data_sources/us_stock.py

@@ -14,7 +14,7 @@
 
 from app.data_sources.base import BaseDataSource
 from app.utils.logger import get_logger
-from app.config import APIKeys, YFinanceConfig
+from app.config import APIKeys
 
 logger = get_logger(__name__)
 

backend_api_python/app/openapi/helpers.py

@@ -3,7 +3,7 @@
 """
 from __future__ import annotations
 
-from typing import Any, Tuple
+from typing import Any
 
 from flask import jsonify
 
@@ -16,8 +16,3 @@ def ok(data: Any = None, msg: str = "success") -> dict:
 def fail(msg: str, *, code: int = 0, data: Any = None, http_status: int = 400):
     """Human API error envelope. Returns (body, status) for Flask views."""
     return jsonify({"code": code, "msg": msg, "data": data}), http_status
-
-
-def visibility_doc(level: str) -> dict:
-    """OpenAPI extension for Public / Internal / Private tiers."""
-    return {"x-visibility": level}