SignupRewardGranter.cs 3.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. using Application.Abstractions.Cache;
  2. using Application.Abstractions.Data;
  3. using Application.Features.Config.Get;
  4. using Domain.Entities.Common.ValueObject;
  5. using Domain.Entities.Members.Logs;
  6. using Domain.Entities.Wallets.ValueObject;
  7. using Microsoft.EntityFrameworkCore;
  8. namespace Application.Helpers;
  9. /// <summary>
  10. /// 가입 축하 보상 지급 (코인=Airdrop / 캐시=Adjusted / XP=MemberStats+MemberExpLog).
  11. /// 멱등: WalletTransaction RefID "signup:{memberID}" 가 이미 존재하면 재지급하지 않는다.
  12. /// 신규 회원 생성 지점(로컬 가입/소셜 자동가입)에서 호출하며, SaveChangesAsync 는 호출자가 수행한다.
  13. /// </summary>
  14. public static class SignupRewardGranter
  15. {
  16. public static string RefIDFor(int memberID) => $"signup:{memberID}";
  17. /// <summary>
  18. /// 가입 보상을 대상 회원 지갑/스탯에 반영한다. 설정 비활성/전액 0 이거나 이미 지급된 경우 아무것도 하지 않는다.
  19. /// 지갑은 호출자 컨텍스트에서 추적 상태로 로드해 변경을 SaveChangesAsync 에 위임한다.
  20. /// </summary>
  21. public static async Task GrantAsync(IAppDbContext db, ICacheService cache, int memberID, CancellationToken ct)
  22. {
  23. if (memberID <= 0)
  24. {
  25. return;
  26. }
  27. var config = await LoadConfigAsync(db, cache, ct);
  28. if (config is null || !config.Enabled)
  29. {
  30. return;
  31. }
  32. var coin = config.CoinAmount;
  33. var cash = config.CashAmount;
  34. var exp = config.ExpAmount;
  35. if (coin <= 0 && cash <= 0 && exp <= 0)
  36. {
  37. return;
  38. }
  39. var refID = RefIDFor(memberID);
  40. // 멱등: 이미 가입 보상 트랜잭션이 있으면 재지급 금지
  41. var alreadyGranted = await db.WalletTransaction.AsNoTracking()
  42. .AnyAsync(c => c.RefID == refID && c.TxType == WalletTransactionType.RewardEarned, ct);
  43. if (alreadyGranted)
  44. {
  45. return;
  46. }
  47. // 코인/캐시 지급 (지갑 필요)
  48. if (coin > 0 || cash > 0)
  49. {
  50. var wallet = await db.Wallet
  51. .Include(c => c.Balances)
  52. .FirstOrDefaultAsync(c => c.MemberID == memberID, ct);
  53. if (wallet is not null)
  54. {
  55. if (coin > 0)
  56. {
  57. wallet.CreditSignupReward(WalletBalanceType.Airdrop, Money.KRW(coin), "SIGNUP_REWARD", refID);
  58. }
  59. if (cash > 0)
  60. {
  61. wallet.CreditSignupReward(WalletBalanceType.Adjusted, Money.KRW(cash), "SIGNUP_REWARD", refID);
  62. }
  63. }
  64. }
  65. // XP 지급 (MemberStats + MemberExpLog)
  66. if (exp > 0)
  67. {
  68. var stats = await db.MemberStats.FirstOrDefaultAsync(c => c.MemberID == memberID, ct);
  69. if (stats is not null)
  70. {
  71. stats.Exp += exp;
  72. db.MemberExpLog.Add(MemberExpLog.Create(memberID, "가입 축하 보상", exp, stats.Exp));
  73. }
  74. }
  75. }
  76. private static async Task<Domain.Entities.Common.SignupRewardConfig?> LoadConfigAsync(IAppDbContext db, ICacheService cache, CancellationToken ct)
  77. {
  78. var cached = await cache.GetAsync<Response>(CacheKeys.Config, ct);
  79. if (cached is not null)
  80. {
  81. return new Domain.Entities.Common.SignupRewardConfig
  82. {
  83. Enabled = cached.SignupReward.Enabled,
  84. CoinAmount = cached.SignupReward.CoinAmount,
  85. CashAmount = cached.SignupReward.CashAmount,
  86. ExpAmount = cached.SignupReward.ExpAmount
  87. };
  88. }
  89. var entity = await db.Config.AsNoTracking().OrderByDescending(c => c.ID).FirstOrDefaultAsync(ct);
  90. return entity?.SignupReward;
  91. }
  92. }