Handler.cs 3.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108
  1. using Application.Abstractions.Data;
  2. using Application.Abstractions.Messaging;
  3. using Domain.Entities.Store.ValueObject;
  4. using Microsoft.EntityFrameworkCore;
  5. namespace Application.Features.Admin.Store.Order.Search;
  6. public sealed class Handler(IAppDbContext db) : IQueryHandler<Query, Response>
  7. {
  8. public async Task<Response> Handle(Query request, CancellationToken ct)
  9. {
  10. // 전체 navtab 카운트 (필터 무관)
  11. var counts = await db.Order.AsNoTracking()
  12. .GroupBy(c => c.Status)
  13. .Select(g => new { Status = g.Key, Count = g.Count() })
  14. .ToListAsync(ct);
  15. int CountOf(OrderStatus s) => counts.FirstOrDefault(x => x.Status == s)?.Count ?? 0;
  16. var statusCounts = new Response.StatusCounts(
  17. All: counts.Sum(x => x.Count),
  18. Paid: CountOf(OrderStatus.Paid),
  19. Preparing: CountOf(OrderStatus.Preparing),
  20. Shipped: CountOf(OrderStatus.Shipped),
  21. Delivered: CountOf(OrderStatus.Delivered),
  22. Cancelled: CountOf(OrderStatus.Cancelled),
  23. Refunded: CountOf(OrderStatus.Refunded),
  24. Exchanged: CountOf(OrderStatus.Exchanged)
  25. );
  26. // 필터 적용
  27. var query = db.Order.AsNoTracking().AsQueryable();
  28. if (request.Status.HasValue)
  29. {
  30. query = query.Where(c => c.Status == request.Status.Value);
  31. }
  32. if (!string.IsNullOrWhiteSpace(request.Keyword))
  33. {
  34. var kw = request.Keyword.Trim();
  35. query = request.Search switch
  36. {
  37. 1 => query.Where(c => c.OrderNumber.Contains(kw)),
  38. 2 => query.Where(c => c.Member!.Email.Contains(kw)),
  39. _ => query.Where(c => c.OrderNumber.Contains(kw) || c.Member!.Email.Contains(kw))
  40. };
  41. }
  42. if (DateTime.TryParse(request.StartAt, out var startAt))
  43. {
  44. query = query.Where(c => c.CreatedAt >= startAt);
  45. }
  46. if (DateTime.TryParse(request.EndAt, out var endAt))
  47. {
  48. query = query.Where(c => c.CreatedAt <= endAt);
  49. }
  50. var total = await query.CountAsync(ct);
  51. var list = await query
  52. .OrderByDescending(c => c.ID)
  53. .Skip((request.Page - 1) * request.PerPage)
  54. .Take(request.PerPage)
  55. .Select(c => new
  56. {
  57. c.ID,
  58. c.OrderNumber,
  59. c.MemberID,
  60. MemberEmail = c.Member!.Email,
  61. c.ChannelID,
  62. ChannelName = c.Channel != null ? c.Channel.Name : null,
  63. c.TotalAmount,
  64. c.PlatformFeeAmount,
  65. c.GameRevenueAmount,
  66. c.ChannelRewardAmount,
  67. c.Status,
  68. c.CreatedAt,
  69. c.PaidAt
  70. })
  71. .ToListAsync(ct);
  72. var startNum = total - ((request.Page - 1) * request.PerPage);
  73. return new Response(
  74. Total: total,
  75. List: [.. list.Select((c, i) => new Response.Row(
  76. Num: startNum - i,
  77. c.ID,
  78. c.OrderNumber,
  79. c.MemberID,
  80. c.MemberEmail,
  81. c.ChannelID,
  82. c.ChannelName,
  83. c.TotalAmount,
  84. c.PlatformFeeAmount,
  85. c.GameRevenueAmount,
  86. c.ChannelRewardAmount,
  87. c.Status,
  88. c.CreatedAt,
  89. c.PaidAt
  90. ))],
  91. Counts: statusCounts
  92. );
  93. }
  94. }