using Application.Abstractions.Cache;
using Application.Abstractions.Data;
using Application.Features.Config.Get;
using Domain.Entities.Common.ValueObject;
using Domain.Entities.Members.Logs;
using Domain.Entities.Wallets.ValueObject;
using Microsoft.EntityFrameworkCore;
namespace Application.Helpers;
///
/// 가입 축하 보상 지급 (코인=Airdrop / 캐시=Adjusted / XP=MemberStats+MemberExpLog).
/// 멱등: WalletTransaction RefID "signup:{memberID}" 가 이미 존재하면 재지급하지 않는다.
/// 신규 회원 생성 지점(로컬 가입/소셜 자동가입)에서 호출하며, SaveChangesAsync 는 호출자가 수행한다.
///
public static class SignupRewardGranter
{
public static string RefIDFor(int memberID) => $"signup:{memberID}";
///
/// 가입 보상을 대상 회원 지갑/스탯에 반영한다. 설정 비활성/전액 0 이거나 이미 지급된 경우 아무것도 하지 않는다.
/// 지갑은 호출자 컨텍스트에서 추적 상태로 로드해 변경을 SaveChangesAsync 에 위임한다.
///
public static async Task GrantAsync(IAppDbContext db, ICacheService cache, int memberID, CancellationToken ct)
{
if (memberID <= 0)
{
return;
}
var config = await LoadConfigAsync(db, cache, ct);
if (config is null || !config.Enabled)
{
return;
}
var coin = config.CoinAmount;
var cash = config.CashAmount;
var exp = config.ExpAmount;
if (coin <= 0 && cash <= 0 && exp <= 0)
{
return;
}
var refID = RefIDFor(memberID);
// 멱등: 이미 가입 보상 트랜잭션이 있으면 재지급 금지
var alreadyGranted = await db.WalletTransaction.AsNoTracking()
.AnyAsync(c => c.RefID == refID && c.TxType == WalletTransactionType.RewardEarned, ct);
if (alreadyGranted)
{
return;
}
// 코인/캐시 지급 (지갑 필요)
if (coin > 0 || cash > 0)
{
var wallet = await db.Wallet
.Include(c => c.Balances)
.FirstOrDefaultAsync(c => c.MemberID == memberID, ct);
if (wallet is not null)
{
if (coin > 0)
{
wallet.CreditSignupReward(WalletBalanceType.Airdrop, Money.KRW(coin), "SIGNUP_REWARD", refID);
}
if (cash > 0)
{
wallet.CreditSignupReward(WalletBalanceType.Adjusted, Money.KRW(cash), "SIGNUP_REWARD", refID);
}
}
}
// XP 지급 (MemberStats + MemberExpLog)
if (exp > 0)
{
var stats = await db.MemberStats.FirstOrDefaultAsync(c => c.MemberID == memberID, ct);
if (stats is not null)
{
stats.Exp += exp;
db.MemberExpLog.Add(MemberExpLog.Create(memberID, "가입 축하 보상", exp, stats.Exp));
}
}
}
private static async Task LoadConfigAsync(IAppDbContext db, ICacheService cache, CancellationToken ct)
{
var cached = await cache.GetAsync(CacheKeys.Config, ct);
if (cached is not null)
{
return new Domain.Entities.Common.SignupRewardConfig
{
Enabled = cached.SignupReward.Enabled,
CoinAmount = cached.SignupReward.CoinAmount,
CashAmount = cached.SignupReward.CashAmount,
ExpAmount = cached.SignupReward.ExpAmount
};
}
var entity = await db.Config.AsNoTracking().OrderByDescending(c => c.ID).FirstOrDefaultAsync(ct);
return entity?.SignupReward;
}
}