Handler.cs 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116
  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. using SharedKernel.Storage;
  7. using ProductEntity = Domain.Entities.Store.Product;
  8. namespace Application.Features.Admin.Store.Product.Create;
  9. public sealed class Handler(IAppDbContext db, IFileStorage fileStorage) : ICommandHandler<Command, Result<int>>
  10. {
  11. private static readonly string[] AllowedImageExt = [".jpg", ".jpeg", ".png", ".gif", ".webp"];
  12. public async Task<Result<int>> Handle(Command request, CancellationToken ct)
  13. {
  14. // Game 존재 검증 — 소모품(ItemKind)은 게임 없이 등록 가능
  15. var gameID = request.GameID is > 0 ? request.GameID : null;
  16. if (gameID.HasValue && !await db.Game.AnyAsync(c => c.ID == gameID.Value && c.IsActive, ct))
  17. {
  18. return Result.Failure<int>(Error.NotFound("Product.GameNotFound", "선택한 게임이 없거나 비활성 상태입니다."));
  19. }
  20. if (request.Price < 0)
  21. {
  22. return Result.Failure<int>(Error.Problem("Product.InvalidPrice", "가격은 0 이상이어야 합니다."));
  23. }
  24. if (request.DiscountType == DiscountType.Percent && (request.DiscountValue < 0 || request.DiscountValue > 99))
  25. {
  26. return Result.Failure<int>(Error.Problem("Product.InvalidDiscountPercent", "할인율은 0 ~ 99% 범위로 입력하세요."));
  27. }
  28. if (request.DiscountType == DiscountType.Amount && (request.DiscountValue < 0 || request.DiscountValue > request.Price))
  29. {
  30. return Result.Failure<int>(Error.Problem("Product.InvalidDiscountAmount", "할인 금액은 0 이상이며 정가 이하로 입력하세요."));
  31. }
  32. if (request.Stock < -1)
  33. {
  34. return Result.Failure<int>(Error.Problem("Product.InvalidStock", "재고는 -1(무제한) 또는 0 이상이어야 합니다."));
  35. }
  36. if (request.MinPurchase < 1 || request.MaxPurchase < request.MinPurchase || request.MaxPurchase > 999)
  37. {
  38. return Result.Failure<int>(Error.Problem("Product.InvalidPurchaseRange", "최소/최대 구매 수량 범위가 올바르지 않습니다 (1 ≤ 최소 ≤ 최대 ≤ 999)."));
  39. }
  40. if (request.SaleStartAt.HasValue && request.SaleEndAt.HasValue && request.SaleStartAt.Value >= request.SaleEndAt.Value)
  41. {
  42. return Result.Failure<int>(Error.Problem("Product.InvalidSalePeriod", "판매 시작일은 종료일보다 이전이어야 합니다."));
  43. }
  44. var product = ProductEntity.Create(
  45. gameID: gameID,
  46. name: request.Name,
  47. type: request.Type,
  48. price: request.Price,
  49. discountType: request.DiscountType,
  50. discountValue: request.DiscountValue,
  51. stock: request.Stock,
  52. description: request.Description,
  53. order: request.Order,
  54. minPurchase: request.MinPurchase,
  55. maxPurchase: request.MaxPurchase,
  56. saleStartAt: request.SaleStartAt,
  57. saleEndAt: request.SaleEndAt,
  58. requireDonationChannel: request.RequireDonationChannel,
  59. itemKind: request.ItemKind,
  60. durationDays: request.DurationDays,
  61. effectPayload: request.EffectPayload,
  62. isGiftable: request.IsGiftable
  63. );
  64. if (!request.IsActive)
  65. {
  66. product.Deactivate();
  67. }
  68. db.Product.Add(product);
  69. await db.SaveChangesAsync(ct);
  70. if (request.ThumbnailFile is not null)
  71. {
  72. var uploadPath = new FileStoragePath(UploadTarget.Upload, UploadFolder.StoreProduct, product.ID);
  73. var saved = await fileStorage.SaveFileAsync(request.ThumbnailFile, uploadPath, AllowedImageExt, ct);
  74. if (saved is not null)
  75. {
  76. product.Update(
  77. gameID: product.GameID,
  78. name: product.Name,
  79. type: product.Type,
  80. price: product.Price,
  81. discountType: product.DiscountType,
  82. discountValue: product.DiscountValue,
  83. stock: product.Stock,
  84. description: product.Description,
  85. thumbnail: saved.Url,
  86. order: product.Order,
  87. minPurchase: product.MinPurchase,
  88. maxPurchase: product.MaxPurchase,
  89. saleStartAt: product.SaleStartAt,
  90. saleEndAt: product.SaleEndAt,
  91. isActive: product.IsActive,
  92. requireDonationChannel: product.RequireDonationChannel
  93. );
  94. await db.SaveChangesAsync(ct);
  95. }
  96. }
  97. return Result.Success(product.ID);
  98. }
  99. }