Handler.cs 2.2 KB

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