Handler.cs 1.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152
  1. using Application.Abstractions.Messaging;
  2. using Application.Abstractions.Data;
  3. using Microsoft.EntityFrameworkCore;
  4. using SharedKernel.Results;
  5. namespace Application.Features.Api.Forum.PostReport.Create;
  6. public sealed class Handler(IAppDbContext db) : ICommandHandler<Command, Result>
  7. {
  8. public async Task<Result> Handle(Command request, CancellationToken ct)
  9. {
  10. var post = await db.Post.FirstOrDefaultAsync(x => x.ID == request.PostID, ct);
  11. if (post is null)
  12. {
  13. return Result.Failure(Error.NotFound("PostReport.PostNotFound", "게시글을 찾을 수 없습니다."));
  14. }
  15. // 중복 신고 확인
  16. var exists = await db.PostReport.AnyAsync(x => x.PostID == request.PostID && x.MemberID == request.MemberID, ct);
  17. if (exists)
  18. {
  19. return Result.Failure(Error.Conflict("PostReport.Duplicate", "이미 신고한 게시글입니다."));
  20. }
  21. var report = new Domain.Entities.Forum.Posts.PostReport
  22. {
  23. BoardID = post.BoardID,
  24. PostID = request.PostID,
  25. MemberID = request.MemberID,
  26. Type = request.Type,
  27. Reason = request.Reason
  28. };
  29. await db.PostReport.AddAsync(report, ct);
  30. post.Reports++;
  31. // 게시글 작성자의 신고 당한 횟수 증가
  32. if (post.MemberID.HasValue)
  33. {
  34. var reportedStats = await db.MemberStats.FirstOrDefaultAsync(x => x.MemberID == post.MemberID.Value, ct);
  35. if (reportedStats is not null)
  36. {
  37. reportedStats.ReportedCount++;
  38. }
  39. }
  40. await db.SaveChangesAsync(ct);
  41. return Result.Success();
  42. }
  43. }