KrxBondSyncService.cs 6.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132
  1. using Application.Abstractions.Data;
  2. using Application.Helpers;
  3. using Domain.Entities.Stocks;
  4. using Domain.Entities.Stocks.ValueObject;
  5. using Microsoft.EntityFrameworkCore;
  6. using Microsoft.Extensions.DependencyInjection;
  7. using Microsoft.Extensions.Logging;
  8. using Microsoft.Extensions.Options;
  9. using SharedKernel;
  10. namespace Infrastructure.StockData;
  11. /// <summary>
  12. /// 채권(국채전문유통/일반채권/소액채권) 일별매매 수집 (KRX OpenAPI) — kts_bydd_trd + bnd_bydd_trd + smb_bydd_trd.
  13. /// 기본 18:40 KST 실행(장 마감 15:30 이후 확정, 신주인수권 수집 18:25 뒤). 공용 KrxBackfill 로 최근 BackfillYears(기본 3)년치를
  14. /// endDate(직전 영업일)부터 과거로 훑으며 미적재일만 채운다. quota 보호를 위해 1회 실행당 BackfillMaxPerRun(기본 60)일까지만 fetch →
  15. /// 여러 날에 걸쳐 3년치를 메우고 이후엔 최신만 유지한다. 각 날짜는 3개 시장 엔드포인트를 모두 수집해 BondDailyTrade upsert
  16. /// (UQ = BondMarket+Code+TradeDate). ApiKey 미설정 시 로그만 남기고 skip (다른 KRX 배치와 동일 정책).
  17. /// </summary>
  18. internal sealed class KrxBondSyncService(
  19. IServiceScopeFactory scopeFactory,
  20. IHttpClientFactory httpClientFactory,
  21. IOptions<AppSettings> settings,
  22. ILogger<KrxBondSyncService> logger
  23. ) : DailyScheduledService(logger)
  24. {
  25. // (시장, 엔드포인트 경로) — 국채전문(kts)/일반(bnd)/소액(smb)
  26. private static readonly (BondMarket Market, string Path)[] Endpoints =
  27. [
  28. (BondMarket.KtsGovt, "/svc/apis/bon/kts_bydd_trd"),
  29. (BondMarket.General, "/svc/apis/bon/bnd_bydd_trd"),
  30. (BondMarket.Small, "/svc/apis/bon/smb_bydd_trd")
  31. ];
  32. protected override string JobName => "KrxBondSync";
  33. protected override TimeOnly TargetTime => ParseTime(settings.Value.KRXCoKr.BondSyncTime, new TimeOnly(18, 40));
  34. protected override int MaxRetryCount => 2;
  35. protected override TimeSpan RetryDelay => TimeSpan.FromHours(2);
  36. protected override async Task<bool> RunOnceAsync(DateOnly todayKst, CancellationToken ct)
  37. {
  38. var cfg = settings.Value.KRXCoKr;
  39. if (string.IsNullOrWhiteSpace(cfg.ApiKey))
  40. {
  41. Logger.LogWarning("[{Job}] KRXCoKr:ApiKey 미설정 — 수집 skip", JobName);
  42. return true;
  43. }
  44. using var scope = scopeFactory.CreateScope();
  45. var db = scope.ServiceProvider.GetRequiredService<IAppDbContext>();
  46. var client = httpClientFactory.CreateClient(KrxCoKrHttp.ClientName);
  47. var endDate = await MarketCalendar.GetPreviousBusinessDayAsync(db, todayKst.AddDays(1), ct);
  48. var years = cfg.BackfillYears > 0 ? cfg.BackfillYears : 3;
  49. var startDate = todayKst.AddYears(-years);
  50. // 백필 창 전체의 휴장일을 한 번에 로드 (KrxBackfill 은 주말은 자동 제외, 휴장일만 필요)
  51. var holidays = (await db.MarketHoliday.AsNoTracking()
  52. .Where(c => c.Date >= startDate && c.Date <= endDate)
  53. .Select(c => c.Date)
  54. .ToListAsync(ct)).ToHashSet();
  55. var maxPerRun = cfg.BackfillMaxPerRun > 0 ? cfg.BackfillMaxPerRun : 60;
  56. var fetched = await KrxBackfill.RunAsync(
  57. existsForDate: (day, token) => db.BondDailyTrade.AsNoTracking().AnyAsync(c => c.TradeDate == day, token),
  58. fetchAndUpsertForDate: (day, token) => FetchAndUpsertAsync(db, client, cfg.BaseUrl, cfg.ApiKey, day, token),
  59. startDate: startDate,
  60. endDate: endDate,
  61. holidays: holidays,
  62. maxPerRun: maxPerRun,
  63. delayMs: 300,
  64. ct: ct);
  65. Logger.LogInformation("[{Job}] 완료 — 창=[{Start}~{End}], 이번 실행 fetch={Fetched}일 (maxPerRun={Max})",
  66. JobName, startDate, endDate, fetched, maxPerRun);
  67. // fetch 가 0 이어도(이미 최신까지 적재됨) 정상 완료 — 재시도 불필요
  68. return true;
  69. }
  70. /// <summary>한 날짜에 대해 3개 시장 엔드포인트를 모두 수집하고 BondDailyTrade upsert.</summary>
  71. private async Task FetchAndUpsertAsync(IAppDbContext db, HttpClient client, string baseUrl, string apiKey, DateOnly day, CancellationToken ct)
  72. {
  73. var rows = new List<KrxBondParser.BondRow>();
  74. foreach (var (market, path) in Endpoints)
  75. {
  76. var url = $"{baseUrl.TrimEnd('/')}{path}?basDd={day:yyyyMMdd}";
  77. var json = await KrxCoKrHttp.GetStringWithRetryAsync(client, url, apiKey, Logger, ct);
  78. var parsed = KrxBondParser.ParseDaily(json, market);
  79. Logger.LogInformation("[{Job}] {Market} basDd={Day} rows={Rows}", JobName, market, day, parsed.Count);
  80. rows.AddRange(parsed);
  81. }
  82. if (rows.Count == 0)
  83. {
  84. Logger.LogInformation("[{Job}] basDd={Day} 채권 미반영 (0건)", JobName, day);
  85. return;
  86. }
  87. var existing = await db.BondDailyTrade.Where(c => c.TradeDate == day).ToListAsync(ct);
  88. var existingByKey = existing.ToDictionary(c => (c.BondMarket, c.Code));
  89. var inserted = 0;
  90. var updated = 0;
  91. foreach (var row in rows)
  92. {
  93. if (existingByKey.TryGetValue((row.BondMarket, row.Code), out var trade))
  94. {
  95. trade.Update(row.Name, row.Close, row.Open, row.High, row.Low, row.ChangeAmount, row.YieldToMaturity, row.OpenYield, row.HighYield, row.LowYield, row.Volume, row.TradeValue, row.MaturityYears, row.IssueType);
  96. updated++;
  97. }
  98. else
  99. {
  100. var created = BondDailyTrade.Create(row.BondMarket, row.Code, row.Name, row.TradeDate, row.Close, row.Open, row.High, row.Low, row.ChangeAmount, row.YieldToMaturity, row.OpenYield, row.HighYield, row.LowYield, row.Volume, row.TradeValue, row.MaturityYears, row.IssueType);
  101. await db.BondDailyTrade.AddAsync(created, ct);
  102. existingByKey[(row.BondMarket, row.Code)] = created;
  103. inserted++;
  104. }
  105. }
  106. await db.SaveChangesAsync(ct);
  107. Logger.LogInformation("[{Job}] basDd={Day} 적재 — rows={Rows}, inserted={Inserted}, updated={Updated}",
  108. JobName, day, rows.Count, inserted, updated);
  109. }
  110. }