From 8ba6d2a31c285db607b51eb4bc4236c7732042a3 Mon Sep 17 00:00:00 2001 From: "zhangkun9038@dingtalk.com" Date: Thu, 27 Nov 2025 17:08:20 +0800 Subject: [PATCH] =?UTF-8?q?redis=E4=BF=9D=E5=AD=98=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- user_data/strategies/grid_manager.py | 3 +++ user_data/strategies/staticgrid.py | 8 ++++++-- 2 files changed, 9 insertions(+), 2 deletions(-) diff --git a/user_data/strategies/grid_manager.py b/user_data/strategies/grid_manager.py index 588b4a1..6871643 100644 --- a/user_data/strategies/grid_manager.py +++ b/user_data/strategies/grid_manager.py @@ -246,6 +246,9 @@ class GridManager: # ✅ 立即同步上次改变上 Redis self.sync_grid_state_to_redis() + + print(f"[GridManager] {self.pair} 网格状态已同步到 Redis", + file=sys.stderr, flush=True) def decide_adjustment(self) -> Optional[PositionRecord]: """ diff --git a/user_data/strategies/staticgrid.py b/user_data/strategies/staticgrid.py index c4deba5..8af0353 100644 --- a/user_data/strategies/staticgrid.py +++ b/user_data/strategies/staticgrid.py @@ -317,7 +317,7 @@ class StaticGrid(IStrategy): file=sys.stderr, flush=True) if adjustment and adjustment.type == AdjustmentType.ADD: - # 订单可窲事执行，先更新网格状态（谨慎起见） + # 订单可执行，先更新网格状态（谨慎起见） grid_manager.apply_adjustment(adjustment) # 计算加仓金额 @@ -329,7 +329,11 @@ class StaticGrid(IStrategy): # 检查是否超过最大可用金额 if stake_amount <= max_stake: - print(f"[StaticGrid] {pair} ✅ 加仓批准 - 返回金额: {stake_amount:.2f}", + # 计算还能加仓多少次 + filled_grids = sum(1 for gs in grid_manager.grid_states.values() if gs.status == "filled") + remaining_times = grid_manager.total_grid_levels - filled_grids + + print(f"[StaticGrid] {pair} 加仓批准, 最多还可以加仓{remaining_times}次 - 返回金额: {stake_amount:.2f}", file=sys.stderr, flush=True) return stake_amount else: