ANTOOZA-BACKEND/Infrastructure/StockData/KrxBondParser.cs

using System.Globalization;
using System.Text.Json;
using Domain.Entities.Stocks.ValueObject;

namespace Infrastructure.StockData;

/// <summary>
/// KRX OpenAPI(data-dbg.krx.co.kr) 채권(국채전문유통/일반채권/소액채권) 일별매매 응답 파서 — 순수 C# (System.Text.Json).
/// 응답 골격: { "OutBlock_1": [ { ...string values }, ... ] }. 모든 값은 문자열, 천단위 콤마 가능, 결측치는 "" 또는 "-".
/// 채권은 주식/증권상품과 필드가 다르다:
///  - 가격: CLSPRC/OPNPRC/HGPRC/LWPRC (주식의 TDD_* 아님), 전일대비 CMPPREVDD_PRC(빈값 가능). 등락률·시가총액·상장주식수 미제공.
///  - 수익률(YD): CLSPRC_YD(만기수익률=종가수익률)/OPNPRC_YD/HGPRC_YD/LWPRC_YD — nullable(미체결 시 "").
///  - 국채전문(KtsGovt)만: BND_EXP_TP_NM(만기년수) / GOVBND_ISU_TP_NM(종목구분). 일반/소액은 응답에 없음 → null.
/// 단축코드(ISU_CD)는 12자리 ISIN(예: KR103503GE96) — 6자리 정규화 없이 원문 유지. 시장은 호출 엔드포인트(bondMarket)로 결정.
/// </summary>
public static class KrxBondParser
{
    /// <summary>채권 일별매매 1행 (수익률은 % 그대로, 미체결은 null)</summary>
    public sealed record BondRow(
        BondMarket BondMarket,
        string Code,
        string Name,
        DateOnly TradeDate,
        decimal Close,
        decimal Open,
        decimal High,
        decimal Low,
        decimal ChangeAmount,
        decimal? YieldToMaturity,
        decimal? OpenYield,
        decimal? HighYield,
        decimal? LowYield,
        long Volume,
        long TradeValue,
        string? MaturityYears,
        string? IssueType
    );

    /// <summary>kts/bnd/smb_bydd_trd 파싱. bondMarket 은 호출 엔드포인트로 결정, 국채전문 전용 필드는 조건 분기.</summary>
    public static IReadOnlyList<BondRow> ParseDaily(string json, BondMarket bondMarket)
    {
        using var doc = JsonDocument.Parse(json);
        var rows = new List<BondRow>();

        if (!doc.RootElement.TryGetProperty("OutBlock_1", out var block) || block.ValueKind != JsonValueKind.Array)
        {
            return rows;
        }

        foreach (var item in block.EnumerateArray())
        {
            var code = ToNull(GetString(item, "ISU_CD"));
            var name = GetString(item, "ISU_NM");
            var tradeDate = ParseDate(GetString(item, "BAS_DD"));

            if (code is null || name.Length == 0 || tradeDate is null)
            {
                continue;
            }

            string? maturityYears = null;
            string? issueType = null;

            if (bondMarket == BondMarket.KtsGovt)
            {
                maturityYears = ToNull(GetString(item, "BND_EXP_TP_NM"));
                issueType = ToNull(GetString(item, "GOVBND_ISU_TP_NM"));
            }

            rows.Add(new BondRow(
                bondMarket,
                code,
                name,
                tradeDate.Value,
                ParseDecimal(GetString(item, "CLSPRC")),
                ParseDecimal(GetString(item, "OPNPRC")),
                ParseDecimal(GetString(item, "HGPRC")),
                ParseDecimal(GetString(item, "LWPRC")),
                ParseDecimal(GetString(item, "CMPPREVDD_PRC")),
                ParseNullableDecimal(GetString(item, "CLSPRC_YD")),
                ParseNullableDecimal(GetString(item, "OPNPRC_YD")),
                ParseNullableDecimal(GetString(item, "HGPRC_YD")),
                ParseNullableDecimal(GetString(item, "LWPRC_YD")),
                ParseLong(GetString(item, "ACC_TRDVOL")),
                ParseLong(GetString(item, "ACC_TRDVAL")),
                maturityYears,
                issueType
            ));
        }

        return rows;
    }

    private static string GetString(JsonElement element, string name)
    {
        if (!element.TryGetProperty(name, out var value))
        {
            return string.Empty;
        }

        return value.ValueKind switch
        {
            JsonValueKind.String => value.GetString()?.Trim() ?? string.Empty,
            JsonValueKind.Number => value.GetRawText(),
            _ => string.Empty
        };
    }

    /// <summary>빈 문자열/"-" 은 null, 나머지는 trim 값</summary>
    private static string? ToNull(string raw)
    {
        return raw.Length == 0 || raw == "-" ? null : raw;
    }

    private static DateOnly? ParseDate(string raw)
    {
        return DateOnly.TryParseExact(raw, "yyyyMMdd", CultureInfo.InvariantCulture, DateTimeStyles.None, out var date) ? date : null;
    }

    private static long ParseLong(string raw)
    {
        return long.TryParse(raw, NumberStyles.Integer | NumberStyles.AllowThousands, CultureInfo.InvariantCulture, out var value) ? value : 0L;
    }

    /// <summary>가격/전일대비 문자열 → decimal 그대로. "" 나 "-" 등 파싱 실패는 0.</summary>
    private static decimal ParseDecimal(string raw)
    {
        return decimal.TryParse(raw, NumberStyles.Float | NumberStyles.AllowThousands, CultureInfo.InvariantCulture, out var value) ? value : 0m;
    }

    /// <summary>수익률(YD) — "" 나 "-" 등 파싱 실패는 null (0 과 구분, 미체결은 값 없음)</summary>
    private static decimal? ParseNullableDecimal(string raw)
    {
        return decimal.TryParse(raw, NumberStyles.Float | NumberStyles.AllowThousands, CultureInfo.InvariantCulture, out var value) ? value : null;
    }
}