Handler.cs 2.5 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Forum.PostImage.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.PostImage.AsNoTracking()
  10. .Include(c => c.Board)
  11. .Include(c => c.Post)
  12. .AsQueryable();
  13. if (request.BoardID.HasValue)
  14. {
  15. query = query.Where(c => c.BoardID == request.BoardID.Value);
  16. }
  17. if (request.PostID.HasValue)
  18. {
  19. query = query.Where(c => c.PostID == request.PostID.Value);
  20. }
  21. if (request.IsDisabled.HasValue)
  22. {
  23. query = query.Where(c => c.IsDisabled == request.IsDisabled.Value);
  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. 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.FileName,
  46. c.Url,
  47. c.Extension,
  48. c.Size,
  49. c.Width,
  50. c.Height,
  51. c.IsDisabled,
  52. c.CreatedAt
  53. })
  54. .ToListAsync(ct);
  55. var startNum = total - ((request.PageNum - 1) * request.PerPage);
  56. return new Response(
  57. total,
  58. [..list.Select((c, i) => new Response.Row(
  59. Num: startNum - i,
  60. c.ID,
  61. c.BoardID,
  62. c.BoardName,
  63. c.PostID,
  64. c.PostSubject,
  65. c.FileName,
  66. c.Url,
  67. c.Extension,
  68. c.Size,
  69. c.Width,
  70. c.Height,
  71. c.IsDisabled,
  72. c.CreatedAt
  73. ))]
  74. );
  75. }
  76. }