From 18592fcd69339cbd3454d537bafbec9f20d0082e Mon Sep 17 00:00:00 2001
From: 27942 <ferfgf@fewfef>
Date: Wed, 21 Jan 2026 11:32:48 +0800
Subject: [PATCH] 23423423

---
 交易/bitmart-趋势策略交易.py | 12 ++++++++++--
 1 file changed, 10 insertions(+), 2 deletions(-)

diff --git a/交易/bitmart-趋势策略交易.py b/交易/bitmart-趋势策略交易.py
index 4a2d23b..ad12f34 100644
--- a/交易/bitmart-趋势策略交易.py
+++ b/交易/bitmart-趋势策略交易.py
@@ -66,8 +66,14 @@ class BitmartFuturesTransaction:
             formatted.sort(key=lambda x: x['id'])
             return formatted  # 最近3根: kline_1 (最老), kline_2, kline_3 (最新)
         except Exception as e:
-            logger.error(f"获取K线异常: {e}")
-            self.ding(msg="获取K线异常", error=True)
+            error_msg = str(e)
+            # 检查是否是429限流错误
+            if "429" in error_msg or "too many requests" in error_msg.lower():
+                logger.warning(f"API限流，等待60秒后重试: {e}")
+                time.sleep(60)  # 等待60秒后重试
+            else:
+                logger.error(f"获取K线异常: {e}")
+                self.ding(msg="获取K线异常", error=True)
             return None
 
     def get_current_price(self):
@@ -346,6 +352,8 @@ class BitmartFuturesTransaction:
             new_price_datas = self.get_klines()
             if not new_price_datas:
                 logger.info("获取最新价格有问题！！！")
+                time.sleep(5)  # 等待一段时间后重试
+                continue  # 跳过本次循环，避免对None进行排序操作
 
             new_price_datas1 = sorted(new_price_datas, key=lambda x: x["id"])
             self.kline_1, self.kline_2, self.kline_3 = new_price_datas1[-3:]