Handler.cs 3.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Forum.Comment.Search;
  5. public sealed class Handler(IAppDbContext db) : IQueryHandler<Query, Response>
  6. {
  7. public async Task<Response> Handle(Query request, CancellationToken ct)
  8. {
  9. var query = db.Comment.AsNoTracking()
  10. .Include(c => c.Board)
  11. .Include(c => c.Post)
  12. .AsQueryable();
  13. if (request.BoardID.HasValue)
  14. query = query.Where(c => c.BoardID == request.BoardID.Value);
  15. if (request.PostID.HasValue)
  16. query = query.Where(c => c.PostID == request.PostID.Value);
  17. if (!string.IsNullOrWhiteSpace(request.Keyword))
  18. {
  19. var kw = request.Keyword.Trim();
  20. query = request.Search switch
  21. {
  22. 0 => query.Where(c => c.Content.Contains(kw)),
  23. 1 => query.Where(c => (c.Name != null && c.Name.Contains(kw)) || (c.SID != null && c.SID.Contains(kw))),
  24. _ => query.Where(c => c.Content.Contains(kw))
  25. };
  26. }
  27. if (!string.IsNullOrWhiteSpace(request.StartAt) && DateTime.TryParse(request.StartAt, out var startDate))
  28. query = query.Where(c => c.CreatedAt >= startDate);
  29. if (!string.IsNullOrWhiteSpace(request.EndAt) && DateTime.TryParse(request.EndAt, out var endDate))
  30. query = query.Where(c => c.CreatedAt <= endDate.AddDays(1));
  31. if (request.IsDeleted == true)
  32. query = query.Where(c => c.IsDeleted);
  33. query = query.OrderByDescending(c => c.ID);
  34. var total = await query.CountAsync(ct);
  35. var list = await query
  36. .Skip((request.PageNum - 1) * request.PerPage)
  37. .Take(request.PerPage)
  38. .Select(c => new
  39. {
  40. c.ID,
  41. c.BoardID,
  42. BoardName = c.Board.Name,
  43. c.PostID,
  44. PostSubject = c.Post.Subject,
  45. c.Content,
  46. c.Name,
  47. c.SID,
  48. c.IsReply,
  49. c.IsSecret,
  50. c.IsDeleted,
  51. c.Likes,
  52. c.Dislikes,
  53. c.Reports,
  54. c.Replies,
  55. c.UpdatedAt,
  56. c.CreatedAt
  57. })
  58. .ToListAsync(ct);
  59. var startNum = total - ((request.PageNum - 1) * request.PerPage);
  60. return new Response(
  61. total,
  62. [..list.Select((c, i) => new Response.Row(
  63. Num: startNum - i,
  64. c.ID,
  65. c.BoardID,
  66. c.BoardName,
  67. c.PostID,
  68. c.PostSubject,
  69. c.Content,
  70. c.Name,
  71. c.SID,
  72. c.IsReply,
  73. c.IsSecret,
  74. c.IsDeleted,
  75. c.Likes,
  76. c.Dislikes,
  77. c.Reports,
  78. c.Replies,
  79. c.UpdatedAt,
  80. c.CreatedAt
  81. ))]
  82. );
  83. }
  84. }