Update namespace for DomainOperations.Products

src/Inventory.Application/DomainOperations/Product/DeleteProducts/DeleteProductsCommand.cs → src/Inventory.Application/DomainOperations/Products/DeleteProducts/DeleteProductsCommand.cs

@@ -1,6 +1,6 @@
 using BuildingBlocks.Application.CQRS.Commands;
 using Inventory.Application.Models;
 
-namespace Inventory.Application.DomainOperations.Product.DeleteProducts;
+namespace Inventory.Application.DomainOperations.Products.DeleteProducts;
 
 internal sealed record DeleteProductsCommand(ProductModel[] Products) : CommandBase;

src/Inventory.Application/DomainOperations/Products/DeleteProducts/DeleteProductsCommandHandler.cs

@@ -0,0 +1,43 @@
+using System.Collections.Generic;
+using System.Linq;
+using System.Threading;
+using System.Threading.Tasks;
+using BuildingBlocks.Application.CQRS.Commands;
+using Inventory.Domain.Orders;
+using Inventory.Domain.Products;
+using Inventory.Domain.Warehouses;
+using Inventory.Persistence.Database.Repositories;
+
+namespace Inventory.Application.DomainOperations.Products.DeleteProducts;
+
+internal sealed class DeleteProductsCommandHandler : ICommandHandler<DeleteProductsCommand>
+{
+    private readonly IProductsRepository _productsRepository;
+    private readonly IOrdersRepository _ordersRepository;
+    private readonly IWarehouseRepository _warehouseRepository;
+
+    public DeleteProductsCommandHandler(IProductsRepository productsRepository, IOrdersRepository ordersRepository, IWarehouseRepository warehouseRepository)
+    {
+        _productsRepository = productsRepository;
+        _ordersRepository = ordersRepository;
+        _warehouseRepository = warehouseRepository;
+    }
+
+    public async Task Handle(DeleteProductsCommand request, CancellationToken cancellationToken)
+    {
+        var productIds = request.Products.Select(productModel => new ProductId(productModel.Id)).ToArray();
+
+        var usedProducts = await _ordersRepository.GetListOfUsedProducts(productIds, cancellationToken);
+        var warehouses = await _warehouseRepository.GetManyByIdsAsync(usedProducts, cancellationToken);
+        foreach (var warehouse in warehouses)
+        {
+            warehouse.DeactivateProduct();
+        }
+
+        var unusedProducts = productIds.Except(usedProducts);
+        foreach (var productId in unusedProducts)
+        {
+            await _productsRepository.DeleteByIdAsync(productId, cancellationToken);
+        }
+    }
+}

src/Inventory.Application/DomainOperations/Product/DeleteProducts/DeleteProductsCommandValidator.cs → src/Inventory.Application/DomainOperations/Products/DeleteProducts/DeleteProductsCommandValidator.cs

@@ -1,6 +1,6 @@
 using FluentValidation;
 
-namespace Inventory.Application.DomainOperations.Product.DeleteProducts;
+namespace Inventory.Application.DomainOperations.Products.DeleteProducts;
 
 internal sealed class DeleteProductsCommandValidator : AbstractValidator<DeleteProductsCommand>
 {

src/Inventory.Application/DomainOperations/Product/GetProductById/GetProductByIdQuery.cs → src/Inventory.Application/DomainOperations/Products/GetProductById/GetProductByIdQuery.cs

@@ -2,6 +2,6 @@
 using BuildingBlocks.Application.CQRS.Queries;
 using Inventory.Application.Models;
 
-namespace Inventory.Application.DomainOperations.Product.GetProductById;
+namespace Inventory.Application.DomainOperations.Products.GetProductById;
 
 internal sealed record GetProductByIdQuery(Guid ProductId) : QueryBase<ProductModel?>;

src/Inventory.Application/DomainOperations/Product/GetProductById/GetProductByIdQueryHandler.cs → src/Inventory.Application/DomainOperations/Products/GetProductById/GetProductByIdQueryHandler.cs

@@ -5,7 +5,7 @@
 using Inventory.Application.Models;
 using Inventory.Domain.Products;
 
-namespace Inventory.Application.DomainOperations.Product.GetProductById;
+namespace Inventory.Application.DomainOperations.Products.GetProductById;
 
 internal sealed class GetProductByIdQueryHandler : IQueryHandler<GetProductByIdQuery, ProductModel?>
 {

src/Inventory.Application/DomainOperations/Product/GetProductById/GetProductByIdQueryValidator.cs → src/Inventory.Application/DomainOperations/Products/GetProductById/GetProductByIdQueryValidator.cs

@@ -1,6 +1,6 @@
 using FluentValidation;
 
-namespace Inventory.Application.DomainOperations.Product.GetProductById;
+namespace Inventory.Application.DomainOperations.Products.GetProductById;
 
 internal sealed class GetProductByIdQueryValidator : AbstractValidator<GetProductByIdQuery>
 {

src/Inventory.Application/DomainOperations/Product/GetProducts/GetProductsStreamQuery.cs → src/Inventory.Application/DomainOperations/Products/GetProducts/GetProductsStreamQuery.cs

@@ -1,6 +1,6 @@
 using Inventory.Application.Models;
 using MediatR;
 
-namespace Inventory.Application.DomainOperations.Product.GetProducts;
+namespace Inventory.Application.DomainOperations.Products.GetProducts;
 
 internal sealed record GetProductsStreamQuery : IStreamRequest<ProductModel>;

src/Inventory.Application/DomainOperations/Product/GetProducts/GetProductsStreamQueryHandler.cs → src/Inventory.Application/DomainOperations/Products/GetProducts/GetProductsStreamQueryHandler.cs

@@ -6,7 +6,7 @@
 using Inventory.Domain.Products;
 using MediatR;
 
-namespace Inventory.Application.DomainOperations.Product.GetProducts;
+namespace Inventory.Application.DomainOperations.Products.GetProducts;
 
 internal sealed class GetProductsStreamQueryHandler : IStreamRequestHandler<GetProductsStreamQuery, ProductModel>
 {

src/Inventory.Application/DomainOperations/Products/ProductDeactivated/ProductDeactivatedNotificationHandler.cs

@@ -0,0 +1,19 @@
+using System.Threading;
+using System.Threading.Tasks;
+using Inventory.Domain.Warehouses.Events;
+using MediatR;
+
+namespace Inventory.Application.DomainOperations.Products.ProductDeactivated;
+
+internal sealed class ProductDeactivatedNotificationHandler : INotificationHandler<ProductDeactivatedEvent>
+{
+    public Task Handle(ProductDeactivatedEvent @event, CancellationToken cancellationToken)
+    {
+        if (@event.RemainingProductsQuantity > 0)
+        {
+            // Handle remaining products management in warehouse.
+        }
+
+        return Task.CompletedTask;
+    }
+}