GC-local-server-rewrite/Application/Jobs/UpdateGlobalScoreRankJob.cs

using System.Diagnostics.CodeAnalysis;
using Domain.Config;
using Domain.Entities;
using Microsoft.Extensions.Logging;
using Microsoft.Extensions.Options;
using Quartz;

namespace Application.Jobs;

public class UpdateGlobalScoreRankJob : IJob
{
    private readonly ILogger<UpdateGlobalScoreRankJob> logger;

    private readonly ICardDbContext cardDbContext;
    
    private readonly AuthConfig authConfig;
    
    public static readonly JobKey KEY = new("UpdateGlobalScoreRankJob");

    public UpdateGlobalScoreRankJob(ILogger<UpdateGlobalScoreRankJob> logger, 
        ICardDbContext cardDbContext,
        IOptions<AuthConfig> authConfig)
    {
        this.logger = logger;
        this.cardDbContext = cardDbContext;
        this.authConfig = authConfig.Value;
    }

    [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 pref = "nesys";
            var lastPlayTenpoId = 1337;
            var tenpoName = "GCLocalServer";
            if (authConfig.Enabled)
            {
                var result = int.TryParse(detail.LastPlayTenpoId, out lastPlayTenpoId);
                if (!result)
                {
                    lastPlayTenpoId = 1337;
                }
                pref = authConfig.Machines.FirstOrDefault(m => m.TenpoId == detail.LastPlayTenpoId)?.Pref ?? "nesys";
                tenpoName = authConfig.Machines.FirstOrDefault(m => m.TenpoId == detail.LastPlayTenpoId)?.TenpoName ?? "GCLocalServer";
            }

            var globalRank = new GlobalScoreRank
            {
                CardId = cardId,
                PlayerName = card.PlayerName,
                Fcol1 = detail.Fcol1,
                Area = "Local",
                AreaId = 1,
                Pref = pref,
                PrefId = 1337,
                LastPlayTenpoId = lastPlayTenpoId,
                TenpoName = tenpoName,
                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;
    }
}