feat: add base package payment initiation and verification

2025-12-16 02:34:57 +03:30
parent 189812e874
commit 26e1243cfe
14 changed files with 654 additions and 5 deletions
@@ -57,11 +57,21 @@ public class VerifyOtpTokenCommandHandler : IRequestHandler<VerifyOtpTokenComman
            if (request.ParentReferralCode == null)
                return new VerifyOtpTokenResponseDto() { Success = false, Message = "کد معرف الزامی است." };

-            var parent = await _context.Users.FirstOrDefaultAsync(u => u.ReferralCode == request.ParentReferralCode,
-                cancellationToken: cancellationToken);
+            var parent = await _context.Users
+                .Include(u => u.ClubMembership)
+                .FirstOrDefaultAsync(u => u.ReferralCode == request.ParentReferralCode,
+                    cancellationToken: cancellationToken);
            if (parent == null)
                return new VerifyOtpTokenResponseDto() { Success = false, Message = "معرف وجود ندارد." };

+            // بررسی فعالیت باشگاه معرف
+            if (parent.ClubMembership == null || !parent.ClubMembership.IsActive)
+                return new VerifyOtpTokenResponseDto() 
+                { 
+                    Success = false, 
+                    Message = "لینک دعوت معرف فعال نیست. لطفاً از کد دعوت معتبر دیگری استفاده کنید." 
+                };
+
            if (await _context.Users.CountAsync(x => x.NetworkParentId == parent.Id, cancellationToken: cancellationToken) > 1)
                return new VerifyOtpTokenResponseDto() { Success = false, Message = "ظرفیت معرف تکمیل است!!" };

@@ -0,0 +1,43 @@
+using MediatR;
+
+namespace CMSMicroservice.Application.PackageCQ.Commands.InitiateBasePackagePayment;
+
+/// <summary>
+/// ثبت اولیه تراکنش و سفارش پکیج پایه (56 میلیون تومان)
+/// این Command توسط BFF فراخوانی می‌شود قبل از ارسال کاربر به درگاه
+/// </summary>
+public record InitiateBasePackagePaymentCommand : IRequest<InitiateBasePackagePaymentResponseDto>
+{
+    /// <summary>
+    /// شناسه کاربر
+    /// </summary>
+    public long UserId { get; init; }
+}
+
+public class InitiateBasePackagePaymentResponseDto
+{
+    /// <summary>
+    /// موفقیت عملیات
+    /// </summary>
+    public bool Success { get; set; }
+    
+    /// <summary>
+    /// پیام
+    /// </summary>
+    public string Message { get; set; } = string.Empty;
+    
+    /// <summary>
+    /// شناسه سفارش
+    /// </summary>
+    public long OrderId { get; set; }
+    
+    /// <summary>
+    /// شناسه تراکنش CMS
+    /// </summary>
+    public long TransactionId { get; set; }
+    
+    /// <summary>
+    /// مبلغ پکیج
+    /// </summary>
+    public long Amount { get; set; }
+}
@@ -0,0 +1,173 @@
+using CMSMicroservice.Application.Common.Exceptions;
+using CMSMicroservice.Application.Common.Interfaces;
+using CMSMicroservice.Domain.Entities;
+using CMSMicroservice.Domain.Enums;
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+using ValidationException = FluentValidation.ValidationException;
+
+namespace CMSMicroservice.Application.PackageCQ.Commands.InitiateBasePackagePayment;
+
+/// <summary>
+/// Handler برای ثبت اولیه تراکنش و سفارش پکیج پایه
+/// این Handler فقط Transaction و Order را با وضعیت Pending ایجاد می‌کند
+/// BFF سپس کاربر را به درگاه PYMS هدایت می‌کند
+/// </summary>
+public class InitiateBasePackagePaymentCommandHandler : IRequestHandler<InitiateBasePackagePaymentCommand, InitiateBasePackagePaymentResponseDto>
+{
+    private readonly IApplicationDbContext _context;
+    private readonly ILogger<InitiateBasePackagePaymentCommandHandler> _logger;
+    
+    /// <summary>
+    /// مبلغ پکیج پایه (56 میلیون تومان)
+    /// </summary>
+    private const long BasePackageAmount = 56_000_000;
+    
+    /// <summary>
+    /// شناسه پکیج پایه در دیتابیس
+    /// </summary>
+    private const long BasePackageId = 4;
+
+    public InitiateBasePackagePaymentCommandHandler(
+        IApplicationDbContext context,
+        ILogger<InitiateBasePackagePaymentCommandHandler> logger)
+    {
+        _context = context;
+        _logger = logger;
+    }
+
+    public async Task<InitiateBasePackagePaymentResponseDto> Handle(
+        InitiateBasePackagePaymentCommand request, 
+        CancellationToken cancellationToken)
+    {
+        try
+        {
+            _logger.LogInformation(
+                "Initiating base package payment for UserId: {UserId}",
+                request.UserId);
+
+            // 1. پیدا کردن کاربر
+            var user = await _context.Users
+                .FirstOrDefaultAsync(u => u.Id == request.UserId, cancellationToken);
+
+            if (user == null)
+            {
+                _logger.LogWarning("User not found. UserId: {UserId}", request.UserId);
+                throw new NotFoundException(nameof(User), request.UserId);
+            }
+
+            // 2. بررسی عدم خرید قبلی پکیج پایه
+            if (user.PackagePurchaseMethod != PackagePurchaseMethod.None)
+            {
+                _logger.LogWarning(
+                    "User {UserId} has already purchased base package via {Method}",
+                    request.UserId,
+                    user.PackagePurchaseMethod);
+
+                return new InitiateBasePackagePaymentResponseDto
+                {
+                    Success = false,
+                    Message = "شما قبلاً پکیج پایه را خریداری کرده‌اید."
+                };
+            }
+
+            // 3. بررسی عدم وجود سفارش Pending
+            var pendingOrder = await _context.UserOrders
+                .FirstOrDefaultAsync(o => 
+                    o.UserId == request.UserId && 
+                    o.PaymentStatus == PaymentStatus.Pending &&
+                    o.PackageId == BasePackageId, 
+                    cancellationToken);
+
+            if (pendingOrder != null)
+            {
+                _logger.LogWarning(
+                    "User {UserId} has pending order {OrderId}",
+                    request.UserId,
+                    pendingOrder.Id);
+
+                // برگرداندن سفارش موجود برای ادامه پرداخت
+                var existingTransaction = await _context.Transactions
+                    .FirstOrDefaultAsync(t => t.Id == pendingOrder.TransactionId, cancellationToken);
+
+                return new InitiateBasePackagePaymentResponseDto
+                {
+                    Success = true,
+                    Message = "سفارش قبلی در انتظار پرداخت یافت شد.",
+                    OrderId = pendingOrder.Id,
+                    TransactionId = existingTransaction?.Id ?? 0,
+                    Amount = BasePackageAmount
+                };
+            }
+
+            // 4. پیدا کردن آدرس پیش‌فرض کاربر
+            var defaultAddress = await _context.UserAddresses
+                .Where(a => a.UserId == request.UserId)
+                .OrderByDescending(a => a.Created)
+                .FirstOrDefaultAsync(cancellationToken);
+
+            if (defaultAddress == null)
+            {
+                _logger.LogWarning("No address found for user {UserId}", request.UserId);
+                throw new ValidationException("لطفاً ابتدا یک آدرس برای خود ثبت کنید.");
+            }
+
+            // 5. ایجاد Transaction با وضعیت Pending
+            var transaction = new Transaction
+            {
+                Amount = BasePackageAmount,
+                Description = $"خرید پکیج پایه ۵۶ میلیونی - کاربر #{user.Id}",
+                PaymentStatus = PaymentStatus.Pending,
+                Type = TransactionType.DepositIpg
+            };
+
+            _context.Transactions.Add(transaction);
+            await _context.SaveChangesAsync(cancellationToken);
+
+            _logger.LogInformation(
+                "Created Transaction {TransactionId} with Pending status for UserId {UserId}",
+                transaction.Id,
+                request.UserId);
+
+            // 6. ایجاد UserOrder با وضعیت Pending
+            var order = new UserOrder
+            {
+                UserId = user.Id,
+                PackageId = BasePackageId,
+                Amount = BasePackageAmount,
+                PaymentStatus = PaymentStatus.Pending,
+                DeliveryStatus = DeliveryStatus.None,
+                UserAddressId = defaultAddress.Id,
+                PaymentMethod = PaymentMethod.IPG,
+                TransactionId = transaction.Id
+            };
+
+            _context.UserOrders.Add(order);
+            await _context.SaveChangesAsync(cancellationToken);
+
+            _logger.LogInformation(
+                "Created UserOrder {OrderId} for UserId {UserId}, TransactionId: {TransactionId}",
+                order.Id,
+                request.UserId,
+                transaction.Id);
+
+            return new InitiateBasePackagePaymentResponseDto
+            {
+                Success = true,
+                Message = "تراکنش و سفارش با موفقیت ثبت شد.",
+                OrderId = order.Id,
+                TransactionId = transaction.Id,
+                Amount = BasePackageAmount
+            };
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(
+                ex,
+                "Error in InitiateBasePackagePaymentCommand for UserId: {UserId}",
+                request.UserId);
+            throw;
+        }
+    }
+}
@@ -0,0 +1,13 @@
+using FluentValidation;
+
+namespace CMSMicroservice.Application.PackageCQ.Commands.InitiateBasePackagePayment;
+
+public class InitiateBasePackagePaymentCommandValidator : AbstractValidator<InitiateBasePackagePaymentCommand>
+{
+    public InitiateBasePackagePaymentCommandValidator()
+    {
+        RuleFor(x => x.UserId)
+            .GreaterThan(0)
+            .WithMessage("شناسه کاربر معتبر نیست.");
+    }
+}
@@ -0,0 +1,72 @@
+using MediatR;
+
+namespace CMSMicroservice.Application.PackageCQ.Commands.VerifyBasePackagePayment;
+
+/// <summary>
+/// تکمیل یا رد پرداخت پکیج پایه (فراخوانی توسط BFF بعد از Callback)
+/// </summary>
+public record VerifyBasePackagePaymentCommand : IRequest<VerifyBasePackagePaymentResponseDto>
+{
+    /// <summary>
+    /// شناسه سفارش CMS
+    /// </summary>
+    public long OrderId { get; init; }
+    
+    /// <summary>
+    /// شناسه تراکنش CMS
+    /// </summary>
+    public long TransactionId { get; init; }
+    
+    /// <summary>
+    /// آیا پرداخت موفق بوده؟ (نتیجه Verify از BFF)
+    /// </summary>
+    public bool PaymentSuccess { get; init; }
+    
+    /// <summary>
+    /// کد پیگیری بانکی (در صورت موفقیت)
+    /// </summary>
+    public string? RefId { get; init; }
+    
+    /// <summary>
+    /// پیام از درگاه
+    /// </summary>
+    public string? Message { get; init; }
+}
+
+public class VerifyBasePackagePaymentResponseDto
+{
+    /// <summary>
+    /// موفقیت عملیات
+    /// </summary>
+    public bool Success { get; set; }
+    
+    /// <summary>
+    /// پیام
+    /// </summary>
+    public string Message { get; set; } = string.Empty;
+    
+    /// <summary>
+    /// شناسه سفارش
+    /// </summary>
+    public long OrderId { get; set; }
+    
+    /// <summary>
+    /// شناسه تراکنش
+    /// </summary>
+    public long TransactionId { get; set; }
+    
+    /// <summary>
+    /// کد پیگیری بانکی
+    /// </summary>
+    public string? ReferenceCode { get; set; }
+    
+    /// <summary>
+    /// موجودی کیف پول بعد از شارژ
+    /// </summary>
+    public long WalletBalance { get; set; }
+    
+    /// <summary>
+    /// موجودی تخفیف بعد از شارژ
+    /// </summary>
+    public long DiscountBalance { get; set; }
+}
@@ -0,0 +1,209 @@
+using CMSMicroservice.Application.Common.Exceptions;
+using CMSMicroservice.Application.Common.Interfaces;
+using CMSMicroservice.Domain.Entities;
+using CMSMicroservice.Domain.Enums;
+using MediatR;
+using Microsoft.EntityFrameworkCore;
+using Microsoft.Extensions.Logging;
+
+namespace CMSMicroservice.Application.PackageCQ.Commands.VerifyBasePackagePayment;
+
+/// <summary>
+/// Handler برای تکمیل یا رد پرداخت پکیج پایه
+/// فراخوانی توسط BFF بعد از اینکه نتیجه Verify از PYMS مشخص شد
+/// 
+/// اگر PaymentSuccess = true:
+/// - شارژ کیف پول (Balance + DiscountBalance)
+/// - ثبت لاگ تغییر کیف پول
+/// - به‌روزرسانی سفارش و کاربر
+/// 
+/// اگر PaymentSuccess = false:
+/// - فقط آپدیت وضعیت تراکنش و سفارش به Reject
+/// </summary>
+public class VerifyBasePackagePaymentCommandHandler : IRequestHandler<VerifyBasePackagePaymentCommand, VerifyBasePackagePaymentResponseDto>
+{
+    private readonly IApplicationDbContext _context;
+    private readonly ILogger<VerifyBasePackagePaymentCommandHandler> _logger;
+    
+    /// <summary>
+    /// مبلغ پکیج پایه (56 میلیون تومان)
+    /// </summary>
+    private const long BasePackageAmount = 56_000_000;
+
+    public VerifyBasePackagePaymentCommandHandler(
+        IApplicationDbContext context,
+        ILogger<VerifyBasePackagePaymentCommandHandler> logger)
+    {
+        _context = context;
+        _logger = logger;
+    }
+
+    public async Task<VerifyBasePackagePaymentResponseDto> Handle(
+        VerifyBasePackagePaymentCommand request, 
+        CancellationToken cancellationToken)
+    {
+        try
+        {
+            _logger.LogInformation(
+                "Processing base package payment result. OrderId: {OrderId}, TransactionId: {TransactionId}, PaymentSuccess: {PaymentSuccess}",
+                request.OrderId,
+                request.TransactionId,
+                request.PaymentSuccess);
+
+            // 1. پیدا کردن سفارش با کاربر
+            var order = await _context.UserOrders
+                .Include(o => o.User)
+                .FirstOrDefaultAsync(o => o.Id == request.OrderId, cancellationToken);
+
+            if (order == null)
+            {
+                _logger.LogWarning("Order not found. OrderId: {OrderId}", request.OrderId);
+                throw new NotFoundException(nameof(UserOrder), request.OrderId);
+            }
+
+            // 2. پیدا کردن تراکنش
+            var transaction = await _context.Transactions
+                .FirstOrDefaultAsync(t => t.Id == request.TransactionId, cancellationToken);
+
+            if (transaction == null)
+            {
+                _logger.LogWarning("Transaction not found. TransactionId: {TransactionId}", request.TransactionId);
+                throw new NotFoundException(nameof(Transaction), request.TransactionId);
+            }
+
+            // 3. بررسی Idempotency - اگر قبلاً تایید شده باشد
+            if (order.PaymentStatus == PaymentStatus.Success)
+            {
+                _logger.LogInformation(
+                    "Order {OrderId} already verified successfully",
+                    request.OrderId);
+
+                var existingWallet = await _context.UserWallets
+                    .FirstOrDefaultAsync(w => w.UserId == order.UserId, cancellationToken);
+
+                return new VerifyBasePackagePaymentResponseDto
+                {
+                    Success = true,
+                    Message = "پرداخت قبلاً با موفقیت تایید شده است.",
+                    OrderId = order.Id,
+                    TransactionId = transaction.Id,
+                    ReferenceCode = transaction.RefId,
+                    WalletBalance = existingWallet?.Balance ?? 0,
+                    DiscountBalance = existingWallet?.DiscountBalance ?? 0
+                };
+            }
+
+            // 4. اگر پرداخت ناموفق بود - فقط وضعیت را Reject می‌کنیم
+            if (!request.PaymentSuccess)
+            {
+                _logger.LogWarning(
+                    "Payment failed. OrderId: {OrderId}, Message: {Message}",
+                    request.OrderId,
+                    request.Message);
+
+                transaction.PaymentStatus = PaymentStatus.Reject;
+                order.PaymentStatus = PaymentStatus.Reject;
+                await _context.SaveChangesAsync(cancellationToken);
+
+                return new VerifyBasePackagePaymentResponseDto
+                {
+                    Success = false,
+                    Message = request.Message ?? "پرداخت ناموفق بود.",
+                    OrderId = order.Id,
+                    TransactionId = transaction.Id
+                };
+            }
+
+            // 5. پرداخت موفق - پیدا کردن یا ایجاد کیف پول
+            var userWallet = await _context.UserWallets
+                .FirstOrDefaultAsync(w => w.UserId == order.UserId, cancellationToken);
+
+            if (userWallet == null)
+            {
+                _logger.LogInformation("Creating new wallet for UserId: {UserId}", order.UserId);
+                userWallet = new UserWallet
+                {
+                    UserId = order.UserId,
+                    Balance = 0,
+                    DiscountBalance = 0,
+                    NetworkBalance = 0
+                };
+                _context.UserWallets.Add(userWallet);
+                await _context.SaveChangesAsync(cancellationToken);
+            }
+
+            // 6. شارژ کیف پول (هم Balance و هم DiscountBalance)
+            var oldBalance = userWallet.Balance;
+            var oldDiscountBalance = userWallet.DiscountBalance;
+            
+            userWallet.Balance += BasePackageAmount;
+            userWallet.DiscountBalance += BasePackageAmount;
+
+            _logger.LogInformation(
+                "Charging wallet for user {UserId}. Balance: {OldBalance} -> {NewBalance}, DiscountBalance: {OldDiscount} -> {NewDiscount}",
+                order.UserId,
+                oldBalance,
+                userWallet.Balance,
+                oldDiscountBalance,
+                userWallet.DiscountBalance);
+
+            // 7. به‌روزرسانی Transaction
+            transaction.PaymentStatus = PaymentStatus.Success;
+            transaction.PaymentDate = DateTime.Now;
+            transaction.RefId = request.RefId;
+
+            // 8. ثبت لاگ تغییر کیف پول
+            var changeLog = new UserWalletChangeLog
+            {
+                WalletId = userWallet.Id,
+                CurrentBalance = userWallet.Balance,
+                ChangeValue = BasePackageAmount,
+                CurrentNetworkBalance = userWallet.NetworkBalance,
+                ChangeNerworkValue = 0,
+                CurrentDiscountBalance = userWallet.DiscountBalance,
+                ChangeDiscountValue = BasePackageAmount,
+                IsIncrease = true,
+                RefrenceId = transaction.Id
+            };
+
+            await _context.UserWalletChangeLogs.AddAsync(changeLog, cancellationToken);
+
+            // 9. به‌روزرسانی Order
+            order.TransactionId = transaction.Id;
+            order.PaymentStatus = PaymentStatus.Success;
+            order.PaymentDate = DateTime.Now;
+            order.PaymentMethod = PaymentMethod.IPG;
+
+            // 10. به‌روزرسانی User
+            order.User.PackagePurchaseMethod = PackagePurchaseMethod.DirectPurchase;
+
+            await _context.SaveChangesAsync(cancellationToken);
+
+            _logger.LogInformation(
+                "Base package payment completed successfully. OrderId: {OrderId}, UserId: {UserId}, TransactionId: {TransactionId}, RefId: {RefId}",
+                order.Id,
+                order.UserId,
+                transaction.Id,
+                request.RefId);
+
+            return new VerifyBasePackagePaymentResponseDto
+            {
+                Success = true,
+                Message = "پرداخت با موفقیت تایید شد. کیف پول شما شارژ گردید.",
+                OrderId = order.Id,
+                TransactionId = transaction.Id,
+                ReferenceCode = request.RefId,
+                WalletBalance = userWallet.Balance,
+                DiscountBalance = userWallet.DiscountBalance
+            };
+        }
+        catch (Exception ex)
+        {
+            _logger.LogError(
+                ex,
+                "Error in VerifyBasePackagePaymentCommand. OrderId: {OrderId}",
+                request.OrderId);
+            throw;
+        }
+    }
+}
@@ -0,0 +1,17 @@
+using FluentValidation;
+
+namespace CMSMicroservice.Application.PackageCQ.Commands.VerifyBasePackagePayment;
+
+public class VerifyBasePackagePaymentCommandValidator : AbstractValidator<VerifyBasePackagePaymentCommand>
+{
+    public VerifyBasePackagePaymentCommandValidator()
+    {
+        RuleFor(x => x.OrderId)
+            .GreaterThan(0)
+            .WithMessage("شناسه سفارش معتبر نیست.");
+
+        RuleFor(x => x.TransactionId)
+            .GreaterThan(0)
+            .WithMessage("شناسه تراکنش معتبر نیست.");
+    }
+}
@@ -22,7 +22,7 @@ public class AdminGetJwtTokenQueryHandler : IRequestHandler<AdminGetJwtTokenQuer
            .ThenInclude(u => u.Contract)
            .Include(u => u.UserRoles)
            .ThenInclude(ur => ur.Role)
-            
+            .Include(u => u.ClubMembership)
            .FirstOrDefaultAsync(f => f.Mobile == request.Username, cancellationToken);
        if (user == null)
            throw new Exception("Invalid username or password.");
@@ -17,6 +17,7 @@ public class GetJwtTokenQueryHandler : IRequestHandler<GetJwtTokenQuery, GetJwtT
            .ThenInclude(u => u.Contract)
            .Include(u => u.UserRoles)
            .ThenInclude(ur => ur.Role)
+            .Include(u => u.ClubMembership)
            .FirstOrDefaultAsync(x => x.Id == request.Id, cancellationToken) ?? throw new NotFoundException(nameof(User), request.Id);
        return new GetJwtTokenResponseDto()
        {