o ̿Si @sUddlZddlZddlmZddlmZddlmZddlmZm Z ddl m Z m Z m Z mZmZmZmZeeZeZdaeeed<d d ed dfd d ZdS)N)datetime)Optional) get_mongo_db)close_paper_trades_for_eod_paper_day_key)backend_market_window format_windowis_backend_market_hours local_nowlocal_time_strnext_backend_market_open_local seconds_until _LAST_RUN_DAY<interval_secondsreturncstdIdHtdt| zts?t}tdttt |dur5tt t |IdHnt|IdHWqt rMt|IdHWqt 4IdHot}t|}t|krtt|IdH WdIdHWqt}t|}zt||d}Wz|WntyYnwz|WwtyYww|dr|atd||d |d WdIdHn 1IdHswYWntytd Ynwt|IdHq) a?Close all intraday paper trades at EOD (IST). Why this exists: - The per-symbol update loop closes trades only when a candle update arrives. - If candle updates stop before cutoff or symbols go quiet, trades can remain OPEN. This loop is DB-only. It runs once per day after the configured cutoff. Nz&[PaperEOD] Loop started (interval=%ss)Tz;[PaperEOD] Backend skipped due to time | now=%s | window=%s)now_utcranz=[PaperEOD] Closed trades at EOD | day=%s closed=%s scanned=%sclosedscannedzaperEOD] Unexpected error)asynciosleeploggerinfointr r r rrr r _EOD_LOCKlockedrutcnowrrrnextrclose Exceptionget exception)rnxtnowday_keydb_gendbresr*9/var/www/html/Trade-python/app/v1/background/paper_eod.pypaper_eod_loopsp       ( r,)r)rloggingrtypingrapp.db.databaserapp.v1.services.paper_tradingrrapp.v1.utils.market_timerrr r r r r getLogger__name__rLockrrstr__annotations__rr,r*r*r*r+s    $