Handler.cs 2.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869
  1. using Application.Abstractions.Messaging;
  2. using Application.Abstractions.Data;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Forum.Board.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.Board.AsNoTracking().Include(c => c.BoardGroup).AsQueryable();
  10. if (request.BoardGroupID.HasValue)
  11. {
  12. query = query.Where(c => c.BoardGroupID == request.BoardGroupID.Value);
  13. }
  14. if (!string.IsNullOrWhiteSpace(request.Keyword))
  15. {
  16. var kw = request.Keyword.Trim();
  17. query = query.Where(c => c.Name.Contains(kw) || c.Code.Contains(kw));
  18. }
  19. var total = await query.CountAsync(ct);
  20. var list = await query
  21. .OrderBy(c => c.Order)
  22. .ThenByDescending(c => c.ID)
  23. .Skip((request.PageNum - 1) * request.PerPage)
  24. .Take(request.PerPage)
  25. .Select(c => new
  26. {
  27. c.ID,
  28. c.BoardGroupID,
  29. BoardGroupName = c.BoardGroup.Name,
  30. c.Code,
  31. c.Name,
  32. c.Order,
  33. c.IsSearch,
  34. c.IsActive,
  35. c.Posts,
  36. c.Comments,
  37. c.UpdatedAt,
  38. c.CreatedAt
  39. })
  40. .ToListAsync(ct);
  41. var startNum = total - ((request.PageNum - 1) * request.PerPage);
  42. return new Response(
  43. total,
  44. [..list.Select((c, i) => new Response.Row(
  45. Num: startNum - i,
  46. c.ID,
  47. c.BoardGroupID,
  48. c.BoardGroupName,
  49. c.Code,
  50. c.Name,
  51. c.Order,
  52. c.IsSearch,
  53. c.IsActive,
  54. c.Posts,
  55. c.Comments,
  56. c.UpdatedAt,
  57. c.CreatedAt
  58. ))]
  59. );
  60. }
  61. }