Handler.cs 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778
  1. using Application.Abstractions.Data;
  2. using MediatR;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Member.Logs.IntroChange.Search;
  5. public sealed class Handler(IAppDbContext db) : IRequestHandler<Query, Response>
  6. {
  7. public async Task<Response> Handle(Query request, CancellationToken ct)
  8. {
  9. var query = db.MemberIntroChangeLog.AsNoTracking().Include(x => x.Member).AsQueryable();
  10. // Search filtering
  11. if (!string.IsNullOrWhiteSpace(request.Keyword))
  12. {
  13. query = request.Search switch
  14. {
  15. 1 => query.Where(x => x.MemberID.ToString().Contains(request.Keyword)),
  16. 2 => query.Where(x => x.Member != null && x.Member.Email.Contains(request.Keyword)),
  17. 3 => query.Where(x => x.Member != null && x.Member.Name != null && x.Member.Name.Contains(request.Keyword)),
  18. 4 => query.Where(x => x.BeforeIntro != null && x.BeforeIntro.Contains(request.Keyword)),
  19. 5 => query.Where(x => x.AfterIntro != null && x.AfterIntro.Contains(request.Keyword)),
  20. _ => query
  21. };
  22. }
  23. // Date filtering
  24. if (!string.IsNullOrWhiteSpace(request.StartAt) && DateTime.TryParse(request.StartAt, out var startAt))
  25. {
  26. query = query.Where(x => x.CreatedAt >= startAt);
  27. }
  28. if (!string.IsNullOrWhiteSpace(request.EndAt) && DateTime.TryParse(request.EndAt, out var endAt))
  29. {
  30. query = query.Where(x => x.CreatedAt <= endAt);
  31. }
  32. var total = await query.CountAsync(ct);
  33. var skip = (request.PageNum - 1) * request.PerPage;
  34. var list = await query
  35. .OrderByDescending(x => x.ID)
  36. .Skip(skip)
  37. .Take(request.PerPage)
  38. .Select(x => new
  39. {
  40. x.ID,
  41. x.MemberID,
  42. MemberEmail = x.Member.Email,
  43. MemberName = x.Member.Email,
  44. x.BeforeIntro,
  45. x.AfterIntro,
  46. x.IpAddress,
  47. x.CreatedAt
  48. })
  49. .ToListAsync(ct);
  50. var rows = list.Select((x, idx) => new Response.Row
  51. {
  52. Num = total - skip - idx,
  53. ID = x.ID,
  54. MemberID = x.MemberID,
  55. MemberEmail = x.MemberEmail,
  56. MemberName = x.MemberName,
  57. BeforeIntro = x.BeforeIntro,
  58. AfterIntro = x.AfterIntro,
  59. IpAddress = x.IpAddress,
  60. CreatedAt = x.CreatedAt
  61. })
  62. .ToList();
  63. return new Response
  64. {
  65. Total = total,
  66. List = rows
  67. };
  68. }
  69. }