Handler.cs 4.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Domain.Entities.Donations.ValueObject;
  4. using Domain.Entities.Wallets.ValueObject;
  5. using Microsoft.EntityFrameworkCore;
  6. using SharedKernel.Results;
  7. namespace Application.Features.Api.Studio.Wallet.GetBalance;
  8. internal sealed class Handler(IAppDbContext db) : IQueryHandler<Query, Result<Response>>
  9. {
  10. private const int RecentLimit = 20;
  11. private static readonly Response Empty = new(0, 0, 0, 0, 0, []);
  12. public async Task<Result<Response>> Handle(Query request, CancellationToken ct)
  13. {
  14. var channel = await db.Channel.AsNoTracking().FirstOrDefaultAsync(c => c.MemberID == request.MemberID && c.IsActive, ct);
  15. if (channel is null)
  16. {
  17. return Result.Success(Empty);
  18. }
  19. var wallet = await db.Wallet.AsNoTracking()
  20. .Include(w => w.Balances)
  21. .FirstOrDefaultAsync(w => w.MemberID == request.MemberID, ct);
  22. // 출금 가능 잔액 = Donation 잔액 (M)
  23. var withdrawableBalance = 0;
  24. if (wallet is not null)
  25. {
  26. var donationBal = wallet.Balances.FirstOrDefault(b => b.Type == WalletBalanceType.Donation);
  27. if (donationBal is not null)
  28. {
  29. withdrawableBalance = (int)donationBal.Amount.Value;
  30. }
  31. }
  32. // 누적 수익 (Donation NetAmount 합계)
  33. var totalEarned = await db.Donation.AsNoTracking()
  34. .Where(d => d.ReceiverMemberID == request.MemberID && !d.IsTest)
  35. .SumAsync(d => d.NetAmount, ct);
  36. // 누적 출금 (완료된 출금)
  37. var totalWithdrawn = await db.WithdrawalRequest.AsNoTracking()
  38. .Where(w => w.MemberID == request.MemberID && w.Status == WithdrawalStatus.Completed)
  39. .SumAsync(w => w.NetAmount, ct);
  40. // 누적 판매 수수료 (채널 보상 입금 합계)
  41. var totalStoreCommission = await db.WalletTransaction.AsNoTracking()
  42. .Where(t => t.Wallet!.MemberID == request.MemberID
  43. && t.BalanceType == WalletBalanceType.StoreRevenue
  44. && t.TxType == WalletTransactionType.OrderChannelReward)
  45. .SumAsync(t => (int)t.Amount.Value, ct);
  46. // 대기 출금
  47. var pendingWithdrawal = await db.WithdrawalRequest.AsNoTracking()
  48. .Where(w => w.MemberID == request.MemberID && (w.Status == WithdrawalStatus.Pending || w.Status == WithdrawalStatus.Processing))
  49. .SumAsync(w => w.RequestedAmount, ct);
  50. // 최근 거래 통합 (Donation 잔액 + StoreRevenue 잔액)
  51. var recentTx = await db.WalletTransaction.AsNoTracking()
  52. .Where(t => t.Wallet!.MemberID == request.MemberID
  53. && (t.BalanceType == WalletBalanceType.Donation || t.BalanceType == WalletBalanceType.StoreRevenue))
  54. .OrderByDescending(t => t.CreatedAt)
  55. .Take(RecentLimit)
  56. .Select(t => new
  57. {
  58. t.ID,
  59. t.TxType,
  60. t.BalanceType,
  61. Amount = (int)t.Amount.Value,
  62. Balance = (int)t.BalanceAfter.Value,
  63. t.RefID,
  64. t.Memo,
  65. t.CreatedAt
  66. })
  67. .ToListAsync(ct);
  68. var unified = recentTx.Select(t => new UnifiedTransactionItem(
  69. t.ID,
  70. MapCategory(t.TxType, t.BalanceType),
  71. t.TxType.ToString(),
  72. t.Amount,
  73. t.Balance,
  74. t.RefID,
  75. t.Memo ?? "",
  76. t.CreatedAt
  77. )).ToList();
  78. return Result.Success(new Response(
  79. withdrawableBalance,
  80. totalEarned,
  81. totalWithdrawn,
  82. totalStoreCommission,
  83. pendingWithdrawal,
  84. unified
  85. ));
  86. }
  87. // 거래 카테고리 분류 — Frontend 필터 키 (전체/후원/수수료)
  88. private static string MapCategory(WalletTransactionType txType, WalletBalanceType balanceType) => txType switch
  89. {
  90. WalletTransactionType.DonationIn => "donation",
  91. WalletTransactionType.OrderChannelReward or
  92. WalletTransactionType.OrderRefundChannelReward or
  93. WalletTransactionType.WithdrawalStoreRevenue => "commission",
  94. _ when balanceType == WalletBalanceType.Donation => "donation",
  95. _ when balanceType == WalletBalanceType.StoreRevenue => "commission",
  96. _ => "other"
  97. };
  98. }