Handler.cs 1.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Microsoft.EntityFrameworkCore;
  4. using SharedKernel.Storage;
  5. namespace Application.Features.Admin.Forum.Trash.Post.PermanentDelete;
  6. public sealed class Handler(IAppDbContext db, IFileStorage fileStorage) : ICommandHandler<Command>
  7. {
  8. public async Task Handle(Command request, CancellationToken ct)
  9. {
  10. if (request.IDs is null || request.IDs.Length == 0)
  11. {
  12. return;
  13. }
  14. var posts = await db.Post.Where(c => request.IDs.Contains(c.ID) && c.IsDeleted).ToListAsync(ct);
  15. foreach (var post in posts)
  16. {
  17. if (!string.IsNullOrEmpty(post.Thumbnail))
  18. {
  19. fileStorage.DeleteByUrl(post.Thumbnail);
  20. }
  21. }
  22. var boardPostCounts = posts.GroupBy(p => p.BoardID).ToDictionary(g => g.Key, g => g.Count());
  23. var boards = await db.Board.Where(b => boardPostCounts.Keys.Contains(b.ID)).ToListAsync(ct);
  24. foreach (var board in boards)
  25. {
  26. board.Posts -= boardPostCounts[board.ID];
  27. board.UpdatedAt = DateTime.UtcNow;
  28. }
  29. var boardGroupIDs = boards.Select(c => c.BoardGroupID).Distinct().ToList();
  30. var boardGroups = await db.BoardGroup.Where(g => boardGroupIDs.Contains(g.ID)).ToListAsync(ct);
  31. var boardToGroup = boards.ToDictionary(b => b.ID, b => b.BoardGroupID);
  32. var groupPostCounts = posts.GroupBy(p => boardToGroup[p.BoardID]).ToDictionary(g => g.Key, g => g.Count());
  33. foreach (var group in boardGroups)
  34. {
  35. if (groupPostCounts.TryGetValue(group.ID, out var count))
  36. {
  37. group.Posts -= count;
  38. group.UpdatedAt = DateTime.UtcNow;
  39. }
  40. }
  41. db.Post.RemoveRange(posts);
  42. await db.SaveChangesAsync(ct);
  43. }
  44. }