a 6j'@sndZddlZddlZddlZddlZddlZddlZddlZddlZ ddl m Z m Z ddl m Z ejjddde dZhd Zd Zd Zd eiZe d ZedZeeZWdn1s0YddeDZddZddddddddddddddd d!d"d#Zd$d%Zd&d'Zd(d)Z d*d+Z!d,d-Z"d.d/Z#e$Z%d0d1Z&d2d3Z'd4d5Z(e)d6krje(dS)7uF Resolve match results in live_data CSVs using data already in the file. Finds FT/AET/PEN rows, extracts the final score, and backfills ftr / result_home / result_away for all rows of that game. Runs nightly at 12:05 AM via Task Scheduler. Safe to re-run — skips already-resolved games. Usage: python resolve_live_data.py N)datetimedate)Pathutf-8replace)encodingerrorszE:\soccer\live_data>ZAETZFTZPENZ 81b487be73030f5dec980d2a1ef2c406z!https://v3.football.api-sports.iozx-apisports-keyz!E:\soccer\data\_result_cache.jsonzE:\soccer\data\league_map.jsoncCs$i|]\}}|dr|d|qS)Zapi_football_id)get.0kvrmain/resolve_live_data.py rcCstd|ddS)NZNFDasciiignore) unicodedataZ normalizeencodedecode)srrr_strip_accentssrZwolvesZathleticzatletico madridzsaint louis cityzseattle sounderszvancouver whitecapszsan jose earthquakesz fc dallaszcolorado rapidszparis saint-germainZnurnbergZlarisaZ panetolikosZ kocaelisporzgenclerbirligi s.k.z gil vicente)Z wolverhamptonZbilbaoZatleticoz saint louisZseattleZ vancouverzsan joseZdallasZcoloradoZpsgZ nurembergZlarissa panaitolikosrZkocaeliZgenclerbirligizvicente barceloscCs*tr&ztttWSYn0iSN)CACHE_Fexistsjsonloadopenrrrr load_cache5s r csXtttd.}tfdd|D|Wdn1sJ0YdS)a5Persist the result cache, MINUS today. Today must stay cached in memory -- one run resolves ~100 same-day games and without it each would re-fetch, which is ~200 API calls per dashboard refresh on a plan that already ran out today. It must NOT reach disk, though: a snapshot written at 3pm contains only the games finished by 3pm, and api_results_for_date returns any non-empty cache entry without re-fetching, so the evening's games would be missing from it permanently. Dropping today keeps the in-run saving and loses the trap. wcsi|]\}}|kr||qSrrr todayrrrIrzsave_cache..N)rr# isoformatrrrdumpitems)cachefrr"r save_cache;s  r)c Csp||vr||r||Si}ztjtdtd|idd}|dgD]}|ddtvrbqL|dd d tvrxqL|d }|d durqLt|d t|d }}||krdn||krdnd}t|dd d } t|dd d } | d| } |||d|| <qL|||<t dWn:t yj} z td|d| WYd} ~ n d} ~ 00|S)Nz /fixturesr)ZheadersparamsZtimeoutZresponseZleagueidZfixturestatusZshortgoalshomeawayHADZteamsname|ftr result_home result_awayg333333?z API error for z: )requestsr AF_BASEHEADERSr LEAGUE_IDSTERMINALintrlowerstriptimesleep Exceptionprint) gd_strr'resultsrZfixr.har7hnankeyerrrapi_results_for_dateKs**rOcCs`z|dtrWdSWnty.Yn0zt|ddkWStyZYdS0dS)aHas this same-day game actually ended? Only matters because live_monitor's clock-based fallback writes status=FT with NO GOALS when it cannot get a score -- which is exactly the case that needs the API. So a terminal status counts as 'ended' even with no score attached, and 115+ minutes on the clock counts as well for a game whose status never advanced at all. The point of the original 'skip today' rule was not to ask about a game still in play. This keeps that, without waiting until tomorrow. r-TelapsedsFN)isinr>anyrDfloatmax)grprrr_finished_todaycs    rWcCst|}t||S)zYApply known team name aliases before matching. Always works on accent-stripped lowercase.)rr@rA TEAM_ALIASESr )r4nrrr_resolve_aliaszsrZcCs^ddlm}tt||}z,t||dd}|t||WntyXYn0|S)zZFetch results for gd_str and gd_str+1 day (catches late games stored under next UTC date).r timedeltaZdays) rr\dictrOr fromisoformatr$updaterD)rFr'r\rGZnext_dayrrrapi_results_for_date_combineds  rbcsTt||}t|}t|}|d|}||vr|tvrt|||dz0ddlm}|t ||dd dWnt yYn0t||}||vr||St |t |} } | d| } | |vr|| Shdfddfd d } |D]:\} }| dd\}}| ||r| ||r|SqdS) Nr5rr[r]r^> realZunitedZafZcityZscZtownZacZfcZsportingZroyalcs&fddt|ddDS)Ncs$g|]}t|dkr|vr|qS))lenr r!skiprr sz-api_lookup..words..- )rr@rsplit)rYrgrrwordsszapi_lookup..wordscsRttt}}tfdd|DpPtfdd|DS)Nc3s|]}|vVqdSrrrf) cache_namerr rz.api_lookup..matches..c3s*|]"}|tvp |tvVqdSr)rr@rZrf)our_namerrror)listr_fromkeysrZrS)rprnZowZcw)rm)rnrprmatchess zapi_lookup..matches)rbrr@rA_refetched_datesaddpoprr\rr`r$rDrZr&rl)r/r0rFr'rGrKrLrMr\ZahZaaZ alias_keyrsr r ZkhZkar)rhrmr api_lookups6    $     rwc CsZtj|dd}dD]}||jvrd||<qtj|ddd|d<tj|ddd|d<z|j}t|}Wntyd}d}Yn0|duo|tk}|tk}d}| d d gD]\\} } } |j | j d f rq| | d t| d @} | js| jd } t| d}t| d}||kr6dn||krDdnd}||j | j d f<||j | j df<||j | j df<d}td| d| d|d|d| q|s|rt| sqt| | ||}|r|d |j | j d f<|d|j | j df<|d|j | j df<d}td| d| d|d d|dd|d q|rV|j|ddd|S)Nr)rr6Z home_goalsZcoerce)rZ away_goalsFr/r0r7r-r1r2r3r8r9Tz [csv] z vs z -> rkrjz [api] )indexr)pdZread_csvcolumnsZ to_numericZstemrr`rDr#groupbyZlocryZnotnarSrRr>emptyZilocr?rErWrwZto_csv)pathr'ZdfcolrFgdZ api_eligibleZis_todayZchangedr/r0rVZterminalZlastrIrJr7resultrrr resolve_filesT         &4rcCstdtddttttd}t}d}|D]6}t j |}td|dt t ||r>|d7}q>t|td |d dS) Nu === Resolve Live Data — z%Y-%m-%d %H:%Mz ===z*.csvrz []r]u Done — z files updated.)rErZnowstrftimesortedglobstrDATA_DIRr osr~basenamerrr))filesr'updatedr(fnamerrrmains  r__main__)*__doc__rrsysrrBr:rZpandasrzrrpathlibrstdout reconfigurerr>ZAPI_KEYr;r<rrr(rZ_lmr&r=rrXr r)rOrWrZrbsetrtrwrr__name__rrrrsZ 8  ( ,>