Ni^dZddlZddlZddlZddlZddlZddlmZmZejjdejjejje ddl mZdZdZdeiZdd d d d d dddddddddZdZdZdZdZdZdZdZedk(reyy)z Fetch upcoming & recent schedules from TheSportsDB v2 for priority leagues. Upserts into SportsGame (deduplicated by externalGameId). Cron: 0 */2 * * * (every 2 hours) N)datetimetimezone)normalize_to_full428892z'https://www.thesportsdb.com/api/v2/jsonz X-API-KEY)nbaNBA)nflNFL)nhlNHL)mlbMLB)ncaabNCAAB)ncaafNCAAF)eplzEnglish Premier League)laligazSpanish La Liga) bundesligazGerman Bundesliga)serieazItalian Serie A)ligue1zFrench Ligue 1)mlsz American MLS)uclzUEFA Champions League)ufcUFC)43874391438044244607447943284335433143324334434644804443ctdd5}|D]b}|jds|jdddjjdjddccdddS dddy #1swYy xYw) Nz/var/www/html/eventheodds/.envrzSPORTS_DATABASE_URL=="?r)open startswithsplitstrip)flines scripts/fetch_tsdb_schedules.py load_db_urlr8's . 4N ND56zz#q)!,224::3?EEcJ1MMNN NN  N sA?AA?4A??Bc Btd|d|} tj|td}|jdk7rgS|j }|jdxs|jdxsgS#t $r }td|d |d |gcYd }~Sd }~wwxYw) z-Fetch next or previous schedule for a league.z /schedule/z/league/)headerstimeoutscheduleeventsz Error fetching schedule//z: N)BASErequestsgetHEADERS status_codejson Exceptionprint) league_id directionurlrespdataes r7fetch_schedulerO/s F*YKx { ;C||C"=   s "Iyy{xx #?txx'9?R?  *9+QykA3GH s",A57A55 B>BBBcJ|y t|S#ttf$rYywxYwN)int ValueError TypeErrorvs r7_intrW=s/y1v  " ""cJ|y t|S#ttf$rYywxYwrQ)floatrSrTrUs r7_floatr[Fs/yQx  "rXcL|jdd}|s@|jdd}|rt|ddStjjS t|j ddS#t tf$r!tjjcYSwxYw)zExtract season year from event. strSeasonr0 dateEventN-r)rCrRrnowyearr3rS IndexError)eventsdates r7 parse_seasonrgOs +r"A yyb) tBQx= ||~"""#1773<?##  ##||~"""#sA33-B#"B#c|sytjtj}d}|j }|D]o}|j dd}|sd|}|j dd} |j dxs|j dxsd} | rt | d k\r | d | dd } n| d } t|j d xs|j dd|} t|j dxsd|} t|j d}t|j d}|j dxs|j dxsd}||d}n|dvrd}t|}|jd||| | | ||||tj|||f |dz }r|j|S)NridEventr0tsdb_r^strTime strTimeLocalz00:00:00 z 00:00:00 strHomeTeamstrEventUnknown strAwayTeamTBD intHomeScore intAwayScore strStatus strPostponedfinal)NSr0 scheduleda3 INSERT INTO "SportsGame" ( league, season, "gameDate", "homeTeam", "awayTeam", "externalGameId", "homeScore", "awayScore", status, raw, "createdAt", "updatedAt" ) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s) ON CONFLICT (league, "externalGameId") DO UPDATE SET "homeScore" = COALESCE(EXCLUDED."homeScore", "SportsGame"."homeScore"), "awayScore" = COALESCE(EXCLUDED."awayScore", "SportsGame"."awayScore"), status = CASE WHEN EXCLUDED.status = 'final' THEN 'final' ELSE "SportsGame".status END, raw = EXCLUDED.raw, "updatedAt" = EXCLUDED."updatedAt" WHERE EXCLUDED."homeScore" IS NOT NULL OR "SportsGame"."homeScore" IS NULL r-)rrarutccursorrClenrrWrgexecuterFdumpscommit)connr? league_coderainsertedcurevevent_idext_iddate_strtime_str game_datehomeaway home_score away_scorestatusseasons r7 upsert_gamesr^s  ,,x|| $CH ++-C+66)R(  #66+r*66)$L~(>L* H *#*Ahrl^4I#*I.I  !6!W"&&Y:WYde  !6!?%M"&&01 "&&01  $D~(>D"  !j&<F z ! Fb!   D$ J F JJrNC  $ A W+Z KKM Oc pt}|s tdytj|}d}tj D]Q\}\}}dD]D}t ||}|st|||}td|d|dt|d|d ||z }FS|jtd |d y) NzERROR: No SPORTS_DATABASE_URLr)nextpreviousz z (z): z events, z upsertedzTOTAL: z games upserted) r8rHpsycopg2connectPRIORITY_LEAGUESitemsrOrr~close) db_urlrtotalrIcodenamerJr?ns r7mainrs ]F  -.   F #D E#3#9#9#; rs  '277??277??8#<=>( 0         - ) / ) ( # , $  #5p,* zFr