Handler.cs 3.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Microsoft.EntityFrameworkCore;
  4. using SharedKernel.Results;
  5. using GameGenreEntity = Domain.Entities.Store.GameGenre;
  6. namespace Application.Features.Admin.Store.GameGenre.Save;
  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. var items = request.Items;
  12. var dbRows = await db.GameGenre.ToListAsync(ct);
  13. var dbByID = dbRows.ToDictionary(c => c.ID);
  14. var requestIDs = items.Where(c => c.ID.HasValue && c.ID.Value > 0).Select(c => c.ID!.Value).ToHashSet();
  15. var deleteTargets = dbRows.Where(x => !requestIDs.Contains(x.ID)).ToList();
  16. if (deleteTargets.Count > 0)
  17. {
  18. var deleteIDs = deleteTargets.Select(c => c.ID).ToList();
  19. var inUse = await db.GameGenreMap.AsNoTracking().AnyAsync(c => deleteIDs.Contains(c.GameGenreID), ct);
  20. if (inUse)
  21. {
  22. return Result.Failure<Response>(Error.Conflict("GameGenre.InUse", "게임에 연결된 장르는 삭제할 수 없습니다. 먼저 해당 게임에서 장르 선택을 해제하세요."));
  23. }
  24. db.GameGenre.RemoveRange(deleteTargets);
  25. }
  26. ushort inserted = 0;
  27. ushort updated = 0;
  28. foreach (var row in items)
  29. {
  30. if (string.IsNullOrWhiteSpace(row.KorName))
  31. {
  32. return Result.Failure<Response>(Error.Problem("GameGenre.KorNameRequired", "장르 한글명은 필수입니다."));
  33. }
  34. // 신규 추가
  35. if (!row.ID.HasValue || row.ID.Value <= 0)
  36. {
  37. if (await db.GameGenre.AnyAsync(c => c.KorName == row.KorName, ct))
  38. {
  39. return Result.Failure<Response>(Error.Conflict("GameGenre.DuplicateKorName", $"`{row.KorName}`는 이미 등록된 장르입니다."));
  40. }
  41. db.GameGenre.Add(GameGenreEntity.Create(row.KorName, row.EngName, row.Order, row.IsActive));
  42. inserted++;
  43. continue;
  44. }
  45. // 수정
  46. if (!dbByID.TryGetValue(row.ID.Value, out var existing))
  47. {
  48. return Result.Failure<Response>(Error.NotFound("GameGenre.NotFound", $"존재하지 않는 ID: {row.ID.Value}"));
  49. }
  50. if (existing.KorName != row.KorName && await db.GameGenre.AnyAsync(c => c.KorName == row.KorName, ct))
  51. {
  52. return Result.Failure<Response>(Error.Conflict("GameGenre.DuplicateKorName", $"`{row.KorName}`는 이미 등록된 장르입니다."));
  53. }
  54. existing.Update(row.KorName, row.EngName, row.Order, row.IsActive);
  55. updated++;
  56. }
  57. var deleted = (ushort)deleteTargets.Count;
  58. await db.SaveChangesAsync(ct);
  59. return Result.Success(new Response(inserted, updated, deleted));
  60. }
  61. }