redis保存状态

user_data/strategies/grid_manager.py

@@ -436,6 +436,10 @@ class GridManager:
             # 平均价 → 上沿：全部 EMPTY
             avg_grid_price = self._round_to_grid(self.avg_entry_price)
             
+            print(f"[GridManager] {self.pair} 从 Trade 初始化 - 平均价: {self.avg_entry_price:.2f}, "
+                  f"舍入后网格价: {avg_grid_price:.2f}",
+                  file=sys.stderr, flush=True)
+            
             for price, grid_state in self.grid_states.items():
                 if price < avg_grid_price:
                     # 下沿：应该是 FILLED
@@ -454,10 +458,11 @@ class GridManager:
                         grid_state.entry_price = self.avg_entry_price
                         grid_state.entry_time = candle_index
             
+            filled_count = sum(1 for gs in self.grid_states.values() if gs.status == "filled")
             print(f"[GridManager] {self.pair} 从 Trade 对象初始化 - "
                   f"持仓: {self.total_quantity:.6f}, "
                   f"平均价: {self.avg_entry_price:.2f}, "
-                  f"下沿到平均价的网格标记为 FILLED",
+                  f"下沿到平均价的网格标记为 FILLED (共 {filled_count} 个)",
                   file=sys.stderr, flush=True)
         else:
             # 之后的同步：仅更新持仓信息，不修改网格状态

user_data/strategies/staticgrid.py

@@ -90,6 +90,9 @@ class StaticGrid(IStrategy):
                     entry_time=0
                 )
             
+            # 重置同步标志，以便网格范围更新后的第一次 sync 能重新初始化
+            grid_manager._synced_from_trade_once = False
+            
             # 从 Redis 恢复网格状态（如果存在）
             if self.redis_available:
                 redis_grid_state = grid_manager.recover_grid_state_from_redis()