v j1x< dZddlZddlmZmZddlmZmZddlmZddl m Z ddl m Z ejeZej dd g d Zej d d g d Zej dd g defdZej dd g dZej dd g dZej dd g dZej dd g dZej dd g dZej dd g defdZej ddg defdZej d d!g defd"Zej d#d g d$Zej d%d g d&Zej d'd!g d(Z ej d)d!g d*Z!ej d+dg d,Z"ej d-d!g d.Z#ej d/d!g d0Z$ej d1d g d2Z%ej d3d g d4Z&ej d5d g d6Z'ej d7d g d8Z(ej d9d:g d;Z)ej dd g d?Z+ej d>d!g d@Z,ej dAd:g dBZ-ej dAdg dCZ.ej dDd!g dEZ/ej dFd g dGZ0ej dHd g dIZ1ej dJd!g dKZ2ej dLd g dMZ3ej dNd g dOZ4ej dPd:g dQefdRZ5ej dSd!g dTZ6ej dUd!g dVZ7ej dWd g dXZ8ej dYd g dZZ9ej dYd!g d[Z:ej d\dg d]Z;y)^zM Hyper Forecast API Endpoints Provides sales forecast data for the dashboard N)jsonifyrequestdatetime timedelta)api_bp) SessionLocal HyperForecastz/forecast/todayGET)methodsct} tdt|}|j}t d|d|j S#t $rm}ddl}|jtjd|td|t dt|d d fcYd}~|j Sd}~wwxYw#|j wxYw) zi Get today's forecast with actuals and projections Perfect for the dashboard cash flow chart zDEBUG: Hit /forecast/todayTsuccessdatarNzError generating forecast: z*DEBUG: CRITICAL ERROR in /forecast/today: Frerror) r printr get_today_with_actualsrclose Exception traceback print_excloggerrstrdbforecastresulters H/var/www/hypershopcomercio.com.br/hyper-ai/app/api/endpoints/forecast.pyget_today_forecastr#s B *+ $002      21#67 :1#>?V        s03A CAC+C,C CC Cz/forecast/today/productsct} t|}|j}| tddddf|j Std|d|j S#t $r_}ddl}|jtjd |tdt|dd fcYd}~|j Sd}~wwxYw#|j wxYw) aa Get today's forecast based on individual product predictions. This method considers stock availability - products without stock = R$0 Returns: - total_forecast: Sum of all product forecasts - lost_to_stock: Revenue lost due to out-of-stock products - breakdown: Top products with their individual forecasts NFz.Product forecast not available, run sync firstrTrrz#Error generating product forecast: r) r r get_product_based_forecastrrrrrrrrrs r"get_today_product_forecastr'-s B $446 > I&        :1#>?V        s6,A' A'' C0AC 4C5C CCC$z/forecast/day/ target_datecVt} tj|dj}tj j dd}t|}|j||}td|d|jS#t$r-}tdd|dd fcYd}~|jSd}~wt$rK}tjd |tdt|dd fcYd}~|jSd}~wwxYw#|jwxYw) z* Get forecast for a specific date %Y-%m-%dcategoryNTrFzInvalid date. rr%zError generating day forecast: r)r rstrptimedaterargsgetr predict_dayrr ValueErrorrrrr)r(r parsed_dater+rr r!s r"get_day_forecastr3Ts B'' Z@EEG <<##J5 $%%k8<  "   %aS)        6qc:;V        sHA.B DB<&D'D< D0D8D9DDDD(z/forecast/chart-datac@t} tdt|}|j}t dDcgc]}|dd }}|j dd}|ddDcgc]}|d  }}d gdz}|dj d gD]}d |vsd |vs |d ||d <d gdz}|dj d gD] } d | vsd| vs | d |kDs| d|| d <"d gdz} d gdz} |dj d gD]>} d | vs| d |kDs| j d| | d <| j d| | d <@tdt d||||| | d||j dd|j dd|j dd|j dd|j dd|j dd|j d|j dd dd|jScc}wcc}w#t$rm} dd l } | jtjd| td | t d!t| d"d#fcYd } ~ |jSd } ~ wwxYw#|jwxYw)$z< Get formatted data for the CashFlowChart component zDEBUG: Hit /forecast/chart-data02dh current_hourrhourlypreviousrevenueNactualshour predictions predictionminmaxz'DEBUG: Chart data prepared successfullyT)r:actualrconfidence_minconfidence_max actual_totalprojected_total projected_min projected_maxvs_previous_percentavg_confidence peak_hour valley_hour) r8rErFrGrHrIrJrKrL)labelsdatasetssummaryrzError generating chart data: z/DEBUG: CRITICAL ERROR in /forecast/chart-data: Frr)r rr rranger/rrrrrrrr)rrrr7rMr8 previous_data actual_data forecast_dataprCrDr!rs r"get_forecast_chart_datarUus BE /0 $..0(-Ry1!QsG1+11xx2 04H~j/IJ!9J Jfrk h##Ir2 6A{yA~)*9 AfI& 6  h##M26 ?A{|q0V9|+/0M!F), ? ""h##M26 :A! & L 8-.UU5\& *-.UU5\& * : 78 -) -&4&4 %1$(HH^Q$?'+xx0A1'E%)XXoq%A%)XXoq%A+/884I1+M&*hh/?&C!%+!6#'88M#:   F  2Kb  4QC89 ?sCDV        sx3H H H* H 6$HH /HHH5HHCH H JAJ-J.J JJ Jz/forecast/projection/todaycddlm}m}ddlm}m}ddlm}t} td|j}|j}|j}g} d} t|dzD]} |j||jjj!| } | |dz} |j#|j%|j&j)||j*| k\|j*| k|j,j/gd j1}t3|xsd}| |z } | j5| | d d t7|d d d g}d}t9|}t|dzdD]=} |j;| |}|j5| | d d |d|ddd||dz }?| |z}||dz }|j||jj}|j||j<j}|j#|j%|j&j)||j*|k\|j*|k|j,j/gd j1}t3|xsd}|dkDr ||z |z dznd}tdt?d|| |t7| d t7|d t7|d t7|d t7|dddd|jAS#tB$rm}ddl"}|jGtHjKd|td|t?dtM|dd fcYd}~|jASd}~wwxYw#|jAwxYw)!z: Get real data + projections (Alternate endpoint) rrfuncand_)MlOrderz%DEBUG: Hit /forecast/projection/today)r=hourspaidshipped deliveredr6r7real)hora hora_labelreceitatipor5r? confidenceprojecao)rdrereceita_prevista confiancargdaysdz(DEBUG: Projection generated successfullyT)receita_realizadareceita_projetada_restantereceita_projetada_fim_dia receita_ontemvariacao_vs_ontem) hora_atual dados_reaisritotaisrNzError getting projection: z5DEBUG: CRITICAL ERROR in /forecast/projection/today: Frr)'rr sqlalchemyrXrYapp.models.ml_orderrZr rnowr-r=rPcombiner@timereplacequerysum total_amountfilter date_closedstatusin_scalarfloatappendroundr predict_hour_with_loggingrArrrrrrrr)rrrXrYrZrrytodayr8rureceita_total_realr7 hour_starthour_endrfrireceita_projetadarpredreceita_fim_dia yesterdayyesterday_start yesterday_endrrvariacao_ontemr!rs r"get_today_projectionrs -%+ B` 56hlln xx  |a'( A)))%1B1B1DEMMSTMUJ!IA$66Hhhtxx(<(<=>EE'':5''(2NN&&'GH fh GLq)G ' )    !"3qk !,    . $|a', 4A55a?D OO!"3qk$($6!,/"   l!3 3  4-/@@I1-- *(**9hll6G6G6IJ(((HLL4E4E4GH '*>*>!?@GG ##6##}4""#CD  &( m0q1 VcfgVg?]:mKcQmn 89**$)./A1)E278I12M161J%*=!%<).~q)A    4    1!56 EaSIJV        s1LM N<AN7!N<"N?7N<<N??Oz/forecast/learning/multiplierscddlm}t} |j|j |j |j j}tdd|Dcgc]l}|j |j t|j|j|j|jr|jjnddnc}id|jScc}w#t $rK}t"j%d|td t'|d d fcYd}~|jSd}~wwxYw#|jwxYw) z_ Get all active multipliers with their current values For the Hyper AI admin panel rMultiplierConfigT multipliersN)rgchavevalorfonterk atualizado_emrzError getting multipliers: Frr)app.models.forecast_learningrr r}order_byrgrallrrr calibradorkr isoformatrrrrr)rrconfigscr!s r"get_multipliersr0s4 > B((+,55  ! !  " "  #%   '  !"!"!&qww!"%&[[HI)B)B)D]a     .  )   21#67V        sCAC0 A1C+  C0+C00 E90D?)E*E?EEEz&/forecast/learning/calibration-historycddlm}t} |j|j |j j jdj}tdd|Dcgc]}|j|j r|j jnd|j|j|jrt|jnd|j rt|j nd|j"rt|j"nd|j$|j&d c}id|j)Scc}w#t*$rK}t,j/d |td t1|d d fcYd}~|j)Sd}~wwxYw#|j)wxYw) zT Get calibration history (last 50 entries) For the Hyper AI admin panel rCalibrationHistory2T historicoN) idr tipo_fator fator_chavevalor_anterior valor_novo erro_medioamostrasnotasrz#Error getting calibration history: Frr)rrr r}rdata_calibracaodesclimitrrrrrrrrrrrrrrrrr)rrhistoryr7r!s r"get_calibration_historyrYs| @ B((-.77  . . 3 3 5 %)CCE  '  ddABARAR 1 1 ; ; =X\&'ll'(}}EFEUEU%0@0@*A[_=>\\eALL&9t=>\\eALL&9t$%JJ!"    4  /   :1#>?V        sCA E2CE EE F3(0F.F3F6.F33F66Gz/forecast/learning/logsc: ddlm}m}ddlm}m}ddlm}t} ttjjdd}ttjjdd}tjjd d }tjjd } tjjd } |j|} | r.| j|j|j| k\} | r.| j|j|j| k} |d k(r+| j|j j#d} n|dk(r+| j|j j%d} nS|dk(rN| j||j&j%d|j&dkD|j&dkz} | j)} tjjdd} tjjdd}ddlm}m}m}m}|dk(r|n|}| dk(rp|t0j3|j&}| j5||j7|dz |zj9|j;}n| dk(rU| j5||j<j7|dz |zj9|j;}nT| dk(rZ| j5|||j j7|dz |zj9|j;}n| d k(r||j j#ddft0j3|j&dkDdfd}| j5|||jj7|dz |zj9|j;}nS| j5||jj7|dz |zj9|j;}|j>fd}tAd|D}|rtC|tE|z dzdnd}tGd | ||| |zdz |z|tE||d!|Dcgc] }|jH|jJr|jJjMnd|jr|jjMnd|j<rtO|j<nd|j rtO|j nd|j&rtO|j&nd|||jPrtO|jPnd|jR|jTxsitW|d"d#tW|d$dd% #c}d&d'|jYScc}w#tZ$rK}t\j_d(|tGd)ta|d*d+fcYd}~|jYSd}~wwxYw#|jYwxYw),zt Get paginated list of forecast logs with filters Perfect for the detailed logs table in Hyper AI panel rrrYr ForecastLogpager[per_pagerr date_fromdate_topendingN reconciled high_errorisort_by hora_alvo sort_orderasc)rrcase nullslastrrvalor_previsto valor_realrb)else_c|j/|jr"tt|jdkDryy|jkryy)Nrrrawaitingr)rerro_percentualabsrr)logrys r" get_statusz%get_forecast_logs..get_statussE~~)&&3uS5H5H/I+JR+O'#$! c3BK|]}t|dddk(sdyw) calibratedNYr[N)getattr).0rs r" z$get_forecast_logs..s![SGCs4SWZ4Zq[srnT)rtotal percentagerrcalibration_impact) rtimestamp_previsaorrrrrbaseline modelo_versaofatores_usadosrr)rrr total_pagescalibration_statslogsrzError getting forecast logs: Frr)1rrrwrYrrrr intrr.r/r}rr fromisoformatris_isnotrcountrrrrXrroffsetrrrryr~rlenrrrrrbaseline_usadorrrrrrrr)rrrYrrrrr status_filterrrr}rrrsql_ascsql_descrr order_func order_clauser status_orderrcalibrated_countcalibration_pctrr!rys @r"get_forecast_logsrs -%8 B~7<<##FA./w||'' B78 ((59 LL$$[1 ,,""9-% LL!6!6:P(:P:PQZ:[![\E LL!6!6:P(:P:PQX:Y!YZE I %LL!7!7!;!;D!ABE l *LL!7!7!=!=d!CDE l *LL//55d; 0025+:U:UX[:[\E ,,""9k:\\%%lE:  QP!+v!5X7 g %dhh{/J/J&KLL>>)L"9:AAX%eHocce ( (>>*[-G-G"HIPPX%eHocce  $>>)J{7M7M,N"OPWWX%eHocce  ''++D115+556;Q?L >>, ;;P;P0QRYYX%eHocce  >>*[-B-B"CDKKX%eHocce  hlln ![D[[LP%!1CI!=!CaHVW$ % 01 4A"2 Y"1&&"&"ffTWTjTjc.D.D.N.N.PptBE--S]]%<%<%>UYGJGYGY%0B0B*C_`?B~~eCNN&;SWILI\I\51D1D+Ebf",S/ADASASE#*<*<$=Y]),):):*-*<*<*B&-c<&E.5c;OQU.V   L  5&  4QC89V        sCSX1+D&X, X1,X11 Z:0Z*Z+ZZZZz$/forecast/learning/logs/log_idc ~ddlm}ddlm}ddlm}t } |j |j|j|k(j}|s tddddf|jS|j}|j2|jr#tt!|jd kDrd nd }n|j"|krd }nd}t%|dd xsg}t%|dd} |s|j"r ddlm} ddlm}  |j*xsi} ddlm} m} ddlm}ddlm}m}| | d}|j"}|| dz}|j4[|j7|}|j7|}|j9| j:}|j9| j:}n6|j9| j:}|j9| j:}|j7d }|j7d }|j |j<|j>|j@jC|j||jD|k\|jD|k|jFjIgdjK}i}i}|D]r\}}}t!|xsd}|jM|d|z||<|s1tO|jQjS}|s[|jM|d|z||<t|j*xsi} | jMdg}i} |r|D!cgc]%}!|!jMds|!jMd'}"}!|"rwddl*m+}#|j |#jX|#j@j|#jXjI|"jK}$|$D%&cic]\}%}&|%|& } }%}&g}'|r}|D]r}!|!j[}(tO|!jMdjQ})|jM|)d}*|*dk(rg | jM|)}+|+s|!jMd}+|+r@tO|+jQjS},|,r|,d k7r|jM|,d}*|*dk(r |*dk(rytO|!jMd"d#jS}.d$|.vrLd%|.vrH|D]C\}}}tO|xsd#jS}/d&|/vs)d'|/vsd(|/vs2|*t!|xsdz }*E|*|(d*<|*dkDxr|!jMd+dd,kD|(d-<|'ja|(u|'| d<t%|ddd/k(} t%|dd }| jMdxsg}1t_d0|1D]T}!tO|!jMd"d#}2d&|2vs#t_d1|2d2|!jMdd3|!jMd*Vtd4|j|jbje|j"jet!|jfxsd|jt!|jnd |jt!|jnd | | |d5 d6|jScc}!wcc}&}%w#t\$r}-t_d!|-Yd }-~-:d }-~-wwxYw#t\$r}-t_d)|-Yd }-~-d }-~-wwxYw#t\$r}0t_d.|0Yd }0~0d }0~0wwxYw#t\$rG}-dd l4}3|3jktdtO|-dd7fcYd }-~-|jSd }-~-wwxYw#|jwxYw)8zY Get detailed information about a specific forecast log For the detail modal rr)rrYF Log not foundrNrrrrrrrrr)r)timezoner)rZ MlOrderItemr\r[tzinfor^ _product_mixmlb_idProductForecastskuNONEzSKU Match failed successfully: titlez 780 LITROSINTEX780SUNSETBOMBAz(Panic Fallback failed (safely ignored): realized_unitsunits_expected皙? accuracy_hitz(CRITICAL: Realized Sales Logic Crashed: rz--- DEBUG PAYLOAD PREP ---zPAYLOAD DEBUG: z -> ID: z -> Realized: T) r timestamprrrrrrrrr)6rrrrwrYr r}rrfirstrrryrrrrrrrrrrrxrZrrr| astimezoneutc ml_item_idquantityrjoinrrrrr/rstripupperapp.models.product_forecastrrcopyrrrrrrrr)4rrrrYrrryrrrrrfatoresrrZrtz_br start_naive end_naive start_local end_local start_utcend_utcrealized_sales_query sales_by_id sales_by_sku r_item_idr_qtyr_skuqtynorm_sku product_mix product_skusrTmlb_ids_in_mixrprods_dbpidr enhanced_mixp_copyrreal_qtyp_sku p_sku_strr!p_title r_sku_stre_main debug_mix p_title_dbgrs4 r"get_forecast_log_detailr:sm 9! BQhh{#**;>>V+CDJJL (Z  Ohlln >> %%(%8%8SsGZGZA[=\_a=a\gsF ]]S FF%S*>EKS,4 "cmm G *  $$*J  5 ( Aib12U==[$yq'99Y""**22%2@&..e.<(33HLLA$// =)33HLLA$// =#**$*7Yd3W %'HH''%%%tG}VV((I5((72^^''(HI su"[\,@X(E5UZa(*5//)S*IC*OY' #E 0 0 2 8 8 :X 2>2B2B8S2QTW2Wh/X))/RW";;~r:[\=H#\AEERZOAEE(O#\.#\#M!#/*@*@/BUBU!V!]!])0044^D"@H%H83c3h%Hl%H\&/2a vvxf"155?399;f"-!=h"Q#&2&6&6v&>e%**+%%,%!&.1%j.>.>.@.F.F.H)%.93F1=1A1A)S1Qh"Q #!)Q,/gr0B,C,I,I,K'%1W%<GASEY'L*A)UE69%+26F6L6L6N)-2i-?XQZEZ^eir^r.6% :K.Kh'L2:f-.081 0aGWYZA[^aAaf^,"))&1_/2d-9'.)S,4; $S*>EKK/52  *, xAquuWb12[$ XaeeHo=Nn]^]b]bcs]t\uvw x ff 33==? ]]446"'(:(:(?a"@7:~~7QeCNN3W[ADATATA`5)<)<#=fj")(&8    (  Q$]&I2"+##&EaS$IJ"#("+##&Nqc$RS"#  >V+CDJJLuGH#M   # 4MBC  A 53q6:;S@@  A  s6A B./.B.. C:7(C5C: C=5C::C==Dz//forecast/learning/logs//regeneratePOSTcddlm}ddlm}t } |j |j |j|k(j}|s tddddf|jS|j}|j}|j}|j||j||}|j!||} tdd | d |jS#t"$r[} |j%t&j)d | tdt+| dd fcYd } ~ |jSd } ~ wwxYw#|jwxYw)zE Regenerate a forecast log (re-run prediction for that hour) rrr FrrrTzLog regenerado)rr>rzRegenerate log failed: rN)rrapp.services.forecastr r r}rrrrrrr=r-r?r@rrrArrr) rrr rr target_dtr= date_partrr r!s r"regenerate_forecast_logrHs5 93 Bhh{#**;>>V+CDJJLuGH#M6  1MM ~~NN$ # !$33D)D'    A  .qc2353q6:;S@@  A  s8A C75A1C77 EAEEEEEE0z/forecast/learning/analyticsc  "ddlm}m}ddlm}m}m}ddlm}t} tdddlm }tjjd}tjjd} |j} |rM| rK |j|d } |j| d j!d d d } td | d| n| |dz } | } |j%|j'||j(| k\|j(| k|j*j-d|j.j-dj1} tdt3| dddlm""d}| D]a} |j8j;d}||dj=t?tA|j.||dxxdz cc<cg}tG|jID]H}||d}|j=||r!tKtM|t3|z dnd||ddJ""fd}| D]} |jNxsi}t?tA|j.}|jQD]B\}}tS|tTt@fr|d}n tW|}|||j=|Di}|jQD]M\}}i||<|jQD]0\}}|r!tKtM|t3|z dnd|||<2Og}| r| Dcgc] }t?tA|j."}}tM|t3|z }|d kr|j=d!d"|d#d$d%d&n:|d'kr|j=d(d)|d#d$d*d&n|j=d+d,|d#d$d-d&|jQD]B\}}|jQD]*\}}|d.kDs |j=d+d/|d0|d1|d2d3d&,Dt3|d4k\rR|dd5}|d6d5} | |d4z kr|j=d!d7d8|d9| d$d&n| |d4zkDr|j=d+d:d;d&|j%|j'|j*jYdj[}!td|!d<|!dkDr|j=d(|!d=d>d&td?t]d@|||t3| dAdB|j_S#t"$r| |dz } | } YwxYw#tB$r&}td|jDd|Yd}~ d}~wwxYw#tB$r&}td|jDd|Yd}~dd}~wwxYwcc}w#tB$rK}t`jcdC|t]dDtW|dEdFfcYd}~|j_Sd}~wwxYw#|j_wxYw)Gz Get analytics data for the Hyper AI panel - Precision evolution by week - Precision by factor type - Auto-generated insights rr)rXrYextractrz'DEBUG: Hit /forecast/learning/analytics)r{ start_dateend_dater*;r=minutesecondzDEBUG: Using filter z to rlNz DEBUG: Found z logs for analytics defaultdictc gddS)NrerrorsrrXrr"z(get_forecast_analytics.._s R!*Drz%Y-W%WrWrr[zDEBUG: Error processing log z: )semanartotal_previsoesctSN)listrSsr"rYz(get_forecast_analytics..ts K,=r.2fz(DEBUG: Error processing factors for log ru$Precisão excelente! Erro médio de .1f%u<Mantenha o sistema coletando dados para melhorias contínuas)rgmensagem recomendacaorinfouPrecisão boa. Erro médio de uBO sistema está aprendendo, precisão deve melhorar com mais dadoswarningu-Precisão em desenvolvimento. Erro médio de u0Aguarde mais dados para calibração automáticazFator '=z' tem erro alto (z%)u/Considere coletar mais dados para este cenáriorbru!Tendência de melhoria detectada!zErro reduziu de z% para uPrecisão diminuiu recentementeu1Verifique se houve mudanças no padrão de vendasz pending logsu& previsões aguardando reconciliaçãou+Próxima reconciliação automática: 03:00z'DEBUG: Analytics generated successfullyT)precisao_por_semanaprecisao_por_fatorinsightstotal_logs_analisadosrz"Error getting forecast analytics: Frr)2rrrwrXrYrJrrr rr{rr.r/ryr,r|r1r}rrrrrrr collectionsrTrstrftimerrrrrsortedkeysrr~ritems isinstancerrrrrrrr)#rrrXrYrJrrr{ start_param end_paramryrKrLr weekly_datarweekr!precision_by_weekrW factor_errorsrerro fator_tiporkeyprecision_by_factorrqrl all_errors avg_errorfirst_week_errorlast_week_errorrrTs# @r"get_forecast_analyticsr/s-..8 Bc 78 "ll&&|4 LL$$Z0 hlln 9 .X..{JG ,8,,Y CKKQS\^giKj,ZLXJGH  r 22ZXxx $++ %%3%%1&&,,T2++11$7    #%   c$i[(;<= ,!"DE  C --66x@D!(+223uS=P=P7Q3RSD!'*a/*  ;++-. D &x0F  $ $EKeCK#f+$=qAQR#.t#4W#=&  $$=>  C ,,25!4!456)0@%J!%#u6!&s !%j!*-c299$? @ ! - 3 3 5 l J.0  +#zz| l V^duS[3v;=VXY7Zjk#J/4 l l  EIJc#eC$7$789JJJJ#j/9IB%"FyQToUV W$b! b""@3q Q$h! %"OPYZ]^_ `$V!!4 9 9 ;  J!ZZ\  T"9OO )&-j\3%?PQUPVVX$Y(Y%    !Q &03LA /3LAO!1A!55% C&67G6HP_O``a$b! !#3a#77% A$W!((;'..  " " & &t , %'   gYm45 Q; OO&i'MN M  78'8&9$),T   "  i  9"#55  6 4SVVHBqcBC 2 @1#NO KT  9!=>V        sA$W A UB>WAU-0A8W)BV,A,W%W=B$W"DWU*&W)U**W- V6VWVW W(W W WW X*0X%X*X-%X**X--X?z/forecast/learning/statusc ` ddlm}ddlm}m}ddlm}m}m}t}tjjd}tjjd}|r<|r: |j|d} |j|djdd d } nt|j|j j#|j$} |j|j j#|j&} |j)|j+|j,j/d |j+|j0j/d j3|j4| k\|j4| kj7} | r!| j8rt;| j8nd } | r!| j<rt;| j<nd } d }| dkDr#t?| | z }t'dd|| z dzz }|j)|j3|j4| k\|j4| kjA}|j)|j3|j4| k\|j4| k|j0jCdjA}|j)|j3|j4| k\|j4| k|j0jEdjA}|j)|jG|j?|jHj3||j4| k\|j4| k|j0jCd|jHjCdjK}|r t;|nd }tMd|||tO|dtO| dtO| dtO|dd|||ddd|jQS#t$rx|j|j j#|j$} |j|j j#|j&} YwxYw#tR$rK}tTjWd|tMdtY|ddfcYd}~jQSd}~wwxYw#jQwxYw)z Get the current status of the learning system - Total predictions logged - Reconciliation status - Average error rrrW)rrr{rKrLr*rMrNrO projectedrealizedrrnNTr[rb)rraccuracy)total_predictionsrpending_reconciliation)total_predictions_loggedpredictions_reconciledr avg_error_7d today_summarycountsrzError getting learning status: Frr)-rrrwrXrYrrr{r rr.r/r,r|r1rzryr-r@rAr}r~rlabelrrrrrrrrrrravgrrrrrrrrr)rrXrYrrr{rrtrurKrL summary_queryperiod_projectedperiod_realizedperiod_accuracydiff total_periodreconciled_periodpending_periodavg_error_queryrr!s r"get_learning_statusrsj<)66 ^ll&&|4 LL$$Z0  9 M.X..{JG ,8,,Y CKKQS\^giKj*)),(,,.*=*=*?JJ'x''  (;(;(=txxHH HH[// 0 6 6{ C HH[++ , 2 2: >  &  ! !Z /  ! !X -  %' >K}OfOf5!8!89lo;H]McMc% 6 67il Q '/9:D!!SD?,BS,H%IJOxx ,33  ! !Z /  ! !X -  %'  HH[188  ! !Z /  ! !X -  " " ( ( .  %'  +.55  ! !Z /  ! !X -  " " & &t ,  %' ((488DHH[5P5P,Q#RSZZ %%3%%1&&,,T2++11$7    &( />E/*3 ,8*;*8 %i 3!&'7!; %oq 9 %oq 9" *6"3.<  .  u M-X--lhlln.A.A.CTXXN +8++LHLLN,?,?,A488L Ml A 6qc:;53q6:;S@@  A  sVA$S'8QNSA=S=SSS T 0T=T>TTTT-z/forecast/learning/reconcilec  ddlm}tjxsi}|j d}||}t d|ddS#t $r;}tjd|t d t|d d fcYd }~Sd }~wwxYw) z; Manually trigger reconciliation of forecast logs. r)run_hourly_reconciliationr-)r(TuReconciliação concluídarrr>zReconciliation trigger failed: FrrN) app.jobs.forecast_jobsrrget_jsonr/rrrrr)rrr(r r!s r"reconcile_learning_logsrXs AD!'Rhhv& *{C3   A 6qc:;53q6:;S@@AsAA B 0BB B z/forecast/learning/calibratec ddlm}tjxsi}|j dd}|j d}|||}|j ddk(r"t d d |j d d gd d S|j dg}t d |ddS#t $r;}tjd|t dt|ddfcYd}~Sd}~wwxYw)z^ Manually trigger a calibration cycle. Runs the hourly calibration job on demand. r)run_weekly_calibrationforceFr-) force_runr(rskippedTreasonuCalibração pulada)r adjustments)rrrruCalibração concluídarzCalibration trigger failed: rrN) rrrrr/rrrrr)rrrr(r rr!s r"trigger_calibrationrps AA!'R%(hhv& '%[Q ::h 9 ,$jj3HI#% jj3 0   A 3A37853q6:;S@@As$BB$ B$$ C(-0C#C(#C(z/forecast/learning/logs/cleanupc ddlm}ddlm}t }|j |j |j|jj|j j|j|jdkDj}d}|D]\}}|j |j|j |k(j|jjj}|d}d} |D]} | j| } n| s|d} |D]2} | j| jk7s|j!| |dz }4|j#t%dd|d|d |j'S#t($rC} j+t%d t-| d d fcYd} ~ |j'Sd} ~ wwxYw#j'wxYw) zt Remove duplicate ForecastLog entries for the same hora_alvo. Keeps the most recent entry (highest ID). rr)rXr[NTuLimpeza concluída. z duplicatas removidas.)rr>deletedFrr)rrrwrXr r}rrrgroup_byhavingrrrrrr?r@rrrrAr) rrXr duplicates deleted_countr=rrkeeperbest_logrr!s r"cleanup_duplicatesrs 4<# ^XX  ! ! JJ{~~ &  (;(( )&&KNN1Ka1O*PQTQTQV   % 'KD%88K(// 0E0E0MNWWXcXfXfXkXkXmnrrtD !WFH >>-"H  7 '66X[[(IIcN!Q&M '+ '4 -m_rFr>z Unknown errorrrzGenerate predictions error: N) rrr/rrrrrrr)rr r!rs r"generate_predictionsrs A@'$7 ::h 4 '"(. 3Eq(I!)&**5G*K)LLrs  I?  A 3A37853q6:;S@@ As%AA;A;; CACCCz%/forecast/migrate/calibration-columnscddlm}t} |j|d}|Dcgc]}|d }}g}d|vr(|j|d|j dd|vr(|j|d|j d|j t d||d d |jScc}w#t$r[}|jtjd |t d t|d dfcYd}~|jSd}~wwxYw#|jwxYw)zx Add calibration columns to forecast_logs table if they don't exist. This is a one-time migration endpoint. r)textz SELECT column_name FROM information_schema.columns WHERE table_name = 'forecast_logs' AND column_name IN ('calibrated', 'calibration_impact') rzFALTER TABLE forecast_logs ADD COLUMN calibrated VARCHAR(1) DEFAULT 'N'rz=ALTER TABLE forecast_logs ADD COLUMN calibration_impact JSONBT) added_columnsexisting_columnsrzMigration error: FrrN) rwrr executerr@rrrrArrr)rrr rowexistingaddedr!s r"add_calibration_columnsrs+  B!D"   '--sCF-- x ' JJtde f LL & x / JJt[\ ] LL- . !&$,    3.( A  (,-53q6:;S@@  A  sAC CAxsdt7| j@xsd| jB| jD| jFd }} |j'|j)|jH|k\}|r |r|j)|jH| k}|j3}i} ddlm%}|j'|j-|jLjOd|jQ|jRjOd}|r5|r3|j)||jL|k\|jL| k}n|j)|jL|k\}|jU|j-|jLj3}|D]}|jP||j,< i}|D]}|jHj-}|| vr"||vr gdddd||<||dxxt7|jXxsdz cc<||dxxdz cc<|jZ#||dxxt7|jZz cc<|j\||dj_t7|j\|D]}||d}|rtad|Dt!|z nd}tcdd|z }|j_|j5te|dte|d||dte||ddte||dd|j|dd d d |jgdtid ||t!|d!d"|jkScc} wcc} w#tV$rYwxYw#|jkwxYw#tV$r;}tljod#|tid$tq|d%d&fcYd }~Sd }~wwxYw)'zZ Get error evolution data for charting. Shows daily accuracy/error over time. r)LearningSnapshotrrWrmrRtyperKrLZz+00:00Nrr`rMrNrOrl) r-rrr>predicted_total real_total calibrations best_factor worst_factorrr-r)rW predictedrcrrr[rcrWc32K|]}t|ywr]rrr!s r"rz)get_learning_evolution..s71A7rnrbc |dS)Nr-rXxs r"rYz(get_learning_evolution..s 6rr|T) evolution period_days total_pointsrzError getting evolution: Frr)9rrrrwrXrYrr.r/rr endswithr|rrrrryrr}rrr-rrrrracuraciaerro_absoluto_medior[receita_prevista_totalreceita_real_totalajustes_realizados melhor_fator pior_fatorrrrrrrrrrrrrr~rArsortrrrrr)rrrXrYrmrKrLrsinceuntilsnapshots_query snapshotsssnapshot_datesr logs_queryrcalibration_countsr cal_queryrcal daily_datardrWrrr!s r"get_learning_evolutionres dAN)||5\\%%l3 <<##J/ ^W h&&s+!+!3!3C!BJ$$S)'//X>H ..z: ..x8<<+!MMM6E<<+!MMM6Ex=B&!MMr"RMHE )== !hh'78?? %%5Oh"1"8"89I9N9NRWR\R\R^9^"_'001A1F1F1J1J1LMQQSI/88aff8N8% FF,,. %ajjoA 6!&q'<'<'A!B#$#4#4',Q-E-E-J'K"'(<(<(A"B$%$8$8#$>>$%LL  I 4+.55%%.Jh'..{/D/D/MN >>#D"$  KHHII0@@AGGOJJ1445;;GD ( ) 0 0*::eC*::eC2!I !* 0 01C1S1SW\1\ ]I(11$))>-qM&)U3>>-BB)&&2qM(+2259L9L3MN# O(  #Ax0IOC777#f+EUV q# /2  KKM %h 2!&y!!4#-a=#9',Z];-G'K"' 1 f(=q"A$6$:$:1a$@#'$( "   $ NN2N 3!*#'$' N HHJe9 n  p HHJ A 04553q6:;S@@AsA>Y$F.Y/X5YB/X:7A#YDX?0B'YD Y$Y$5 Y? Y Y Y  YY!!Y$$ Z(-0Z#Z(#Z(z/forecast/analytics/heatmapc  ddlm}ddlm}tj j ddt}t} tjt|z }|j|j||j|k\|jj!dj#}i}|D]}|jj%}|jj&} |d | } | |vrgdd || <|| d j)t+t-|j|| d xxd z cc<g} gd} t/dD]}t/dD]} |d | } |j | gdd } | d rt1| d t3| d z nd}| j)| ||| |r t5|dnd| d |r|dkrdn|r|dkrdn|rdnddt7d| |t3|dd|j9S#|j9wxYw#t:$r;}t<j?d|t7dtA|ddfcYd}~Sd}~wwxYw) zn Get hour x day performance heatmap data. Shows which hour+day combinations have high/low errors. rrrrmrRrrlN_rVrWrr[)segterquaquisexsabdomr5rbr`goodrmediumbadno_data)day day_indexr=rsamplesrT)heatmapr total_samplesrzError getting heatmap: Frr)!rrrwrYrr.r/rr rryrr}rrrrrweekdayr=rrrrPr~rrrrrrrr)rrYrmrrrr rdowr=r|r day_namesrrr!s r"get_performance_heatmapr%s >A<#||5 ^3 LLNYD%99E88K(//))U2//55d; ce G +mm++-}}))Qtfog%.01#=GCL X&--c%8K8K2L.MN W%*% +FIIQx !"I D E4&/C";;srA,FGDMQRZ^DN 3c$x.6I IaeIMM(~%( $.sE1AErrb) rr|valuerhsource change_24h change_7drr updated_atc|d|dfS)Nrr|rXrs r"rYz&get_factor_analytics..s& 1U8'<rrrT)factorsgrouped total_configsrrzError getting factors: Frr)2rrrrrwrYrrr.r/rr rryrr}rrrrrrrrrrrrrr startswithr|rrrsrgrr~rrrkrrrrrrrrrr)"rrrrYrrmrr since_24hsince_7drcalibrations_24hcalibrations_7d changes_24hrr|change changes_7drryrrzftypefvalue actual_type actual_key composite_keyr5config error_datarr6fr!s" r"get_factor_analyticsrHYsi yAbb)||4 ^n LLNYD%99E )<ce  K% Da 7q||,uQ5E5E/FF#.??3#:V#C C  D J$ Ba 7q||,uQ5E5E/FF",..a"86"A 3 B 88K(//))U2//55d;..44T: ce M 9))S001&)%7%7%=%=%?9ME6''1&+mmHb&A %([ +6-q (E ( =FHST;UM-8%m4X>EEdK%m4W=B=&ddmwx~BEGLAMnN!&q1m3<>1KM#.%c*84;;DA%c*73q83)9 9<G!  Qv||n5*..srA4NO eopxeyCE 80DEEJW_L`Haa@D "KK!<<"6<<0"("2"2$.."' Q(?"C!&z~~c1'=q!A8Ay!!4t)'2FLFZFZ&"6"6"@"@"B`d    & LL/PUTc ddlm}m}ddlm}t j }|jd}|tdddd fSt|}|d ks|d kDrtdd dd fSt} |j|j|j|k(|j|k(j}|s:||||t!t#|d dd}|j%|d} n'?@ #+ ) ( 1&&&s5A+>'?@"3uY':#;<"3<")#eY5JQ5NRU4UWX.Y*Z"[1 G FF7O IIK'%!*!*  HHJBHHJ A .qc2353q6:;S@@AsCAH$H, H7E1G9(H9H  H I0I I Iz/forecast/analytics/snapshotscN ddlm}tjj ddt }t } tjt|z }|j|j|j|jk\j|jjj!}g}|D]}|j#|jj%|j&t)|j*xsdt)|j,xsdt)|j.xsdt)|j0xsd|j2|j4|j6|j8|j:d t=d|t?||d d |jAS#|jAwxYw#tB$r;}tDjGd |t=d tI|d dfcYd}~Sd}~wwxYw)z? Get daily learning snapshots for historical analysis. r)rrmrRrrl) r-r>rrrrrrrfactor_performanceadjustment_detailsT)rrrrzError getting snapshots: FrrN)%rrrr.r/rr rryrr}rrr-rrrrrr[rrrrrrrrfatores_performancedetalhes_ajustesrrrrrrr)rrmrrrr rr!s r"get_learning_snapshotsr_'s +AA||5 ^! LLNYD%99E!1299 %%5h',,1134SSU F  FF,,.#$#4#4 %ajjoA 6!&q'<'<'A!B',Q-E-E-J'K"'(<(<(A"B$%$8$8#$>>$%LL*+*?*?*+*<*<   !' [#' HHJBHHJ A 04553q6:;S@@As56G FG :G GG H$)0HH$H$z/forecast/eventsc ddlm}tjj ddj dk(}tjj d}tjj d}t } |j|}|r|j|jdk(}|r|j|j|k\}|r|j|j|k}|j|jjj}td|Dcgc]}|j |j"|j$|jj'|jj't)|j*|j,|j.dk(|jdk(d c}t1|d d |j3Scc}w#|j3wxYw#t4$r;}t6j9d |td t;|ddfcYd}~Sd}~wwxYw)z5Get all forecast events, optionally filtered by date.r ForecastEventactivetruefromtorT) rnome descricao data_iniciodata_fim multiplicadorrg recorrenteativo)eventsrrzError getting events: FrrN)rrbrr.r/lowerr r}rrmrjrirrrrrrgrhrrrkrgrlrrrrrr)rb active_only from_dateto_daterr}rnr!s r"get_forecast_eventsrs^s0A>ll&&x8>>@FJ LL$$V, ,,""4( ^# HH]+E ]%8%8C%?@ ]%;%;y%HI ]%>%>'%IJ^^M$=$=$B$B$DEIIKF$*  #$$$$%FF)*+,==+B+B+D() (<(<(>-21??-C$%FF*+,,#*=%&WW^  ![* HHJ% $ HHJ A -aS1253q6:;S@@AsJA?H B2G64BG1 G6 H 1G66HH I0I I Ic L ddlm}ddlm}t j }gd}|D]}||vst dd|ddfcSt} ||d |jd d tj|d d jtj|dd j|t|d|jdd|jddrdndd}|j||jt d|j|j dd|j#S#|j#wxYw#t$$r;}t&j)d|t dt|ddfcYd}~Sd}~wwxYw)zCreate a new forecast event.rrarK)rgrirjrkFzMissing required field: rr%rgrhrrir*rjrkrgrNrlrr)rgrhrirjrkrgrlrmTrrgrzError creating event: rN)rrbrTrLrrrr r/rr,r-rrUr@rrgrrrr)rbrLrrequiredfieldreventr!s r"create_forecast_eventrys)A>#!H eED 5=UV[U\;]^_addd e^ !&\((;3$--d=.A:NSSU!**4 +;ZHMMO%c$*?&@AXXfh/"&((<"?3S E FF5M IIK((!JJ HHJBHHJ A -aS1253q6:;S@@AsA-EE EC(E 9E EE F#(0FF#F#z/forecast/events/c ddlm}ddlm}t j }t } |j|j|j|k(j}|s tddddf|jSd|vr |d|_ d |vr |d |_d |vr,tj |d d j#|_d |vr,tj |d d j#|_d |vr|t)|d |_d|vr |d|_d|vr|drdnd|_d|vr|drdnd|_|j3td|j|jdd|jS#|jwxYw#t4$r;}t6j9d|tdt)|ddfcYd}~Sd}~wwxYw)z"Update an existing forecast event.rrarKFEvent not foundrrrgrhrir*rjrkrgrlrrrmTrurzError updating event: rN)rrbrTrLrrr r}rrrrrrgrhrr,r-rirjrrkrgrlrmr@rrr)event_idrbrLrrrxr!s r"update_forecast_eventr}s+A>#! ^ HH]+22=3C3Cx3OPVVXE5;LMNPSS8 HHJ3~!&\ d""&{"3$$,$5$5d=6I:$V$[$[$]!T!!)!2!24 3CZ!P!U!U!W$&&-c$2G.H&I#~!&\ t#*.|*<3# $%)']c IIK$xx< HHJBHHJ A -aS1253q6:;S@@AsB*F/A F9F/ C?F F/F,,F// G380G.(G3.G3c ddlm}t} |j|j |j |k(j }|s tddddf|jS|j||jtdd|id |jS#|jwxYw#t$r;}tjd |tdt|dd fcYd }~Sd }~wwxYw) zDelete a forecast event.rraFr{rrTrrzError deleting event: rN)rrbr r}rrrrrr?r@rrrr)r|rbrrxr!s r"delete_forecast_eventrsA> ^ HH]+22=3C3Cx3OPVVXE5;LMNPSS HHJ IIe  IIKti5JKL HHJBHHJ A -aS1253q6:;S@@AsACA B1C00B1 C1CC D 0D?D D z;/forecast/analytics/factors///lockcR ddlm}t} |j|j |j |k(|j |k(j}|s tddddf|jS|jdk(rdnd}||_ |jtd |||dk(d d |jS#|jwxYw#t$r;}tjd |tdt|dd fcYd}~Sd}~wwxYw)zGToggle lock status on a factor (prevents auto-calibration when locked).rrFzFactor not foundrrrrT)rr|lockedrzError toggling lock: rN)rrr r}rrgrrrrrr@rrrr)rWrXrrrEnew_lockr!s r"toggle_factor_lockrs AA ^ XX./66 %%4 &&*4eg  5;MNOQTT" HHJ%mms2sH$FM IIK'%&#o HHJBHHJ A ,QC0153q6:;S@@AsAC"AC -C">>C <C" CC"" D&+0D!D&!D&z/forecast/events/todayc  ddlm}ddlm}|j }t } |j |j|jdk(|j|k|j|k\j}d}|D]}|t|jz}td|j|Dcgc]/}|j |j"t|jd1c}t%|dt'|d d |j)Scc}w#|j)wxYw#t*$r;}t,j/d |td t1|d dfcYd}~Sd}~wwxYw)z:Get events that are active today (for use in predictions).rra)r-rrOT)rrgrkrM)r-rncombined_multiplierrrzError getting today's events: FrrN)rrbrr-rr r}rrmrirjrrrkrrrrgrrrrrrr)rbr-rrrncombinedr!s r"get_active_events_for_todayr4sb(A>!  ^ XXm,33##s*))U2&&%/ce H 3E!//22 3!OO- $*   #$$$$%FF-21??-C,11+= [ " HHJ HHJ A 5aS9:53q6:;S@@AsG&D8BD#:4D .D# D8D##D55D88 E<0E71E<7E<z/forecast/productscH ddlm}t} |j|j |j dk(}t jjd}|r,|j |j|jk(}t jjd}|r|j |j|k(}t jjd}|r|j |j|k(}t jjd}|dk(r|j |jdk(}t jjd d }t jjd d }|j|j|j |j"|j$d } | j||j} |dk(r |j'| j)}n|j'| j+}|j-} t/d| D} t/d| D} t/d| D}t1dt3| | | |t/d| Dt/d| Dt/d| Dd| Dcgc]}id|j4d|j6d|j8d|j:d|jxs |j<d|jdt?|j@xsddt?|jBxsddt?|jDxsddt?|jFxsddt?|jHxsdd|jxsdd t?|jxsdd!|jJd"t?|j"xsdd#|j d$|jL|jN|jPt?|j$xsd|j|jt?|jRxsdt?|jTxsdd%c}d&d'|jWScc}w#tX$r_}tZj]d(|dd)l/}|jat1d*tc|d+d,fcYd)}~|jWSd)}~wwxYw#|jWwxYw)-aV Get product-level forecast data with stock status. Query params: - curve: Filter by ABC curve (A, B, C) - stock_status: Filter by status (ok, low, critical, stockout) - category: Filter by category - sort_by: Sort field (revenue, units, stock, trend) default: revenue - sort_order: asc or desc, default: desc rrTcurve stock_statusr+ rupture_onlyrdrr;rr)r;unitsstocktrendcoveragerc3NK|]}t|jxsdyw)rN)rforecast_revenue_todayrrTs r"rz(get_product_forecasts..s TaU1#;#;#@qATs#%c3:K|]}|jsdyw)r[N)has_rupture_riskrs r"rz(get_product_forecasts..sF!13E3EAFsc3@K|]}|jdk(sdyw)stockoutr[N)rrs r"rz(get_product_forecasts..sQ1ANNj4PQQc3@K|]}|jdk(sdyw)Ar[Nrrs r"rz(get_product_forecasts.."I!''S.1"Irc3@K|]}|jdk(sdyw)Br[Nrrs r"rz(get_product_forecasts..rrc3@K|]}|jdk(sdyw)Cr[Nrrs r"rz(get_product_forecasts..rr)total_productstotal_forecast_todayrupture_risk_countstockout_countcurve_acurve_bcurve_crr thumbnailrpricecost margin_pct avg_units_7d avg_units_30dtotal_units_7dtotal_revenue_7dr trend_pct stock_current stock_full) stock_localstock_incomingdays_of_coveragerrforecast_units_todayr)rOproductsrz!Error getting product forecasts: NFrr)2rrr r}r is_activerr.r/rrrcategory_normalizedrrrrrrrrrrr~rrrrrr category_mlrrrrrrrrrrrrrrrrrrr)rrr}rrr+rrrsort_map sort_fieldrtotal_forecast rupture_countrrTr!rs r"get_product_forecastsrfs< B`)001J1Jd1RS   ) LL!6!6%++-!GHE||''7 LL!=!=!MNE<<##J/ LL!D!D!PQE||''7 6 !LL!A!AT!IJE,,""9i8\\%%lF; '77$33$22$..'88  \\'?+K+KL  NN:>>#34ENN:??#45E99;T8TTFxFF QQQ'*(m,:*7&4""Ih"II""Ih"II""Ih"IIH&765 !(($Q[[quu  #A$9$9$JQ]]     qww|!!4affk 2%eALL,=A&>'ann.A(B(q/C!)D)!*:*:*?a+E!2D2D2I,J $U1;;+;!%< (!"%all#$()}}*+*:*:,1!2D2D2I,J(),-,>,>05a6L6L6QPQ0R278P8P8UTU2V1'* * d  M@ A 8<=53q6:;S@@  A  sDJ&R$8G R  R$R$$ T -AT1T 2TT  TT!z/forecast/products/synccX ddlm}|}tjd|j ddlm}tjd|}td|ddS#t$r;}tjd |td t|d d fcYd }~Sd }~wwxYw)zF Manually trigger comprehensive sync (Ads + Product Metrics). r) SyncEnginez![MANUAL-SYNC] Starting Ad Sync...)sync_product_metricsz.[MANUAL-SYNC] Starting Product Metrics Sync...Tz Full sync completed successfullyrz!Error syncing product forecasts: FrrN) app.services.sync_enginerrresync_adsapp.jobs.product_syncrrrrr)r sync_enginerr r!s r"sync_product_forecastsrs A7 l  78 ? DE%'9   A 8<=53q6:;S@@AsA"A%% B).0B$B)$B)z/forecast/products/alertsc ddlm}t} g}|j|j |j dk(|j dk(|jdkDj|jjj}|D]n}|jr"t|j|jznd}|jdd|j|j d|dd||j"d p|j|j |j dk(|j dk(|j$dkDj|j&j)j}|D]|}|jd d |j|j d |j$d t|j&dd|j$t|j&|j"d~|j|j |j dk(|j*dk(|j&dkj|j,jj/dj}|D]y}||vs||vs |jdd|j|j dt|j,ddt|j,|j$|j"d{t1dt3|t5d|Dt5d|D|dd|j7S#t8$rK}t:j=d|t1dt?|dd fcYd!}~|j7Sd!}~wwxYw#|j7wxYw)"z? Get critical alerts for products requiring attention. rrTrcriticalz"Sem estoque - perda estimada de R$r_z/dia)rseverityrrr> daily_impactr low_stockhighuEstoque crítico: z un (raz dias))rrrrr>r days_coveragerupr rising_demandrzDemanda subindo u% - considere reposição)rrrrr>rrrc32K|]}|ddk(s dyw)rrr[NrXras r"rz%get_product_alerts..; s%WA1Z=J;Va%W c32K|]}|ddk(s dyw)rrr[NrXrs r"rz%get_product_alerts..< s!Oq}7N!!Or) total_alertscritical_count high_countalertsrzError getting product alerts: FrrN) rrr r}rrrrrrrrrrrrrrrrrrrrrrr~rrrrr) rrr stockoutsrT daily_lossrrisingr!s r"get_product_alertsrsY < BKHH_-44  % % -  ( (J 6  ( (1 ,  (?3388: ;CCE   A<=GGq~~78J MM"&((? 3?OtT *  88O,33  % % -  ( (J 6  ) )A -  (?33779 :335   A MM#"((//@eAL^L^F_`cEddjk!"!&q'9'9!:   /*11  % % -  ! !T )  , ,r 1  (?,,113 4UU1Xcce   A !ax&7 + (hhWW!1% 2DS1IIbc!&q{{!3%&__WW    #F "%%W%W"W!!OV!OO     A 5aS9:53q6:;S@@  A  s=JMM B*M N/$0N*N/N2*N//N22Oz/forecast/categoriescddlm}t} |j|j |j j }tdt||Dcgc]}|j|j |j|jt|jxsdt|jxsdt|jxsdt|j xsd|j"d c}dd|j%Scc}w#t&$rK}t(j+d|td t-|d d fcYd }~|j%Sd }~wwxYw#|j%wxYw) z:Get all category mappings with their seasonal multipliers.rCategoryMappingTrO) rrcategory_ml_namermultiplier_summermultiplier_wintermultiplier_fallmultiplier_springr)r categoriesrzError getting categories: FrrN)rrr r}rrrrrrrrrrrrrrrrrrr)rrrrr!s r"get_categoriesrL sL< BXXo.778S8STXXZ Z(  dd'(}},-,>,>/0/D/D-213F3F3M#-N-213F3F3M#-N+01B1B1Ic+J-213F3F3M#-N%&[[    2  + " A 1!5653q6:;S@@  A  sCA DB!D ? DD E3(0E.E3E6.E33E66Fz&/forecast/categories/ category_idc2ddlm}t} |j|j |j |k(j }|s tddddf|jStj}d|vr |d|_ d|vr |d|_ d |vr |d |_ d |vr |d |_d |vr |d |_d |vr |d |_d |vr |d |_|j%tdd|j&dd|jS#t($r[}t*j-d||j/tdt1|ddfcYd}~|jSd}~wwxYw#|jwxYw)zFUpdate category mapping with normalized name and seasonal multipliers.rrFzCategory not foundrrrrrrrrrTz Category z updatedr=zError updating category: rN)rrr r}rrrrrrjsonrrrrrrrr@rrrrrAr)rrrr+rr!s r"update_categoryrq s< B#88O,33O4F4F+4UV\\^u7KLMsR>  ;|| D (+/0E+FH (  %(,-?(@H % $ &)-.A)BH & $ &)-.A)BH &  $'+,='>H $ $ &)-.A)BH & $ !%k!2H  "8#7#7"8A    A 045 53q6:;S@@  A  s8A D/BD F&AE<&F'F<FFFz/forecast/categories/syncc ddlm}|}td|dS#t$r;}tj d|tdt |ddfcYd }~Sd }~wwxYw) z.Sync category mappings from existing products.r)sync_category_mappingTrzError syncing categories: FrrN)app.jobs.category_syncrrrrrr)rr r!s r"sync_categoriesr sl A@&(    A 1!5653q6:;S@@As A!0AA!A!z$/forecast/learning/generate-for-datecddlm}|S)Nrgenerate_for_specific_date)!app.api.endpoints.forecast_extrasrrs r" generate_for_specific_date_router sL % ''rz"/forecast/learning/incomplete-dayscddlm}|S)Nrget_incomplete_days)rrrs r"get_incomplete_days_router E   rz/forecast/allowed-factorscddlm}|S)Nrget_allowed_factors)rrrs r"get_allowed_factors_router rrcddlm}|S)Nradd_allowed_factor)rrrs r"add_allowed_factor_router sD  rz)/forecast/allowed-factors/cddlm}||S)Nr)delete_allowed_factor)rr) factor_idrs r"delete_allowed_factor_router sG  ++r)<__doc__loggingflaskrrrrapp.apirapp.core.databaser rEr getLogger__name__rrouter#r'rr3rUrrrrrr:rBrHrrrrrrrrrr%rHrYr_rsryr}rrrrrrrrrrrrrrrXrr"rs"(*/   8 $%12:(5':#;#L+eW=#>@$ug6J7JZ*UG<i=iX.@%A%P6H'I'T'%9H:HV4ugF[C[G[|4xjIJ*?&R&C&S&R,ug>o?of)E7;q<qh,vh?A@A.,vh?"A@"AH/(D9E9z7&JAKAD5xH)I)V&8;9;D-w?iA@iAX+eW=CA>CAL+eW=~A>~ABFQVPWXHAYHAV-w?/A@/Al 5'22A32Aj 6(3+A4+A\/%A-AB-A`/(DAEA2KV\U]^"A_"AJ&8*A9*Ab"UG4m5m`'&:A;A4)E7;R<Rr$ug6!7!H6H((I(V)F8< A= A4vhG(H( 2UGD!E! )E7;!<!)F8< = 9H:N,O,r