Handler.cs 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118
  1. using Application.Abstractions.Messaging;
  2. using Application.Abstractions.Data;
  3. using Microsoft.EntityFrameworkCore;
  4. namespace Application.Features.Admin.Crypto.List.Search
  5. {
  6. public sealed class Handler(IAppDbContext db) : IQueryHandler<Query, Response>
  7. {
  8. public async Task<Response> Handle(Query request, CancellationToken ct)
  9. {
  10. var query = db.Coin.AsNoTracking().Include(c => c.CoinCategoryMap).ThenInclude(m => m.CoinCategory).AsQueryable();
  11. if (request.CategoryID.HasValue)
  12. {
  13. query = query.Where(c => c.CoinCategoryMap.Any(m => m.CategoryID == request.CategoryID.Value));
  14. }
  15. if (!string.IsNullOrWhiteSpace(request.Keyword))
  16. {
  17. var kw = request.Keyword.Trim();
  18. query = query.Where(c => c.Symbol.Contains(kw) || c.KorName.Contains(kw) || c.EngName.Contains(kw));
  19. }
  20. if (request.IsActive.HasValue)
  21. {
  22. query = query.Where(c => c.IsActive == request.IsActive.Value);
  23. }
  24. if (request.IsWarning.HasValue)
  25. {
  26. query = query.Where(c => c.IsWarning == request.IsWarning.Value);
  27. }
  28. if (request.IsNew.HasValue)
  29. {
  30. query = query.Where(c => c.IsNew == request.IsNew.Value);
  31. }
  32. if (request.IsDelisted.HasValue)
  33. {
  34. query = query.Where(c => c.IsDelisted == request.IsDelisted.Value);
  35. }
  36. var baseQuery = query;
  37. var allCount = await baseQuery.CountAsync(ct);
  38. var krwCount = await baseQuery.Where(c => c.CoinMarket.Any(m => m.Market.StartsWith("KRW-"))).CountAsync(ct);
  39. var btcCount = await baseQuery.Where(c => c.CoinMarket.Any(m => m.Market.StartsWith("BTC-"))).CountAsync(ct);
  40. var usdtCount = await baseQuery.Where(c => c.CoinMarket.Any(m => m.Market.StartsWith("USDT-"))).CountAsync(ct);
  41. if (request.Tab > 0)
  42. {
  43. var prefix = request.Tab switch
  44. {
  45. 1 => "KRW-",
  46. 2 => "BTC-",
  47. 3 => "USDT-",
  48. _ => ""
  49. };
  50. if (prefix.Length > 0)
  51. {
  52. query = query.Where(c => c.CoinMarket.Any(m => m.Market.StartsWith(prefix)));
  53. }
  54. }
  55. var total = await query.CountAsync(ct);
  56. var list = await query
  57. .OrderByDescending(c => c.ID)
  58. .Skip((request.PageNum - 1) * request.PerPage)
  59. .Take(request.PerPage)
  60. .Select(c => new
  61. {
  62. c.ID,
  63. c.CoinMarket,
  64. c.Symbol,
  65. c.KorName,
  66. c.EngName,
  67. c.LogoImage,
  68. CategoryNames = c.CoinCategoryMap.Select(m => m.CoinCategory.Name).ToList(),
  69. c.IsActive,
  70. c.IsWarning,
  71. c.IsNew,
  72. c.IsDelisted,
  73. c.UpdatedAt,
  74. c.CreatedAt
  75. })
  76. .ToListAsync(ct);
  77. var startNum = total - ((request.PageNum - 1) * request.PerPage);
  78. return new Response(
  79. total,
  80. [..list.Select((c, i) => new Response.Row(
  81. Num: startNum - i,
  82. c.ID,
  83. c.CoinMarket,
  84. c.Symbol,
  85. c.KorName,
  86. c.EngName,
  87. c.LogoImage,
  88. c.CategoryNames,
  89. c.IsActive,
  90. c.IsWarning,
  91. c.IsNew,
  92. c.IsDelisted,
  93. c.UpdatedAt,
  94. c.CreatedAt
  95. ))],
  96. allCount,
  97. krwCount,
  98. btcCount,
  99. usdtCount
  100. );
  101. }
  102. }
  103. }