CrewRankingByToken.cs 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136
  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로 CrewWidgetConfig → Crew 식별 → CrewMember 기반 base ranking + CrewDonationSummary로 수치 갱신.
  8. /// 후원 없는 크루원도 0원으로 표시.</summary>
  9. internal sealed class CrewRankingByToken : IEndpoint
  10. {
  11. public void MapEndpoint(IEndpointRouteBuilder app)
  12. {
  13. app.MapGet("api/widget/crew/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>(), totalAmount = 0 });
  26. }
  27. // CrewWidgetConfig 조회
  28. var widgetCfgQuery = db.CrewWidgetConfig.AsNoTracking()
  29. .Where(w => w.ChannelID == channelID);
  30. if (configID.HasValue)
  31. {
  32. widgetCfgQuery = widgetCfgQuery.Where(w => w.ID == configID.Value);
  33. }
  34. else
  35. {
  36. widgetCfgQuery = widgetCfgQuery.Where(w => w.IsActive);
  37. }
  38. var widgetCfg = await widgetCfgQuery
  39. .OrderByDescending(w => w.ID)
  40. .Select(w => new { w.CrewID, w.MaxDisplayCount })
  41. .FirstOrDefaultAsync(ct);
  42. if (widgetCfg is null)
  43. {
  44. return ApiResponse.Ok(new { list = Array.Empty<object>(), totalAmount = 0 });
  45. }
  46. // Base: 크루의 모든 active 크루원 (Channel.ThumbnailUrl 우선)
  47. var baseMembers = await db.CrewMember.AsNoTracking()
  48. .Where(m => m.CrewID == widgetCfg.CrewID && m.IsActive)
  49. .OrderBy(m => m.SortOrder).ThenBy(m => m.JoinedAt)
  50. .Select(m => new
  51. {
  52. ID = m.ID,
  53. Nickname = m.Nickname,
  54. Icon = m.Channel != null && m.Channel.ThumbnailUrl != null
  55. ? m.Channel.ThumbnailUrl
  56. : (m.Member != null ? m.Member.Thumb : null),
  57. ChannelName = m.Channel != null ? m.Channel.Name : null
  58. })
  59. .ToListAsync(ct);
  60. // 가장 최근 CrewSession (active 우선, 없으면 ended)
  61. var sessionID = await db.CrewSession.AsNoTracking()
  62. .Where(s => s.CrewID == widgetCfg.CrewID && s.Status == CrewSessionStatus.Active)
  63. .OrderByDescending(s => s.CreatedAt)
  64. .Select(s => (int?)s.ID)
  65. .FirstOrDefaultAsync(ct);
  66. if (sessionID is null)
  67. {
  68. sessionID = await db.CrewSession.AsNoTracking()
  69. .Where(s => s.CrewID == widgetCfg.CrewID)
  70. .OrderByDescending(s => s.CreatedAt)
  71. .Select(s => (int?)s.ID)
  72. .FirstOrDefaultAsync(ct);
  73. }
  74. // CrewDonationSummary 데이터 (있으면)
  75. var summaryDict = sessionID.HasValue
  76. ? (await db.CrewDonationSummary.AsNoTracking()
  77. .Where(s => s.CrewSessionID == sessionID.Value)
  78. .Select(s => new { s.CrewMemberID, s.TotalAmount, s.DonationCount, s.ContributionRate })
  79. .ToListAsync(ct)).ToDictionary(s => s.CrewMemberID)
  80. : new();
  81. var sessionTotal = sessionID.HasValue
  82. ? await db.CrewSession.AsNoTracking()
  83. .Where(s => s.ID == sessionID.Value)
  84. .Select(s => s.TotalAmount)
  85. .FirstOrDefaultAsync(ct)
  86. : 0;
  87. // base + summary merge
  88. var merged = baseMembers.Select(m =>
  89. {
  90. var s = summaryDict.GetValueOrDefault(m.ID);
  91. return new
  92. {
  93. crewMemberID = m.ID,
  94. nickname = m.Nickname,
  95. icon = m.Icon,
  96. channelName = m.ChannelName,
  97. totalAmount = s?.TotalAmount ?? 0,
  98. donationCount = s?.DonationCount ?? 0,
  99. contributionRate = s?.ContributionRate ?? 0m
  100. };
  101. })
  102. .OrderByDescending(x => x.totalAmount)
  103. .Take(widgetCfg.MaxDisplayCount)
  104. .ToList();
  105. var list = merged.Select((x, i) => new
  106. {
  107. rank = i + 1,
  108. crewMemberID = x.crewMemberID,
  109. nickname = x.nickname,
  110. icon = x.icon,
  111. channelName = x.channelName,
  112. totalAmount = x.totalAmount,
  113. donationCount = x.donationCount,
  114. contributionRate = x.contributionRate
  115. }).ToList();
  116. return ApiResponse.Ok(new { list, totalAmount = sessionTotal });
  117. })
  118. .WithTags("Widget")
  119. .AllowAnonymous();
  120. }
  121. }