DonationRankingByToken.cs 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107
  1. using Application.Abstractions.Data;
  2. using Domain.Entities.Donations.ValueObject;
  3. using Web.Api.Common;
  4. using Microsoft.EntityFrameworkCore;
  5. namespace Web.Api.Endpoints.Widget;
  6. /// <summary>WidgetToken + configID 기반 후원 순위 (위젯 초기 로드용, 인증 불필요).
  7. /// configID 지정 시 해당 RankConfig의 Period + MaxRankCount 적용. 미지정 시 활성 첫 번째 또는 Daily/Top5 default.
  8. /// Donation 테이블 실시간 GROUP BY (DonationRanking 사전 집계 무시).</summary>
  9. internal sealed class DonationRankingByToken : IEndpoint
  10. {
  11. public void MapEndpoint(IEndpointRouteBuilder app)
  12. {
  13. app.MapGet("api/widget/rank/by-token/{widgetToken}", async (
  14. string widgetToken,
  15. int? configID,
  16. IAppDbContext db,
  17. CancellationToken ct
  18. ) => {
  19. var channelID = await db.Channel.AsNoTracking()
  20. .Where(c => c.WidgetToken == widgetToken && c.IsActive)
  21. .Select(c => c.ID)
  22. .FirstOrDefaultAsync(ct);
  23. if (channelID == 0)
  24. {
  25. return ApiResponse.Ok(new { list = Array.Empty<object>() });
  26. }
  27. // RankConfig 조회 (configID 지정 또는 활성 첫 번째)
  28. var rankCfgQuery = db.DonationRankConfig.AsNoTracking()
  29. .Where(r => r.ChannelID == channelID);
  30. if (configID.HasValue)
  31. {
  32. rankCfgQuery = rankCfgQuery.Where(r => r.ID == configID.Value);
  33. }
  34. else
  35. {
  36. rankCfgQuery = rankCfgQuery.Where(r => r.IsActive);
  37. }
  38. var rankCfg = await rankCfgQuery
  39. .OrderByDescending(r => r.ID)
  40. .Select(r => new { r.Period, r.MaxRankCount, r.StartAt, r.EndAt })
  41. .FirstOrDefaultAsync(ct);
  42. // config 없으면 default (Daily, Top5)
  43. var period = rankCfg?.Period ?? RankPeriodType.Daily;
  44. var limit = rankCfg?.MaxRankCount ?? 5;
  45. // Period에 따른 시작 시각
  46. var now = DateTime.UtcNow;
  47. DateTime? rangeStart = period switch
  48. {
  49. RankPeriodType.Daily => now.Date,
  50. RankPeriodType.Weekly => now.Date.AddDays(-(int)now.DayOfWeek),
  51. RankPeriodType.Monthly => new DateTime(now.Year, now.Month, 1, 0, 0, 0, DateTimeKind.Utc),
  52. _ => null // Total 등
  53. };
  54. // 추가 StartAt/EndAt 필터 (config가 명시한 기간)
  55. var startAt = rankCfg?.StartAt ?? rangeStart;
  56. var endAt = rankCfg?.EndAt;
  57. var donationQuery = db.Donation.AsNoTracking()
  58. .Where(d => d.ChannelID == channelID && !d.IsTest);
  59. if (startAt.HasValue)
  60. {
  61. donationQuery = donationQuery.Where(d => d.CreatedAt >= startAt.Value);
  62. }
  63. if (endAt.HasValue)
  64. {
  65. donationQuery = donationQuery.Where(d => d.CreatedAt <= endAt.Value);
  66. }
  67. // SponsorMemberID로 통합 (같은 sponsor가 다른 별명으로 후원해도 합산). SendName은 가장 최근 것.
  68. var raw = await donationQuery
  69. .GroupBy(d => d.SponsorMemberID)
  70. .Select(g => new
  71. {
  72. SponsorMemberID = g.Key,
  73. SendName = g.OrderByDescending(d => d.CreatedAt).Select(d => d.SendName).FirstOrDefault() ?? "",
  74. TotalAmount = g.Sum(d => d.NetAmount),
  75. DonationCount = g.Count()
  76. })
  77. .OrderByDescending(g => g.TotalAmount)
  78. .Take(limit)
  79. .ToListAsync(ct);
  80. var list = raw.Select((r, i) => new
  81. {
  82. rank = i + 1,
  83. sponsorMemberID = r.SponsorMemberID,
  84. sponsorName = r.SendName,
  85. totalAmount = r.TotalAmount,
  86. donationCount = r.DonationCount
  87. }).ToList();
  88. return ApiResponse.Ok(new { list });
  89. })
  90. .WithTags("Widget")
  91. .AllowAnonymous();
  92. }
  93. }