Add method GetCustomersWithPartySizeGreaterThan

DotNetBackendTraining · May 4, 2024 · dd4cde2 · dd4cde2
1 parent 9eb4d2f
commit dd4cde2
Show file tree

Hide file tree

Showing 4 changed files with 18 additions and 0 deletions.
diff --git a/RestaurantReservation.Db/Repositories/ReservationRepository.cs b/RestaurantReservation.Db/Repositories/ReservationRepository.cs
@@ -24,4 +24,11 @@ public IAsyncEnumerable<Reservation> GetAllReservationsByCustomerAsync(int custo
     {
         return await _context.ReservationDetails.FindAsync(reservationId);
     }
+
+    public IAsyncEnumerable<Customer> GetCustomersWithPartySizeGreaterThan(int partySize)
+    {
+        return _context.Customers
+            .FromSqlInterpolated($"EXEC FindCustomersWithPartySizeGreaterThan @PartySize = {partySize}")
+            .AsAsyncEnumerable();
+    }
 }
diff --git a/RestaurantReservation.Domain/Interfaces/Repositories/IReservationRepository.cs b/RestaurantReservation.Domain/Interfaces/Repositories/IReservationRepository.cs
@@ -5,5 +5,8 @@ namespace RestaurantReservation.Domain.Interfaces.Repositories;
 public interface IReservationRepository
 {
     IAsyncEnumerable<Reservation> GetAllReservationsByCustomerAsync(int customerId);
+
     Task<ReservationDetail?> GetReservationDetailAsync(int reservationId);
+
+    IAsyncEnumerable<Customer> GetCustomersWithPartySizeGreaterThan(int partySize);
 }
diff --git a/RestaurantReservation/Application/Interfaces/Services/IReservationService.cs b/RestaurantReservation/Application/Interfaces/Services/IReservationService.cs
@@ -7,4 +7,6 @@ public interface IReservationService
     IAsyncEnumerable<ReservationDto> GetReservationsByCustomerAsync(int customerId);
 
     Task<ReservationDetailDto?> GetReservationDetailAsync(int reservationId);
+
+    IAsyncEnumerable<CustomerDto> GetCustomersWithPartySizeGreaterThan(int partySize);
 }
diff --git a/RestaurantReservation/Application/Services/ReservationService.cs b/RestaurantReservation/Application/Services/ReservationService.cs
@@ -29,4 +29,10 @@ public IAsyncEnumerable<ReservationDto> GetReservationsByCustomerAsync(int custo
         var reservationDetail = await _reservationRepository.GetReservationDetailAsync(reservationId);
         return _mapper.Map<ReservationDetailDto>(reservationDetail);
     }
+
+    public IAsyncEnumerable<CustomerDto> GetCustomersWithPartySizeGreaterThan(int partySize)
+    {
+        return _reservationRepository.GetCustomersWithPartySizeGreaterThan(partySize)
+            .Select(c => _mapper.Map<CustomerDto>(c));
+    }
 }