refactor(bootstrap): migrate /pack/info to seed file
This commit is contained in:
107
SVSim.Bootstrap/Importers/PackImporter.cs
Normal file
107
SVSim.Bootstrap/Importers/PackImporter.cs
Normal file
@@ -0,0 +1,107 @@
|
||||
using Microsoft.EntityFrameworkCore;
|
||||
using SVSim.Bootstrap.Models.Seed;
|
||||
using SVSim.Database;
|
||||
using SVSim.Database.Enums;
|
||||
using SVSim.Database.Models;
|
||||
using static SVSim.Bootstrap.Importers.ImporterBase;
|
||||
|
||||
namespace SVSim.Bootstrap.Importers;
|
||||
|
||||
/// <summary>
|
||||
/// Idempotent upsert of /pack/info catalog from <c>seeds/packs.json</c>. Owned collections
|
||||
/// (ChildGachas, Banners) are replaced wholesale per pack (clear-then-rehydrate) -- diffing owned
|
||||
/// collections by composite keys is more code than it's worth for catalog updates, and this
|
||||
/// matches the wholesale-replace semantics of the previous in-line ImportPacks implementation.
|
||||
/// Rows missing from the seed are LEFT INTACT.
|
||||
/// </summary>
|
||||
public class PackImporter
|
||||
{
|
||||
public async Task<int> ImportAsync(SVSimDbContext context, string seedDir)
|
||||
{
|
||||
var seed = SeedLoader.LoadList<PackSeed>(Path.Combine(seedDir, "packs.json"));
|
||||
if (seed.Count == 0)
|
||||
{
|
||||
Console.WriteLine("[PackImporter] No seed rows; skipping.");
|
||||
return 0;
|
||||
}
|
||||
|
||||
var existing = await context.Packs
|
||||
.Include(p => p.ChildGachas)
|
||||
.Include(p => p.Banners)
|
||||
.ToDictionaryAsync(p => p.Id);
|
||||
|
||||
int created = 0, updated = 0;
|
||||
foreach (var s in seed)
|
||||
{
|
||||
if (s.ParentGachaId == 0) continue;
|
||||
|
||||
var pack = existing.TryGetValue(s.ParentGachaId, out var ex)
|
||||
? ex : new PackConfigEntry { Id = s.ParentGachaId };
|
||||
|
||||
pack.BasePackId = s.BasePackId;
|
||||
pack.GachaType = s.GachaType;
|
||||
pack.PackCategory = (PackCategory)s.PackCategory;
|
||||
pack.PosterType = s.PosterType;
|
||||
pack.CommenceDate = ParseWireDateTime(s.CommenceDate);
|
||||
pack.CompleteDate = ParseWireDateTime(s.CompleteDate);
|
||||
pack.SleeveId = s.SleeveId;
|
||||
pack.SpecialSleeveId = s.SpecialSleeveId;
|
||||
pack.OverrideDrawEffectPackId = s.OverrideDrawEffectPackId;
|
||||
pack.OverrideUiEffectPackId = s.OverrideUiEffectPackId;
|
||||
pack.GachaDetail = s.GachaDetail;
|
||||
pack.IsHide = s.IsHide;
|
||||
pack.IsNew = s.IsNew;
|
||||
pack.IsPreRelease = s.IsPreRelease;
|
||||
pack.OpenCountLimit = s.OpenCountLimit;
|
||||
pack.SalesPeriodTime = string.IsNullOrEmpty(s.SalesPeriodTime)
|
||||
? null
|
||||
: ParseWireDateTime(s.SalesPeriodTime);
|
||||
pack.GachaPointConfig = s.GachaPoint is null ? null : new PackGachaPointConfig
|
||||
{
|
||||
ExchangeablePoint = s.GachaPoint.ExchangeablePoint,
|
||||
IncreaseGachaPoint = s.GachaPoint.IncreaseGachaPoint,
|
||||
};
|
||||
|
||||
// Owned collections -- clear and rehydrate (matches the previous wholesale-replace semantics).
|
||||
pack.ChildGachas.Clear();
|
||||
foreach (var c in s.ChildGachas)
|
||||
{
|
||||
pack.ChildGachas.Add(new PackChildGachaEntry
|
||||
{
|
||||
GachaId = c.GachaId,
|
||||
TypeDetail = c.TypeDetail,
|
||||
Cost = c.Cost,
|
||||
CardCount = c.CardCount,
|
||||
ItemId = c.ItemId,
|
||||
IsDailySingle = c.IsDailySingle,
|
||||
OverrideIncreaseGachaPoint = c.OverrideIncreaseGachaPoint,
|
||||
PurchaseLimitCount = c.PurchaseLimitCount,
|
||||
FreeGachaCampaignId = c.FreeGachaCampaignId,
|
||||
CampaignName = c.CampaignName,
|
||||
});
|
||||
}
|
||||
|
||||
pack.Banners.Clear();
|
||||
foreach (var b in s.Banners)
|
||||
{
|
||||
pack.Banners.Add(new PackBannerEntry
|
||||
{
|
||||
BannerName = b.BannerName,
|
||||
DialogTitle = b.DialogTitle,
|
||||
});
|
||||
}
|
||||
|
||||
if (ex is null)
|
||||
{
|
||||
context.Packs.Add(pack);
|
||||
existing[s.ParentGachaId] = pack;
|
||||
created++;
|
||||
}
|
||||
else updated++;
|
||||
}
|
||||
|
||||
await context.SaveChangesAsync();
|
||||
Console.WriteLine($"[PackImporter] +{created}/~{updated}");
|
||||
return created + updated;
|
||||
}
|
||||
}
|
||||
Reference in New Issue
Block a user