rata para bens, colocado retorno no arquivo puxados_bens, algumas con…

…figurações e movido o env para a raiz do projeto para causar menos instabilidades

.env

@@ -0,0 +1,3 @@
+PYTHONPATH=/Gastos-DF-Squad12
+#PYTHONPATH=/home/vini/2projeto/Gastos-DF-Squad12
+

Back/puxador_bens.py

@@ -1,71 +1,92 @@
 import requests
 import re
+from typing import List, Dict, Union
+from pydantic import BaseModel
+from datetime import date
 
-# Fazendo a solicitação GET para a API
-response = requests.get(
-    'https://queridodiario.ok.org.br/api/gazettes?territory_ids=5300108&published_since=2024-01-01&published_until=2024-07-01&querystring=%22EXTRATO%20DO%20CONTRATO%20DE%20AQUISI%C3%87%C3%83O%20DE%20BENS%22&excerpt_size=4000&number_of_excerpts=10000&pre_tags=&post_tags=&size=10000&sort_by=descending_date')
+class DateRange(BaseModel):
+    published_since: date
+    published_until: date
 
-# Verificando se a solicitação foi bem-sucedida
-if response.status_code == 200:
+async def puxador_bens1(date_range: DateRange) -> Union[List[Dict[str, Union[str, float]]], int]:
+    # Formatando as datas no formato americano
+    published_since_str = date_range.published_since.strftime('%Y-%m-%d')
+    published_until_str = date_range.published_until.strftime('%Y-%m-%d')
+    # Fazendo a solicitação GET para a API
+    response = requests.get(
+        f'https://queridodiario.ok.org.br/api/gazettes?territory_ids=5300108&published_since={published_since_str}&published_until={published_until_str}&querystring=%22EXTRATO%20DO%20CONTRATO%20DE%20AQUISI%C3%87%C3%83O%20DE%20BENS%22&excerpt_size=4000&number_of_excerpts=10000&pre_tags=&post_tags=&size=10000&sort_by=descending_date')
+    # Verificando se a solicitação foi bem-sucedida
+    if response.status_code == 200:
 
-    # Convertendo a resposta para JSON
-    dados = response.json()
+        # Convertendo a resposta para JSON
+        dados = response.json()
 
-    # Acessando a lista de gazettes dentro dos dados
-    gazettes = dados['gazettes']
+        # Acessando a lista de gazettes dentro dos dados
+        gazettes = dados['gazettes']
+
+        # Lista para armazenar os dicionários com as informações extraídas
+        results = []
 
-    # Conjunto para armazenar as datas já vistas
-    datas_vistas = set()
+        # Conjunto para armazenar as datas já vistas
+        datas_vistas = set()
 
-    # Iterando sobre cada gazette na lista
-    for gazette in gazettes:
-        # Acessando a data de cada gazette
-        data = gazette['date']
+        # Iterando sobre cada gazette na lista
+        for gazette in gazettes:
+            # Acessando a data de cada gazette
+            data = gazette['date']
 
-        # Verificando se a data já foi impressa
-        if data not in datas_vistas:
-            print("\nData:", data)
-            # Adicionando a data ao conjunto de datas vistas
-            datas_vistas.add(data)
+            # Verificando se a data já foi processada
+            if data not in datas_vistas:
+                # Adicionando a data ao conjunto de datas vistas
+                datas_vistas.add(data)
 
-        # Acessando a lista de excertos de cada gazette
-        excertos = gazette['excerpts']
-        total_diario = 0
+            # Acessando a lista de excertos de cada gazette
+            excertos = gazette['excerpts']
+            total_diario = 0
 
-        # Iterando sobre cada excerto
-        for excerto in excertos:
-            # Remover quebras de linha no meio das palavras
-            excerto = re.sub(r'(\w)-\n(\w)', r'\1\2', excerto)
-            # Remover todas as quebras de linha
-            excerto = excerto.replace('\n', ' ')
+            # Iterando sobre cada excerto
+            for excerto in excertos:
+                # Remover quebras de linha no meio das palavras
+                excerto = re.sub(r'(\w)-\n(\w)', r'\1\2', excerto)
+                # Remover todas as quebras de linha
+                excerto = excerto.replace('\n', ' ')
 
-            # Usando expressão regular para encontrar Empresa, CNPJ, Objeto e Valor
-            empresa_match = re.search(r'(?:FORNECEDOR|empresa)\s+([\w\s\-ÇçÉéÁáÍíÓóÚúÃãÕõâêîôûÂÊÎÔÛäëïöüÄËÏÖÜ]+)\s+.*?CNPJ[\s:nº]*([\d./-]+)', excerto, re.DOTALL)
-            objeto_match = re.search(r'OBJETO:\s*([^\n,]+?(?:,\s*para atender as demandas)?(?:\s*da Vice-Governadoria)?.*?)\s*VALOR', excerto, re.DOTALL)
-            valor_match = re.search(r'VALOR (?:DO CONTRATO)?:\s*R\$ ([\d,.]+)', excerto)
+                # Usando expressão regular para encontrar Empresa, CNPJ, Objeto e Valor
+                empresa_match = re.search(r'(?:FORNECEDOR|empresa)\s+([\w\s\-ÇçÉéÁáÍíÓóÚúÃãÕõâêîôûÂÊÎÔÛäëïöüÄËÏÖÜ]+)\s+.*?CNPJ[\s:nº]*([\d./-]+)', excerto, re.DOTALL)
+                objeto_match = re.search(r'OBJETO:\s*([^\n,]+?(?:,\s*para atender as demandas)?(?:\s*da Vice-Governadoria)?.*?)\s*VALOR', excerto, re.DOTALL)
+                valor_match = re.search(r'VALOR (?:DO CONTRATO)?:\s*R\$ ([\d,.]+)', excerto)
 
-            if empresa_match and objeto_match and valor_match:
-                # Extraindo a empresa e o CNPJ encontrados
-                empresa = empresa_match.group(1).strip()
-                cnpj = empresa_match.group(2).strip()
+                if empresa_match and objeto_match and valor_match:
+                    # Extraindo a empresa e o CNPJ encontrados
+                    empresa = empresa_match.group(1).strip()
+                    cnpj = empresa_match.group(2).strip()
 
-                # Extraindo o objeto encontrado e removendo parte desnecessária
-                objeto = objeto_match.group(1).strip()
+                    # Extraindo o objeto encontrado e removendo parte desnecessária
+                    objeto = objeto_match.group(1).strip()
 
-                # Extraindo o valor encontrado
-                valor = valor_match.group(1)
-                # Removendo caracteres não numéricos, exceto vírgulas e pontos
-                valor_limpo = re.sub(r'[^\d,.]', '', valor)
-                # Removendo pontos extras como separadores de milhar
-                valor_limpo = valor_limpo.replace('.', '')
-                # Trocando a vírgula por ponto para ter o formato correto para float
-                valor_limpo = valor_limpo.replace(',', '.')
-                # Convertendo o valor para float
-                valor_float = float(valor_limpo)
-                total_diario += valor_float
+                    # Extraindo o valor encontrado
+                    valor = valor_match.group(1)
+                    # Removendo caracteres não numéricos, exceto vírgulas e pontos
+                    valor_limpo = re.sub(r'[^\d,.]', '', valor)
+                    # Removendo pontos extras como separadores de milhar
+                    valor_limpo = valor_limpo.replace('.', '')
+                    # Trocando a vírgula por ponto para ter o formato correto para float
+                    valor_limpo = valor_limpo.replace(',', '.')
+                    # Convertendo o valor para float
+                    valor_float = float(valor_limpo)
+                    total_diario += valor_float
 
-                print(f"Empresa: {empresa} -- CNPJ: {cnpj}\nObjeto: {objeto}\nValor: R${valor_float:.2f}")
-        print(f'Dívidas totais = R${total_diario:.2f}')
-else:
-    # Se a solicitação falhar, imprima o código de status
-    print("Erro:", response.status_code)
+                    # Adicionando as informações à lista de resultados
+                    results.append({
+                        "data": data,
+                        "empresa": empresa,
+                        "cnpj": cnpj,
+                        "objeto": objeto,
+                        "valor": valor_float
+                    })
+                    # não adicionei o total diário à lista de resultados pois pode ser facilmente feito pelo front na hora de montar os gráficos.
+                    # mas ficaria assim: results.append({"data": data, "total_diario": total_diario})
+        return results
+    else:
+        # Se a solicitação falhar, retorne o código de status
+        return response.status_code

_config.yml

@@ -1,2 +1,2 @@
 exclude:
-  - api/venv/
+  - venv/

api/main.py

@@ -1,8 +1,20 @@
+from dotenv import load_dotenv
+import os
+
+load_dotenv()
+
+# Agora o PYTHONPATH será configurado conforme o arquivo .env
+import sys
+sys.path.insert(0, os.getenv('PYTHONPATH'))
+
 import uvicorn
 from fastapi import FastAPI 
 
+from puxador_bens.routers import puxador_bens_router
+
 app = FastAPI()
 
+app.include_router(puxador_bens_router.router)
 
 
 

api/puxador_bens/routers/puxador_bens_router.py

@@ -0,0 +1,29 @@
+from fastapi import APIRouter, HTTPException
+from typing import Dict, Any
+from pydantic import BaseModel
+from datetime import date
+#from Back import puxador_bens
+#from ...Back import puxador_bens
+from Back.puxador_bens import puxador_bens1
+
+
+router = APIRouter(prefix="/puxador-bens")
+
+# A data deve ser no formato americano YYYY-MM-DD.
+# Se o formato estiver incorreto ou se as datas não forem fornecidas, o FastAPI retornará um erro 422 de validação.
+
+class DateRange(BaseModel):
+    published_since: date
+    published_until: date
+
+@router.post("/")
+async def post_bens(date_range: DateRange):
+
+    result = await puxador_bens1(date_range)
+
+    if isinstance(result, int):
+        # Se o resultado for um código de status, retorne um erro
+        raise HTTPException(status_code=result, detail=f"Erro ao acessar a API: {result}")
+
+    return result
+