#!/usr/bin/env python3
from __future__ import annotations
import sys
from pathlib import Path
ROOT = Path(__file__).resolve().parents[1]
if str(ROOT) not in sys.path:
    sys.path.insert(0, str(ROOT))
from database import TradeDB

db = TradeDB()
# skip 로그: 09:08:49 fid20=090844 025980 — DB에 09:08:49 recv + tick 090844 있는지
rows = db.conn.execute(
    "SELECT code, tick_time, tick_time_raw, recv_ts, price FROM ws_ticks "
    "WHERE source=%s AND code=%s AND recv_ts >= %s AND recv_ts <= %s "
    "ORDER BY recv_ts LIMIT 20",
    ("kiwoom", "025980", "2026-08-19 09:08:40", "2026-08-19 09:09:00"),
).fetchall()
print("025980 around skip 09:08:49")
for r in rows:
    print(dict(r))

rows2 = db.conn.execute(
    "SELECT code, tick_time, tick_time_raw, recv_ts, price FROM ws_ticks "
    "WHERE source=%s AND tick_time_raw=%s AND recv_ts >= %s AND recv_ts <= %s "
    "LIMIT 10",
    ("kiwoom", "090844", "2026-08-19 09:08:40", "2026-08-19 09:09:10"),
).fetchall()
print("tick_time_raw=090844 near 09:08:49")
for r in rows2:
    print(dict(r))
if not rows2:
    print("(없음 — skip된 catch-up이 DB에 안 들어간 것)")