phyer/myTestFreqAI
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

redis保存状态

Browse Source
This commit is contained in:
zhangkun9038@dingtalk.com 2025-11-27 17:08:20 +08:00
parent dd2c4dc470
commit 8ba6d2a31c
2 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
user_data/strategies/grid_manager.py
View File

@ -246,6 +246,9 @@ class GridManager:
# ✅ 立即同步上次改变上 Redis # ✅ 立即同步上次改变上 Redis
self.sync_grid_state_to_redis() self.sync_grid_state_to_redis()
print(f"[GridManager] {self.pair} 网格状态已同步到 Redis",
file=sys.stderr, flush=True)
def decide_adjustment(self) -> Optional[PositionRecord]: def decide_adjustment(self) -> Optional[PositionRecord]:
""" """

8
user_data/strategies/staticgrid.py
View File

@ -317,7 +317,7 @@ class StaticGrid(IStrategy):
file=sys.stderr, flush=True) file=sys.stderr, flush=True)
if adjustment and adjustment.type == AdjustmentType.ADD: if adjustment and adjustment.type == AdjustmentType.ADD:
# 订单可窲事执行，先更新网格状态（谨慎起见） # 订单可执行，先更新网格状态（谨慎起见）
grid_manager.apply_adjustment(adjustment) grid_manager.apply_adjustment(adjustment)
# 计算加仓金额 # 计算加仓金额
@ -329,7 +329,11 @@ class StaticGrid(IStrategy):
# 检查是否超过最大可用金额 # 检查是否超过最大可用金额
if stake_amount <= max_stake: 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) file=sys.stderr, flush=True)
return stake_amount return stake_amount
else: else: