merge develop_add_log

Reviewed-on: #104

src/main/java/com/kamco/cd/kamcoback/config/FileProperties.java

@@ -0,0 +1,33 @@
+package com.kamco.cd.kamcoback.config;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Getter
+@Setter
+@Component
+@ConfigurationProperties(prefix = "file")
+public class FileProperties {
+
+  private String root;
+  private String nfs;
+  private String syncRootDir;
+  private String syncTmpDir;
+  private String syncFileExtention;
+  private String datasetDir;
+  private String datasetTmpDir;
+  private String modelDir;
+  private String modelTmpDir;
+  private String modelFileExtention;
+  private String ptPath;
+  private String datasetResponse;
+  private TrainingData trainingData;
+
+  @Getter
+  @Setter
+  public static class TrainingData {
+    private String geojsonDir;
+  }
+}

src/main/java/com/kamco/cd/kamcoback/config/InferenceProperties.java

@@ -0,0 +1,20 @@
+package com.kamco.cd.kamcoback.config;
+
+import lombok.Getter;
+import lombok.Setter;
+import org.springframework.boot.context.properties.ConfigurationProperties;
+import org.springframework.stereotype.Component;
+
+@Getter
+@Setter
+@Component
+@ConfigurationProperties(prefix = "inference")
+public class InferenceProperties {
+
+  private String nfs;
+  private String url;
+  private String batchUrl;
+  private String geojsonDir;
+  private String jarPath;
+  private String inferenceServerName;
+}

src/main/java/com/kamco/cd/kamcoback/config/SecurityConfig.java

@@ -106,7 +106,7 @@ public class SecurityConfig {
                         "/api/layer/tile-url",
                         "/api/layer/tile-url-year",
                         "/api/common-code/clazz",
-                        "/api/inference/download/*")
+                        "/api/inference/download/**")
                     .permitAll()
                     // 로그인한 사용자만 가능 IAM
                     .requestMatchers(

src/main/java/com/kamco/cd/kamcoback/config/StartupLogger.java

@@ -16,6 +16,8 @@ public class StartupLogger {
 
   private final Environment environment;
   private final DataSource dataSource;
+  private final FileProperties fileProperties;
+  private final InferenceProperties inferenceProperties;
 
   @EventListener(ApplicationReadyEvent.class)
   public void logStartupInfo() {
@@ -79,6 +81,25 @@ public class StartupLogger {
           │  DDL Auto         : %s
           │  JDBC Batch Size  : %s
           │  Fetch Batch Size : %s
+          ╠════════════════════════════════════════════════════════════════════════════════╣
+          ║  FILE CONFIGURATION                                                            ║
+          ╠────────────────────────────────────────────────────────────────────────────────╣
+          │  Root Directory   : %s
+          │  NFS Mount Path   : %s
+          │  Sync Root Dir    : %s
+          │  Sync Tmp Dir     : %s
+          │  Dataset Dir      : %s
+          │  Model Dir        : %s
+          │  PT Path          : %s
+          ╠════════════════════════════════════════════════════════════════════════════════╣
+          ║  INFERENCE CONFIGURATION                                                       ║
+          ╠────────────────────────────────────────────────────────────────────────────────╣
+          │  NFS Mount Path   : %s
+          │  Inference URL    : %s
+          │  Batch URL        : %s
+          │  GeoJSON Dir      : %s
+          │  JAR Path         : %s
+          │  Server Names     : %s
           ╚════════════════════════════════════════════════════════════════════════════════╝
           """,
             profileInfo,
@@ -89,7 +110,24 @@ public class StartupLogger {
             showSql,
             ddlAuto,
             batchSize,
-            batchFetchSize);
+            batchFetchSize,
+            fileProperties.getRoot() != null ? fileProperties.getRoot() : "N/A",
+            fileProperties.getNfs() != null ? fileProperties.getNfs() : "N/A",
+            fileProperties.getSyncRootDir() != null ? fileProperties.getSyncRootDir() : "N/A",
+            fileProperties.getSyncTmpDir() != null ? fileProperties.getSyncTmpDir() : "N/A",
+            fileProperties.getDatasetDir() != null ? fileProperties.getDatasetDir() : "N/A",
+            fileProperties.getModelDir() != null ? fileProperties.getModelDir() : "N/A",
+            fileProperties.getPtPath() != null ? fileProperties.getPtPath() : "N/A",
+            inferenceProperties.getNfs() != null ? inferenceProperties.getNfs() : "N/A",
+            inferenceProperties.getUrl() != null ? inferenceProperties.getUrl() : "N/A",
+            inferenceProperties.getBatchUrl() != null ? inferenceProperties.getBatchUrl() : "N/A",
+            inferenceProperties.getGeojsonDir() != null
+                ? inferenceProperties.getGeojsonDir()
+                : "N/A",
+            inferenceProperties.getJarPath() != null ? inferenceProperties.getJarPath() : "N/A",
+            inferenceProperties.getInferenceServerName() != null
+                ? inferenceProperties.getInferenceServerName()
+                : "N/A");
 
     log.info(startupMessage);
   }

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

@@ -119,6 +119,12 @@ public class InferenceResultService {
     return dto.getUuid();
   }
 
+  /**
+   * 추론 실행 - 추론제외, 이전년도 도엽 사용 분기
+   *
+   * @param req
+   * @return
+   */
   @Transactional
   public UUID run(InferenceResultDto.RegReq req) {
     if (req.getDetectOption().equals(DetectOption.EXCL.getId())) {

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

@@ -1,224 +0,0 @@
-package com.kamco.cd.kamcoback.inference.service;
-
-import com.fasterxml.jackson.core.JsonProcessingException;
-import com.fasterxml.jackson.core.type.TypeReference;
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.kamco.cd.kamcoback.common.exception.CustomApiException;
-import com.kamco.cd.kamcoback.common.geometry.GeoJsonFileWriter.Scene;
-import com.kamco.cd.kamcoback.config.resttemplate.ExternalHttpClient;
-import com.kamco.cd.kamcoback.config.resttemplate.ExternalHttpClient.ExternalCallResult;
-import com.kamco.cd.kamcoback.inference.dto.InferenceSendDto;
-import com.kamco.cd.kamcoback.inference.dto.InferenceSendDto.pred_requests_areas;
-import com.kamco.cd.kamcoback.model.dto.ModelMngDto.Basic;
-import com.kamco.cd.kamcoback.model.dto.ModelMngDto.ModelType;
-import com.kamco.cd.kamcoback.postgres.core.MapSheetMngCoreService;
-import com.kamco.cd.kamcoback.postgres.core.ModelMngCoreService;
-import java.nio.file.Paths;
-import java.util.HashSet;
-import java.util.List;
-import java.util.Map;
-import java.util.Set;
-import java.util.UUID;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.log4j.Log4j2;
-import org.springframework.beans.factory.annotation.Value;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpMethod;
-import org.springframework.http.HttpStatus;
-import org.springframework.http.MediaType;
-import org.springframework.stereotype.Service;
-
-@Service
-@Log4j2
-@RequiredArgsConstructor
-public class InferenceRunService {
-  private final ExternalHttpClient externalHttpClient;
-  private final MapSheetMngCoreService mapSheetMngCoreService;
-  private final ModelMngCoreService modelMngCoreService;
-  private final ObjectMapper objectMapper;
-
-  @Value("${spring.profiles.active}")
-  private String profile;
-
-  @Value("${inference.url}")
-  private String inferenceUrl;
-
-  // TODO 이거 쓰는건가?
-  public void run(Integer compareYear, Integer targetYear, UUID modelUuid) {
-
-    List<String> compareList = mapSheetMngCoreService.getMapSheetMngHst(compareYear);
-    List<String> targetList = mapSheetMngCoreService.getMapSheetMngHst(targetYear);
-
-    log.info(
-        "hst list count compareList = {}, targetList = {}", compareList.size(), targetList.size());
-
-    Set<String> compareSet = new HashSet<>(compareList);
-    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 = getSceneInference(compareYear.toString(), filteredTargetList, "", "");
-
-    Scene modelTargetPath = getSceneInference(targetYear.toString(), filteredTargetList, "", "");
-
-    // ai 서버에 전달할 파라미터 생성
-    pred_requests_areas predRequestsAreas = new pred_requests_areas();
-    predRequestsAreas.setInput1_year(compareYear);
-    predRequestsAreas.setInput2_year(targetYear);
-    predRequestsAreas.setInput1_scene_path(modelComparePath.getFilePath());
-    predRequestsAreas.setInput2_scene_path(modelTargetPath.getFilePath());
-
-    InferenceSendDto m1 = this.getModelInfo(modelUuid);
-    m1.setPred_requests_areas(predRequestsAreas);
-
-    // ai 추론 실행 api 호출
-    Long batchId = ensureAccepted(m1);
-  }
-
-  private Scene getSceneInference(
-      String yyyy, List<String> mapSheetNums, String mapSheetScope, String detectOption) {
-    return mapSheetMngCoreService.getSceneInference(
-        yyyy, mapSheetNums, mapSheetScope, detectOption);
-  }
-
-  /**
-   * 추론 AI API 호출
-   *
-   * @param dto
-   */
-  private Long ensureAccepted(InferenceSendDto dto) {
-
-    if (dto == null) {
-      log.warn("not InferenceSendDto dto");
-      throw new CustomApiException("BAD_REQUEST", HttpStatus.BAD_REQUEST);
-    }
-
-    // 1) 요청 로그
-    try {
-      log.info("Inference request dto={}", objectMapper.writeValueAsString(dto));
-    } catch (JsonProcessingException e) {
-      log.warn("Failed to serialize inference dto", e);
-    }
-
-    // 3) HTTP 호출
-    HttpHeaders headers = new HttpHeaders();
-    headers.setContentType(MediaType.APPLICATION_JSON);
-    headers.setAccept(List.of(MediaType.APPLICATION_JSON));
-
-    ExternalCallResult<String> result =
-        externalHttpClient.call(inferenceUrl, HttpMethod.POST, dto, headers, String.class);
-
-    if (result.statusCode() < 200 || result.statusCode() >= 300) {
-      log.error("Inference API failed. status={}, body={}", result.statusCode(), result.body());
-      throw new CustomApiException("BAD_GATEWAY", HttpStatus.BAD_GATEWAY);
-    }
-
-    // 4) 응답 파싱
-    try {
-      List<Map<String, Object>> list =
-          objectMapper.readValue(result.body(), new TypeReference<>() {});
-
-      if (list.isEmpty()) {
-        throw new IllegalStateException("Inference response is empty");
-      }
-
-      Object batchIdObj = list.get(0).get("batch_id");
-      if (batchIdObj == null) {
-        throw new IllegalStateException("batch_id not found in response");
-      }
-
-      return Long.valueOf(batchIdObj.toString());
-
-    } catch (Exception e) {
-      log.error("Failed to parse inference response. body={}", result.body(), e);
-      throw new CustomApiException("INVALID_INFERENCE_RESPONSE", HttpStatus.BAD_GATEWAY);
-    }
-  }
-
-  /**
-   * 모델정보 조회 dto 생성 후 반환
-   *
-   * @param uuid
-   * @return
-   */
-  private InferenceSendDto getModelInfo(UUID uuid) {
-
-    Basic modelInfo = modelMngCoreService.findByModelUuid(uuid);
-
-    String cdModelPath = "";
-    String cdModelConfigPath = "";
-    String cdClsModelPath = "";
-
-    if (modelInfo.getCdModelPath() != null && modelInfo.getCdModelFileName() != null) {
-      cdModelPath =
-          Paths.get(modelInfo.getCdModelPath(), modelInfo.getCdModelFileName()).toString();
-    }
-
-    if (modelInfo.getCdModelConfig() != null && modelInfo.getCdModelConfigFileName() != null) {
-      cdModelConfigPath =
-          Paths.get(modelInfo.getCdModelConfig(), modelInfo.getCdModelConfigFileName()).toString();
-    }
-
-    if (modelInfo.getClsModelPath() != null && modelInfo.getClsModelFileName() != null) {
-      cdClsModelPath =
-          Paths.get(modelInfo.getClsModelPath(), modelInfo.getClsModelFileName()).toString();
-    }
-
-    String modelType = "";
-
-    if (modelInfo.getModelType().equals(ModelType.G1.getId())) {
-      modelType = ModelType.G1.getId();
-    } else if (modelInfo.getModelType().equals(ModelType.G2.getId())) {
-      modelType = ModelType.G2.getId();
-    } else {
-      modelType = ModelType.G3.getId();
-    }
-
-    InferenceSendDto sendDto = new InferenceSendDto();
-    sendDto.setModel_version(modelInfo.getModelVer());
-    sendDto.setCd_model_path(cdModelPath);
-    sendDto.setCd_model_config(cdModelConfigPath);
-    sendDto.setCls_model_path(cdClsModelPath);
-    sendDto.setCls_model_version(modelInfo.getModelVer());
-    sendDto.setCd_model_type(modelType);
-    sendDto.setPriority(5.0);
-    return sendDto;
-  }
-}

src/main/java/com/kamco/cd/kamcoback/postgres/repository/Inference/MapSheetLearnRepositoryCustom.java

@@ -73,8 +73,6 @@ public interface MapSheetLearnRepositoryCustom {
    */
   MapSheetLearnEntity getProcessing();
 
-  Integer getLearnStage(Integer compareYear, Integer targetYear);
-
   /**
    * 추론 결과 정보 조회
    *

src/main/java/com/kamco/cd/kamcoback/postgres/repository/Inference/MapSheetLearnRepositoryImpl.java

@@ -291,24 +291,6 @@ public class MapSheetLearnRepositoryImpl implements MapSheetLearnRepositoryCusto
         .fetchOne();
   }
 
-  @Override
-  public Integer getLearnStage(Integer compareYear, Integer targetYear) {
-    Integer stage =
-        queryFactory
-            .select(mapSheetLearnEntity.stage)
-            .from(mapSheetLearnEntity)
-            .where(
-                mapSheetLearnEntity
-                    .compareYyyy
-                    .eq(compareYear)
-                    .and(mapSheetLearnEntity.targetYyyy.eq(targetYear)))
-            .orderBy(mapSheetLearnEntity.id.desc())
-            .limit(1)
-            .fetchOne();
-
-    return stage == null ? 1 : stage + 1;
-  }
-
   @Override
   public AnalResultInfo getInferenceResultInfo(UUID uuid) {
     QModelMngEntity m1 = new QModelMngEntity("m1");

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

@@ -64,6 +64,12 @@ public interface MapSheetMngRepositoryCustom {
 
   List<MapSheetMngDto.MngFilesDto> findByHstUidMapSheetFileList(Long hstUid);
 
+  /**
+   * 변화탐지 실행 가능 기준 연도 조회
+   *
+   * @param req 조회 연도, 도엽번호 목록,
+   * @return
+   */
   List<MngListDto> findByHstMapSheetTargetList(InferenceResultDto.RegReq req);
 
   List<MngListDto> findByHstMapSheetTargetList(int mngYyyy, List<String> mapIds);