KrxEsgSecurityParser.cs 3.3 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576777879808182838485868788899091
  1. using System.Globalization;
  2. using System.Text.Json;
  3. namespace Infrastructure.StockData;
  4. /// <summary>
  5. /// KRX OpenAPI(data-dbg.krx.co.kr) ESG 증권상품(esg/esg_etp_info) 응답 파서 — 순수 C# (System.Text.Json).
  6. /// 응답 골격: { "OutBlock_1": [ { BAS_DD, ISU_ABBRV, TDD_CLSPRC, CMPPREVDD_PRC, FLUC_RT, LIST_SHRS, ACC_TRDVOL, ACC_TRDVAL }, ... ] }.
  7. /// 모든 값은 문자열이며 천단위 콤마 포함 가능. 등락률(FLUC_RT)은 소수 % 그대로 저장한다 ("-.43"/".06" 형태도 decimal 로 흡수, Bp 아님).
  8. /// ISU_CD 가 없고 종목명(ISU_ABBRV)만 제공되므로 종목명이 UQ 키의 일부가 된다. EtpDailyTrade(etp) 와 shape 이 달라 별도 파서.
  9. /// </summary>
  10. public static class KrxEsgSecurityParser
  11. {
  12. /// <summary>ESG 증권상품 1행 (등락률은 소수 % 그대로 — Bp 아님)</summary>
  13. public sealed record EsgSecurityRow(
  14. string Name,
  15. DateOnly TradeDate,
  16. decimal Close,
  17. decimal ChangeAmount,
  18. decimal ChangeRate,
  19. long ListedShares,
  20. long Volume,
  21. long TradeValue
  22. );
  23. public static IReadOnlyList<EsgSecurityRow> ParseDaily(string json)
  24. {
  25. using var doc = JsonDocument.Parse(json);
  26. var rows = new List<EsgSecurityRow>();
  27. if (!doc.RootElement.TryGetProperty("OutBlock_1", out var block) || block.ValueKind != JsonValueKind.Array)
  28. {
  29. return rows;
  30. }
  31. foreach (var item in block.EnumerateArray())
  32. {
  33. var name = GetString(item, "ISU_ABBRV");
  34. var tradeDate = ParseDate(GetString(item, "BAS_DD"));
  35. if (name.Length == 0 || tradeDate is null)
  36. {
  37. continue;
  38. }
  39. rows.Add(new EsgSecurityRow(
  40. name,
  41. tradeDate.Value,
  42. ParseDecimal(GetString(item, "TDD_CLSPRC")),
  43. ParseDecimal(GetString(item, "CMPPREVDD_PRC")),
  44. ParseDecimal(GetString(item, "FLUC_RT")),
  45. ParseLong(GetString(item, "LIST_SHRS")),
  46. ParseLong(GetString(item, "ACC_TRDVOL")),
  47. ParseLong(GetString(item, "ACC_TRDVAL"))
  48. ));
  49. }
  50. return rows;
  51. }
  52. private static string GetString(JsonElement element, string name)
  53. {
  54. if (!element.TryGetProperty(name, out var value))
  55. {
  56. return string.Empty;
  57. }
  58. return value.ValueKind switch
  59. {
  60. JsonValueKind.String => value.GetString()?.Trim() ?? string.Empty,
  61. JsonValueKind.Number => value.GetRawText(),
  62. _ => string.Empty
  63. };
  64. }
  65. private static DateOnly? ParseDate(string raw)
  66. {
  67. return DateOnly.TryParseExact(raw, "yyyyMMdd", CultureInfo.InvariantCulture, DateTimeStyles.None, out var date) ? date : null;
  68. }
  69. private static long ParseLong(string raw)
  70. {
  71. return long.TryParse(raw, NumberStyles.Integer | NumberStyles.AllowThousands, CultureInfo.InvariantCulture, out var value) ? value : 0L;
  72. }
  73. /// <summary>가격/전일비/등락률(%) 문자열 → decimal 그대로. "" 나 "-" 등 파싱 실패는 0. ".06"/"-.43" 형태도 흡수.</summary>
  74. private static decimal ParseDecimal(string raw)
  75. {
  76. return decimal.TryParse(raw, NumberStyles.Float | NumberStyles.AllowThousands, CultureInfo.InvariantCulture, out var value) ? value : 0m;
  77. }
  78. }