Handler.cs 2.5 KB

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