Handler.cs 3.0 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Admin.Channel.List.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.Channel.AsNoTracking().Include(c => c.Member).AsQueryable();
  10. if (!string.IsNullOrWhiteSpace(request.Keyword))
  11. {
  12. var kw = request.Keyword.Trim();
  13. query = request.Search switch
  14. {
  15. 1 => query.Where(c => c.Name.Contains(kw)),
  16. 2 => query.Where(c => c.SID.Contains(kw)),
  17. 3 => query.Where(c => c.Handle != null && c.Handle.Contains(kw)),
  18. 4 => query.Where(c => c.YouTubeUrl.Contains(kw)),
  19. 5 => query.Where(c => c.MemberID.ToString().Contains(kw)),
  20. 6 => query.Where(c => c.Member.Email.Contains(kw)),
  21. 7 => query.Where(c => c.Member.Name != null && c.Member.Name.Contains(kw)),
  22. _ => query.Where(c => c.Name.Contains(kw))
  23. };
  24. }
  25. if (request.IsVerified.HasValue)
  26. {
  27. query = query.Where(c => c.IsVerified == request.IsVerified.Value);
  28. }
  29. if (!string.IsNullOrWhiteSpace(request.StartAt) && DateTime.TryParse(request.StartAt, out var startDate))
  30. {
  31. query = query.Where(c => c.CreatedAt >= startDate);
  32. }
  33. if (!string.IsNullOrWhiteSpace(request.EndAt) && DateTime.TryParse(request.EndAt, out var endDate))
  34. {
  35. query = query.Where(c => c.CreatedAt <= endDate.AddDays(1));
  36. }
  37. query = query.OrderByDescending(c => c.ID);
  38. var total = await query.CountAsync(ct);
  39. var list = await query
  40. .Skip((request.PageNum - 1) * request.PerPage)
  41. .Take(request.PerPage)
  42. .Select(c => new
  43. {
  44. c.ID,
  45. c.SID,
  46. c.Name,
  47. c.Handle,
  48. c.YouTubeUrl,
  49. c.PlatformFeeRate,
  50. c.IsVerified,
  51. c.IsActive,
  52. c.MemberID,
  53. MemberName = c.Member.Name,
  54. MemberEmail = c.Member.Email,
  55. c.UpdatedAt,
  56. c.CreatedAt
  57. })
  58. .ToListAsync(ct);
  59. var startNum = total - ((request.PageNum - 1) * request.PerPage);
  60. return new Response(
  61. total,
  62. [..list.Select((c, i) => new Response.Row(
  63. Num: startNum - i,
  64. c.ID,
  65. c.SID,
  66. c.Name,
  67. c.Handle,
  68. c.YouTubeUrl,
  69. c.PlatformFeeRate,
  70. c.IsVerified,
  71. c.IsActive,
  72. c.MemberID,
  73. c.MemberName,
  74. c.MemberEmail,
  75. c.UpdatedAt,
  76. c.CreatedAt
  77. ))]
  78. );
  79. }
  80. }