Handler.cs 1.4 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Forum.Trash.Comment.PermanentDelete;
  5. public sealed class Handler(IAppDbContext db) : ICommandHandler<Command>
  6. {
  7. public async Task Handle(Command request, CancellationToken ct)
  8. {
  9. if (request.IDs is null || request.IDs.Length == 0)
  10. {
  11. return;
  12. }
  13. var comments = await db.Comment
  14. .Where(c => request.IDs.Contains(c.ID) && c.IsDeleted)
  15. .ToListAsync(ct);
  16. var postIDs = comments.Select(c => c.PostID).Distinct().ToList();
  17. var posts = await db.Post.Where(c => postIDs.Contains(c.ID)).ToListAsync(ct);
  18. foreach (var post in posts)
  19. {
  20. var count = comments.Count(c => c.PostID == post.ID);
  21. post.Comments -= count;
  22. post.UpdatedAt = DateTime.UtcNow;
  23. }
  24. var boardIDs = comments.Select(c => c.BoardID).Distinct().ToList();
  25. var boards = await db.Board.Where(c => boardIDs.Contains(c.ID)).ToListAsync(ct);
  26. foreach (var board in boards)
  27. {
  28. var count = comments.Count(c => c.BoardID == board.ID);
  29. board.Comments -= count;
  30. board.UpdatedAt = DateTime.UtcNow;
  31. }
  32. db.Comment.RemoveRange(comments);
  33. await db.SaveChangesAsync(ct);
  34. }
  35. }