Merge pull request #95 from SynergyX-AI-Pattern/feat/#94_collect_past_15m_data

[FEAT] 과거 15분봉 수집 로직 추가 #94

Author: eldeoddt

src/main/java/com/synergyx/trading/controller/KisTestController.java

@@ -7,12 +7,14 @@
 import io.swagger.v3.oas.annotations.Parameter;
 import io.swagger.v3.oas.annotations.tags.Tag;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
 @RestController
 @RequiredArgsConstructor
+@Slf4j
 @RequestMapping("/test/kis")
 @Tag(name = "    Test API", description = "테스트 API 입니다.")
 public class KisTestController {
@@ -25,6 +27,7 @@ public class KisTestController {
     private final KisOhlcvUpdateService kisOhlcvUpdateService;
     private final Kis1dOhlcvUpdateService kis1dOhlcvUpdateService;
     private final Kis1mOhlcvUpdateService kis1mOhlcvUpdateService;
+    private final KisPast15mOhlcvUpdateService kisPast15mOhlcvUpdateService;
 
     @Hidden
     @Operation(summary = "KIS Access Token API", description = "KIS의 Access Token 을 발급 또는 로드합니다.")
@@ -239,4 +242,70 @@ public ResponseEntity<?> update5yOhlcvByStockIdRange(
                     .body(ApiResponse.onFailure("INTERNAL_ERROR", "저장 중 오류 발생", e.getMessage()));
         }
     }
+
+    @Operation(summary = "종목 구간 과거 1년간 15분 Ohlcv 업데이트 API", description = "startId ~ endId 사이 종목들의 1년간의 15분봉 OHLCV를 업데이트합니다.")
+    @PostMapping("/stocks/ohlcv/15m/range")
+    public ResponseEntity<?> updatePast15mOhlcvByStockIdRange(
+            @Parameter(description = "시작 종목 ID", required = true)
+            @RequestParam Long startId,
+
+            @Parameter(description = "종료 종목 ID (미입력 시 startId와 동일)")
+            @RequestParam(required = false) Long endId
+    ) {
+        try {
+            // endId가 null이면 startId로 세팅
+            if (endId == null) {
+                endId = startId;
+            }
+
+            log.info("[API] 종목 구간 15m OHLCV 업데이트 호출 - startId={}, endId={}", startId, endId);
+
+            kisPast15mOhlcvUpdateService.updateStocksByIdRange(startId, endId);
+
+            return ResponseEntity.ok(
+                    ApiResponse.onSuccess("STOCK_UPDATE_SUCCESS",
+                            String.format("과거 1년치 15분봉 OHLCV 저장 완료 (ID %d ~ %d)", startId, endId))
+            );
+        } catch (Exception e) {
+            log.error("[API] 종목 구간 15m OHLCV 업데이트 실패 - startId={}, endId={}", startId, endId, e);
+            return ResponseEntity
+                    .status(HttpStatus.INTERNAL_SERVER_ERROR)
+                    .body(ApiResponse.onFailure("INTERNAL_ERROR", "저장 중 오류 발생", e.getMessage()));
+        }
+    }
+
+    @Operation(
+            summary = "단일 종목 당일 15분 OHLCV 테스트 API",
+            description = "특정 종목 ID에 대해 오늘 하루치 1분봉을 조회하여 15분봉으로 변환 후 저장합니다. "
+                    + "배치 전체가 아닌 단일 종목 테스트 용도로 사용합니다."
+    )
+//    @PostMapping("/stocks/ohlcv/15m/test")
+    public ResponseEntity<?> testSingleStock(
+            @Parameter(description = "종목 ID", required = true)
+            @RequestParam Long stockId
+    ) {
+        try {
+            log.info("[API] 단일 종목 15m OHLCV 테스트 호출 - stockId={}", stockId);
+
+            kisPast15mOhlcvUpdateService.testSingleStockById(stockId);
+
+            return ResponseEntity.ok(
+                    ApiResponse.onSuccess(
+                            "STOCK_TEST_SUCCESS",
+                            String.format("종목 ID=%d 오늘 하루치 15분봉 OHLCV 저장 완료", stockId)
+                    )
+            );
+        } catch (IllegalArgumentException e) {
+            log.warn("[API] 단일 종목 테스트 실패 - 잘못된 종목 ID. stockId={}", stockId, e);
+            return ResponseEntity
+                    .status(HttpStatus.BAD_REQUEST)
+                    .body(ApiResponse.onFailure("INVALID_STOCK_ID", "존재하지 않는 종목 ID", e.getMessage()));
+        } catch (Exception e) {
+            log.error("[API] 단일 종목 15m OHLCV 테스트 실패 - stockId={}", stockId, e);
+            return ResponseEntity
+                    .status(HttpStatus.INTERNAL_SERVER_ERROR)
+                    .body(ApiResponse.onFailure("INTERNAL_ERROR", "저장 중 오류 발생", e.getMessage()));
+        }
+    }
+
 }