Aggregation Pipeline în MongoDB: Etapele $match, $group, $project, $lookup și Analiză de Date în Timp Real în MongoDB & NoSQL

db.orders.aggregate([
  // Etapa 1: Filtrare doar comenzile finalizate din anul curent
  { $match: { status: "DELIVERED", createdAt: { $gte: ISODate("2026-01-01") } } },

  // Etapa 2: Expandarea tabloului de produse cumpărate
  { $unwind: "$items" },

  // Etapa 3: Gruparea pe cod produs și calculul cifrelor de afaceri
  {
    $group: {
      _id: "$items.sku",
      totalRevenue: { $sum: { $multiply: ["$items.qty", "$items.price"] } },
      unitsSold: { $sum: "$items.qty" }
    }
  },

  // Etapa 4: JOIN cu colecția 'products' pentru a prelua numele oficial
  {
    $lookup: {
      from: "products",
      localField: "_id",
      foreignField: "sku",
      as: "productDetails"
    }
  },

  // Etapa 5: Sortare descrescătoare după venit
  { $sort: { totalRevenue: -1 } },
  { $limit: 5 }
]);