iz[dZddlZddlZddlZddlZddlZddlZddlZddlmZm Z ddl m Z ddl m Z mZmZmZmZddlZe ej&j&dz Zej+ree5ZeD]Zej3sej5dr&devs+ej3j7dd \ZZej<j?eej3d j3d  dddej<jAd d Z!ej<jAdZ"ej<jAddZ#e"se$dejJd iddddddddddddddd d!d"d!d#d$d%d&d'd(d)d*d+d,d-d.d/d0d1d2d3d4iZ&e&jODcic]\}}|| c}}Z(d e(d!<d5e(d&<d6e(d(<d7e(d,<d8e(d.<gd9Z)Gd:d;Z*dZ.d?e d//*./ $t*40S00d0.3.$..4.rIr;rLc|yt|ttfr t|St|tr t|j ddSy#t $rYywxYw)z2Parse odds string like '+100' or '-110' to integerN+r)rXrfloatr]replace ValueErrorvalues rGparse_odds_valuers` }%#u&5z% u}}S"-. .   sA AAc|yt|ttfr t|St|tr t|Sy#t$rYywxYw)zParse line value to floatN)rXrrr]rrs rGparse_line_valuersT }%#u&U|% <    s A A Aeventc 6|jdi}d}d}|jdi}|jdi}|r-t|jdxs|jd}|r-t|jdxs|jd}d}d}|jdi}|jdi} |r-t|jd xs|jd }| r-t| jd xs| jd }d} |jd i} | r-t| jd xs| jd } ||||| dtjt j jdS)z%Parse event and extract key odds dataoddsNzpoints-home-game-ml-homezpoints-away-game-ml-awaybookOddsfairOddszpoints-home-game-sp-homezpoints-away-game-sp-away bookSpread fairSpreadzpoints-all-game-ou-over bookOverUnder fairOverUndersportsgameodds) moneylineHome moneylineAway spreadHome spreadAwaytotal oddsSource oddsUpdatedAt)rTrrrnowrutc isoformat) r odds_datahome_mlaway_mlml_homeml_away spread_home spread_awaysp_homesp_awayrou_overs rGparse_event_oddsrss &"%IGGmm6;Gmm6;G"7;;z#:#Ugkk*>UV"7;;z#:#Ugkk*>UVKKmm6;Gmm6;G&w{{<'@']GKKP\D]^ &w{{<'@']GKKP\D]^  Emm5r:G _!=!]_A]^! !!&!hll3==? rIc Rg}|jdi}|jd}|jd}tj||r|jnd}|jD]\}}|j d}t |dk\s&|ddk(s/|d } |d } |d } |d } | d vrH|jd} |jdxs|jd}| |j ||| | | d| t| |r t|ndd|d |S)z$Extract player prop lines from eventreventIDrhunknown-ourr )homeawayalllinerrNr) leaguegameIdplayerExternalIdpropTypemarket lineValue oddsAmericanvendorraw) rTSGO_TO_DB_LEAGUErmitemssplitrZappendrr)rpropsrevent_id sgo_leaguerodd_idodd_datapartsstat player_idperiodsiderrs rGextract_player_propsrs> E &"%Iyy#H:&J  ! !*Jj.>.>.@T] ^F%OO- S! u:?uQx4/8DaI1XF8D33<<'D<< +Gx||J/GD $&(1 $!'$0!&t15CI4.#  #: LrIctsy tjdd}d|vr|jdd}|jd\}}|jd\}}|jd\}}d|vr|jd\}}n|d }}tj|t |||| } | S#t $r} td | Yd} ~ yd} ~ wwxYw) zGet PostgreSQL connectionNz postgresql://r?r@:rN5432)hostportdatabaseuserpasswordzDatabase connection error: ) SPORTS_DB_URLrrpsycopg2connectr Exceptionrq) r^ user_passhost_dbrr host_portrrrconnr`s rGget_db_connectionr*s ##OR8 #:))C.#C YYs^ 7"-h%mmC0 8 ) "-JD$"F$DT    +A3/0sB+B55 C>CCrlrc,|r|sy|j}d}d}|D]i} |jd}|jdi}|jdi} |jdi} | jdrG| jdijd xs&| jdd jd dnd } | jdrG| jdijd xs&| jdd jd dnd } dd lm} | | |} | | |} |jdi}|jd}|jdrd}n*|jdrd}n|jdrd}nd}|jdi}t |jdtr!|jdijdn|jd}t |jdtr!|jdijdn|jd}t|}|rPtj|jdd}|jdk\r |jn|jdz }n/tjtj }|j}|j#d|j#d|f|j%}|r4|j#d||||d|d|d|d |dd!|df |dz }n5|j#d"|||| | |||||d|d|d|d |dd!f|dz }|j#d#l|j+|j-||fS#t $rYwxYw#t&$rM}t)d$|jdd%| |j#d&n#t&$rYnwxYwYd'}~d'}~wwxYw)(z Upsert games to SportsGame table)rrrrr~rrteamIDnamesshortr_UNK)normalize_to_fullstatusstartsAt completedlive cancelled scheduledscorerZz+00:00r zSAVEPOINT event_spze SELECT id FROM "SportsGame" WHERE "externalGameId" = %s a UPDATE "SportsGame" SET "homeScore" = COALESCE(%s, "homeScore"), "awayScore" = COALESCE(%s, "awayScore"), status = %s, "moneylineHome" = COALESCE(%s, "moneylineHome"), "moneylineAway" = COALESCE(%s, "moneylineAway"), "spreadHome" = COALESCE(%s, "spreadHome"), "spreadAway" = COALESCE(%s, "spreadAway"), total = COALESCE(%s, total), "oddsSource" = %s, "oddsUpdatedAt" = NOW(), "updatedAt" = NOW() WHERE id = %s rrrrra{ INSERT INTO "SportsGame" ( league, season, "gameDate", "homeTeam", "awayTeam", "externalGameId", "homeScore", "awayScore", status, "moneylineHome", "moneylineAway", "spreadHome", "spreadAway", total, "oddsSource", "oddsUpdatedAt", "createdAt", "updatedAt" ) VALUES ( %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, NOW(), NOW(), NOW() ) ON CONFLICT (league, season, "gameDate", "homeTeam", "awayTeam") DO UPDATE SET "externalGameId" = COALESCE("SportsGame"."externalGameId", EXCLUDED."externalGameId"), "moneylineHome" = COALESCE(EXCLUDED."moneylineHome", "SportsGame"."moneylineHome"), "moneylineAway" = COALESCE(EXCLUDED."moneylineAway", "SportsGame"."moneylineAway"), "spreadHome" = COALESCE(EXCLUDED."spreadHome", "SportsGame"."spreadHome"), "spreadAway" = COALESCE(EXCLUDED."spreadAway", "SportsGame"."spreadAway"), total = COALESCE(EXCLUDED.total, "SportsGame".total), "oddsSource" = EXCLUDED."oddsSource", "oddsUpdatedAt" = NOW(), "updatedAt" = NOW() zRELEASE SAVEPOINT event_spz Error upserting event z: zROLLBACK TO SAVEPOINT event_spN)rfrTr team_namesr ImportErrorrXdictrr fromisoformatrmonthyearrrrexecutefetchonerrqcommitclose)rrlrrfinsertedupdatedrrr~home_team_dataaway_team_data home_team away_teamr status_data start_timerr home_score away_scorer game_dateseasonexistingr`s rG upsert_gamesrKs. v [[]FHGBA yy+HIIgr*E"YYvr2N"YYvr2N CQBTBTU]B^""7B/33G<?""8R066s;A>di  CQBTBTU]B^""7B/33G<?""8R066s;A>di   8-i@ -i@  ))Hb1K$4J{+$(-$$IIgr*E?I%))TZJ[]a?b62.227;hmhqhqrxhyJ?I%))TZJ[]a?b62.227;hmhqhqrxhyJ$E*D$22:3E3Ec83TU +4??a+?Y^^VWEW$LL6 " NN/ 0 NN  (H  F)4+@&\(:DM$hqk (1  (FIy)j*f)4+@&\(:DM$ '4A  NN7 8sBH KKM LLN W ]  F  ,UYYy-A,B"QCH I ?@    saC;N=N-5IN=- N:6N=9N::N== P P'O98P9 PPPPPrc|r|sy|j}d}|D]} |jd|d|jd|d|d|jd|d|jd |jd d tj|jd if |j dkDr|d z }|j|j|S#t $r }Yd}~d}~wwxYw)z+Upsert player props to PlayerPropLine tablera INSERT INTO "PlayerPropLine" ( league, "gameId", "playerExternalId", "propType", market, "lineValue", "oddsAmerican", vendor, raw, "createdAt" ) VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, NOW()) ON CONFLICT (league, "gameId", "playerExternalId", vendor, "propType", "lineValue", "oddsAmerican") DO NOTHING rrrrrrrrrrr N) rfrrTrWdumpsrowcountrrr)rrrfrpropr`s rGupsert_player_propsrs u [[]FH  NNX 2D9K4LZ $((8"4d;6G($((8=M*N 488E2./  "A !( KKM LLN O    sBC C0+C0sourcec |r|sy|j}d}|D]z} tj|t}t j |j j}|jd|d|||f|jdkDr|dz }||j|j|S#t$r } Yd} ~ d} ~ wwxYw)z5Save raw events to ExternalFeedRecord for audit trailr)defaulta INSERT INTO "ExternalFeedRecord" ( source, kind, league, "contentHash", raw, "fetchedAt", "createdAt" ) VALUES (%s, %s, %s, %s, %s, NOW(), NOW()) ON CONFLICT (source, "contentHash") DO NOTHING rr N) rfrWrr]hashlibmd5encode hexdigestrrrrr) rrlrrrfrrraw_json content_hashr`s rGsave_to_external_feedr"s v [[]FH zz%5H";;x'89CCEL NN &&,A  C"A " KKM LLN O    sA7B99 C C c | tjd}|jdddd|jdd d |jd d d |jdd d |jdtdd|jdd d |j }t dt dt dt t}|j}|jddk7rt d|jdi|jrt}n|jjg}|jrdn t}|r t dn|js t dd}d}d}d} |D]} t j| | } t dd t d!| d"t d |j#| |j$|j&#} | st d$| |t d%t)| |t)| z }t+d&| D} t d'| |rGt-|| | \}}t d(|d)|d*||z }| |z } t/|| | }t d+||j0rhg}| D]}t3|}|j5| |rAt d,t)||t)|z }|rt7||}t d-|| st d.| dd/D]J}|jd0i}|jd1ijd2ijd3xs"|jd1ijd4d}|jd5ijd2ijd3xs"|jd5ijd4d}|jd6ijd7r%|jd6ijd7ddd8nd}t9|}t d9|d:|d;|d<t d=|d>d?|d@dA|dBdC|dDMt dEt dFt dt dG|t dH|t dI|t dJ| t dK|j:t dL|j<|j}|jdrt dM|d|r|j?yy)NNz"Fetch odds from SportsGameOdds API) descriptionrrrzLeague to fetch (default: nba))nargsrhelpz--props store_truezInclude player props)actionr&z--allzFetch all major leaguesz --alt-lineszInclude alternate linesz--limitrzMax events per request)typerr&z --dry-runzDon't save to databasez<============================================================zSPORTSGAMEODDS API ODDS FETCHERrQFz API Usage: rSz Connected to PostgreSQL databasez?WARNING: Could not connect to database, will only print resultsr z(========================================z Fetching z...)rdrez No events found for z Total events: c3DK|]}|jdsdyw)rr N)rT).0r`s rG zmain..XsBQAEE&MqBs  z Events with odds: z Database: z inserted, z updatedz External feed records: z Player props found: z Props inserted: z Sample events:rr~rrmediumrrrrz z @ z ()z ML: rrNrz | Spread: rz | Total: rz= ============================================================SUMMARYzTotal events fetched: zTotal player props: zDatabase inserts: zDatabase updates: zAPI requests made: zObjects used: zRemaining quota: ) argparseArgumentParser add_argumentr parse_argsrqr; SGO_API_KEYrrTr MAJOR_LEAGUESrrmdry_runr LEAGUE_MAPrx alt_linesrerZsumrr"rrrrrrrDrEr)parserargsclientusageleaguesr total_events total_propstotal_inserted total_updatedrrbrlevents_with_oddsrr feed_count all_propsrrprops_insertedr~rrstartr final_usages rGmainrKsj  $ $1U VF UAab  ,=ST  ;TU  lAZ[  S?WX  L?WX    D (O +, (O !+ .F    E yyu$ EIIfb1234 xx;;$$&'<<4%6%8D  01 \\ OPLKNM<LNN662  6(m )C() && "nn**'   *9+6 7   V ./F # B&BB $%5$678  ,T66 B Hg L +gYhG H h &N W $M/tVVDJ -j\: ; ::I (,U3  ' (.s9~.>?@s9~- %8y%IN.~.>?@  & ' L '2.yy,00"=AA(KwuyyY_acOdOhOhiqsvOwyy,00"=AA(KwuyyY_acOdOhOhiqsvOwMRYYW_acMdMhMhisMt (B/33JDSbIz}'.TF#dV2eWA67 4#8"94;P:QQ\]abn]o\ppz{AH|I{JKL Lk<L~ / ) (O "<. 12  ./ ~. /0 }o ./  4 45 67 N6../ 01""$Kv !+f"5!678   rI__main__)r)8rossysrWrsrr2rrrpathlibrtypingrrrr r?__file__parentENV_FILEexistsopenfrstrip startswithrkeyvalenviron setdefaultrTrr6rrqexitr9rrr7r;rrrrrrrr]rrr"rKr)kvs00rGr`sI& '66 > ' '& 0 ?? hF1 FDzz|DOOC$8SD[::<--c15S %%c399S>+?+?+DE FFzz~~79\] jjnn56  4b9  @A CHHQK 5 5 5 5   W   W  F 5 5 5 i l, l "  5!" 5#$ 5% ,&0%5%5%78TQAqD8'!*!*,>()M a.a.H x}  x (D(T(V%%d%PBOtDzO3OdT$ZBT C