Handler.cs 2.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Domain.Entities.Store.ValueObject;
  4. using Microsoft.EntityFrameworkCore;
  5. using SharedKernel.Results;
  6. namespace Application.Features.Admin.Store.Coupon.RestoreCodes;
  7. public sealed class Handler(IAppDbContext db) : ICommandHandler<Command, Result<Response>>
  8. {
  9. public async Task<Result<Response>> Handle(Command request, CancellationToken ct)
  10. {
  11. if (request.CodeIDs is null || request.CodeIDs.Length == 0)
  12. {
  13. return Result.Failure<Response>(Error.Problem("CouponCode.NoIDs", "복귀 처리할 코드를 선택해 주세요."));
  14. }
  15. var targets = await db.CouponCode
  16. .Where(c => c.CouponID == request.CouponID && request.CodeIDs.Contains(c.ID))
  17. .ToListAsync(ct);
  18. if (targets.Count == 0)
  19. {
  20. return Result.Failure<Response>(Error.NotFound("CouponCode.NotFound", "복귀 처리할 코드를 찾을 수 없습니다."));
  21. }
  22. var blocked = targets.Where(c => c.Status != CouponCodeStatus.Expired).ToList();
  23. if (blocked.Count > 0)
  24. {
  25. var preview = string.Join(", ", blocked.Take(10).Select(c => $"#{c.ID}({StatusText(c.Status)})"));
  26. var more = blocked.Count > 10 ? $" 외 {blocked.Count - 10}건" : string.Empty;
  27. return Result.Failure<Response>(Error.Conflict(
  28. "CouponCode.NotRestorable",
  29. $"만료(Expired) 상태 코드만 복귀할 수 있습니다. 대상 외 코드: {preview}{more}"
  30. ));
  31. }
  32. // Issued 로 복귀하는 코드의 MemberInventory.ExpiresAt 을 null 로 해제 (B1 정책)
  33. var issuedTargetCodeIDs = targets.Where(c => c.IssuedToMemberID.HasValue).Select(c => c.ID).ToList();
  34. if (issuedTargetCodeIDs.Count > 0)
  35. {
  36. var inventories = await db.MemberInventory
  37. .Where(i => issuedTargetCodeIDs.Contains(i.CouponCodeID) && i.UsedAt == null)
  38. .ToListAsync(ct);
  39. foreach (var inv in inventories)
  40. {
  41. inv.ClearExpiry();
  42. }
  43. }
  44. foreach (var code in targets)
  45. {
  46. code.RestoreFromExpired();
  47. }
  48. await db.SaveChangesAsync(ct);
  49. return Result.Success(new Response(targets.Count));
  50. }
  51. private static string StatusText(CouponCodeStatus status) => status switch
  52. {
  53. CouponCodeStatus.Available => "사용 가능",
  54. CouponCodeStatus.Reserved => "결제 진행 중",
  55. CouponCodeStatus.Issued => "발급됨",
  56. CouponCodeStatus.Used => "사용됨",
  57. CouponCodeStatus.Expired => "만료",
  58. _ => status.ToString()
  59. };
  60. }