Handler.cs 2.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475
  1. using Application.Abstractions.Messaging;
  2. using Application.Abstractions.Data;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Admin.Member.Logs.NameChange.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.MemberNameChangeLog.AsNoTracking().Include(x => x.Member).AsQueryable();
  10. if (!string.IsNullOrWhiteSpace(request.Keyword))
  11. {
  12. query = request.Search switch
  13. {
  14. 1 => query.Where(x => x.MemberID.ToString().Contains(request.Keyword)),
  15. 2 => query.Where(x => x.Member != null && x.Member.Email.Contains(request.Keyword)),
  16. 3 => query.Where(x => x.Member != null && x.Member.Name != null && x.Member.Name.Contains(request.Keyword)),
  17. 4 => query.Where(x => x.BeforeName != null && x.BeforeName.Contains(request.Keyword)),
  18. 5 => query.Where(x => x.AfterName != null && x.AfterName.Contains(request.Keyword)),
  19. 6 => query.Where(x => x.Member != null && x.Member.SID.Contains(request.Keyword)),
  20. _ => query
  21. };
  22. }
  23. if (!string.IsNullOrWhiteSpace(request.StartAt) && DateTime.TryParse(request.StartAt, out var startAt))
  24. {
  25. query = query.Where(x => x.CreatedAt >= startAt);
  26. }
  27. if (!string.IsNullOrWhiteSpace(request.EndAt) && DateTime.TryParse(request.EndAt, out var endAt))
  28. {
  29. query = query.Where(x => x.CreatedAt <= endAt);
  30. }
  31. var total = await query.CountAsync(ct);
  32. var skip = (request.Page - 1) * request.PerPage;
  33. var list = await query
  34. .OrderByDescending(x => x.ID)
  35. .Skip(skip)
  36. .Take(request.PerPage)
  37. .Select(x => new
  38. {
  39. x.ID,
  40. x.MemberID,
  41. MemberEmail = x.Member.Email,
  42. x.BeforeName,
  43. x.AfterName,
  44. x.IpAddress,
  45. x.CreatedAt
  46. })
  47. .ToListAsync(ct);
  48. var rows = list.Select((x, idx) => new Response.Row
  49. {
  50. Num = total - skip - idx,
  51. ID = x.ID,
  52. MemberID = x.MemberID,
  53. MemberEmail = x.MemberEmail,
  54. BeforeName = x.BeforeName,
  55. AfterName = x.AfterName,
  56. IpAddress = x.IpAddress,
  57. CreatedAt = x.CreatedAt
  58. })
  59. .ToList();
  60. return new Response
  61. {
  62. Total = total,
  63. List = rows
  64. };
  65. }
  66. }