BaseRepository + ProductRepository

Add update method to process multiple entity updates prior to saving changes

Author: SuiteBee

Controllers/Models/Requests/ShipRequest.cs

@@ -5,7 +5,7 @@ public class ShipRequest
         /// <summary>
         /// List of order ID's
         /// </summary>
-        /// <example>1,2,3</example>
+        /// <example>[1,2,3]</example>
         public required List<int> OrderIds { get; set; }
         /// <summary>
         /// Date shipped

Controllers/Models/Responses/RegionsResponse.cs

@@ -7,7 +7,7 @@ public class RegionsResponse
         /// <summary>
         /// List of global regions
         /// </summary>
-        /// <example>Central America,Western Europe,British Isles</example>
+        /// <example>"Central America,Western Europe,British Isles"</example>
         public IEnumerable<RegionDto> Regions { get; set; } = new List<RegionDto>();
     }
 }

Controllers/OrderController.cs

@@ -1,5 +1,6 @@
 using AutoMapper;
 using Microsoft.AspNetCore.Authorization;
+using Microsoft.AspNetCore.Http.HttpResults;
 using Microsoft.AspNetCore.Mvc;
 using NorthWindAPI.Controllers.Models.Requests;
 using NorthWindAPI.Controllers.Models.Responses;
@@ -12,13 +13,15 @@ namespace NorthWindAPI.Controllers
     public class OrderController(
         IOrderService orderService,
         ICustomerService customerService,
+        IProductService productService,
         IUserService employeeService,
         IMapper mapper,
         ILogger<OrderController> logger
     ) : ControllerBase
     {
         private readonly IOrderService _orderService = orderService;
         private readonly ICustomerService _customerService = customerService;
+        private readonly IProductService _productService = productService;
         private readonly IUserService _employeeService = employeeService;
 
         private readonly IMapper _mapper = mapper;
@@ -119,6 +122,9 @@ public async Task<ActionResult<OrderResponse>> Create(NewOrderRequest newOrder)
         {
             try
             {
+                //Update product stock - subtract quantity ordered from units in stock
+                await _productService.RemoveStock(newOrder.OrderDetail);
+
                 var order = await _orderService.ProcessNewOrder(newOrder);
 
                 if (order == null)
@@ -136,9 +142,9 @@ public async Task<ActionResult<OrderResponse>> Create(NewOrderRequest newOrder)
 
                 return orderResponse;
             }
-            catch
+            catch(Exception ex)
             {
-                return Forbid();
+                return Forbid(ex.Message);
             }
         }
 
@@ -259,10 +265,20 @@ public async Task<ActionResult<ShipOptionResponse>> Carriers()
         [ProducesResponseType(typeof(NoContentResult), StatusCodes.Status200OK)]
         [ProducesResponseType(typeof(BadRequestResult), StatusCodes.Status400BadRequest)]
         [ProducesResponseType(typeof(UnauthorizedResult), StatusCodes.Status401Unauthorized)]
+        [ProducesResponseType(typeof(NotFoundResult), StatusCodes.Status404NotFound)]
         [Authorize]
         [HttpDelete("{id}")]
         public async Task<ActionResult> Delete(int id)
         {
+            var order = await _orderService.FindOrder(id);
+            if(order == null)
+            {
+                return NotFound();
+            }
+
+            //Update product stock - add quantity ordered from order to be deleted
+            await _productService.ReplaceStock(order.Items);
+
             var result = await _orderService.RemoveOrder(id);
             if (!result)
             {

Data/DB/Northwind_data.sqlite

@@ -38,7 +38,6 @@ public async Task<T> AddEntityAsync(T entity)
         /// Delete entity and save changes to database
         /// </summary>
         /// <param name="id"></param>
-        /// <returns></returns>
         public async Task<bool> RemoveEntityAsync(int id)
         {
             var entity = await _dbSet.FindAsync(id);
@@ -54,7 +53,7 @@ public async Task<bool> RemoveEntityAsync(int id)
             }
             catch
             {
-                return true;
+                return false;
             }
 
             return true;
@@ -64,7 +63,6 @@ public async Task<bool> RemoveEntityAsync(int id)
         /// Deletes entity and does not save the changes. Call this method to delete all dependencies and finish with RemoveEntityAsync()
         /// </summary>
         /// <param name="id"></param>
-        /// <returns></returns>
         public async Task<bool> RemoveDependentEntityAsync(int id)
         {
             var entity = await _dbSet.FindAsync(id);
@@ -98,19 +96,39 @@ public async Task<bool> RemoveDependentEntityAsync(int id)
             {
                 await _context.SaveChangesAsync();
             }
-            catch (DbUpdateConcurrencyException)
+            catch (DbUpdateConcurrencyException ex)
             {
                 if (!await _dbSet.AnyAsync(x => x.Id == id))
                 {
                     return entity;
                 }
                 else
                 {
-                    throw;
+                    throw new Exception(ex.Message + " : Error updating entity");
                 }
             }
 
             return await _dbSet.FindAsync(id);
         }
+
+        /// <summary>
+        /// Updates multiple entities before saving because EntityFramework doesn't handle many single updates well
+        /// </summary>
+        /// <param name="entities"></param>
+        public async Task UpdateMultipleEntityAsync(IEnumerable<T> entities)
+        {
+            var entityIdCollection = entities.Select(x => x.Id);
+            var entitiesToUpdate = _dbSet.Where(x => entityIdCollection.Contains(x.Id)).ToList();
+            entitiesToUpdate.ForEach(x => _dbSet.Entry(x).State = EntityState.Modified);
+
+            try
+            {
+                await _context.SaveChangesAsync();
+            }
+            catch (DbUpdateConcurrencyException ex)
+            {
+                throw new Exception(ex.Message + " : Error updating multiple entity");
+            }
+        }
     }
 }

Data/Repositories/BaseRepository.cs

@@ -65,7 +65,7 @@ public async Task<bool> RemoveEntityAsync(string id)
         /// Deletes entity and does not save the changes. Call this method to delete all dependencies and finish with RemoveEntityAsync()
         /// </summary>
         /// <param name="id"></param>
-        /// <returns></returns>
+
         public async Task<bool> RemoveDependentEntityAsync(string id)
         {
             var entity = await _dbSet.FindAsync(id);

Data/Repositories/BaselAltRepository.cs

@@ -108,22 +108,5 @@ public async Task<bool> DeleteOrder(int id)
         }
 
         #endregion
-
-
-
-        //public async Task<List<object>> FindFullOrder(int id)
-        //{
-        //    var sqlRaw =
-        //        "SELECT * " +
-        //        "FROM " +
-        //        "FROM [Order] o " +
-        //        "JOIN [Employee] e ON e.Id = o.EmployeeId " +
-        //        "JOIN [OrderDetail] od ON o.Id = od.OrderId " +
-        //        "JOIN [Product] p ON p.Id = od.ProductId " +
-        //        $"WHERE o.Id = {id}";
-
-        //    var query = FormattableStringFactory.Create(sqlRaw);
-        //    return await _context.Database.SqlQuery<object>(query).ToListAsync();
-        //}
     }
 }

Data/Repositories/OrderRepository.cs

@@ -76,6 +76,11 @@ public async Task<Product> UpdateProduct(int id, Product prod)
             return await _baseProductRepo.UpdateEntityAsync(id, prod);
         }
 
+        public async Task UpdateMultipleProducts(IEnumerable<Product> prods)
+        {
+            await _baseProductRepo.UpdateMultipleEntityAsync(prods);
+        }
+
         #endregion
     }
 }

Data/Repositories/ProductRepository.cs

@@ -8,6 +8,7 @@ public interface IBaseRepository<T> where T : class
         public Task<bool> RemoveEntityAsync(int id);
         public Task<bool> RemoveDependentEntityAsync(int id);
         public Task<T?> UpdateEntityAsync(int id, T entity);
+        public Task UpdateMultipleEntityAsync(IEnumerable<T> entities);
 
     }
 }

Data/RepositoryInterfaces/IBaseRepository.cs

@@ -11,5 +11,6 @@ public interface IProductRepository
         public Task<Category> FindCategory(int categoryId);
         public Task<Supplier> FindSupplier(int supplierId);
         public Task<Product> UpdateProduct(int id, Product prod);
+        public Task UpdateMultipleProducts(IEnumerable<Product> prods);
     }
 }