Handler.cs 2.1 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. using SharedKernel.Extensions;
  2. using Application.Abstractions.Data;
  3. using MediatR;
  4. using Microsoft.EntityFrameworkCore;
  5. namespace Application.Features.Member.LoginLog.Search;
  6. public sealed class Handler(IAppDbContext db) : IRequestHandler<Query, Response>
  7. {
  8. public async Task<Response> Handle(Query request, CancellationToken ct)
  9. {
  10. var query = db.MemberLoginLog
  11. .AsNoTracking()
  12. .Include(x => x.Member)
  13. .AsQueryable();
  14. // 필터링
  15. if (request.MemberId.HasValue)
  16. {
  17. query = query.Where(x => x.MemberID == request.MemberId.Value);
  18. }
  19. if (!string.IsNullOrWhiteSpace(request.Account))
  20. {
  21. query = query.Where(x => x.Account.Contains(request.Account));
  22. }
  23. if (request.Success.HasValue)
  24. {
  25. query = query.Where(x => x.Success == request.Success.Value);
  26. }
  27. var total = await query.CountAsync(ct);
  28. var skip = (request.PageNum - 1) * request.PerPage;
  29. var list = await query
  30. .OrderByDescending(x => x.ID)
  31. .Skip(skip)
  32. .Take(request.PerPage)
  33. .Select(x => new
  34. {
  35. x.ID,
  36. x.MemberID,
  37. MemberName = x.Member != null ? x.Member.Name : null,
  38. x.Account,
  39. x.Success,
  40. x.Reason,
  41. x.IpAddress,
  42. x.UserAgent,
  43. x.CreatedAt
  44. })
  45. .ToListAsync(ct);
  46. var rows = list
  47. .Select((x, idx) => new Response.Row
  48. {
  49. Num = total - skip - idx,
  50. ID = x.ID,
  51. MemberID = x.MemberID,
  52. MemberName = x.MemberName,
  53. Account = x.Account,
  54. Success = x.Success,
  55. Reason = x.Reason,
  56. IpAddress = x.IpAddress,
  57. UserAgent = x.UserAgent,
  58. CreatedAt = x.CreatedAt.GetDateAt()
  59. })
  60. .ToList();
  61. return new Response
  62. {
  63. Total = total,
  64. List = rows
  65. };
  66. }
  67. }