o SLNi* @s\ddlZddlZddlZddlmZmZddlmZmZmZm Z m Z ddl m Z ddl mZmZmZddlmZddlmZeeZeedd Zeed d ZdZeZd eeefd eeeffddZ d eefddZ!deed eeeeefffddZ"d"deededed e efddZ#d#ddZ$d#ddZ%d$ded dfd d!Z&dS)%N)datetime timedelta)AnyDictListOptionalSet) get_mongo_db)_get_global_user_id_get_global_zerodha_client_is_market_hours_ist)analyze_symbol_service)normalize_confidencePORTFOLIO_INTRADAY_MAX_ANALYSES200$PORTFOLIO_INTRADAY_FRESHNESS_MINUTES30analysisreturncCst|tsiS|dp|dpd}t|}|dkr!|Sd|d<d|d<d|d<d|d<d}z|d }|d urFt|tsFt|}Wn tyRd}Ynwt |d |d <d D] }||vrfd ||<q\|d pmd}d}|r||d|n||d <|S)zPortfolio constraint: never publish short/SELL signals. If the upstream analysis suggests SELL, we downgrade to HOLD and clear any execution fields so consumers (alerts, UI, paper trading) don't treat it as an actionable short. decisionactionHOLDSELLLOW confidence convictiongscoreNgC@) entry_price entry_zone stop_lossstop_loss_zone price_targettargettargets exec_entryexec_sl exec_targets trend_label rationalez9[portfolio:no-shorting enforced: SELL downgraded to HOLD] ) isinstancedictgetstrstripupperboolfloat Exceptionmin)rr score_val raw_scorekr(suffixr9B/var/www/html/Trade-python/app/v1/background/portfolio_intraday.py"_enforce_no_shorting_for_portfolios8    r;cCsvz|dddddid}WntytdgYSwg}|p%gD]}t|tr8|r8||q&|S)zsz(_run_portfolio_cycle..zP[PortfolioIntraday] Universe=%d eligible=%d fresh=%d freshness_minutes=%d cap=%drzB[PortfolioIntraday] Reached per-cycle cap (max=%d); stopping earlyrN)5minute15minute30minutedayweekmonthzgeneral portfolio analysisportfolio_intradayT)rDzerodha_clientrN timeframesquestioncontextuser_idinclude_market_dataz.[PortfolioIntraday] Analysis failed for %s: %s market_datafeaturesrdecision_probabilityr)rxrr#rrrr!r"r( PORTFOLIO) r=rXrrentryrr"reasonsourcerrvrwrWz>[PortfolioIntraday] Failed to persist analysis snapshot for %sz0[PortfolioIntraday] Cycle finished | analyzed=%d)!rAinfor errorr rHrSrutcnowrmaxintFRESHNESS_MINUTESrclistkeysr\MAX_ANALYSES_PER_CYCLErZsortedr-r.r/r0r]r r3rBr+r,rr; insert_one)rDrprtrI stocks_by_idrU eligible_idsanalyzed seen_symbolsrGstockrNsym_keyrervrwconfr#primary_target snapshot_docr9rfr:_run_portfolio_cycles              rcCszt}t|}zt|Wz|WdSty%tjdddYdSwz|Wwty<tjdddYww)Nz.[PortfolioIntraday] Error closing DB generatorT)exc_info)r nextrcloser3rAdebug)db_genrDr9r9r:_run_portfolio_cycle_sync s    rinterval_secondsc stdIdHtd| ts1ddlm}m}m}td|||t|IdHqt rCtdt|IdHqt 4IdH$z t t IdHWnt ybtd YnwWdIdHn 1IdHsswYt|IdHq) aBackground loop for global portfolio-driven analysis. - Universe: distinct ACTIVE portfolio stocks across all users (deduped by stock_id) - Skips symbols with a recent snapshot (<= PORTFOLIO_INTRADAY_FRESHNESS_MINUTES) - Runs only during IST market hours (same gate as ET/global loops) Start from FastAPI startup via `asyncio.create_task(portfolio_intraday_loop(...))`. Nz:[PortfolioIntraday] Background loop started (interval=%ss)Tr)backend_market_window format_windowlocal_time_strzD[PortfolioIntraday] Backend skipped due to time | now=%s | window=%szD[PortfolioIntraday] Previous cycle still running; skipping this tickz-[PortfolioIntraday] Unexpected error in cycle)asynciosleeprAr}r app.v1.utils.market_timerrr_PORTFOLIO_INTRADAY_LOCKlocked to_threadrr3rB)rrrrr9r9r:portfolio_intraday_loops6   (r)rT)rN)r)'rloggingosrrtypingrrrrrapp.db.databaser !app.v1.background.global_intradayr r r app.v1.services.teGPTr app.v1.utils.confidencer getLogger__name__rArgetenvrrISTLockrr.r;rHrSrcrrrr9r9r9r:s*    "4&$  s