Merge branch 'develop' into feat/infer_dev_260211

# Conflicts:
#	src/main/java/com/kamco/cd/kamcoback/inference/service/InferenceRunService.java

src/main/java/com/kamco/cd/kamcoback/gukyuin/service/GukYuinApiService.java

@@ -453,7 +453,7 @@ public class GukYuinApiService {
       return new ResponseObj(ApiResponseCode.DUPLICATE_DATA, "이미 국유인 연동을 한 회차입니다.");
     }
 
-    if (!Files.isDirectory(Path.of("/kamco-nfs/dataset/export/" + info.getUid()))) {
+    if (!Files.isDirectory(Path.of(datasetDir + info.getUid()))) {
       return new ResponseObj(
           ApiResponseCode.NOT_FOUND_DATA, "파일 경로에 회차 실행 파일이 생성되지 않았습니다. 확인 부탁드립니다.");
     }
@@ -468,7 +468,7 @@ public class GukYuinApiService {
     reqDto.setCrtrYr(String.valueOf(info.getTargetYyyy()));
     reqDto.setChnDtctSno(String.valueOf(maxStage + 1));
     reqDto.setChnDtctId(info.getUid());
-    reqDto.setPathNm("/kamco-nfs/dataset/export/" + info.getUid());
+    reqDto.setPathNm(datasetDir + info.getUid());
 
     // 1회차를 종료 상태로 처리하고 2회차를 보내야 함
     // 추론(learn), 학습데이터(inference) 둘 다 종료 처리

src/main/java/com/kamco/cd/kamcoback/inference/InferenceRunController.java

@@ -1,57 +0,0 @@
-package com.kamco.cd.kamcoback.inference;
-
-import com.kamco.cd.kamcoback.config.api.ApiResponseDto;
-import com.kamco.cd.kamcoback.inference.service.InferenceRunService;
-import io.swagger.v3.oas.annotations.Operation;
-import io.swagger.v3.oas.annotations.Parameter;
-import io.swagger.v3.oas.annotations.media.Content;
-import io.swagger.v3.oas.annotations.media.Schema;
-import io.swagger.v3.oas.annotations.responses.ApiResponse;
-import io.swagger.v3.oas.annotations.responses.ApiResponses;
-import io.swagger.v3.oas.annotations.tags.Tag;
-import java.util.UUID;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.web.bind.annotation.GetMapping;
-import org.springframework.web.bind.annotation.RequestMapping;
-import org.springframework.web.bind.annotation.RequestParam;
-import org.springframework.web.bind.annotation.RestController;
-
-@Tag(name = "추론 실행", description = "추론 실행")
-@Log4j2
-@RequestMapping("/api/inference/run")
-@RequiredArgsConstructor
-@RestController
-public class InferenceRunController {
-
-  private final InferenceRunService inferenceRunService;
-
-  @Operation(summary = "추론 진행 여부 확인", description = "어드민 홈 > 추론관리 > 추론관리 > 추론관리 목록")
-  @ApiResponses(
-      value = {
-        @ApiResponse(
-            responseCode = "200",
-            description = "검색 성공",
-            content =
-                @Content(
-                    mediaType = "application/json",
-                    schema =
-                        @Schema(
-                            description = "진행 여부 (UUID 있으면 진행중)",
-                            type = "UUID",
-                            example = "44709877-2e27-4fc5-bacb-8e0328c69b64"))),
-        @ApiResponse(responseCode = "400", description = "잘못된 검색 조건", content = @Content),
-        @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
-      })
-  @GetMapping
-  public ApiResponseDto<Void> getProcessing(
-      @Parameter(description = "비교년도", example = "2021") @RequestParam(required = false)
-          Integer compareYear,
-      @Parameter(description = "기준년도", example = "2022") @RequestParam(required = false)
-          Integer targetYear,
-      @Parameter(description = "모델 uuid") @RequestParam(required = false) UUID modelUuid) {
-
-    inferenceRunService.run(compareYear, targetYear, modelUuid);
-    return ApiResponseDto.ok(null);
-  }
-}

src/main/java/com/kamco/cd/kamcoback/inference/dto/InferenceResultDto.java

@@ -676,4 +676,13 @@ public class InferenceResultDto {
     private Long m2ModelBatchId;
     private Long m3ModelBatchId;
   }
+
+  @Getter
+  @Setter
+  @NoArgsConstructor
+  @AllArgsConstructor
+  public static class MapSheetFallbackYearDto {
+    private String mapSheetNum;
+    private Integer mngYyyy;
+  }
 }

src/main/java/com/kamco/cd/kamcoback/inference/service/InferenceManualService.java

@@ -17,6 +17,8 @@ public class InferenceManualService {
 
     if (resultList.isEmpty()) {}
 
-    for (InferenceResultsTestingDto.Basic result : resultList) {}
+    for (InferenceResultsTestingDto.Basic result : resultList) {
+      System.out.println(result);
+    }
   }
 }

src/main/java/com/kamco/cd/kamcoback/inference/service/InferenceResultService.java

@@ -21,6 +21,7 @@ import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.DetectOption;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.InferenceLearnDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.InferenceServerStatusDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.InferenceStatusDetailDto;
+import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.MapSheetFallbackYearDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.MapSheetNumDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.ResultList;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.SaveInferenceAiDto;
@@ -46,12 +47,14 @@ import java.util.ArrayList;
 import java.util.Comparator;
 import java.util.HashMap;
 import java.util.HashSet;
+import java.util.LinkedHashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 import java.util.Optional;
 import java.util.Set;
 import java.util.UUID;
+import java.util.function.Function;
 import java.util.stream.Collectors;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.log4j.Log4j2;
@@ -119,92 +122,223 @@ public class InferenceResultService {
 
   @Transactional
   public UUID run(InferenceResultDto.RegReq req) {
+    if (req.getDetectOption().equals(DetectOption.EXCL.getId())) {
+      return runExcl(req);
+    }
+    return runPrev(req);
+  }
+
+  /**
+   * 변화탐지 옵션 추론제외 실행
+   *
+   * @param req
+   * @return
+   */
+  public UUID runExcl(InferenceResultDto.RegReq req) {
+    // target 도엽  조회
     List<MngListDto> targetDtoList = mapSheetMngCoreService.getHstMapSheetList(req);
-    List<String> compareList = mapSheetMngCoreService.getMapSheetMngHst(req.getCompareYyyy());
+
+    // target  리스트 추출 (null 제거 + 중복 제거)
     List<String> targetList =
-        mapSheetMngCoreService.getHstMapSheetList(req).stream()
+        targetDtoList.stream()
             .map(MngListDto::getMapSheetNum)
             .filter(Objects::nonNull)
             .distinct()
             .toList();
 
-    log.info(
+    // compare 도엽번호 리스트 조회 (null 제거 + 중복 제거)
-        "hst list count compareList = {}, targetList = {}", compareList.size(), targetList.size());
+    List<String> compareList =
-
+        mapSheetMngCoreService.getMapSheetNumByHst(req.getCompareYyyy()).stream()
-    Set<String> compareSet = new HashSet<>(compareList);
+            .filter(Objects::nonNull)
-    Set<String> targetSet = new HashSet<>(targetList);
-
-    long intersectionCount =
-        targetSet.stream()
             .distinct()
-            .filter(compareSet::contains)
-            .count(); // compare와 target에 공통으로 존재하는 도협 수
-
-    long excludedTargetCount =
-        targetSet.stream()
-            .distinct()
-            .filter(s -> !compareSet.contains(s))
-            .count(); // target 에만 존재하는 도협 수 (compare 에는 없음)
-
-    long onlyCompareCount =
-        compareSet.stream()
-            .distinct()
-            .filter(s -> !targetSet.contains(s))
-            .count(); // compare 에만 존재하는 도협 수 (target 에는 없음)
-
-    log.info(
-        """
-    ===== MapSheet Year Comparison =====
-    target Total: {}
-    compare Total: {}
-    Intersection: {}
-    target Only (Excluded from compare): {}
-    compare Only: {}
-    ====================================
-    """,
-        targetSet.size(),
-        compareSet.size(),
-        intersectionCount,
-        excludedTargetCount,
-        onlyCompareCount);
-
-    List<String> filteredTargetList =
-        targetSet.stream() // target 기준으로
-            .filter(compareSet::contains) // compare에 있는 도협만 남김
             .toList();
 
-    Scene modelComparePath =
+    // compare 기준
-        getSceneInference(req.getCompareYyyy().toString(), filteredTargetList, "", "");
+    Set<String> compareSet = new HashSet<>(compareList);
 
-    Scene modelTargetPath =
+    // target 기준으로 compare에 존재하는 도엽만 필터링
-        getSceneInference(req.getTargetYyyy().toString(), filteredTargetList, "", "");
+    List<String> filteredTargetList = targetList.stream().filter(compareSet::contains).toList();
 
-    // 작은 쪽 기준으로 탐지건수/파일생성 리스트 결정
+    // 도엽 비교 로그 출력
-    List<ImageFeature> imageFeatureList;
+    logYearComparison(targetList, compareList, filteredTargetList);
-    if (modelComparePath.getFeatures().size() <= modelTargetPath.getFeatures().size()) {
-      imageFeatureList = modelComparePath.getFeatures();
-    } else {
-      imageFeatureList = modelTargetPath.getFeatures();
-    }
 
-    // imageFeatureList 기준 sceneId Set
+    // compare geojson 파일 생성
-    Set<String> sceneIdSet =
+    Scene compareScene =
-        imageFeatureList.stream()
+        getSceneInference(
-            .map(ImageFeature::getSceneId)
+            req.getCompareYyyy().toString(), // 기준년도
+            filteredTargetList, // 교집합 도엽
+            req.getMapSheetScope(), // ALL / 부분
+            req.getDetectOption()); // EXCL / PREV
+
+    // target geojson 파일 생성
+    Scene targetScene =
+        getSceneInference(
+            req.getTargetYyyy().toString(), // 대상년도
+            filteredTargetList, // 교집합 도엽
+            req.getMapSheetScope(),
+            req.getDetectOption());
+
+    // 추론 실행
+    return executeInference(
+        req,
+        targetDtoList, // 전체 target 목록
+        filteredTargetList, // 최종 추론 대상
+        compareScene, // compare geojson
+        targetScene // target geojson
+        );
+  }
+
+  /**
+   * 변화탐지 옵션 이전 년도 도엽 사용 실행
+   *
+   * @param req
+   * @return
+   */
+  @Transactional
+  public UUID runPrev(InferenceResultDto.RegReq req) {
+    // target 목록 조회
+    List<MngListDto> targetDtoList = mapSheetMngCoreService.getHstMapSheetList(req);
+
+    // target 도엽번호 리스트 추출
+    List<String> targetList =
+        targetDtoList.stream()
+            .map(MngListDto::getMapSheetNum)
+            .filter(Objects::nonNull)
+            .distinct()
+            .toList();
+
+    // target 포함 여부 판단
+    Set<String> targetSet = new HashSet<>(targetList);
+
+    // compare 목록 조회
+    List<MapSheetFallbackYearDto> compareDtoList =
+        new ArrayList<>(mapSheetMngCoreService.getMapSheetNumDtoByHst(req.getCompareYyyy()));
+
+    // compare 도엽번호 Set 구성
+    Set<String> compareSet =
+        compareDtoList.stream()
+            .map(MapSheetFallbackYearDto::getMapSheetNum)
             .filter(Objects::nonNull)
             .collect(Collectors.toSet());
 
-    // targetList(List<MngListDto>) 리턴용으로 필터링
+    // arget에는 있으나 compare에는 없는 도엽 추출
+    List<String> remainingTargetList =
+        targetList.stream().filter(s -> !compareSet.contains(s)).toList();
+
+    // fallback년도 도엽 조회
+    List<MapSheetFallbackYearDto> fallbackYearDtoList =
+        mapSheetMngCoreService.findFallbackCompareYearByMapSheets(
+            req.getTargetYyyy(), // 대상년도 기준
+            remainingTargetList // compare에 없는 도엽들
+            );
+
+    // 기존 compare , fallback 합치기
+    compareDtoList.addAll(fallbackYearDtoList);
+
+    // mapSheetNum 기준 중복 제거 (기존 compare 우선 유지)
+    compareDtoList =
+        new ArrayList<>(
+            compareDtoList.stream()
+                .filter(d -> d.getMapSheetNum() != null)
+                .collect(
+                    Collectors.toMap(
+                        MapSheetFallbackYearDto::getMapSheetNum,
+                        Function.identity(),
+                        (existing, replacement) -> existing, // 기존 우선
+                        LinkedHashMap::new))
+                .values());
+
+    // 최종 compare 도엽 Set 구성
+    Set<String> availableCompareSheets =
+        compareDtoList.stream()
+            .map(MapSheetFallbackYearDto::getMapSheetNum)
+            .filter(Objects::nonNull)
+            .collect(Collectors.toSet());
+
+    // 최종 추론 대상 도엽
+    // target 중 compare(fallback)에 존재하는 도엽만 추출
+    List<String> filteredTargetList =
+        targetList.stream().filter(availableCompareSheets::contains).toList();
+
+    // compare only 계산 (target에는 없는 compare 도엽 수)
+    long compareOnlyCount =
+        compareDtoList.stream()
+            .map(MapSheetFallbackYearDto::getMapSheetNum)
+            .filter(s -> s != null && !targetSet.contains(s))
+            .count();
+
+    // 연도별 도엽 비교 로그 출력
+    log.info(
+        """
+      ===== MapSheet Year Comparison =====
+      target Total: {}
+      compare Total: {}
+      Intersection: {}
+      target Only (Excluded): {}
+      compare Only: {}
+      ====================================
+      """,
+        targetList.size(), // target count
+        compareDtoList.size(), // compare count
+        filteredTargetList.size(), // target 기준으로 compare 비교하여 최종 추론할 도엽 count
+        targetList.size() - filteredTargetList.size(), // compare에 존재하지 않는 target 도엽 수
+        compareOnlyCount); // target 에 존재하지 않는 compare 도엽수
+
+    // compareDtoList도 최종 교집합 기준으로 필터
+    Set<String> filteredTargetSet = new HashSet<>(filteredTargetList);
+
+    List<MapSheetFallbackYearDto> filteredCompareDtoList =
+        compareDtoList.stream()
+            .filter(d -> d.getMapSheetNum() != null)
+            .filter(d -> filteredTargetSet.contains(d.getMapSheetNum()))
+            .toList();
+
+    // compare 기준 geojson 생성 (년도 fallback 반영)
+    Scene compareScene =
+        getSceneInference(
+            filteredCompareDtoList,
+            req.getCompareYyyy().toString(),
+            req.getMapSheetScope(),
+            req.getDetectOption());
+
+    // target 기준 geojson 생성
+    Scene targetScene =
+        getSceneInference(
+            req.getTargetYyyy().toString(),
+            filteredTargetList,
+            req.getMapSheetScope(),
+            req.getDetectOption());
+
+    // AI 추론 실행
+    return executeInference(req, targetDtoList, filteredTargetList, compareScene, targetScene);
+  }
+
+  /**
+   * learn 테이블 저장 및 AI 추론 API 호출
+   *
+   * @param req
+   * @param targetDtoList
+   * @param filteredTargetList
+   * @param modelComparePath
+   * @param modelTargetPath
+   * @return
+   */
+  private UUID executeInference(
+      InferenceResultDto.RegReq req,
+      List<MngListDto> targetDtoList,
+      List<String> filteredTargetList,
+      Scene modelComparePath,
+      Scene modelTargetPath) {
+    Set<String> filteredSet = new HashSet<>(filteredTargetList);
+
     List<MngListDto> newTargetList =
         targetDtoList.stream()
             .filter(m -> m.getMapSheetNum() != null)
-            .filter(m -> sceneIdSet.contains(m.getMapSheetNum()))
+            .filter(m -> filteredSet.contains(m.getMapSheetNum()))
             .toList();
 
-    // 목록 및 추론 대상 도엽정보 저장
     UUID uuid = inferenceResultCoreService.saveInferenceInfo(req, newTargetList);
 
-    // ai 서버에 전달할 파라미터 생성
     pred_requests_areas predRequestsAreas = new pred_requests_areas();
     predRequestsAreas.setInput1_year(req.getCompareYyyy());
     predRequestsAreas.setInput2_year(req.getTargetYyyy());
@@ -215,12 +349,9 @@ public class InferenceResultService {
     m1.setPred_requests_areas(predRequestsAreas);
 
     log.info("[INFERENCE] Start m1 = {}", m1);
-    m1.setPred_requests_areas(predRequestsAreas);
 
-    // ai 추론 실행 api 호출
     Long batchId = ensureAccepted(m1);
 
-    // ai 추론 실행후 응답값 update
     SaveInferenceAiDto saveInferenceAiDto = new SaveInferenceAiDto();
     saveInferenceAiDto.setUuid(uuid);
     saveInferenceAiDto.setBatchId(batchId);
@@ -230,11 +361,42 @@ public class InferenceResultService {
     saveInferenceAiDto.setModelComparePath(modelComparePath.getFilePath());
     saveInferenceAiDto.setModelTargetPath(modelTargetPath.getFilePath());
     saveInferenceAiDto.setModelStartDttm(ZonedDateTime.now());
+
     inferenceResultCoreService.update(saveInferenceAiDto);
 
     return uuid;
   }
 
+  /**
+   * EXCL 로그
+   *
+   * @param targetList
+   * @param compareList
+   * @param filteredTargetList
+   */
+  private void logYearComparison(
+      List<String> targetList, List<String> compareList, List<String> filteredTargetList) {
+    Set<String> targetSet = new HashSet<>(targetList);
+
+    long compareOnlyCount = compareList.stream().filter(s -> !targetSet.contains(s)).count();
+
+    log.info(
+        """
+    ===== MapSheet Year Comparison =====
+    target Total: {}
+    compare Total: {}
+    Intersection: {}
+    target Only (Excluded): {}
+    compare Only: {}
+    ====================================
+    """,
+        targetList.size(), // target count
+        compareList.size(), // compare count
+        filteredTargetList.size(), // target 기준으로 compare 비교하여 최종 추론할 도엽 count
+        targetList.size() - filteredTargetList.size(), // compare에 존재하지 않는 target 도엽 수
+        compareOnlyCount); // target 에 존재하지 않는 compare 도엽수
+  }
+
   /**
    * 변화탐지 실행 정보 생성
    *
@@ -265,31 +427,31 @@ public class InferenceResultService {
 
     List<TotalListDto> totalNumList = new ArrayList<>();
 
-    //    if (DetectOption.EXCL.getId().equals(req.getDetectOption())) {
+    if (DetectOption.EXCL.getId().equals(req.getDetectOption())) {
-    //      // "추론제외" 일때 전년도 이전 값이 있어도 전년도 도엽이 없으면 비교 안함
+      // "추론제외" 일때 전년도 이전 값이 있어도 전년도 도엽이 없으면 비교 안함
-    //      for (MngListCompareDto dto : compareList) {
+      for (MngListCompareDto dto : compareList) {
-    //        if (Objects.equals(dto.getBeforeYear(), req.getCompareYyyy())) {
+        if (Objects.equals(dto.getBeforeYear(), req.getCompareYyyy())) {
-    //          TotalListDto totalDto = new TotalListDto();
+          TotalListDto totalDto = new TotalListDto();
-    //          totalDto.setBeforeYear(dto.getBeforeYear() == null ? 0 : dto.getBeforeYear());
+          totalDto.setBeforeYear(dto.getBeforeYear() == null ? 0 : dto.getBeforeYear());
-    //          totalDto.setMapSheetNum(dto.getMapSheetNum());
+          totalDto.setMapSheetNum(dto.getMapSheetNum());
-    //          totalNumList.add(totalDto);
+          totalNumList.add(totalDto);
-    //        }
+        }
-    //      }
+      }
-    //    } else if (DetectOption.PREV.getId().equals(req.getDetectOption())) {
+    } else if (DetectOption.PREV.getId().equals(req.getDetectOption())) {
-    //      // "이전 년도 도엽 사용" 이면 전년도 이전 도엽도 사용
+      // "이전 년도 도엽 사용" 이면 전년도 이전 도엽도 사용
-    //      for (MngListCompareDto dto : compareList) {
+      for (MngListCompareDto dto : compareList) {
-    //        if (dto.getBeforeYear() != 0) {
+        if (dto.getBeforeYear() != 0) {
-    //          TotalListDto totalDto = new TotalListDto();
+          TotalListDto totalDto = new TotalListDto();
-    //          totalDto.setBeforeYear(dto.getBeforeYear() == null ? 0 : dto.getBeforeYear());
+          totalDto.setBeforeYear(dto.getBeforeYear() == null ? 0 : dto.getBeforeYear());
-    //          totalDto.setMapSheetNum(dto.getMapSheetNum());
+          totalDto.setMapSheetNum(dto.getMapSheetNum());
-    //          totalNumList.add(totalDto);
+          totalNumList.add(totalDto);
-    //        }
+        }
-    //      }
+      }
-    //    }
+    }
-    //
+
-    //    if (totalNumList.isEmpty()) {
+    if (totalNumList.isEmpty()) {
-    //      throw new CustomApiException("NOT_FOUND_COMPARE_YEAR", HttpStatus.NOT_FOUND);
+      throw new CustomApiException("NOT_FOUND_COMPARE_YEAR", HttpStatus.NOT_FOUND);
-    //    }
+    }
 
     // 사용할 영상파일 년도 기록 및 추론에 포함되는지 설정
     for (MngListDto target : targetList) {
@@ -579,6 +741,23 @@ public class InferenceResultService {
         yyyy, mapSheetNums, mapSheetScope, detectOption);
   }
 
+  /**
+   * 년도 별로 조회하여 geojson 파일 생성
+   *
+   * @param yearDtos
+   * @param year
+   * @param mapSheetScope
+   * @param detectOption
+   * @return
+   */
+  private Scene getSceneInference(
+      List<MapSheetFallbackYearDto> yearDtos,
+      String year,
+      String mapSheetScope,
+      String detectOption) {
+    return mapSheetMngCoreService.getSceneInference(yearDtos, year, mapSheetScope, detectOption);
+  }
+
   /**
    * 분석결과 요약정보
    *

src/main/java/com/kamco/cd/kamcoback/postgres/core/MapSheetMngCoreService.java

@@ -7,6 +7,7 @@ import com.kamco.cd.kamcoback.common.geometry.GeoJsonFileWriter.ImageFeature;
 import com.kamco.cd.kamcoback.common.geometry.GeoJsonFileWriter.Scene;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.DetectOption;
+import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.MapSheetFallbackYearDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.MapSheetScope;
 import com.kamco.cd.kamcoback.mapsheet.dto.MapSheetMngDto;
 import com.kamco.cd.kamcoback.mapsheet.dto.MapSheetMngDto.MngListCompareDto;
@@ -24,13 +25,14 @@ import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
 import java.time.ZonedDateTime;
+import java.util.ArrayList;
 import java.util.Arrays;
-import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Objects;
 import java.util.Optional;
 import java.util.UUID;
+import java.util.stream.Collectors;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.beans.factory.annotation.Value;
@@ -233,27 +235,52 @@ public class MapSheetMngCoreService {
   }
 
   /**
-   * 추론 실행에 필요한 geojson 파일 생성
+   * geojson 생성
    *
-   * @param yyyy 영상관리 파일별 년도
+   * @param yyyy
-   * @param scenes 5k 도엽 번호 리스트
+   * @param scenes
-   * @param mapSheetScope EXCL : 추론제외, PREV 이전 년도 도엽 사용
+   * @param mapSheetScope
+   * @param detectOption
    * @return
    */
   public Scene getSceneInference(
       String yyyy, List<String> scenes, String mapSheetScope, String detectOption) {
+    List<ImageFeature> features = loadSceneInferenceBySheets(yyyy, scenes);
+    return writeSceneGeoJson(yyyy, mapSheetScope, detectOption, features);
+  }
 
-    Map<String, Object> result = new HashMap<>();
+  /**
+   * geojson 생성
+   *
+   * @param yearDtos
+   * @param yyyy
+   * @param mapSheetScope
+   * @param detectOption
+   * @return
+   */
+  public Scene getSceneInference(
+      List<MapSheetFallbackYearDto> yearDtos,
+      String yyyy,
+      String mapSheetScope,
+      String detectOption) {
+    List<ImageFeature> features = loadSceneInferenceByFallbackYears(yearDtos);
+    return writeSceneGeoJson(yyyy, mapSheetScope, detectOption, features);
+  }
+
+  /**
+   * 파일 경로/이름 , 파일 생성 , 도엽번호 반환
+   *
+   * @param yyyy
+   * @param mapSheetScope
+   * @param detectOption
+   * @param sceneInference
+   * @return Scene
+   */
+  private Scene writeSceneGeoJson(
+      String yyyy, String mapSheetScope, String detectOption, List<ImageFeature> sceneInference) {
     boolean isAll = MapSheetScope.ALL.getId().equals(mapSheetScope);
+    String optionSuffix = buildOptionSuffix(detectOption);
 
-    String optionSuffix = "";
-    if (DetectOption.EXCL.getId().equals(detectOption)) {
-      optionSuffix = "_EXCL";
-    } else if (DetectOption.PREV.getId().equals(detectOption)) {
-      optionSuffix = "_PREV";
-    }
-
-    // 1) 경로/파일명 결정
     String targetDir =
         "local".equals(activeEnv) ? System.getProperty("user.home") + "/geojson" : inferenceDir;
 
@@ -264,24 +291,11 @@ public class MapSheetMngCoreService {
 
     Path outputPath = Paths.get(targetDir, filename);
 
-    // 2) ALL일 때만 재사용
-    //    if (isAll && Files.exists(outputPath)) {
-    //      return outputPath.toString();
-    //    }
-
-    // 3) 데이터 조회
-    List<ImageFeature> sceneInference = mapSheetMngRepository.getSceneInference(yyyy, scenes);
-
     if (sceneInference == null || sceneInference.isEmpty()) {
-      log.warn(
+      log.warn("NOT_FOUND_TARGET_YEAR: yyyy={}, isAll={}, featuresSize={}", yyyy, isAll, 0);
-          "NOT_FOUND_TARGET_YEAR: yyyy={}, isAll={}, scenesSize={}",
-          yyyy,
-          isAll,
-          scenes == null ? 0 : scenes.size());
       throw new CustomApiException("NOT_FOUND_TARGET_YEAR", HttpStatus.NOT_FOUND);
     }
 
-    // 4) 파일 생성
     try {
       log.info("create Directories outputPath: {}", outputPath);
       log.info(
@@ -291,15 +305,15 @@ public class MapSheetMngCoreService {
           targetDir,
           filename);
       log.info("outputPath={}, parent={}", outputPath.toAbsolutePath(), outputPath.getParent());
+
       Files.createDirectories(outputPath.getParent());
 
       new GeoJsonFileWriter()
           .exportToFile(sceneInference, "scene_inference_" + yyyy, 5186, outputPath.toString());
-      log.info("GeoJsonFileWriter: {}", "scene_inference_" + yyyy);
+
       Scene scene = new Scene();
       scene.setFeatures(sceneInference);
       scene.setFilePath(outputPath.toString());
-
       return scene;
 
     } catch (IOException e) {
@@ -309,6 +323,77 @@ public class MapSheetMngCoreService {
     }
   }
 
+  /**
+   * geojson 파일명 Suffix
+   *
+   * @param detectOption
+   * @return
+   */
+  private String buildOptionSuffix(String detectOption) {
+    if (DetectOption.EXCL.getId().equals(detectOption)) return "_EXCL";
+    if (DetectOption.PREV.getId().equals(detectOption)) return "_PREV";
+    return "";
+  }
+
+  /**
+   * 년도, 도엽번호로 조회
+   *
+   * @param yyyy
+   * @param scenes
+   * @return ImageFeature
+   */
+  private List<ImageFeature> loadSceneInferenceBySheets(String yyyy, List<String> scenes) {
+    List<ImageFeature> sceneInference = mapSheetMngRepository.getSceneInference(yyyy, scenes);
+
+    if (sceneInference == null || sceneInference.isEmpty()) {
+      log.warn(
+          "NOT_FOUND_TARGET_YEAR: yyyy={}, scenesSize={}",
+          yyyy,
+          scenes == null ? 0 : scenes.size());
+      throw new CustomApiException("NOT_FOUND_TARGET_YEAR", HttpStatus.NOT_FOUND);
+    }
+    return sceneInference;
+  }
+
+  /**
+   * 년도별로 나눠 조회
+   *
+   * @param yearDtos
+   * @return ImageFeature
+   */
+  private List<ImageFeature> loadSceneInferenceByFallbackYears(
+      List<MapSheetFallbackYearDto> yearDtos) {
+    if (yearDtos == null || yearDtos.isEmpty()) {
+      return List.of();
+    }
+
+    Map<Integer, List<MapSheetFallbackYearDto>> groupedByYear =
+        yearDtos.stream()
+            .filter(d -> d.getMngYyyy() != null && d.getMapSheetNum() != null)
+            .collect(Collectors.groupingBy(MapSheetFallbackYearDto::getMngYyyy));
+
+    List<ImageFeature> sceneInference = new ArrayList<>();
+
+    for (Map.Entry<Integer, List<MapSheetFallbackYearDto>> entry : groupedByYear.entrySet()) {
+      Integer year = entry.getKey();
+
+      List<String> sheetNums =
+          entry.getValue().stream()
+              .map(MapSheetFallbackYearDto::getMapSheetNum)
+              .filter(Objects::nonNull)
+              .distinct()
+              .toList();
+
+      List<ImageFeature> temp = mapSheetMngRepository.getSceneInference(year.toString(), sheetNums);
+
+      if (temp != null && !temp.isEmpty()) {
+        sceneInference.addAll(temp);
+      }
+    }
+
+    return sceneInference;
+  }
+
   /**
    * 변화탐지 실행 가능 기준 년도 조회
    *
@@ -343,8 +428,24 @@ public class MapSheetMngCoreService {
     return mapSheetMngYearRepository.findByHstMapSheetCompareList(mngYyyy, mapId);
   }
 
-  public List<String> getMapSheetMngHst(Integer year) {
+  public List<String> getMapSheetNumByHst(Integer year) {
     List<MapSheetMngHstEntity> entity = mapSheetMngRepository.getMapSheetMngHst(year);
     return entity.stream().map(MapSheetMngHstEntity::getMapSheetNum).toList();
   }
+
+  public List<MapSheetFallbackYearDto> getMapSheetNumDtoByHst(Integer year) {
+    List<MapSheetMngHstEntity> entity = mapSheetMngRepository.getMapSheetMngHst(year);
+    return entity.stream()
+        .map(
+            e ->
+                new MapSheetFallbackYearDto(
+                    e.getMapSheetNum(), e.getMngYyyy() // 조회 기준 연도
+                    ))
+        .toList();
+  }
+
+  public List<MapSheetFallbackYearDto> findFallbackCompareYearByMapSheets(
+      Integer year, List<String> mapIds) {
+    return mapSheetMngRepository.findFallbackCompareYearByMapSheets(year, mapIds);
+  }
 }

src/main/java/com/kamco/cd/kamcoback/postgres/repository/mapsheet/MapSheetMngRepositoryCustom.java

@@ -2,6 +2,7 @@ package com.kamco.cd.kamcoback.postgres.repository.mapsheet;
 
 import com.kamco.cd.kamcoback.common.geometry.GeoJsonFileWriter.ImageFeature;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto;
+import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.MapSheetFallbackYearDto;
 import com.kamco.cd.kamcoback.mapsheet.dto.MapSheetMngDto;
 import com.kamco.cd.kamcoback.mapsheet.dto.MapSheetMngDto.AddReq;
 import com.kamco.cd.kamcoback.mapsheet.dto.MapSheetMngDto.MngListDto;
@@ -82,4 +83,7 @@ public interface MapSheetMngRepositoryCustom {
   void insertMapSheetMngTile(@Valid AddReq addReq);
 
   List<MapSheetMngHstEntity> getMapSheetMngHst(Integer year);
+
+  List<MapSheetFallbackYearDto> findFallbackCompareYearByMapSheets(
+      Integer year, List<String> mapIds);
 }

src/main/java/com/kamco/cd/kamcoback/postgres/repository/mapsheet/MapSheetMngRepositoryImpl.java

@@ -5,12 +5,14 @@ import static com.kamco.cd.kamcoback.postgres.entity.QMapSheetMngEntity.mapSheet
 import static com.kamco.cd.kamcoback.postgres.entity.QMapSheetMngFileEntity.mapSheetMngFileEntity;
 import static com.kamco.cd.kamcoback.postgres.entity.QMapSheetMngHstEntity.mapSheetMngHstEntity;
 import static com.kamco.cd.kamcoback.postgres.entity.QMapSheetMngTileEntity.mapSheetMngTileEntity;
+import static com.kamco.cd.kamcoback.postgres.entity.QMapSheetMngYearYnEntity.mapSheetMngYearYnEntity;
 import static com.kamco.cd.kamcoback.postgres.entity.QYearEntity.yearEntity;
 import static com.querydsl.core.types.dsl.Expressions.nullExpression;
 
 import com.kamco.cd.kamcoback.common.enums.CommonUseStatus;
 import com.kamco.cd.kamcoback.common.geometry.GeoJsonFileWriter.ImageFeature;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto;
+import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.MapSheetFallbackYearDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.MapSheetScope;
 import com.kamco.cd.kamcoback.mapsheet.dto.MapSheetMngDto;
 import com.kamco.cd.kamcoback.mapsheet.dto.MapSheetMngDto.AddReq;
@@ -1119,4 +1121,24 @@ public class MapSheetMngRepositoryImpl extends QuerydslRepositorySupport
                 .and(mapSheetMngFileEntity.fileExt.eq("tif")))
         .fetch();
   }
+
+  @Override
+  public List<MapSheetFallbackYearDto> findFallbackCompareYearByMapSheets(
+      Integer year, List<String> mapIds) {
+    BooleanBuilder builder = new BooleanBuilder();
+    builder.and(mapSheetMngYearYnEntity.id.mapSheetNum.in(mapIds));
+    builder.and(mapSheetMngYearYnEntity.id.mngYyyy.lt(year));
+    builder.and(mapSheetMngYearYnEntity.yn.eq("Y"));
+
+    return queryFactory
+        .select(
+            Projections.constructor(
+                MapSheetFallbackYearDto.class,
+                mapSheetMngYearYnEntity.id.mapSheetNum,
+                mapSheetMngYearYnEntity.id.mngYyyy.max()))
+        .from(mapSheetMngYearYnEntity)
+        .where(builder)
+        .groupBy(mapSheetMngYearYnEntity.id.mapSheetNum)
+        .fetch();
+  }
 }