Add Binance spot fallback bases

coinpush.py

@@ -51,6 +51,14 @@ BINANCE_API_SECRET = os.getenv("BINANCE_API_SECRET")
 SPOT_BASE = os.getenv("BINANCE_SPOT_BASE", "https://api.binance.com")
 FAPI_BASE = os.getenv("BINANCE_FAPI_BASE", "https://fapi.binance.com")
 FSTREAM_BASE = os.getenv("BINANCE_FSTREAM_BASE", "wss://fstream.binance.com/ws")
+SPOT_FALLBACK_BASES = [
+    base.strip().rstrip("/")
+    for base in os.getenv(
+        "BINANCE_SPOT_FALLBACK_BASES",
+        "https://data-api.binance.vision,https://api1.binance.com,https://api2.binance.com,https://api3.binance.com",
+    ).split(",")
+    if base.strip()
+]
 FAPI_451_COOLDOWN_SEC = int(os.getenv("BINANCE_FAPI_451_COOLDOWN_SEC", "3600"))
 ALPHA_BASE = os.getenv("BINANCE_ALPHA_BASE", "https://www.binance.com")
 ALPHA_TOKEN_CACHE_TTL_SEC = int(os.getenv("BINANCE_ALPHA_TOKEN_CACHE_TTL_SEC", "300"))
@@ -672,30 +680,48 @@ class BinanceAPI:
         self.session = requests.Session()
         self.session.headers.update(REQ_HEADERS)
         self.fapi_blocked_until = 0.0
+        self.spot_fallback_logged = set()
         if BINANCE_API_KEY:
             self.session.headers.update({"X-MBX-APIKEY": BINANCE_API_KEY})
 
+    def _bases_for(self, base):
+        if base != SPOT_BASE:
+            return [base]
+        bases = [SPOT_BASE.rstrip("/")]
+        for candidate in SPOT_FALLBACK_BASES:
+            if candidate and candidate not in bases:
+                bases.append(candidate)
+        return bases
+
     def _get(self, base, path, params=None, timeout=10):
         is_fapi = base == FAPI_BASE or path.startswith("/fapi/")
         now = time.time()
         if is_fapi and now < self.fapi_blocked_until:
             return None
-        try:
-            r = self.session.get(base + path, params=params, timeout=timeout)
-            if r.status_code != 200:
-                if is_fapi and r.status_code == 451:
-                    self.fapi_blocked_until = now + FAPI_451_COOLDOWN_SEC
-                    mins = max(1, int(FAPI_451_COOLDOWN_SEC / 60))
-                    self.logger(
-                        f"⚠️ Binance 合约接口 /fapi 当前区域受限(451)，"
-                        f"暂停直连 {mins} 分钟并使用备用行情")
-                    return None
-                self.logger(f"⚠️ 接口 {path} 状态码 {r.status_code}")
+        last_error = None
+        for current_base in self._bases_for(base):
+            try:
+                r = self.session.get(current_base + path, params=params, timeout=timeout)
+            except Exception as e:
+                last_error = f"异常 {e} ({current_base})"
+                continue
+            if r.status_code == 200:
+                if current_base != base.rstrip("/"):
+                    key = (path, current_base)
+                    if key not in self.spot_fallback_logged:
+                        self.logger(f"ℹ️ Binance 现货主源不可用，已切换备用行情 {current_base}")
+                        self.spot_fallback_logged.add(key)
+                return r.json()
+            if is_fapi and r.status_code == 451:
+                self.fapi_blocked_until = now + FAPI_451_COOLDOWN_SEC
+                mins = max(1, int(FAPI_451_COOLDOWN_SEC / 60))
+                self.logger(
+                    f"⚠️ Binance 合约接口 /fapi 当前区域受限(451)，"
+                    f"暂停直连 {mins} 分钟并使用备用行情")
                 return None
-            return r.json()
-        except Exception as e:
-            self.logger(f"⚠️ 接口 {path} 异常: {e}")
-            return None
+            last_error = f"状态码 {r.status_code} ({current_base})"
+        self.logger(f"⚠️ 接口 {path} {last_error or '无可用响应'}")
+        return None
 
     # 现货行情
     def ticker_24h(self, symbol):