RRj+>dZddlZddlZddlmZmZddlmZmZddl m Z ddl m Z ddl mZddlmZdd lmZdd lmZmZmZdd lmZej2eZd Zd Ze j<ddgdZe j<ddgdZ e j<ddgdZ!e j<ddgdZ"e j<ddgdZ#defdZ$e j<ddgdZ%e j<ddgdZ&e j<d d!gd"Z'e j<d d#gd$Z(y)%u6 Endpoints do módulo Full (Fulfillment ML) — Fase 1, read-only. GET /full/overview resumo operacional (unidades, valor imobilizado, alertas) GET /full/inventory lista por produto (estoque por estado, cobertura, custo real/un) GET /full/inventory/ detalhe + série histórica diária POST /full/sync dispara sync manual (mesmo do job diário) GET/POST/PUT/DELETE /full/tariffs[/] CRUD da tabela de tarifas (Settings) Nada escreve no ML. O custo real calculado aqui alimenta ProductFinancialMetric. N)date timedelta)requestjsonify)func)api_bp) SessionLocal)Ad)ProductFinancialMetric) FullInventoryFullStockDailyFullStorageTariff) TinyStockZz/full/replenishmentGET)methodsct} tdtdtjj ddt }tdt|tjj ddt }i}|jtjtjjd jD]E}|j |jd t |jxsd z||j<Gii}}|jtjtjjd jD]}t |jxsd }|j |jd |z||j<|j sU|j#|jgj%|j |d i}|jt&jt&j(d k(t&jjd jD]E} |j#| j| d d } | dxxt | j*xsd z cc<Gg} |j-D]\} } | d} |j | d } |j | d }| ddz }|d kr=t/| |z d}||k\rRt1j2||z}td || z }t||}| j%| j4| | j6| ||j | g| dt/|d|||||d kDrdndddddd| j9dt;||t=| | dd|j?S#t@$rJ}tBjEd|t;dtG|idfcYd }~|j?Sd }~wwxYw#|j?wxYw) zCRead-only replenishment suggestions from real Full and local stock.r target_days)type trigger_daysrNr) warehouse availableT)ad sales_30drrg>@readyno_local_stockzfull_inventory (ML Full, real)ztiny_stock (local, real)zads.sales_30d / 30 (estimate))full_availablelocal_availablevelocity)ad_idskutitler"r#local_warehousesrdaily_sales_estimate coverage_daystarget_full_quantityquantity_neededquantity_suggestedstatussourcesc |dS)Nr*)items D/var/www/hypershopcomercio.com.br/hyper-ai/app/api/endpoints/full.pyz4full_replenishment_recommendations..^s D$9keysuggestion_only)rrcountitemsmodez$full_replenishment_recommendations: error)$r maxminrargsgetintqueryr filterr&isnotall available_qtyrrr setdefaultappendr is_fullrr:roundmathceilidr'sortrlenclose Exceptionloggerr<str)dbrr full_by_skurow local_by_skuwarehouses_by_skuquantity ads_by_skurentryr:r&r"r# daily_salesr*target_quantityneeded suggestedes r3"full_replenishment_recommendationsrb s BA!SW\\%5%5mRc%5%RST 1c+w||/?/?PRY\/?/]^_  88M*11-2C2C2I2I$2OPTTV ]C#.??377A#>SEVEVE[Z[A\#\K  ]+-b' 88I&--imm.A.A$.GHLLN C3==-A.H$0$4$4SWWa$@8$KL !}}!,,SWWb9@@!$XB   ((2,%%bjjD&8"&&,,t:LMQQS 9B))"&&!2LME + #bll&7a"8 8  9$**,! JCtB(__S!4N*..sA6O ,t3Ka!.;">BM ,"ii k(ABOOn<=FFO4I LL"0#2$5$9$9#r$B";/(-k1(=!.(7#)&/%.]'8H&F'A ? ! F  9 :{L!$UeEVXY  / ;A3?@Q()3..  /  s7F4OHO P+!/P&P+P.&P++P..Qz/full/overviewc t} |jtj}|s t ddiid|j S|Dcgc]}|j s|j }}|rh|jtjtjj|jDcic]}|j|c}ni}dx}x}}d} t} dx} x} } |D]4}||jxsdz }||jxsdz }||jxsdz }|j r| j|j |j!|j }|r5|j"r)| |jxsdt%|j"zz } |j&|j&t(kr| dz } |j*|j*t,kDr| dz } |jxsddkDs|j&|j&dkDs0| dz } 7t dt/| t/||||t1| d d | | | d d |j Scc}wcc}w#t2$rK}t4j7d |t dt9|ddfcYd}~|j Sd}~wwxYw#|j wxYw)NFzISem dados de Full. Rode o sync: python -m app.scripts.backfill_full_stock)has_datamessagesummaryalertsrgrTr)products_countinventories_countunits_availableunits_in_transitunits_not_availableimmobilized_value) low_coverage aged_stockstranded)rdrfrgzfull_overview: rdr<r=)r rCr rFrrQr%r rDrNin_setrGin_transit_qtynot_available_qtyaddrAcostfloat days_of_stockLOW_COVERAGE_DAYSoldest_stock_days AGED_DEFAULTrPrKrRrSr<rT)rUrowsrad_idsaads_maprk units_transitunits_na immobilizedproductslow_covagedrqrras r3 full_overviewrhs B6xx &**,!ff  Y$(3a177!''33U[BHHRL$7$7 &8I$J$N$N$PQq1447Qac5666-( 5$%%%$ A q3! 3O Q--2 2M ++0q 0Hww QWW%QWW%Bbgg 41bggFF *qAR/R1 "".13F3F3U $1)q/F!//\_J_A   "%h-%(Y#2$1'/%*;%: !("$  (  Y4QN B qc*+ECF;K?KKKK.z/full/inventoryct} tjjdd}tjjddk(}|j t j }|Dcgc]}|js|j}}|Dcgc]}|js|j}}|rh|j tjtjj|j Dcic]}|j|c}ni}i} |rg|j tjtjj|j D cic]} | j| } } g} |D]}|j|j} | j|j} | r!| jrt| jnd}| r!| j rt| j nd}|j"duxr|j"t$kD}|j&duxr|j&t(k}|r|s|s| j+id|j,d|jd|jd|j.d | r | j0ndd | r | j2ndd | r | j4ndd |j6d |j8d|j:d|j<d|j&d|j"d|d|d|d|d|j>r|j>jAndi|dk(r| jCdn,|dk(r| jCdn| jCdtEtG| tI| | d|jKScc}wcc}wcc}wcc} w#tL$rK}tNjQd|tEdtS|d d!fcYd}~|jKSd}~wwxYw#|jKwxYw)"Nsort_bycoveragerg1 inventory_idr%r& variation_idr' thumbnail permalinkrGrurv total_qtyrzr|storage_cost_unitstorage_risk_unitis_agedis_low_coverage updated_atrc$|ddu|dxsd fS)Nr|rr1xs r3r4z%full_inventory_list..s%a(;&<&DJ]H^HcbcFd%er5r6rc|dxsd S)NrGrr1rs r3r4z%full_inventory_list..sq'9'>Q%?r5c"|ddu|dxsdfS)NrzgeAr1rs r3r4z%full_inventory_list..s a&8D&@!OBTB[X[%\r5)rdr9r:zfull_inventory_list: Frrr=)*r rr@rArCr rFr%r&r rDrNrsr storage_costrystorage_risk_costr|r}rzr{rIrrr'rrrGrurvrr isoformatrOrboolrPrQrRrSr<rT)rUr only_alertsr~rrskusrr metric_mapmr:rmetric storage_unit storage_riskris_lowras r3full_inventory_listrs B;,,""9j9ll&&x0C7 xx &**,#'3a177!''33#-!quu--U[BHHRL$7$7 &8I$J$N$N$PQq1447Qac ,.HH5K,L!6"8"<"<"@"@"FGOq!%%(OJO AQWW%B^^AEE*F9?FDWDW5!4!45]aL>DIaIa5!9!9:gkL))5\!:M:MP\:\G__D0XQ__GX5XFGv LLquu  RT  RR\\T RR\\T !!"2"2$Q%8%8Q[[ $Q%8%8$\$\ 7!""6#$!,,all446D%  B f  JJeJ f  # JJ?J @ JJ\J ]DK#e*uUV  m4-QOZ B ,QC01ECF;O-H;O2O22 Q;0Q+Q,Q QQ Qz/full/inventory/ct} |jtjtj|k(j }|st ddidf|jS|jtjtj|k(j}|Dcgc]}|j}}tjtdz }|jtj t#j$tj&t#j$tj(t#j$tj*jtjj-|tj |k\j/tj j1tj j }t ||r |j2nd|r |j4nd|Dcgc]]}|j|j6|j&|j(|j*|j8|j:|j<d_c}|Dcgc]J}|dj?tA|dxsdtA|d xsdtA|d xsdd Lc}d |jScc}wcc}wcc}w#tB$rJ} tDjGd | t dtI| idfcYd} ~ |jSd} ~ wwxYw#|jwxYw)Nr<u$Sem estoque Full para este anúncio.<)days)rrrGrurvrrzr|rrr)rr in_transit not_available)r%r'r inventories daily_serieszfull_inventory_detail: r=)%r rCr rDr%rFrrQr rNfirstrrtodayrr dayrsumrGrurvrsgroup_byorder_byr'rrrrzr|rrBrRrSr<rT) r%rUr~rrinv_idssincedailydras r3full_inventory_detailrs B-xx &--m.A.AU.JKOOQG%KLMsRT  QXXb\ % 0 6 6 8+/0a1>>00 yb11    HH^11 2 HH^22 3 HH^55 6  &  ' ' + +G 4   % '  (>%% &xx0B0B'CCCE !#RXX)+ !" !!""#"2"2%&%8%8[[!"%&%8%8     !( 1^!!A$)!n!$QqTYQ   2  O1$  / .qc23Q()3..  /  sdAK?0AK?7K0 EK? A"K5K?AK:K?0K?? M/M 7M8M MMM'z /full/syncPOSTcTddlm}|} |j}tddi||j S#t $rK}t jd|tdt|ddfcYd }~|j Sd }~wwxYw#|j wxYw) uDDispara o sync + custo sob demanda (o job diário também faz isso).r) FullServicesuccessTz full_sync: Frr<r=N) app.services.full_servicer sync_and_costrrQrRrSr<rT)rsvcresultras r3 full_syncrs6 -C""$ 42623 A {1#&'53q6:;S@@ A s-> B0B 7B8B BBB'tc *|j|j|j|j|jt |jnd|j t |j nd|j|j|jd S)N) rNname min_volume_l max_volume_l daily_fee inbound_feeaged_days_thresholdaged_daily_factoractive) rNrrrrryrrrr)rs r3 _tariff_dictr*sodd+,;;+BU1;;'/0}}/HuQ]]+d 4400((  r5z /full/tariffsc 4t} |jtjtjj }t d|Dcgc] }t|c}i|jScc}w#|jwxYw)Ntariffs) r rCrrrrFrrrQ)rUrrs r3full_tariffs_listr8sn B((,-667H7U7UVZZ\ W#ELO#EFG  $F  sA BB (BBBcxt} tjdxsi}t|j dt |j dxsd|j ddvrt |dndt |j dxsdt |j d xsdt |j d xsd t |j d xsd t|j dd}|j||jtdt|ddf|jS#t$rC}|jtdt|ddfcYd}~|jSd}~wwxYw#|jwxYw)NTsilentrrrrNrrrrr@r)rrrrrrrrrtariffFr)r rget_jsonrrAryrBrrwcommitrrrQrRrollbackrT)rUrrras r3full_tariffs_createrBs^ B   D ) /R vquu^49:56UU>5JR\5\q01bfAEE+.3!4aeeM27a8 #AEE*?$@$FB G#AEE*=$>$E#Fh-.  q  4<?CDcI  A 53q6:;S@@  A  s0D;E F$!(F F$ F'F$$F''F9z/full/tariffs/PUTct} |jtj|j }|s t ddddf|j Stjdxsi}d|vr |d|_ d |vrt|d xsd |_ d |vr|d d vrt|d nd|_ d |vrt|d xsd |_ d|vrt|dxsd |_d|vrt|dxsd|_d|vrt|dxsd|_d|vrt%|d|_|j)t dt+|d|j S#t,$rC}|j/t dt1|ddfcYd}~|j Sd}~wwxYw#|j wxYw)NrNFTarifa não encontradarrTrrrrrrrrrrrrrrr)r rCr filter_byrrrQrrrryrrrrrBrrrrrrrRrrT) tariff_idrUrrras r3full_tariffs_updater[s B HH& ' 1 1Y 1 ? E E Gu7OPQSVV"  !   D ) /R Q;6 Q q7H7MA1N Q 9:>9JR\9\U1^#45bfAN ! 5;1D1+EQ[ A uQ}5E5J/Kq} A %s1EZC[Ca_a?bq'< ! #5CVAWA^[^;_Q%8 q=T!H+%6!( 4<?CD  A 53q6:;S@@  A  s7AE>!D E>> G (G/G 0G G  G GDELETEct} |jtj|j }|s t ddddf|j S|j||jt ddi|j S#t$rC}|jt dt|ddfcYd}~|j Sd}~wwxYw#|j wxYw) NrFrrrrTr) r rCrrrrrQdeleterrRrrT)rrUrras r3full_tariffs_deleterus B  HH& ' 1 1Y 1 ? E E Gu7OPQSVV   !   4()  A 53q6:;S@@  A  s6AB!-B C+((C&C+C.&C++C..D))__doc__loggingrLdatetimerrflaskrr sqlalchemyrapp.apirapp.core.databaser app.models.adr app.models.financialr app.models.fullr r rapp.models.tiny_stockr getLogger__name__rSr}r{routerbrrrrrrrrrr1r5r3rs  $"*7LL+   8 $ #eW5D6DN0818v%1=2=@'%9/:/dlVH- . " % ow/0ox010-w?@2-zB C r5