diff --git a/__pycache__/consultoras.cpython-312.pyc b/__pycache__/consultoras.cpython-312.pyc new file mode 100644 index 0000000..1bdeaa7 Binary files /dev/null and b/__pycache__/consultoras.cpython-312.pyc differ diff --git a/__pycache__/data_handler.cpython-312.pyc b/__pycache__/data_handler.cpython-312.pyc new file mode 100644 index 0000000..5dc4ec0 Binary files /dev/null and b/__pycache__/data_handler.cpython-312.pyc differ diff --git a/__pycache__/datas.cpython-312.pyc b/__pycache__/datas.cpython-312.pyc new file mode 100644 index 0000000..cb8e25f Binary files /dev/null and b/__pycache__/datas.cpython-312.pyc differ diff --git a/__pycache__/gerentes_erp.cpython-312.pyc b/__pycache__/gerentes_erp.cpython-312.pyc new file mode 100644 index 0000000..1d8d3d9 Binary files /dev/null and b/__pycache__/gerentes_erp.cpython-312.pyc differ diff --git a/__pycache__/login.cpython-312.pyc b/__pycache__/login.cpython-312.pyc new file mode 100644 index 0000000..6919dde Binary files /dev/null and b/__pycache__/login.cpython-312.pyc differ diff --git a/busca_pdv.py b/busca_pdv.py deleted file mode 100644 index 5ef59b0..0000000 --- a/busca_pdv.py +++ /dev/null @@ -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) - - diff --git a/consultoras.xlsx b/consultoras.xlsx deleted file mode 100644 index 6763637..0000000 Binary files a/consultoras.xlsx and /dev/null differ diff --git a/data_handler.py b/data_handler.py index b76bdbe..edb7ff6 100644 --- a/data_handler.py +++ b/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() - mensagem = gerp.exec(cpf, primeiro_dia_formatado, hoje_formatado) + dados = GI.main(cpf) + mensagem = f"O realizado dos seus PDVS são {dados} " resposta = f"Olá, {name} " + mensagem else: mensagem = "Seu cpf não está cadastrado." diff --git a/login.py b/login.py index f7b9c66..d82f848 100644 --- a/login.py +++ b/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 \ No newline at end of file + return realizado \ No newline at end of file diff --git a/main.py b/main.py index fee49d9..12e345e 100644 --- a/main.py +++ b/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"