起動をスキップする場合は`false`に設定 | `true`または`false` | ✅ はい | +| `ai_model` | 使用するAIプロバイダー | `"deepseek"`または`"qwen"`または`"custom"` | ✅ はい | +| `exchange` | 使用する取引所 | `"binance"`または`"hyperliquid"`または`"aster"` | ✅ はい | +| `binance_api_key` | Binance APIキー | `"abc123..."` | Binance使用時に必須 | +| `binance_secret_key` | Binanceシークレットキー | `"xyz789..."` | Binance使用時に必須 | +| `hyperliquid_private_key` | Hyperliquid秘密鍵
⚠️ `0x`プレフィックスを削除 | `"your_key..."` | Hyperliquid使用時に必須 | +| `hyperliquid_wallet_addr` | Hyperliquidウォレットアドレス | `"0xabc..."` | Hyperliquid使用時に必須 | +| `hyperliquid_testnet` | テストネットを使用 | `true`または`false` | ❌ いいえ（デフォルトはfalse） | +| `use_qwen` | Qwenを使用するかどうか | `true`または`false` | ✅ はい | +| `deepseek_key` | DeepSeek APIキー | `"sk-xxx"` | DeepSeek使用時 | +| `qwen_key` | Qwen APIキー | `"sk-xxx"` | Qwen使用時 | +| `initial_balance` | 損益計算の開始残高 | `1000.0` | ✅ はい | +| `scan_interval_minutes` | 判断を行う頻度 | `3`（3-5推奨） | ✅ はい | +| **`leverage`** | **レバレッジ設定（v2.0.3+）** | 下記参照 | ✅ はい | +| `btc_eth_leverage` | BTC/ETHの最大レバレッジ
⚠️ サブアカウント：≤5x | `5`（デフォルト、安全）
`50`（メインアカウント最大） | ✅ はい | +| `altcoin_leverage` | アルトコインの最大レバレッジ
⚠️ サブアカウント：≤5x | `5`（デフォルト、安全）
`20`（メインアカウント最大） | ✅ はい | +| `use_default_coins` | 組み込みコインリストを使用
**✨ スマートデフォルト：`true`**（v2.0.2+）
API URLが提供されていない場合自動有効化 | `true`または省略 | ❌ いいえ
（オプション、自動デフォルト） | +| `coin_pool_api_url` | カスタムコインプールAPI
*`use_default_coins: false`の場合のみ必要* | `""`（空） | ❌ いいえ | +| `oi_top_api_url` | 建玉API
*オプション補足データ* | `""`（空） | ❌ いいえ | +| `api_server_port` | Webダッシュボードポート | `8080` | ✅ はい | + +**デフォルト取引コイン**（`use_default_coins: true`の場合）： +- BTC、ETH、SOL、BNB、XRP、DOGE、ADA、HYPE + +--- + +#### ⚙️ レバレッジ設定（v2.0.3+） + +**レバレッジ設定とは？** + +レバレッジ設定は、AIが各取引で使用できる最大レバレッジを制御します。これは、特にレバレッジ制限があるBinanceサブアカウントでリスク管理に重要です。 + +**設定形式：** + +```json +"leverage": { + "btc_eth_leverage": 5, // BTCとETHの最大レバレッジ + "altcoin_leverage": 5 // その他すべてのコインの最大レバレッジ +} +``` + +**⚠️ 重要：Binanceサブアカウント制限** + +- **サブアカウント**: Binanceにより**≤5xレバレッジ**に制限 +- **メインアカウント**: 最大20x（アルトコイン）または50x（BTC/ETH）を使用可能 +- サブアカウントを使用していてレバレッジを>5xに設定すると、取引は**失敗**し、エラーが表示されます：`Subaccounts are restricted from using leverage greater than 5x` + +**推奨設定：** + +| アカウントタイプ | BTC/ETHレバレッジ | アルトコインレバレッジ | リスクレベル | +|-------------|------------------|------------------|------------| +| **サブアカウント** | `5` | `5` | ✅ 安全（デフォルト） | +| **メイン（保守的）** | `10` | `10` | 🟡 中程度 | +| **メイン（積極的）** | `20` | `15` | 🔴 高 | +| **メイン（最大）** | `50` | `20` | 🔴🔴 非常に高 | + +**例：** + +**安全な設定（サブアカウントまたは保守的）：** +```json +"leverage": { + "btc_eth_leverage": 5, + "altcoin_leverage": 5 +} +``` + +**積極的な設定（メインアカウントのみ）：** +```json +"leverage": { + "btc_eth_leverage": 20, + "altcoin_leverage": 15 +} +``` + +**AIのレバレッジ使用方法：** + +- AIは設定された最大値まで**1xから任意のレバレッジを選択**できます +- たとえば、`altcoin_leverage: 20`の場合、AIは市場条件に基づいて5x、10x、または20xを使用することを決定する可能性があります +- 設定は固定値ではなく**上限**を設定します +- AIはレバレッジを選択する際にボラティリティ、リスクリワード比率、アカウント残高を考慮します + +--- + +#### ⚠️ 重要：`use_default_coins`フィールド + +**スマートデフォルト動作（v2.0.2+）：** + +次の場合、システムは自動的に`use_default_coins: true`をデフォルトにします： +- config.jsonにこのフィールドを含めていない、または +- `false`に設定したが`coin_pool_api_url`を提供していない + +これにより初心者に優しくなります！このフィールドを完全に省略することもできます。 + +**設定例：** + +✅ **オプション1：明示的に設定（明確性のため推奨）** +```json +"use_default_coins": true, +"coin_pool_api_url": "", +"oi_top_api_url": "" +``` + +✅ **オプション2：フィールドを省略（デフォルトコインを自動使用）** +```json +// "use_default_coins"を含めないだけ +"coin_pool_api_url": "", +"oi_top_api_url": "" +``` + +⚙️ **高度：外部APIを使用** +```json +"use_default_coins": false, +"coin_pool_api_url": "http://your-api.com/coins", +"oi_top_api_url": "http://your-api.com/oi" +``` + +--- + +### 6. システムを実行 + +#### 🚀 システムの起動（2ステップ） + +システムには別々に実行される**2つの部分**があります： +1. **バックエンド**（AIトレーディングブレイン + API） +2. **フロントエンド**（監視用Webダッシュボード） + +--- + +#### **ステップ1：バックエンドを起動** + +ターミナルを開いて実行： + +```bash +# プログラムをビルド（初回のみ、またはコード変更後） +go build -o nofx + +# バックエンドを起動 +./nofx +``` + +**表示されるべきもの：** + +``` +🚀 启动自动交易系统... +✓ Trader [my_trader] 已初始化 +✓ API服务器启动在端口 8080 +📊 开始交易监控... +``` + +**⚠️ エラーが表示される場合：** + +| エラーメッセージ | 解決策 | +|--------------|----------| +| `invalid API key` | config.jsonのBinance APIキーを確認 | +| `TA-Lib not found` | `brew install ta-lib`を実行（macOS） | +| `port 8080 already in use` | config.jsonの`api_server_port`を変更 | +| `DeepSeek API error` | DeepSeek APIキーと残高を確認 | + +**✅ バックエンドが正しく実行されているとき：** +- エラーメッセージなし +- "开始交易监控..."が表示される +- システムがアカウント残高を表示 +- このターミナルウィンドウを開いたままにしてください！ + +--- + +#### **ステップ2：フロントエンドを起動** + +**新しいターミナルウィンドウ**を開き（最初のものは実行したまま）、次を実行： + +```bash +cd web +npm run dev +``` + +**表示されるべきもの：** + +``` +VITE v5.x.x ready in xxx ms + +➜ Local: http://localhost:3000/ +➜ Network: use --host to expose +``` + +**✅ フロントエンドが実行されているとき：** +- "Local: http://localhost:3000/"メッセージ +- エラーメッセージなし +- このターミナルウィンドウも開いたままにしてください！ + +--- + +#### **ステップ3：ダッシュボードにアクセス** + +Webブラウザを開いて次にアクセス： + +**🌐 http://localhost:3000** + +**表示されるもの：** +- 📊 リアルタイムアカウント残高 +- 📈 オープンポジション（ある場合） +- 🤖 AI判断ログ +- 📉 エクイティカーブチャート + +**初回のヒント：** +- 最初のAI判断まで3-5分かかることがあります +- 初期判断は「観望」（待機）と言う場合があります - これは正常です +- AIは最初に市場状況を分析する必要があります + +--- + +### 7. システムを監視 + +**監視すべきもの：** + +✅ **健全なシステムの兆候：** +- バックエンドターミナルが3-5分ごとに判断サイクルを表示 +- 継続的なエラーメッセージなし +- アカウント残高の更新 +- Webダッシュボードの自動更新 + +⚠️ **警告の兆候：** +- 繰り返されるAPIエラー +- 10分以上判断なし +- 残高の急速な減少 + +**システムステータスの確認：** + +```bash +# 新しいターミナルウィンドウで +curl http://localhost:8080/health +``` + +戻り値：`{"status":"ok"}` + +--- + +### 8. システムを停止 + +**グレースフルシャットダウン（推奨）：** + +1. **バックエンドターミナル**（最初のもの）に移動 +2. `Ctrl+C`を押す +3. "系统已停止"メッセージを待つ +4. **フロントエンドターミナル**（2番目のもの）に移動 +5. `Ctrl+C`を押す + +**⚠️ 重要：** +- 常にバックエンドを最初に停止 +- ターミナルを閉じる前に確認を待つ +- 強制終了しない（ターミナルを直接閉じない） + +--- + +## 📖 AI判断フロー + +各判断サイクル（デフォルト3分）で、システムは以下のインテリジェントプロセスを実行します： + +``` +┌──────────────────────────────────────────────────────────┐ +│ 1. 📊 過去パフォーマンスを分析（過去20サイクル） │ +├──────────────────────────────────────────────────────────┤ +│ ✓ 総合勝率、平均利益、損益比を計算 │ +│ ✓ コインごとの統計（勝率、平均損益（USDT）） │ +│ ✓ 最高/最悪パフォーマンスコインを特定 │ +│ ✓ 正確なPnLを含む最後の5取引の詳細をリスト │ +│ ✓ リスク調整パフォーマンスのシャープレシオを計算 │ +│ 📌 NEW（v2.0.2）：レバレッジを含む正確なUSDT PnL │ +└──────────────────────────────────────────────────────────┘ + ↓ +┌──────────────────────────────────────────────────────────┐ +│ 2. 💰 アカウントステータスを取得 │ +├──────────────────────────────────────────────────────────┤ +│ • 総エクイティと利用可能残高 │ +│ • オープンポジション数と未実現損益 │ +│ • 証拠金使用率（AIは最大90%を管理） │ +│ • 日次損益追跡とドローダウン監視 │ +└──────────────────────────────────────────────────────────┘ + ↓ +┌──────────────────────────────────────────────────────────┐ +│ 3. 🔍 既存ポジションを分析（ある場合） │ +├──────────────────────────────────────────────────────────┤ +│ • 各ポジションについて、最新の市場データを取得 │ +│ • リアルタイムのテクニカル指標を計算： │ +│ - 3分K線：RSI(7)、MACD、EMA20 │ +│ - 4時間K線：RSI(14)、EMA20/50、ATR │ +│ • ポジション保有期間を追跡（例：「2時間15分」） │ +│ 📌 NEW（v2.0.2）：各ポジションの保有期間を表示 │ +│ • 表示：エントリー価格、現在価格、損益%、期間 │ +│ • AIが評価：保持するかクローズするか？ │ +└──────────────────────────────────────────────────────────┘ + ↓ +┌──────────────────────────────────────────────────────────┐ +│ 4. 🎯 新しい機会を評価（候補コイン） │ +├──────────────────────────────────────────────────────────┤ +│ • コインプールを取得（2モード）： │ +│ 🌟 デフォルトモード：BTC、ETH、SOL、BNB、XRPなど │ +│ ⚙️ 高度モード：AI500（上位20）+ OI Top（上位20） │ +│ • 候補コインをマージして重複削除 │ +│ • フィルター：低流動性を削除（<1500万USD OI値） │ +│ • 市場データ + テクニカル指標をバッチ取得 │ +│ • ボラティリティ、トレンド強度、出来高急増を計算 │ +└──────────────────────────────────────────────────────────┘ + ↓ +┌──────────────────────────────────────────────────────────┐ +│ 5. 🧠 AI総合判断（DeepSeek/Qwen） │ +├──────────────────────────────────────────────────────────┤ +│ • 過去フィードバックをレビュー： │ +│ - 最近の勝率と利益率 │ +│ - 最高/最悪コインパフォーマンス │ +│ - 繰り返しミスを回避 │ +│ • すべての生シーケンスデータを分析： │ +│ - 3分価格シーケンス、4時間K線シーケンス │ +│ - 完全な指標シーケンス（最新のみではない） │ +│ 📌 NEW（v2.0.2）：AIは分析の完全な自由を持つ │ +│ • 思考連鎖（CoT）推論プロセス │ +│ • 構造化された判断を出力： │ +│ - アクション：close_long/close_short/open_long/open_short│ +│ - コインシンボル、数量、レバレッジ │ +│ - ストップロスとテイクプロフィットレベル（≥1:2比率） │ +│ • 判断：待機/保持/クローズ/オープン │ +└──────────────────────────────────────────────────────────┘ + ↓ +┌──────────────────────────────────────────────────────────┐ +│ 6. ⚡ 取引を実行 │ +├──────────────────────────────────────────────────────────┤ +│ • 優先順位：既存をクローズ → その後新規をオープン │ +│ • 実行前のリスクチェック： │ +│ - ポジションサイズ制限（アルトコイン1.5x、BTC 10x） │ +│ - 重複ポジションなし（同じコイン + 方向） │ +│ - 証拠金使用量が90%制限内 │ +│ • Binance LOT_SIZE精度を自動取得して適用 │ +│ • Binance Futures APIで注文を実行 │ +│ • クローズ後：すべての保留注文を自動キャンセル │ +│ • 実際の実行価格と注文IDを記録 │ +│ 📌 期間計算のためにポジションオープン時間を追跡 │ +└──────────────────────────────────────────────────────────┘ + ↓ +┌──────────────────────────────────────────────────────────┐ +│ 7. 📝 完全なログを記録してパフォーマンスを更新 │ +├──────────────────────────────────────────────────────────┤ +│ • decision_logs/{trader_id}/に判断ログを保存 │ +│ • ログには以下が含まれます： │ +│ - 完全な思考連鎖（CoT） │ +│ - すべての市場データを含む入力プロンプト │ +│ - 構造化された判断JSON │ +│ - アカウントスナップショット（残高、ポジション、証拠金）│ +│ - 実行結果（成功/失敗、価格） │ +│ • パフォーマンスデータベースを更新： │ +│ - symbol_sideキーでオープン/クローズペアをマッチ │ +│ 📌 NEW：ロング/ショート競合を防止 │ +│ - 正確なUSDT PnLを計算： │ +│ PnL = ポジション価値 × 価格変化% × レバレッジ │ +│ 📌 NEW：数量 + レバレッジを考慮 │ +│ - 保存：数量、レバレッジ、オープン時間、クローズ時間 │ +│ - 更新：勝率、利益率、シャープレシオ │ +│ • パフォーマンスデータは次のサイクルにフィードバック │ +└──────────────────────────────────────────────────────────┘ + ↓ + （3-5分ごとに繰り返し） +``` + +### v2.0.2の主な改善点 + +**📌 ポジション期間追跡：** +- システムが各ポジションの保有期間を追跡 +- ユーザープロンプトに表示：「持仓时长2小时15分钟」 +- AIが出口タイミングについてより良い判断を下すのに役立つ + +**📌 正確なPnL計算：** +- 以前：パーセンテージのみ（100U@5% = 1000U@5% = 両方とも「5.0」と表示） +- 現在：実際のUSDT利益 = ポジション価値 × 価格変化 × レバレッジ +- 例：1000 USDT × 5% × 20x = 1000 USDT実際の利益 + +**📌 AI自由度の向上：** +- AIはすべての生シーケンスデータを自由に分析可能 +- 事前定義された指標の組み合わせに制限されない +- 独自のトレンド分析、サポート/レジスタンス計算を実行可能 + +**📌 改善されたポジション追跡：** +- `symbol_side`キーを使用（例：「BTCUSDT_long」） +- ロングとショートの両方を保有する際の競合を防止 +- 完全なデータを保存：数量、レバレッジ、オープン/クローズ時間 + +--- + +## 🧠 AI自己学習の例 + +### 過去フィードバック（プロンプトに自動追加） + +```markdown +## 📊 過去パフォーマンスフィードバック + +### 総合パフォーマンス +- **総取引数**: 15（利益：8 | 損失：7） +- **勝率**: 53.3% +- **平均利益**: +3.2% | 平均損失：-2.1% +- **損益比**: 1.52:1 + +### 最近の取引 +1. BTCUSDT LONG: 95000.0000 → 97500.0000 = +2.63% ✓ +2. ETHUSDT SHORT: 3500.0000 → 3450.0000 = +1.43% ✓ +3. SOLUSDT LONG: 185.0000 → 180.0000 = -2.70% ✗ +4. BNBUSDT LONG: 610.0000 → 625.0000 = +2.46% ✓ +5. ADAUSDT LONG: 0.8500 → 0.8300 = -2.35% ✗ + +### コインパフォーマンス +- **最高**: BTCUSDT（勝率75%、平均+2.5%） +- **最悪**: SOLUSDT（勝率25%、平均-1.8%） +``` + +### AIのフィードバック使用方法 + +1. **連続損失を回避**: SOLUSDTが3回連続でストップロスになっているのを見て、AIは回避するかより慎重になる +2. **成功戦略を強化**: BTCブレイクアウトロングが75%の勝率で、AIはこのパターンを継続 +3. **動的スタイル調整**: 勝率<40% → 保守的；損益比>2 → 積極的を維持 +4. **市場状況の特定**: 連続損失は荒れた市場を示す可能性があり、取引頻度を減らす + +--- + +## 📊 Webインターフェース機能 + +### 1. 競争ページ + +- **🏆 リーダーボード**: リアルタイムROIランキング、ゴールドボーダーでリーダーをハイライト +- **📈 パフォーマンス比較**: デュアルAI ROIカーブ比較（紫対青） +- **⚔️ 一対一**: リードマージンを示す直接比較 +- **リアルタイムデータ**: 総エクイティ、損益%、ポジション数、証拠金使用量 + +### 2. 詳細ページ + +- **エクイティカーブ**: 過去トレンドチャート（USD/パーセンテージ切り替え） +- **統計**: 総サイクル、成功/失敗、オープン/クローズ統計 +- **ポジションテーブル**: すべてのポジション詳細（エントリー価格、現在価格、損益%、清算価格） +- **AI判断ログ**: 最近の判断記録（展開可能なCoT） + +### 3. リアルタイム更新 + +- システムステータス、アカウント情報、ポジションリスト：**5秒更新** +- 判断ログ、統計：**10秒更新** +- エクイティチャート：**10秒更新** + +--- + +## 🎛️ APIエンドポイント + +### 競争関連 + +```bash +GET /api/competition # 競争リーダーボード（全トレーダー） +GET /api/traders # トレーダーリスト +``` + +### 単一トレーダー関連 + +```bash +GET /api/status?trader_id=xxx # システムステータス +GET /api/account?trader_id=xxx # アカウント情報 +GET /api/positions?trader_id=xxx # ポジションリスト +GET /api/equity-history?trader_id=xxx # エクイティ履歴（チャートデータ） +GET /api/decisions/latest?trader_id=xxx # 最新5判断 +GET /api/statistics?trader_id=xxx # 統計 +``` + +### システムエンドポイント + +```bash +GET /health # ヘルスチェック +GET /api/config # システム設定 +``` + +--- + +## ⚠️ 重要なリスク警告 + +### 取引リスク + +1. **暗号通貨市場は非常にボラティルが高い**、AI判断は利益を保証しません +2. **先物取引はレバレッジを使用**、損失が元本を超える可能性があります +3. **極端な市場状況**は清算リスクにつながる可能性があります +4. **ファンディングレート**は保有コストに影響する可能性があります +5. **流動性リスク**: 一部のコインでスリッページが発生する可能性があります + +### 技術リスク + +1. **ネットワークレイテンシ**は価格スリッページを引き起こす可能性があります +2. **APIレート制限**は取引実行に影響する可能性があります +3. **AI APIタイムアウト**は判断失敗を引き起こす可能性があります +4. **システムバグ**は予期しない動作を引き起こす可能性があります + +### 使用推奨事項 + +✅ **推奨** +- テストには失っても構わない資金のみを使用 +- 少額から始める（推奨100-500 USDT） +- システムの動作状態を定期的に確認 +- アカウント残高の変化を監視 +- AI判断ログを分析して戦略を理解 + +❌ **非推奨** +- すべての資金または借りたお金を投資 +- 長期間監視なしで実行 +- AI判断を盲目的に信頼 +- システムを理解せずに使用 +- 極端な市場ボラティリティ中に実行 + +--- + +## 🛠️ よくある問題 + +### 1. コンパイルエラー：TA-Libが見つからない + +**解決策**: TA-Libライブラリをインストール +```bash +# macOS +brew install ta-lib + +# Ubuntu +sudo apt-get install libta-lib0-dev +``` + +### 2. 精度エラー：Precision is over the maximum + +**解決策**: システムがBinance LOT_SIZEから精度を自動処理します。エラーが続く場合は、ネットワーク接続を確認してください。 + +### 3. AI APIタイムアウト + +**解決策**: +- APIキーが正しいか確認 +- ネットワーク接続を確認（プロキシが必要な場合があります） +- システムタイムアウトは120秒に設定されています + +### 4. フロントエンドがバックエンドに接続できない + +**解決策**: +- バックエンドが実行中であることを確認（http://localhost:8080） +- ポート8080が占有されていないか確認 +- ブラウザコンソールでエラーを確認 + +### 5. コインプールAPI失敗 + +**解決策**: +- コインプールAPIはオプションです +- APIが失敗した場合、システムはデフォルトのメインストリームコイン（BTC、ETHなど）を使用 +- config.jsonのAPI URLと認証パラメータを確認 + +--- + +## 📈 パフォーマンス最適化のヒント + +1. **合理的な判断サイクルを設定**: 3-5分を推奨、過剰取引を避ける +2. **候補コイン数を制御**: システムはデフォルトでAI500上位20 + OI Top上位20 +3. **ログを定期的にクリーン**: 過度なディスク使用を避ける +4. **API呼び出し数を監視**: Binanceレート制限のトリガーを避ける +5. **少額資本でテスト**: まず100-500 USDTで戦略検証をテスト + +--- + +## 🔄 変更履歴 + +### v2.0.2（2025-10-29） + +**重大なバグ修正 - 取引履歴とパフォーマンス分析：** + +このバージョンは、収益性統計に大きく影響した過去取引記録とパフォーマンス分析システムの**重大な計算エラー**を修正します。 + +**1. PnL計算 - 主要エラー修正**（logger/decision_logger.go） +- **問題**: 以前はパーセンテージのみで計算され、ポジションサイズとレバレッジを完全に無視 + - 例：100 USDTポジションが5%獲得と1000 USDTポジションが5%獲得の両方が利益として`5.0`と表示 + - これによりパフォーマンス分析が完全に不正確に +- **解決策**: 実際のUSDT利益額を計算 + ``` + PnL（USDT）= ポジション価値 × 価格変化% × レバレッジ + 例：1000 USDT × 5% × 20x = 1000 USDT実際の利益 + ``` +- **影響**: 勝率、利益率、シャープレシオが正確なUSDT額に基づくようになりました + +**2. ポジション追跡 - 重要データの欠落** +- **問題**: オープンポジション記録が価格と時間のみを保存、数量とレバレッジが欠落 +- **解決策**: 完全な取引データを保存： + - `quantity`: ポジションサイズ（コイン単位） + - `leverage`: レバレッジ倍率（例：20x） + - これらは正確なPnL計算に不可欠 + +**3. ポジションキーロジック - ロング/ショート競合** +- **問題**: `symbol`をポジションキーとして使用し、ロングとショートの両方を保有する際にデータ競合を引き起こす + - 例：BTCUSDTロングとBTCUSDTショートが互いに上書き +- **解決策**: `symbol_side`形式に変更（例：`BTCUSDT_long`、`BTCUSDT_short`） + - ロングとショートポジションを適切に区別 + +**4. シャープレシオ計算 - コード最適化** +- **問題**: 平方根計算にカスタムニュートン法を使用 +- **解決策**: 標準ライブラリ`math.Sqrt`に置き換え + - より信頼性が高く、保守可能で効率的 + +**このアップデートが重要な理由：** +- ✅ 過去取引統計が無意味なパーセンテージではなく**実際のUSDT損益**を表示 +- ✅ 異なるレバレッジ取引間のパフォーマンス比較が正確に +- ✅ AI自己学習メカニズムが正しい過去フィードバックを受信 +- ✅ 利益率とシャープレシオの計算が意味を持つように +- ✅ マルチポジション追跡（ロング + ショート同時）が正しく機能 + +**推奨**: このアップデート前にシステムを実行していた場合、過去統計は不正確でした。v2.0.2にアップデート後、新しい取引は正しく計算されます。 + +### v2.0.2（2025-10-29） + +**バグ修正：** +- ✅ Aster取引所精度エラーを修正（コード-1111：「Precision is over the maximum defined for this asset」） +- ✅ 取引所の精度要件に合わせて価格と数量のフォーマットを改善 +- ✅ デバッグ用の詳細な精度処理ログを追加 +- ✅ 適切な精度処理ですべての注文関数（OpenLong、OpenShort、CloseLong、CloseShort、SetStopLoss、SetTakeProfit）を強化 + +**技術詳細：** +- float64を正しい精度で文字列に変換する`formatFloatWithPrecision`関数を追加 +- 価格と数量パラメータが取引所の`pricePrecision`と`quantityPrecision`仕様に従ってフォーマットされるようになりました +- API リクエストを最適化するために、フォーマットされた値から末尾のゼロを削除 + +### v2.0.1（2025-10-29） + +**バグ修正：** +- ✅ ComparisonChartデータ処理ロジックを修正 - cycle_numberからタイムスタンプグループ化に切り替え +- ✅ バックエンド再起動時にcycle_numberがリセットされるとチャートがフリーズする問題を解決 +- ✅ チャートデータ表示を改善 - すべての過去データポイントを時系列で表示 +- ✅ トラブルシューティングを改善するためのデバッグログを強化 + +### v2.0.0（2025-10-28） + +**主要アップデート：** +- ✅ AI自己学習メカニズム（過去フィードバック、パフォーマンス分析） +- ✅ マルチトレーダー競争モード（Qwen対DeepSeek） +- ✅ BinanceスタイルUI（完全なBinanceインターフェース模倣） +- ✅ パフォーマンス比較チャート（リアルタイムROI比較） +- ✅ リスク管理最適化（コインごとのポジション制限調整） + +**バグ修正：** +- 初期残高のハードコーディング問題を修正 +- マルチトレーダーデータ同期問題を修正 +- チャートデータの整列を最適化（cycle_numberを使用） + +### v1.0.0（2025-10-27） +- 初回リリース +- 基本的なAI取引機能 +- 判断ログシステム +- シンプルなWebインターフェース + +--- + +## 📄 ライセンス + +MITライセンス - 詳細は[LICENSE](LICENSE)ファイルを参照してください + +--- + +## 🤝 貢献 + +IssueとPull Requestを歓迎します！ + +### 開発ガイド + +1. プロジェクトをフォーク +2. 機能ブランチを作成（`git checkout -b feature/AmazingFeature`） +3. 変更をコミット（`git commit -m 'Add some AmazingFeature'`） +4. ブランチにプッシュ（`git push origin feature/AmazingFeature`） +5. Pull Requestを開く + +--- + +## 📬 お問い合わせ + + +### 🐛 技術サポート +- **GitHub Issues**: [Issueを提出](https://github.com/tinkle-community/nofx/issues) +- **開発者コミュニティ**: [Telegramグループ](https://t.me/nofx_dev_community) + +--- + +## 🙏 謝辞 + +- [Binance API](https://binance-docs.github.io/apidocs/futures/en/) - Binance先物API +- [DeepSeek](https://platform.deepseek.com/) - DeepSeek AI API +- [Qwen](https://dashscope.aliyuncs.com/) - Alibaba Cloud Qwen +- [TA-Lib](https://ta-lib.org/) - テクニカル指標ライブラリ +- [Recharts](https://recharts.org/) - Reactチャートライブラリ + +--- + +**最終更新**: 2025-10-29（v2.0.3） + +**⚡ AIの力で量的取引の可能性を探求しましょう！** + +--- + +## ⭐ Star履歴 + +[](https://star-history.com/#tinkle-community/nofx&Date) diff --git a/README.md b/README.md index f76b9067..4a82bfed 100644 --- a/README.md +++ b/README.md @@ -3,7 +3,7 @@ [](https://golang.org/) [](https://reactjs.org/) [](https://www.typescriptlang.org/) -[](LICENSE) +[](LICENSE) [](https://amber.ac) **Languages:** [English](README.md) | [中文](docs/i18n/zh-CN/README.md) | [Українська](docs/i18n/uk/README.md) | [Русский](docs/i18n/ru/README.md) @@ -281,7 +281,7 @@ Docker automatically handles all dependencies (Go, Node.js, TA-Lib, SQLite) and #### Step 1: Prepare Configuration ```bash # Copy configuration template -cp config.example.jsonc config.json +cp config.json.example config.json # Edit and fill in your API keys nano config.json # or use any editor @@ -1240,7 +1240,15 @@ sudo apt-get install libta-lib0-dev ## 📄 License -MIT License - See [LICENSE](LICENSE) file for details +This project is licensed under the **GNU Affero General Public License v3.0 (AGPL-3.0)** - See [LICENSE](LICENSE) file for details. + +**What this means:** +- ✅ You can use, modify, and distribute this software +- ✅ You must disclose source code of your modifications +- ✅ If you run a modified version on a server, you must make the source code available to users +- ✅ All derivatives must also be licensed under AGPL-3.0 + +For commercial licensing or questions, please contact the maintainers. --- diff --git a/api/server.go b/api/server.go index bb0a6eaf..b068d5aa 100644 --- a/api/server.go +++ b/api/server.go @@ -4,11 +4,13 @@ import ( "encoding/json" "fmt" "log" + "net" "net/http" "nofx/auth" "nofx/config" "nofx/decision" "nofx/manager" + "nofx/trader" "strconv" "strings" "time" @@ -88,7 +90,7 @@ func (s *Server) setupRoutes() { // 系统提示词模板管理（无需认证） api.GET("/prompt-templates", s.handleGetPromptTemplates) api.GET("/prompt-templates/:name", s.handleGetPromptTemplate) - + // 公开的竞赛数据（无需认证） api.GET("/traders", s.handlePublicTraderList) api.GET("/competition", s.handlePublicCompetition) @@ -100,6 +102,9 @@ func (s *Server) setupRoutes() { // 需要认证的路由 protected := api.Group("/", s.authMiddleware()) { + // 服务器IP查询（需要认证，用于白名单配置） + protected.GET("/server-ip", s.handleGetServerIP) + // AI交易员管理 protected.GET("/my-traders", s.handleTraderList) protected.GET("/traders/:id/config", s.handleGetTraderConfig) @@ -109,6 +114,7 @@ func (s *Server) setupRoutes() { protected.POST("/traders/:id/start", s.handleStartTrader) protected.POST("/traders/:id/stop", s.handleStopTrader) protected.PUT("/traders/:id/prompt", s.handleUpdateTraderPrompt) + protected.POST("/traders/:id/sync-balance", s.handleSyncBalance) // AI模型配置 protected.GET("/models", s.handleGetModelConfigs) @@ -168,7 +174,7 @@ func (s *Server) handleGetSystemConfig(c *gin.Context) { if val, err := strconv.Atoi(altcoinLeverageStr); err == nil && val > 0 { altcoinLeverage = val } - + // 获取内测模式配置 betaModeStr, _ := s.database.GetSystemConfig("beta_mode") betaMode := betaModeStr == "true" @@ -182,6 +188,133 @@ func (s *Server) handleGetSystemConfig(c *gin.Context) { }) } +// handleGetServerIP 获取服务器IP地址（用于白名单配置） +func (s *Server) handleGetServerIP(c *gin.Context) { + // 尝试通过第三方API获取公网IP + publicIP := getPublicIPFromAPI() + + // 如果第三方API失败，从网络接口获取第一个公网IP + if publicIP == "" { + publicIP = getPublicIPFromInterface() + } + + // 如果还是没有获取到，返回错误 + if publicIP == "" { + c.JSON(http.StatusInternalServerError, gin.H{"error": "无法获取公网IP地址"}) + return + } + + c.JSON(http.StatusOK, gin.H{ + "public_ip": publicIP, + "message": "请将此IP地址添加到白名单中", + }) +} + +// getPublicIPFromAPI 通过第三方API获取公网IP +func getPublicIPFromAPI() string { + // 尝试多个公网IP查询服务 + services := []string{ + "https://api.ipify.org?format=text", + "https://icanhazip.com", + "https://ifconfig.me", + } + + client := &http.Client{ + Timeout: 5 * time.Second, + } + + for _, service := range services { + resp, err := client.Get(service) + if err != nil { + continue + } + defer resp.Body.Close() + + if resp.StatusCode == http.StatusOK { + body := make([]byte, 128) + n, err := resp.Body.Read(body) + if err != nil && err.Error() != "EOF" { + continue + } + + ip := strings.TrimSpace(string(body[:n])) + // 验证是否为有效的IP地址 + if net.ParseIP(ip) != nil { + return ip + } + } + } + + return "" +} + +// getPublicIPFromInterface 从网络接口获取第一个公网IP +func getPublicIPFromInterface() string { + interfaces, err := net.Interfaces() + if err != nil { + return "" + } + + for _, iface := range interfaces { + // 跳过未启用的接口和回环接口 + if iface.Flags&net.FlagUp == 0 || iface.Flags&net.FlagLoopback != 0 { + continue + } + + addrs, err := iface.Addrs() + if err != nil { + continue + } + + for _, addr := range addrs { + var ip net.IP + switch v := addr.(type) { + case *net.IPNet: + ip = v.IP + case *net.IPAddr: + ip = v.IP + } + + if ip == nil || ip.IsLoopback() { + continue + } + + // 只考虑IPv4地址 + if ip.To4() != nil { + ipStr := ip.String() + // 排除私有IP地址范围 + if !isPrivateIP(ip) { + return ipStr + } + } + } + } + + return "" +} + +// isPrivateIP 判断是否为私有IP地址 +func isPrivateIP(ip net.IP) bool { + // 私有IP地址范围： + // 10.0.0.0/8 + // 172.16.0.0/12 + // 192.168.0.0/16 + privateRanges := []string{ + "10.0.0.0/8", + "172.16.0.0/12", + "192.168.0.0/16", + } + + for _, cidr := range privateRanges { + _, subnet, _ := net.ParseCIDR(cidr) + if subnet.Contains(ip) { + return true + } + } + + return false +} + // getTraderFromQuery 从query参数获取trader func (s *Server) getTraderFromQuery(c *gin.Context) (*manager.TraderManager, string, error) { userID := c.GetString("user_id") @@ -343,8 +476,75 @@ func (s *Server) handleCreateTrader(c *gin.Context) { // 设置扫描间隔默认值 scanIntervalMinutes := req.ScanIntervalMinutes - if scanIntervalMinutes <= 0 { - scanIntervalMinutes = 3 // 默认3分钟 + if scanIntervalMinutes < 3 { + scanIntervalMinutes = 3 // 默认3分钟，且不允许小于3 + } + + // ✨ 查询交易所实际余额，覆盖用户输入 + actualBalance := req.InitialBalance // 默认使用用户输入 + exchanges, err := s.database.GetExchanges(userID) + if err != nil { + log.Printf("⚠️ 获取交易所配置失败，使用用户输入的初始资金: %v", err) + } + + // 查找匹配的交易所配置 + var exchangeCfg *config.ExchangeConfig + for _, ex := range exchanges { + if ex.ID == req.ExchangeID { + exchangeCfg = ex + break + } + } + + if exchangeCfg == nil { + log.Printf("⚠️ 未找到交易所 %s 的配置，使用用户输入的初始资金", req.ExchangeID) + } else if !exchangeCfg.Enabled { + log.Printf("⚠️ 交易所 %s 未启用，使用用户输入的初始资金", req.ExchangeID) + } else { + // 根据交易所类型创建临时 trader 查询余额 + var tempTrader trader.Trader + var createErr error + + switch req.ExchangeID { + case "binance": + tempTrader = trader.NewFuturesTrader(exchangeCfg.APIKey, exchangeCfg.SecretKey) + case "hyperliquid": + tempTrader, createErr = trader.NewHyperliquidTrader( + exchangeCfg.APIKey, // private key + exchangeCfg.HyperliquidWalletAddr, + exchangeCfg.Testnet, + ) + case "aster": + tempTrader, createErr = trader.NewAsterTrader( + exchangeCfg.AsterUser, + exchangeCfg.AsterSigner, + exchangeCfg.AsterPrivateKey, + ) + default: + log.Printf("⚠️ 不支持的交易所类型: %s，使用用户输入的初始资金", req.ExchangeID) + } + + if createErr != nil { + log.Printf("⚠️ 创建临时 trader 失败，使用用户输入的初始资金: %v", createErr) + } else if tempTrader != nil { + // 查询实际余额 + balanceInfo, balanceErr := tempTrader.GetBalance() + if balanceErr != nil { + log.Printf("⚠️ 查询交易所余额失败，使用用户输入的初始资金: %v", balanceErr) + } else { + // 提取可用余额 + if availableBalance, ok := balanceInfo["available_balance"].(float64); ok && availableBalance > 0 { + actualBalance = availableBalance + log.Printf("✓ 查询到交易所实际余额: %.2f USDT (用户输入: %.2f USDT)", actualBalance, req.InitialBalance) + } else if totalBalance, ok := balanceInfo["balance"].(float64); ok && totalBalance > 0 { + // 有些交易所可能只返回 balance 字段 + actualBalance = totalBalance + log.Printf("✓ 查询到交易所实际余额: %.2f USDT (用户输入: %.2f USDT)", actualBalance, req.InitialBalance) + } else { + log.Printf("⚠️ 无法从余额信息中提取可用余额，使用用户输入的初始资金") + } + } + } } // 创建交易员配置（数据库实体） @@ -354,7 +554,7 @@ func (s *Server) handleCreateTrader(c *gin.Context) { Name: req.Name, AIModelID: req.AIModelID, ExchangeID: req.ExchangeID, - InitialBalance: req.InitialBalance, + InitialBalance: actualBalance, // 使用实际查询的余额 BTCETHLeverage: btcEthLeverage, AltcoinLeverage: altcoinLeverage, TradingSymbols: req.TradingSymbols, @@ -369,7 +569,7 @@ func (s *Server) handleCreateTrader(c *gin.Context) { } // 保存到数据库 - err := s.database.CreateTrader(trader) + err = s.database.CreateTrader(trader) if err != nil { c.JSON(http.StatusInternalServerError, gin.H{"error": fmt.Sprintf("创建交易员失败: %v", err)}) return @@ -458,6 +658,8 @@ func (s *Server) handleUpdateTrader(c *gin.Context) { scanIntervalMinutes := req.ScanIntervalMinutes if scanIntervalMinutes <= 0 { scanIntervalMinutes = existingTrader.ScanIntervalMinutes // 保持原值 + } else if scanIntervalMinutes < 3 { + scanIntervalMinutes = 3 } // 更新交易员配置 @@ -531,14 +733,14 @@ func (s *Server) handleDeleteTrader(c *gin.Context) { func (s *Server) handleStartTrader(c *gin.Context) { userID := c.GetString("user_id") traderID := c.Param("id") - + // 校验交易员是否属于当前用户 _, _, _, err := s.database.GetTraderConfig(userID, traderID) if err != nil { c.JSON(http.StatusNotFound, gin.H{"error": "交易员不存在或无访问权限"}) return } - + trader, err := s.traderManager.GetTrader(traderID) if err != nil { c.JSON(http.StatusNotFound, gin.H{"error": "交易员不存在"}) @@ -574,14 +776,14 @@ func (s *Server) handleStartTrader(c *gin.Context) { func (s *Server) handleStopTrader(c *gin.Context) { userID := c.GetString("user_id") traderID := c.Param("id") - + // 校验交易员是否属于当前用户 _, _, _, err := s.database.GetTraderConfig(userID, traderID) if err != nil { c.JSON(http.StatusNotFound, gin.H{"error": "交易员不存在或无访问权限"}) return } - + trader, err := s.traderManager.GetTrader(traderID) if err != nil { c.JSON(http.StatusNotFound, gin.H{"error": "交易员不存在"}) @@ -641,6 +843,113 @@ func (s *Server) handleUpdateTraderPrompt(c *gin.Context) { c.JSON(http.StatusOK, gin.H{"message": "自定义prompt已更新"}) } +// handleSyncBalance 同步交易所余额到initial_balance（选项B：手动同步 + 选项C：智能检测） +func (s *Server) handleSyncBalance(c *gin.Context) { + userID := c.GetString("user_id") + traderID := c.Param("id") + + log.Printf("🔄 用户 %s 请求同步交易员 %s 的余额", userID, traderID) + + // 从数据库获取交易员配置（包含交易所信息） + traderConfig, _, exchangeCfg, err := s.database.GetTraderConfig(userID, traderID) + if err != nil { + c.JSON(http.StatusNotFound, gin.H{"error": "交易员不存在"}) + return + } + + if exchangeCfg == nil || !exchangeCfg.Enabled { + c.JSON(http.StatusBadRequest, gin.H{"error": "交易所未配置或未启用"}) + return + } + + // 创建临时 trader 查询余额 + var tempTrader trader.Trader + var createErr error + + switch traderConfig.ExchangeID { + case "binance": + tempTrader = trader.NewFuturesTrader(exchangeCfg.APIKey, exchangeCfg.SecretKey) + case "hyperliquid": + tempTrader, createErr = trader.NewHyperliquidTrader( + exchangeCfg.APIKey, + exchangeCfg.HyperliquidWalletAddr, + exchangeCfg.Testnet, + ) + case "aster": + tempTrader, createErr = trader.NewAsterTrader( + exchangeCfg.AsterUser, + exchangeCfg.AsterSigner, + exchangeCfg.AsterPrivateKey, + ) + default: + c.JSON(http.StatusBadRequest, gin.H{"error": "不支持的交易所类型"}) + return + } + + if createErr != nil { + log.Printf("⚠️ 创建临时 trader 失败: %v", createErr) + c.JSON(http.StatusInternalServerError, gin.H{"error": fmt.Sprintf("连接交易所失败: %v", createErr)}) + return + } + + // 查询实际余额 + balanceInfo, balanceErr := tempTrader.GetBalance() + if balanceErr != nil { + log.Printf("⚠️ 查询交易所余额失败: %v", balanceErr) + c.JSON(http.StatusInternalServerError, gin.H{"error": fmt.Sprintf("查询余额失败: %v", balanceErr)}) + return + } + + // 提取可用余额 + var actualBalance float64 + if availableBalance, ok := balanceInfo["available_balance"].(float64); ok && availableBalance > 0 { + actualBalance = availableBalance + } else if availableBalance, ok := balanceInfo["availableBalance"].(float64); ok && availableBalance > 0 { + actualBalance = availableBalance + } else if totalBalance, ok := balanceInfo["balance"].(float64); ok && totalBalance > 0 { + actualBalance = totalBalance + } else { + c.JSON(http.StatusInternalServerError, gin.H{"error": "无法获取可用余额"}) + return + } + + oldBalance := traderConfig.InitialBalance + + // ✅ 选项C：智能检测余额变化 + changePercent := ((actualBalance - oldBalance) / oldBalance) * 100 + changeType := "增加" + if changePercent < 0 { + changeType = "减少" + } + + log.Printf("✓ 查询到交易所实际余额: %.2f USDT (当前配置: %.2f USDT, 变化: %.2f%%)", + actualBalance, oldBalance, changePercent) + + // 更新数据库中的 initial_balance + err = s.database.UpdateTraderInitialBalance(userID, traderID, actualBalance) + if err != nil { + log.Printf("❌ 更新initial_balance失败: %v", err) + c.JSON(http.StatusInternalServerError, gin.H{"error": "更新余额失败"}) + return + } + + // 重新加载交易员到内存 + err = s.traderManager.LoadUserTraders(s.database, userID) + if err != nil { + log.Printf("⚠️ 重新加载用户交易员到内存失败: %v", err) + } + + log.Printf("✅ 已同步余额: %.2f → %.2f USDT (%s %.2f%%)", oldBalance, actualBalance, changeType, changePercent) + + c.JSON(http.StatusOK, gin.H{ + "message": "余额同步成功", + "old_balance": oldBalance, + "new_balance": actualBalance, + "change_percent": changePercent, + "change_type": changeType, + }) +} + // handleGetModelConfigs 获取AI模型配置 func (s *Server) handleGetModelConfigs(c *gin.Context) { userID := c.GetString("user_id") @@ -791,19 +1100,12 @@ func (s *Server) handleTraderList(c *gin.Context) { } } - // AIModelID 应该已经是 provider（如 "deepseek"），直接使用 - // 如果是旧数据格式（如 "admin_deepseek"），提取 provider 部分 - aiModelID := trader.AIModelID - // 兼容旧数据：如果包含下划线，提取最后一部分作为 provider - if strings.Contains(aiModelID, "_") { - parts := strings.Split(aiModelID, "_") - aiModelID = parts[len(parts)-1] - } - + // 返回完整的 AIModelID（如 "admin_deepseek"），不要截断 + // 前端需要完整 ID 来验证模型是否存在（与 handleGetTraderConfig 保持一致） result = append(result, map[string]interface{}{ "trader_id": trader.ID, "trader_name": trader.Name, - "ai_model": aiModelID, + "ai_model": trader.AIModelID, // 使用完整 ID "exchange_id": trader.ExchangeID, "is_running": isRunning, "initial_balance": trader.InitialBalance, @@ -1363,7 +1665,6 @@ func (s *Server) handleLogin(c *gin.Context) { // 验证密码 if !auth.CheckPassword(req.Password, user.PasswordHash) { - log.Printf("DEBUG: 密码验证失败") c.JSON(http.StatusUnauthorized, gin.H{"error": "邮箱或密码错误"}) return } @@ -1582,7 +1883,7 @@ func (s *Server) handlePublicCompetition(c *gin.Context) { }) return } - + c.JSON(http.StatusOK, competition) } @@ -1595,7 +1896,7 @@ func (s *Server) handleTopTraders(c *gin.Context) { }) return } - + c.JSON(http.StatusOK, topTraders) } @@ -1604,7 +1905,7 @@ func (s *Server) handleEquityHistoryBatch(c *gin.Context) { var requestBody struct { TraderIDs []string `json:"trader_ids"` } - + // 尝试解析POST请求的JSON body if err := c.ShouldBindJSON(&requestBody); err != nil { // 如果JSON解析失败，尝试从query参数获取（兼容GET请求） @@ -1618,13 +1919,13 @@ func (s *Server) handleEquityHistoryBatch(c *gin.Context) { }) return } - + traders, ok := topTraders["traders"].([]map[string]interface{}) if !ok { c.JSON(http.StatusInternalServerError, gin.H{"error": "交易员数据格式错误"}) return } - + // 提取trader IDs traderIDs := make([]string, 0, len(traders)) for _, trader := range traders { @@ -1632,24 +1933,24 @@ func (s *Server) handleEquityHistoryBatch(c *gin.Context) { traderIDs = append(traderIDs, traderID) } } - + result := s.getEquityHistoryForTraders(traderIDs) c.JSON(http.StatusOK, result) return } - + // 解析逗号分隔的trader IDs requestBody.TraderIDs = strings.Split(traderIDsParam, ",") for i := range requestBody.TraderIDs { requestBody.TraderIDs[i] = strings.TrimSpace(requestBody.TraderIDs[i]) } } - + // 限制最多20个交易员，防止请求过大 if len(requestBody.TraderIDs) > 20 { requestBody.TraderIDs = requestBody.TraderIDs[:20] } - + result := s.getEquityHistoryForTraders(requestBody.TraderIDs) c.JSON(http.StatusOK, result) } @@ -1659,31 +1960,31 @@ func (s *Server) getEquityHistoryForTraders(traderIDs []string) map[string]inter result := make(map[string]interface{}) histories := make(map[string]interface{}) errors := make(map[string]string) - + for _, traderID := range traderIDs { if traderID == "" { continue } - + trader, err := s.traderManager.GetTrader(traderID) if err != nil { errors[traderID] = "交易员不存在" continue } - + // 获取历史数据（用于对比展示，限制数据量） records, err := trader.GetDecisionLogger().GetLatestRecords(500) if err != nil { errors[traderID] = fmt.Sprintf("获取历史数据失败: %v", err) continue } - + // 构建收益率历史数据 history := make([]map[string]interface{}, 0, len(records)) for _, record := range records { // 计算总权益（余额+未实现盈亏） totalEquity := record.AccountState.TotalBalance + record.AccountState.TotalUnrealizedProfit - + history = append(history, map[string]interface{}{ "timestamp": record.Timestamp, "total_equity": totalEquity, @@ -1691,16 +1992,16 @@ func (s *Server) getEquityHistoryForTraders(traderIDs []string) map[string]inter "balance": record.AccountState.TotalBalance, }) } - + histories[traderID] = history } - + result["histories"] = histories result["count"] = len(histories) if len(errors) > 0 { result["errors"] = errors } - + return result } @@ -1734,4 +2035,3 @@ func (s *Server) handleGetPublicTraderConfig(c *gin.Context) { c.JSON(http.StatusOK, result) } - diff --git a/config.json.example b/config.json.example index fefa1673..820f39a7 100644 --- a/config.json.example +++ b/config.json.example @@ -20,5 +20,8 @@ "max_daily_loss": 10.0, "max_drawdown": 20.0, "stop_trading_minutes": 60, - "jwt_secret": "Qk0kAa+d0iIEzXVHXbNbm+UaN3RNabmWtH8rDWZ5OPf+4GX8pBflAHodfpbipVMyrw1fsDanHsNBjhgbDeK9Jg==" + "jwt_secret": "Qk0kAa+d0iIEzXVHXbNbm+UaN3RNabmWtH8rDWZ5OPf+4GX8pBflAHodfpbipVMyrw1fsDanHsNBjhgbDeK9Jg==", + "log": { + "level": "info" + } } \ No newline at end of file diff --git a/config/config.go b/config/config.go index 37a537db..b913212f 100644 --- a/config/config.go +++ b/config/config.go @@ -50,6 +50,20 @@ type LeverageConfig struct { AltcoinLeverage int `json:"altcoin_leverage"` // 山寨币的杠杆倍数（主账户建议5-20，子账户≤5） } +// LogConfig 日志配置 +type LogConfig struct { + Level string `json:"level"` // 日志级别: debug, info, warn, error (默认: info) + Telegram *TelegramConfig `json:"telegram"` // Telegram推送配置（可选） +} + +// TelegramConfig Telegram推送配置（简化版，只保留必需字段） +type TelegramConfig struct { + Enabled bool `json:"enabled"` // 是否启用（默认: false） + BotToken string `json:"bot_token"` // Bot Token + ChatID int64 `json:"chat_id"` // Chat ID + MinLevel string `json:"min_level"` // 最低日志级别，该级别及以上的日志会推送到Telegram（可选，默认: error） +} + // Config 总配置 type Config struct { Traders []TraderConfig `json:"traders"` @@ -60,6 +74,7 @@ type Config struct { MaxDrawdown float64 `json:"max_drawdown"` StopTradingMinutes int `json:"stop_trading_minutes"` Leverage LeverageConfig `json:"leverage"` // 杠杆配置 + Log *LogConfig `json:"log"` // 日志配置（可选） } // LoadConfig 从文件加载配置 diff --git a/config/database.go b/config/database.go index 932982b4..3749df4d 100644 --- a/config/database.go +++ b/config/database.go @@ -40,6 +40,7 @@ type DatabaseInterface interface { GetTraders(userID string) ([]*TraderRecord, error) UpdateTraderStatus(userID, id string, isRunning bool) error UpdateTrader(trader *TraderRecord) error + UpdateTraderInitialBalance(userID, id string, newBalance float64) error UpdateTraderCustomPrompt(userID, id string, customPrompt string, overrideBase bool) error DeleteTrader(userID, id string) error GetTraderConfig(userID, traderID string) (*TraderRecord, *AIModelConfig, *ExchangeConfig, error) @@ -899,6 +900,12 @@ func (d *Database) UpdateTraderCustomPrompt(userID, id string, customPrompt stri return err } +// UpdateTraderInitialBalance 更新交易员初始余额（用于自动同步交易所实际余额） +func (d *Database) UpdateTraderInitialBalance(userID, id string, newBalance float64) error { + _, err := d.db.Exec(`UPDATE traders SET initial_balance = ? WHERE id = ? AND user_id = ?`, newBalance, id, userID) + return err +} + // DeleteTrader 删除交易员 func (d *Database) DeleteTrader(userID, id string) error { _, err := d.db.Exec(`DELETE FROM traders WHERE id = ? AND user_id = ?`, id, userID) @@ -928,8 +935,13 @@ func (d *Database) GetTraderConfig(userID, traderID string) (*TraderRecord, *AIM `, traderID, userID).Scan( &trader.ID, &trader.UserID, &trader.Name, &trader.AIModelID, &trader.ExchangeID, &trader.InitialBalance, &trader.ScanIntervalMinutes, &trader.IsRunning, + &trader.BTCETHLeverage, &trader.AltcoinLeverage, &trader.TradingSymbols, + &trader.UseCoinPool, &trader.UseOITop, + &trader.CustomPrompt, &trader.OverrideBasePrompt, &trader.SystemPromptTemplate, + &trader.IsCrossMargin, &trader.CreatedAt, &trader.UpdatedAt, &aiModel.ID, &aiModel.UserID, &aiModel.Name, &aiModel.Provider, &aiModel.Enabled, &aiModel.APIKey, + &aiModel.CustomAPIURL, &aiModel.CustomModelName, &aiModel.CreatedAt, &aiModel.UpdatedAt, &exchange.ID, &exchange.UserID, &exchange.Name, &exchange.Type, &exchange.Enabled, &exchange.APIKey, &exchange.SecretKey, &exchange.Testnet, @@ -1065,7 +1077,7 @@ func (d *Database) LoadBetaCodesFromFile(filePath string) error { log.Printf("插入内测码 %s 失败: %v", code, err) continue } - + if rowsAffected, _ := result.RowsAffected(); rowsAffected > 0 { insertedCount++ } diff --git a/config/database_pg.go b/config/database_pg.go index b8dd560f..ad11ca07 100644 --- a/config/database_pg.go +++ b/config/database_pg.go @@ -464,6 +464,12 @@ func (d *PostgreSQLDatabase) UpdateTraderCustomPrompt(userID, id string, customP return err } +// UpdateTraderInitialBalance 更新交易员初始余额（用于自动同步交易所实际余额） +func (d *PostgreSQLDatabase) UpdateTraderInitialBalance(userID, id string, newBalance float64) error { + _, err := d.db.Exec(`UPDATE traders SET initial_balance = $1, updated_at = CURRENT_TIMESTAMP WHERE id = $2 AND user_id = $3`, newBalance, id, userID) + return err +} + // DeleteTrader 删除交易员 func (d *PostgreSQLDatabase) DeleteTrader(userID, id string) error { _, err := d.db.Exec(`DELETE FROM traders WHERE id = $1 AND user_id = $2`, id, userID) diff --git a/config/database_test.go b/config/database_test.go deleted file mode 100644 index 45d1ddb4..00000000 --- a/config/database_test.go +++ /dev/null @@ -1,9 +0,0 @@ -package config - -import "testing" - -func TestExample(t *testing.T) { - if 1+1 != 2 { - t.Error("Math is broken") - } -} diff --git a/decision/engine.go b/decision/engine.go index df48d534..598658d1 100644 --- a/decision/engine.go +++ b/decision/engine.go @@ -7,10 +7,22 @@ import ( "nofx/market" "nofx/mcp" "nofx/pool" + "regexp" "strings" "time" ) +// 预编译正则表达式（性能优化：避免每次调用时重新编译） +var ( + // ✅ 安全的正則：精確匹配 ```json 代碼塊 + // 使用反引號 + 拼接避免轉義問題 + reJSONFence = regexp.MustCompile(`(?is)` + "```json\\s*(\\[\\s*\\{.*?\\}\\s*\\])\\s*```") + reJSONArray = regexp.MustCompile(`(?is)\[\s*\{.*?\}\s*\]`) + reArrayHead = regexp.MustCompile(`^\[\s*\{`) + reArrayOpenSpace = regexp.MustCompile(`^\[\s+\{`) + reInvisibleRunes = regexp.MustCompile("[\u200B\u200C\u200D\uFEFF]") +) + // PositionInfo 持仓信息 type PositionInfo struct { Symbol string `json:"symbol"` @@ -71,11 +83,20 @@ type Context struct { // Decision AI的交易决策 type Decision struct { Symbol string `json:"symbol"` - Action string `json:"action"` // "open_long", "open_short", "close_long", "close_short", "hold", "wait" + Action string `json:"action"` // "open_long", "open_short", "close_long", "close_short", "update_stop_loss", "update_take_profit", "partial_close", "hold", "wait" + + // 开仓参数 Leverage int `json:"leverage,omitempty"` PositionSizeUSD float64 `json:"position_size_usd,omitempty"` StopLoss float64 `json:"stop_loss,omitempty"` TakeProfit float64 `json:"take_profit,omitempty"` + + // 调整参数（新增） + NewStopLoss float64 `json:"new_stop_loss,omitempty"` // 用于 update_stop_loss + NewTakeProfit float64 `json:"new_take_profit,omitempty"` // 用于 update_take_profit + ClosePercentage float64 `json:"close_percentage,omitempty"` // 用于 partial_close (0-100) + + // 通用参数 Confidence int `json:"confidence,omitempty"` // 信心度 (0-100) RiskUSD float64 `json:"risk_usd,omitempty"` // 最大美元风险 Reasoning string `json:"reasoning"` @@ -160,17 +181,20 @@ func fetchMarketDataForContext(ctx *Context) error { continue } - // ⚠️ 流动性过滤：持仓价值低于15M USD的币种不做（多空都不做） + // ⚠️ 流动性过滤：持仓价值低于阈值的币种不做（多空都不做） // 持仓价值 = 持仓量 × 当前价格 // 但现有持仓必须保留（需要决策是否平仓） + // 💡 OI 門檻配置：用戶可根據風險偏好調整 + const minOIThresholdMillions = 15.0 // 可調整：15M(保守) / 10M(平衡) / 8M(寬鬆) / 5M(激進) + isExistingPosition := positionSymbols[symbol] if !isExistingPosition && data.OpenInterest != nil && data.CurrentPrice > 0 { // 计算持仓价值（USD）= 持仓量 × 当前价格 oiValue := data.OpenInterest.Latest * data.CurrentPrice oiValueInMillions := oiValue / 1_000_000 // 转换为百万美元单位 - if oiValueInMillions < 15 { - log.Printf("⚠️ %s 持仓价值过低(%.2fM USD < 15M)，跳过此币种 [持仓量:%.0f × 价格:%.4f]", - symbol, oiValueInMillions, data.OpenInterest.Latest, data.CurrentPrice) + if oiValueInMillions < minOIThresholdMillions { + log.Printf("⚠️ %s 持仓价值过低(%.2fM USD < %.1fM)，跳过此币种 [持仓量:%.0f × 价格:%.4f]", + symbol, oiValueInMillions, minOIThresholdMillions, data.OpenInterest.Latest, data.CurrentPrice) continue } } @@ -200,10 +224,31 @@ func fetchMarketDataForContext(ctx *Context) error { // calculateMaxCandidates 根据账户状态计算需要分析的候选币种数量 func calculateMaxCandidates(ctx *Context) int { - // 直接返回候选池的全部币种数量 - // 因为候选池已经在 auto_trader.go 中筛选过了 - // 固定分析前20个评分最高的币种（来自AI500） - return len(ctx.CandidateCoins) + // ⚠️ 重要：限制候选币种数量，避免 Prompt 过大 + // 根据持仓数量动态调整：持仓越少，可以分析更多候选币 + const ( + maxCandidatesWhenEmpty = 30 // 无持仓时最多分析30个候选币 + maxCandidatesWhenHolding1 = 25 // 持仓1个时最多分析25个候选币 + maxCandidatesWhenHolding2 = 20 // 持仓2个时最多分析20个候选币 + maxCandidatesWhenHolding3 = 15 // 持仓3个时最多分析15个候选币（避免 Prompt 过大） + ) + + positionCount := len(ctx.Positions) + var maxCandidates int + + switch positionCount { + case 0: + maxCandidates = maxCandidatesWhenEmpty + case 1: + maxCandidates = maxCandidatesWhenHolding1 + case 2: + maxCandidates = maxCandidatesWhenHolding2 + default: // 3+ 持仓 + maxCandidates = maxCandidatesWhenHolding3 + } + + // 返回实际候选币数量和上限中的较小值 + return min(len(ctx.CandidateCoins), maxCandidates) } // buildSystemPromptWithCustom 构建包含自定义内容的 System Prompt @@ -264,9 +309,11 @@ func buildSystemPrompt(accountEquity float64, btcEthLeverage, altcoinLeverage in sb.WriteString("# 硬约束（风险控制）\n\n") sb.WriteString("1. 风险回报比: 必须 ≥ 1:3（冒1%风险，赚3%+收益）\n") sb.WriteString("2. 最多持仓: 3个币种（质量>数量）\n") - sb.WriteString(fmt.Sprintf("3. 单币仓位: 山寨%.0f-%.0f U(%dx杠杆) | BTC/ETH %.0f-%.0f U(%dx杠杆)\n", - accountEquity*0.8, accountEquity*1.5, altcoinLeverage, accountEquity*5, accountEquity*10, btcEthLeverage)) - sb.WriteString("4. 保证金: 总使用率 ≤ 90%\n\n") + sb.WriteString(fmt.Sprintf("3. 单币仓位: 山寨%.0f-%.0f U | BTC/ETH %.0f-%.0f U\n", + accountEquity*0.8, accountEquity*1.5, accountEquity*5, accountEquity*10)) + sb.WriteString(fmt.Sprintf("4. 杠杆限制: **山寨币最大%dx杠杆** | **BTC/ETH最大%dx杠杆** (⚠️ 严格执行，不可超过)\n", altcoinLeverage, btcEthLeverage)) + sb.WriteString("5. 保证金: 总使用率 ≤ 90%\n") + sb.WriteString("6. 开仓金额: 建议 **≥12 USDT** (交易所最小名义价值 10 USDT + 安全边际)\n\n") // 3. 输出格式 - 动态生成 sb.WriteString("#输出格式\n\n") @@ -430,25 +477,44 @@ func extractCoTTrace(response string) string { // extractDecisions 提取JSON决策列表 func extractDecisions(response string) ([]Decision, error) { - // 直接查找JSON数组 - 找第一个完整的JSON数组 - arrayStart := strings.Index(response, "[") - if arrayStart == -1 { - return nil, fmt.Errorf("无法找到JSON数组起始") + // 预清洗：去零宽/BOM + s := removeInvisibleRunes(response) + s = strings.TrimSpace(s) + + // 🔧 關鍵修復：在正則匹配之前就先修復全角字符！ + // 否則正則表達式 \[ 無法匹配全角的 ［ + s = fixMissingQuotes(s) + + // 1) 优先从 ```json 代码块中提取 + if m := reJSONFence.FindStringSubmatch(s); m != nil && len(m) > 1 { + jsonContent := strings.TrimSpace(m[1]) + jsonContent = compactArrayOpen(jsonContent) // 把 "[ {" 规整为 "[{" + jsonContent = fixMissingQuotes(jsonContent) // 二次修復（防止 regex 提取後還有全角） + if err := validateJSONFormat(jsonContent); err != nil { + return nil, fmt.Errorf("JSON格式验证失败: %w\nJSON内容: %s\n完整响应:\n%s", err, jsonContent, response) + } + var decisions []Decision + if err := json.Unmarshal([]byte(jsonContent), &decisions); err != nil { + return nil, fmt.Errorf("JSON解析失败: %w\nJSON内容: %s", err, jsonContent) + } + return decisions, nil } - // 从 [ 开始，匹配括号找到对应的 ] - arrayEnd := findMatchingBracket(response, arrayStart) - if arrayEnd == -1 { - return nil, fmt.Errorf("无法找到JSON数组结束") + // 2) 退而求其次：全文寻找首个对象数组 + // 注意：此時 s 已經過 fixMissingQuotes()，全角字符已轉換為半角 + jsonContent := strings.TrimSpace(reJSONArray.FindString(s)) + if jsonContent == "" { + return nil, fmt.Errorf("无法找到JSON数组起始（已嘗試修復全角字符）\n原始響應前200字符: %s", s[:min(200, len(s))]) } - jsonContent := strings.TrimSpace(response[arrayStart : arrayEnd+1]) + // 🔧 規整格式（此時全角字符已在前面修復過） + jsonContent = compactArrayOpen(jsonContent) + jsonContent = fixMissingQuotes(jsonContent) // 二次修復（防止 regex 提取後還有殘留全角） - // 🔧 修复常见的JSON格式错误：缺少引号的字段值 - // 匹配: "reasoning": 内容"} 或 "reasoning": 内容} (没有引号) - // 修复为: "reasoning": "内容"} - // 使用简单的字符串扫描而不是正则表达式 - jsonContent = fixMissingQuotes(jsonContent) + // 🔧 验证 JSON 格式（检测常见错误） + if err := validateJSONFormat(jsonContent); err != nil { + return nil, fmt.Errorf("JSON格式验证失败: %w\nJSON内容: %s\n完整响应:\n%s", err, jsonContent, response) + } // 解析JSON var decisions []Decision @@ -459,15 +525,86 @@ func extractDecisions(response string) ([]Decision, error) { return decisions, nil } -// fixMissingQuotes 替换中文引号为英文引号（避免输入法自动转换） +// fixMissingQuotes 替换中文引号和全角字符为英文引号和半角字符（避免AI输出全角JSON字符导致解析失败） func fixMissingQuotes(jsonStr string) string { + // 替换中文引号 jsonStr = strings.ReplaceAll(jsonStr, "\u201c", "\"") // " jsonStr = strings.ReplaceAll(jsonStr, "\u201d", "\"") // " jsonStr = strings.ReplaceAll(jsonStr, "\u2018", "'") // ' jsonStr = strings.ReplaceAll(jsonStr, "\u2019", "'") // ' + + // ⚠️ 替换全角括号、冒号、逗号（防止AI输出全角JSON字符） + jsonStr = strings.ReplaceAll(jsonStr, "［", "[") // U+FF3B 全角左方括号 + jsonStr = strings.ReplaceAll(jsonStr, "］", "]") // U+FF3D 全角右方括号 + jsonStr = strings.ReplaceAll(jsonStr, "｛", "{") // U+FF5B 全角左花括号 + jsonStr = strings.ReplaceAll(jsonStr, "｝", "}") // U+FF5D 全角右花括号 + jsonStr = strings.ReplaceAll(jsonStr, "：", ":") // U+FF1A 全角冒号 + jsonStr = strings.ReplaceAll(jsonStr, "，", ",") // U+FF0C 全角逗号 + + // ⚠️ 替换CJK标点符号（AI在中文上下文中也可能输出这些） + jsonStr = strings.ReplaceAll(jsonStr, "【", "[") // CJK左方头括号 U+3010 + jsonStr = strings.ReplaceAll(jsonStr, "】", "]") // CJK右方头括号 U+3011 + jsonStr = strings.ReplaceAll(jsonStr, "〔", "[") // CJK左龟壳括号 U+3014 + jsonStr = strings.ReplaceAll(jsonStr, "〕", "]") // CJK右龟壳括号 U+3015 + jsonStr = strings.ReplaceAll(jsonStr, "、", ",") // CJK顿号 U+3001 + + // ⚠️ 替换全角空格为半角空格（JSON中不应该有全角空格） + jsonStr = strings.ReplaceAll(jsonStr, " ", " ") // U+3000 全角空格 + return jsonStr } +// validateJSONFormat 验证 JSON 格式，检测常见错误 +func validateJSONFormat(jsonStr string) error { + trimmed := strings.TrimSpace(jsonStr) + + // 允许 [ 和 { 之间存在任意空白（含零宽） + if !reArrayHead.MatchString(trimmed) { + // 检查是否是纯数字/范围数组（常见错误） + if strings.HasPrefix(trimmed, "[") && !strings.Contains(trimmed[:min(20, len(trimmed))], "{") { + return fmt.Errorf("不是有效的决策数组（必须包含对象 {}），实际内容: %s", trimmed[:min(50, len(trimmed))]) + } + return fmt.Errorf("JSON 必须以 [{ 开头（允许空白），实际: %s", trimmed[:min(20, len(trimmed))]) + } + + // 检查是否包含范围符号 ~（LLM 常见错误） + if strings.Contains(jsonStr, "~") { + return fmt.Errorf("JSON 中不可包含范围符号 ~，所有数字必须是精确的单一值") + } + + // 检查是否包含千位分隔符（如 98,000） + // 使用简单的模式匹配：数字+逗号+3位数字 + for i := 0; i < len(jsonStr)-4; i++ { + if jsonStr[i] >= '0' && jsonStr[i] <= '9' && + jsonStr[i+1] == ',' && + jsonStr[i+2] >= '0' && jsonStr[i+2] <= '9' && + jsonStr[i+3] >= '0' && jsonStr[i+3] <= '9' && + jsonStr[i+4] >= '0' && jsonStr[i+4] <= '9' { + return fmt.Errorf("JSON 数字不可包含千位分隔符逗号，发现: %s", jsonStr[i:min(i+10, len(jsonStr))]) + } + } + + return nil +} + +// min 返回两个整数中的较小值 +func min(a, b int) int { + if a < b { + return a + } + return b +} + +// removeInvisibleRunes 去除零宽字符和 BOM，避免肉眼看不见的前缀破坏校验 +func removeInvisibleRunes(s string) string { + return reInvisibleRunes.ReplaceAllString(s, "") +} + +// compactArrayOpen 规整开头的 "[ {" → "[{" +func compactArrayOpen(s string) string { + return reArrayOpenSpace.ReplaceAllString(strings.TrimSpace(s), "[{") +} + // validateDecisions 验证所有决策（需要账户信息和杠杆配置） func validateDecisions(decisions []Decision, accountEquity float64, btcEthLeverage, altcoinLeverage int) error { for i, decision := range decisions { @@ -504,12 +641,15 @@ func findMatchingBracket(s string, start int) int { func validateDecision(d *Decision, accountEquity float64, btcEthLeverage, altcoinLeverage int) error { // 验证action validActions := map[string]bool{ - "open_long": true, - "open_short": true, - "close_long": true, - "close_short": true, - "hold": true, - "wait": true, + "open_long": true, + "open_short": true, + "close_long": true, + "close_short": true, + "update_stop_loss": true, + "update_take_profit": true, + "partial_close": true, + "hold": true, + "wait": true, } if !validActions[d.Action] { @@ -532,6 +672,22 @@ func validateDecision(d *Decision, accountEquity float64, btcEthLeverage, altcoi if d.PositionSizeUSD <= 0 { return fmt.Errorf("仓位大小必须大于0: %.2f", d.PositionSizeUSD) } + + // ✅ 验证最小开仓金额（防止数量格式化为 0 的错误） + // Binance 最小名义价值 10 USDT + 安全边际 + const minPositionSizeGeneral = 12.0 // 10 + 20% 安全边际 + const minPositionSizeBTCETH = 60.0 // BTC/ETH 因价格高和精度限制需要更大金额（更灵活） + + if d.Symbol == "BTCUSDT" || d.Symbol == "ETHUSDT" { + if d.PositionSizeUSD < minPositionSizeBTCETH { + return fmt.Errorf("%s 开仓金额过小(%.2f USDT)，必须≥%.2f USDT（因价格高且精度限制，避免数量四舍五入为0）", d.Symbol, d.PositionSizeUSD, minPositionSizeBTCETH) + } + } else { + if d.PositionSizeUSD < minPositionSizeGeneral { + return fmt.Errorf("开仓金额过小(%.2f USDT)，必须≥%.2f USDT（Binance 最小名义价值要求）", d.PositionSizeUSD, minPositionSizeGeneral) + } + } + // 验证仓位价值上限（加1%容差以避免浮点数精度问题） tolerance := maxPositionValue * 0.01 // 1%容差 if d.PositionSizeUSD > maxPositionValue+tolerance { @@ -589,5 +745,26 @@ func validateDecision(d *Decision, accountEquity float64, btcEthLeverage, altcoi } } + // 动态调整止损验证 + if d.Action == "update_stop_loss" { + if d.NewStopLoss <= 0 { + return fmt.Errorf("新止损价格必须大于0: %.2f", d.NewStopLoss) + } + } + + // 动态调整止盈验证 + if d.Action == "update_take_profit" { + if d.NewTakeProfit <= 0 { + return fmt.Errorf("新止盈价格必须大于0: %.2f", d.NewTakeProfit) + } + } + + // 部分平仓验证 + if d.Action == "partial_close" { + if d.ClosePercentage <= 0 || d.ClosePercentage > 100 { + return fmt.Errorf("平仓百分比必须在0-100之间: %.1f", d.ClosePercentage) + } + } + return nil } diff --git a/docker-compose.yml b/docker-compose.yml index 6a60bf54..31d5a474 100644 --- a/docker-compose.yml +++ b/docker-compose.yml @@ -56,6 +56,7 @@ services: - /etc/localtime:/etc/localtime:ro # Sync host time environment: - TZ=${NOFX_TIMEZONE:-Asia/Shanghai} # Set timezone + - AI_MAX_TOKENS=4000 # AI响应的最大token数（默认2000，建议4000-8000） - POSTGRES_HOST=postgres - POSTGRES_PORT=5432 - POSTGRES_DB=${POSTGRES_DB:-nofx} diff --git a/docker/Dockerfile.backend b/docker/Dockerfile.backend index 1145d501..7bd02348 100644 --- a/docker/Dockerfile.backend +++ b/docker/Dockerfile.backend @@ -47,7 +47,9 @@ COPY go.mod go.sum ./ RUN go mod download COPY . . -RUN CGO_ENABLED=1 GOOS=linux CGO_CFLAGS="-D_LARGEFILE64_SOURCE" go build -trimpath -ldflags="-s -w" -o nofx . +RUN CGO_ENABLED=1 GOOS=linux \ + CGO_CFLAGS="-D_LARGEFILE64_SOURCE" \ + go build -trimpath -ldflags="-s -w" -o nofx . # ────────────────────────────────────────────────────────────── # Runtime Stage (Minimal Executable Environment) diff --git a/docs/community/bounty-guide.md b/docs/community/bounty-guide.md index a6b841d2..326ab726 100644 --- a/docs/community/bounty-guide.md +++ b/docs/community/bounty-guide.md @@ -197,7 +197,7 @@ Details: [详情链接] ### 法律 & 合规 - ✅ 明确说明这是开源贡献，不是雇佣关系 -- ✅ 确保贡献者同意 MIT License +- ✅ 确保贡献者同意 AGPL-3.0 License - ✅ 保留最终合并决定权 ### 资金管理 diff --git a/docs/getting-started/README.md b/docs/getting-started/README.md index c35926f9..9e1740f7 100644 --- a/docs/getting-started/README.md +++ b/docs/getting-started/README.md @@ -23,7 +23,7 @@ Choose the method that best fits your needs: **Quick Start:** ```bash -cp config.example.jsonc config.json +cp config.json.example config.json ./start.sh start --build ``` diff --git a/docs/getting-started/README.zh-CN.md b/docs/getting-started/README.zh-CN.md index aafe5cfb..836619f6 100644 --- a/docs/getting-started/README.zh-CN.md +++ b/docs/getting-started/README.zh-CN.md @@ -21,7 +21,7 @@ **快速开始：** ```bash -cp config.example.jsonc config.json +cp config.json.example config.json ./start.sh start --build ``` diff --git a/docs/getting-started/docker-deploy.en.md b/docs/getting-started/docker-deploy.en.md index bd909273..7cb4e3d2 100644 --- a/docs/getting-started/docker-deploy.en.md +++ b/docs/getting-started/docker-deploy.en.md @@ -50,7 +50,7 @@ docker compose --version # Docker 24+ includes this, no separate installation n ```bash # Copy configuration template -cp config.example.jsonc config.json +cp config.json.example config.json # Edit configuration file with your API keys nano config.json # or use any other editor @@ -267,7 +267,7 @@ kill -9
+
- );
+ )
}
// Handle specific routes regardless of authentication
if (route === '/login') {
- return
- 
+
+
{t('loading', language)}
-
+ {
- console.log('Competition page onPageChange called with:', page);
- console.log('Current route:', route, 'Current page:', currentPage);
-
+ console.log('Competition page onPageChange called with:', page)
+ console.log('Current route:', route, 'Current page:', currentPage)
+
if (page === 'competition') {
- console.log('Navigating to competition');
- window.history.pushState({}, '', '/competition');
- setRoute('/competition');
- setCurrentPage('competition');
+ console.log('Navigating to competition')
+ window.history.pushState({}, '', '/competition')
+ setRoute('/competition')
+ setCurrentPage('competition')
} else if (page === 'traders') {
- console.log('Navigating to traders');
- window.history.pushState({}, '', '/traders');
- setRoute('/traders');
- setCurrentPage('traders');
+ console.log('Navigating to traders')
+ window.history.pushState({}, '', '/traders')
+ setRoute('/traders')
+ setCurrentPage('traders')
} else if (page === 'trader') {
- console.log('Navigating to trader/dashboard');
- window.history.pushState({}, '', '/dashboard');
- setRoute('/dashboard');
- setCurrentPage('trader');
+ console.log('Navigating to trader/dashboard')
+ window.history.pushState({}, '', '/dashboard')
+ setRoute('/dashboard')
+ setCurrentPage('trader')
}
-
- console.log('After navigation - route:', route, 'currentPage:', currentPage);
+
+ console.log(
+ 'After navigation - route:',
+ route,
+ 'currentPage:',
+ currentPage
+ )
}}
/>
- );
+ )
}
-
+
// Show landing page for root route
if (route === '/' || route === '') {
- return
-
+ {
- console.log('Main app onPageChange called with:', page);
-
+ console.log('Main app onPageChange called with:', page)
+
if (page === 'competition') {
- window.history.pushState({}, '', '/competition');
- setRoute('/competition');
- setCurrentPage('competition');
+ window.history.pushState({}, '', '/competition')
+ setRoute('/competition')
+ setCurrentPage('competition')
} else if (page === 'traders') {
- window.history.pushState({}, '', '/traders');
- setRoute('/traders');
- setCurrentPage('traders');
+ window.history.pushState({}, '', '/traders')
+ setRoute('/traders')
+ setCurrentPage('traders')
} else if (page === 'trader') {
- window.history.pushState({}, '', '/dashboard');
- setRoute('/dashboard');
- setCurrentPage('trader');
+ window.history.pushState({}, '', '/dashboard')
+ setRoute('/dashboard')
+ setCurrentPage('trader')
}
}}
/>
@@ -301,12 +328,12 @@ function App() {
{currentPage === 'competition' ? (
{
- setSelectedTraderId(traderId);
- window.history.pushState({}, '', '/dashboard');
- setRoute('/dashboard');
- setCurrentPage('trader');
+ setSelectedTraderId(traderId)
+ window.history.pushState({}, '', '/dashboard')
+ setRoute('/dashboard')
+ setCurrentPage('trader')
}}
/>
) : (
@@ -327,8 +354,14 @@ function App() {
{/* Footer */}
-
- );
+ )
}
return (
{/* Trader Header */}
-
+
-
-
+
-
-
+
+
🤖
{selectedTrader.trader_name}
-
+
{/* Trader Selector */}
{traders && traders.length > 0 && (
- {t('switchTrader', language)}:
+
+ {t('switchTrader', language)}:
+
)}
- AI Model: {getModelDisplayName(selectedTrader.ai_model.split('_').pop() || selectedTrader.ai_model)}
+
+
+ AI Model:{' '}
+
+ {getModelDisplayName(
+ selectedTrader.ai_model.split('_').pop() ||
+ selectedTrader.ai_model
+ )}
+
+
{status && (
<>
•
@@ -460,11 +542,16 @@ function TraderDetailsPage({
{/* Debug Info */}
{account && (
-
+
)}
@@ -480,7 +567,7 @@ function TraderDetailsPage({
{/* Current Positions */}
-
- 🔄 Last Update: {lastUpdate} | Total Equity: {account?.total_equity?.toFixed(2) || '0.00'} |
- Available: {account?.available_balance?.toFixed(2) || '0.00'} | P&L: {account?.total_pnl?.toFixed(2) || '0.00'}{' '}
- ({account?.total_pnl_pct?.toFixed(2) || '0.00'}%)
+ 🔄 Last Update: {lastUpdate} | Total Equity:{' '}
+ {account?.total_equity?.toFixed(2) || '0.00'} | Available:{' '}
+ {account?.available_balance?.toFixed(2) || '0.00'} | P&L:{' '}
+ {account?.total_pnl?.toFixed(2) || '0.00'} (
+ {account?.total_pnl_pct?.toFixed(2) || '0.00'}%)
-
-
{/* 左侧结束 */}
{/* 右侧：Recent Decisions - 卡片容器 */}
- - 📈 {t('currentPositions', language)} -
- {positions && positions.length > 0 && ( -
- {positions.length} {t('active', language)}
+
+
- {positions && positions.length > 0 ? (
-
+
- )}
- + 📈 {t('currentPositions', language)} +
+ {positions && positions.length > 0 && ( +
+ {positions.length} {t('active', language)}
+
+ )}
-
-
-
+
+ ) : (
+ | {t('symbol', language)} | -{t('side', language)} | -{t('entryPrice', language)} | -{t('markPrice', language)} | -{t('quantity', language)} | -{t('positionValue', language)} | -{t('leverage', language)} | -{t('unrealizedPnL', language)} | -{t('liqPrice', language)} | -||||||||||||||||||
|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|---|
| {pos.symbol} | -
- 0 ? (
+
+
- ) : (
-
-
- )}
+ 📊
- {t('noPositions', language)}
- {t('noActivePositions', language)}
- | + {pos.symbol} + | ++ + {t( + pos.side === 'long' ? 'long' : 'short', + language + )} + + | ++ {pos.entry_price.toFixed(4)} + | ++ {pos.mark_price.toFixed(4)} + | ++ {pos.quantity.toFixed(4)} + | ++ {(pos.quantity * pos.mark_price).toFixed(2)} USDT + | ++ {pos.leverage}x + | ++ = 0 ? '#0ECB81' : '#F6465D', + fontWeight: 'bold', + }} + > + {pos.unrealized_pnl >= 0 ? '+' : ''} + {pos.unrealized_pnl.toFixed(2)} ( + {pos.unrealized_pnl_pct.toFixed(2)}%) + + | ++ {pos.liquidation_price.toFixed(4)} + | +
+
+ )}
📊
+
+ {t('noPositions', language)}
+
+
+ {t('noActivePositions', language)}
+
+
+
{/* 标题 */}
-
-
+
+
🧠
-
- );
+ )
}
// Stat Card Component - Binance Style Enhanced
@@ -635,16 +824,26 @@ function StatCard({
positive,
subtitle,
}: {
- title: string;
- value: string;
- change?: number;
- positive?: boolean;
- subtitle?: string;
+ title: string
+ value: string
+ change?: number
+ positive?: boolean
+ subtitle?: string
}) {
return (
{t('recentDecisions', language)}
++ {t('recentDecisions', language)} +
{decisions && decisions.length > 0 && (
{t('lastCycles', language, { count: decisions.length })}
@@ -602,7 +781,10 @@ function TraderDetailsPage({
{/* 决策列表 - 可滚动 */}
-
+
{decisions && decisions.length > 0 ? (
decisions.map((decision, i) => (
@@ -624,7 +813,7 @@ function TraderDetailsPage({
🧠
- {t('noDecisionsYet', language)}
- {t('aiDecisionsWillAppear', language)}
+
+ {t('noDecisionsYet', language)}
+
+
+ {t('aiDecisionsWillAppear', language)}
+
-
)}
- {subtitle &&
- );
+ )
}
// Decision Card Component with CoT Trace - Binance Style
-function DecisionCard({ decision, language }: { decision: DecisionRecord; language: Language }) {
- const [showInputPrompt, setShowInputPrompt] = useState(false);
- const [showCoT, setShowCoT] = useState(false);
+function DecisionCard({
+ decision,
+ language,
+}: {
+ decision: DecisionRecord
+ language: Language
+}) {
+ const [showInputPrompt, setShowInputPrompt] = useState(false)
+ const [showCoT, setShowCoT] = useState(false)
return (
-
{title}
- {value}
+
+ {title}
+
+
+ {value}
+
{change !== undefined && (
{subtitle}
}
+ {subtitle && (
+
+ {subtitle}
+
+ )}
+
{/* Header */}
-
{t('cycle', language)} #{decision.cycle_number}
+
+ {t('cycle', language)} #{decision.cycle_number}
+
{new Date(decision.timestamp).toLocaleString()}
{t(decision.success ? 'success' : 'failed', language)}
@@ -695,11 +914,24 @@ function DecisionCard({ decision, language }: { decision: DecisionRecord; langua
className="flex items-center gap-2 text-sm transition-colors"
style={{ color: '#60a5fa' }}
>
- 📥 {t('inputPrompt', language)}
- {showInputPrompt ? t('collapse', language) : t('expand', language)}
+
+ 📥 {t('inputPrompt', language)}
+
+
+ {showInputPrompt
+ ? t('collapse', language)
+ : t('expand', language)}
+
{showInputPrompt && (
-
+
{decision.input_prompt}
)}
@@ -714,11 +946,22 @@ function DecisionCard({ decision, language }: { decision: DecisionRecord; langua
className="flex items-center gap-2 text-sm transition-colors"
style={{ color: '#F0B90B' }}
>
- 📤 {t('aiThinking', language)}
- {showCoT ? t('collapse', language) : t('expand', language)}
+
+ 📤 {t('aiThinking', language)}
+
+
+ {showCoT ? t('collapse', language) : t('expand', language)}
+
{showCoT && (
-
+
{decision.cot_trace}
)}
@@ -729,25 +972,52 @@ function DecisionCard({ decision, language }: { decision: DecisionRecord; langua
{decision.decisions && decision.decisions.length > 0 && (
{decision.decisions.map((action, j) => (
-
- {action.symbol}
+
@@ -755,11 +1025,60 @@ function DecisionCard({ decision, language }: { decision: DecisionRecord; langua
{/* Account State Summary */}
{decision.account_state && (
-
+
+ {action.symbol}
+
{action.action}
- {action.leverage > 0 && {action.leverage}x}
+ {action.leverage > 0 && (
+ {action.leverage}x
+ )}
{action.price > 0 && (
- @{action.price.toFixed(4)}
+
+ @{action.price.toFixed(4)}
+
)}
{action.success ? '✓' : '✗'}
- {action.error && {action.error}}
+ {action.error && (
+
+ {action.error}
+
+ )}
))}
- 净值: {decision.account_state.total_balance.toFixed(2)} USDT
- 可用: {decision.account_state.available_balance.toFixed(2)} USDT
- 保证金率: {decision.account_state.margin_used_pct.toFixed(1)}%
+ (
traderId ? `performance-${traderId}` : 'performance',
() => api.getPerformance(traderId),
@@ -60,74 +70,98 @@ export default function AILearning({ traderId }: AILearningProps) {
revalidateOnFocus: false,
dedupingInterval: 20000,
}
- );
+ )
if (error) {
return (
-
+
+ 净值: {decision.account_state.total_balance.toFixed(2)} USDT
+
+
+ 可用: {decision.account_state.available_balance.toFixed(2)} USDT
+
+
+ 保证金率: {decision.account_state.margin_used_pct.toFixed(1)}%
+
持仓: {decision.account_state.position_count}
+
+ {t('candidateCoins', language)}: {decision.candidate_coins?.length || 0}
+
+
+ )}
+
+ {/* Candidate Coins Warning */}
+ {decision.candidate_coins && decision.candidate_coins.length === 0 && (
+
+
)}
@@ -770,7 +1089,12 @@ function DecisionCard({ decision, language }: { decision: DecisionRecord; langua
+
⚠️ {t('candidateCoinsZeroWarning', language)}
+
+
+ {t('possibleReasons', language)}
+ -
+
- {t('coinPoolApiNotConfigured', language)} +
- {t('apiConnectionTimeout', language)} +
- {t('noCustomCoinsAndApiFailed', language)} +
+ {t('solutions', language)}
+
+ -
+
- {t('setCustomCoinsInConfig', language)} +
- {t('orConfigureCorrectApiUrl', language)} +
- {t('orDisableCoinPoolOptions', language)} +
{log}
@@ -780,12 +1104,15 @@ function DecisionCard({ decision, language }: { decision: DecisionRecord; langua
{/* Error Message */}
{decision.error_message && (
-
+
- );
+ )
}
// Wrap App with providers
@@ -796,5 +1123,5 @@ export default function AppWithProviders() {
❌ {decision.error_message}
)}
+
- );
+ )
}
if (!performance) {
return (
-
{t('loadingError', language)}
+
+
{t('aiLearning', language)}
-
- {t('noCompleteData', language)}
+
+ + {t('aiLearning', language)} +
{t('noCompleteData', language)}
{/* 标题区 - 优化设计 */}
-
-
+
+
-
+
@@ -136,98 +170,165 @@ export default function AILearning({ traderId }: AILearningProps) {
{/* 核心指标卡片 - 4列网格 */}
-
+
+
{t('aiLearning', language)}
- {t('tradesAnalyzed', language, { count: performance.total_trades })} + {t('tradesAnalyzed', language, { + count: performance.total_trades, + })}
{/* 总交易数 */}
-
-
+
+
-
+
{t('totalTrades', language)}
-
+
{/* 胜率 */}
-
{performance.total_trades}
-
+
= 50
- ? 'linear-gradient(135deg, rgba(16, 185, 129, 0.2) 0%, rgba(30, 35, 41, 0.8) 100%)'
- : 'linear-gradient(135deg, rgba(248, 113, 113, 0.2) 0%, rgba(30, 35, 41, 0.8) 100%)',
- border: `1px solid ${(performance.win_rate || 0) >= 50 ? 'rgba(16, 185, 129, 0.4)' : 'rgba(248, 113, 113, 0.4)'}`,
- boxShadow: `0 4px 16px ${(performance.win_rate || 0) >= 50 ? 'rgba(16, 185, 129, 0.2)' : 'rgba(248, 113, 113, 0.2)'}`
- }}>
-
= 50 ? '#10B981' : '#F87171'} 0%, transparent 70%)`,
- filter: 'blur(20px)'
- }} />
+
= 50
+ ? 'linear-gradient(135deg, rgba(16, 185, 129, 0.2) 0%, rgba(30, 35, 41, 0.8) 100%)'
+ : 'linear-gradient(135deg, rgba(248, 113, 113, 0.2) 0%, rgba(30, 35, 41, 0.8) 100%)',
+ border: `1px solid ${(performance.win_rate || 0) >= 50 ? 'rgba(16, 185, 129, 0.4)' : 'rgba(248, 113, 113, 0.4)'}`,
+ boxShadow: `0 4px 16px ${(performance.win_rate || 0) >= 50 ? 'rgba(16, 185, 129, 0.2)' : 'rgba(248, 113, 113, 0.2)'}`,
+ }}
+ >
+
= 50 ? '#10B981' : '#F87171'} 0%, transparent 70%)`,
+ filter: 'blur(20px)',
+ }}
+ />
-
= 50 ? '#6EE7B7' : '#FCA5A5'
- }}>
+
{/* 平均盈利 */}
- = 50 ? '#6EE7B7' : '#FCA5A5',
+ }}
+ >
{t('winRate', language)}
- = 50 ? '#10B981' : '#F87171'
- }}>
+
= 50 ? '#10B981' : '#F87171',
+ }}
+ >
{(performance.win_rate || 0).toFixed(1)}%
- {performance.winning_trades || 0}W / {performance.losing_trades || 0}L
+ {performance.winning_trades || 0}W /{' '}
+ {performance.losing_trades || 0}L
-
+
+
-
+
{t('avgWin', language)}
-
+
{/* 平均亏损 */}
-
+{(performance.avg_win || 0).toFixed(2)}
-
+
-
+
+
-
+
{t('avgLoss', language)}
-
+
{(performance.avg_loss || 0).toFixed(2)}
-
+
@@ -237,67 +338,121 @@ export default function AILearning({ traderId }: AILearningProps) {
{/* 关键指标：夏普比率 & 盈亏比 - 2列网格 */}
{/* 夏普比率 */}
-
-
+
+
-
+
-
夏普比率
- 风险调整后收益 · AI自我进化指标
+
+ 夏普比率
+
+
+ 风险调整后收益 · AI自我进化指标
+
-
= 2 ? '#10B981' :
- (performance.sharpe_ratio || 0) >= 1 ? '#22D3EE' :
- (performance.sharpe_ratio || 0) >= 0 ? '#F0B90B' : '#F87171',
- textShadow: '0 4px 12px rgba(0, 0, 0, 0.3)'
- }}>
- {performance.sharpe_ratio ? performance.sharpe_ratio.toFixed(2) : 'N/A'}
+
= 2
+ ? '#10B981'
+ : (performance.sharpe_ratio || 0) >= 1
+ ? '#22D3EE'
+ : (performance.sharpe_ratio || 0) >= 0
+ ? '#F0B90B'
+ : '#F87171',
+ textShadow: '0 4px 12px rgba(0, 0, 0, 0.3)',
+ }}
+ >
+ {performance.sharpe_ratio
+ ? performance.sharpe_ratio.toFixed(2)
+ : 'N/A'}
{performance.sharpe_ratio !== undefined && (
-
{performance.sharpe_ratio !== undefined && (
- = 2 ? '#10B981' :
- (performance.sharpe_ratio || 0) >= 1 ? '#22D3EE' :
- (performance.sharpe_ratio || 0) >= 0 ? '#F0B90B' : '#F87171',
- background: (performance.sharpe_ratio || 0) >= 2 ? 'rgba(16, 185, 129, 0.2)' :
- (performance.sharpe_ratio || 0) >= 1 ? 'rgba(34, 211, 238, 0.2)' :
- (performance.sharpe_ratio || 0) >= 0 ? 'rgba(240, 185, 11, 0.2)' : 'rgba(248, 113, 113, 0.2)'
- }}>
- {performance.sharpe_ratio >= 2 ? '🟢 卓越表现' :
- performance.sharpe_ratio >= 1 ? '🟢 良好表现' :
- performance.sharpe_ratio >= 0 ? '🟡 波动较大' : '🔴 需要调整'}
+
)}
= 2
+ ? '#10B981'
+ : (performance.sharpe_ratio || 0) >= 1
+ ? '#22D3EE'
+ : (performance.sharpe_ratio || 0) >= 0
+ ? '#F0B90B'
+ : '#F87171',
+ background:
+ (performance.sharpe_ratio || 0) >= 2
+ ? 'rgba(16, 185, 129, 0.2)'
+ : (performance.sharpe_ratio || 0) >= 1
+ ? 'rgba(34, 211, 238, 0.2)'
+ : (performance.sharpe_ratio || 0) >= 0
+ ? 'rgba(240, 185, 11, 0.2)'
+ : 'rgba(248, 113, 113, 0.2)',
+ }}
+ >
+ {performance.sharpe_ratio >= 2
+ ? '🟢 卓越表现'
+ : performance.sharpe_ratio >= 1
+ ? '🟢 良好表现'
+ : performance.sharpe_ratio >= 0
+ ? '🟡 波动较大'
+ : '🔴 需要调整'}
-
- {performance.sharpe_ratio >= 2 && '✨ AI策略非常有效！风险调整后收益优异，可适度扩大仓位但保持纪律。'}
- {performance.sharpe_ratio >= 1 && performance.sharpe_ratio < 2 && '✅ 策略表现稳健，风险收益平衡良好，继续保持当前策略。'}
- {performance.sharpe_ratio >= 0 && performance.sharpe_ratio < 1 && '⚠️ 收益为正但波动较大，AI正在优化策略，降低风险。'}
- {performance.sharpe_ratio < 0 && '🚨 当前策略需要调整！AI已自动进入保守模式，减少仓位和交易频率。'}
+
{/* 盈亏比 */}
-
+
)}
@@ -305,21 +460,32 @@ export default function AILearning({ traderId }: AILearningProps) {
+ {performance.sharpe_ratio >= 2 &&
+ '✨ AI策略非常有效！风险调整后收益优异，可适度扩大仓位但保持纪律。'}
+ {performance.sharpe_ratio >= 1 &&
+ performance.sharpe_ratio < 2 &&
+ '✅ 策略表现稳健，风险收益平衡良好，继续保持当前策略。'}
+ {performance.sharpe_ratio >= 0 &&
+ performance.sharpe_ratio < 1 &&
+ '⚠️ 收益为正但波动较大，AI正在优化策略，降低风险。'}
+ {performance.sharpe_ratio < 0 &&
+ '🚨 当前策略需要调整！AI已自动进入保守模式，减少仓位和交易频率。'}
-
+
+
-
+
@@ -333,39 +499,82 @@ export default function AILearning({ traderId }: AILearningProps) {
-
= 2.0 ? '#10B981' :
- (performance.profit_factor || 0) >= 1.5 ? '#F0B90B' :
- (performance.profit_factor || 0) >= 1.0 ? '#FB923C' : '#F87171',
- textShadow: '0 4px 12px rgba(0, 0, 0, 0.3)'
- }}>
- {(performance.profit_factor || 0) > 0 ? (performance.profit_factor || 0).toFixed(2) : 'N/A'}
+
= 2.0
+ ? '#10B981'
+ : (performance.profit_factor || 0) >= 1.5
+ ? '#F0B90B'
+ : (performance.profit_factor || 0) >= 1.0
+ ? '#FB923C'
+ : '#F87171',
+ textShadow: '0 4px 12px rgba(0, 0, 0, 0.3)',
+ }}
+ >
+ {(performance.profit_factor || 0) > 0
+ ? (performance.profit_factor || 0).toFixed(2)
+ : 'N/A'}
-
- = 2.0 ? '#10B981' :
- (performance.profit_factor || 0) >= 1.5 ? '#F0B90B' : '#94A3B8',
- background: (performance.profit_factor || 0) >= 2.0 ? 'rgba(16, 185, 129, 0.2)' :
- (performance.profit_factor || 0) >= 1.5 ? 'rgba(240, 185, 11, 0.2)' : 'rgba(148, 163, 184, 0.2)'
- }}>
- {(performance.profit_factor || 0) >= 2.0 && t('excellent', language)}
- {(performance.profit_factor || 0) >= 1.5 && (performance.profit_factor || 0) < 2.0 && t('good', language)}
- {(performance.profit_factor || 0) >= 1.0 && (performance.profit_factor || 0) < 1.5 && t('fair', language)}
- {(performance.profit_factor || 0) > 0 && (performance.profit_factor || 0) < 1.0 && t('poor', language)}
+
= 2.0
+ ? '#10B981'
+ : (performance.profit_factor || 0) >= 1.5
+ ? '#F0B90B'
+ : '#94A3B8',
+ background:
+ (performance.profit_factor || 0) >= 2.0
+ ? 'rgba(16, 185, 129, 0.2)'
+ : (performance.profit_factor || 0) >= 1.5
+ ? 'rgba(240, 185, 11, 0.2)'
+ : 'rgba(148, 163, 184, 0.2)',
+ }}
+ >
+ {(performance.profit_factor || 0) >= 2.0 &&
+ t('excellent', language)}
+ {(performance.profit_factor || 0) >= 1.5 &&
+ (performance.profit_factor || 0) < 2.0 &&
+ t('good', language)}
+ {(performance.profit_factor || 0) >= 1.0 &&
+ (performance.profit_factor || 0) < 1.5 &&
+ t('fair', language)}
+ {(performance.profit_factor || 0) > 0 &&
+ (performance.profit_factor || 0) < 1.0 &&
+ t('poor', language)}
-
- {(performance.profit_factor || 0) >= 2.0 && '🔥 盈利能力出色！每亏1元能赚' + (performance.profit_factor || 0).toFixed(1) + '元，AI策略表现优异。'}
- {(performance.profit_factor || 0) >= 1.5 && (performance.profit_factor || 0) < 2.0 && '✓ 策略稳定盈利，盈亏比健康，继续保持纪律性交易。'}
- {(performance.profit_factor || 0) >= 1.0 && (performance.profit_factor || 0) < 1.5 && '⚠️ 策略略有盈利但需优化，AI正在调整仓位和止损策略。'}
- {(performance.profit_factor || 0) > 0 && (performance.profit_factor || 0) < 1.0 && '❌ 平均亏损大于盈利，需要调整策略或降低交易频率。'}
+
@@ -376,44 +585,83 @@ export default function AILearning({ traderId }: AILearningProps) {
{(performance.best_symbol || performance.worst_symbol) && (
+
+ {(performance.profit_factor || 0) >= 2.0 &&
+ '🔥 盈利能力出色！每亏1元能赚' +
+ (performance.profit_factor || 0).toFixed(1) +
+ '元，AI策略表现优异。'}
+ {(performance.profit_factor || 0) >= 1.5 &&
+ (performance.profit_factor || 0) < 2.0 &&
+ '✓ 策略稳定盈利，盈亏比健康，继续保持纪律性交易。'}
+ {(performance.profit_factor || 0) >= 1.0 &&
+ (performance.profit_factor || 0) < 1.5 &&
+ '⚠️ 策略略有盈利但需优化，AI正在调整仓位和止损策略。'}
+ {(performance.profit_factor || 0) > 0 &&
+ (performance.profit_factor || 0) < 1.0 &&
+ '❌ 平均亏损大于盈利，需要调整策略或降低交易频率。'}
{performance.best_symbol && (
-
+
+
{performance.best_symbol}
{symbolStats[performance.best_symbol] && (
-
- {symbolStats[performance.best_symbol].total_pn_l > 0 ? '+' : ''}
- {symbolStats[performance.best_symbol].total_pn_l.toFixed(2)} USDT {t('pnl', language)}
+
)}
{performance.worst_symbol && (
-
+ {symbolStats[performance.best_symbol].total_pn_l > 0
+ ? '+'
+ : ''}
+ {symbolStats[performance.best_symbol].total_pn_l.toFixed(2)}{' '}
+ USDT {t('pnl', language)}
)}
+
-
-
+
{performance.worst_symbol}
{symbolStats[performance.worst_symbol] && (
-
- {symbolStats[performance.worst_symbol].total_pn_l > 0 ? '+' : ''}
- {symbolStats[performance.worst_symbol].total_pn_l.toFixed(2)} USDT {t('pnl', language)}
+
@@ -425,57 +673,129 @@ export default function AILearning({ traderId }: AILearningProps) {
+ {symbolStats[performance.worst_symbol].total_pn_l > 0
+ ? '+'
+ : ''}
+ {symbolStats[performance.worst_symbol].total_pn_l.toFixed(2)}{' '}
+ USDT {t('pnl', language)}
)}
{/* 左侧：币种表现统计表格 */}
{symbolStatsList.length > 0 && (
-
-
-
-
-
+
-
+
-
- Symbol
- Trades
- Win Rate
- Total P&L (USDT)
- Avg P&L (USDT)
+
+
+ Symbol
+
+
+ Trades
+
+
+ Win Rate
+
+
+ Total P&L (USDT)
+
+
+ Avg P&L (USDT)
+
{symbolStatsList.map((stat, idx) => (
- 0 ? '1px solid rgba(99, 102, 241, 0.1)' : 'none'
- }}>
+ 0
+ ? '1px solid rgba(99, 102, 241, 0.1)'
+ : 'none',
+ }}
+ >
- {stat.symbol}
+
+ {stat.symbol}
+
-
+
{stat.total_trades}
- = 50 ? '#10B981' : '#F87171'
- }}>
+ = 50 ? '#10B981' : '#F87171',
+ }}
+ >
{(stat.win_rate || 0).toFixed(1)}%
- 0 ? '#10B981' : '#F87171'
- }}>
- {(stat.total_pn_l || 0) > 0 ? '+' : ''}{(stat.total_pn_l || 0).toFixed(2)}
+ 0 ? '#10B981' : '#F87171',
+ }}
+ >
+ {(stat.total_pn_l || 0) > 0 ? '+' : ''}
+ {(stat.total_pn_l || 0).toFixed(2)}
- 0 ? '#10B981' : '#F87171'
- }}>
- {(stat.avg_pn_l || 0) > 0 ? '+' : ''}{(stat.avg_pn_l || 0).toFixed(2)}
+ 0 ? '#10B981' : '#F87171',
+ }}
+ >
+ {(stat.avg_pn_l || 0) > 0 ? '+' : ''}
+ {(stat.avg_pn_l || 0).toFixed(2)}
))}
@@ -486,164 +806,253 @@ export default function AILearning({ traderId }: AILearningProps) {
)}
{/* 右侧：历史成交记录 */}
-
-
+
+
{t('tradeHistory', language)}
+
+ {t('tradeHistory', language)}
+
- {performance?.recent_trades && performance.recent_trades.length > 0
- ? t('completedTrades', language, { count: performance.recent_trades.length })
+ {performance?.recent_trades &&
+ performance.recent_trades.length > 0
+ ? t('completedTrades', language, {
+ count: performance.recent_trades.length,
+ })
: t('completedTradesWillAppear', language)}
-
- {performance?.recent_trades && performance.recent_trades.length > 0 ? (
- performance.recent_trades.map((trade: TradeOutcome, idx: number) => {
- const isProfitable = trade.pn_l >= 0;
- const isRecent = idx === 0;
+
+ {performance?.recent_trades &&
+ performance.recent_trades.length > 0 ? (
+ performance.recent_trades.map(
+ (trade: TradeOutcome, idx: number) => {
+ const isProfitable = trade.pn_l >= 0
+ const isRecent = idx === 0
- return (
-
-
-
-
- {trade.symbol}
-
-
- {trade.side.toUpperCase()}
-
- {isRecent && (
-
- {t('latest', language)}
+ return (
+
+
+
+
+ {trade.symbol}
+
+
+ {trade.side.toUpperCase()}
+
+ {isRecent && (
+
+ {t('latest', language)}
+
+ )}
+
+
+ {isProfitable ? '+' : ''}
+ {trade.pn_l_pct.toFixed(2)}%
+
+
+
+
+
+
+ {t('entry', language)}
+
+
+ {trade.open_price.toFixed(4)}
+
+
+
+
+ {t('exit', language)}
+
+
+ {trade.close_price.toFixed(4)}
+
+
+
+
+ {/* Position Details */}
+
+
+ Quantity
+
+ {trade.quantity ? trade.quantity.toFixed(4) : '-'}
+
+
+
+ Leverage
+
+ {trade.leverage ? `${trade.leverage}x` : '-'}
+
+
+
+ Position Value
+
+ {trade.position_value
+ ? `$${trade.position_value.toFixed(2)}`
+ : '-'}
+
+
+
+ Margin Used
+
+ {trade.margin_used
+ ? `$${trade.margin_used.toFixed(2)}`
+ : '-'}
+
+
+
+
+
+
+ P&L
+
+ {isProfitable ? '+' : ''}
+ {trade.pn_l.toFixed(2)} USDT
+
+
+
+
+
+ ⏱️ {formatDuration(trade.duration)}
+ {trade.was_stop_loss && (
+
+ {t('stopLoss', language)}
)}
-
- {isProfitable ? '+' : ''}{trade.pn_l_pct.toFixed(2)}%
-
-
-
-
- {t('entry', language)}
-
- {trade.open_price.toFixed(4)}
-
-
-
- {t('exit', language)}
-
- {trade.close_price.toFixed(4)}
-
+
+ {new Date(trade.close_time).toLocaleString('en-US', {
+ month: 'short',
+ day: '2-digit',
+ hour: '2-digit',
+ minute: '2-digit',
+ })}
-
- {/* Position Details */}
-
-
- Quantity
-
- {trade.quantity ? trade.quantity.toFixed(4) : '-'}
-
-
-
- Leverage
-
- {trade.leverage ? `${trade.leverage}x` : '-'}
-
-
-
- Position Value
-
- {trade.position_value ? `$${trade.position_value.toFixed(2)}` : '-'}
-
-
-
- Margin Used
-
- {trade.margin_used ? `$${trade.margin_used.toFixed(2)}` : '-'}
-
-
-
-
-
-
- P&L
-
- {isProfitable ? '+' : ''}{trade.pn_l.toFixed(2)} USDT
-
-
-
-
-
- ⏱️ {formatDuration(trade.duration)}
- {trade.was_stop_loss && (
-
- {t('stopLoss', language)}
-
- )}
-
-
-
- {new Date(trade.close_time).toLocaleString('en-US', {
- month: 'short',
- day: '2-digit',
- hour: '2-digit',
- minute: '2-digit'
- })}
-
-
- );
- })
+ )
+ }
+ )
) : (
- {t('howAILearns', language)}
+
+ {t('howAILearns', language)}
+
•
- {t('aiLearningPoint1', language)}
+
+ {t('aiLearningPoint1', language)}
+
•
- {t('aiLearningPoint2', language)}
+
+ {t('aiLearningPoint2', language)}
+
•
- {t('aiLearningPoint3', language)}
+
+ {t('aiLearningPoint3', language)}
+
•
- {t('aiLearningPoint4', language)}
+
+ {t('aiLearningPoint4', language)}
+
- );
+ )
}
// 格式化持仓时长
function formatDuration(duration: string | undefined): string {
- if (!duration) return '-';
+ if (!duration) return '-'
- const match = duration.match(/(\d+h)?(\d+m)?(\d+\.?\d*s)?/);
- if (!match) return duration;
+ const match = duration.match(/(\d+h)?(\d+m)?(\d+\.?\d*s)?/)
+ if (!match) return duration
- const hours = match[1] || '';
- const minutes = match[2] || '';
- const seconds = match[3] || '';
+ const hours = match[1] || ''
+ const minutes = match[2] || ''
+ const seconds = match[3] || ''
- let result = '';
- if (hours) result += hours.replace('h', '小时');
- if (minutes) result += minutes.replace('m', '分');
- if (!hours && seconds) result += seconds.replace(/(\d+)\.?\d*s/, '$1秒');
+ let result = ''
+ if (hours) result += hours.replace('h', '小时')
+ if (minutes) result += minutes.replace('m', '分')
+ if (!hours && seconds) result += seconds.replace(/(\d+)\.?\d*s/, '$1秒')
- return result || duration;
+ return result || duration
}
diff --git a/web/src/components/AITradersPage.tsx b/web/src/components/AITradersPage.tsx
index 6965d8f8..b691bb2f 100644
--- a/web/src/components/AITradersPage.tsx
+++ b/web/src/components/AITradersPage.tsx
@@ -1,64 +1,83 @@
-import React, { useState, useEffect } from 'react';
-import useSWR from 'swr';
-import { api } from '../lib/api';
-import type { TraderInfo, CreateTraderRequest, AIModel, Exchange } from '../types';
-import { useLanguage } from '../contexts/LanguageContext';
-import { t, type Language } from '../i18n/translations';
-import { useAuth } from '../contexts/AuthContext';
-import { getExchangeIcon } from './ExchangeIcons';
-import { getModelIcon } from './ModelIcons';
-import { TraderConfigModal } from './TraderConfigModal';
-import { Bot, Brain, Landmark, BarChart3, Trash2, Plus, Users, AlertTriangle } from 'lucide-react';
+import React, { useState, useEffect } from 'react'
+import useSWR from 'swr'
+import { api } from '../lib/api'
+import type {
+ TraderInfo,
+ CreateTraderRequest,
+ AIModel,
+ Exchange,
+} from '../types'
+import { useLanguage } from '../contexts/LanguageContext'
+import { t, type Language } from '../i18n/translations'
+import { useAuth } from '../contexts/AuthContext'
+import { getExchangeIcon } from './ExchangeIcons'
+import { getModelIcon } from './ModelIcons'
+import { TraderConfigModal } from './TraderConfigModal'
+import {
+ Bot,
+ Brain,
+ Landmark,
+ BarChart3,
+ Trash2,
+ Plus,
+ Users,
+ AlertTriangle,
+ BookOpen,
+ HelpCircle,
+} from 'lucide-react'
// 获取友好的AI模型名称
function getModelDisplayName(modelId: string): string {
switch (modelId.toLowerCase()) {
case 'deepseek':
- return 'DeepSeek';
+ return 'DeepSeek'
case 'qwen':
- return 'Qwen';
+ return 'Qwen'
case 'claude':
- return 'Claude';
+ return 'Claude'
default:
- return modelId.toUpperCase();
+ return modelId.toUpperCase()
}
}
// 提取下划线后面的名称部分
function getShortName(fullName: string): string {
- const parts = fullName.split('_');
- return parts.length > 1 ? parts[parts.length - 1] : fullName;
+ const parts = fullName.split('_')
+ return parts.length > 1 ? parts[parts.length - 1] : fullName
}
interface AITradersPageProps {
- onTraderSelect?: (traderId: string) => void;
+ onTraderSelect?: (traderId: string) => void
}
export function AITradersPage({ onTraderSelect }: AITradersPageProps) {
- const { language } = useLanguage();
- const { user, token } = useAuth();
- const [showCreateModal, setShowCreateModal] = useState(false);
- const [showEditModal, setShowEditModal] = useState(false);
- const [showModelModal, setShowModelModal] = useState(false);
- const [showExchangeModal, setShowExchangeModal] = useState(false);
- const [showSignalSourceModal, setShowSignalSourceModal] = useState(false);
- const [editingModel, setEditingModel] = useState(null);
- const [editingExchange, setEditingExchange] = useState(null);
- const [editingTrader, setEditingTrader] = useState(null);
- const [allModels, setAllModels] = useState([]);
- const [allExchanges, setAllExchanges] = useState([]);
- const [supportedModels, setSupportedModels] = useState([]);
- const [supportedExchanges, setSupportedExchanges] = useState([]);
- const [userSignalSource, setUserSignalSource] = useState<{coinPoolUrl: string, oiTopUrl: string}>({
+ const { language } = useLanguage()
+ const { user, token } = useAuth()
+ const [showCreateModal, setShowCreateModal] = useState(false)
+ const [showEditModal, setShowEditModal] = useState(false)
+ const [showModelModal, setShowModelModal] = useState(false)
+ const [showExchangeModal, setShowExchangeModal] = useState(false)
+ const [showSignalSourceModal, setShowSignalSourceModal] = useState(false)
+ const [editingModel, setEditingModel] = useState(null)
+ const [editingExchange, setEditingExchange] = useState(null)
+ const [editingTrader, setEditingTrader] = useState(null)
+ const [allModels, setAllModels] = useState([])
+ const [allExchanges, setAllExchanges] = useState([])
+ const [supportedModels, setSupportedModels] = useState([])
+ const [supportedExchanges, setSupportedExchanges] = useState([])
+ const [userSignalSource, setUserSignalSource] = useState<{
+ coinPoolUrl: string
+ oiTopUrl: string
+ }>({
coinPoolUrl: '',
- oiTopUrl: ''
- });
+ oiTopUrl: '',
+ })
const { data: traders, mutate: mutateTraders } = useSWR(
user && token ? 'traders' : null,
api.getTraders,
{ refreshInterval: 5000 }
- );
+ )
// 加载AI模型和交易所配置
useEffect(() => {
@@ -68,133 +87,151 @@ export function AITradersPage({ onTraderSelect }: AITradersPageProps) {
try {
const [supportedModels, supportedExchanges] = await Promise.all([
api.getSupportedModels(),
- api.getSupportedExchanges()
- ]);
- setSupportedModels(supportedModels);
- setSupportedExchanges(supportedExchanges);
+ api.getSupportedExchanges(),
+ ])
+ setSupportedModels(supportedModels)
+ setSupportedExchanges(supportedExchanges)
} catch (err) {
- console.error('Failed to load supported configs:', err);
+ console.error('Failed to load supported configs:', err)
}
- return;
+ return
}
try {
- const [modelConfigs, exchangeConfigs, supportedModels, supportedExchanges] = await Promise.all([
+ const [
+ modelConfigs,
+ exchangeConfigs,
+ supportedModels,
+ supportedExchanges,
+ ] = await Promise.all([
api.getModelConfigs(),
api.getExchangeConfigs(),
api.getSupportedModels(),
- api.getSupportedExchanges()
- ]);
- setAllModels(modelConfigs);
- setAllExchanges(exchangeConfigs);
- setSupportedModels(supportedModels);
- setSupportedExchanges(supportedExchanges);
+ api.getSupportedExchanges(),
+ ])
+ setAllModels(modelConfigs)
+ setAllExchanges(exchangeConfigs)
+ setSupportedModels(supportedModels)
+ setSupportedExchanges(supportedExchanges)
// 加载用户信号源配置
try {
- const signalSource = await api.getUserSignalSource();
+ const signalSource = await api.getUserSignalSource()
setUserSignalSource({
coinPoolUrl: signalSource.coin_pool_url || '',
- oiTopUrl: signalSource.oi_top_url || ''
- });
+ oiTopUrl: signalSource.oi_top_url || '',
+ })
} catch (error) {
- console.log('📡 用户信号源配置暂未设置');
+ console.log('📡 用户信号源配置暂未设置')
}
} catch (error) {
- console.error('Failed to load configs:', error);
+ console.error('Failed to load configs:', error)
}
- };
- loadConfigs();
- }, [user, token]);
+ }
+ loadConfigs()
+ }, [user, token])
// 显示所有用户的模型和交易所配置（用于调试）
- const configuredModels = allModels || [];
- const configuredExchanges = allExchanges || [];
-
+ const configuredModels = allModels || []
+ const configuredExchanges = allExchanges || []
+
// 只在创建交易员时使用已启用且配置完整的
- const enabledModels = allModels?.filter(m => m.enabled && m.apiKey) || [];
- const enabledExchanges = allExchanges?.filter(e => {
- if (!e.enabled) return false;
+ const enabledModels = allModels?.filter((m) => m.enabled && m.apiKey) || []
+ const enabledExchanges =
+ allExchanges?.filter((e) => {
+ if (!e.enabled) return false
- // Aster 交易所需要特殊字段
- if (e.id === 'aster') {
- return e.asterUser && e.asterUser.trim() !== '' &&
- e.asterSigner && e.asterSigner.trim() !== '' &&
- e.asterPrivateKey && e.asterPrivateKey.trim() !== '';
- }
+ // Aster 交易所需要特殊字段
+ if (e.id === 'aster') {
+ return (
+ e.asterUser &&
+ e.asterUser.trim() !== '' &&
+ e.asterSigner &&
+ e.asterSigner.trim() !== '' &&
+ e.asterPrivateKey &&
+ e.asterPrivateKey.trim() !== ''
+ )
+ }
- // Hyperliquid 只需要私钥（作为apiKey）和钱包地址
- if (e.id === 'hyperliquid') {
- return e.apiKey && e.apiKey.trim() !== '' &&
- e.hyperliquidWalletAddr && e.hyperliquidWalletAddr.trim() !== '';
- }
+ // Hyperliquid 只需要私钥（作为apiKey），钱包地址会自动从私钥生成
+ if (e.id === 'hyperliquid') {
+ return e.apiKey && e.apiKey.trim() !== ''
+ }
- // Binance 等其他交易所需要 apiKey 和 secretKey
- return e.apiKey && e.apiKey.trim() !== '' && e.secretKey && e.secretKey.trim() !== '';
- }) || [];
+ // Binance 等其他交易所需要 apiKey 和 secretKey
+ return (
+ e.apiKey &&
+ e.apiKey.trim() !== '' &&
+ e.secretKey &&
+ e.secretKey.trim() !== ''
+ )
+ }) || []
// 检查模型是否正在被运行中的交易员使用
const isModelInUse = (modelId: string) => {
- return traders?.some(t => t.ai_model === modelId && t.is_running) || false;
- };
+ return traders?.some((t) => t.ai_model === modelId && t.is_running) || false
+ }
// 检查交易所是否正在被运行中的交易员使用
const isExchangeInUse = (exchangeId: string) => {
- return traders?.some(t => t.exchange_id === exchangeId && t.is_running) || false;
- };
+ return (
+ traders?.some((t) => t.exchange_id === exchangeId && t.is_running) ||
+ false
+ )
+ }
const handleCreateTrader = async (data: CreateTraderRequest) => {
try {
- const model = allModels?.find(m => m.id === data.ai_model_id);
- const exchange = allExchanges?.find(e => e.id === data.exchange_id);
+ const model = allModels?.find((m) => m.id === data.ai_model_id)
+ const exchange = allExchanges?.find((e) => e.id === data.exchange_id)
if (!model?.enabled) {
- alert(t('modelNotConfigured', language));
- return;
+ alert(t('modelNotConfigured', language))
+ return
}
if (!exchange?.enabled) {
- alert(t('exchangeNotConfigured', language));
- return;
+ alert(t('exchangeNotConfigured', language))
+ return
}
- await api.createTrader(data);
- setShowCreateModal(false);
- mutateTraders();
+ await api.createTrader(data)
+ setShowCreateModal(false)
+ mutateTraders()
} catch (error) {
- console.error('Failed to create trader:', error);
- alert(t('createTraderFailed', language));
+ console.error('Failed to create trader:', error)
+ alert(t('createTraderFailed', language))
}
- };
+ }
const handleEditTrader = async (traderId: string) => {
try {
- const traderConfig = await api.getTraderConfig(traderId);
- setEditingTrader(traderConfig);
- setShowEditModal(true);
+ const traderConfig = await api.getTraderConfig(traderId)
+ setEditingTrader(traderConfig)
+ setShowEditModal(true)
} catch (error) {
- console.error('Failed to fetch trader config:', error);
- alert(t('getTraderConfigFailed', language));
+ console.error('Failed to fetch trader config:', error)
+ alert(t('getTraderConfigFailed', language))
}
- };
+ }
const handleSaveEditTrader = async (data: CreateTraderRequest) => {
- if (!editingTrader) return;
+ if (!editingTrader) return
try {
- const model = allModels?.find(m => m.id === data.ai_model_id);
- const exchange = allExchanges?.find(e => e.id === data.exchange_id);
+ const model = enabledModels?.find((m) => m.id === data.ai_model_id)
+ const exchange = enabledExchanges?.find((e) => e.id === data.exchange_id)
if (!model) {
- alert(t('modelConfigNotExist', language));
- return;
+ alert(t('modelConfigNotExist', language))
+ return
}
if (!exchange) {
- alert(t('exchangeConfigNotExist', language));
- return;
+ alert(t('exchangeConfigNotExist', language))
+ return
}
-
+
const request = {
name: data.name,
ai_model_id: data.ai_model_id,
@@ -208,222 +245,269 @@ export function AITradersPage({ onTraderSelect }: AITradersPageProps) {
override_base_prompt: data.override_base_prompt,
is_cross_margin: data.is_cross_margin,
use_coin_pool: data.use_coin_pool,
- use_oi_top: data.use_oi_top
- };
-
- await api.updateTrader(editingTrader.trader_id, request);
- setShowEditModal(false);
- setEditingTrader(null);
- mutateTraders();
+ use_oi_top: data.use_oi_top,
+ }
+
+ await api.updateTrader(editingTrader.trader_id, request)
+ setShowEditModal(false)
+ setEditingTrader(null)
+ mutateTraders()
} catch (error) {
- console.error('Failed to update trader:', error);
- alert(t('updateTraderFailed', language));
+ console.error('Failed to update trader:', error)
+ alert(t('updateTraderFailed', language))
}
- };
+ }
const handleDeleteTrader = async (traderId: string) => {
- if (!confirm(t('confirmDeleteTrader', language))) return;
+ if (!confirm(t('confirmDeleteTrader', language))) return
try {
- await api.deleteTrader(traderId);
- mutateTraders();
+ await api.deleteTrader(traderId)
+ mutateTraders()
} catch (error) {
- console.error('Failed to delete trader:', error);
- alert(t('deleteTraderFailed', language));
+ console.error('Failed to delete trader:', error)
+ alert(t('deleteTraderFailed', language))
}
- };
+ }
const handleToggleTrader = async (traderId: string, running: boolean) => {
try {
if (running) {
- await api.stopTrader(traderId);
+ await api.stopTrader(traderId)
} else {
- await api.startTrader(traderId);
+ await api.startTrader(traderId)
}
- mutateTraders();
+ mutateTraders()
} catch (error) {
- console.error('Failed to toggle trader:', error);
- alert(t('operationFailed', language));
+ console.error('Failed to toggle trader:', error)
+ alert(t('operationFailed', language))
}
- };
+ }
const handleModelClick = (modelId: string) => {
if (!isModelInUse(modelId)) {
- setEditingModel(modelId);
- setShowModelModal(true);
+ setEditingModel(modelId)
+ setShowModelModal(true)
}
- };
+ }
const handleExchangeClick = (exchangeId: string) => {
if (!isExchangeInUse(exchangeId)) {
- setEditingExchange(exchangeId);
- setShowExchangeModal(true);
+ setEditingExchange(exchangeId)
+ setShowExchangeModal(true)
}
- };
+ }
const handleDeleteModelConfig = async (modelId: string) => {
- if (!confirm(t('confirmDeleteModel', language))) return;
+ if (!confirm(t('confirmDeleteModel', language))) return
try {
- const updatedModels = allModels?.map(m =>
- m.id === modelId ? { ...m, apiKey: '', customApiUrl: '', customModelName: '', enabled: false } : m
- ) || [];
+ const updatedModels =
+ allModels?.map((m) =>
+ m.id === modelId
+ ? {
+ ...m,
+ apiKey: '',
+ customApiUrl: '',
+ customModelName: '',
+ enabled: false,
+ }
+ : m
+ ) || []
const request = {
models: Object.fromEntries(
- updatedModels.map(model => [
+ updatedModels.map((model) => [
model.provider, // 使用 provider 而不是 id
{
enabled: model.enabled,
api_key: model.apiKey || '',
custom_api_url: model.customApiUrl || '',
- custom_model_name: model.customModelName || ''
- }
+ custom_model_name: model.customModelName || '',
+ },
])
- )
- };
+ ),
+ }
- await api.updateModelConfigs(request);
- setAllModels(updatedModels);
- setShowModelModal(false);
- setEditingModel(null);
+ await api.updateModelConfigs(request)
+ setAllModels(updatedModels)
+ setShowModelModal(false)
+ setEditingModel(null)
} catch (error) {
- console.error('Failed to delete model config:', error);
- alert(t('deleteConfigFailed', language));
+ console.error('Failed to delete model config:', error)
+ alert(t('deleteConfigFailed', language))
}
- };
+ }
- const handleSaveModelConfig = async (modelId: string, apiKey: string, customApiUrl?: string, customModelName?: string) => {
+ const handleSaveModelConfig = async (
+ modelId: string,
+ apiKey: string,
+ customApiUrl?: string,
+ customModelName?: string
+ ) => {
try {
// 创建或更新用户的模型配置
- const existingModel = allModels?.find(m => m.id === modelId);
- let updatedModels;
+ const existingModel = allModels?.find((m) => m.id === modelId)
+ let updatedModels
// 找到要配置的模型（优先从已配置列表，其次从支持列表）
- const modelToUpdate = existingModel || supportedModels?.find(m => m.id === modelId);
+ const modelToUpdate =
+ existingModel || supportedModels?.find((m) => m.id === modelId)
if (!modelToUpdate) {
- alert(t('modelNotExist', language));
- return;
+ alert(t('modelNotExist', language))
+ return
}
if (existingModel) {
// 更新现有配置
- updatedModels = allModels?.map(m =>
- m.id === modelId ? { ...m, apiKey, customApiUrl: customApiUrl || '', customModelName: customModelName || '', enabled: true } : m
- ) || [];
+ updatedModels =
+ allModels?.map((m) =>
+ m.id === modelId
+ ? {
+ ...m,
+ apiKey,
+ customApiUrl: customApiUrl || '',
+ customModelName: customModelName || '',
+ enabled: true,
+ }
+ : m
+ ) || []
} else {
// 添加新配置
- const newModel = { ...modelToUpdate, apiKey, customApiUrl: customApiUrl || '', customModelName: customModelName || '', enabled: true };
- updatedModels = [...(allModels || []), newModel];
+ const newModel = {
+ ...modelToUpdate,
+ apiKey,
+ customApiUrl: customApiUrl || '',
+ customModelName: customModelName || '',
+ enabled: true,
+ }
+ updatedModels = [...(allModels || []), newModel]
}
const request = {
models: Object.fromEntries(
- updatedModels.map(model => [
+ updatedModels.map((model) => [
model.provider, // 使用 provider 而不是 id
{
enabled: model.enabled,
api_key: model.apiKey || '',
custom_api_url: model.customApiUrl || '',
- custom_model_name: model.customModelName || ''
- }
+ custom_model_name: model.customModelName || '',
+ },
])
- )
- };
+ ),
+ }
- await api.updateModelConfigs(request);
+ await api.updateModelConfigs(request)
// 重新获取用户配置以确保数据同步
- const refreshedModels = await api.getModelConfigs();
- setAllModels(refreshedModels);
+ const refreshedModels = await api.getModelConfigs()
+ setAllModels(refreshedModels)
- setShowModelModal(false);
- setEditingModel(null);
+ setShowModelModal(false)
+ setEditingModel(null)
} catch (error) {
- console.error('Failed to save model config:', error);
- alert(t('saveConfigFailed', language));
+ console.error('Failed to save model config:', error)
+ alert(t('saveConfigFailed', language))
}
- };
+ }
const handleDeleteExchangeConfig = async (exchangeId: string) => {
- if (!confirm(t('confirmDeleteExchange', language))) return;
-
+ if (!confirm(t('confirmDeleteExchange', language))) return
+
try {
- const updatedExchanges = allExchanges?.map(e =>
- e.id === exchangeId ? { ...e, apiKey: '', secretKey: '', enabled: false } : e
- ) || [];
-
+ const updatedExchanges =
+ allExchanges?.map((e) =>
+ e.id === exchangeId
+ ? { ...e, apiKey: '', secretKey: '', enabled: false }
+ : e
+ ) || []
+
const request = {
exchanges: Object.fromEntries(
- updatedExchanges.map(exchange => [
+ updatedExchanges.map((exchange) => [
exchange.id,
{
enabled: exchange.enabled,
api_key: exchange.apiKey || '',
secret_key: exchange.secretKey || '',
- testnet: exchange.testnet || false
- }
+ testnet: exchange.testnet || false,
+ },
])
- )
- };
-
- await api.updateExchangeConfigs(request);
- setAllExchanges(updatedExchanges);
- setShowExchangeModal(false);
- setEditingExchange(null);
- } catch (error) {
- console.error('Failed to delete exchange config:', error);
- alert(t('deleteExchangeConfigFailed', language));
- }
- };
+ ),
+ }
- const handleSaveExchangeConfig = async (exchangeId: string, apiKey: string, secretKey?: string, testnet?: boolean, hyperliquidWalletAddr?: string, asterUser?: string, asterSigner?: string, asterPrivateKey?: string) => {
+ await api.updateExchangeConfigs(request)
+ setAllExchanges(updatedExchanges)
+ setShowExchangeModal(false)
+ setEditingExchange(null)
+ } catch (error) {
+ console.error('Failed to delete exchange config:', error)
+ alert(t('deleteExchangeConfigFailed', language))
+ }
+ }
+
+ const handleSaveExchangeConfig = async (
+ exchangeId: string,
+ apiKey: string,
+ secretKey?: string,
+ testnet?: boolean,
+ hyperliquidWalletAddr?: string,
+ asterUser?: string,
+ asterSigner?: string,
+ asterPrivateKey?: string
+ ) => {
try {
// 找到要配置的交易所（从supportedExchanges中）
- const exchangeToUpdate = supportedExchanges?.find(e => e.id === exchangeId);
+ const exchangeToUpdate = supportedExchanges?.find(
+ (e) => e.id === exchangeId
+ )
if (!exchangeToUpdate) {
- alert(t('exchangeNotExist', language));
- return;
+ alert(t('exchangeNotExist', language))
+ return
}
// 创建或更新用户的交易所配置
- const existingExchange = allExchanges?.find(e => e.id === exchangeId);
- let updatedExchanges;
-
+ const existingExchange = allExchanges?.find((e) => e.id === exchangeId)
+ let updatedExchanges
+
if (existingExchange) {
// 更新现有配置
- updatedExchanges = allExchanges?.map(e =>
- e.id === exchangeId ? {
- ...e,
- apiKey,
- secretKey,
- testnet,
- hyperliquidWalletAddr,
- asterUser,
- asterSigner,
- asterPrivateKey,
- enabled: true
- } : e
- ) || [];
+ updatedExchanges =
+ allExchanges?.map((e) =>
+ e.id === exchangeId
+ ? {
+ ...e,
+ apiKey,
+ secretKey,
+ testnet,
+ hyperliquidWalletAddr,
+ asterUser,
+ asterSigner,
+ asterPrivateKey,
+ enabled: true,
+ }
+ : e
+ ) || []
} else {
// 添加新配置
- const newExchange = {
- ...exchangeToUpdate,
- apiKey,
- secretKey,
- testnet,
- hyperliquidWalletAddr,
- asterUser,
- asterSigner,
- asterPrivateKey,
- enabled: true
- };
- updatedExchanges = [...(allExchanges || []), newExchange];
+ const newExchange = {
+ ...exchangeToUpdate,
+ apiKey,
+ secretKey,
+ testnet,
+ hyperliquidWalletAddr,
+ asterUser,
+ asterSigner,
+ asterPrivateKey,
+ enabled: true,
+ }
+ updatedExchanges = [...(allExchanges || []), newExchange]
}
-
+
const request = {
exchanges: Object.fromEntries(
- updatedExchanges.map(exchange => [
+ updatedExchanges.map((exchange) => [
exchange.id,
{
enabled: exchange.enabled,
@@ -433,65 +517,77 @@ export function AITradersPage({ onTraderSelect }: AITradersPageProps) {
hyperliquid_wallet_addr: exchange.hyperliquidWalletAddr || '',
aster_user: exchange.asterUser || '',
aster_signer: exchange.asterSigner || '',
- aster_private_key: exchange.asterPrivateKey || ''
- }
+ aster_private_key: exchange.asterPrivateKey || '',
+ },
])
- )
- };
-
- await api.updateExchangeConfigs(request);
-
+ ),
+ }
+
+ await api.updateExchangeConfigs(request)
+
// 重新获取用户配置以确保数据同步
- const refreshedExchanges = await api.getExchangeConfigs();
- setAllExchanges(refreshedExchanges);
-
- setShowExchangeModal(false);
- setEditingExchange(null);
+ const refreshedExchanges = await api.getExchangeConfigs()
+ setAllExchanges(refreshedExchanges)
+
+ setShowExchangeModal(false)
+ setEditingExchange(null)
} catch (error) {
- console.error('Failed to save exchange config:', error);
- alert(t('saveConfigFailed', language));
+ console.error('Failed to save exchange config:', error)
+ alert(t('saveConfigFailed', language))
}
- };
+ }
const handleAddModel = () => {
- setEditingModel(null);
- setShowModelModal(true);
- };
+ setEditingModel(null)
+ setShowModelModal(true)
+ }
const handleAddExchange = () => {
- setEditingExchange(null);
- setShowExchangeModal(true);
- };
+ setEditingExchange(null)
+ setShowExchangeModal(true)
+ }
- const handleSaveSignalSource = async (coinPoolUrl: string, oiTopUrl: string) => {
+ const handleSaveSignalSource = async (
+ coinPoolUrl: string,
+ oiTopUrl: string
+ ) => {
try {
- await api.saveUserSignalSource(coinPoolUrl, oiTopUrl);
- setUserSignalSource({ coinPoolUrl, oiTopUrl });
- setShowSignalSourceModal(false);
+ await api.saveUserSignalSource(coinPoolUrl, oiTopUrl)
+ setUserSignalSource({ coinPoolUrl, oiTopUrl })
+ setShowSignalSourceModal(false)
} catch (error) {
- console.error('Failed to save signal source:', error);
- alert(t('saveSignalSourceFailed', language));
+ console.error('Failed to save signal source:', error)
+ alert(t('saveSignalSourceFailed', language))
}
- };
+ }
return (
{/* Header */}
-
+
+
{t('aiTraders', language)}
-
+
{traders?.length || 0} {t('active', language)}
@@ -508,7 +604,7 @@ export function AITradersPage({ onTraderSelect }: AITradersPageProps) {
style={{
background: '#2B3139',
color: '#EAECEF',
- border: '1px solid #474D57'
+ border: '1px solid #474D57',
}}
>
+ {/* 信号源配置警告 */}
+ {traders &&
+ traders.some((t) => t.use_coin_pool || t.use_oi_top) &&
+ !userSignalSource.coinPoolUrl &&
+ !userSignalSource.oiTopUrl && (
+
+
+ {t('signalSourceWarningMessage', language)}
+
+
+ {t('solutions', language)}
+
+
+ - 点击"📡 {t('signalSource', language)}"按钮配置API地址
+ - 或在交易员配置中禁用"使用币种池"和"使用OI Top"
+ - 或在交易员配置中设置自定义币种列表
+
+
+
+
+
+ )}
+
{/* Configuration Status */}
{/* AI Models */}
-
-
+
- {configuredModels.map(model => {
- const inUse = isModelInUse(model.id);
+ {configuredModels.map((model) => {
+ const inUse = isModelInUse(model.id)
return (
handleModelClick(model.id)}
>
- {getModelIcon(model.provider || model.id, { width: 28, height: 28 }) || (
-
+ {getModelIcon(model.provider || model.id, {
+ width: 28,
+ height: 28,
+ }) || (
+
{getShortName(model.name)[0]}
)}
- {getShortName(model.name)}
+
+ {getShortName(model.name)}
+
- {inUse ? t('inUse', language) : model.enabled ? t('enabled', language) : t('configured', language)}
+ {inUse
+ ? t('inUse', language)
+ : model.enabled
+ ? t('enabled', language)
+ : t('configured', language)}
-
+
- );
+ )
})}
{configuredModels.length === 0 && (
-
+
-
+
- {configuredExchanges.map(exchange => {
- const inUse = isExchangeInUse(exchange.id);
+ {configuredExchanges.map((exchange) => {
+ const inUse = isExchangeInUse(exchange.id)
return (
handleExchangeClick(exchange.id)}
@@ -630,20 +820,41 @@ export function AITradersPage({ onTraderSelect }: AITradersPageProps) {
{getExchangeIcon(exchange.id, { width: 28, height: 28 })}
- {getShortName(exchange.name)}
+
+ {getShortName(exchange.name)}
+
{exchange.type.toUpperCase()} • {inUse ? t('inUse', language) : exchange.enabled ? t('enabled', language) : t('configured', language)}
+ {/* 添加地址信息 */}
+ {inUse && (exchange.hyperliquidWalletAddr || exchange.asterUser) && (
+
+ ({exchange.hyperliquidWalletAddr
+ ? `${exchange.hyperliquidWalletAddr.slice(0, 6)}...${exchange.hyperliquidWalletAddr.slice(-4)}`
+ : (exchange.asterUser ? `${exchange.asterUser.slice(0, 6)}...${exchange.asterUser.slice(-4)}` : '')
+ })
+
+ )}
-
+
- );
+ )
})}
{configuredExchanges.length === 0 && (
-
+
-
+
{traders && traders.length > 0 ? (
- {traders.map(trader => (
-
+ {traders.map((trader) => (
+
-
+
📡 {t('signalSourceConfig', language)}
-
+
+
+
-
+
+
-
| Symbol | -Trades | -Win Rate | -Total P&L (USDT) | -Avg P&L (USDT) | +||||
|---|---|---|---|---|---|---|---|---|
| + Symbol + | ++ Trades + | ++ Win Rate + | ++ Total P&L (USDT) + | ++ Avg P&L (USDT) + | ||||
| - {stat.symbol} + + {stat.symbol} + | -+ | {stat.total_trades} | -= 50 ? '#10B981' : '#F87171' - }}> + | = 50 ? '#10B981' : '#F87171', + }} + > {(stat.win_rate || 0).toFixed(1)}% | -0 ? '#10B981' : '#F87171' - }}> - {(stat.total_pn_l || 0) > 0 ? '+' : ''}{(stat.total_pn_l || 0).toFixed(2)} + | 0 ? '#10B981' : '#F87171', + }} + > + {(stat.total_pn_l || 0) > 0 ? '+' : ''} + {(stat.total_pn_l || 0).toFixed(2)} | -0 ? '#10B981' : '#F87171' - }}> - {(stat.avg_pn_l || 0) > 0 ? '+' : ''}{(stat.avg_pn_l || 0).toFixed(2)} + | 0 ? '#10B981' : '#F87171', + }} + > + {(stat.avg_pn_l || 0) > 0 ? '+' : ''} + {(stat.avg_pn_l || 0).toFixed(2)} |