Handler.cs 2.7 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Forum.CommentImage.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.CommentImage.AsNoTracking()
  10. .Include(c => c.Board)
  11. .Include(c => c.Post)
  12. .Include(c => c.Comment)
  13. .AsQueryable();
  14. if (request.BoardID.HasValue)
  15. {
  16. query = query.Where(c => c.BoardID == request.BoardID.Value);
  17. }
  18. if (request.PostID.HasValue)
  19. {
  20. query = query.Where(c => c.PostID == request.PostID.Value);
  21. }
  22. if (request.CommentID.HasValue)
  23. {
  24. query = query.Where(c => c.CommentID == request.CommentID.Value);
  25. }
  26. if (request.IsDisabled.HasValue)
  27. {
  28. query = query.Where(c => c.IsDisabled == request.IsDisabled.Value);
  29. }
  30. if (!string.IsNullOrWhiteSpace(request.StartAt) && DateTime.TryParse(request.StartAt, out var startDate))
  31. {
  32. query = query.Where(c => c.CreatedAt >= startDate);
  33. }
  34. if (!string.IsNullOrWhiteSpace(request.EndAt) && DateTime.TryParse(request.EndAt, out var endDate))
  35. {
  36. query = query.Where(c => c.CreatedAt <= endDate.AddDays(1));
  37. }
  38. query = query.OrderByDescending(c => c.ID);
  39. var total = await query.CountAsync(ct);
  40. var list = await query
  41. .Skip((request.PageNum - 1) * request.PerPage)
  42. .Take(request.PerPage)
  43. .Select(c => new
  44. {
  45. c.ID,
  46. c.BoardID,
  47. BoardName = c.Board.Name,
  48. c.PostID,
  49. PostSubject = c.Post.Subject,
  50. c.CommentID,
  51. c.FileName,
  52. c.Url,
  53. c.Extension,
  54. c.Size,
  55. c.Width,
  56. c.Height,
  57. c.IsDisabled,
  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.CommentID,
  72. c.FileName,
  73. c.Url,
  74. c.Extension,
  75. c.Size,
  76. c.Width,
  77. c.Height,
  78. c.IsDisabled,
  79. c.CreatedAt
  80. ))]
  81. );
  82. }
  83. }