feat: 网格日志能力补齐 (#89)

* feat: 网格日志能力补齐

* fix: 修正error标记

Author: loadchange

grid_main.py

@@ -125,6 +125,21 @@ def run_cycle(self):
                 current_grid_summary,
             )
 
+            # 记录网格决策到本地日志 + 云端
+            action = ai_decision.get("action", "UNKNOWN")
+            reason = ai_decision.get("reason", "")
+            confidence = float(ai_decision.get("confidence", 0.0))
+            self.logger.log_decision(
+                symbol=self.config.symbols[0],
+                market_data=market_data,
+                prompt="[GridAgent]",
+                ai_response=reason,
+                decision=action,
+                action_details=ai_decision,
+                status="SUCCESS" if action != "ERROR" else "ERROR",
+                confidence=confidence,
+            )
+
             self.grid_manager.sync_grid(self.config.symbols[0], ai_decision)
             self.logger.print_header("✅ 网格交易周期完成")
 

src/trading/grid_manager.py

@@ -235,6 +235,14 @@ def sync_grid(self, symbol: str, ai_config: dict[str, Any]):
                         if oid:
                             buy_orders.append({"oid": oid, "px": p})
                             self.logger.print_info(f"   [Grid] ✅ 买单挂载: ${p}")
+                            self.logger.log_trade(
+                                symbol=symbol,
+                                action="GRID_BUY",
+                                amount=new_amount,
+                                price=p,
+                                order_id=str(oid),
+                                status="PLACED",
+                            )
                     elif res and not res.get("success"):
                         self.logger.print_warning(
                             f"   [Grid] ⚠️ 买单跳过 @ ${p}: {res.get('message', 'unknown')}"
@@ -254,6 +262,14 @@ def sync_grid(self, symbol: str, ai_config: dict[str, Any]):
                         if oid:
                             sell_orders.append({"oid": oid, "px": p})
                             self.logger.print_info(f"   [Grid] ✅ 卖单挂载: ${p}")
+                            self.logger.log_trade(
+                                symbol=symbol,
+                                action="GRID_SELL",
+                                amount=new_amount,
+                                price=p,
+                                order_id=str(oid),
+                                status="PLACED",
+                            )
                     elif res and not res.get("success"):
                         self.logger.print_warning(
                             f"   [Grid] ⚠️ 卖单跳过 @ ${p}: {res.get('message', 'unknown')}"
@@ -669,6 +685,14 @@ def _ensure_position_exit_orders(
                 self.logger.print_warning(
                     f"   [Grid] 🛟 补减仓{side_name}单: {order_size:.6f} @ ${limit_price} (reduce_only)"
                 )
+                self.logger.log_trade(
+                    symbol=symbol,
+                    action="GRID_REDUCE_BUY" if close_with_buy else "GRID_REDUCE_SELL",
+                    amount=order_size,
+                    price=float(limit_price),
+                    order_id=str(oid) if oid is not None else "",
+                    status="PLACED",
+                )
             else:
                 self.logger.print_warning(
                     f"   [Grid] ⚠️ 减仓{side_name}单失败 @ ${limit_price}: {result}"

src/utils/logger.py

@@ -341,6 +341,7 @@ def log_decision(
         action_details: dict[str, Any] = None,
         status: str = "SUCCESS",
         error_message: str = None,
+        confidence: float = 0.0,
     ):
         """
         记录决策日志到文件
@@ -384,6 +385,7 @@ def log_decision(
                 decision=decision,
                 status=status,
                 ai_response=ai_response or "",
+                confidence=confidence,
                 current_price=float(market_data.get("current_price", 0)),
                 error_message=error_message or "",
             )

tests/test_grid_manager_exit_orders.py

@@ -20,6 +20,12 @@ def print_warning(self, *args, **kwargs):
     def print_error(self, *args, **kwargs):
         pass
 
+    def log_trade(self, *args, **kwargs):
+        pass
+
+    def log_decision(self, *args, **kwargs):
+        pass
+
 
 class FakeClient:
     def __init__(self):