WorldIndexSyncService.cs 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106
  1. using Application.Abstractions.Data;
  2. using Domain.Entities.Stocks;
  3. using Microsoft.EntityFrameworkCore;
  4. using Microsoft.Extensions.DependencyInjection;
  5. using Microsoft.Extensions.Logging;
  6. using Microsoft.Extensions.Options;
  7. using SharedKernel;
  8. namespace Infrastructure.StockData;
  9. /// <summary>
  10. /// 세계 주요국 증시지수 스냅샷 수집 — Stooq 배치 라이트 시세(/q/l/?f=sd2t2ohlc)를 하루 1회 조회해 심볼당 최신 종가를 upsert.
  11. /// config(WorldIndex:Items) 심볼을 한 요청으로 모아 조회하고, 응답 CSV 를 파싱해 WorldIndexSnapshot 에 반영한다(전일 대비는 직전 저장 종가로 산출).
  12. /// 국내(코스피)는 이 배치가 아니라 GetWorldIndices Handler 가 IndexDailyPrice 실데이터에서 병합한다.
  13. /// 기본 07:00 KST 실행(미국장 마감 이후 확정치 확보). Items 비었거나 전량 실패 시 로그만 남기고 skip/재시도.
  14. /// </summary>
  15. internal sealed class WorldIndexSyncService(
  16. IServiceScopeFactory scopeFactory,
  17. IHttpClientFactory httpClientFactory,
  18. IOptions<AppSettings> settings,
  19. ILogger<WorldIndexSyncService> logger
  20. ) : DailyScheduledService(logger)
  21. {
  22. protected override string JobName => "WorldIndexSync";
  23. protected override TimeOnly TargetTime => ParseTime(settings.Value.WorldIndex.SyncTime, new TimeOnly(7, 0));
  24. protected override int MaxRetryCount => 2;
  25. protected override TimeSpan RetryDelay => TimeSpan.FromMinutes(settings.Value.WorldIndex.RetryDelayMinutes > 0 ? settings.Value.WorldIndex.RetryDelayMinutes : 60);
  26. protected override async Task<bool> RunOnceAsync(DateOnly todayKst, CancellationToken ct)
  27. {
  28. var cfg = settings.Value.WorldIndex;
  29. var items = cfg.Items.Where(c => !string.IsNullOrWhiteSpace(c.Symbol)).ToList();
  30. if (items.Count == 0)
  31. {
  32. Logger.LogWarning("[{Job}] WorldIndex:Items 미설정 — 수집 skip", JobName);
  33. return true;
  34. }
  35. using var scope = scopeFactory.CreateScope();
  36. var db = scope.ServiceProvider.GetRequiredService<IAppDbContext>();
  37. var client = httpClientFactory.CreateClient(StooqHttp.ClientName);
  38. // 심볼별 config 매핑 (소문자 정규화 — 응답 심볼과 대소문자 무시 매칭, 중복 심볼은 첫 항목)
  39. var bySymbol = items
  40. .GroupBy(c => c.Symbol.Trim().ToLowerInvariant())
  41. .ToDictionary(g => g.Key, g => g.First());
  42. var symbolList = string.Join(",", bySymbol.Keys);
  43. var url = $"{cfg.BaseUrl.TrimEnd('/')}/q/l/?s={symbolList}&f=sd2t2ohlc&h&e=csv";
  44. string csv;
  45. try
  46. {
  47. csv = await StooqHttp.GetStringWithRetryAsync(client, url, Logger, ct);
  48. }
  49. catch (Exception ex) when (ex is not OperationCanceledException)
  50. {
  51. Logger.LogError(ex, "[{Job}] Stooq 호출 실패 — 재시도 대상", JobName);
  52. return false;
  53. }
  54. var quotes = WorldIndexCsvParser.Parse(csv);
  55. Logger.LogInformation("[{Job}] 응답 파싱 rows={Rows} (요청 {Count} 심볼)", JobName, quotes.Count, bySymbol.Count);
  56. if (quotes.Count == 0)
  57. {
  58. Logger.LogWarning("[{Job}] 파싱 0건 — 재시도 대상", JobName);
  59. return false;
  60. }
  61. var existing = await db.WorldIndexSnapshot.ToListAsync(ct);
  62. var existingBySymbol = existing.ToDictionary(c => c.Symbol, StringComparer.OrdinalIgnoreCase);
  63. var inserted = 0;
  64. var updated = 0;
  65. foreach (var q in quotes)
  66. {
  67. if (!bySymbol.TryGetValue(q.Symbol, out var meta))
  68. {
  69. continue; // 요청하지 않은 심볼 방어
  70. }
  71. if (existingBySymbol.TryGetValue(q.Symbol, out var snap))
  72. {
  73. snap.UpdateMeta(meta.Name, meta.CountryCode, meta.ExchangeName);
  74. snap.Apply(q.TradeDate, q.Close, q.Open, q.High, q.Low);
  75. updated++;
  76. }
  77. else
  78. {
  79. var created = WorldIndexSnapshot.Create(q.Symbol, meta.Name, meta.CountryCode, meta.ExchangeName, q.TradeDate, q.Close, q.Open, q.High, q.Low);
  80. await db.WorldIndexSnapshot.AddAsync(created, ct);
  81. existingBySymbol[q.Symbol] = created;
  82. inserted++;
  83. }
  84. }
  85. await db.SaveChangesAsync(ct);
  86. Logger.LogInformation("[{Job}] 완료 — inserted={Inserted}, updated={Updated}", JobName, inserted, updated);
  87. return true;
  88. }
  89. }