update pay function

2025-11-24 19:28:52 +08:00
parent 7743a8a26a
commit 4a0e156bec
2 changed files with 23 additions and 29 deletions
--- a/app.py
+++ b/app.py
@@ -6904,18 +6904,18 @@ def get_daily_kline(stock_code, event_datetime, stock_name):
    stock_code = stock_code.split('.')[0]

    with engine.connect() as conn:
-        # 获取事件日期前后的数据
+        # 获取事件日期前后的数据（前730天/2年，后30天）
        kline_sql = """
                    WITH date_range AS (SELECT TRADEDATE \
                                        FROM ea_trade \
                                        WHERE SECCODE = :stock_code \
-                                          AND TRADEDATE BETWEEN DATE_SUB(:trade_date, INTERVAL 60 DAY) \
+                                          AND TRADEDATE BETWEEN DATE_SUB(:trade_date, INTERVAL 730 DAY) \
                                            AND DATE_ADD(:trade_date, INTERVAL 30 DAY) \
                                        GROUP BY TRADEDATE \
                                        ORDER BY TRADEDATE)
                    SELECT t.TRADEDATE,
                           CAST(t.F003N AS FLOAT) as open,
-                   CAST(t.F007N AS FLOAT) as close, 
+                   CAST(t.F007N AS FLOAT) as close,
                   CAST(t.F005N AS FLOAT) as high,
                   CAST(t.F006N AS FLOAT) as low,
                   CAST(t.F004N AS FLOAT) as volume