Handler.cs 2.7 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495
  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.PostReport.Search;
  6. public sealed class Handler(IAppDbContext db) : IQueryHandler<Query, Response>
  7. {
  8. public async Task<Response> Handle(Query request, CancellationToken ct)
  9. {
  10. var query = db.PostReport.AsNoTracking()
  11. .Include(c => c.Board)
  12. .Include(c => c.Post)
  13. .Include(c => c.Member)
  14. .AsQueryable();
  15. if (request.BoardID.HasValue)
  16. {
  17. query = query.Where(c => c.BoardID == request.BoardID.Value);
  18. }
  19. if (request.PostID.HasValue)
  20. {
  21. query = query.Where(c => c.PostID == request.PostID.Value);
  22. }
  23. if (request.Status.HasValue)
  24. {
  25. query = query.Where(c => c.Status == (ReportStatus)request.Status.Value);
  26. }
  27. if (request.Type.HasValue)
  28. {
  29. query = query.Where(c => c.Type == (ReportType)request.Type.Value);
  30. }
  31. if (!string.IsNullOrWhiteSpace(request.StartAt) && DateTime.TryParse(request.StartAt, out var startDate))
  32. {
  33. query = query.Where(c => c.CreatedAt >= startDate);
  34. }
  35. if (!string.IsNullOrWhiteSpace(request.EndAt) && DateTime.TryParse(request.EndAt, out var endDate))
  36. {
  37. query = query.Where(c => c.CreatedAt <= endDate.AddDays(1));
  38. }
  39. query = query.OrderByDescending(c => c.ID);
  40. var total = await query.CountAsync(ct);
  41. var list = await query
  42. .Skip((request.PageNum - 1) * request.PerPage)
  43. .Take(request.PerPage)
  44. .Select(c => new
  45. {
  46. c.ID,
  47. c.BoardID,
  48. BoardName = c.Board.Name,
  49. c.PostID,
  50. PostSubject = c.Post.Subject,
  51. c.MemberID,
  52. MemberName = c.Member.Name,
  53. c.Type,
  54. c.Reason,
  55. c.Status,
  56. c.Memo,
  57. c.UpdatedAt,
  58. c.CreatedAt
  59. })
  60. .ToListAsync(ct);
  61. var startNum = total - ((request.PageNum - 1) * request.PerPage);
  62. return new Response(
  63. total,
  64. [..list.Select((c, i) => new Response.Row(
  65. Num: startNum - i,
  66. c.ID,
  67. c.BoardID,
  68. c.BoardName,
  69. c.PostID,
  70. c.PostSubject,
  71. c.MemberID,
  72. c.MemberName,
  73. c.Type,
  74. c.Reason,
  75. c.Status,
  76. c.Memo,
  77. c.UpdatedAt,
  78. c.CreatedAt
  79. ))]
  80. );
  81. }
  82. }