118 lines
3.9 KiB
C#
118 lines
3.9 KiB
C#
using System.Diagnostics.CodeAnalysis;
|
|
using Domain.Entities;
|
|
using Microsoft.Extensions.Logging;
|
|
using Quartz;
|
|
|
|
namespace Application.Jobs;
|
|
|
|
public class UpdateGlobalScoreRankJob : IJob
|
|
{
|
|
private readonly ILogger<UpdateGlobalScoreRankJob> logger;
|
|
|
|
private readonly ICardDbContext cardDbContext;
|
|
|
|
public static readonly JobKey KEY = new("UpdateGlobalScoreRankJob");
|
|
|
|
public UpdateGlobalScoreRankJob(ILogger<UpdateGlobalScoreRankJob> logger, ICardDbContext cardDbContext)
|
|
{
|
|
this.logger = logger;
|
|
this.cardDbContext = cardDbContext;
|
|
}
|
|
|
|
[SuppressMessage("ReSharper.DPA", "DPA0007: Large number of DB records",
|
|
Justification = "All play record will be read")]
|
|
public async Task Execute(IJobExecutionContext context)
|
|
{
|
|
logger.LogInformation("Starting update global rank");
|
|
|
|
var cardMains = await cardDbContext.CardMains.ToListAsync();
|
|
|
|
var totalScoresByCardId = await cardDbContext.CardDetails.Where(detail => detail.Pcol1 == 21)
|
|
.GroupBy(detail => detail.CardId)
|
|
.Select(detailGroup => new
|
|
{
|
|
CardId = detailGroup.Key,
|
|
TotalScore = detailGroup.Sum(detail => detail.ScoreUi1)
|
|
})
|
|
.ToListAsync();
|
|
|
|
var avatarAndTitles = await cardDbContext.CardDetails.Where(detail => detail.Pcol1 == 0 &&
|
|
detail.Pcol2 == 0 &&
|
|
detail.Pcol3 == 0).ToListAsync();
|
|
|
|
var ranks = new List<GlobalScoreRank>();
|
|
foreach (var record in totalScoresByCardId)
|
|
{
|
|
var cardId = record.CardId;
|
|
var score = record.TotalScore;
|
|
var card = cardMains.FirstOrDefault(card => card.CardId == cardId);
|
|
if (card is null)
|
|
{
|
|
logger.LogWarning("Card id {CardId} missing in main card table!", cardId);
|
|
continue;
|
|
}
|
|
|
|
var detail = avatarAndTitles.First(detail => detail.CardId == cardId);
|
|
|
|
var globalRank = new GlobalScoreRank
|
|
{
|
|
CardId = cardId,
|
|
PlayerName = card.PlayerName,
|
|
Fcol1 = detail.Fcol1,
|
|
Area = "Local",
|
|
AreaId = 1,
|
|
Pref = "nesys",
|
|
PrefId = 1337,
|
|
LastPlayTenpoId = 1337,
|
|
TenpoName = "GCLocalServer",
|
|
AvatarId = (int)detail.ScoreI1,
|
|
Title = "Title",
|
|
TitleId = detail.Fcol2,
|
|
TotalScore = score
|
|
};
|
|
|
|
ranks.Add(globalRank);
|
|
}
|
|
|
|
ranks.AddRange(GetFakeRanks());
|
|
ranks.Sort((rank, other) => -rank.TotalScore.CompareTo(other.TotalScore));
|
|
ranks = ranks.Select((rank, i) =>
|
|
{
|
|
rank.Rank = i + 1;
|
|
return rank;
|
|
}).ToList();
|
|
|
|
await cardDbContext.GlobalScoreRanks.UpsertRange(ranks).RunAsync();
|
|
await cardDbContext.SaveChangesAsync(new CancellationToken());
|
|
|
|
logger.LogInformation("Updating global score rank done");
|
|
}
|
|
|
|
private static IEnumerable<GlobalScoreRank> GetFakeRanks()
|
|
{
|
|
var fakeList = new List<GlobalScoreRank>();
|
|
for (int i = 0; i < 5; i++)
|
|
{
|
|
var rank = new GlobalScoreRank
|
|
{
|
|
CardId = 1020392010281502 + i,
|
|
PlayerName = $"Fake{i}",
|
|
Fcol1 = 0,
|
|
Area = "Local",
|
|
AreaId = 1,
|
|
Pref = "nesys",
|
|
PrefId = 1337,
|
|
LastPlayTenpoId = 1337,
|
|
TenpoName = "GCLocalServer",
|
|
AvatarId = i + 10,
|
|
Title = "Title",
|
|
TitleId = i + 100,
|
|
TotalScore = (i + 1) * 1000000
|
|
};
|
|
|
|
fakeList.Add(rank);
|
|
}
|
|
|
|
return fakeList;
|
|
}
|
|
} |