Testando webhook

busca_pdv.py

@@ -1,21 +0,0 @@
-import pandas as pd
-
-def extract_data(file):
-    consultoras = pd.read_excel(f"{file}", sheet_name="PDV")
-    consultoras.drop(index=1, inplace=True)
-    consultoras.columns = consultoras.iloc[0]
-    consultoras.drop(index=0, inplace=True)
-    consultoras= consultoras.iloc[:,[0,2,3,8,9]]
-    consultoras.columns =  ['PDV','GMV ATUAL', 'VAR GMV', 'BOLETO MEDIO', 'VAR BOL']
-    return consultoras 
-
-def busca_realizado(codigo_pesquisar):
-    dimensao = pd.read_csv('Dimensao.csv',encoding='utf-8')
-    df = dimensao
-    codigos_correspondentes = df[(df['cpf_gr'] == codigo_pesquisar) | (df['cpf_sup'] == codigo_pesquisar)]['codigo'].tolist()
-    dados = extract_data("consultoras.xlsx")
-    pdv_filtrados = dados[dados['PDV'].isin(codigos_correspondentes)]
-    receita_gmv = pdv_filtrados["GMV ATUAL"].sum()
-    return int(receita_gmv)
-
-

data_handler.py

@@ -25,18 +25,16 @@ def extract_message_data(data):
         
         elif number in user_states and user_states[number] == "aguardando_nome":
             # Usuário enviou o nome da consultora, processar a consulta
+            
             cpf = message.strip()
             cpf = int(cpf)
             hoje = datetime.today()
-            primeiro_dia_mes = hoje.replace(day=1)
-            hoje_formatado = hoje.strftime('%Y-%m-%d')
-            primeiro_dia_formatado = primeiro_dia_mes.strftime('%Y-%m-%d')
             gerp.log_pdv(cpf)
 
             if cpf in dimensao['cpf_gr'].values or cpf in dimensao['cpf_sup'].values:
             # Executa a consulta no sistema ERP
-                dados = GI.main()
+                dados = GI.main(cpf)
-                mensagem = gerp.exec(cpf, primeiro_dia_formatado, hoje_formatado)
+                mensagem = f"O realizado dos seus PDVS são {dados} "
                 resposta = f"Olá, {name} " + mensagem
             else:
                 mensagem = "Seu cpf não está cadastrado."

login.py

@@ -197,13 +197,13 @@ def busca_realizado(codigo_pesquisar, file):
     dimensao = pd.read_csv('Dimensao.csv',encoding='utf-8')
     df = dimensao
     codigos_correspondentes = df[(df['cpf_gr'] == codigo_pesquisar) | (df['cpf_sup'] == codigo_pesquisar)]['codigo'].tolist()
-    dados = extract_data(f"{file}")
+    dados = extract_data(file)
     pdv_filtrados = dados[dados['PDV'].isin(codigos_correspondentes)]
     receita_gmv = pdv_filtrados["GMV ATUAL"].sum()
     return int(receita_gmv)
 
 # Processo principal
-def main():
+def main(codigo_pesquisar):
     session = requests.Session()  # Iniciar uma sessão persistente
 
     code_verifier = generate_code_verifier()
@@ -245,7 +245,7 @@ def main():
     else:
              print("Falha ao carregar ou processar o JSON.")
 
-    url = c.consultoras(Access, d.acumulado_do_dia_atual()[0], d.acumulado_do_dia_atual()[1])
+    url = c.consultoras(Access, d.acumulado_mes_atual()[0], d.acumulado_mes_atual()[1])
     baixar = requests.get(url)
     file_name = f"consultoras{d.data_hora_atual()}.xlsx"
     if baixar.status_code == 200:
@@ -253,7 +253,8 @@ def main():
          with open(file_name, "wb") as file:
             file.write(baixar.content)
             dados = extract_data(file_name)
+            realizado  = busca_realizado(codigo_pesquisar, file_name)
             print(f"Arquivo salvo com sucesso como {file_name}.")
     else:
         print(f"Erro ao acessar o arquivo. Código de status: {baixar.status_code}")
-    return dados
+    return realizado

main.py

@@ -1,8 +1,7 @@
 from flask import Flask, request, jsonify
 from data_handler import extract_message_data
 import requests
-import gerentes_erp as gerp
+
-import login as lg
 
 # URL do endpoint
 url = "http://localhost:8081/message/sendText/Consultme"