aaron/stock-ai-agent
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

1

Browse Source
This commit is contained in:
aaron 2026-03-23 21:33:15 +08:00
parent d246486068
commit 8dee4c8f7b
2 changed files with 57 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

34
backend/app/crypto_agent/crypto_agent.py
View File

@ -1835,11 +1835,28 @@ class CryptoAgent:
# Hyperliquid 执行方法
# ============================================================
async def _notify_hyperliquid_error(self, symbol: str, operation: str, error: str):
"""发送 Hyperliquid 操作失败的飞书/钉钉/Telegram 通知"""
title = f"❌ Hyperliquid 操作失败 - {symbol}"
content = "\n".join([
f"🔴 **操作**: {operation}",
f"⚠️ **错误**: {error}",
f"🕐 **时间**: {datetime.now().strftime('%Y-%m-%d %H:%M:%S')}",
])
logger.error(f"[Hyperliquid] {operation} 失败 | {symbol} | {error}")
if self.settings.feishu_enabled:
await self.feishu.send_card(title, content, "red")
if self.settings.telegram_enabled:
await self.telegram.send_message(f"{title}\n\n{content}")
if self.settings.dingtalk_enabled:
await self.dingtalk.send_action_card(title, content)
async def _execute_hyperliquid_decisions(self, decision: Dict[str, Any],
market_signal: Dict[str, Any],
current_price: float):
"""执行 Hyperliquid 决策"""
decision_type = decision.get('decision', 'HOLD') # 修复：使用 'decision' 字段而不是 'action'
symbol = decision.get('symbol', 'UNKNOWN')
if decision_type == 'HOLD':
reasoning = decision.get('reasoning', '观望')
@ -1854,8 +1871,13 @@ class CryptoAgent:
if result.get('success'):
logger.info(f" ✅ Hyperliquid 交易成功")
await self._send_signal_notification(market_signal, decision, current_price, prefix="[Hyperliquid]")
# 止盈止损设置失败时单独告警
if result.get('tp_sl_warning'):
await self._notify_hyperliquid_error(symbol, "设置止盈止损", result['tp_sl_warning'])
else:
logger.error(f" ❌ Hyperliquid 交易失败: {result.get('error')}")
error = result.get('error', '未知错误')
logger.error(f" ❌ Hyperliquid 交易失败: {error}")
await self._notify_hyperliquid_error(symbol, decision_type, error)
elif decision_type == 'CLOSE':
logger.info(f" 准备 Hyperliquid 平仓...")
@ -1865,7 +1887,9 @@ class CryptoAgent:
logger.info(f" ✅ Hyperliquid 平仓成功")
await self._send_signal_notification(market_signal, decision, current_price, prefix="[Hyperliquid]")
else:
logger.error(f" ❌ Hyperliquid 平仓失败: {result.get('error')}")
error = result.get('error', '未知错误')
logger.error(f" ❌ Hyperliquid 平仓失败: {error}")
await self._notify_hyperliquid_error(symbol, "平仓", error)
elif decision_type == 'CANCEL_PENDING':
logger.info(f" 准备取消 Hyperliquid 挂单...")
@ -1874,10 +1898,13 @@ class CryptoAgent:
if result.get('success'):
logger.info(f" ✅ Hyperliquid 取消成功")
else:
logger.error(f" ❌ Hyperliquid 取消失败: {result.get('error')}")
error = result.get('error', '未知错误')
logger.error(f" ❌ Hyperliquid 取消失败: {error}")
await self._notify_hyperliquid_error(symbol, "取消挂单", error)
except Exception as e:
logger.error(f" ❌ Hyperliquid 执行异常: {e}")
await self._notify_hyperliquid_error(symbol, decision_type, str(e))
async def _execute_hyperliquid_trade(self, decision: Dict[str, Any],
market_signal: Dict[str, Any],
@ -1940,6 +1967,7 @@ class CryptoAgent:
if not tp_sl_result.get('success'):
logger.warning(f" ⚠️ 设置止盈止损失败: {tp_sl_result.get('error')}")
result['tp_sl_warning'] = tp_sl_result.get('error', '设置止盈止损失败')
return result

26
backend/app/services/hyperliquid_trading_service.py
View File

@ -168,6 +168,19 @@ class HyperliquidTradingService:
# 开仓使用 market_open
result = self.exchange.market_open(symbol, is_buy, size)
# 检查 API 响应状态
if result.get("status") != "ok":
error_msg = result.get("response", "Unknown error")
logger.error(f"❌ Hyperliquid 市价单失败: {error_msg}")
return {"success": False, "error": str(error_msg), "result": result}
# 检查单个订单状态
statuses = result.get("response", {}).get("data", {}).get("statuses", [])
error_statuses = [s for s in statuses if "error" in s]
if error_statuses:
logger.error(f"❌ Hyperliquid 市价单错误: {error_statuses}")
return {"success": False, "error": str(error_statuses), "result": result}
side = "买入" if is_buy else "卖出"
order_type = "平仓" if reduce_only else "开仓"
logger.info(f"✅ Hyperliquid 市价单: {order_type} {side} {symbol} {size}")
@ -203,6 +216,19 @@ class HyperliquidTradingService:
{"limit": {"tif": "Gtc"}},
reduce_only=reduce_only)
# 检查 API 响应状态
if result.get("status") != "ok":
error_msg = result.get("response", "Unknown error")
logger.error(f"❌ Hyperliquid 限价单失败: {error_msg}")
return {"success": False, "error": str(error_msg), "result": result}
# 检查单个订单状态
statuses = result.get("response", {}).get("data", {}).get("statuses", [])
error_statuses = [s for s in statuses if "error" in s]
if error_statuses:
logger.error(f"❌ Hyperliquid 限价单错误: {error_statuses}")
return {"success": False, "error": str(error_statuses), "result": result}
side = "买入" if is_buy else "卖出"
logger.info(f"✅ Hyperliquid 限价单: {side} {symbol} {size} @ ${price}")