Handler.cs 3.2 KB

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