Handler.cs 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Admin.Forum.Trash.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().Include(c => c.Board).Include(c => c.Post).Where(c => c.IsDeleted).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. 1 => query.Where(c => c.PostID.ToString().Contains(kw)),
  20. 2 => query.Where(c => c.Post.Subject.Contains(kw)),
  21. 3 => query.Where(c => c.Content.Contains(kw)),
  22. 4 => query.Where(c => (c.Name != null && c.Name.Contains(kw)) || (c.SID != null && c.SID.Contains(kw))),
  23. _ => query.Where(c => c.Content.Contains(kw))
  24. };
  25. }
  26. if (!string.IsNullOrWhiteSpace(request.StartAt) && DateTime.TryParse(request.StartAt, out var startDate))
  27. {
  28. query = query.Where(c => c.DeletedAt >= startDate);
  29. }
  30. if (!string.IsNullOrWhiteSpace(request.EndAt) && DateTime.TryParse(request.EndAt, out var endDate))
  31. {
  32. query = query.Where(c => c.DeletedAt <= endDate.AddDays(1));
  33. }
  34. query = query.OrderByDescending(c => c.DeletedAt);
  35. var total = await query.CountAsync(ct);
  36. var list = await query
  37. .Skip((request.PageNum - 1) * request.PerPage)
  38. .Take(request.PerPage)
  39. .Select(c => new
  40. {
  41. c.ID,
  42. c.BoardID,
  43. BoardName = c.Board.Name,
  44. c.PostID,
  45. PostSubject = c.Post.Subject,
  46. c.Content,
  47. c.IsReply,
  48. c.Name,
  49. c.SID,
  50. c.DeletedAt,
  51. c.CreatedAt
  52. })
  53. .ToListAsync(ct);
  54. var startNum = total - ((request.PageNum - 1) * request.PerPage);
  55. return new Response(
  56. total,
  57. [..list.Select((c, i) => new Response.Row(
  58. Num: startNum - i,
  59. c.ID,
  60. c.BoardID,
  61. c.BoardName,
  62. c.PostID,
  63. c.PostSubject,
  64. c.Content,
  65. c.IsReply,
  66. c.Name,
  67. c.SID,
  68. c.DeletedAt,
  69. c.CreatedAt
  70. ))]
  71. );
  72. }
  73. }