Handler.cs 2.7 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879
  1. using Application.Abstractions.Messaging;
  2. using Application.Abstractions.Data;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Admin.Member.Logs.IntroChange.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.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. 6 => query.Where(x => x.Member != null && x.Member.SID.Contains(request.Keyword)),
  21. _ => query
  22. };
  23. }
  24. // Date filtering
  25. if (!string.IsNullOrWhiteSpace(request.StartAt) && DateTime.TryParse(request.StartAt, out var startAt))
  26. {
  27. query = query.Where(x => x.CreatedAt >= startAt);
  28. }
  29. if (!string.IsNullOrWhiteSpace(request.EndAt) && DateTime.TryParse(request.EndAt, out var endAt))
  30. {
  31. query = query.Where(x => x.CreatedAt <= endAt);
  32. }
  33. var total = await query.CountAsync(ct);
  34. var skip = (request.Page - 1) * request.PerPage;
  35. var list = await query
  36. .OrderByDescending(x => x.ID)
  37. .Skip(skip)
  38. .Take(request.PerPage)
  39. .Select(x => new
  40. {
  41. x.ID,
  42. x.MemberID,
  43. MemberEmail = x.Member.Email,
  44. MemberName = x.Member.Email,
  45. x.BeforeIntro,
  46. x.AfterIntro,
  47. x.IpAddress,
  48. x.CreatedAt
  49. })
  50. .ToListAsync(ct);
  51. var rows = list.Select((x, idx) => new Response.Row
  52. {
  53. Num = total - skip - idx,
  54. ID = x.ID,
  55. MemberID = x.MemberID,
  56. MemberEmail = x.MemberEmail,
  57. MemberName = x.MemberName,
  58. BeforeIntro = x.BeforeIntro,
  59. AfterIntro = x.AfterIntro,
  60. IpAddress = x.IpAddress,
  61. CreatedAt = x.CreatedAt
  62. })
  63. .ToList();
  64. return new Response
  65. {
  66. Total = total,
  67. List = rows
  68. };
  69. }
  70. }