diff --git a/app.py b/app.py
index 89b4ce93..9326c2d9 100755
--- a/app.py
+++ b/app.py
@@ -5601,21 +5601,23 @@ def get_historical_event_stocks(event_id):
             if event_trading_date:
                 try:
                     # 查询股票在事件对应交易日的数据
-                    # ea_dailyline 表的 seccode 不带后缀，需要去掉 .SH/.SZ 后缀
+                    # ea_trade 表的 SECCODE 不带后缀，需要去掉 .SH/.SZ 后缀
+                    # F007N 是收盘价，F008N 是涨跌幅
                     base_stock_code = stock.stock_code.split('.')[0] if stock.stock_code else ''
+                    # 日期格式转换为 YYYYMMDD
+                    trade_date_str = event_trading_date.strftime('%Y%m%d') if hasattr(event_trading_date, 'strftime') else str(event_trading_date).replace('-', '')
                     with engine.connect() as conn:
                         query = text("""
-                                     SELECT close_price, change_pct
-                                     FROM ea_dailyline
-                                     WHERE seccode = :stock_code
-                                       AND date = :trading_date
-                                     ORDER BY date DESC
-                                         LIMIT 1
+                                     SELECT F007N as close_price, F008N as change_pct
+                                     FROM ea_trade
+                                     WHERE SECCODE = :stock_code
+                                       AND TRADEDATE = :trading_date
+                                     LIMIT 1
                                      """)
 
                         result = conn.execute(query, {
                             'stock_code': base_stock_code,
-                            'trading_date': event_trading_date
+                            'trading_date': trade_date_str
                         }).fetchone()
 
                         if result: