Update routes/dashboard_home.py

routes/dashboard_home.py

@@ -289,6 +289,85 @@ async def get_monthly_revenue_data(target_date) -> Dict[str, Any]:
         "transfer_count": transfer_data["transfer_count"]
     }
 
+async def get_top_stylists(start_timestamp: Optional[int] = None, end_timestamp: Optional[int] = None, limit: int = 10) -> List[Dict[str, Any]]:
+    """Obtém os estilistas que mais receberam pagamentos no período"""
+    try:
+        # Obter transferências no período
+        query_params = {"limit": 100}
+        
+        # Adicionar filtros de data se fornecidos
+        if start_timestamp and end_timestamp:
+            query_params["created"] = {"gte": start_timestamp, "lte": end_timestamp}
+        elif start_timestamp:
+            query_params["created"] = {"gte": start_timestamp}
+        elif end_timestamp:
+            query_params["created"] = {"lte": end_timestamp}
+        
+        transfers = []
+        has_more = True
+        last_id = None
+        
+        # Usar batch para reduzir chamadas
+        while has_more:
+            if last_id:
+                query_params["starting_after"] = last_id
+            
+            # Usar thread para não bloquear o evento loop
+            transfer_list = await fetch_stripe_data(stripe.Transfer.list, expand=["data.destination"], **query_params)
+            transfers.extend(transfer_list.data)
+            
+            has_more = transfer_list.has_more
+            if transfer_list.data:
+                last_id = transfer_list.data[-1].id
+            else:
+                has_more = False
+        
+        # Agrupar transferências por estilista (destination account)
+        stylist_totals = {}
+        for transfer in transfers:
+            destination = transfer.destination
+            if destination not in stylist_totals:
+                stylist_totals[destination] = {
+                    "account_id": destination,
+                    "total_received": 0
+                }
+            stylist_totals[destination]["total_received"] += transfer.amount
+        
+        # Ordenar estilistas por valor recebido
+        top_stylists_by_account = sorted(
+            stylist_totals.values(), 
+            key=lambda x: x["total_received"], 
+            reverse=True
+        )[:limit]
+        
+        # Buscar informações adicionais dos estilistas no Supabase
+        async with aiohttp.ClientSession() as session:
+            top_stylists = []
+            for stylist_data in top_stylists_by_account:
+                account_id = stylist_data["account_id"]
+                
+                # Buscar usuário correspondente pelo Stripe account_id
+                query_url = f"{SUPABASE_URL}/rest/v1/User?stripe_account_id=eq.{account_id}&select=id,name,avatar"
+                async with session.get(query_url, headers=SUPABASE_HEADERS) as response:
+                    if response.status == 200:
+                        user_data = await response.json()
+                        if user_data and len(user_data) > 0:
+                            # Combinar dados do Stripe com dados do Supabase
+                            stylist_info = {
+                                "id": user_data[0].get("id"),
+                                "name": user_data[0].get("name", "Estilista"),
+                                "avatar": user_data[0].get("avatar"),
+                                "total_received": stylist_data["total_received"],
+                                "total_transfers": stylist_totals[account_id].get("total_transfers", 1)
+                            }
+                            top_stylists.append(stylist_info)
+        
+        return top_stylists[:limit]
+        
+    except Exception as e:
+        logger.error(f"❌ Erro ao obter top estilistas: {str(e)}")
+        return []
+
 @router.get("/admin/dashboard")
 async def get_admin_dashboard(
     user_token: str = Header(None, alias="User-key"),
@@ -320,7 +399,8 @@ async def get_admin_dashboard(
         tasks = [
             get_total_platform_revenue(start_timestamp, end_timestamp),
             get_platform_transfers(start_timestamp, end_timestamp),
-            get_platform_users()
+            get_platform_users(),
+            get_top_stylists(start_timestamp, end_timestamp, 10)
         ]
         
         # Adicionar task para dados mensais se necessário
@@ -335,9 +415,9 @@ async def get_admin_dashboard(
         
         # Extrair resultados
         if period == "last_month":
-            revenue_data, transfer_data, user_data, monthly_data = results
+            revenue_data, transfer_data, user_data, top_stylists, monthly_data = results
         else:
-            revenue_data, transfer_data, user_data = results
+            revenue_data, transfer_data, user_data, top_stylists = results
             monthly_data = None
         
         # Calcular divisão de receita
@@ -358,7 +438,8 @@ async def get_admin_dashboard(
             "transfer_count": transfer_data["transfer_count"],
             "currency": "BRL",
             "period": period,
-            "users": user_data
+            "users": user_data,
+            "top_stylists": top_stylists
         }
         
         # Adicionar dados específicos de mês apenas para período last_month