QjHUdZddlmZddlZddlZddlZddlZddlZddlmZm Z m Z ddl m Z ddl mZe dZedZed Zej$d Zej(Zgdd d d Zd ed<dZej2dZd dZd!dZd"dZd#dZd$dZd%dZ d&dZ! d' d(dZ"d)dZ#d*dZ$d+d,dZ% d- d.dZ&d/dZ'd0dZ( d1 d2dZ)y)3a Modulo de VENDAS REAIS (CAPI PX3). Parseia /opt/mia/logs/track_capi_px3.log procurando eventos Purchase enviados ao Facebook. Retorna agregacoes por periodo, produto, vendedor e curva diaria. - Live vs Backfill: eventos com event_id comecando por "backfill-vra-" sao considerados historicos (importacoes retroativas) e ficam SEPARADOS da contagem viva. O front escolhe se soma ou nao. - Test mode: eventos com test_mode=true nao entram nas metricas de producao. ) annotationsN)datetime timedeltatimezone)Path)ZoneInfoz /opt/mia/logs/track_capi_px3.logzAmerica/Sao_PauloUTCzCAPI\s+(\{.*\})\s*$) purchaseslog_size log_mtimetsdict_CACHExvendasc|j}|rd|vrytj|}|sy tj|j d}|jddk7ry|S#t $rYywxYw)NPurchaseevent)strip _CAPI_LINE_REsearchjsonloadsgroup Exceptionget)linemds 6/opt/mia/workspace/clientes/px3lab/dashboard/vendas.py _parse_liner#0sy :: 99 6*B sAA AAcz|xsdjj}|sy|jdddvry|S)zSNormaliza content_name variantes (FOTODRIVE/FOTO DRIVE/PHOTO DRIVE -> PHOTO DRIVE).z SEM PRODUTO ) FOTODRIVE PHOTODRIVE PHOTO DRIVE)rupperr&) content_namens r" _norm_produtorKws@  ""$**,A yyb88 Hc |xsdjj}|sy|jdry|jdr;|jd}t |dk\r|d}|j rd |S|Sy) z event_id observado: backfill-vra-r39-20260527 vra-paulo-prod-1787593107 vra-9483 vra-public-1787593154 vra-integracao-test-1787593825 Extrai a "tag" logo apos "vra-" (paulo, public, integracao, 9483 etc.) rC desconhecido backfill-vrabackfillzvra--rz execucao )rlower startswithsplitlenisdigit)event_ideidpartstags r"_extrair_vendedorr\s >r " ( ( *C  ~~n% ~~f # u:?(C{{}"3%((J rLcH|xsdjjdS)NrCrO)rSrT)rXs r" _is_backfillr^s N ! ! # . .~ >>rLc6t|jdS)N test_mode)boolr)purchases r"_is_testrcs  [) **rLcg}|D]k}t|jdd}|s!||cxkr|ksn/|st|jddrM|s t|r[|j |m|S)NrrCrX)rArr^rcr2)r inicio_utcfim_utcincluir_backfill incluir_testoutpr@s r"filtrar_periodorksx C   quuT2 ' b+G+ Lz21F$G   1   JrLc t|xsd}|d}|jddjddjdd}d|S#ttf$rd}YNwxYw)Nrr z,.2f,@.zR$ )float TypeError ValueErrorr&)valuevss r"_fmt_brlrvsq %*1  T(A #s##C-55c3?A 9 z " sA A A c t|}d}i}i}i}|D]$}d} t|jdxsd}||z }t |jdd}||vrddd||<||dxxdz cc<||d xx|z cc<t |jd d} | rP| jtjd } | |vrddd|| <|| dxxdz cc<|| d xx|z cc<t|jd d} | |vrddd|| <|| dxxdz cc<|| d xx|z cc<'|r||z nd} |jD cgc](\} }| |dt|d d t|d d*}} }|jdg}t|j!D]S}||} t#j$|d jd}|j)|||dt|d d dU|jD cgc](\} }| |dt|d d t|d d*}} }|jd|t|d t|t| d t| d|||dS#ttf$rd}YpwxYwcc}} w#t&$r|}YwxYwcc}} w)z0Agrega KPIs, produtos, curva diaria, vendedores.r rsrrIrC)rreceitarrrxrz%Y-%m-%drXrR)produtorrx receita_fmtc|d SNrxxs r"z agregar_vendas..s q|mrLkeyz%d/%m)datadata_isorrx)vendedorrrxrzc|d Sr|r}r~s r"rz agregar_vendas.. s 9 rL) total_vendas receita_totalreceita_total_fmt ticket_medioticket_medio_fmt)kpis por_produto curva_diaria vendedores)rVrprrqrrrKrA astimezoneTZ_BRstrftimer\itemsroundrvsortsortedkeysrstrptimerr2)rtotalrxrpor_dia por_vendedorrjvalprodr@data_brvendrkrtprodutos_lista dias_listar!infolabelvendedores_listas r"agregar_vendasrsJ KEG#%K!G$&L - g+!,C 3QUU>267 { "+, =K D(#q(#D)$+$ quuT2 ' mmE*33J?Gg%./C#@ G X &! + & G Y '3 . ' z2!67 | #,-#!>L T8$)$T9%,%5-8).GeO3L  %%' Aq8q|Q9O 9. 0N 34J GLLN #  qz %%a4==gFE 8nT)_a0    !&&( Aq!H+%) a:P 9. 0 56""7A.!)'!2!,2 ( 6  &"&  o:& C 6 E s/J-J/%J5!-KJ,+J,5 KKctjt}|jdddd}|jdddd}|t dz }|jddddt |dz z }t ||j t|j t}t ||j t|j t}t|} t|} |r | dd |z nd } | dd } d } | dkDr| dd | z | z d z} d }| dkDr| dd | z | z d z}| d|t| d t| d t| dt| dt|dddS)zkCompara vendas de HOJE vs media dos ultimos `janela_dias` dias anteriores. Ignora backfill e test. r)hourminutesecond microsecond;r)seconds)daysrrr rdrR)dias vendas_diarr) vendas_pct ticket_pct)hoje media_janeladiff) rr6rr&rrkrr?rrrv)r janela_diasnow_brhoje_inihoje_fim janela_fim janela_inirjanelaagg_hoje agg_janela media_vendas media_ticketdiff_vendas_pctdiff_ticket_pcts r"comparar_hoje_mediars\\% F~~1Qqa~HH~~2b~KHIa00J##1QA#NQZ`kno`oQppJ 9h&9&9&&A8CVCVW]C^ _D Y (=(=f(EzG\G\]cGd eFd#H'JITJv&~6DZ]Lf%n5LOa$V,^<|K|[^aaOa$V,^<|K|[^aa  a0!,2 ( 6   33   rLc t}t||||}t|}|Dcgc]a}t|j ddrDt |j ddr)|t |j ddcxkr|krnn|c}}t|}t |d} |d|d|d |d |dd |dd |dd d| t|tjtjddScc}w)ztPonto de entrada usado pelo app.py. Retorna dict pronto com KPIs + curva + produtos + vendedores + alertas. )rgrXrCr)rrrrrrrr)rrrr)timespec)rrrrhistorico_backfillalerta total_no_log gerado_em) r:rkrr^rrArrVrr6r? isoformat) rerfrgr liveaggrjhistorico_puro agg_historicors r"coletar_vendasrDs5 !I 9j'L\ ]D  C  j"- .9QUU4_3MR\`ijkjojoptvxjy`zSFFSF N#>2M  :FF =)N+,')&1.A*62?C!.v!67J!K I\\&)33Y3G  sA&DcDddlm}|jd}|||S)zFReusa a mesma logica do tracking mas escolhe entre first e last touch.r)_classificar_canal attributions)modo)trackingrr)contatorrrs r"_classificar_contato_por_modorms",;;~.L l 66rLcdddddd}|jdixsi}i}|jD]U\}}|jD]=\}}|s |j|jvs*|||j<UW|S)a Tenta montar um mapa {tag_compra: valor_padrao_produto} a partir do tags_cfg (arquivo /tmp/px3_tags_linkia.json). Se nao houver valor, retorna dict vazio (o cruzamento cai no fallback proporcional). Suporta duas fontes: - tags_cfg['compra_produtos'][tag] = 'nome_produto' -> usa mapa produto->valor abaixo - hardcoded fallback pra produtos PX3 conhecidos gr@g@gx@)rGz CLOUD PHOTORFz E-PHOTORFzCHECKOUT PHOTORFz FAST ALBUMcompra_produtos)rrrS)tags_cfg PRECO_APROX tag_produtomapar[rychavevalors r"_mapa_valor_por_produtorus! K,,0"5;K D#))+ W'--/ LE55;;=GMMO;$)SYY[!  KrLctd|jD}td|D}t|} |} i} |dk(rI|rF|rCtd|j dgD} t |} dDcic] }|dddd  } }| Dcic]}|d}}|D]}|j d xsgDcgc]}t |j}}|Dcgc] }|| vs| }}|sSt|d}|| vrd }| |d xxd z cc<|D]2}| |dxxd z cc<| |dxx| j |dz cc<4||xxd z cc<td| jD}|dkDr |dkDr||z }nd}d} nd} g}|jD]3\}}t|j ddxsd}t|j ddxsd}| dk(rP|| vrL| |}t|dzd}|d}|}|ttd| jDd z } n+|dkDr||z } nd} t|| zd}t| | zd }d}!|dk(r|}!n|dk(r|}!|!dkDr||!z nd}"|dkDr|!|z nd}#|j|||t| dzd ||t|!dt|"dt|#dd 6|jd|| t|d| |t|dt|d|dkDrttd|D|z dnd|dkDrttd|D|z dndddScc}wcc}wcc}wcc}w)a Combina CAPI (receita real) com atribuicao GHL pra calcular ROAS por canal. Metodos: - "proporcional" (padrao, legado): receita CAPI eh distribuida entre canais seguindo a proporcao de compras GHL (share_compras). Simples, sem depender de bater 1-to-1. - "last_touch": para cada contato GHL que comprou, reclassifica o canal pelo last-touch (attribution mais recente) e soma valor aproximado por tag de compra (a partir de tags_cfg + precos conhecidos). Fica mais fiel para canal, mas o valor TOTAL pode divergir do CAPI (calibra pra CAPI ao final via factor de correcao). O metodo "last_touch" precisa de `contatos_ghl` e `tags_cfg`. Se nao vier, cai automaticamente pro "proporcional". c3HK|]}|jddxsdyw)comprasrN)r).0dadoss r" z(cruzar_com_atribuicao..s(+09a %A %s "c3XK|]"}t|jdxsd$yw)rsrN)rpr)rrjs r"rz(cruzar_com_atribuicao..s"PAU155>#6Q7Ps(* last_touchc3<K|]}|jyw)N)rS)rts r"rz(cruzar_com_atribuicao..sH!'')Hscompra)metagooglewhatsappcrmdiretorr ) compradoresr receita_brutatagsrrrrrc3&K|] }|d yw)rNr}rrts r"rz(cruzar_com_atribuicao..sP?+P proporcionalleadsrRc3&K|] }|d yw)rNr}rs r"rz(cruzar_com_atribuicao..s*\A1Y<*\rrrr) canalr compras_ghl share_comprasvendas_atribuidasreceita_atribuidagastoroascpac|d S)Nrr}r~s r"rz'cruzar_com_atribuicao..s1%8#9"9rLrc38K|]}|ddk(s |dyw)rrrNr}rcs r"rz(cruzar_com_atribuicao..s%#gqRST[R\`fRfA&9$:#g  c38K|]}|ddk(s |dyw)rrrNr}rs r"rz(cruzar_com_atribuicao..s%%kTUV]T^bjTja(;&<%kr) receita_capi vendas_capir gasto_meta gasto_google roas_meta roas_google)canaismetodototais)sumvaluesrVsetrrstrrSrrintrmaxr2r)$vendas_periodoatribuicao_por_canalr r  contatos_ghlrrtotal_ghl_comprastotal_receita_capitotal_vendas_capimetodo_efetivocanais_last_touch tags_compra valor_por_tagrcontatos_com_compra_por_canalrrrcompras_do_contatorr[ soma_brutafator canais_outr compras_cleads_cltr compras_lastrsharerrrs$ r"cruzar_com_atribuicaor-sJ24H4O4O4QPPPN+N  ,8HX\\(B-GHH /9 E  qQE E  8I(I!A(I%(I# 6G-4[[-@-FBHqCFLLNHDH-1!FQ+5E!!F !F%1'<HE--  e $] 3q 8 3) Y!%(3q83!%(9]=N=NsTW=XX9 Y *% 0A 5 0 6 P5F5M5M5OPP >014&3EE+N'J,224( u )Q/415 eii+0q1 \ )e7H.H#5)B %b&9E&A1 E i=L ,  3s*\ARAYAYA[*\'\^_#``E!1$!$55 %&85&@! D  %&7%&? C  F?E h  E.3ai!E)S%.]uy $"53;2!2!25!_$Na=  =( VOO9O: !"4a8,, A.!,2~HKL~L#gJ#g gjt twxyRUDPSTDT5#%kj%k"knz"z}~Z]   Y )JH!Fs?M# M(; M-! M2+M2)rrreturn dict | None)r. list[dict])rrr.zdatetime | None)rIrr.r)rXrr.r)rXrr.ra)rbrr.ra)FF) r r0rerrfrrgrarhrar.r0)r.r)rr0r.r)r)r r0rrr.r)F)rerrfrrgrar.r)rrrrr.r)rrr.r)NNr)rr0rrr rpr rprzlist[dict] | Nonerr/rrr.r)*__doc__ __future__rrloggingre threadingr-rrrpathlibrzoneinforr*rr?compilerLockr)r__annotations__r0 getLoggerr3r#r:rArKr\r^rcrkrvrrrrrr-r}rLr"r<s #   22 2 3$% % 12 inn    g!  %V  6?+#      ,Nb(\### ## #R7F'+  ~~~~ ~ $ ~  ~ ~ ~rL