Create main.py

main.py

@@ -0,0 +1,167 @@
+from fastapi import FastAPI, HTTPException
+from pydantic import BaseModel
+import requests
+import pandas as pd
+from io import StringIO
+import warnings
+
+app = FastAPI()
+
+class ConsultaParams(BaseModel):
+    fecha_inicio_value: str
+    fecha_fin_value: str
+    cod_donacion: str
+
+@app.post("/consulta")
+async def consulta_data(params: ConsultaParams):
+    fecha_inicio_value = params.fecha_inicio_value
+    fecha_fin_value = params.fecha_fin_value
+    cod_donacion = params.cod_donacion
+
+    # Desactivar todas las advertencias
+    warnings.filterwarnings("ignore")
+
+    # Desactivar las advertencias de FutureWarning
+    warnings.simplefilter(action='ignore', category=FutureWarning)
+
+    # URL sin filtros de fecha
+    url = "https://beneficiarios.eatcloud.info/api/abaco/eatc_match_registry?eatc-dona_header_code=_*&_csv"
+
+    # Realizar la solicitud a la API
+    response = requests.get(url)
+
+    # Verificar si la solicitud fue exitosa (código de estado 200)
+    if response.status_code == 200:
+        # Obtener la URL del archivo CSV desde la respuesta JSON
+        csv_url = response.json()["csv"]
+
+        # Descargar el archivo CSV
+        csv_data = requests.get(csv_url).content
+
+        # Convertir los datos CSV a un DataFrame de pandas con punto y coma como delimitador
+        df_match = pd.read_csv(StringIO(csv_data.decode('latin-1')), delimiter=';')
+
+        # Generar un archivo CSV con el DataFrame
+        #df_match.to_csv('df_match.csv', index=False)
+
+        # Imprimir mensaje de éxito
+        print("Proceso completado: carga datos de match.")
+    else:
+        print("Error al realizar la solicitud a la API. Código de estado:", response.status_code)
+
+    # Verificar si ambas fechas fueron ingresadas
+    if fecha_inicio_value is not None and fecha_fin_value is not None:
+        # Construir la URL con las fechas ingresadas
+        url = f"https://donantes.eatcloud.info/api/abaco/eatc_dona_headers?eatc-publication_date[0]={fecha_inicio_value}&eatc-publication_date[1]={fecha_fin_value}&_csv"
+
+        # Realizar la solicitud a la API
+        response = requests.get(url)
+
+        # Verificar si la solicitud fue exitosa (código de estado 200)
+        if response.status_code == 200:
+            # Obtener la URL del archivo CSV desde la respuesta JSON
+            csv_url = response.json()["csv"]
+
+            # Descargar el archivo CSV
+            csv_data = requests.get(csv_url).content
+
+            # Convertir los datos CSV a un DataFrame de pandas con punto y coma como delimitador
+            df_headers = pd.read_csv(StringIO(csv_data.decode('latin-1')), delimiter=';')
+            # Generar un archivo CSV con el DataFrame
+            #df_headers.to_csv('df_headers.csv', index=False)
+            # Imprimir mensaje de éxito
+            print("Proceso completado. Carga de datos de donación")
+        else:
+            print("Error al realizar la solicitud a la API. Código de estado:", response.status_code)
+    else:
+        print("Por favor, ingrese ambas fechas.")
+
+    #FILTRAR POR CODIGO INGRESADO cod_donacion
+
+    # Desactivar las advertencias de FutureWarning
+    warnings.simplefilter(action='ignore', category=FutureWarning)
+
+    # Filtrar registros para 'eatc-donation_manager_code' igual a '805025018'
+    filtro_codigo = df_match['eatc-dona_header_code'] == f"{cod_donacion}"
+    df_filtrado_cod = df_match[filtro_codigo].copy()
+
+    # Contar la cantidad de registros
+    cantidad_registros = len(df_filtrado_cod)
+
+    # Visualizar 'eatc-pod_name' y 'eatc-dona_header_code'
+    if cantidad_registros > 0:
+        pod_name_y_dona_header_code = df_filtrado_cod[['eatc-pod_name', 'eatc-dona_header_code']]
+        print(f"Para 'eatc-dona_header_code' igual a '{cod_donacion}', hay {cantidad_registros} registros en el MATCH:")
+    else:
+        print(f"LA DONACIÓN INGRESADA 'eatc-dona_header' igual a '{cod_donacion}' NO TIENE REGISTROS EN EL MATCH")
+
+    #RESULTADOS
+
+    # URL del nuevo API
+    url = "https://donantes.eatcloud.info/api/abaco/eatc_dona_headers"
+
+    # Parámetros de la consulta
+    params = {
+        'eatc-code': cod_donacion
+    }
+
+    # Realizar la consulta al nuevo API
+    response = requests.get(url, params=params)
+
+    # Verificar si la solicitud fue exitosa (código de estado 200)
+    if response.status_code == 200:
+        # Obtener los datos en formato JSON
+        data = response.json()
+
+        # Extraer los campos específicos e imprimirlos
+        result = data.get('res', [])
+
+        for item in result:
+            for key, value in item.items():
+                print(f"{key}: {value}")
+            print()  # Separador entre elementos
+
+    else:
+        # Imprimir un mensaje de error si la solicitud no fue exitosa
+        print(f"Error en la solicitud. Código de estado: {response.status_code}")
+        print(response.text)
+
+    #VERIFICAR REGLA DEL MATCH
+
+    # URL del nuevo API
+    url = "https://donantes.eatcloud.info/api/abaco/eatc_dona_headers"
+
+    # Par��metros de la consulta
+    params = {
+        'eatc-code': cod_donacion
+    }
+
+    # Realizar la consulta al nuevo API
+    response = requests.get(url, params=params)
+
+    # Verificar si la solicitud fue exitosa (código de estado 200)
+    if response.status_code == 200:
+        # Obtener los datos en formato JSON
+        data = response.json()
+
+        # Extraer los campos específicos
+        result = data.get('res', [])
+
+        for item in result:
+            # Verificar si el campo eatc_match_asignation_rule está vacío
+            match_rule = item.get('eatc_match_asignation_rule', '')
+            if not match_rule:
+                print("ESTA DONACIÓN NO TIENE REGLA DE MATCH")
+            else:
+                print(f"LA REGLA DEL MATCH PARA ESTA DONACIÓN ES: {match_rule}")
+
+    else:
+        # Imprimir un mensaje de error si la solicitud no fue exitosa
+        print(f"Error en la solicitud. Código de estado: {response.status_code}")
+        print(response.text)
+
+    return {"message": "Consulta realizada exitosamente", "fecha_inicio_value": fecha_inicio_value, "fecha_fin_value": fecha_fin_value, "cod_donacion": cod_donacion}
+
+if __name__ == "__main__":
+    import uvicorn
+    uvicorn.run(app, host="0.0.0.0", port=8000)