update pay ui

app.py

@@ -12539,6 +12539,40 @@ def get_hotspot_overview():
         # 2. 获取概念异动数据（从 concept_anomaly_hybrid 表）
         alerts = []
         with engine.connect() as conn:
+            # 首先确保表存在
+            try:
+                conn.execute(text("""
+                    CREATE TABLE IF NOT EXISTS concept_anomaly_hybrid (
+                        id INT AUTO_INCREMENT PRIMARY KEY,
+                        concept_id VARCHAR(64) NOT NULL,
+                        alert_time DATETIME NOT NULL,
+                        trade_date DATE NOT NULL,
+                        alert_type VARCHAR(32) NOT NULL,
+                        final_score FLOAT NOT NULL,
+                        rule_score FLOAT NOT NULL,
+                        ml_score FLOAT NOT NULL,
+                        trigger_reason VARCHAR(64),
+                        alpha FLOAT,
+                        alpha_delta FLOAT,
+                        amt_ratio FLOAT,
+                        amt_delta FLOAT,
+                        rank_pct FLOAT,
+                        limit_up_ratio FLOAT,
+                        stock_count INT,
+                        total_amt FLOAT,
+                        triggered_rules JSON,
+                        created_at TIMESTAMP DEFAULT CURRENT_TIMESTAMP,
+                        UNIQUE KEY uk_concept_time (concept_id, alert_time, trade_date),
+                        INDEX idx_trade_date (trade_date),
+                        INDEX idx_concept_id (concept_id),
+                        INDEX idx_final_score (final_score),
+                        INDEX idx_alert_type (alert_type)
+                    ) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COMMENT='概念异动检测结果（融合版）'
+                """))
+                conn.commit()
+            except Exception as create_err:
+                logger.debug(f"创建表检查: {create_err}")
+
             # 查询 concept_anomaly_hybrid 表
             alert_result = conn.execute(text("""
                 SELECT