ANTOOZA-BACKEND/Infrastructure/StockData/SeibroBondImport.cs

using Application.Abstractions.Data;
using Domain.Entities.Stocks;
using Microsoft.EntityFrameworkCore;

namespace Infrastructure.StockData;

/// <summary>
/// SeibroBondSyncService 의 DB 반영 로직 분리 (테스트 가능) — HTTP 없이 파서 출력(fixture)으로 검증한다
/// (SeibroCorpActionImport 패턴 미러링). 여덟 엔티티(발행·마스터·이자·조기상환·단기발행·CD·CP·전단채) upsert 담당.
/// getBondStatInfo/getIntPayInfo/getCDInfo/getCPInfo/getESTBInfo 응답에는 ISIN 필드가 없어(요청 파라미터로만 받음)
/// 배치가 요청 ISIN 을 스탬핑한다 — 해당 upsert 는 isin 을 인자로 받고 파서 필드 묶음에서 첫 행만 채택한다.
/// </summary>
public static class SeibroBondImport
{
    /// <summary>getBondIssuInfo 결과를 BondIssuance 로 upsert — UQ (Isin). rows 는 발행일 스윕 per 콜 결과(다수 종목).</summary>
    public static async Task<(int Inserted, int Updated)> UpsertBondIssuancesAsync(IAppDbContext db, IReadOnlyList<SeibroBondIssuParser.Row> rows, CancellationToken ct)
    {
        if (rows.Count == 0)
        {
            return (0, 0);
        }

        var isins = rows.Select(c => c.Isin).Distinct().ToList();
        var existing = await db.BondIssuance.Where(c => isins.Contains(c.Isin)).ToListAsync(ct);
        var byKey = existing.ToDictionary(c => c.Isin);
        var seen = new HashSet<string>();
        var inserted = 0;
        var updated = 0;

        foreach (var row in rows)
        {
            if (!seen.Add(row.Isin))
            {
                continue;
            }

            if (byKey.TryGetValue(row.Isin, out var entity))
            {
                var was = entity.UpdatedAt;
                entity.Update(row.IssuDt, row.IssucoCustno, row.IssucoCustNm, row.KorSecnNm);
                if (entity.UpdatedAt != was)
                {
                    updated++;
                }
            }
            else
            {
                var created = BondIssuance.Create(row.IssuDt, row.IssucoCustno, row.IssucoCustNm, row.Isin, row.KorSecnNm);
                await db.BondIssuance.AddAsync(created, ct);
                byKey[row.Isin] = created;
                inserted++;
            }
        }

        await db.SaveChangesAsync(ct);
        return (inserted, updated);
    }

    /// <summary>
    /// getBondStatInfo 결과를 BondMaster 로 upsert — PK Isin(요청값 스탬핑). rolling per-ISIN 1콜 결과(첫 행만).
    /// 신용등급 4사 포함. 빈결과면 no-op.
    /// </summary>
    public static async Task<bool> UpsertBondMasterAsync(IAppDbContext db, string isin, IReadOnlyList<BondMasterFields> rows, CancellationToken ct)
    {
        if (rows.Count == 0)
        {
            return false;
        }

        var fields = rows[0];
        var entity = await db.BondMaster.FirstOrDefaultAsync(c => c.Isin == isin, ct);

        if (entity is null)
        {
            await db.BondMaster.AddAsync(BondMaster.Create(isin, fields), ct);
        }
        else
        {
            entity.Update(fields);
        }

        await db.SaveChangesAsync(ct);
        return true;
    }

    /// <summary>
    /// getIntPayInfo 결과를 BondInterestPayment 로 upsert — PK Isin(요청값 스탬핑) 스냅샷 갱신. rolling per-ISIN 1콜(첫 행만).
    /// 빈결과면 no-op(대다수 채권이 이표 정보 미제공 가능 — 운영 로그 확인).
    /// </summary>
    public static async Task<bool> UpsertInterestPaymentAsync(IAppDbContext db, string isin, IReadOnlyList<SeibroIntPayParser.Row> rows, CancellationToken ct)
    {
        if (rows.Count == 0)
        {
            return false;
        }

        var row = rows[0];
        var entity = await db.BondInterestPayment.FirstOrDefaultAsync(c => c.Isin == isin, ct);

        if (entity is null)
        {
            await db.BondInterestPayment.AddAsync(BondInterestPayment.Create(isin, row.CouponRate, row.IntPayWayTpcd, row.IntPayCycleTerms, row.IntPayCycleTpcd, row.RvltSeverTpcd, row.AcrintPayYn, row.BankHolidayIntPaydayTpcd, row.IntPayTimsTpcd, row.BeforeDate, row.AfterDate), ct);
        }
        else
        {
            entity.Update(row.CouponRate, row.IntPayWayTpcd, row.IntPayCycleTerms, row.IntPayCycleTpcd, row.RvltSeverTpcd, row.AcrintPayYn, row.BankHolidayIntPaydayTpcd, row.IntPayTimsTpcd, row.BeforeDate, row.AfterDate);
        }

        await db.SaveChangesAsync(ct);
        return true;
    }

    /// <summary>
    /// getBondOptionXrcInfo 결과를 BondEarlyRedemption 로 window(조기상환일 begin~end) delete+insert 반영.
    /// 날짜 스윕(ERLY_RED_DT)이라 창 재구성으로 삭제분 반영. 같은 창 내 중복 (Isin, ErlyRedDt) 방어.
    /// </summary>
    public static async Task<(int Inserted, int Deleted)> ReplaceEarlyRedemptionWindowAsync(IAppDbContext db, DateOnly begin, DateOnly end, IReadOnlyList<SeibroBondOptionXrcParser.Row> rows, CancellationToken ct)
    {
        var deleted = await db.BondEarlyRedemption.Where(c => c.ErlyRedDt >= begin && c.ErlyRedDt <= end).ExecuteDeleteAsync(ct);

        var seen = new HashSet<(string, DateOnly)>();
        var inserted = 0;

        foreach (var row in rows)
        {
            if (row.ErlyRedDt < begin || row.ErlyRedDt > end)
            {
                continue; // 스윕 창 밖 — 다른 창이 담당
            }

            if (!seen.Add((row.Isin, row.ErlyRedDt)))
            {
                continue;
            }

            var created = BondEarlyRedemption.Create(row.Isin, row.KorSecnNm, row.XrcBeginDt, row.XrcExpryDt, row.ErlyRedDt, row.OptionTpcd, row.ApliIrate, row.ErlyRedamtVal, row.IntPayAmt, row.IssuRema, row.XrcRatio);
            await db.BondEarlyRedemption.AddAsync(created, ct);
            inserted++;
        }

        await db.SaveChangesAsync(ct);
        return (inserted, deleted);
    }

    /// <summary>
    /// getShortmIssuInfo 결과를 ShortTermIssuance 로 upsert — UQ (Isin). 응답에 없는 SECN_TPCD·ISSU_DT 는 요청값 스탬핑.
    /// rows 는 발행일×구분 스윕 per 콜 결과(다수 종목).
    /// </summary>
    public static async Task<(int Inserted, int Updated)> UpsertShortTermIssuancesAsync(IAppDbContext db, string secnTpcd, DateOnly issuDt, IReadOnlyList<SeibroShortmIssuParser.Row> rows, CancellationToken ct)
    {
        if (rows.Count == 0)
        {
            return (0, 0);
        }

        var isins = rows.Select(c => c.Isin).Distinct().ToList();
        var existing = await db.ShortTermIssuance.Where(c => isins.Contains(c.Isin)).ToListAsync(ct);
        var byKey = existing.ToDictionary(c => c.Isin);
        var seen = new HashSet<string>();
        var inserted = 0;
        var updated = 0;

        foreach (var row in rows)
        {
            if (!seen.Add(row.Isin))
            {
                continue;
            }

            if (byKey.TryGetValue(row.Isin, out var entity))
            {
                var was = entity.UpdatedAt;
                entity.Update(row.KorSecnNm, row.IssucoCustno, row.IssucoCustNm, secnTpcd, issuDt);
                if (entity.UpdatedAt != was)
                {
                    updated++;
                }
            }
            else
            {
                var created = ShortTermIssuance.Create(row.Isin, row.KorSecnNm, row.IssucoCustno, row.IssucoCustNm, secnTpcd, issuDt);
                await db.ShortTermIssuance.AddAsync(created, ct);
                byKey[row.Isin] = created;
                inserted++;
            }
        }

        await db.SaveChangesAsync(ct);
        return (inserted, updated);
    }

    /// <summary>getCDInfo 결과를 CdMaster 로 upsert — PK Isin(요청값 스탬핑). rolling per-ISIN 1콜(첫 행만). 빈결과면 no-op.</summary>
    public static async Task<bool> UpsertCdMasterAsync(IAppDbContext db, string isin, IReadOnlyList<SeibroCDParser.Row> rows, CancellationToken ct)
    {
        if (rows.Count == 0)
        {
            return false;
        }

        var row = rows[0];
        var entity = await db.CdMaster.FirstOrDefaultAsync(c => c.Isin == isin, ct);

        if (entity is null)
        {
            await db.CdMaster.AddAsync(CdMaster.Create(isin, row.IssucoCustno, row.KorSecnNm, row.IssuCurCd, row.FirstIssuAmt, row.IssuWhcd, row.FaceAmt, row.SaleAmt, row.DiscnRate, row.IntPayMannTpcd, row.IssuDt, row.XpirDt, row.EltscYn), ct);
        }
        else
        {
            entity.Update(row.IssucoCustno, row.KorSecnNm, row.IssuCurCd, row.FirstIssuAmt, row.IssuWhcd, row.FaceAmt, row.SaleAmt, row.DiscnRate, row.IntPayMannTpcd, row.IssuDt, row.XpirDt, row.EltscYn);
        }

        await db.SaveChangesAsync(ct);
        return true;
    }

    /// <summary>getCPInfo 결과를 CpMaster 로 upsert — PK Isin(요청값 스탬핑). rolling per-ISIN 1콜(첫 행만). 빈결과면 no-op.</summary>
    public static async Task<bool> UpsertCpMasterAsync(IAppDbContext db, string isin, IReadOnlyList<CpMasterFields> rows, CancellationToken ct)
    {
        if (rows.Count == 0)
        {
            return false;
        }

        var fields = rows[0];
        var entity = await db.CpMaster.FirstOrDefaultAsync(c => c.Isin == isin, ct);

        if (entity is null)
        {
            await db.CpMaster.AddAsync(CpMaster.Create(isin, fields), ct);
        }
        else
        {
            entity.Update(fields);
        }

        await db.SaveChangesAsync(ct);
        return true;
    }

    /// <summary>getESTBInfo 결과를 EstbMaster 로 upsert — PK Isin(요청값 스탬핑). rolling per-ISIN 1콜(첫 행만). 빈결과면 no-op.</summary>
    public static async Task<bool> UpsertEstbMasterAsync(IAppDbContext db, string isin, IReadOnlyList<EstbMasterFields> rows, CancellationToken ct)
    {
        if (rows.Count == 0)
        {
            return false;
        }

        var fields = rows[0];
        var entity = await db.EstbMaster.FirstOrDefaultAsync(c => c.Isin == isin, ct);

        if (entity is null)
        {
            await db.EstbMaster.AddAsync(EstbMaster.Create(isin, fields), ct);
        }
        else
        {
            entity.Update(fields);
        }

        await db.SaveChangesAsync(ct);
        return true;
    }
}