!+idZddlZddlmZmZddlmZmZddlmZddl m Z ddl m Z ejeZGd d Zy) zv Hyper Forecast - Momentum Calculator Calculates short-term trend adjustments based on recent performance vs expected N)datetime timedelta)DictOptional)Session) DataCollector)BaselineCalculatorcJeZdZdZdefdZ d dededefdZ d dedefd Z y ) MomentumCalculatorz Calculates momentum multiplier based on recent sales vs expected If recent hours are performing above/below expectations, adjust future predictions dbcR||_t||_t||_y)N)r r data_collectorr baseline_calc)selfr s X/var/www/hypershopcomercio.com.br/hyper-ai/app/services/forecast/multipliers/momentum.py__init__zMomentumCalculator.__init__s#+B//3hours_lookbacksmoothing_factorreturnc tj}|j}|j}|dkrdddidSd}d}d}g} t dt |dz|dzD]} || z } |j j|| } | d} |jj| |}|d}|dkDsP|| z }||z }|dz }| j| d d | ||dkDr| |z ndd |dk(s|dk(rddd | dS||z }|dz }||z}d|z}td t d|}|dkDrd|dz dzdd|d }d}n|dkrdd|z dzdd|d }d}nd}d}t dd|dzz}t|dt|d||||||| d S)aY Calculate momentum multiplier based on last N hours performance Args: hours_lookback: How many recent hours to analyze smoothing_factor: How much to dampen the adjustment (0.5 = half the deviation) Returns: Dict with momentum multiplier and analysis details ?g333333?u$Dados insuficientes (início do dia)) multiplier confidencereasondetailsrrevenuebaseline02dh)houractualexpectedratiou)Sem baseline histórico para comparaçãogffffff?gffffff?g?zVendas dz.1fu!% acima do esperado nas últimas upgffffff?u"% abaixo do esperado nas últimas downzVendas dentro do esperadoneutralg?g?g?) r raw_ratio actual_totalexpected_totalhours_analyzed directionrrr) rnowr#daterangeminrget_hourly_salesrcalculate_baselineappendmaxround)rrrr1 current_hourtodayr-r.r/r hour_offsetr#r$actual_revenuer expected_revenuer, deviationsmoothed_deviationrrr0rs rcalculate_momentumz%MomentumCalculator.calculate_momentumsUllnxx   ! !!@    C(:L1>\_  ! . Q .A"5!!E"  !>1 O &)99-- s445   Q# 5s;;\]k\llmnFI $ Y# 5s;;]^l]mmnoFI0F!Ic^c%9:;  A.y!,(,,"$  r days_lookbackcddddS)z Calculate correction factor based on recent prediction errors If the model consistently over/under-predicts, apply a correction rgu*Correção de erro não implementada ainda)correction_factor avg_errorr)rrBs rcalculate_error_correctionz-MomentumCalculator.calculate_error_corrections"%B  rN)g?)) __name__ __module__ __qualname____doc__rrintfloatrrArGrFrrr r s] 474 "%e e  e   e R    rr )rMloggingrrtypingrrsqlalchemy.ormrrr r r getLoggerrJloggerr rFrrrUs<(!"*)   8 $B B r