거래로그>시간별 수동집계 기능 추가

src/main/java/com/eactive/ext/kjb/statistics/ApiStatsAggregationController.java

@@ -15,6 +15,7 @@ import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PostMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 
+import com.eactive.eai.rms.ext.djb.job.ApiStatsHourlyAggregationJob;
 import com.eactive.ext.kjb.statistics.job.DailyToMonthlyAggregationJob;
 import com.eactive.ext.kjb.statistics.job.HourlyToDailyAggregationJob;
 import com.eactive.ext.kjb.statistics.job.MonthlyToYearlyAggregationJob;
@@ -33,12 +34,62 @@ public class ApiStatsAggregationController {
 	private final HourlyToDailyAggregationJob hourlyToDailyAggregationJob;
 	private final DailyToMonthlyAggregationJob dailyToMonthlyAggregationJob;
 	private final MonthlyToYearlyAggregationJob monthlyToYearlyAggregationJob;
+	
+	private final ApiStatsHourlyAggregationJob apiStatsHourlyAggregationJob;
 
 	@GetMapping(value = "/onl/kjb/statistics/apiStatsAggregationMan.view")
 	public String view() {
 		return "/onl/kjb/statistics/apiStatsAggregationMan";
 	}
 	
+	/**
+	 * 거래로그→시간별 통계 집계 수동 실행
+	 * @param targetDate 집계 대상 날짜 (yyyyMMdd 형식, 예: 20250120)
+	 * @return 처리 결과
+	 */
+	@PostMapping(value = "/onl/kjb/statistics/apiStatsAggregationMan.json", params = "cmd=AGGREGATION_HOUR")
+	public ResponseEntity<Map<String, Object>> executeAggregationHourly(
+			@RequestParam(required = false) String targetDate) {
+
+		Map<String, Object> result = new HashMap<>();
+
+		try {
+			// 날짜 입력 검증
+			if (targetDate == null || targetDate.trim().isEmpty()) {
+				log.error("targetDate 미입력");
+				result.put("success", false);
+				result.put("message", "대상 날짜를 입력하세요. (예: 20250120)");
+				return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(result);
+			}
+
+			LocalDate date;
+			try {
+				date = LocalDate.parse(targetDate, DateTimeFormatter.ofPattern("yyyyMMdd"));
+			} catch (DateTimeParseException e) {
+				log.error("잘못된 날짜 형식: {}", targetDate);
+				result.put("success", false);
+				result.put("message", "잘못된 날짜 형식입니다. yyyyMMdd 형식으로 입력하세요. (예: 20250120)");
+				return ResponseEntity.status(HttpStatus.BAD_REQUEST).body(result);
+			}
+
+			log.info("거래로그→시간별 통계 집계 수동 실행 시작. targetDate: {}", date);
+			int count = apiStatsHourlyAggregationJob.executeManual(date);
+
+			result.put("success", true);
+			result.put("message", "거래로그→시간별 통계 집계가 완료되었습니다.");
+			result.put("targetDate", date.format(DateTimeFormatter.ofPattern("yyyyMMdd")));
+			result.put("processedCount", count);
+
+			return ResponseEntity.ok(result);
+
+		} catch (Exception e) {
+			log.error("거래로그→시간별 통계 집계 실행 중 오류 발생", e);
+			result.put("success", false);
+			result.put("message", "집계 실행 중 오류가 발생했습니다: " + e.getMessage());
+			return ResponseEntity.status(HttpStatus.INTERNAL_SERVER_ERROR).body(result);
+		}
+	}
+	
 	/**
 	 * 시간별→일별 통계 집계 수동 실행
 	 * @param targetDate 집계 대상 날짜 (yyyyMMdd 형식, 예: 20250120)