diff --git a/src/ashare_dp/apps/api/app.py b/src/ashare_dp/apps/api/app.py
index 7fb491e..eecba2c 100644
--- a/src/ashare_dp/apps/api/app.py
+++ b/src/ashare_dp/apps/api/app.py
@@ -11,8 +11,10 @@ from fastapi.responses import HTMLResponse
from loguru import logger
from ashare_dp.apps.api.routers import stocks, kline, realtime, calendar
+from ashare_dp.apps.api.routers.wyckoff import router as wyckoff_router
from ashare_dp.apps.api.dashboard.router import router as dashboard_router
from ashare_dp.apps.api.dashboard.html import DASHBOARD_HTML
+from ashare_dp.apps.api.wyckoff.html import WYCKOFF_HTML
from ashare_dp.core.models import Freq
from ashare_dp.data.store.repository import KLineRepository
from ashare_dp.apps.api.websocket.handlers import router as ws_router
@@ -572,6 +574,11 @@ def create_app() -> FastAPI:
"""Trading OS Dashboard — professional trader decision support."""
return DASHBOARD_HTML
+ @app.get("/wyckoff", response_class=HTMLResponse)
+ async def wyckoff_page():
+ """Wyckoff Screener — multi-timeframe stock discovery."""
+ return WYCKOFF_HTML
+
@app.get("/api/v1/screening/ema52")
async def api_ema52_screening(
freq: str = Query("1d", description="Frequency: 1d or 1w"),
@@ -617,6 +624,7 @@ def create_app() -> FastAPI:
app.include_router(realtime.router, prefix="/api/v1")
app.include_router(calendar.router, prefix="/api/v1")
app.include_router(dashboard_router, prefix="/api/v1")
+ app.include_router(wyckoff_router, prefix="/api/v1")
app.include_router(ws_router)
return app
diff --git a/src/ashare_dp/apps/api/routers/wyckoff.py b/src/ashare_dp/apps/api/routers/wyckoff.py
new file mode 100644
index 0000000..5e57c3f
--- /dev/null
+++ b/src/ashare_dp/apps/api/routers/wyckoff.py
@@ -0,0 +1,170 @@
+"""Wyckoff Screener REST API."""
+
+from __future__ import annotations
+
+from datetime import date
+
+from fastapi import APIRouter, HTTPException, Query
+
+from ashare_dp.domain.wyckoff import DecisionSignal, WyckoffCycle, WyckoffEvent, WyckoffPhase
+from ashare_dp.wyckoff import store as wyckoff_store
+from ashare_dp.wyckoff.annotate import annotate_symbol
+from ashare_dp.wyckoff.version import ARCHITECTURE_VERSION, WYCKOFF_ENGINE_VERSION
+
+router = APIRouter(prefix="/wyckoff", tags=["wyckoff"])
+
+
+@router.get("/meta")
+async def wyckoff_meta():
+ latest = wyckoff_store.latest_trade_date()
+ count = wyckoff_store.count_for_date(latest) if latest else 0
+ dist = wyckoff_store.facet_counts(latest) if latest else {}
+ return {
+ "architecture_version": ARCHITECTURE_VERSION,
+ "engine_version": WYCKOFF_ENGINE_VERSION,
+ "latest_trade_date": latest.isoformat() if latest else None,
+ "scan_count": count,
+ "cycles": [c.value for c in WyckoffCycle],
+ "phases": [p.value for p in WyckoffPhase],
+ "events": [e.value for e in WyckoffEvent],
+ "decision_signals": [s.value for s in DecisionSignal],
+ "facets": dist,
+ "sort_fields": [
+ "overall_score", "alignment", "entry_score", "trend_score", "structure_score",
+ ],
+ }
+
+
+@router.get("/scan")
+async def wyckoff_scan(
+ trade_date: str | None = Query(None),
+ m_cycle: str | None = Query(None),
+ w_phase: str | None = Query(None),
+ d_event: str | None = Query(None),
+ decision_signal: str | None = Query(None),
+ industry: str | None = Query(None),
+ min_overall_score: float | None = Query(None),
+ min_alignment: float | None = Query(None),
+ engine_version: str | None = Query(None),
+ sort: str = Query("overall_score"),
+ limit: int = Query(100, ge=1, le=500),
+ offset: int = Query(0, ge=0),
+):
+ td = date.fromisoformat(trade_date) if trade_date else None
+ rows = wyckoff_store.query_scan(
+ trade_date=td,
+ m_cycle=m_cycle,
+ w_phase=w_phase,
+ d_event=d_event,
+ decision_signal=decision_signal,
+ industry=industry,
+ min_overall_score=min_overall_score,
+ min_alignment=min_alignment,
+ engine_version=engine_version,
+ sort=sort,
+ limit=limit,
+ offset=offset,
+ )
+ # list projection
+ items = []
+ for r in rows:
+ items.append({
+ "ts_code": r["ts_code"],
+ "name": r.get("name"),
+ "industry": r.get("industry"),
+ "m_cycle": r.get("m_cycle"),
+ "w_cycle": r.get("w_cycle"),
+ "w_phase": r.get("w_phase"),
+ "w_current_event": r.get("w_current_event"),
+ "d_current_event": r.get("d_current_event"),
+ "alignment": r.get("alignment"),
+ "stars": r.get("stars"),
+ "decision_signal": r.get("decision_signal"),
+ "overall_score": r.get("overall_score"),
+ "trend_score": r.get("trend_score"),
+ "structure_score": r.get("structure_score"),
+ "entry_score": r.get("entry_score"),
+ "risk": r.get("risk"),
+ "engine_version": r.get("engine_version"),
+ "trade_date": str(r.get("trade_date"))[:10],
+ })
+ return {
+ "trade_date": str(rows[0]["trade_date"])[:10] if rows else (trade_date or None),
+ "count": len(items),
+ "items": items,
+ }
+
+
+@router.get("/scan/{ts_code}/overlay")
+async def wyckoff_overlay(
+ ts_code: str,
+ freq: str = Query("1d", description="1d | 1w | 1M"),
+ bars: int = Query(180, ge=60, le=400),
+):
+ """Walk-forward phase bands + event markers for chart overlay."""
+ if freq not in ("1d", "1w", "1M"):
+ raise HTTPException(status_code=400, detail="freq 仅支持 1d / 1w / 1M")
+ try:
+ return annotate_symbol(ts_code, freq=freq, lookback=bars)
+ except Exception as e:
+ raise HTTPException(status_code=500, detail=f"标注失败: {e}") from e
+
+
+@router.get("/scan/{ts_code}")
+async def wyckoff_detail(ts_code: str, trade_date: str | None = Query(None)):
+ td = date.fromisoformat(trade_date) if trade_date else None
+ row = wyckoff_store.get_detail(ts_code, td)
+ if not row:
+ raise HTTPException(status_code=404, detail="Wyckoff scan not found")
+ return {
+ "ts_code": row["ts_code"],
+ "name": row.get("name"),
+ "industry": row.get("industry"),
+ "trade_date": str(row.get("trade_date"))[:10],
+ "engine_version": row.get("engine_version"),
+ "monthly": {
+ "cycle": row.get("m_cycle"),
+ "confidence": row.get("cycle_confidence"),
+ "trend_score": row.get("trend_score"),
+ },
+ "weekly": {
+ "cycle": row.get("w_cycle"),
+ "phase": row.get("w_phase"),
+ "current_event": row.get("w_current_event"),
+ "active_events": row.get("w_active_events") or row.get("w_recent_events"),
+ "recent_events": row.get("w_active_events") or row.get("w_recent_events"),
+ "confidence": row.get("phase_confidence"),
+ "structure_score": row.get("structure_score"),
+ },
+ "daily": {
+ "current_event": row.get("d_current_event"),
+ "active_events": row.get("d_active_events") or row.get("d_recent_events"),
+ "recent_events": row.get("d_active_events") or row.get("d_recent_events"),
+ "confidence": row.get("event_confidence"),
+ "entry_score": row.get("entry_score"),
+ },
+ "decision": {
+ "signal": row.get("decision_signal"),
+ "alignment": row.get("alignment"),
+ "stars": row.get("stars"),
+ "overall_score": row.get("overall_score"),
+ "overall_confidence": row.get("overall_confidence"),
+ "signal_confidence": row.get("signal_confidence"),
+ "risk": row.get("risk"),
+ "scores": {
+ "trend": row.get("trend_score"),
+ "structure": row.get("structure_score"),
+ "entry": row.get("entry_score"),
+ },
+ "reasons": row.get("reasons") or row.get("reasons_json"),
+ },
+ "plan": {
+ "entry": row.get("entry"),
+ "stop": row.get("stop"),
+ "target1": row.get("target1"),
+ "target2": row.get("target2"),
+ "rr": row.get("rr"),
+ },
+ "feature_snapshot": row.get("feature_snapshot") or row.get("feature_snapshot_json"),
+ "markers": row.get("markers") or row.get("markers_json"),
+ }
diff --git a/src/ashare_dp/apps/api/wyckoff/__init__.py b/src/ashare_dp/apps/api/wyckoff/__init__.py
new file mode 100644
index 0000000..52a28f9
--- /dev/null
+++ b/src/ashare_dp/apps/api/wyckoff/__init__.py
@@ -0,0 +1 @@
+"""Wyckoff Screener presentation package."""
diff --git a/src/ashare_dp/apps/api/wyckoff/html.py b/src/ashare_dp/apps/api/wyckoff/html.py
new file mode 100644
index 0000000..68e507d
--- /dev/null
+++ b/src/ashare_dp/apps/api/wyckoff/html.py
@@ -0,0 +1,731 @@
+"""威科夫选股界面 — 三栏布局 + 本地 K 线。"""
+
+WYCKOFF_HTML = r"""
+
+
+
+威科夫选股
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+
+ K 线
+
+
+
+
+
+
+
+
+
+