Handler.cs 1.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using SharedKernel.Storage;
  4. using Microsoft.EntityFrameworkCore;
  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 boardIDs = posts.Select(c => c.BoardID).Distinct().ToList();
  23. var boards = await db.Board.Where(c => boardIDs.Contains(c.ID)).ToListAsync(ct);
  24. var groupIDs = boards.Select(c => c.BoardGroupID).Distinct().ToList();
  25. var groups = await db.BoardGroup.Where(c => groupIDs.Contains(c.ID)).ToListAsync(ct);
  26. foreach (var board in boards)
  27. {
  28. var count = posts.Count(c => c.BoardID == board.ID);
  29. board.Posts -= count;
  30. board.UpdatedAt = DateTime.UtcNow;
  31. }
  32. foreach (var group in groups)
  33. {
  34. var relatedBoards = boards.Where(b => b.BoardGroupID == group.ID).Select(b => b.ID).ToList();
  35. var count = posts.Count(c => relatedBoards.Contains(c.BoardID));
  36. group.Posts -= count;
  37. group.UpdatedAt = DateTime.UtcNow;
  38. }
  39. db.Post.RemoveRange(posts);
  40. await db.SaveChangesAsync(ct);
  41. }
  42. }