o SLNi< @sddlZddlZddlZddlZddlmZmZddlmZmZm Z m Z ddl m Z ddl mZmZmZmZddlmZmZddlmZddlmZdd lmZdd lmZdd lmZeeZ d Z!e"e#d dZ$e"e#ddZ%e"e#ddZ&e"e#ddZ'e"e#ddZ(e"e#ddZ)e*Z+de"de"de"de"fddZ,d0de-d e-de ee-effd!d"Z.de e-fd#d$Z/d%e e-d&ede0fd'd(Z1d1d)d*Z2d1d+d,Z3d2d-e e"ddfd.d/Z4dS)3N)datetime timedelta)AnyDictListOptional) get_mongo_db)_get_global_user_id_get_global_account_id_get_global_zerodha_client_is_market_hours_ist)fetch_equity_index_symbolsshould_refresh_by_ttl)analyze_symbol_service)fetch_market_data) process_signal_and_market_update)normalize_confidence)score_market_datazNIFTY 50NIFTY50_REFRESH_MINUTES60NIFTY50_CRAWL_TTL_HOURS24NIFTY50_FRESHNESS_MINUTESNIFTY50_MAX_ANALYSES50NIFTY50_GPT_TOP_N25 NIFTY50_FEATURES_REFRESH_MINUTES10vlohireturncCs4zt|}Wn ty|YSwt|t||SN)int Exceptionmaxmin)rr r!r(@/var/www/html/Trade-python/app/v1/background/nifty50_intraday.py _clamp_int+s   r*NSEsymbolexchangec Cs|pd}|s dS|pd}t}|d||dp*|dd|i}|sE||dd|d}|d|}i|d |ji}|d set|d }|d d |d id d |ii||d <|d d t |ddd|dddddddddd} | r| dr| d| dp|| d| d| d| d| dp||d} |d d |d id dd| Di| dd| D|S) z@DB-only ensure for `stocks` + best-effort instrument enrichment.Nr+stocks)r,r-r,T)r,r-sector is_active created_at_idstock_id$setzerodha_instruments^$i)z$regexz$options) tradingsymbolr-r)r3instrument_tokenr:namesegment tick_sizelot_sizer-r<r:r=r>r?r@r-)r<r:r=r>r?r@r-instrument_updated_atcSi|] \}}|dur||qSr#r(.0krr(r(r) gz*_ensure_stock_identity..cSrBr#r(rCr(r(r)rFhrG)stripupperrutcnowfind_one insert_one inserted_idgetstr update_onereescapeitemsupdate) dbr,r-symnowstock stock_docinsertedsidinstpatchr(r(r)_ensure_stock_identity3sX&     * r^c Cs:t}ttdd}|ddti}t|tr|dnd}t|tr?t|dt r?t |||ds?dd |dpz(z3_refresh_constituents_if_needed..cSrer(rfrgr(r(r)rirjz/[NIFTY50] Failed ensuring stock identity for %snseindia)r`rbrasourcercr2)r5z $setOnInsertT)upsertz:[NIFTY50] Constituents refreshed | symbols=%d ttl_hours=%d)rrJr*CRAWL_TTL_HOURSrK _INDEX_NAME isinstancedictrNlistrr r^r%logger exceptionrPinfolen)rUrWrcdocrarbrVr(r(r)_refresh_constituents_if_neededmsF   rx stock_idscutoffcCs`|stSz|ddd|id|id}dd|pgDWSty/tdtYSw) Nstock_analysis_snapshotsr4$in$gter4 timestampcSsh|]}|rt|qSr()rOrDxr(r(r) sz-_latest_snapshot_stock_ids..z.[NIFTY50] Failed to compute fresh snapshot ids)setdistinctr%rsrt)rUryrzidsr(r(r)_latest_snapshot_stock_idss   rc%stsddlm}m}m}td|||dSt|}|s'tddSt|}|s4t ddSt |}|sAt ddSt |}t |d dd |iid d d d }d d |D} g} |D]} | | } | slqb| ddurtqb| | qb| stddSttd d} tt| d}g}| D]}t|d}|dpd} |r| sqi}zI|dj|d|idddgdd d d dd}|rt|dtr|dpi}n|rt|dtr|dpid|dpidd }Wn tyi}Ynw|rt|tr|ds<|dsndd?}!t|trW|!|d<<|t|d@|!|dA|dB|dCpu|dDpu| |dEdF|t|tr|dndt|tr|dnddG }"d}#z|d'|"}$t|$j(}#WntytdH| Ynwzt)||||| |t|tr|dnddFdI|#|"dJdK WntytdL| Ynw|d 7}qtdM|t*|dS)NNrbackend_market_window format_windowlocal_time_str:[NIFTY50] Backend skipped due to time | now=%s | window=%sz-[NIFTY50] No constituents available; skippingz;[NIFTY50] Skipping cycle: global Zerodha client unavailablez*[NIFTY50] Global user_id missing; skippingr/r,r|r;)r4r,r1cSs.i|]}|dr|dpd|qS)r4r,r.)rNrHrIrgr(r(r)rFs.z&_run_nifty50_cycle..r1Fz&[NIFTY50] No eligible stocks; skipping<)minutesr4r.r{r}r~)r)r3r)r3 market_datafeaturesr)sort projectionrr indicators strategies)rr)5minute15minuteday)zerodha_clientr, timeframesrU include_quotez'[NIFTY50] Feature compute failed for %s opportunity directionquality)r4r,scorerrz"[NIFTY50] No scored rows; skippingcSs$t|dpdt|dpdfS)Nrrr)floatrN)rr(r(r) $z$_run_nifty50_cycle..T)keyreverse2cSs$g|]}|drt|dqSr4)rNrOrr(r(r)rirz&_run_nifty50_cycle..)rzcs"g|] }t|dvr|qSr)rOrNr fresh_idsr(r)ris"z3[NIFTY50] Top ranked all fresh (<=%d min); skippingi)rr30minuterweekmonthzgeneral intraday analysisnifty50)rUrr,rquestioncontextuser_idinclude_market_dataz$[NIFTY50] Analysis failed for %s: %stargets confidencedecision_probabilityr)rrdecision entry_price stop_loss price_targettarget rationaleNIFTY50) r4rrrentryrrreasonrlanalysisrrz4[NIFTY50] Failed to persist analysis snapshot for %s60minuter) rUr account_idr4r,rrrlpreferred_timeframe snapshot_idsnapshot_timestampz0[NIFTY50] Paper trading simulation failed for %sz/[NIFTY50] Cycle finished | analyzed=%d stale=%d)+r app.v1.utils.market_timerrrrsrurxr errorr r rrfindrNappendr*rrrJrrOrHrIrKrprqr%rrtrrrrFRESHNESS_MINUTESrMAX_ANALYSES_PER_CYCLErrrLrMrrv)%rUrrrrbrrrr/ by_symboleligiblerVrowfeatures_refresh feat_cutoff scored_rowsrr[mdsnaprhtop_nrankedfreshness_minutesrz eligible_ids to_analyze max_per_cycleanalyzedrerprimary_targetconf snapshot_docrinsr(rr)_run_nifty50_cycles@   $      *  >               rcCszt}t|}zt|Wz|WdSty%tjdddYdSwz|Wwty<tjdddYww)Nz$[NIFTY50] Error closing DB generatorT)exc_info)rnextrcloser%rsdebug)db_genrUr(r(r)_run_nifty50_cycle_syncns    rinterval_secondsc s,tdIdHttdd}t|tr|dkr|n|d}td| tsFddl m }m }m }td |||t|IdHq$t rXtd t|IdHq$t 4IdH$z ttIdHWntywtd YnwWdIdHn 1IdHswYt|IdHq%) a@Background loop for NIFTY50 constituents. - Refreshes constituents list on a TTL (daily/weekly) via NSE API - Runs analysis only during IST market hours - Writes snapshots to `stock_analysis_snapshots` with source="NIFTY50" IMPORTANT: API endpoints must remain DB-only; this loop does Zerodha/GPT. Nrrrz0[NIFTY50] Background loop started (interval=%ss)Trrz:[NIFTY50] Previous cycle still running; skipping this tickz#[NIFTY50] Unexpected error in cycle)asynciosleepr*REFRESH_MINUTESrpr$rsrur rrrr _NIFTY50_LOCKlocked to_threadrr%rt)rrefresh_minutesintervalrrrr(r(r)nifty50_intraday_loopzs:    (r)r+)r"Nr#)5rloggingosrQrrtypingrrrrapp.db.databaser!app.v1.background.global_intradayr r r r app.v1.libraries.nse_indicesr rapp.v1.services.teGPTrrapp.v1.services.paper_tradingrapp.v1.utils.confidencerapp.v1.utils.symbol_rankingr getLogger__name__rsror$getenvrrnrrrrLockrr*rOr^rxrrrrrr(r(r(r)s>       $:0  D