From f9c90bb87126317be5c245d063c67d358f4cbe5e Mon Sep 17 00:00:00 2001
From: masoodafar-web <masoud.afarin.moghaddam@outlook.com>
Date: Sun, 4 Jan 2026 23:29:02 +0330
Subject: [PATCH] fix: Synchronize RemainingCount for Regular and Discount
 products in inventory commands

---
 .../IncreaseInventoryCommandHandler.cs        | 20 +++++++++++++++++++
 .../ReduceInventoryCommandHandler.cs          | 20 +++++++++++++++++++
 2 files changed, 40 insertions(+)

diff --git a/src/CMSMicroservice.Application/InventoryItemCQ/Commands/IncreaseInventory/IncreaseInventoryCommandHandler.cs b/src/CMSMicroservice.Application/InventoryItemCQ/Commands/IncreaseInventory/IncreaseInventoryCommandHandler.cs
index d8d69b2..aead7ac 100644
--- a/src/CMSMicroservice.Application/InventoryItemCQ/Commands/IncreaseInventory/IncreaseInventoryCommandHandler.cs
+++ b/src/CMSMicroservice.Application/InventoryItemCQ/Commands/IncreaseInventory/IncreaseInventoryCommandHandler.cs
@@ -41,6 +41,26 @@ public class IncreaseInventoryCommandHandler : IRequestHandler<IncreaseInventory
         };
 
         await _context.StockMovements.AddAsync(stockMovement, cancellationToken);
+
+        // همگام‌سازی با Product.RemainingCount یا DiscountProduct.RemainingCount
+        if (item.ProductType == ProductType.RegularProduct && item.ProductId.HasValue)
+        {
+            var product = await _context.Products.FindAsync(new object[] { item.ProductId.Value }, cancellationToken);
+            if (product != null)
+            {
+                product.RemainingCount = item.Quantity;
+            }
+        }
+        else if (item.ProductType == ProductType.DiscountProduct && item.DiscountProductId.HasValue)
+        {
+            var discountProduct = await _context.DiscountProducts.FindAsync(
+                new object[] { item.DiscountProductId.Value }, cancellationToken);
+            if (discountProduct != null)
+            {
+                discountProduct.RemainingCount = item.Quantity;
+            }
+        }
+
         await _context.SaveChangesAsync(cancellationToken);
 
         return new IncreaseInventoryResponseDto
diff --git a/src/CMSMicroservice.Application/InventoryItemCQ/Commands/ReduceInventory/ReduceInventoryCommandHandler.cs b/src/CMSMicroservice.Application/InventoryItemCQ/Commands/ReduceInventory/ReduceInventoryCommandHandler.cs
index caf3da9..a4587e8 100644
--- a/src/CMSMicroservice.Application/InventoryItemCQ/Commands/ReduceInventory/ReduceInventoryCommandHandler.cs
+++ b/src/CMSMicroservice.Application/InventoryItemCQ/Commands/ReduceInventory/ReduceInventoryCommandHandler.cs
@@ -65,6 +65,26 @@ public class ReduceInventoryCommandHandler : IRequestHandler<ReduceInventoryComm
         };
 
         await _context.StockMovements.AddAsync(stockMovement, cancellationToken);
+
+        // همگام‌سازی با Product.RemainingCount یا DiscountProduct.RemainingCount
+        if (item.ProductType == ProductType.RegularProduct && item.ProductId.HasValue)
+        {
+            var product = await _context.Products.FindAsync(new object[] { item.ProductId.Value }, cancellationToken);
+            if (product != null)
+            {
+                product.RemainingCount = item.Quantity;
+            }
+        }
+        else if (item.ProductType == ProductType.DiscountProduct && item.DiscountProductId.HasValue)
+        {
+            var discountProduct = await _context.DiscountProducts.FindAsync(
+                new object[] { item.DiscountProductId.Value }, cancellationToken);
+            if (discountProduct != null)
+            {
+                discountProduct.RemainingCount = item.Quantity;
+            }
+        }
+
         await _context.SaveChangesAsync(cancellationToken);
 
         return new ReduceInventoryResponseDto { Success = true };