'+
''+esc(x.symbol)+' #'+esc(x.id)+' · Rec '+esc(x.recommendation_id)+' | '+
''+st+' | '+
''+fmt(x.notional_usdt,0)+'U '+fmt(x.leverage,1)+'x · 保证金 '+fmt(x.margin_usdt,0)+'U | '+
'$'+fmt(x.entry_price,6)+' '+time(x.opened_at)+' | '+
'TP $'+fmt(x.tp1,6)+'SL $'+fmt(x.stop_loss,6)+' | '+
- '$'+fmt(latest,6)+' '+(x.closed_at?time(x.closed_at):'最新')+' | '+
+ '$'+fmt(latest,6)+' '+(x.latest_price_updated_at?time(x.latest_price_updated_at):'最新')+' | '+
+ ''+(x.status==='closed'?'$'+fmt(x.exit_price,6):'--')+' '+(x.status==='closed'?'实际退出':'未平仓')+' | '+
+ ''+(x.closed_at?time(x.closed_at):'--')+' | '+
''+pct(x.status==='closed'?x.realized_pnl_pct:x.pnl_pct)+' | '+
''+money(pnlUsdt)+' 账户 '+(x.account_return_pct>0?'+':'')+fmt(x.account_return_pct,2)+'% · 保证金 '+(x.margin_roi_pct>0?'+':'')+fmt(x.margin_roi_pct,2)+'% | '+
''+esc(x.exit_reason||'--')+' | '+
diff --git a/tests/test_opportunity_level.py b/tests/test_opportunity_level.py
new file mode 100644
index 0000000..c2c26c2
--- /dev/null
+++ b/tests/test_opportunity_level.py
@@ -0,0 +1,146 @@
+import json
+import os
+import sys
+
+sys.path.insert(0, os.path.dirname(os.path.dirname(__file__)))
+
+from app.core.opportunity_level import (
+ attach_opportunity_level,
+ classify_opportunity_level,
+ level_tp_parameters,
+ select_level_stop_loss,
+)
+from app.core.opportunity_lifecycle import apply_entry_quality_gate
+from app.db.altcoin_db import create_recommendation, get_conn, init_db
+
+
+def test_intraday_breakout_requires_current_low_timeframe_trigger():
+ meta = classify_opportunity_level(
+ signals=["1H 量价齐飞K(量3.2x)", "🟢 15min即刻入场信号"],
+ entry_plan={"entry_action": "即刻买入"},
+ m30_aligned=True,
+ )
+
+ assert meta["opportunity_level"] == "intraday_breakout"
+ assert meta["label"] == "日内启动"
+ assert meta["max_action"] == "buy_now"
+
+
+def test_short_swing_uses_mid_timeframe_confirmation():
+ meta = classify_opportunity_level(
+ signals=["1H 量价齐飞K(量3.0x)", "30min 4阳动K(与1H共振)", "4H需求区反弹"],
+ entry_plan={"entry_action": "等回踩"},
+ m30_aligned=True,
+ )
+
+ assert meta["opportunity_level"] == "short_swing"
+ assert meta["holding_horizon"] == "1-3天"
+
+
+def test_higher_timeframe_background_stays_structure_watch():
+ meta = classify_opportunity_level(
+ signals=["日线 底部缩量(0.6x)", "日线 晨星反转", "1H历史放量阳线已过期(10小时前)"],
+ entry_plan={"entry_action": "等回踩"},
+ )
+
+ assert meta["opportunity_level"] == "structure_watch"
+ assert meta["max_action"] == "wait_pullback"
+
+
+def test_theme_without_price_trigger_is_research_trend():
+ meta = classify_opportunity_level(
+ signals=["生态主题扩散", "舆情催化"],
+ entry_plan={"entry_action": "观察"},
+ sector_context={"hot_sectors": ["AI"]},
+ )
+
+ assert meta["opportunity_level"] == "theme_trend"
+ assert meta["max_action"] == "observe"
+
+
+def test_level_stop_and_tp_models_are_different():
+ stops = [90, 94, 96]
+ intraday_stop, _ = select_level_stop_loss(level="intraday_breakout", price=100, entry_price=100, stop_candidates=stops)
+ structure_stop, _ = select_level_stop_loss(level="structure_watch", price=100, entry_price=100, stop_candidates=stops)
+
+ assert intraday_stop == 96
+ assert structure_stop == 90
+ assert level_tp_parameters("intraday_breakout")["tp1_floor"] < level_tp_parameters("structure_watch")["tp1_floor"]
+
+
+def test_quality_gate_caps_structure_watch_without_current_trigger():
+ meta = classify_opportunity_level(
+ signals=["日线 需求区反弹", "4H静K蓄力观察(4静K)"],
+ entry_plan={"entry_action": "即刻买入"},
+ )
+ plan = attach_opportunity_level(
+ {
+ "entry_action": "即刻买入",
+ "entry_price": 1.0,
+ "stop_loss": 0.92,
+ "tp1": 1.16,
+ "risk_reward_ok": True,
+ "rr1": 2.0,
+ },
+ meta,
+ )
+
+ action, gated_plan, reasons = apply_entry_quality_gate(
+ action_status="可即刻买入",
+ entry_plan=plan,
+ signals=["日线 需求区反弹", "4H静K蓄力观察(4静K)"],
+ current_price=1.0,
+ market_context={"change_24h": 2.0},
+ )
+
+ assert action != "可即刻买入"
+ assert gated_plan["opportunity_level"] == "structure_watch"
+ assert any("结构观察" in reason for reason in reasons)
+
+
+def test_create_recommendation_persists_opportunity_level_fields():
+ init_db()
+ plan = attach_opportunity_level(
+ {
+ "entry_action": "即刻买入",
+ "entry_price": 1.0,
+ "stop_loss": 0.95,
+ "tp1": 1.08,
+ "tp2": 1.12,
+ "risk_reward_ok": True,
+ "rr1": 1.6,
+ "entry_trigger_confirmed": True,
+ },
+ classify_opportunity_level(
+ signals=["1H 量价齐飞K(量3.2x)", "🟢 15min即刻入场信号"],
+ entry_plan={"entry_action": "即刻买入"},
+ m30_aligned=True,
+ ),
+ )
+
+ rec_id = create_recommendation(
+ symbol="TEST/USDT",
+ rec_state="爆发",
+ rec_score=18,
+ entry_price=plan["entry_price"],
+ stop_loss=plan["stop_loss"],
+ tp1=plan["tp1"],
+ tp2=plan["tp2"],
+ signals=["1H 量价齐飞K(量3.2x)", "🟢 15min即刻入场信号"],
+ entry_plan=plan,
+ )
+
+ conn = get_conn()
+ try:
+ row = conn.execute(
+ "SELECT opportunity_level, opportunity_level_label, holding_horizon, entry_plan_json FROM recommendation WHERE id=%s",
+ (rec_id,),
+ ).fetchone()
+ finally:
+ conn.close()
+
+ stored_plan = json.loads(row["entry_plan_json"])
+ assert row["opportunity_level"] == "intraday_breakout"
+ assert row["opportunity_level_label"] == "日内启动"
+ assert row["holding_horizon"] == "数小时-1天"
+ assert stored_plan["entry_model"] == "15m触发 / 1H突破延续"
diff --git a/tests/test_paper_trading.py b/tests/test_paper_trading.py
index f8dcedd..3508b3c 100644
--- a/tests/test_paper_trading.py
+++ b/tests/test_paper_trading.py
@@ -81,6 +81,10 @@ def test_default_paper_trade_uses_5000u_notional_5x_and_1000u_margin(monkeypatch
assert trade["leverage"] == pytest.approx(5.0)
assert trade["margin_usdt"] == pytest.approx(1000.0)
assert summary["account_equity_usdt"] == pytest.approx(20000.0)
+ assert summary["initial_equity_usdt"] == pytest.approx(20000.0)
+ assert summary["current_balance_usdt"] == pytest.approx(20000.0)
+ assert summary["open_position_value_usdt"] == pytest.approx(5000.0)
+ assert summary["cumulative_leverage"] == pytest.approx(0.25)
assert summary["notional_usdt"] == pytest.approx(5000.0)
assert summary["margin_usdt"] == pytest.approx(1000.0)
@@ -134,6 +138,20 @@ def test_open_paper_trade_closes_on_tp1_and_summary_counts_win(buy_now_rec):
assert summary["win_rate"] == pytest.approx(100.0)
+def test_closed_paper_trade_keeps_exit_price_and_shows_latest_market_price(buy_now_rec):
+ sync_recommendation(buy_now_rec, 100, event_time="2026-05-16T10:00:00")
+ sync_recommendation(buy_now_rec, 106, event_time="2026-05-16T10:05:00")
+ altcoin_db.update_latest_price_cache("PAPER/USDT", 103.25, updated_at="2026-05-16T10:10:00", source="unit")
+
+ trade = list_paper_trades()["items"][0]
+
+ assert trade["status"] == "closed"
+ assert trade["exit_price"] == pytest.approx(106.0)
+ assert trade["current_price"] == pytest.approx(106.0)
+ assert trade["latest_price"] == pytest.approx(103.25)
+ assert trade["latest_price_updated_at"] == "2026-05-16T10:10:00"
+
+
def test_disabled_paper_trading_skips_without_writing(monkeypatch, buy_now_rec):
monkeypatch.setenv("ALPHAX_PAPER_TRADING_ENABLED", "0")
diff --git a/tests/test_screener_optimizations.py b/tests/test_screener_optimizations.py
index da9df1e..41cd670 100644
--- a/tests/test_screener_optimizations.py
+++ b/tests/test_screener_optimizations.py
@@ -16,6 +16,8 @@ def test_fetch_all_tickers_filters_stable_and_fiat_suffixes(monkeypatch):
"fetch_tickers",
lambda: {
"BTC/USDT": {"last": 1, "percentage": 1, "quoteVolume": 100},
+ "ETH/USDT": {"last": 2, "percentage": 2, "quoteVolume": 200},
+ "BNB/USDT": {"last": 3, "percentage": 3, "quoteVolume": 300},
"RLUSD/USDT": {"last": 1, "percentage": 0.1, "quoteVolume": 100},
"BFUSD/USDT": {"last": 1, "percentage": 0.1, "quoteVolume": 100},
"EUR/USDT": {"last": 1, "percentage": 0.1, "quoteVolume": 100},
@@ -36,6 +38,9 @@ def test_fetch_all_tickers_filters_stable_and_fiat_suffixes(monkeypatch):
pairs = altcoin_screener.fetch_all_tickers()
assert "AI/USDT" in pairs
+ assert "BTC/USDT" in pairs
+ assert "ETH/USDT" in pairs
+ assert "BNB/USDT" in pairs
assert "RLUSD/USDT" not in pairs
assert "BFUSD/USDT" not in pairs
assert "EUR/USDT" not in pairs
@@ -49,7 +54,6 @@ def test_fetch_all_tickers_filters_stable_and_fiat_suffixes(monkeypatch):
assert "USDD/USDT" not in pairs
assert "EURS/USDT" not in pairs
assert "AUD/USDT" not in pairs
- assert "BTC/USDT" not in pairs
def _mock_weights():