Update app.py

app.py

@@ -30,7 +30,7 @@ async def get_total_revenue(ano: int):
         )  # Usa a função text() para executar a consulta
         result = conn.execute(stmt).fetchone()
         if result:
-            return {"total_revenue": result[2]}
+            return {"total_revenue": result[1]}
         else:
             raise HTTPException(status_code=404, detail="KPI não encontrada")
 
@@ -90,7 +90,7 @@ async def get_best_selling_product_value(ano: int):
         stmt = text(f"SELECT * FROM best_selling_product_value WHERE year = {ano}")
         result = conn.execute(stmt).fetchone()
         if result:
-            return {"produto": result[1], "total_product_revenue": result[2]}
+            return {"produto": result[0], "total_product_revenue": result[2]}
         else:
             raise HTTPException(status_code=404, detail="KPI não encontrada")
 
@@ -102,7 +102,7 @@ async def get_best_selling_product_quantity(ano: int):
         stmt = text(f"SELECT * FROM best_selling_product_quantity WHERE year = {ano}")
         result = conn.execute(stmt).fetchone()
         if result:
-            return {"produto": result[1], "total_product_quantity": result[2]}
+            return {"produto": result[0], "total_product_quantity": result[2]}
         else:
             raise HTTPException(status_code=404, detail="KPI não encontrada")
 
@@ -113,16 +113,16 @@ async def get_product_revenue(ano: int):
     with engine.connect() as conn:
         results = conn.execute(text(f"SELECT * FROM product_revenue WHERE year = {ano}")).fetchall()
         if results:
-            return [{"produto": row[1], "product_revenue": row[2]} for row in results]
+            return [{"produto": row[0], "product_revenue": row[2]} for row in results]
         else:
             raise HTTPException(status_code=404, detail="KPI não encontrada")
 
 
 # Endpoint para obter o Vendedor com Mais Vendas (em Valor)
 @app.get("/top3_salesperson_value/{ano}")  # Adiciona o parâmetro 'ano'
-async def get_top_salesperson_value(ano: int):
+async def get_top3_salesperson_value(ano: int):
     with engine.connect() as conn:
-        stmt = text(f"SELECT * FROM top3_salesperson_value WHERE year = {ano}")
+        stmt = text(f"SELECT * FROM revenue_per_salesperson WHERE year = {ano} Order by revenue_per_salesperson Desc LIMIT 3")
         result = conn.execute(stmt).fetchone()
         if result:
             return {"email": result[1], "salesperson_total_revenue": result[2]}
@@ -132,12 +132,12 @@ async def get_top_salesperson_value(ano: int):
 
 # Endpoint para obter o Vendedor com Mais Vendas (em Quantidade)
 @app.get("/top3_salesperson_quantity/{ano}")  # Adiciona o parâmetro 'ano'
-async def get_top_salesperson_quantity(ano: int):
+async def get_top3_salesperson_quantity(ano: int):
     with engine.connect() as conn:
-        stmt = text(f"SELECT * FROM top3_salesperson_quantity WHERE year = {ano}")
+        stmt = text(f"SELECT * FROM sales_per_salesperson WHERE year = {ano} Order by sales_per_salesperson Desc LIMIT 3")
         result = conn.execute(stmt).fetchone()
         if result:
-            return {"email": result[1], "salesperson_total_sales": result[2]}
+            return {"email": result[0], "salesperson_total_sales": result[2]}
         else:
             raise HTTPException(status_code=404, detail="KPI não encontrada")
 
@@ -149,7 +149,7 @@ async def get_sales_per_salesperson(ano: int):
         results = conn.execute(text(f"SELECT * FROM sales_per_salesperson WHERE year = {ano}")).fetchall()
         if results:
             return [
-                {"email": row[1], "sales_per_salesperson": row[2]} for row in results
+                {"email": row[0], "sales_per_salesperson": row[2]} for row in results
             ]
         else:
             raise HTTPException(status_code=404, detail="KPI não encontrada")
@@ -177,7 +177,7 @@ async def get_sales_per_day(ano: int):
         results = conn.execute(text(f"SELECT * FROM  sales_per_day WHERE year = {ano}")).fetchall()
         if results:
             return [
-                {"sales_date": str(row[1]), "sales_per_day": row[2]} for row in results
+                {"sales_date": str(row[0]), "sales_per_day": row[2]} for row in results
             ]
         else:
             raise HTTPException(status_code=404, detail="KPI não encontrada")
@@ -190,7 +190,7 @@ async def get_sales_per_month(ano: int):
         results = conn.execute(text(f"SELECT * FROM  sales_per_month WHERE year = {ano}")).fetchall()
         if results:
             return [
-                {"sales_year": row[1], "sales_month": row[2], "sales_per_month": row[2]}
+                {"sales_year": row[0], "sales_month": row[1], "sales_per_month": row[2]}
                 for row in results
             ]
                     
@@ -202,9 +202,9 @@ async def get_sales_per_month(ano: int):
 @app.get("/sales_per_year/{ano}")  # Adiciona o parâmetro 'ano'
 async def get_sales_per_year(ano: int):
     with engine.connect() as conn:
-        results = conn.execute(text(f"SELECT * FROM  sales_per_year WHERE year = {ano}")).fetchall()
+        results = conn.execute(text(f"SELECT * FROM  sales_per_year WHERE sales_year = {ano}")).fetchall()
         if results:
-            return [{"sales_year": row[1], "sales_per_year": row[2]} for row in results]
+            return [{"sales_year": row[0], "sales_per_year": row[1]} for row in results]
         else:
             raise HTTPException(status_code=404, detail="KPI não encontrada")
 
@@ -230,7 +230,7 @@ async def get_revenue_per_month(ano: int):
         results = conn.execute(text(f"SELECT * FROM  revenue_per_month WHERE year = {ano}")).fetchall()
         if results:
             return [
-                {"revenue_year": row[1], "revenue_month": row[2], "revenue_per_month": row[2]}
+                {"revenue_year": row[0], "revenue_month": row[1], "revenue_per_month": row[2]}
                 for row in results
             ]
         else:
@@ -241,7 +241,7 @@ async def get_revenue_per_month(ano: int):
 @app.get("/revenue_per_year/{ano}")  # Adiciona o parâmetro 'ano'
 async def get_revenue_per_year(ano: int):
     with engine.connect() as conn:
-        results = conn.execute(text(f"SELECT * FROM  revenue_per_year WHERE year = {ano}")).fetchall()
+        results = conn.execute(text(f"SELECT * FROM  revenue_per_year WHERE revenue_year = {ano}")).fetchall()
         if results:
             return [
                 {"revenue_year": row[1], "revenue_per_year": row[2]} for row in results