KrxDailyPriceSyncService.cs 4.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111
  1. using Application.Abstractions.Data;
  2. using Domain.Entities.Stocks;
  3. using Domain.Entities.Stocks.ValueObject;
  4. using Microsoft.EntityFrameworkCore;
  5. using Microsoft.Extensions.DependencyInjection;
  6. using Microsoft.Extensions.Logging;
  7. using Microsoft.Extensions.Options;
  8. using SharedKernel;
  9. namespace Infrastructure.StockData;
  10. /// <summary>
  11. /// 일별 마감 시세 수집 (KRX OpenAPI) — stk_bydd_trd(KOSPI) + ksq_bydd_trd(KOSDAQ) 일별매매정보.
  12. /// 기본 18:10 KST 실행(장 마감 15:30 이후 확정), basDd=직전 영업일 전량 수집 →
  13. /// StockDailyPrice upsert (StockID+TradingDate) + Stock.UpdateLastPrice denorm(최근 종가/등락률/시총) 갱신.
  14. /// 마스터 미동기화 코드는 skip (다음 마스터 동기화 후 자연 반영). 미반영(0건)이면 2시간 간격 2회 재시도.
  15. /// ApiKey 미설정 시 로그만 남기고 skip (data.go.kr 배치와 동일 정책).
  16. /// </summary>
  17. internal sealed class KrxDailyPriceSyncService(
  18. IServiceScopeFactory scopeFactory,
  19. IHttpClientFactory httpClientFactory,
  20. IOptions<AppSettings> settings,
  21. ILogger<KrxDailyPriceSyncService> logger
  22. ) : DailyScheduledService(logger)
  23. {
  24. // (시장, 엔드포인트 경로) — KOSPI/KOSDAQ. KONEX(knx_bydd_trd)·ETF/채권/파생 등은 D1 범위 밖.
  25. private static readonly (StockMarket Market, string Path)[] Endpoints =
  26. [
  27. (StockMarket.KOSPI, "/svc/apis/sto/stk_bydd_trd"),
  28. (StockMarket.KOSDAQ, "/svc/apis/sto/ksq_bydd_trd")
  29. ];
  30. protected override string JobName => "KrxDailyPriceSync";
  31. protected override TimeOnly TargetTime => ParseTime(settings.Value.KRXCoKr.StockSyncTime, new TimeOnly(18, 10));
  32. protected override int MaxRetryCount => 2;
  33. protected override TimeSpan RetryDelay => TimeSpan.FromHours(2);
  34. protected override async Task<bool> RunOnceAsync(DateOnly todayKst, CancellationToken ct)
  35. {
  36. var cfg = settings.Value.KRXCoKr;
  37. if (string.IsNullOrWhiteSpace(cfg.ApiKey))
  38. {
  39. Logger.LogWarning("[{Job}] KRXCoKr:ApiKey 미설정 — 수집 skip", JobName);
  40. return true;
  41. }
  42. using var scope = scopeFactory.CreateScope();
  43. var db = scope.ServiceProvider.GetRequiredService<IAppDbContext>();
  44. var client = httpClientFactory.CreateClient(KrxCoKrHttp.ClientName);
  45. var targetDate = await MarketCalendar.GetPreviousBusinessDayAsync(db, todayKst.AddDays(1), ct);
  46. var rows = new List<KrxStockParser.DailyPriceItem>();
  47. foreach (var (market, path) in Endpoints)
  48. {
  49. var url = $"{cfg.BaseUrl.TrimEnd('/')}{path}?basDd={targetDate:yyyyMMdd}";
  50. var json = await KrxCoKrHttp.GetStringWithRetryAsync(client, url, cfg.ApiKey, Logger, ct);
  51. var parsed = KrxStockParser.ParseDailyPrices(json, market);
  52. Logger.LogInformation("[{Job}] {Market} basDd={TargetDate} rows={Rows}", JobName, market, targetDate, parsed.Count);
  53. rows.AddRange(parsed);
  54. }
  55. if (rows.Count == 0)
  56. {
  57. Logger.LogInformation("[{Job}] basDd={TargetDate} 시세 미반영 (0건)", JobName, targetDate);
  58. return false;
  59. }
  60. var stockByCode = await db.Stock.ToDictionaryAsync(c => c.Code, ct);
  61. var existingByStockID = await db.StockDailyPrice.Where(c => c.TradingDate == targetDate).ToDictionaryAsync(c => c.StockID, ct);
  62. var inserted = 0;
  63. var updated = 0;
  64. var unknown = 0;
  65. foreach (var row in rows)
  66. {
  67. if (!stockByCode.TryGetValue(row.Code, out var stock))
  68. {
  69. // 마스터 미동기화 종목 — 다음 마스터 동기화 후 자연 반영 (DailyPriceSyncService 와 동일 정책)
  70. unknown++;
  71. continue;
  72. }
  73. if (existingByStockID.TryGetValue(stock.ID, out var price))
  74. {
  75. price.Update(row.Open, row.High, row.Low, row.Close, row.Volume, row.TradingValue, row.ChangeAmount, row.ChangeRate, row.MarketCap, row.ListedShares);
  76. updated++;
  77. }
  78. else
  79. {
  80. var created = StockDailyPrice.Create(stock.ID, row.TradingDate, row.Open, row.High, row.Low, row.Close, row.Volume, row.TradingValue, row.ChangeAmount, row.ChangeRate, row.MarketCap, row.ListedShares);
  81. await db.StockDailyPrice.AddAsync(created, ct);
  82. existingByStockID[stock.ID] = created;
  83. inserted++;
  84. }
  85. stock.UpdateLastPrice(row.TradingDate, row.Close, row.ChangeRate, row.MarketCap);
  86. }
  87. await db.SaveChangesAsync(ct);
  88. Logger.LogInformation("[{Job}] 완료 — basDd={TargetDate}, rows={Rows}, inserted={Inserted}, updated={Updated}, unknownCode={Unknown}",
  89. JobName, targetDate, rows.Count, inserted, updated, unknown);
  90. return true;
  91. }
  92. }