KrxWarrantSyncService.cs 6.8 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  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) — sw_bydd_trd(증권) + sr_bydd_trd(증서).
  13. /// 기본 18:25 KST 실행(장 마감 15:30 이후 확정, 증권상품 수집 18:20 뒤). 공용 KrxBackfill 로 최근 BackfillYears(기본 3)년치를
  14. /// endDate(직전 영업일)부터 과거로 훑으며 미적재일만 채운다. quota 보호를 위해 1회 실행당 BackfillMaxPerRun(기본 60)일까지만 fetch →
  15. /// 여러 날에 걸쳐 3년치를 메우고 이후엔 최신만 유지한다. 각 날짜는 2개 유형 엔드포인트를 모두 수집해 WarrantDailyTrade upsert
  16. /// (UQ = WarrantType+Code+TradeDate).
  17. /// 증서(sr)는 유상증자 시에만 상장되는 단기 상품이라 대부분의 영업일에 0건이 정상 — 두 엔드포인트 합계로 0 판정하고,
  18. /// existsForDate 도 유형 구분 없이 그날 한 건이라도 있으면 적재됨으로 간주(증서 0건 날의 영구 재수집 방지).
  19. /// ApiKey 미설정 시 로그만 남기고 skip (다른 KRX 배치와 동일 정책).
  20. /// </summary>
  21. internal sealed class KrxWarrantSyncService(
  22. IServiceScopeFactory scopeFactory,
  23. IHttpClientFactory httpClientFactory,
  24. IOptions<AppSettings> settings,
  25. ILogger<KrxWarrantSyncService> logger
  26. ) : DailyScheduledService(logger)
  27. {
  28. // (유형, 엔드포인트 경로) — 증권(sw)/증서(sr)
  29. private static readonly (WarrantType Type, string Path)[] Endpoints =
  30. [
  31. (WarrantType.SubscriptionWarrant, "/svc/apis/sto/sw_bydd_trd"),
  32. (WarrantType.SubscriptionRight, "/svc/apis/sto/sr_bydd_trd")
  33. ];
  34. protected override string JobName => "KrxWarrantSync";
  35. protected override TimeOnly TargetTime => ParseTime(settings.Value.KRXCoKr.WarrantSyncTime, new TimeOnly(18, 25));
  36. protected override int MaxRetryCount => 2;
  37. protected override TimeSpan RetryDelay => TimeSpan.FromHours(2);
  38. protected override async Task<bool> RunOnceAsync(DateOnly todayKst, CancellationToken ct)
  39. {
  40. var cfg = settings.Value.KRXCoKr;
  41. if (string.IsNullOrWhiteSpace(cfg.ApiKey))
  42. {
  43. Logger.LogWarning("[{Job}] KRXCoKr:ApiKey 미설정 — 수집 skip", JobName);
  44. return true;
  45. }
  46. using var scope = scopeFactory.CreateScope();
  47. var db = scope.ServiceProvider.GetRequiredService<IAppDbContext>();
  48. var client = httpClientFactory.CreateClient(KrxCoKrHttp.ClientName);
  49. var endDate = await MarketCalendar.GetPreviousBusinessDayAsync(db, todayKst.AddDays(1), ct);
  50. var years = cfg.BackfillYears > 0 ? cfg.BackfillYears : 3;
  51. var startDate = todayKst.AddYears(-years);
  52. // 백필 창 전체의 휴장일을 한 번에 로드 (KrxBackfill 은 주말은 자동 제외, 휴장일만 필요)
  53. var holidays = (await db.MarketHoliday.AsNoTracking()
  54. .Where(c => c.Date >= startDate && c.Date <= endDate)
  55. .Select(c => c.Date)
  56. .ToListAsync(ct)).ToHashSet();
  57. var maxPerRun = cfg.BackfillMaxPerRun > 0 ? cfg.BackfillMaxPerRun : 60;
  58. var fetched = await KrxBackfill.RunAsync(
  59. existsForDate: (day, token) => db.WarrantDailyTrade.AsNoTracking().AnyAsync(c => c.TradeDate == day, token),
  60. fetchAndUpsertForDate: (day, token) => FetchAndUpsertAsync(db, client, cfg.BaseUrl, cfg.ApiKey, day, token),
  61. startDate: startDate,
  62. endDate: endDate,
  63. holidays: holidays,
  64. maxPerRun: maxPerRun,
  65. delayMs: 300,
  66. ct: ct);
  67. Logger.LogInformation("[{Job}] 완료 — 창=[{Start}~{End}], 이번 실행 fetch={Fetched}일 (maxPerRun={Max})",
  68. JobName, startDate, endDate, fetched, maxPerRun);
  69. // 다른 KRX 일별 배치와 달리 endDate 미적재 재시도(false 반환)를 연결하지 않는다 —
  70. // 신주인수권은 상장 종목이 없는 날 0건이 정상이라(특히 증서 sr) "미적재 = 미반영"으로 판정할 수 없다.
  71. return true;
  72. }
  73. /// <summary>한 날짜에 대해 2개 유형 엔드포인트를 모두 수집하고 WarrantDailyTrade upsert.</summary>
  74. private async Task FetchAndUpsertAsync(IAppDbContext db, HttpClient client, string baseUrl, string apiKey, DateOnly day, CancellationToken ct)
  75. {
  76. var rows = new List<KrxWarrantParser.WarrantRow>();
  77. foreach (var (type, path) in Endpoints)
  78. {
  79. var url = $"{baseUrl.TrimEnd('/')}{path}?basDd={day:yyyyMMdd}";
  80. var json = await KrxCoKrHttp.GetStringWithRetryAsync(client, url, apiKey, Logger, ct);
  81. var parsed = KrxWarrantParser.ParseDaily(json, type);
  82. Logger.LogInformation("[{Job}] {Type} basDd={Day} rows={Rows}", JobName, type, day, parsed.Count);
  83. rows.AddRange(parsed);
  84. }
  85. if (rows.Count == 0)
  86. {
  87. Logger.LogInformation("[{Job}] basDd={Day} 신주인수권 미반영 (0건)", JobName, day);
  88. return;
  89. }
  90. var existing = await db.WarrantDailyTrade.Where(c => c.TradeDate == day).ToListAsync(ct);
  91. var existingByKey = existing.ToDictionary(c => (c.WarrantType, c.Code));
  92. var inserted = 0;
  93. var updated = 0;
  94. foreach (var row in rows)
  95. {
  96. if (existingByKey.TryGetValue((row.WarrantType, row.Code), out var trade))
  97. {
  98. trade.Update(row.Name, row.Market, row.Close, row.Open, row.High, row.Low, row.ChangeAmount, row.ChangeRate, row.Volume, row.TradeValue, row.MarketCap, row.ListedShares, row.TargetStockCode, row.TargetStockName, row.TargetStockPrice, row.ExercisePrice, row.ExerciseStartDate, row.ExerciseEndDate, row.IssuePrice, row.DelistDate);
  99. updated++;
  100. }
  101. else
  102. {
  103. var created = WarrantDailyTrade.Create(row.WarrantType, row.Code, row.Name, row.Market, row.TradeDate, row.Close, row.Open, row.High, row.Low, row.ChangeAmount, row.ChangeRate, row.Volume, row.TradeValue, row.MarketCap, row.ListedShares, row.TargetStockCode, row.TargetStockName, row.TargetStockPrice, row.ExercisePrice, row.ExerciseStartDate, row.ExerciseEndDate, row.IssuePrice, row.DelistDate);
  104. await db.WarrantDailyTrade.AddAsync(created, ct);
  105. existingByKey[(row.WarrantType, row.Code)] = created;
  106. inserted++;
  107. }
  108. }
  109. await db.SaveChangesAsync(ct);
  110. Logger.LogInformation("[{Job}] basDd={Day} 적재 — rows={Rows}, inserted={Inserted}, updated={Updated}",
  111. JobName, day, rows.Count, inserted, updated);
  112. }
  113. }