Handler.cs 1.2 KB

123456789101112131415161718192021222324252627282930313233343536
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Domain.Entities.Forum.ValueObject;
  4. using Microsoft.EntityFrameworkCore;
  5. namespace Application.Features.Forum.PostReaction.Delete;
  6. public sealed class Handler(IAppDbContext db) : 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 reactions = await db.PostReaction
  15. .Where(c => request.IDs.Contains(c.ID))
  16. .ToListAsync(ct);
  17. var postIDs = reactions.Select(c => c.PostID).Distinct().ToList();
  18. var posts = await db.Post.Where(c => postIDs.Contains(c.ID)).ToListAsync(ct);
  19. foreach (var post in posts)
  20. {
  21. var likes = reactions.Count(c => c.PostID == post.ID && c.Reaction == Reaction.Like);
  22. var dislikes = reactions.Count(c => c.PostID == post.ID && c.Reaction == Reaction.Dislike);
  23. post.Likes -= likes;
  24. post.Dislikes -= dislikes;
  25. post.UpdatedAt = DateTime.UtcNow;
  26. }
  27. db.PostReaction.RemoveRange(reactions);
  28. await db.SaveChangesAsync(ct);
  29. }
  30. }