Handler.cs 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136
  1. using Application.Abstractions.Messaging;
  2. using Application.Abstractions.Data;
  3. using SharedKernel.Storage;
  4. using Microsoft.EntityFrameworkCore;
  5. namespace Application.Features.Admin.Forum.Post.Update;
  6. public sealed class Handler(IAppDbContext db, IFileStorage fileStorage) : ICommandHandler<Command>
  7. {
  8. private static readonly string[] AllowedImageExtensions = [".jpg", ".jpeg", ".png", ".gif", ".webp", ".bmp"];
  9. private static readonly string[] AllowedFileExtensions = [".jpg", ".jpeg", ".png", ".gif", ".webp", ".bmp", ".pdf", ".doc", ".docx", ".xls", ".xlsx", ".ppt", ".pptx", ".txt", ".zip", ".rar", ".7z", ".hwp", ".hwpx", ".csv"];
  10. public async Task Handle(Command request, CancellationToken ct)
  11. {
  12. var post = await db.Post.FirstOrDefaultAsync(x => x.ID == request.ID, ct);
  13. if (post is null)
  14. {
  15. throw new KeyNotFoundException("게시글을 찾을 수 없습니다.");
  16. }
  17. post.BoardPrefixID = request.BoardPrefixID;
  18. post.Subject = request.Subject;
  19. post.Content = request.Content ?? string.Empty;
  20. post.IsNotice = request.IsNotice;
  21. post.IsSecret = request.IsSecret;
  22. post.IsAnonymous = request.IsAnonymous;
  23. post.UpdatedAt = DateTime.UtcNow;
  24. // 썸네일 처리
  25. if (request.ThumbnailFile is not null)
  26. {
  27. var uploadPath = new FileStoragePath(UploadTarget.Upload, UploadFolder.Post, post.ID);
  28. if (!string.IsNullOrEmpty(post.Thumbnail))
  29. {
  30. fileStorage.DeleteByUrl(post.Thumbnail);
  31. }
  32. var result = await fileStorage.SaveFileAsync(request.ThumbnailFile, uploadPath, AllowedImageExtensions, ct);
  33. post.Thumbnail = result?.Url;
  34. }
  35. // 파일 처리 (새 파일 추가)
  36. if (request.Files is { Count: > 0 })
  37. {
  38. var uploadPath = new FileStoragePath(UploadTarget.Upload, UploadFolder.Post, post.ID);
  39. foreach (var file in request.Files)
  40. {
  41. var result = await fileStorage.SaveFileAsync(file, uploadPath, AllowedFileExtensions, ct);
  42. if (result is not null)
  43. {
  44. var ext = Path.GetExtension(file.FileName).ToLowerInvariant();
  45. await db.PostFile.AddAsync(new Domain.Entities.Forum.Posts.PostFile
  46. {
  47. BoardID = post.BoardID,
  48. PostID = post.ID,
  49. UUID = Guid.NewGuid(),
  50. FileName = file.FileName,
  51. HashedName = result.FileName,
  52. Path = uploadPath.ToRelativePath(),
  53. Url = result.Url,
  54. Extension = ext,
  55. ContentType = file.ContentType,
  56. Size = result.Size
  57. }, ct);
  58. }
  59. }
  60. var fileCount = await db.PostFile.CountAsync(x => x.PostID == post.ID && !x.IsDisabled, ct);
  61. post.Files = (byte)Math.Min(fileCount + request.Files.Count, byte.MaxValue);
  62. }
  63. // 태그 처리 (diff 기반)
  64. if (request.Tags is not null)
  65. {
  66. var existingPostTags = await db.PostTag.Include(x => x.Tag).Where(x => x.PostID == post.ID).ToListAsync(ct);
  67. var newTagSlugs = request.Tags.Where(t => !string.IsNullOrWhiteSpace(t)).Select(t => t.Trim().ToLowerInvariant().Replace(' ', '-')).ToHashSet();
  68. var existingSlugs = existingPostTags.Select(x => x.Tag.Slug).ToHashSet();
  69. // 삭제할 태그: 기존에 있지만 새 목록에 없는 것
  70. var toRemove = existingPostTags.Where(x => !newTagSlugs.Contains(x.Tag.Slug)).ToList();
  71. foreach (var postTag in toRemove)
  72. {
  73. db.PostTag.Remove(postTag);
  74. if (postTag.Tag.UsageCount > 0)
  75. {
  76. postTag.Tag.UsageCount--;
  77. postTag.Tag.UpdatedAt = DateTime.UtcNow;
  78. }
  79. }
  80. // 추가할 태그: 새 목록에 있지만 기존에 없는 것
  81. var toAdd = request.Tags
  82. .Where(t => !string.IsNullOrWhiteSpace(t))
  83. .Select(t => t.Trim())
  84. .Where(t => !existingSlugs.Contains(t.ToLowerInvariant().Replace(' ', '-')))
  85. .ToList();
  86. foreach (var tagName in toAdd)
  87. {
  88. var slug = tagName.ToLowerInvariant().Replace(' ', '-');
  89. var tag = await db.Tag.FirstOrDefaultAsync(x => x.Slug == slug, ct);
  90. if (tag is null)
  91. {
  92. tag = new Domain.Entities.Forum.Posts.Tag
  93. {
  94. Name = tagName,
  95. Slug = slug
  96. };
  97. await db.Tag.AddAsync(tag, ct);
  98. await db.SaveChangesAsync(ct);
  99. }
  100. tag.UsageCount++;
  101. tag.UpdatedAt = DateTime.UtcNow;
  102. await db.PostTag.AddAsync(new Domain.Entities.Forum.Posts.PostTag
  103. {
  104. BoardID = post.BoardID,
  105. PostID = post.ID,
  106. TagID = tag.ID
  107. }, ct);
  108. }
  109. post.Tags = (byte)Math.Min(newTagSlugs.Count, byte.MaxValue);
  110. }
  111. await db.SaveChangesAsync(ct);
  112. }
  113. }