KrxDailyPriceSyncService.cs 5.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113
  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) + knx_bydd_trd(KONEX) 일별매매정보.
  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. /// KONEX 응답 필드셋은 KOSPI/KOSDAQ 과 동일(ISU_CD/TDD_*/ACC_*/MKTCAP/LIST_SHRS) — KrxStockParser 재사용.
  17. /// </summary>
  18. internal sealed class KrxDailyPriceSyncService(
  19. IServiceScopeFactory scopeFactory,
  20. IHttpClientFactory httpClientFactory,
  21. IOptions<AppSettings> settings,
  22. ILogger<KrxDailyPriceSyncService> logger
  23. ) : DailyScheduledService(logger)
  24. {
  25. // (시장, 엔드포인트 경로) — KOSPI/KOSDAQ/KONEX. 세 시장 모두 StockDailyPrice 에 동일 스키마로 적재된다.
  26. private static readonly (StockMarket Market, string Path)[] Endpoints =
  27. [
  28. (StockMarket.KOSPI, "/svc/apis/sto/stk_bydd_trd"),
  29. (StockMarket.KOSDAQ, "/svc/apis/sto/ksq_bydd_trd"),
  30. (StockMarket.KONEX, "/svc/apis/sto/knx_bydd_trd")
  31. ];
  32. protected override string JobName => "KrxDailyPriceSync";
  33. protected override TimeOnly TargetTime => ParseTime(settings.Value.KRXCoKr.StockSyncTime, new TimeOnly(18, 10));
  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 targetDate = await MarketCalendar.GetPreviousBusinessDayAsync(db, todayKst.AddDays(1), ct);
  48. var rows = new List<KrxStockParser.DailyPriceItem>();
  49. foreach (var (market, path) in Endpoints)
  50. {
  51. var url = $"{cfg.BaseUrl.TrimEnd('/')}{path}?basDd={targetDate:yyyyMMdd}";
  52. var json = await KrxCoKrHttp.GetStringWithRetryAsync(client, url, cfg.ApiKey, Logger, ct);
  53. var parsed = KrxStockParser.ParseDailyPrices(json, market);
  54. Logger.LogInformation("[{Job}] {Market} basDd={TargetDate} rows={Rows}", JobName, market, targetDate, parsed.Count);
  55. rows.AddRange(parsed);
  56. }
  57. if (rows.Count == 0)
  58. {
  59. Logger.LogInformation("[{Job}] basDd={TargetDate} 시세 미반영 (0건)", JobName, targetDate);
  60. return false;
  61. }
  62. var stockByCode = await db.Stock.ToDictionaryAsync(c => c.Code, ct);
  63. var existingByStockID = await db.StockDailyPrice.Where(c => c.TradingDate == targetDate).ToDictionaryAsync(c => c.StockID, ct);
  64. var inserted = 0;
  65. var updated = 0;
  66. var unknown = 0;
  67. foreach (var row in rows)
  68. {
  69. if (!stockByCode.TryGetValue(row.Code, out var stock))
  70. {
  71. // 마스터 미동기화 종목 — 다음 마스터 동기화 후 자연 반영 (DailyPriceSyncService 와 동일 정책)
  72. unknown++;
  73. continue;
  74. }
  75. if (existingByStockID.TryGetValue(stock.ID, out var price))
  76. {
  77. price.Update(row.Open, row.High, row.Low, row.Close, row.Volume, row.TradingValue, row.ChangeAmount, row.ChangeRate, row.MarketCap, row.ListedShares);
  78. updated++;
  79. }
  80. else
  81. {
  82. 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);
  83. await db.StockDailyPrice.AddAsync(created, ct);
  84. existingByStockID[stock.ID] = created;
  85. inserted++;
  86. }
  87. stock.UpdateLastPrice(row.TradingDate, row.Close, row.ChangeRate, row.MarketCap);
  88. }
  89. await db.SaveChangesAsync(ct);
  90. Logger.LogInformation("[{Job}] 완료 — basDd={TargetDate}, rows={Rows}, inserted={Inserted}, updated={Updated}, unknownCode={Unknown}",
  91. JobName, targetDate, rows.Count, inserted, updated, unknown);
  92. return true;
  93. }
  94. }