Handler.cs 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133
  1. using Application.Abstractions.Messaging;
  2. using Application.Abstractions.Data;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Admin.Forum.Post.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.Post.AsNoTracking().Include(c => c.Board).AsQueryable();
  10. if (request.BoardID.HasValue)
  11. {
  12. query = query.Where(c => c.BoardID == request.BoardID.Value);
  13. }
  14. if (!string.IsNullOrWhiteSpace(request.Keyword))
  15. {
  16. var kw = request.Keyword.Trim();
  17. query = request.Search switch
  18. {
  19. 0 => query.Where(c => c.Subject.Contains(kw)),
  20. 1 => query.Where(c => c.Content.Contains(kw)),
  21. 2 => query.Where(c => (c.Name != null && c.Name.Contains(kw)) || (c.SID != null && c.SID.Contains(kw))),
  22. _ => query.Where(c => c.Subject.Contains(kw) || c.Content.Contains(kw))
  23. };
  24. }
  25. if (!string.IsNullOrWhiteSpace(request.StartAt) && DateTime.TryParse(request.StartAt, out var startDate))
  26. {
  27. query = query.Where(c => c.CreatedAt >= startDate);
  28. }
  29. if (!string.IsNullOrWhiteSpace(request.EndAt) && DateTime.TryParse(request.EndAt, out var endDate))
  30. {
  31. query = query.Where(c => c.CreatedAt <= endDate.AddDays(1));
  32. }
  33. if (request.IsNotice == true)
  34. {
  35. query = query.Where(c => c.IsNotice);
  36. }
  37. if (request.IsSecret == true)
  38. {
  39. query = query.Where(c => c.IsSecret);
  40. }
  41. if (request.IsReply == true)
  42. {
  43. query = query.Where(c => c.IsReply);
  44. }
  45. if (request.IsDeleted == true)
  46. {
  47. query = query.Where(c => c.IsDeleted);
  48. }
  49. query = request.Sort switch
  50. {
  51. 1 => query.OrderByDescending(c => c.Views),
  52. 2 => query.OrderByDescending(c => c.Comments),
  53. 3 => query.OrderByDescending(c => c.Likes),
  54. _ => query.OrderByDescending(c => c.ID)
  55. };
  56. var total = await query.CountAsync(ct);
  57. var list = await query
  58. .Skip((request.PageNum - 1) * request.PerPage)
  59. .Take(request.PerPage)
  60. .Select(c => new
  61. {
  62. c.ID,
  63. c.BoardID,
  64. BoardName = c.Board.Name,
  65. c.Subject,
  66. c.Thumbnail,
  67. c.Name,
  68. c.SID,
  69. c.IsNotice,
  70. c.IsSecret,
  71. c.IsReply,
  72. c.IsSpeaker,
  73. c.IsAnonymous,
  74. c.IsDeleted,
  75. c.Views,
  76. c.Likes,
  77. c.Dislikes,
  78. c.Comments,
  79. c.Images,
  80. c.Medias,
  81. c.Files,
  82. c.Tags,
  83. c.UpdatedAt,
  84. c.CreatedAt
  85. })
  86. .ToListAsync(ct);
  87. var startNum = total - ((request.PageNum - 1) * request.PerPage);
  88. return new Response(
  89. total,
  90. [..list.Select((c, i) => new Response.Row(
  91. Num: startNum - i,
  92. c.ID,
  93. c.BoardID,
  94. c.BoardName,
  95. c.Subject,
  96. c.Thumbnail,
  97. c.Name,
  98. c.SID,
  99. c.IsNotice,
  100. c.IsSecret,
  101. c.IsReply,
  102. c.IsSpeaker,
  103. c.IsAnonymous,
  104. c.IsDeleted,
  105. c.Views,
  106. c.Likes,
  107. c.Dislikes,
  108. c.Comments,
  109. c.Images,
  110. c.Medias,
  111. c.Files,
  112. c.Tags,
  113. c.UpdatedAt,
  114. c.CreatedAt
  115. ))]
  116. );
  117. }
  118. }