Vercel] - CITYCARD[Scan Terminal City Cards
AI airport read + bucket mapping] + CITYCARD[Scan Terminal City Cards
structured observations + probability mapping] TG[Telegram Bot
TeleBot + Handlers] end @@ -127,7 +127,7 @@ Scan Terminal 的城市决策卡现在承担“从天气分析到市场动作解 **Python 依赖**：`requirements.txt` 包含 `requests`、`loguru`、`pyTelegramBotAPI`、`python-dotenv`、`numpy`、`web3`、`fastapi`、`uvicorn` 等，符合“采集+bot+api+链上交互”的需求。 **容器环境**：`Dockerfile` 基于 `python:3.11-slim`，默认启动 bot；`docker-compose.yml` 通过不同 command 分别启动 bot 与 web（`python bot_listener.py` / `python web/app.py`），并挂载运行态数据目录。 -**前端依赖**：前端 README 描述 Next.js、Leaflet、Chart.js、Supabase Auth、WalletConnect 等；`frontend/package.json` 是前端依赖来源。 +**前端依赖**：前端 README 描述 Next.js、Leaflet、Recharts、Supabase Auth、WalletConnect 等；`frontend/package.json` 是前端依赖来源。 ### 数据预处理、模型与“训练/推理”管线 本项目的“模型”主要是统计融合与规则/启发式引擎，而非深度网络训练： @@ -181,7 +181,7 @@ Web/Telegram 请求 → FastAPI 调用采集器抓取/复用缓存 → 分析引 **对标结论**：PolyWeather 与这类“全球神经天气模型”不在同一层级：PolyWeather 是“面向结算市场的产品化情报系统”，其价值核心是**将预测转成可交易/可结算的决策信息**。短中期内更高 ROI 的方向不是“自训大模型”，而是把现有“采集+后处理+市场映射”的链路做成**可复现、可观测、可评测、可扩展**的工程平台；在许可合规前提下，再评估引入外部模型推理作为额外信号源。 ## 优先级改进建议 -下表按截至 `2026-05-23` 的真实状态重排优先级。已完成项不再继续列为”待做”，只保留当前仍需推进的事项。 +下表按截至 `2026-05-28` 的真实状态重排优先级。已完成项不再继续列为”待做”，只保留当前仍需推进的事项。 | 优先级 | 改进项 | 预估工作量 | 主要收益 | 主要风险 | 可执行步骤（建议顺序） | | ------ | --------------------------------------------------------------------------------------------------------------------------------- | -------------------: | ------------------------------------------------------------------- | ------------------------------------------------------- | ---------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------- | | 中 | **把最小外部监控继续补深**：从“可告警”提升到“可运营” | 3–7 天 | 不再只知道服务坏没坏，还能看资源趋势、来源 SLA 和支付波动 | 指标过多会带来维护噪音 | 1) 增加节点 CPU/内存/磁盘 → 2) 增加 SQLite/支付体积与事件趋势 → 3) 把 HTTP/来源指标细分到城市/来源维度 → 4) 增加日报或异常摘要 | @@ -270,5 +270,3 @@ PolyWeather 的评测应围绕“结算场景”而非传统数值天气预报 - Pangu-Weather（权重 BY-NC-SA，禁商用）：https://github.com/198808xc/Pangu-Weather - Polymarket 官方 Python CLOB SDK（MIT）：https://github.com/Polymarket/py-clob-client - aiopolymarket（async、类型安全）：https://github.com/the-odds-company/aiopolymarket - - diff --git a/docs/images/demo_ankara.png b/docs/images/demo_ankara.png deleted file mode 100644 index 7e12554e..00000000 Binary files a/docs/images/demo_ankara.png and /dev/null differ diff --git a/docs/images/demo_map.png b/docs/images/demo_map.png deleted file mode 100644 index 7cc1bc2a..00000000 Binary files a/docs/images/demo_map.png and /dev/null differ diff --git a/docs/payments/POLYGONSCAN_VERIFY.md b/docs/payments/POLYGONSCAN_VERIFY.md index 721e618d..e98d02f3 100644 --- a/docs/payments/POLYGONSCAN_VERIFY.md +++ b/docs/payments/POLYGONSCAN_VERIFY.md @@ -1,4 +1,4 @@ -# PolyWeatherCheckout PolygonScan 验证（v1.8.0） +# PolyWeatherCheckout PolygonScan 验证（v1.8.1） 最后更新：`2026-03-20` diff --git a/docs/product-review-jun-2026.md b/docs/product-review-jun-2026.md index 57d5eccf..8c45fa4b 100644 --- a/docs/product-review-jun-2026.md +++ b/docs/product-review-jun-2026.md @@ -1,6 +1,6 @@ # PolyWeather 前端产品审查报告 -> 审查日期：2026-06 | 视角：产品经理 | 范围：`frontend/` 全部页面、组件、用户流程 +> 审查日期：2026-06 | 视角：产品经理 | 范围：`frontend/` 全部页面、组件、用户流程 | 最后校准：2026-05-28 ## 一、产品概览 @@ -18,7 +18,7 @@ PolyWeather 是一个面向天气衍生品交易者的气象情报平台。核 | 路由 | 功能 | 是否必需登录 | |------|------|-------------| -| `/` | 主看板 — AI 天气决策台 | 否 | +| `/` | 主看板 — 实时天气决策台 | 否 | | `/account` | 账户中心 — 身份/订阅/钱包/积分/Bot 绑定 | 是 | | `/auth/login` | 登录页（Google OAuth + 邮箱密码） | 否 | | `/docs/[...slug]` | 产品文档中心（8 篇双语文档） | 否 | @@ -37,7 +37,7 @@ PolyWeather 是一个面向天气衍生品交易者的气象情报平台。核 │ 点击城市 → 自动添加到决策卡工作区 + 切换到卡片视图 │ │ 免费用户和 Pro 用户均可使用 │ ├─ 决策卡（分析） ──────────────────────────────┤ -│ 钉选的城市卡片：AI 机场解读 + 模型集群 + 市场层 + 图表 │ +│ 钉选的城市卡片：结构化实况 + 模型集群 + 市场层 + 实时图表 │ │ 需要 Pro 订阅 │ └──────────────────────────────────────────────┘ └── 右侧栏：城市简报面板（始终可见，免费可用） @@ -46,7 +46,7 @@ PolyWeather 是一个面向天气衍生品交易者的气象情报平台。核 ### 关键用户路径 1. **新用户落地** → 看到 3 步引导 → 地图 + 城市列表 → 点击城市 → 看到城市简报 → 想深入分析 → 遇到 Pro 付费墙（含功能说明） -2. **Pro 用户工作流** → 地图选城市 → 自动钉选到决策卡 → 展开卡片 → 阅读 AI 报文解读 → 查看市场层 → 判断交易方向 +2. **Pro 用户工作流** → 地图选城市 → 自动钉选到决策卡 → 展开卡片 → 查看实测/DEB/概率/市场层 → 判断交易方向 ## 三、做得好的地方 @@ -67,4 +67,3 @@ PolyWeather 是一个面向天气衍生品交易者的气象情报平台。核 | 1 | **Docs 无搜索** — 8 篇文档没有搜索功能，用户必须逐篇浏览 | 🟢 待做 | | 2 | **Ops 面板无审计日志** — 管理员补发积分等操作没有审计记录 | 🟢 需后端 | | 3 | **注册后邮件验证引导** — 未验证邮箱的用户反复登录失败 | 🟡 需后端 | - diff --git a/docs/superpowers/plans/2026-05-27-redis-stream-realtime-event-architecture.md b/docs/superpowers/plans/2026-05-27-redis-stream-realtime-event-architecture.md index 1653da9c..a6640d70 100644 --- a/docs/superpowers/plans/2026-05-27-redis-stream-realtime-event-architecture.md +++ b/docs/superpowers/plans/2026-05-27-redis-stream-realtime-event-architecture.md @@ -4,6 +4,8 @@ **Goal:** Add Redis Stream as the production realtime event store and live fanout source while preserving the existing SSE patch protocol. +**Implementation status (2026-05-28):** completed in `v1.8.1`. Production uses Redis Stream when `POLYWEATHER_EVENT_STORE=redis`; SQLite remains the local/fallback event log. Browser API and frontend contract stayed on `/api/events` + `city_observation_patch.v1`. + **Architecture:** Keep `city_observation_patch.v1` and numeric `revision` as the browser contract. Add a Redis-backed event store beside the existing SQLite store, select it through an event-store factory, and let Redis-backed deployments fan out live events through a Redis subscriber loop instead of direct in-process ingest broadcast. **Tech Stack:** FastAPI, redis-py, Redis Stream, SQLite fallback, pytest, existing frontend EventSource hook. @@ -16,21 +18,21 @@ - Create: `tests/test_redis_realtime_event_store.py` - Create: `web/redis_realtime_event_store.py` -- [ ] **Step 1: Write failing tests** +- [x] **Step 1: Write failing tests** Cover append, replay by city, replay gap, and fallback-independent event shape. -- [ ] **Step 2: Verify tests fail** +- [x] **Step 2: Verify tests fail** Run: `python -m pytest tests/test_redis_realtime_event_store.py -q` Expected: fails because `web.redis_realtime_event_store` does not exist. -- [ ] **Step 3: Implement Redis store** +- [x] **Step 3: Implement Redis store** Add `RedisRealtimeEventStore` with `append_event`, `latest_revision`, `replay_events`, `replay_requires_resync`, and idempotent `start_live_subscription`. -- [ ] **Step 4: Verify tests pass** +- [x] **Step 4: Verify tests pass** Run: `python -m pytest tests/test_redis_realtime_event_store.py -q` @@ -41,19 +43,19 @@ Run: `python -m pytest tests/test_redis_realtime_event_store.py -q` - Modify: `web/routers/sse_router.py` - Test: `tests/test_sse_replay.py` -- [ ] **Step 1: Write failing tests** +- [x] **Step 1: Write failing tests** Cover `POLYWEATHER_EVENT_STORE=redis` selecting Redis, SQLite fallback when Redis is not configured, and Redis ingest not doing direct local broadcast. -- [ ] **Step 2: Verify tests fail** +- [x] **Step 2: Verify tests fail** Run: `python -m pytest tests/test_sse_replay.py tests/test_realtime_event_store_factory.py -q` -- [ ] **Step 3: Implement factory and router integration** +- [x] **Step 3: Implement factory and router integration** Use Redis store when configured; otherwise keep existing SQLite store. Ingest broadcasts directly only for stores that do not provide external live fanout. -- [ ] **Step 4: Verify tests pass** +- [x] **Step 4: Verify tests pass** Run: `python -m pytest tests/test_sse_replay.py tests/test_realtime_event_store_factory.py -q` @@ -63,11 +65,11 @@ Run: `python -m pytest tests/test_sse_replay.py tests/test_realtime_event_store_ - Modify: `requirements.txt` - Modify: `docs/superpowers/specs/2026-05-27-redis-stream-realtime-event-architecture-design.md` -- [ ] **Step 1: Add redis-py dependency** +- [x] **Step 1: Add redis-py dependency** Add `redis>=5.0.0` to `requirements.txt`. -- [ ] **Step 2: Add final config notes** +- [x] **Step 2: Add final config notes** Ensure the design doc names the runtime env vars used by code. @@ -76,7 +78,7 @@ Ensure the design doc names the runtime env vars used by code. **Files:** - No production edits unless tests reveal a gap. -- [ ] **Step 1: Run backend realtime tests** +- [x] **Step 1: Run backend realtime tests** Run: @@ -84,7 +86,7 @@ Run: python -m pytest tests/test_realtime_patch_schema.py tests/test_realtime_event_store.py tests/test_redis_realtime_event_store.py tests/test_realtime_event_store_factory.py tests/test_sse_replay.py -q ``` -- [ ] **Step 2: Run broader frontend/backend checks** +- [x] **Step 2: Run broader frontend/backend checks** Run: @@ -95,7 +97,7 @@ npm run typecheck npm run build ``` -- [ ] **Step 3: Inspect diff** +- [x] **Step 3: Inspect diff** Run: diff --git a/docs/superpowers/specs/2026-05-27-redis-stream-realtime-event-architecture-design.md b/docs/superpowers/specs/2026-05-27-redis-stream-realtime-event-architecture-design.md index f385159e..d46238cf 100644 --- a/docs/superpowers/specs/2026-05-27-redis-stream-realtime-event-architecture-design.md +++ b/docs/superpowers/specs/2026-05-27-redis-stream-realtime-event-architecture-design.md @@ -3,6 +3,7 @@ > 日期: 2026-05-27 > 范围: PolyWeather 网站图表实时观测事件层 > 目标服务器: 2 vCPU / 8 GB RAM / 50 GB 系统盘 +> 实施状态: 2026-05-28 已落地为 `v1.8.1` ## 背景 @@ -29,7 +30,7 @@ - 前端协议保持 `city_observation_patch.v1`，不让浏览器感知 Redis。 - 继续使用 numeric `revision`，兼容现有前端 `since_revision` 逻辑。 - 支持按城市订阅、断线 replay、多 worker fanout。 -- 事件只保留短窗口，默认 24 小时；生产不建议超过 24 小时。 +- 事件只保留短窗口；当前默认按 Redis Stream `MAXLEN` 控制，建议以约 24 小时 replay 为目标，不做 72 小时保留。 ## 非目标 diff --git a/frontend/README.md b/frontend/README.md index eec8aa94..90a2a617 100644 --- a/frontend/README.md +++ b/frontend/README.md @@ -9,7 +9,7 @@ PolyWeather Pro 的生产前端工程。 - Next.js App Router - React + Tailwind -- Leaflet + Chart.js +- Leaflet + Recharts - Supabase Auth - WalletConnect + 浏览器 EVM 钱包 @@ -23,6 +23,11 @@ PolyWeather Pro 的生产前端工程。 - 主站 Dashboard 支持地图、城市详情、今日日内分析和账户中心 - `/docs` 已提供公开双语产品文档中心，解释日内分析、校准概率、模型栈、TAF 和结算来源 +- 终端图表默认展示全天，可切换高温窗口；所有横轴与 tooltip 时间按城市当地时间渲染 +- 可见终端图表通过 SSE patch 无痛增量刷新，后台切回前台时主动补齐最新 detail，不用 loading 遮罩覆盖已有曲线 +- AMSC/AMOS 跑道城市默认展示结算跑道曲线并高亮，辅助跑道弱化展示；单跑道机场不重复展示聚合线 +- 香港默认展示 CoWIN 6087 参考站 1 分钟曲线，并保留 HKO 10 分钟官方气象层 +- legacy 高斯概率在图表上展示为概率温度带和 `mu` 参考线，不作为时间序列曲线 - 今日日内分析支持： - `锚点状态` - `当前节奏` @@ -185,6 +190,8 @@ Ops： - 支付相关路由：`no-store` - 当 detail 缓存只返回单模型或单日 forecast 时，前端会自动强刷完整 detail，并在补齐前显示同步提示 / 占位卡 - 今日日内分析打开时如果正在切换城市、日期或 detail 深度，弹窗会阻断旧内容点击并显示刷新锁 +- 终端图表订阅 `/api/events?cities=...&since_revision=...&replay_limit=500`，接收 `city_observation_patch.v1`；无 patch 超过 2 分钟时，可见图表才触发 60 秒兜底刷新 +- 前端只消费 HTTP snapshot + SSE patch，不直接感知 Redis；Redis Stream / SQLite event log 都由后端统一封装 ## Vercel 节流建议 @@ -199,4 +206,4 @@ Ops： 详见根目录策略文档：`docs/OPEN_CORE_POLICY.md` -最后更新：`2026-05-23` +最后更新：`2026-05-28` diff --git a/frontend/components/landing/InstitutionalLandingPage.tsx b/frontend/components/landing/InstitutionalLandingPage.tsx index bc3474f3..dbd11334 100644 --- a/frontend/components/landing/InstitutionalLandingPage.tsx +++ b/frontend/components/landing/InstitutionalLandingPage.tsx @@ -3,18 +3,14 @@ import { useEffect, useState } from "react"; import Link from "next/link"; import { - Activity, ArrowRight, - BarChart3, Check, CheckCircle2, - CloudSun, Gauge, LineChart, LockKeyhole, Radar, ShieldCheck, - TrendingUp, } from "lucide-react"; import { I18nProvider, useI18n } from "@/hooks/useI18n"; import { @@ -22,22 +18,6 @@ import { hasSupabasePublicEnv, } from "@/lib/supabase/client"; -const RAW_MARKET_ROWS_EN = [ - ["New York", "91.8°F", "+2.4", "High Anomaly", "Approve Temp"], - ["Austin", "103.1°F", "+1.1", "Normal", "Observe"], - ["Seoul", "83.4°F", "-0.7", "Low Anomaly", "Veto Anomaly"], - ["Tokyo", "88.2°F", "+1.8", "High Anomaly", "Approve Temp"], - ["London", "72.6°F", "-0.2", "Normal", "Observe"], -]; - -const RAW_MARKET_ROWS_ZH = [ - ["纽约", "91.8°F", "+2.4", "高偏差", "符合高温"], - ["奥斯汀", "103.1°F", "+1.1", "正常", "持续观察"], - ["首尔", "83.4°F", "-0.7", "低偏差", "否决偏差"], - ["东京", "88.2°F", "+1.8", "高偏差", "符合高温"], - ["伦敦", "72.6°F", "-0.2", "正常", "持续观察"], -]; - const COVERAGE_EN = [ "Live airport observations", "DEB blend forecast", @@ -94,7 +74,6 @@ function InstitutionalLandingScreen() { }); }, []); - const marketRows = isEn ? RAW_MARKET_ROWS_EN : RAW_MARKET_ROWS_ZH; const coverage = isEn ? COVERAGE_EN : COVERAGE_ZH; const platformCards = isEn ? [ @@ -132,10 +111,6 @@ function InstitutionalLandingScreen() { }, ]; - const modelLabels = isEn - ? ["DEB Blend", "Live METAR", "Model Consensus"] - : ["DEB 融合预测", "METAR 机场实测", "模型多方共识"]; - return (
+
-
-
- {isEn ? "Live" : "实时数据"}
+ {isEn ? "Real product screenshot" : "真实产品截图"}
-
-
-
- {isEn ? "Temperature Metrics" : "温度决策指标"}
-
- {isEn ? "Observed / Deviation / Decision" : "实测 / 偏差 / 决策"}
-
-
-
- {marketRows.map((row) => (
-
-
- {row[0]}
- {row[1]}
-
- {row[2]}
-
-
- {row[3]}
-
-
- {row[4]}
-
-
- ))}
-
-
@@ -420,8 +335,8 @@ function InstitutionalLandingScreen() {
-
-
- {isEn ? "Model Stack" : "模型堆栈"}
-
-
- {modelLabels.map((label, index) => (
-
-
-
- ))}
-
- {label}
- {[82, 67, 74][index]}%
-
-
-
-
-
-
+
-
- - {isEn - ? "New York high-temperature target shows a positive observation deviation with confirmed airport evidence." - : "纽约高温阈值监测出现显著的正向观测偏差，机场天气实况已验证确认。"} -
-
+
+ 
{isEn - ? "Full access to the institutional weather intelligence workspace. Live METAR, DEB forecasts, probability distribution, AI decision cards, and real-time alerts." - : "完整访问机构级天气决策分析台。实时 METAR、DEB 预报、概率分布、AI 决策卡片、实时通知。"} + ? "Full access to the institutional weather intelligence workspace. Live METAR, DEB forecasts, probability distribution, realtime terminal charts, and alerts." + : "完整访问机构级天气决策分析台。实时 METAR、DEB 预报、概率分布、实时终端图表、实时通知。"}
diff --git a/frontend/package-lock.json b/frontend/package-lock.json
index ca24211a..a46e22e2 100644
--- a/frontend/package-lock.json
+++ b/frontend/package-lock.json
@@ -1,12 +1,12 @@
{
"name": "polyweather-frontend",
- "version": "1.7.0",
+ "version": "1.8.1",
"lockfileVersion": 3,
"requires": true,
"packages": {
"": {
"name": "polyweather-frontend",
- "version": "1.7.0",
+ "version": "1.8.1",
"dependencies": {
"@radix-ui/react-slot": "^1.1.2",
"@supabase/ssr": "^0.5.2",
diff --git a/frontend/package.json b/frontend/package.json
index 8c425b02..f97fbb3d 100644
--- a/frontend/package.json
+++ b/frontend/package.json
@@ -1,6 +1,6 @@
{
"name": "polyweather-frontend",
- "version": "1.8.0",
+ "version": "1.8.1",
"private": true,
"scripts": {
"dev": "node scripts/sync-next-server-chunks.mjs --clean-root && next dev",
diff --git a/frontend/public/static/tel.png b/frontend/public/static/tel.png
new file mode 100644
index 00000000..a5f8e864
Binary files /dev/null and b/frontend/public/static/tel.png differ
diff --git a/frontend/public/static/web.png b/frontend/public/static/web.png
new file mode 100644
index 00000000..7cad6036
Binary files /dev/null and b/frontend/public/static/web.png differ