update

src/CMSMicroservice.Application/UserOrderCQ/Commands/CreateNewUserOrder/CreateNewUserOrderCommand.cs

@@ -1,3 +1,5 @@
+using CMSMicroservice.Domain.Enums;
+
 namespace CMSMicroservice.Application.UserOrderCQ.Commands.CreateNewUserOrder;
 public record CreateNewUserOrderCommand : IRequest<CreateNewUserOrderResponseDto>
 {

src/CMSMicroservice.Application/UserOrderCQ/Commands/CreateNewUserOrder/CreateNewUserOrderCommandHandler.cs

@@ -19,7 +19,7 @@ public class CreateNewUserOrderCommandHandler : IRequestHandler<CreateNewUserOrd
             .FirstOrDefaultAsync(x => x.Id == request.PackageId, cancellationToken) ?? throw new NotFoundException(nameof(Package), request.PackageId);
 
         var entity = request.Adapt<UserOrder>();
-        entity.Price = package.Price;
+        entity.Amount = package.Price;
         await _context.UserOrders.AddAsync(entity, cancellationToken);
         entity.AddDomainEvent(new CreateNewUserOrderEvent(entity));
         await _context.SaveChangesAsync(cancellationToken);

src/CMSMicroservice.Application/UserOrderCQ/Commands/SubmitShopBuyOrder/SubmitShopBuyOrderCommandHandler.cs

@@ -18,30 +18,77 @@ public class
     {
         var user = await _context.Users
             .Include(i => i.UserAddresss)
+            .Include(i => i.UserWallets)
+            .ThenInclude(i => i.UserWalletChangeLogs)
             .Include(i => i.UserCartss)
             .ThenInclude(i => i.Product)
             .FirstOrDefaultAsync(w => w.Id == request.UserId, cancellationToken: cancellationToken);
         if (user.UserCartss.Count == 0)
             throw new NotFoundException("UserCart", request.UserId);
+
         if (user.UserCartss.Sum(s => s.Count * s.Product.Price) != request.TotalAmount)
             throw new Exception("مبلغ سفارش با مجموع سبد خرید مطابقت ندارد.");
 
-        await _context.UserOrders.AddAsync(new UserOrder()
+
+        var userWallet = user.UserWallets.FirstOrDefault();
+        if (userWallet == null)
+            throw new Exception("کیف پول کاربر یافت نشد.");
+        
+        
+        var newTransaction = new Transactions()
         {
-            Price = request.TotalAmount,
+            Amount = request.TotalAmount,
+            Description = "خرید از فروشگاه",
+            PaymentStatus = PaymentStatus.Success,
+            PaymentDate = DateTime.Now,
+            Type = TransactionType.Buy,
+            RefId = "localwallet-" + Guid.NewGuid().ToString()
+        };
+        await _context.Transactionss.AddAsync(newTransaction, cancellationToken);
+        await _context.SaveChangesAsync(cancellationToken);
+        
+        var newWalletLog = new UserWalletChangeLog()
+        {
+            CurrentBalance = userWallet.Balance,
+            ChangeValue = -1*request.TotalAmount,
+            IsIncrease = false,
+            RefrenceId = newTransaction.Id
+        };
+        userWallet.Balance -= request.TotalAmount;
+        
+        await _context.UserWalletChangeLogs.AddAsync(newWalletLog, cancellationToken);
+        await _context.SaveChangesAsync(cancellationToken);
+
+        var newOrder = new UserOrder()
+        {
+            Amount = request.TotalAmount,
             PaymentStatus = PaymentStatus.Success,
             PaymentMethod = PaymentMethod.Wallet,
-            PaymentDate =DateTime.Now,
+            PaymentDate = DateTime.Now,
             UserId = request.UserId,
-            UserAddressId = user.UserAddresss.First(f=>f.IsDefault).Id
-        }, cancellationToken);
+            UserAddressId = user.UserAddresss.First(f => f.IsDefault).Id,
+            TransactionId = newTransaction.Id
+        };
+        await _context.UserOrders.AddAsync(newOrder, cancellationToken);
+        await _context.SaveChangesAsync(cancellationToken);
+
         await _context.FactorDetailss.AddRangeAsync(user.UserCartss.Select(s => new FactorDetails()
         {
             ProductId = s.ProductId,
             Count = s.Count,
             UnitPrice = s.Product.Price,
-            
+            OrderId = newOrder.Id
         }), cancellationToken);
-        return new SubmitShopBuyOrderResponseDto();
+        user.UserCartss.Clear();
+        await _context.SaveChangesAsync(cancellationToken);
+        return new SubmitShopBuyOrderResponseDto()
+        {
+            Id = newOrder.Id,
+            PaymentMethod = newOrder.PaymentMethod,
+            PaymentStatus = newOrder.PaymentStatus,
+            TotalAmount = newOrder.Amount,
+            UserAddressText = user.UserAddresss.First(f => f.IsDefault).Address,
+            Created = newOrder.PaymentDate
+        };
     }
 }

src/CMSMicroservice.Application/UserOrderCQ/Commands/UpdateUserOrder/UpdateUserOrderCommand.cs

@@ -1,3 +1,5 @@
+using CMSMicroservice.Domain.Enums;
+
 namespace CMSMicroservice.Application.UserOrderCQ.Commands.UpdateUserOrder;
 public record UpdateUserOrderCommand : IRequest<Unit>
 {

src/CMSMicroservice.Application/UserOrderCQ/Queries/GetAllUserOrderByFilter/GetAllUserOrderByFilterQuery.cs

@@ -1,3 +1,5 @@
+using CMSMicroservice.Domain.Enums;
+
 namespace CMSMicroservice.Application.UserOrderCQ.Queries.GetAllUserOrderByFilter;
 public record GetAllUserOrderByFilterQuery : IRequest<GetAllUserOrderByFilterResponseDto>
 {

src/CMSMicroservice.Application/UserOrderCQ/Queries/GetAllUserOrderByFilter/GetAllUserOrderByFilterQueryHandler.cs

@@ -18,7 +18,7 @@ public class GetAllUserOrderByFilterQueryHandler : IRequestHandler<GetAllUserOrd
         {
             query = query
                 .Where(x => request.Filter.Id == null || x.Id == request.Filter.Id)
-                .Where(x => request.Filter.Price == null || x.Price == request.Filter.Price)
+                .Where(x => request.Filter.Amount == null || x.Amount == request.Filter.Amount)
                 .Where(x => request.Filter.PackageId == null || x.PackageId == request.Filter.PackageId)
                 .Where(x => request.Filter.TransactionId == null || x.TransactionId == request.Filter.TransactionId)
                 .Where(x => request.Filter.PaymentStatus == null || x.PaymentStatus.GetHashCode() == request.Filter.PaymentStatus.Value.GetHashCode())

src/CMSMicroservice.Application/UserOrderCQ/Queries/GetAllUserOrderByFilter/GetAllUserOrderByFilterResponseDto.cs

@@ -1,3 +1,5 @@
+using CMSMicroservice.Domain.Enums;
+
 namespace CMSMicroservice.Application.UserOrderCQ.Queries.GetAllUserOrderByFilter;
 public class GetAllUserOrderByFilterResponseDto
 {

src/CMSMicroservice.Application/UserOrderCQ/Queries/GetUserOrder/GetUserOrderResponseDto.cs

@@ -1,3 +1,5 @@
+using CMSMicroservice.Domain.Enums;
+
 namespace CMSMicroservice.Application.UserOrderCQ.Queries.GetUserOrder;
 public class GetUserOrderResponseDto
 {