#iu dZddlmZmZmZddlmZddlmZddl m Z m Z m Z m Z ddlZddlZddlZddlZddlZddlZddlmZ ddlZej.dd j1d k(Zej.d d j1d k(Zer es ed ned erdndej8j;ej8j=ej8j=ej8j?e ejBejDejFe$Z%dZ& ddl'm(Z(e(Z)e%jUd ddl-m-Z-e-j\Z/e/re%jUdne%jadedddZ1e1jeeddgd d!gd!g"dXd#e3d$e4fd%Z5dYd#e3fd&Z6d'Z7Gd(d)eZ8Gd*d+eZ9iZ:Gd,d-Z;Gd.d/Ze1j{d2d3Z?e1j{d4d5Z@e1jd6dZd7e4fd8ZBe1j{d9dXd#e3d$e4fd:ZCe1j{d;dYd#e3fd<ZDe1j{d=d>ZEe1jd?d@e8dAefdBZGe1jdCd@e9dAefdDZHe1j{dEdFe4fdGZIe1j{dHdIZJe1jdJd@e e4e ffdKZKdFe4d@e9fdLZLdMe4dNe e4e fdOe e e4e ffdPZMdMe4dNe e4e fdOe e e4e ffdQZNe$dRk(rddlOZOeOjdSdTdUd dVWyy#e$rdZYPwxYw#e$r!Z+e%jYde+dZ)YdZ+[+ZdZ+[+wwxYw#e$r#Z+e%jYde+dZ-dZ/YdZ+[+MdZ+[+wwxYw)[zn FastAPI Microservice for QuantEdge AI Provides high-performance NBA data processing and backtesting services )FastAPI HTTPExceptionBackgroundTasks)CORSMiddleware) BaseModel)DictListAnyOptionalN)datetimePRODUCTION_MODEfalsetrueALLOW_MOCK_DATAu2🚨 PRODUCTION MODE: Mock data fallbacks DISABLEDu#🔧 DEV MODE: Mock data fallbacks ENABLEDDISABLED)levelct|tr-|jDcic]\}}|t|c}}St|tr|Dcgc] }t|c}St|t r,|t dk(s|t dk(s||k7r |dkDrdSdS|S ddl}t||jr t|St||jr2t |}|t dk(s|t dk(r |dkDrdSdS|St||jr|jSt|dr|jS |Scc}}wcc}w#t$rY|SwxYw)zTRecursively replace infinity, NaN values and numpy types with JSON-compatible valuesinfz-infrgR?@gR?Nitem) isinstancedictitemsclean_infinity_valueslistfloatnumpyintegerintfloatingndarraytolisthasattrr ImportError)objkvrnpvals -/var/www/html/backtest/python_service/main.pyrr'sQ#t8; D1(++DD C 8;<%d+<< C  %, #v"63#: 1W6 1' 1   #rzz*3xC-Cj%,&#v*>%(1W69'9 C,zz|#f%xxz!& 1E<(    s<EE$$E! AE! E!E!%E!7E!! E.-E.)UniversalBacktestingEngineu2✅ UniversalBacktestingEngine loaded successfullyu1❌ Failed to import UniversalBacktestingEngine: ) cache_serviceu✅ Redis cache service enabledu4⚠️ Redis cache service disabled - using fallbacku$❌ Failed to import cache service: FzQuantEdge AI Python Servicez6High-performance NBA data and backtesting microservicez1.0.0)title descriptionversionzhttp://localhost:3000zhttp://localhost:3003T*) allow_originsallow_credentials allow_methods allow_headerslimitseasonc ~tr6tj||}|rtj d|d|d|St s[t rts tddtjddd d d d d dddg}trtj|||d|S dt jvrt jdd}|dd}t|trf|r$|Dcgc]}|jd|k(s|}}|d|}tr3tj|||tj d|d|d|St rts tdddd d d d d dddg} trtj| ||d| Scc}w#t$r"}tj!d|Yd}~qd}~wwxYw)z6Load NBA games data using the real engine with cachingu%✅ Cache hit for NBA games (season: z , limit: )zFNBA data service unavailable and mock data disabled in production mode status_codedetailz1Backtesting engine not available, using mock datazmock-001LALGSWz 2024-01-152023-24xshome)game_id home_team away_team game_dater6 home_score away_scorewinner ttl_hoursnba data_loaderN1dayr6u$💾 Cached NBA games data (season: zError loading NBA games: z=NBA API unavailable and mock data disabled in production modez fallback-001) CACHE_ENABLEDr, get_nba_gamesloggerinfoBACKTESTING_ENGINEr rrwarning set_nba_gamesmarket_enginesrrget Exceptionerror) r5r6 cached_data mock_datarNdatagameresulte fallback_datas r*load_nba_gamesrbjs#11&%@  KK?xyQVPWWXY Z   ?_  JK&"")#!!       ' ' 65A N6 &55 5,;;EB=QKtV,D$%-1RTTXXh5G65QDRDRfu!!//FKK"FvhiX]W^^_ `a R  &%  M##M65AN IS 6 04556s2AF&F F AF F F<F77F<c tr2tj|}|rtj d|d|Sddddddd d d d d dddddd d gd|}tr/tj ||tj d|d|S)z"Load NBA players data with cachingu&✅ Cache hit for NBA players (limit: r8 lebron_jamesz LeBron Jamesr=SFg<@gffffff @g333333&@)ppgapgrpg) player_idnameteampositionstats stephen_curryz Stephen Curryr>PGgL8@gffffff@g@Nu%💾 Cached NBA players data (limit: )rPr,get_nba_playersrRrSset_nba_players)r5r[r\s r*load_nba_playersrrs#33E:  KK@qI J  ("!#d;  )#!#c:   uI$%%i7 ;E7!DE ctr-tj}|rtj d|Sdddddddd ddd d d d ddddd dg}tr,tj |dtj d|S)z Load NBA teams data with cachingu✅ Cache hit for NBA teamsr=zLos Angeles Lakersz Los AngelesWestern)team_idrjcity conferencer>zGolden State Warriorsz San FranciscoBOSzBoston CelticsBostonEasternNYKzNew York KnickszNew YorkrKu💾 Cached NBA teams data)rPr, get_nba_teamsrRrS set_nba_teams)r[r\s r*load_nba_teamsrs#113  KK5 6 (!#  +##  $#  %#  'I8##I= 01 rscbeZdZUeed<dZeed<dZeeee fed<dZ eeee fed<y)StrategyRequest strategy_coderMmarketNparams time_period) __name__ __module__ __qualname__str__annotations__rrr rr rrsr*rr s@FC'+FHT#s(^ $+,0K$sCx.)0rsrceZdZUeed<eed<eeefed<dZeeeefed<dZ eeed<dZ eeed<dZ eeeefed <dZ eeeefed <dZ eeeefed <d Zeeed <y)BacktestRequest strategy_namerrNrr1hour timeframewalk_forward_configwalk_forward_periodsoptimization_configFuse_intrabar_ticks)rrrrrrr rr rrrrrrboolrrsr*rrs K cN,0K$sCx.)0#'M8C='&Ix}&48$sCx.1859(4S>2948$sCx.18)..rsrceZdZdZdZdZdZy) JobStatuspendingrunning completedfailedN)rrrPENDINGRUNNING COMPLETEDFAILEDrrsr*rrsGGI FrsrceZdZdedefdZy) BacktestJobjob_idrequestc||_||_tj|_t j |_d|_d|_ d|_ d|_ y)N) rrrrstatusr utcnow created_at started_at completed_atr_rZ)selfrrs r*__init__zBacktestJob.__init__%sH  '' "//+   rsN)rrrrrrrrsr*rr$ss_rsr/cVKddtjjdSw)zHealth check endpoint operationalz QuantEdge AI Python Microservice)rservice timestamp)r r isoformatrrsr*rootr/s+ 5__&002 s')z/healthcKtrdnd}trdnd}dddd||tjj d Sw) zDetailed health checkenableddisabledloadedrhealthyrnormalactive)ruptime memory_usage connectionsr,backtesting_enginer)rPrTr rr) cache_status engine_statuss r* health_checkr8sK!.9:L 2HM %+__&002 s?Az /cache/statscFKtsddiStjSw)zGet cache statisticsrZCache service not available)rPr, get_statsrrsr* cache_statsrHs& 677  " " $$s!z /cache/cleartypecKtsddiS|dk(rtj}n8|dk(rtj}n|dk(rtj}nddiSd||dSw) zClear cache by typerZrrMbacktestallz.Invalid cache type. Use: nba, backtest, or allT)success cache_type keys_cleared)rPr,clear_nba_cacheclear_backtest_cacheclear_all_cache)rcleareds r* clear_cacherPsx 677 u}//1  446 //1IJJ sA#A%z /nba/gamescK t||}d|t|dS#t$r*}tj d|t ddd}~wwxYww)zGet NBA games dataTrr]countzError fetching NBA games: zFailed to fetch NBA gamesr:N)rblenrYrRrZr)r5r6gamesr`s r*rQrQesd Quf-Z  Q 1!564OPPQs$AA A%A  AAz /nba/playerscK t|}d|t|dS#t$r*}tj d|t ddd}~wwxYww)zGet NBA players dataTrzError fetching NBA players: rzFailed to fetch NBA playersr:N)rrrrYrRrZr)r5playersr`s r*rprpssb S"5)\  S 3A3784QRRSs$AA A%A  AAz /nba/teamscK t}d|t|dS#t$r*}tj d|t ddd}~wwxYww)zGet NBA teams dataTrzError fetching NBA teams: rzFailed to fetch NBA teamsr:N)rrrYrRrZr)teamsr`s r*r~r~s` Q Z  Q 1!564OPPQs$AA A%A  AAz/strategy/executerbackground_taskscK tjd|jd|jdk(r4t|j|j |j d{}n3t|j|j |j d{}d|ddS7>7 #t$r6}tjd|td dt| d}~wwxYww) zExecute a dynamic strategyz Executing z strategyrMNT2)rr_execution_time_mszStrategy execution failed: rr:) rRrSrexecute_nba_strategyrrrexecute_financial_strategyrYrZrr)rrr_r`s r*execute_strategyrs\ j 0 :; >>U "/0E0Ew~~W^WjWjkkF5g6K6KW^^]d]p]pqqF!#  lq \ 21#676QRUVWRXQY4Z[[\sMC)A B'$B#%3B'B% B'"C)#B'%B'' C&01C!!C&&C)z /backtest/runcK tjd|jd|jts t dd|j jddxsF|j jddxs(t|j jd d d kD}|rutd ttj}t||}|t|<td ||jt ||tdd|ddddS |j"xs |j$}tj'|j|j|j |j jdd|j(||j*|j,|j. }t5|t6rd#|vrt d$|d#t9|}d|d%d&S#t0$r}tj3dt|ddt|d d d dt|dgdi|jd|jidt|t|ggddid d! cYd"}~Sd"}~wwxYw#t $rt0$r6}tj3d'|t d(d't|d"}~wwxYww))z/Run a backtest using UniversalBacktestingEnginezRunning z backtest for r9 Backtesting engine not availabler: run_asyncF large_dataset data_filerz0DEBUG: Creating background job for large datasetz&DEBUG: Adding background task for job z)DEBUG: Background task added successfullyTacceptedzPBacktest started in background. Use /backtest/status/{job_id} to check progress.z30-120 seconds)rrrmessageestimated_time min_trades rr parametersrrrrrrzBacktest execution failed: Visualization failed: z3Backtest core succeeded, but visualization failed: ) total_tradeswin_rate total_profitnotez+Backtest completed with visualization error on z5Strategy executed successfully, visualization error: rzChart generation failed)rZ price_datatradessummary) rrZresultsrperformance_summary risk_metricsequation_summarydetailed_statistics trade_logchart_visualizationNrZd)rrrzBacktest failed: r)rRrSrrrTrrrXrprintruuiduuid4r job_storeadd_taskrun_backtest_backgroundrr run_backtestrrrrrYrZrrr)rrrun_in_backgroundrjobwalk_forward_datar_r`s r*rrs]R hw~~.nW=R=R>">>--lB?!++%6$+$?$?#*#=#=%335 FL fd #6(9CwH H'v.!$  C  LL6s1vh? @ 1#a&:$% !$%QRUVWRXQYZ  'T "'.'<'<&=T'..AQ$R')TUXYZU[T\] V"$ &(AB (  N  R (,-6GAx4PQQRsgKDJ K"BG/:4J.K/ J8A?I=7J8J<K=JJK 1KK  Kz/backtest/status/{job_id}rchK|tvr tddt|}||j|jj |j j |j jd}|jr|jj |d<|jtjk(r.|jj |d<|j|d<|S|jtjk(r,|jj |d<|j|d<|Sw) z'Check status of background backtest jobiz Job not foundr:)rrrrstrategyrrrrZ)rrrrrrrrrrrrr_rrZ)rr responses r*get_backtest_statusrsYODD F C**nn..0++$$KK-- H ~~!$!9!9!; zzY(((##3#=#=#? !jj O y'' '##3#=#=#? II OsD0D2z/backtest/jobsc Kg}tjD]\}}|j||j|jj |jj |jj|jr|jjnd|jr|jjndd|t|dSw)zList all backtest jobsN)rrrr rrr)jobstotal) rrappendrrrrrrrrr)rrr s r*list_backtest_jobsr#s D (   jjkk(( 11..2248;#..224D6QRUVWRXQY4Z[[\swG/CF$ 7D=G/;D=<G/=F!!E=7F!8F$<G/=!F!F$G/ F!!F$$ G,-:G''G,,G/c. K td|tdttj|tvrtd|dyt|}td|tj |_tj|_ tjd|d|jtd t|d dxs t|d d}td |jtj!|j|j"|j|jj%d d|j&||j(|j*|j, }tdt/|t0rt|jn t3||j%d|j%dg}|j%dddi}d|vs|j%ds tj4j%|ji}|rd|vr|r|d}||jj%d|j&|j*} | rt7| dkDr~ddl} t/| tr| j;| } n| } tj=|| |j}tjd|dt7|j%dgd|j%dd|j%dd|j%d d|j%d!d|j%d"d|j%d#d|j%d$d||d%|j%ddd&|j%ddd'|j%d$d|j%d#d|j%d"dd(|j"d)|j|d*d+} tE| |_#tjH|_tj|_%tjd,|d-t7|d.y#t>$r6} tjAd|d| ddtC| i}Yd} ~ d} ~ wwxYw#t>$rl}tjMd/|d0tC|tjN_tC||_&tj|_%Yd}~yd}~wwxYww)1zBackground task to run backtestz/DEBUG: run_backtest_background STARTED for job z DEBUG: Available jobs in store: z ERROR: Job z not found in job_store!NzDEBUG: Found job in store: u&🟡 Starting background backtest job z for z!DEBUG: About to call run_backtestrrz8DEBUG: Background job calling run_backtest with params: rrrz/DEBUG: run_backtest returned result with keys: all_tradesrrrZzVisualization not availablerNrru1✅ Regenerated visualization for background job r$z trades plottedz6Could not regenerate visualization for background job rrrravg_profit_per_trade profit_factor sharpe_ratio max_drawdownzBackground backtest completed: z trades, z % win rate)r4r3r2rz7Strategy executed successfully in background processing)rrrr1r2r3r4rrrrrrru✅ Background backtest job z completed successfully with z trades visualizedu❌ Background backtest job z failed: )(rrrkeysrrrr rrrRrSrgetattrrrTrrrXrrrrrrrrWrpandas DataFrame"_generate_trade_visualization_datarYrUrrr_rrrZr)rrr r r_rr market_enginerN data_sourcepddata_df viz_errorcomplete_resultr`s r*rr~sd- ?xHI 0inn6F1G0HIJ  " Kx'?@ A  +F845&& !* >!//~~~~)),;''!2 ' ; ;&99!//1   ?WabhjnWoV[[]@Suy{AvB@CD EL&**Xr*BC$jj)>Jg@hi ) )1D1H1H1R [ 2 A A E EgnnVX Y  ]m%C"/ ">K"-**;7))22#K #s;'7!';+%k48&(ll;&?G&1G.@.c.c"GW^^/+ &WX^W__abefyf}f}GIKgLcMbNN]%^_#JJ~q9 :q1"JJ~q9$*JJ/Eq$I#ZZ;"JJ~q9"JJ~q9#6%DVZZP^`aEbDcclmsmwmwyCEFnGmHHR$S & >1 = & >1 =!'OQ!? $+#8#8"9gnn=M N#)R% *+?; (( #??, 26(:WX[\bXcWddvwx= [!WX^W__abkalmn'.2HYHX0Y&Z# [@ - 3F89SVHMN%% F #??, -siTARTF2RC,LLTSYZ " % +"("& !   D9#a&BCCDs5B8A,BB8 BB8 B5B00B55B8c Kts td dddddddd d d gd S#t$r}td t|d}~wwxYww)zExecute financial strategy codergףp= ?g?z2024-01-15T10:00:00ZAAPLBUYg?g0g@)rsymbolactionrI entry_price)signals_generatedrrr2recommended_signalsz%Financial strategy execution failed: N)rTrYr)r@rrr`s r*rrsx :;;J"$ "8$#"&#) $    J?AxHIIJs$A $A  A AA  A __main__zmain:appz0.0.0.0i@rS)hostportreload log_level)rr?)r)r)Q__doc__fastapirrrfastapi.middleware.corsrpydanticrtypingrr r r rasynciologgingsysosrr r'r$getenvlowerr rrpathrdirnameabspath__file__ basicConfigINFO getLoggerrrRruniversal_backtestingr+rTrSr`rZr,rrPrUappadd_middlewarerrrbrrrrrrrrrXrrrdeleterrQrpr~r(rrrrr.rrruvicornrunrrsr*rzs <;2,,   "))-w7==?6I"))-v6<<>&H? >? /_ R\/] ^_0I JKL',,'   8 $<@35 KKDE +!))M 56MN  'H *,CD%% P#PSPd C D)V1i1 /i /      %%NC( Qs Q# Q Q S S S Q Q \O\\\*/_R_R?_R_RB $%c&6 ..  G\4S>G\G\Rf-#f-f-PDSD$sCx.DxX\]`be]eXfOgDBJ3JS#XJU]^bcfhkck^lUmJ4 zGKK   [Hj LLDQCHI LL7s;<MMsBNN$7ONNO!N==OO- O((O-