Handler.cs 3.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394959697
  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().Include(c => c.Board).Include(c => c.Post).AsQueryable();
  10. if (request.BoardID.HasValue)
  11. {
  12. query = query.Where(c => c.BoardID == request.BoardID.Value);
  13. }
  14. if (request.PostID.HasValue)
  15. {
  16. query = query.Where(c => c.PostID == request.PostID.Value);
  17. }
  18. if (!string.IsNullOrWhiteSpace(request.Keyword))
  19. {
  20. var kw = request.Keyword.Trim();
  21. query = request.Search switch
  22. {
  23. 1 => query.Where(c => c.PostID.ToString().Contains(kw)),
  24. 2 => query.Where(c => c.Post.Subject.Contains(kw)),
  25. 3 => query.Where(c => (c.Post.Name != null && c.Post.Name.Contains(kw)) || (c.Post.SID != null && c.Post.SID.Contains(kw))),
  26. _ => query.Where(c => c.Post.Subject.Contains(kw))
  27. };
  28. }
  29. if (request.IsDisabled.HasValue)
  30. {
  31. query = query.Where(c => c.IsDisabled == request.IsDisabled.Value);
  32. }
  33. if (!string.IsNullOrWhiteSpace(request.StartAt) && DateTime.TryParse(request.StartAt, out var startDate))
  34. {
  35. query = query.Where(c => c.CreatedAt >= startDate);
  36. }
  37. if (!string.IsNullOrWhiteSpace(request.EndAt) && DateTime.TryParse(request.EndAt, out var endDate))
  38. {
  39. query = query.Where(c => c.CreatedAt <= endDate.AddDays(1));
  40. }
  41. query = query.OrderByDescending(c => c.ID);
  42. var total = await query.CountAsync(ct);
  43. var list = await query
  44. .Skip((request.PageNum - 1) * request.PerPage)
  45. .Take(request.PerPage)
  46. .Select(c => new
  47. {
  48. c.ID,
  49. c.BoardID,
  50. BoardName = c.Board.Name,
  51. c.PostID,
  52. PostSubject = c.Post.Subject,
  53. c.FileName,
  54. c.Url,
  55. c.Extension,
  56. c.Size,
  57. c.Width,
  58. c.Height,
  59. c.IsDisabled,
  60. c.CreatedAt
  61. })
  62. .ToListAsync(ct);
  63. var startNum = total - ((request.PageNum - 1) * request.PerPage);
  64. return new Response(
  65. total,
  66. [..list.Select((c, i) => new Response.Row(
  67. Num: startNum - i,
  68. c.ID,
  69. c.BoardID,
  70. c.BoardName,
  71. c.PostID,
  72. c.PostSubject,
  73. c.FileName,
  74. c.Url,
  75. c.Extension,
  76. c.Size,
  77. c.Width,
  78. c.Height,
  79. c.IsDisabled,
  80. c.CreatedAt
  81. ))]
  82. );
  83. }
  84. }