| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113 |
- using Application.Abstractions.Data;
- using Domain.Entities.Stocks;
- using Domain.Entities.Stocks.ValueObject;
- using Microsoft.EntityFrameworkCore;
- using Microsoft.Extensions.DependencyInjection;
- using Microsoft.Extensions.Logging;
- using Microsoft.Extensions.Options;
- using SharedKernel;
- namespace Infrastructure.StockData;
- /// <summary>
- /// 일별 마감 시세 수집 (KRX OpenAPI) — stk_bydd_trd(KOSPI) + ksq_bydd_trd(KOSDAQ) + knx_bydd_trd(KONEX) 일별매매정보.
- /// 기본 18:10 KST 실행(장 마감 15:30 이후 확정), basDd=직전 영업일 전량 수집 →
- /// StockDailyPrice upsert (StockID+TradingDate) + Stock.UpdateLastPrice denorm(최근 종가/등락률/시총) 갱신.
- /// 마스터 미동기화 코드는 skip (다음 마스터 동기화 후 자연 반영). 미반영(0건)이면 2시간 간격 2회 재시도.
- /// ApiKey 미설정 시 로그만 남기고 skip (data.go.kr 배치와 동일 정책).
- /// KONEX 응답 필드셋은 KOSPI/KOSDAQ 과 동일(ISU_CD/TDD_*/ACC_*/MKTCAP/LIST_SHRS) — KrxStockParser 재사용.
- /// </summary>
- internal sealed class KrxDailyPriceSyncService(
- IServiceScopeFactory scopeFactory,
- IHttpClientFactory httpClientFactory,
- IOptions<AppSettings> settings,
- ILogger<KrxDailyPriceSyncService> logger
- ) : DailyScheduledService(logger)
- {
- // (시장, 엔드포인트 경로) — KOSPI/KOSDAQ/KONEX. 세 시장 모두 StockDailyPrice 에 동일 스키마로 적재된다.
- private static readonly (StockMarket Market, string Path)[] Endpoints =
- [
- (StockMarket.KOSPI, "/svc/apis/sto/stk_bydd_trd"),
- (StockMarket.KOSDAQ, "/svc/apis/sto/ksq_bydd_trd"),
- (StockMarket.KONEX, "/svc/apis/sto/knx_bydd_trd")
- ];
- protected override string JobName => "KrxDailyPriceSync";
- protected override TimeOnly TargetTime => ParseTime(settings.Value.KRXCoKr.StockSyncTime, new TimeOnly(18, 10));
- protected override int MaxRetryCount => 2;
- protected override TimeSpan RetryDelay => TimeSpan.FromHours(2);
- protected override async Task<bool> RunOnceAsync(DateOnly todayKst, CancellationToken ct)
- {
- var cfg = settings.Value.KRXCoKr;
- if (string.IsNullOrWhiteSpace(cfg.ApiKey))
- {
- Logger.LogWarning("[{Job}] KRXCoKr:ApiKey 미설정 — 수집 skip", JobName);
- return true;
- }
- using var scope = scopeFactory.CreateScope();
- var db = scope.ServiceProvider.GetRequiredService<IAppDbContext>();
- var client = httpClientFactory.CreateClient(KrxCoKrHttp.ClientName);
- var targetDate = await MarketCalendar.GetPreviousBusinessDayAsync(db, todayKst.AddDays(1), ct);
- var rows = new List<KrxStockParser.DailyPriceItem>();
- foreach (var (market, path) in Endpoints)
- {
- var url = $"{cfg.BaseUrl.TrimEnd('/')}{path}?basDd={targetDate:yyyyMMdd}";
- var json = await KrxCoKrHttp.GetStringWithRetryAsync(client, url, cfg.ApiKey, Logger, ct);
- var parsed = KrxStockParser.ParseDailyPrices(json, market);
- Logger.LogInformation("[{Job}] {Market} basDd={TargetDate} rows={Rows}", JobName, market, targetDate, parsed.Count);
- rows.AddRange(parsed);
- }
- if (rows.Count == 0)
- {
- Logger.LogInformation("[{Job}] basDd={TargetDate} 시세 미반영 (0건)", JobName, targetDate);
- return false;
- }
- var stockByCode = await db.Stock.ToDictionaryAsync(c => c.Code, ct);
- var existingByStockID = await db.StockDailyPrice.Where(c => c.TradingDate == targetDate).ToDictionaryAsync(c => c.StockID, ct);
- var inserted = 0;
- var updated = 0;
- var unknown = 0;
- foreach (var row in rows)
- {
- if (!stockByCode.TryGetValue(row.Code, out var stock))
- {
- // 마스터 미동기화 종목 — 다음 마스터 동기화 후 자연 반영 (DailyPriceSyncService 와 동일 정책)
- unknown++;
- continue;
- }
- if (existingByStockID.TryGetValue(stock.ID, out var price))
- {
- price.Update(row.Open, row.High, row.Low, row.Close, row.Volume, row.TradingValue, row.ChangeAmount, row.ChangeRate, row.MarketCap, row.ListedShares);
- updated++;
- }
- else
- {
- 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);
- await db.StockDailyPrice.AddAsync(created, ct);
- existingByStockID[stock.ID] = created;
- inserted++;
- }
- stock.UpdateLastPrice(row.TradingDate, row.Close, row.ChangeRate, row.MarketCap);
- }
- await db.SaveChangesAsync(ct);
- Logger.LogInformation("[{Job}] 완료 — basDd={TargetDate}, rows={Rows}, inserted={Inserted}, updated={Updated}, unknownCode={Unknown}",
- JobName, targetDate, rows.Count, inserted, updated, unknown);
- return true;
- }
- }
|