Handler.cs 2.5 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Forum.PostFile.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.PostFile.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.Downloads,
  50. c.IsDisabled,
  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.FileName,
  65. c.Url,
  66. c.Extension,
  67. c.Size,
  68. c.Downloads,
  69. c.IsDisabled,
  70. c.CreatedAt
  71. ))]
  72. );
  73. }
  74. }