Handler.cs 2.9 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091929394
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Admin.Store.Game.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.Game.AsNoTracking().AsQueryable();
  10. if (!string.IsNullOrWhiteSpace(request.Keyword))
  11. {
  12. var kw = request.Keyword.Trim();
  13. query = request.Search switch
  14. {
  15. 1 => int.TryParse(kw, out var id) ? query.Where(c => c.ID == id) : query.Where(c => false),
  16. 2 => query.Where(c => c.KorName.Contains(kw)),
  17. 3 => query.Where(c => c.EngName != null && c.EngName.Contains(kw)),
  18. 4 => query.Where(c => c.Code != null && c.Code.Contains(kw)),
  19. 5 => query.Where(c => c.Publisher.Contains(kw)),
  20. _ => query.Where(c =>
  21. c.KorName.Contains(kw)
  22. || (c.EngName != null && c.EngName.Contains(kw))
  23. || (c.Code != null && c.Code.Contains(kw))
  24. || c.Publisher.Contains(kw))
  25. };
  26. }
  27. if (DateTime.TryParse(request.StartAt, out var startAt))
  28. {
  29. query = query.Where(c => c.CreatedAt >= startAt);
  30. }
  31. if (DateTime.TryParse(request.EndAt, out var endAt))
  32. {
  33. query = query.Where(c => c.CreatedAt <= endAt);
  34. }
  35. if (request.IsActive.HasValue)
  36. {
  37. query = query.Where(c => c.IsActive == request.IsActive.Value);
  38. }
  39. var total = await query.CountAsync(ct);
  40. var list = await query
  41. .OrderBy(c => c.Order)
  42. .ThenByDescending(c => c.ID)
  43. .Skip((request.Page - 1) * request.PerPage)
  44. .Take(request.PerPage)
  45. .Select(c => new
  46. {
  47. c.ID,
  48. c.Code,
  49. c.KorName,
  50. c.EngName,
  51. c.Publisher,
  52. c.Thumbnail,
  53. c.CommissionRate,
  54. c.Link,
  55. c.IsActive,
  56. c.Order,
  57. ProductCount = db.Product.Count(p => p.GameID == c.ID),
  58. c.UpdatedAt,
  59. c.CreatedAt
  60. })
  61. .ToListAsync(ct);
  62. var startNum = total - ((request.Page - 1) * request.PerPage);
  63. return new Response(
  64. total,
  65. [.. list.Select((c, i) => new Response.Row(
  66. Num: startNum - i,
  67. c.ID,
  68. c.Code,
  69. c.KorName,
  70. c.EngName,
  71. c.Publisher,
  72. c.Thumbnail,
  73. c.CommissionRate,
  74. c.Link,
  75. c.IsActive,
  76. c.Order,
  77. c.ProductCount,
  78. c.UpdatedAt,
  79. c.CreatedAt
  80. ))]
  81. );
  82. }
  83. }