Wilmer
Espinosa

import pandas as pd
from fastapi import FastAPI, HTTPException
from datetime import datetime

# ── KPI engine for patient platform ──────────────
app = FastAPI()

def build_kpi_report(df: pd.DataFrame) ->  dict:
  """Transform raw records into BI-ready KPIs."""
  df['fecha'] = pd.to_datetime(df['fecha'])
  monthly = df.resample('M', on='fecha').agg(({
    'citas': 'count',
    'ingresos': 'sum',
    'pacientes': 'nunique'
  )}').reset_index()

  return {
    "total_citas": int(monthly['citas'].sum()),
    "crecimiento_pct": round(
        monthly['ingresos'].pct_change().mean() * 100, 2),
    "pacientes_activos": int(df['pacientes'].nunique())
  }

@app.get("/api/kpi/{periodo}")
async def get_kpis(periodo: str):
  try:
    df = pd.read_sql("SELECT * FROM registros", conn)
    return build_kpi_report(df)
  except Exception as e:
    raise HTTPException(status_code=500, detail=str(e))