'+items.map(function(x){return '<
function rows(items,label,value,sub){items=items||[];if(!items.length)return '
暂无数据
';return '
'+items.map(function(x){return '
'+esc(label(x))+'
'+esc(sub?sub(x):'')+'
'+esc(value?value(x):'')+'
'}).join('')+'
'}
function digestItems(items,label,sub){items=items||[];if(!items.length)return '
暂无动作
';return items.slice(0,4).map(function(x){return '
'+esc(label(x))+''+esc(sub?sub(x):'')+'
'}).join('')}
function renderStrategyDigest(d){var it=d.iteration||{},dig=it.digest||{},latest=dig.latest||{},m=latest.metrics||{},decision=latest.decision||'hold';var badgeCls=decision==='release'?'ok':decision==='gray'?'warn':'warn';$('strategyDigest').innerHTML='
策略迭代摘要
'+esc(latest.title||'暂无复盘')+' · '+time(latest.time)+' · 版本 '+esc(latest.strategy_version||'--')+'
'+[['因子生效调整',m.factor_weight_updates||0,'blue'],['候选 / 灰度',(it.summary&&it.summary.candidate_count||0)+' / '+(it.summary&&it.summary.gray_count||0),''],['本轮有效复盘',m.effective_review_count||0,''],['发布状态',latest.reason||'继续观察','']].map(function(x){return '
'+esc(x[0])+''+esc(x[1])+'
'}).join('')+'
升权了什么
'+digestItems(dig.upgraded,function(x){return x.signal||'--'},function(x){return '权重 '+x.old_weight+' → '+x.new_weight+' · 样本 '+(x.sample_size||0)+' · 命中 '+(x.hit_rate||0)+'%'})+'降权 / 淘汰
'+digestItems(dig.downgraded,function(x){return x.signal||'--'},function(x){return (x.action||'调整')+' · '+(x.old_weight!=null?'权重 '+x.old_weight+' → '+x.new_weight:x.detail||'')})+'灰度观察
'+digestItems(dig.gray,function(x){return x.signal||('候选 #'+x.id)},function(x){return '样本 '+(x.sample_size||0)+' · 置信 '+(x.confidence||0)+'% · '+(x.description||'')})+'最近迭代
'+digestItems(dig.timeline,function(x){return time(x.time)+' · '+(x.decision||'hold')},function(x){return x.reason||x.title||''})+''}
+function decisionCls(d){return ({promote:'promote',pause:'pause',gray:'gray',tune_entry:'tune_entry',review_entry_gate:'review_entry_gate'}[d]||'')}
+function renderStrategyBoard(d){var se=d.strategy_evaluation||{},s=se.summary||{},items=se.strategies||[];var cards=items.slice(0,6).map(function(x){var score=Math.max(0,Math.min(100,Number(x.evaluation_score||0)));return '
'+esc(x.strategy_name||x.strategy_code)+'
'+esc(x.description||'暂无策略说明')+'
'+score.toFixed(0)+'
信号'+esc(x.signal_count||0)+'
机会'+esc(x.opportunity_count||0)+'
平仓'+esc(x.closed_trade_count||0)+'
胜率'+num(x.win_rate_pct,1)+'%
收益'+usd(x.realized_pnl_usdt)+'
均值'+pct(x.avg_realized_pnl_pct)+'
成交'+num(x.order_fill_rate_pct,1)+'%
转化'+num(x.trade_conversion_pct,1)+'%
'+esc(x.decision_label||x.decision)+' '+esc((x.reasons||[])[0]||'继续观察')+'
'+esc((x.next_actions||[])[0]||'等待更多样本')+'
'}).join('')||'
暂无策略评价数据
';$('strategyBoard').innerHTML='
多策略优胜劣汰
'+esc(se.definition||'按策略独立评价发现、执行、收益和风险。')+'
'+cards+'
'}
function renderOpportunity(o){var s=o.summary||{};$('oppDef').textContent=o.definition||'';$('opportunityPanel').innerHTML=kpis([['机会样本',s.total_opportunities||0,'blue'],['可买/等回踩',(s.buy_now_count||0)+' / '+(s.wait_pullback_count||0),''],['策略执行',s.paper_executed_count||0,'green'],['漏选爆发',s.missed_explosion_count||0,'red'],['有效复盘',s.effective_review_count||0,''],['机会命中',num(s.opportunity_hit_rate,1)+'%','green'],['观察样本',s.observe_count||0,''],['失效样本',s.invalid_count||0,'red']])+'
状态分布
'+rows(o.status_distribution,function(x){return x.name||'--'},function(x){return x.count})+'
复盘结果
'+rows(o.outcome_distribution,function(x){return x.name||'--'},function(x){return x.count})+'
'}
function renderPaper(p){var s=p.summary||{},ta=p.trade_attribution||{},wo=p.watch_order_attribution||{},tf=ta.factor||[],te=ta.entry_path||[],tg=ta.factor_group||[],ts=ta.strategy_code||[],wr=wo.watch_pool||[],orows=wo.paper_orders||[];$('paperDef').textContent=p.definition||'';$('paperPanel').innerHTML=kpis([['当前余额','$'+num(s.current_balance_usdt,2),'blue'],['总收益',usd(s.total_pnl_usdt),Number(s.total_pnl_usdt||0)>=0?'green':'red'],['账户收益率',pct(s.account_total_return_pct),Number(s.account_total_return_pct||0)>=0?'green':'red'],['胜率',num(s.win_rate,1)+'%',''],['开仓/平仓',(s.open_count||0)+' / '+(s.closed_count||0),''],['已实现',usd(s.realized_pnl_usdt),Number(s.realized_pnl_usdt||0)>=0?'green':'red'],['未实现',usd(s.open_unrealized_pnl_usdt),Number(s.open_unrealized_pnl_usdt||0)>=0?'green':'red'],['累计杠杆',num(s.cumulative_leverage,2)+'x','']])+'
策略表现
'+rows(ts.slice(0,8),function(x){return x.strategy_name||x.strategy_code||'--'},function(x){return usd(x.realized_pnl_usdt)},function(x){return '平仓 '+(x.closed_trade_count||0)+' · 胜率 '+num(x.win_rate_pct,1)+'% · 均值 '+pct(x.avg_realized_pnl_pct)})+'
退出原因
'+rows(p.exit_reasons,function(x){return x.name||'--'},function(x){return x.count})+'
执行事件
'+rows(p.event_types,function(x){return x.name||'--'},function(x){return x.count})+'
真实交易因子
'+rows(tf.slice(0,6),function(x){return x.factor||'--'},function(x){return usd(x.realized_pnl_usdt)},function(x){return '平仓 '+(x.closed_trade_count||0)+' · 胜率 '+num(x.win_rate_pct,1)+'% · 均值 '+pct(x.avg_realized_pnl_pct)})+'
因子组表现
'+rows(tg.slice(0,6),function(x){return x.factor_group||'--'},function(x){return usd(x.realized_pnl_usdt)},function(x){return '平仓 '+(x.closed_trade_count||0)+' · 胜率 '+num(x.win_rate_pct,1)+'%'})+'
入场路径表现
'+rows(te.slice(0,6),function(x){return x.entry_path||'--'},function(x){return usd(x.realized_pnl_usdt)},function(x){return '平仓 '+(x.closed_trade_count||0)+' · 胜率 '+num(x.win_rate_pct,1)+'%'})+'
观察/挂单推进
'+rows(wr.concat(orows).slice(0,6),function(x){return x.watch_bucket||x.order_bucket||'--'},function(x){return (x.executed_pct!=null?num(x.executed_pct,1):num(x.fill_pct,1))+'%'},function(x){return '样本 '+(x.opportunity_count||x.order_count||0)+' · 执行/成交 '+(x.executed_count||x.filled_count||0)})+'
'}
function renderEvidence(e){var s=e.summary||{};$('evidenceDef').textContent=e.definition||'';$('evidencePanel').innerHTML=kpis([['新闻事件',s.news_count||0,'blue'],['有效舆情',s.actionable_news_count||0,''],['链上信号',s.onchain_signal_count||0,'blue'],['高置信链上',s.high_confidence_onchain_count||0,'green'],['原始链上',s.raw_onchain_count||0,''],['已映射原始',s.mapped_raw_onchain_count||0,'green'],['LLM 调用',s.llm_runs||0,''],['LLM 成功',s.llm_success_count||0,'green']])+'
链上信号
'+rows(e.onchain_signals,function(x){return x.name||'--'},function(x){return x.count})+'
舆情决策
'+rows(e.news_decisions,function(x){return x.name||'未处理'},function(x){return x.count})+'
'}
function renderIteration(i){var s=i.summary||{};$('iterationDef').textContent=i.definition||'';$('iterationPanel').innerHTML=kpis([['迭代记录',s.iteration_count||0,'blue'],['候选规则',s.candidate_count||0,''],['灰度规则',s.gray_count||0,'green'],['生效规则',s.active_count||0,'green']])+'
最新发布结论：'+esc(s.latest_release_decision||'hold')+'
'+esc(s.latest_release_reason||'暂无发布说明')+'
闸门
发布决策
'+rows(i.release_decisions,function(x){return x.name||'--'},function(x){return x.count})+'
候选状态
'+rows(i.candidate_status,function(x){return x.name||'--'},function(x){return x.count})+'
'}
function renderRecent(d){var opp=(d.opportunity&&d.opportunity.missed_explosions)||[], trades=(d.paper_trading&&d.paper_trading.recent_trades)||[], news=(d.evidence&&d.evidence.recent_news)||[], chain=(d.evidence&&d.evidence.recent_onchain)||[];$('recentPanel').innerHTML='
最近策略交易
'+rows(trades.slice(0,8),function(x){return (x.symbol||'--')+' · '+(x.status||'--')},function(x){return x.status==='closed'?pct(x.realized_pnl_pct):pct(x.pnl_pct)},function(x){return time(x.opened_at)+' · '+(x.exit_reason||x.source_status||'')})+'
漏选爆发
'+rows(opp.slice(0,8),function(x){return x.symbol||'--'},function(x){return pct(x.gain_pct)},function(x){return time(x.detect_time)+' · '+(x.reason_missed||'')})+'
舆情事件
'+rows(news.slice(0,8),function(x){return (x.symbol||'--')+' · '+(x.title||'--')},function(x){return x.importance||'--'},function(x){return time(x.detected_at)+' · '+(x.source||'')+' · '+(x.decision||'未处理')})+'
链上信号
'+rows(chain.slice(0,8),function(x){return (x.symbol||'--')+' · '+(x.signal_label||x.signal_code||'--')},function(x){return x.severity||x.confidence||'--'},function(x){return time(x.detected_at)+' · '+(x.source||'')+' · '+(x.direction||'')})+'
'}
-function render(d){renderStrategyDigest(d);$('principles').innerHTML=(d.principles||[]).map(function(x){return '
'+esc(x)+'
'}).join('');renderOpportunity(d.opportunity||{});renderPaper(d.paper_trading||{});renderEvidence(d.evidence||{});renderIteration(d.iteration||{});renderRecent(d)}
-async function loadAll(){try{var days=$('daysSel').value;var d=await (await fetch(API+'/api/review-center/dashboard?days='+days+'&_ts='+Date.now(),{cache:'no-store'})).json();render(d)}catch(e){['strategyDigest','principles','opportunityPanel','paperPanel','evidencePanel','iterationPanel','recentPanel'].forEach(function(id){$(id).innerHTML='
加载失败
'})}}
+function render(d){renderStrategyDigest(d);renderStrategyBoard(d);$('principles').innerHTML=(d.principles||[]).map(function(x){return '
'+esc(x)+'
'}).join('');renderOpportunity(d.opportunity||{});renderPaper(d.paper_trading||{});renderEvidence(d.evidence||{});renderIteration(d.iteration||{});renderRecent(d)}
+async function loadAll(){try{var days=$('daysSel').value;var d=await (await fetch(API+'/api/review-center/dashboard?days='+days+'&_ts='+Date.now(),{cache:'no-store'})).json();render(d)}catch(e){['strategyDigest','strategyBoard','principles','opportunityPanel','paperPanel','evidencePanel','iterationPanel','recentPanel'].forEach(function(id){$(id).innerHTML='
加载失败
'})}}
loadAll();
{% endblock %}
diff --git a/tests/test_llm_insights.py b/tests/test_llm_insights.py
index 49580a3..6376fdb 100644
--- a/tests/test_llm_insights.py
+++ b/tests/test_llm_insights.py
@@ -79,7 +79,7 @@ def _fetch_llm_row(db_path):
return dict(row) if row else None
-def test_disabled_llm_skips_and_does_not_change_mainline(monkeypatch, temp_db):
+def test_disabled_llm_skips_and_does_not_change_strategy_state(monkeypatch, temp_db):
_insert_recommendation(temp_db)
monkeypatch.setattr(llm_insights, "get_llm_module_enabled", lambda module: False)
result = llm_insights.run(scope="recommendations", limit=10)
diff --git a/tests/test_multi_strategy_infra.py b/tests/test_multi_strategy_infra.py
index 209ab0c..3d7e558 100644
--- a/tests/test_multi_strategy_infra.py
+++ b/tests/test_multi_strategy_infra.py
@@ -1,9 +1,23 @@
from app.core.factor_roles import RISK, TRIGGER, factor_role, factor_roles_for_codes
from app.core.strategy_contract import StrategySignal, default_main_composite_signal
-from app.core.strategy_registry import BOX_RETEST_1H_STRATEGY, BOX_RETEST_4H_STRATEGY, MAIN_COMPOSITE_STRATEGY, strategy_label
+from app.core.strategy_registry import (
+ BOX_RETEST_1H_STRATEGY,
+ BOX_RETEST_4H_STRATEGY,
+ COMPRESSION_BREAKOUT_4H_STRATEGY,
+ INTRADAY_MOMENTUM_15M_STRATEGY,
+ MAIN_COMPOSITE_STRATEGY,
+ VOLUME_IGNITION_1H_STRATEGY,
+ strategy_label,
+)
from app.db.recommendation_commands import create_recommendation
-from app.db.strategy_signal_queries import insert_strategy_signal
from app.db.paper_trading import _open_trade, _order_payload_from_rec
+from app.db.strategy_signal_queries import insert_strategy_signal
+from app.db.strategy_insights import evaluate_strategy_decision
+from app.strategies.altcoin_breakout import (
+ build_compression_breakout_4h_signal,
+ build_intraday_momentum_15m_signal,
+ build_volume_ignition_1h_signal,
+)
from app.strategies.box_retest_4h import build_box_retest_1h_signal
@@ -27,9 +41,109 @@ def test_default_main_composite_strategy_signal_is_stable():
).to_json_dict()
assert signal["strategy_code"] == MAIN_COMPOSITE_STRATEGY
- assert signal["strategy_name"] == "综合确认主链路"
+ assert signal["strategy_name"] == "综合确认策略"
assert signal["factor_roles"]["vp_fly_1h_current"] == "trigger"
assert strategy_label(BOX_RETEST_1H_STRATEGY) == "1H箱体突破回踩"
+ assert strategy_label(VOLUME_IGNITION_1H_STRATEGY) == "1H放量突破启动"
+ assert strategy_label(COMPRESSION_BREAKOUT_4H_STRATEGY) == "4H压缩蓄力突破"
+ assert strategy_label(INTRADAY_MOMENTUM_15M_STRATEGY) == "15m日内动量延续"
+
+
+def test_volume_ignition_strategy_builds_independent_signal():
+ signal = build_volume_ignition_1h_signal(
+ symbol="VOL/USDT",
+ result={
+ "score": 8,
+ "signals": ["1H量价齐飞 · 连续放量", "15min即刻入场"],
+ "trigger_context": {"current_triggers": ["15m突破"], "trigger_status": "current"},
+ "entry_plan": {"entry_action": "可即刻买入"},
+ },
+ entry_plan={"entry_action": "可即刻买入", "entry_price": 1.0},
+ )
+ payload = signal.to_json_dict()
+
+ assert payload["strategy_code"] == VOLUME_IGNITION_1H_STRATEGY
+ assert payload["status"] == "candidate"
+ assert payload["trigger"]["factor_code"] == "vp_fly_1h_current"
+ assert payload["factor_roles"]["vp_fly_1h_current"] == "trigger"
+
+
+def test_compression_breakout_strategy_requires_structure_and_breakout_context():
+ signal = build_compression_breakout_4h_signal(
+ symbol="QUIET/USDT",
+ result={"score": 6, "signals": ["4H静K压缩，突破箱体上沿"], "entry_plan": {"entry_action": "等回踩"}},
+ entry_plan={"entry_action": "等回踩", "entry_price": 1.0},
+ )
+ payload = signal.to_json_dict()
+
+ assert payload["strategy_code"] == COMPRESSION_BREAKOUT_4H_STRATEGY
+ assert payload["status"] == "candidate"
+ assert payload["factor_roles"]["compression_surge_4h"] == "trigger"
+ assert build_compression_breakout_4h_signal(
+ symbol="NOBOX/USDT",
+ result={"score": 6, "signals": ["1H量价齐飞"], "entry_plan": {"entry_action": "可即刻买入"}},
+ entry_plan={"entry_action": "可即刻买入"},
+ ) is None
+
+
+def test_intraday_momentum_strategy_requires_current_trigger():
+ stale = build_intraday_momentum_15m_signal(
+ symbol="FAST/USDT",
+ result={"score": 7, "signals": ["15m短周期启动"], "entry_plan": {"entry_action": "可即刻买入"}},
+ entry_plan={"entry_action": "可即刻买入"},
+ ).to_json_dict()
+ fresh = build_intraday_momentum_15m_signal(
+ symbol="FAST/USDT",
+ result={
+ "score": 7,
+ "signals": ["15min强突破"],
+ "trigger_context": {"current_triggers": ["15m突破"], "trigger_status": "current"},
+ "entry_plan": {"entry_action": "可即刻买入"},
+ },
+ entry_plan={"entry_action": "可即刻买入"},
+ ).to_json_dict()
+
+ assert stale["status"] == "observe"
+ assert "缺少当前低周期触发" in stale["risk_plan"]["risk_reasons"]
+ assert fresh["status"] == "candidate"
+
+
+def test_strategy_evaluation_recommends_promote_or_pause():
+ strong = evaluate_strategy_decision({
+ "signal_count": 24,
+ "opportunity_count": 16,
+ "trade_count": 8,
+ "closed_trade_count": 8,
+ "win_rate_pct": 62.5,
+ "avg_realized_pnl_pct": 3.2,
+ "realized_pnl_usdt": 180,
+ "worst_pnl_pct": -3.5,
+ "order_fill_rate_pct": 45,
+ "trade_conversion_pct": 50,
+ })
+ weak = evaluate_strategy_decision({
+ "signal_count": 24,
+ "opportunity_count": 16,
+ "trade_count": 8,
+ "closed_trade_count": 8,
+ "win_rate_pct": 25,
+ "avg_realized_pnl_pct": -2.5,
+ "realized_pnl_usdt": -120,
+ "worst_pnl_pct": -9,
+ "order_fill_rate_pct": 20,
+ "trade_conversion_pct": 50,
+ })
+ unfilled = evaluate_strategy_decision({
+ "signal_count": 18,
+ "opportunity_count": 12,
+ "trade_count": 0,
+ "closed_trade_count": 0,
+ })
+
+ assert strong["decision"] == "promote"
+ assert strong["evaluation_score"] > weak["evaluation_score"]
+ assert weak["decision"] == "pause"
+ assert unfilled["decision"] == "review_entry_gate"
def test_strategy_signal_insert_and_recommendation_lineage(pg_conn):