라벨링툴 count 종료된 회차는 count하지 않게 조건 추가

Dockerfile-prod

@@ -1,5 +1,6 @@
 # 1단계에서 만든 로컬 베이스 이미지를 사용
-FROM 127.0.0.1:18082/kamco-cd/base-java21-gdal:1.0
+FROM 192.168.2.73:18082/kamco-cd/base-java21-gdal:1.0
+FROM 192.168.2.73:18082/kamco-cd/base-java21-gdal:1.0
 
 # 사용자 설정 (앱 별로 다를 수 있으므로 여기에 유지)
 ARG UID=1000

docker-compose-dev.yml

@@ -15,6 +15,10 @@ services:
       - SPRING_PROFILES_ACTIVE=dev
       - TZ=Asia/Seoul
     volumes:
+      - /mnt/nfs_share/images:/app/original-images
+      - /mnt/nfs_share/model_output:/app/model-outputs
+      - /mnt/nfs_share/train_dataset:/app/train-dataset
+      - /mnt/nfs_share/tmp:/app/tmp
       - /kamco-nfs:/kamco-nfs
     networks:
       - kamco-cds

docker-compose-prod.yml

@@ -15,7 +15,11 @@ services:
       - SPRING_PROFILES_ACTIVE=dev
       - TZ=Asia/Seoul
     volumes:
-      - /data:/kamco-nfs
+      - /mnt/nfs_share/images:/app/original-images
+      - /mnt/nfs_share/model_output:/app/model-outputs
+      - /mnt/nfs_share/train_dataset:/app/train-dataset
+      - /mnt/nfs_share/tmp:/app/tmp
+      - /kamco-nfs:/kamco-nfs
     networks:
       - kamco-cds
     restart: unless-stopped

src/main/java/com/kamco/cd/kamcoback/auth/JwtAuthenticationFilter.java

@@ -18,13 +18,12 @@ import org.springframework.web.filter.OncePerRequestFilter;
 @RequiredArgsConstructor
 public class JwtAuthenticationFilter extends OncePerRequestFilter {
 
-  private static final AntPathMatcher PATH_MATCHER = new AntPathMatcher();
-  private static final String[] EXCLUDE_PATHS = {
-    //    "/api/auth/signin", "/api/auth/refresh", "/api/auth/logout", "/api/members/*/password"
-    "/api/auth/signin", "/api/auth/refresh", "/api/auth/logout"
-  };
   private final JwtTokenProvider jwtTokenProvider;
   private final UserDetailsService userDetailsService;
+  private static final AntPathMatcher PATH_MATCHER = new AntPathMatcher();
+  private static final String[] EXCLUDE_PATHS = {
+    "/api/auth/signin", "/api/auth/refresh", "/api/auth/logout", "/api/members/*/password"
+  };
 
   @Override
   protected void doFilterInternal(

src/main/java/com/kamco/cd/kamcoback/common/download/DownloadAuditEventListener.java

@@ -1,92 +0,0 @@
-package com.kamco.cd.kamcoback.common.download;
-
-import com.fasterxml.jackson.databind.ObjectMapper;
-import com.kamco.cd.kamcoback.common.download.dto.DownloadAuditEvent;
-import com.kamco.cd.kamcoback.menu.dto.MenuDto;
-import com.kamco.cd.kamcoback.menu.service.MenuService;
-import com.kamco.cd.kamcoback.postgres.entity.AuditLogEntity;
-import com.kamco.cd.kamcoback.postgres.repository.log.AuditLogRepository;
-import java.util.Comparator;
-import java.util.LinkedHashMap;
-import java.util.List;
-import java.util.Objects;
-import lombok.RequiredArgsConstructor;
-import lombok.extern.slf4j.Slf4j;
-import org.springframework.context.event.EventListener;
-import org.springframework.scheduling.annotation.Async;
-import org.springframework.stereotype.Component;
-import org.springframework.transaction.annotation.Propagation;
-import org.springframework.transaction.annotation.Transactional;
-
-@Slf4j
-@Component
-@RequiredArgsConstructor
-public class DownloadAuditEventListener {
-
-  private final AuditLogRepository auditLogRepository;
-  private final MenuService menuService;
-  private final ObjectMapper objectMapper;
-
-  @Async("auditLogExecutor")
-  @Transactional(propagation = Propagation.REQUIRES_NEW)
-  @EventListener
-  public void onDownloadAudit(DownloadAuditEvent ev) {
-    try {
-      String menuUid = resolveMenuUid(ev.normalizedUri());
-      if (menuUid == null) {
-        // menuUid null 불가 -> 스킵
-        log.warn(
-            "MenuUid not resolved. skip audit. uri={}, normalized={}",
-            ev.requestUri(),
-            ev.normalizedUri());
-        return;
-      }
-
-      AuditLogEntity logEntity =
-          AuditLogEntity.forFileDownload(
-              ev.userId(), ev.requestUri(), menuUid, ev.ip(), ev.status(), ev.downloadUuid());
-
-      auditLogRepository.save(logEntity);
-
-    } catch (Exception e) {
-      // 본 요청과 분리되어야 함
-      log.warn("Download audit save failed. uri={}, err={}", ev.requestUri(), e.toString());
-    }
-  }
-
-  private String resolveMenuUid(String normalizedUri) {
-    try {
-      List<?> list = menuService.getFindAll();
-
-      List<MenuDto.Basic> basics =
-          list.stream()
-              .map(
-                  item -> {
-                    if (item instanceof LinkedHashMap<?, ?> map) {
-                      return objectMapper.convertValue(map, MenuDto.Basic.class);
-                    } else if (item instanceof MenuDto.Basic dto) {
-                      return dto;
-                    }
-                    return null;
-                  })
-              .filter(Objects::nonNull)
-              .toList();
-
-      MenuDto.Basic basic =
-          basics.stream()
-              .filter(m -> m.getMenuUrl() != null && normalizedUri.startsWith(m.getMenuUrl()))
-              .max(Comparator.comparingInt(m -> m.getMenuUrl().length()))
-              .orElse(null);
-
-      if (basic == null) return null;
-
-      String menuUidStr = basic.getMenuUid(); // ← String
-      if (menuUidStr == null || menuUidStr.isBlank()) return null;
-
-      return menuUidStr; // ← Long 변환
-
-    } catch (Exception e) {
-      return null;
-    }
-  }
-}

src/main/java/com/kamco/cd/kamcoback/common/download/DownloadExecutor.java

@@ -0,0 +1,48 @@
+package com.kamco.cd.kamcoback.common.download;
+
+import com.kamco.cd.kamcoback.common.download.dto.DownloadSpec;
+import com.kamco.cd.kamcoback.common.utils.UserUtil;
+import java.io.IOException;
+import java.io.InputStream;
+import java.nio.file.Files;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.HttpHeaders;
+import org.springframework.http.MediaType;
+import org.springframework.http.ResponseEntity;
+import org.springframework.stereotype.Service;
+import org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
+
+@Service
+@RequiredArgsConstructor
+public class DownloadExecutor {
+
+  private final UserUtil userUtil;
+
+  public ResponseEntity<StreamingResponseBody> stream(DownloadSpec spec) throws IOException {
+
+    if (!Files.isReadable(spec.filePath())) {
+      return ResponseEntity.notFound().build();
+    }
+
+    StreamingResponseBody body =
+        os -> {
+          try (InputStream in = Files.newInputStream(spec.filePath())) {
+            in.transferTo(os);
+            os.flush();
+          } catch (Exception e) {
+            // 고용량은 중간 끊김 흔하니까 throw 금지
+          }
+        };
+
+    String fileName =
+        spec.downloadName() != null
+            ? spec.downloadName()
+            : spec.filePath().getFileName().toString();
+
+    return ResponseEntity.ok()
+        .contentType(
+            spec.contentType() != null ? spec.contentType() : MediaType.APPLICATION_OCTET_STREAM)
+        .header(HttpHeaders.CONTENT_DISPOSITION, "attachment; filename=\"" + fileName + "\"")
+        .body(body);
+  }
+}

src/main/java/com/kamco/cd/kamcoback/common/download/RangeDownloadResponder.java

@@ -1,79 +0,0 @@
-package com.kamco.cd.kamcoback.common.download;
-
-import jakarta.servlet.http.HttpServletRequest;
-import java.io.IOException;
-import java.nio.file.Files;
-import java.nio.file.Path;
-import java.util.List;
-import org.springframework.core.io.FileSystemResource;
-import org.springframework.core.io.Resource;
-import org.springframework.core.io.support.ResourceRegion;
-import org.springframework.http.HttpHeaders;
-import org.springframework.http.HttpRange;
-import org.springframework.http.MediaType;
-import org.springframework.http.ResponseEntity;
-import org.springframework.stereotype.Component;
-
-@Component
-public class RangeDownloadResponder {
-
-  public ResponseEntity<?> buildZipResponse(
-      Path filePath, String downloadFileName, HttpServletRequest request) throws IOException {
-
-    if (!Files.isRegularFile(filePath)) {
-      return ResponseEntity.notFound().build();
-    }
-
-    long totalSize = Files.size(filePath);
-    Resource resource = new FileSystemResource(filePath);
-
-    String disposition = "attachment; filename=\"" + downloadFileName + "\"";
-    String rangeHeader = request.getHeader(HttpHeaders.RANGE);
-
-    // 🔥 공통 헤더 (여기 고정)
-    ResponseEntity.BodyBuilder base =
-        ResponseEntity.ok()
-            .contentType(MediaType.APPLICATION_OCTET_STREAM)
-            .header(HttpHeaders.CONTENT_DISPOSITION, disposition)
-            .header(HttpHeaders.ACCEPT_RANGES, "bytes")
-            .header("X-Accel-Buffering", "no");
-
-    if (rangeHeader == null || rangeHeader.isBlank()) {
-      return base.contentLength(totalSize).body(resource);
-    }
-
-    List<HttpRange> ranges;
-    try {
-      ranges = HttpRange.parseRanges(rangeHeader);
-    } catch (IllegalArgumentException ex) {
-      return ResponseEntity.status(416)
-          .header(HttpHeaders.CONTENT_RANGE, "bytes */" + totalSize)
-          .header("X-Accel-Buffering", "no")
-          .build();
-    }
-
-    HttpRange range = ranges.get(0);
-
-    long start = range.getRangeStart(totalSize);
-    long end = range.getRangeEnd(totalSize);
-
-    if (start >= totalSize) {
-      return ResponseEntity.status(416)
-          .header(HttpHeaders.CONTENT_RANGE, "bytes */" + totalSize)
-          .header("X-Accel-Buffering", "no")
-          .build();
-    }
-
-    long regionLength = end - start + 1;
-    ResourceRegion region = new ResourceRegion(resource, start, regionLength);
-
-    return ResponseEntity.status(206)
-        .contentType(MediaType.APPLICATION_OCTET_STREAM)
-        .header(HttpHeaders.CONTENT_DISPOSITION, disposition)
-        .header(HttpHeaders.ACCEPT_RANGES, "bytes")
-        .header("X-Accel-Buffering", "no")
-        .header(HttpHeaders.CONTENT_RANGE, "bytes " + start + "-" + end + "/" + totalSize)
-        .contentLength(regionLength)
-        .body(region);
-  }
-}

src/main/java/com/kamco/cd/kamcoback/common/download/dto/DownloadAuditEvent.java

@@ -1,11 +0,0 @@
-package com.kamco.cd.kamcoback.common.download.dto;
-
-import java.util.UUID;
-
-public record DownloadAuditEvent(
-    Long userId,
-    String requestUri,
-    String normalizedUri,
-    String ip,
-    int status,
-    UUID downloadUuid) {}

src/main/java/com/kamco/cd/kamcoback/common/download/dto/DownloadSpec.java

@@ -0,0 +1,12 @@
+package com.kamco.cd.kamcoback.common.download.dto;
+
+import java.nio.file.Path;
+import java.util.UUID;
+import org.springframework.http.MediaType;
+
+public record DownloadSpec(
+    UUID uuid, // 다운로드 식별(로그/정책용)
+    Path filePath, // 실제 파일 경로
+    String downloadName, // 사용자에게 보일 파일명
+    MediaType contentType // 보통 OCTET_STREAM
+    ) {}

src/main/java/com/kamco/cd/kamcoback/common/exception/CustomApiException.java

@@ -27,10 +27,4 @@ public class CustomApiException extends RuntimeException {
     this.codeName = errorCode.getCode();
     this.status = errorCode.getStatus();
   }
-
-  public CustomApiException(String codeName, HttpStatus status, Throwable cause) {
-    super(codeName, cause);
-    this.codeName = codeName;
-    this.status = status;
-  }
 }

src/main/java/com/kamco/cd/kamcoback/common/service/ExternalJarRunner.java

@@ -7,14 +7,11 @@ import java.util.ArrayList;
 import java.util.List;
 import java.util.concurrent.TimeUnit;
 import lombok.extern.log4j.Log4j2;
-import org.springframework.beans.factory.annotation.Value;
 import org.springframework.stereotype.Component;
 
 @Log4j2
 @Component
 public class ExternalJarRunner {
-  @Value("${spring.profiles.active}")
-  private String profile;
 
   private static final long TIMEOUT_MINUTES = TimeUnit.DAYS.toMinutes(3);
 
@@ -43,7 +40,7 @@ public class ExternalJarRunner {
     if (mode != null && !mode.isEmpty()) {
       addArg(args, "converter.mode", mode);
     }
-    addArg(args, "spring.profiles.active", profile);
+
     execJar(jarPath, args);
   }
 
@@ -60,7 +57,6 @@ public class ExternalJarRunner {
     addArg(args, "upload-shp", register);
     //    addArg(args, "layer", layer);
 
-    addArg(args, "spring.profiles.active", profile);
     execJar(jarPath, args);
   }
 

src/main/java/com/kamco/cd/kamcoback/common/utils/FIleChecker.java

@@ -300,12 +300,10 @@ public class FIleChecker {
                     String parentPath = path.getParent().toString();
                     String fullPath = path.toAbsolutePath().toString();
 
-                    boolean isShowHide =
-                        !parentFolderNm.equals("kamco-nfs"); // 폴더 리스트에 kamco-nfs 하위만 나오도록 처리
-                    //              boolean isValid =
-                    //                !NameValidator.containsKorean(folderNm)
-                    //                  && !NameValidator.containsWhitespaceRegex(folderNm)
-                    //                  && !parentFolderNm.equals("kamco-nfs");
+                    boolean isValid =
+                        !NameValidator.containsKorean(folderNm)
+                            && !NameValidator.containsWhitespaceRegex(folderNm)
+                            && !parentFolderNm.equals("kamco-nfs");
 
                     File file = new File(fullPath);
                     int childCnt = getChildFolderCount(file);
@@ -319,7 +317,7 @@ public class FIleChecker {
                         depth,
                         childCnt,
                         lastModified,
-                        isShowHide);
+                        isValid);
                   })
               .collect(Collectors.toList());
 

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

@@ -1,64 +1,98 @@
 package com.kamco.cd.kamcoback.config;
 
-import com.kamco.cd.kamcoback.common.download.dto.DownloadAuditEvent;
+import com.fasterxml.jackson.databind.ObjectMapper;
+import com.kamco.cd.kamcoback.common.utils.HeaderUtil;
 import com.kamco.cd.kamcoback.common.utils.UserUtil;
 import com.kamco.cd.kamcoback.config.api.ApiLogFunction;
-import jakarta.servlet.DispatcherType;
+import com.kamco.cd.kamcoback.menu.dto.MenuDto;
+import com.kamco.cd.kamcoback.menu.service.MenuService;
+import com.kamco.cd.kamcoback.postgres.entity.AuditLogEntity;
+import com.kamco.cd.kamcoback.postgres.repository.log.AuditLogRepository;
 import jakarta.servlet.http.HttpServletRequest;
 import jakarta.servlet.http.HttpServletResponse;
+import java.util.Comparator;
+import java.util.LinkedHashMap;
+import java.util.List;
+import java.util.Objects;
 import java.util.UUID;
-import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
-import org.springframework.context.ApplicationEventPublisher;
+import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.web.servlet.HandlerInterceptor;
 
 @Slf4j
 @Component
-@RequiredArgsConstructor
 public class FileDownloadInteceptor implements HandlerInterceptor {
 
-  private final ApplicationEventPublisher publisher;
+  private final AuditLogRepository auditLogRepository;
+  private final MenuService menuService;
   private final UserUtil userUtil;
 
+  @Autowired private ObjectMapper objectMapper;
+
+  public FileDownloadInteceptor(
+      AuditLogRepository auditLogRepository, MenuService menuService, UserUtil userUtil) {
+    this.auditLogRepository = auditLogRepository;
+    this.menuService = menuService;
+    this.userUtil = userUtil;
+  }
+
   @Override
-  public void afterCompletion(
-      HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) {
+  public boolean preHandle(
+      HttpServletRequest request, HttpServletResponse response, Object handler) {
 
-    String uri = request.getRequestURI();
-    if (uri == null || !uri.contains("/download")) return;
-    if (request.getDispatcherType() != DispatcherType.REQUEST) return;
+    if (!request.getRequestURI().contains("/download")) return true;
 
-    Long userId;
-    try {
-      userId = userUtil.getId();
-      if (userId == null) return; // userId null 불가면 스킵
-    } catch (Exception e) {
-      log.warn("Download audit userId resolve failed. uri={}, err={}", uri, e.toString());
+    if (request.getDispatcherType() != jakarta.servlet.DispatcherType.REQUEST) {
+      return true;
+    }
+
+    saveLog(request, response);
+
+    return true;
+  }
+
+  private void saveLog(HttpServletRequest request, HttpServletResponse response) {
+    // 파일 다운로드 API만 필터링
+    if (!request.getRequestURI().contains("/download")) {
       return;
     }
 
+    Long userId = userUtil.getId();
     String ip = ApiLogFunction.getClientIp(request);
-    int status = response.getStatus();
-    String normalizedUri = uri.replace("/api", "");
 
-    UUID downloadUuid = extractUuidFromUri(uri);
-    if (downloadUuid == null) {
-      log.warn("Download UUID parse failed. uri={}", uri);
-      return; // downloadUuid null 불가 -> 스킵
-    }
+    List<?> list = menuService.getFindAll();
+    List<MenuDto.Basic> result =
+        list.stream()
+            .map(
+                item -> {
+                  if (item instanceof LinkedHashMap<?, ?> map) {
+                    return objectMapper.convertValue(map, MenuDto.Basic.class);
+                  } else if (item instanceof MenuDto.Basic dto) {
+                    return dto;
+                  } else {
+                    throw new IllegalStateException("Unsupported cache type: " + item.getClass());
+                  }
+                })
+            .toList();
 
-    publisher.publishEvent(
-        new DownloadAuditEvent(userId, uri, normalizedUri, ip, status, downloadUuid));
-  }
+    String normalizedUri = request.getRequestURI().replace("/api", "");
+    MenuDto.Basic basic =
+        result.stream()
+            .filter(
+                menu -> menu.getMenuUrl() != null && normalizedUri.startsWith(menu.getMenuUrl()))
+            .max(Comparator.comparingInt(m -> m.getMenuUrl().length()))
+            .orElse(null);
 
-  private UUID extractUuidFromUri(String uri) {
-    try {
-      String[] parts = uri.split("/");
-      String last = parts[parts.length - 1];
-      return UUID.fromString(last);
-    } catch (Exception e) {
-      return null;
-    }
+    AuditLogEntity log =
+        AuditLogEntity.forFileDownload(
+            userId,
+            request.getRequestURI(),
+            Objects.requireNonNull(basic).getMenuUid(),
+            ip,
+            response.getStatus(),
+            UUID.fromString(HeaderUtil.get(request, "kamco-download-uuid")));
+
+    auditLogRepository.save(log);
   }
 }

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

@@ -95,9 +95,9 @@ public class SecurityConfig {
                         "/api/auth/refresh",
                         "/api/auth/logout",
                         "/swagger-ui/**",
+                        "/api/members/*/password",
                         "/v3/api-docs/**",
                         "/chunk_upload_test.html",
-                        "/download_progress_test.html",
                         "/api/model/file-chunk-upload",
                         "/api/upload/file-chunk-upload",
                         "/api/upload/chunk-upload-complete",
@@ -112,7 +112,6 @@ public class SecurityConfig {
                         "/api/user/**",
                         "/api/my/menus",
                         "/api/common-code/**",
-                        "/api/members/*/password",
                         "/api/training-data/label/**",
                         "/api/training-data/review/**")
                     .authenticated()

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

@@ -1,6 +1,7 @@
 package com.kamco.cd.kamcoback.inference;
 
-import com.kamco.cd.kamcoback.common.download.RangeDownloadResponder;
+import com.kamco.cd.kamcoback.common.download.DownloadExecutor;
+import com.kamco.cd.kamcoback.common.download.dto.DownloadSpec;
 import com.kamco.cd.kamcoback.common.exception.CustomApiException;
 import com.kamco.cd.kamcoback.config.api.ApiResponseDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceDetailDto;
@@ -25,7 +26,6 @@ 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 jakarta.servlet.http.HttpServletRequest;
 import jakarta.validation.Valid;
 import java.io.IOException;
 import java.nio.file.Path;
@@ -34,8 +34,8 @@ import java.util.List;
 import java.util.Map;
 import java.util.UUID;
 import lombok.RequiredArgsConstructor;
-import lombok.extern.log4j.Log4j2;
 import org.springframework.data.domain.Page;
+import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.DeleteMapping;
 import org.springframework.web.bind.annotation.GetMapping;
@@ -45,9 +45,9 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
 
 @Tag(name = "추론관리", description = "추론관리 API")
-@Log4j2
 @RequestMapping("/api/inference")
 @RequiredArgsConstructor
 @RestController
@@ -56,7 +56,7 @@ public class InferenceResultApiController {
   private final InferenceResultService inferenceResultService;
   private final MapSheetMngService mapSheetMngService;
   private final ModelMngService modelMngService;
-  private final RangeDownloadResponder rangeDownloadResponder;
+  private final DownloadExecutor downloadExecutor;
 
   @Operation(summary = "추론관리 목록", description = "어드민 홈 > 추론관리 > 추론관리 > 추론관리 목록")
   @ApiResponses(
@@ -195,7 +195,7 @@ public class InferenceResultApiController {
           LocalDate endDttm,
       @Parameter(description = "키워드 (모델버전)", example = "M1.H1.E28") @RequestParam(required = false)
           String searchVal,
-      @Parameter(description = "타입", example = "G1") @RequestParam(required = false)
+      @Parameter(description = "타입", example = "M1") @RequestParam(required = false)
           String modelType,
       @RequestParam(defaultValue = "0") int page,
       @RequestParam(defaultValue = "20") int size) {
@@ -356,8 +356,9 @@ public class InferenceResultApiController {
         @ApiResponse(responseCode = "404", description = "파일 없음", content = @Content),
         @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
       })
-  @GetMapping("/download/{uuid}")
-  public ResponseEntity<?> download(@PathVariable UUID uuid, HttpServletRequest request)
+  @GetMapping(value = "/download/{uuid}")
+  public ResponseEntity<StreamingResponseBody> download(
+      @Parameter(example = "69c4e56c-e0bf-4742-9225-bba9aae39052") @PathVariable UUID uuid)
       throws IOException {
 
     String path;
@@ -373,8 +374,8 @@ public class InferenceResultApiController {
 
     Path zipPath = Path.of(path);
 
-    // Range + 200/206/416 공통 처리 (추가 헤더 포함)
-    return rangeDownloadResponder.buildZipResponse(zipPath, uid + ".zip", request);
+    return downloadExecutor.stream(
+        new DownloadSpec(uuid, zipPath, uid + ".zip", MediaType.APPLICATION_OCTET_STREAM));
   }
 
   @Operation(summary = "shp 파일 다운로드 이력 조회", description = "추론관리 분석결과 shp 파일 다운로드 이력 조회")
@@ -414,7 +415,7 @@ public class InferenceResultApiController {
     downloadReq.setStartDate(strtDttm);
     downloadReq.setEndDate(endDttm);
     downloadReq.setSearchValue(searchValue);
-    downloadReq.setRequestUri("/api/inference/download/" + uuid);
+    downloadReq.setRequestUri("/api/inference/download-audit/download/" + uuid);
 
     return ApiResponseDto.ok(inferenceResultService.getDownloadAudit(searchReq, downloadReq));
   }

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

@@ -246,15 +246,15 @@ public class InferenceResultDto {
     @NotBlank
     private String title;
 
-    @Schema(description = "G1", example = "b40e0f68-c1d8-49fc-93f9-a36270093861")
+    @Schema(description = "M1", example = "b40e0f68-c1d8-49fc-93f9-a36270093861")
     @NotNull
     private UUID model1Uuid;
 
-    @Schema(description = "G2", example = "ec92b7d2-b5a3-4915-9bdf-35fb3ca8ad27")
+    @Schema(description = "M2", example = "ec92b7d2-b5a3-4915-9bdf-35fb3ca8ad27")
     @NotNull
     private UUID model2Uuid;
 
-    @Schema(description = "G3", example = "37f45782-8ccf-4cf6-911c-a055a1510d39")
+    @Schema(description = "M3", example = "37f45782-8ccf-4cf6-911c-a055a1510d39")
     @NotNull
     private UUID model3Uuid;
 
@@ -297,30 +297,6 @@ public class InferenceResultDto {
   @Schema(name = "InferenceStatusDetailDto", description = "추론(변화탐지) 진행상태")
   public static class InferenceStatusDetailDto {
 
-    @Schema(description = "모델1 사용시간 시작일시")
-    @JsonFormatDttm
-    ZonedDateTime m1ModelStartDttm;
-
-    @Schema(description = "모델2 사용시간 시작일시")
-    @JsonFormatDttm
-    ZonedDateTime m2ModelStartDttm;
-
-    @Schema(description = "모델3 사용시간 시작일시")
-    @JsonFormatDttm
-    ZonedDateTime m3ModelStartDttm;
-
-    @Schema(description = "모델1 사용시간 종료일시")
-    @JsonFormatDttm
-    ZonedDateTime m1ModelEndDttm;
-
-    @Schema(description = "모델2 사용시간 종료일시")
-    @JsonFormatDttm
-    ZonedDateTime m2ModelEndDttm;
-
-    @Schema(description = "모델3 사용시간 종료일시")
-    @JsonFormatDttm
-    ZonedDateTime m3ModelEndDttm;
-
     @Schema(description = "탐지대상 도엽수")
     private Long detectingCnt;
 
@@ -360,6 +336,30 @@ public class InferenceResultDto {
     @Schema(description = "모델3 분석 실패")
     private Integer m3FailedJobs;
 
+    @Schema(description = "모델1 사용시간 시작일시")
+    @JsonFormatDttm
+    ZonedDateTime m1ModelStartDttm;
+
+    @Schema(description = "모델2 사용시간 시작일시")
+    @JsonFormatDttm
+    ZonedDateTime m2ModelStartDttm;
+
+    @Schema(description = "모델3 사용시간 시작일시")
+    @JsonFormatDttm
+    ZonedDateTime m3ModelStartDttm;
+
+    @Schema(description = "모델1 사용시간 종료일시")
+    @JsonFormatDttm
+    ZonedDateTime m1ModelEndDttm;
+
+    @Schema(description = "모델2 사용시간 종료일시")
+    @JsonFormatDttm
+    ZonedDateTime m2ModelEndDttm;
+
+    @Schema(description = "모델3 사용시간 종료일시")
+    @JsonFormatDttm
+    ZonedDateTime m3ModelEndDttm;
+
     @Schema(description = "변화탐지 제목")
     private String title;
 
@@ -496,19 +496,19 @@ public class InferenceResultDto {
       return MapSheetScope.getDescByCode(this.mapSheetScope);
     }
 
-    @Schema(description = "G1 사용시간")
+    @Schema(description = "M1 사용시간")
     @JsonProperty("m1ElapsedTim")
     public String getM1ElapsedTime() {
       return formatElapsedTime(this.m1ModelStartDttm, this.m1ModelEndDttm);
     }
 
-    @Schema(description = "G2 사용시간")
+    @Schema(description = "M2 사용시간")
     @JsonProperty("m2ElapsedTim")
     public String getM2ElapsedTime() {
       return formatElapsedTime(this.m2ModelStartDttm, this.m2ModelEndDttm);
     }
 
-    @Schema(description = "G3 사용시간")
+    @Schema(description = "M3 사용시간")
     @JsonProperty("m3ElapsedTim")
     public String getM3ElapsedTime() {
       return formatElapsedTime(this.m3ModelStartDttm, this.m3ModelEndDttm);

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

@@ -248,7 +248,7 @@ public class InferenceResultService {
     saveInferenceAiDto.setUuid(uuid);
     saveInferenceAiDto.setBatchId(batchId);
     saveInferenceAiDto.setStatus(Status.IN_PROGRESS.getId());
-    saveInferenceAiDto.setType(ModelType.G1.getId());
+    saveInferenceAiDto.setType("M1");
     saveInferenceAiDto.setInferStartDttm(ZonedDateTime.now());
     saveInferenceAiDto.setModelComparePath(modelComparePath.getFilePath());
     saveInferenceAiDto.setModelTargetPath(modelTargetPath.getFilePath());
@@ -414,12 +414,12 @@ public class InferenceResultService {
 
     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();
+    if (modelInfo.getModelType().equals(ModelType.M1.getId())) {
+      modelType = "G1";
+    } else if (modelInfo.getModelType().equals(ModelType.M2.getId())) {
+      modelType = "G2";
     } else {
-      modelType = ModelType.G3.getId();
+      modelType = "G3";
     }
 
     InferenceSendDto sendDto = new InferenceSendDto();

src/main/java/com/kamco/cd/kamcoback/label/LabelAllocateApiController.java

@@ -1,6 +1,7 @@
 package com.kamco.cd.kamcoback.label;
 
-import com.kamco.cd.kamcoback.common.download.RangeDownloadResponder;
+import com.kamco.cd.kamcoback.common.download.DownloadExecutor;
+import com.kamco.cd.kamcoback.common.download.dto.DownloadSpec;
 import com.kamco.cd.kamcoback.config.api.ApiResponseDto;
 import com.kamco.cd.kamcoback.label.dto.LabelAllocateDto;
 import com.kamco.cd.kamcoback.label.dto.LabelAllocateDto.InferenceDetail;
@@ -22,13 +23,10 @@ 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 jakarta.servlet.http.HttpServletRequest;
 import jakarta.validation.Valid;
 import java.io.IOException;
-import java.nio.file.Files;
 import java.nio.file.Path;
 import java.nio.file.Paths;
-import java.time.LocalDate;
 import java.util.List;
 import java.util.UUID;
 import lombok.RequiredArgsConstructor;
@@ -36,6 +34,7 @@ import lombok.extern.slf4j.Slf4j;
 import org.apache.coyote.BadRequestException;
 import org.springframework.beans.factory.annotation.Value;
 import org.springframework.data.domain.Page;
+import org.springframework.http.MediaType;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.GetMapping;
 import org.springframework.web.bind.annotation.PathVariable;
@@ -44,6 +43,7 @@ import org.springframework.web.bind.annotation.RequestBody;
 import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RequestParam;
 import org.springframework.web.bind.annotation.RestController;
+import org.springframework.web.servlet.mvc.method.annotation.StreamingResponseBody;
 
 @Slf4j
 @Tag(name = "라벨링 작업 관리", description = "라벨링 작업 배정 및 통계 조회 API")
@@ -53,7 +53,7 @@ import org.springframework.web.bind.annotation.RestController;
 public class LabelAllocateApiController {
 
   private final LabelAllocateService labelAllocateService;
-  private final RangeDownloadResponder rangeDownloadResponder;
+  private final DownloadExecutor downloadExecutor;
 
   @Value("${file.dataset-response}")
   private String responsePath;
@@ -382,17 +382,19 @@ public class LabelAllocateApiController {
         @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
       })
   @GetMapping("/download/{uuid}")
-  public ResponseEntity<?> download(@PathVariable UUID uuid, HttpServletRequest request)
+  public ResponseEntity<StreamingResponseBody> download(
+      @Parameter(example = "6d8d49dc-0c9d-4124-adc7-b9ca610cc394") @PathVariable UUID uuid)
       throws IOException {
 
+    if (!labelAllocateService.isDownloadable(uuid)) {
+      throw new BadRequestException();
+    }
+
     String uid = labelAllocateService.findLearnUid(uuid);
     Path zipPath = Paths.get(responsePath).resolve(uid + ".zip");
 
-    if (!Files.isRegularFile(zipPath)) {
-      throw new BadRequestException();
-    }
-
-    return rangeDownloadResponder.buildZipResponse(zipPath, uid + ".zip", request);
+    return downloadExecutor.stream(
+        new DownloadSpec(uuid, zipPath, uid + ".zip", MediaType.APPLICATION_OCTET_STREAM));
   }
 
   @Operation(summary = "라벨 파일 다운로드 이력 조회", description = "라벨 파일 다운로드 이력 조회")
@@ -459,43 +461,4 @@ public class LabelAllocateApiController {
           UUID uuid) {
     return ApiResponseDto.ok(labelAllocateService.isDownloadable(uuid));
   }
-
-  @Operation(
-      summary = "라벨링작업 관리 > 추가 작업 배정(실태조사 추가되면)",
-      description = "라벨링작업 관리 > 추가 작업 배정(실태조사 추가되면)")
-  @ApiResponses(
-      value = {
-        @ApiResponse(
-            responseCode = "201",
-            description = "등록 성공",
-            content =
-                @Content(
-                    mediaType = "application/json",
-                    schema = @Schema(implementation = Long.class))),
-        @ApiResponse(responseCode = "400", description = "잘못된 요청 데이터", content = @Content),
-        @ApiResponse(responseCode = "404", description = "코드를 찾을 수 없음", content = @Content),
-        @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
-      })
-  @PostMapping("/allocate-add-stblt")
-  public ApiResponseDto<ApiResponseDto.ResponseObj> labelAllocateAddStblt(
-      @RequestBody @Valid LabelAllocateDto.AllocateAddStbltDto dto) {
-
-    return ApiResponseDto.okObject(
-        labelAllocateService.allocateAddStbltYn(
-            dto.getTotalCnt(), dto.getUuid(), dto.getLabelers(), dto.getBaseDate()));
-  }
-
-  @Operation(summary = "라벨링 추가 할당 가능한 건수", description = "라벨링 추가 할당 가능한 건수 API")
-  @ApiResponses(
-      value = {
-        @ApiResponse(responseCode = "200", description = "조회 성공"),
-        @ApiResponse(responseCode = "404", description = "코드를 찾을 수 없음"),
-        @ApiResponse(responseCode = "500", description = "서버 오류")
-      })
-  @GetMapping("/allocate-add-cnt")
-  public ApiResponseDto<Long> allocateAddCnt(
-      @RequestParam UUID uuid, @RequestParam LocalDate baseDate) {
-
-    return ApiResponseDto.ok(labelAllocateService.findAllocateAddCnt(uuid, baseDate));
-  }
 }

src/main/java/com/kamco/cd/kamcoback/label/dto/LabelAllocateDto.java

@@ -3,7 +3,6 @@ package com.kamco.cd.kamcoback.label.dto;
 import com.kamco.cd.kamcoback.common.utils.enums.CodeExpose;
 import com.kamco.cd.kamcoback.common.utils.enums.EnumType;
 import io.swagger.v3.oas.annotations.media.Schema;
-import java.time.LocalDate;
 import java.time.ZonedDateTime;
 import java.util.List;
 import java.util.UUID;
@@ -366,35 +365,9 @@ public class LabelAllocateDto {
   @AllArgsConstructor
   @NoArgsConstructor
   public static class InferenceLearnDto {
-
     private UUID analUuid;
     private String learnUid;
     private String analState;
     private Long analId;
   }
-
-  @Getter
-  @Setter
-  @AllArgsConstructor
-  public static class AllocateAddStbltDto {
-
-    @Schema(description = "총 잔여 건수", example = "179")
-    private Integer totalCnt;
-
-    @Schema(
-        description = "추가할당할 라벨러",
-        example =
-            """
-        [
-          "123454", "654321", "222233", "777222"
-        ]
-        """)
-    private List<String> labelers;
-
-    @Schema(description = "회차 마스터 key", example = "c0e77cc7-8c28-46ba-9ca4-11e90246ab44")
-    private UUID uuid;
-
-    @Schema(description = "기준일자", example = "2026-02-20")
-    private LocalDate baseDate;
-  }
 }

src/main/java/com/kamco/cd/kamcoback/label/service/LabelAllocateService.java

@@ -20,7 +20,6 @@ import com.kamco.cd.kamcoback.log.dto.AuditLogDto;
 import com.kamco.cd.kamcoback.log.dto.AuditLogDto.DownloadReq;
 import com.kamco.cd.kamcoback.postgres.core.AuditLogCoreService;
 import com.kamco.cd.kamcoback.postgres.core.LabelAllocateCoreService;
-import java.time.LocalDate;
 import java.util.List;
 import java.util.Objects;
 import java.util.UUID;
@@ -28,12 +27,11 @@ import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.domain.Page;
 import org.springframework.stereotype.Service;
-import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 
 @Slf4j
 @Service
-@Transactional(readOnly = true)
+@Transactional
 @RequiredArgsConstructor
 public class LabelAllocateService {
 
@@ -278,7 +276,6 @@ public class LabelAllocateService {
     return labelAllocateCoreService.findLabelingIngProcessCnt();
   }
 
-  @Transactional(propagation = Propagation.NOT_SUPPORTED)
   public String findLearnUid(UUID uuid) {
     return labelAllocateCoreService.findLearnUid(uuid);
   }
@@ -303,52 +300,4 @@ public class LabelAllocateService {
   public boolean isDownloadable(UUID uuid) {
     return labelAllocateCoreService.isDownloadable(uuid);
   }
-
-  /**
-   * 실태조사가 값 들어온 기간만큼 할당하는 로직 (최초 할당 이후 작업)
-   *
-   * @param uuid
-   * @param targetUsers
-   * @return
-   */
-  @Transactional
-  public ApiResponseDto.ResponseObj allocateAddStbltYn(
-      Integer totalCnt, UUID uuid, List<String> targetUsers, LocalDate baseDate) {
-
-    int userCount = targetUsers.size();
-    if (userCount == 0) {
-      return new ApiResponseDto.ResponseObj(ApiResponseCode.BAD_REQUEST, "추가 할당할 라벨러를 선택해주세요.");
-    }
-
-    int base = totalCnt / userCount;
-    int remainder = totalCnt % userCount;
-    Long lastId = null;
-    List<AllocateInfoDto> allIds =
-        labelAllocateCoreService.fetchNextIdsAddStbltYn(
-            uuid, baseDate, lastId, totalCnt.longValue());
-
-    // MapSheetAnalInferenceEntity analUid 가져오기
-    Long analUid = labelAllocateCoreService.findMapSheetAnalInferenceUid(uuid);
-
-    int index = 0;
-    for (int i = 0; i < userCount; i++) {
-      int assignCount = base;
-      // 마지막 사람에게 나머지 몰아주기
-      if (i == userCount - 1) {
-        assignCount += remainder;
-      }
-
-      int end = index + assignCount;
-      List<AllocateInfoDto> sub = allIds.subList(index, end);
-
-      labelAllocateCoreService.assignOwner(sub, targetUsers.get(i), analUid);
-      index = end;
-    }
-
-    return new ApiResponseDto.ResponseObj(ApiResponseCode.OK, "추가 할당이 완료되었습니다.");
-  }
-
-  public Long findAllocateAddCnt(UUID uuid, LocalDate baseDate) {
-    return labelAllocateCoreService.findAllocateAddCnt(uuid, baseDate);
-  }
 }

src/main/java/com/kamco/cd/kamcoback/mapsheet/service/MapSheetMngService.java

@@ -134,6 +134,7 @@ public class MapSheetMngService {
     }
 
     MngDto mngDto = mapSheetMngCoreService.findMapSheetMng(errDto.getMngYyyy());
+    String targetYearDir = mngDto.getMngPath();
 
     // 중복체크 -> 도엽50k/uuid 경로에 업로드 할 거라 overwrite 되지 않음
     //    if (!overwrite) {

src/main/java/com/kamco/cd/kamcoback/model/ModelMngApiController.java

@@ -41,6 +41,21 @@ public class ModelMngApiController {
 
   private final ModelMngService modelMngService;
 
+  @Value("${file.sync-root-dir}")
+  private String syncRootDir;
+
+  @Value("${file.sync-tmp-dir}")
+  private String syncTmpDir;
+
+  @Value("${file.sync-file-extention}")
+  private String syncFileExtention;
+
+  @Value("${file.dataset-dir}")
+  private String datasetDir;
+
+  @Value("${file.dataset-tmp-dir}")
+  private String datasetTmpDir;
+
   @Value("${file.model-dir}")
   private String modelDir;
 

src/main/java/com/kamco/cd/kamcoback/model/dto/ModelMngDto.java

@@ -21,9 +21,9 @@ public class ModelMngDto {
   @Getter
   @AllArgsConstructor
   public enum ModelType implements EnumType {
-    G1("G1"),
-    G2("G2"),
-    G3("G3");
+    M1("모델 M1"),
+    M2("모델 M2"),
+    M3("모델 M3");
 
     private final String desc;
 

src/main/java/com/kamco/cd/kamcoback/model/service/ModelMngService.java

@@ -35,6 +35,27 @@ public class ModelMngService {
 
   private final UploadService uploadService;
 
+  @Value("${file.sync-root-dir}")
+  private String syncRootDir;
+
+  @Value("${file.sync-tmp-dir}")
+  private String syncTmpDir;
+
+  @Value("${file.sync-file-extention}")
+  private String syncFileExtention;
+
+  @Value("${file.dataset-dir}")
+  private String datasetDir;
+
+  @Value("${file.dataset-tmp-dir}")
+  private String datasetTmpDir;
+
+  @Value("${file.model-dir}")
+  private String modelDir;
+
+  @Value("${file.model-tmp-dir}")
+  private String modelTmpDir;
+
   @Value("${file.pt-path}")
   private String ptPath;
 

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

@@ -19,7 +19,6 @@ import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.ResultList;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.SaveInferenceAiDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultsTestingDto;
 import com.kamco.cd.kamcoback.mapsheet.dto.MapSheetMngDto.MngListDto;
-import com.kamco.cd.kamcoback.model.dto.ModelMngDto.ModelType;
 import com.kamco.cd.kamcoback.postgres.entity.InferenceResultsTestingEntity;
 import com.kamco.cd.kamcoback.postgres.entity.MapInkx5kEntity;
 import com.kamco.cd.kamcoback.postgres.entity.MapSheetAnalDataInferenceEntity;
@@ -111,7 +110,7 @@ public class InferenceResultCoreService {
 
     MapSheetLearnEntity mapSheetLearnEntity = new MapSheetLearnEntity();
     mapSheetLearnEntity.setTitle(req.getTitle());
-    mapSheetLearnEntity.setRunningModelType(ModelType.G1.getId());
+    mapSheetLearnEntity.setRunningModelType("M1");
     mapSheetLearnEntity.setM1ModelUuid(req.getModel1Uuid());
     mapSheetLearnEntity.setM2ModelUuid(req.getModel2Uuid());
     mapSheetLearnEntity.setM3ModelUuid(req.getModel3Uuid());
@@ -302,7 +301,7 @@ public class InferenceResultCoreService {
 
   private void applyModelUpdate(MapSheetLearnEntity entity, SaveInferenceAiDto request) {
     switch (request.getType()) {
-      case "G1" ->
+      case "M1" ->
           applyModelFields(
               request,
               entity::setM1ModelBatchId,
@@ -312,7 +311,7 @@ public class InferenceResultCoreService {
               entity::setM1RunningJobs,
               entity::setM1CompletedJobs,
               entity::setM1FailedJobs);
-      case "G2" ->
+      case "M2" ->
           applyModelFields(
               request,
               entity::setM2ModelBatchId,
@@ -322,7 +321,7 @@ public class InferenceResultCoreService {
               entity::setM2RunningJobs,
               entity::setM2CompletedJobs,
               entity::setM2FailedJobs);
-      case "G3" ->
+      case "M3" ->
           applyModelFields(
               request,
               entity::setM3ModelBatchId,

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

@@ -257,20 +257,16 @@ public class LabelAllocateCoreService {
 
     // 파일이 있는지만 확인
     Path path = Paths.get(responsePath).resolve(dto.getLearnUid() + ".zip");
-    if (!Files.isRegularFile(path)) {
-      return false; // exists 포함
+
+    if (!Files.exists(path) || !Files.isRegularFile(path)) {
+      // 실제 파일만 true (디렉터리는 제외)
+      return false;
     }
 
-    String state = dto.getAnalState();
-    boolean isLabelingIng =
-        LabelMngState.ASSIGNED.getId().equals(state) || LabelMngState.ING.getId().equals(state);
-
-    if (isLabelingIng) {
-      Long analId = dto.getAnalId();
-      if (analId == null) {
-        return false;
-      }
-      return batchStepHistoryRepository.isDownloadable(analId);
+    // 다운로드 확인할 학습데이터가 라벨링중인 경우 파일 생성여부가 정상인지 확인
+    if (dto.getAnalState().equals(LabelMngState.ASSIGNED.getId())
+        || dto.getAnalState().equals(LabelMngState.ING.getId())) {
+      return batchStepHistoryRepository.isDownloadable(dto.getAnalId());
     }
 
     return true;
@@ -281,13 +277,4 @@ public class LabelAllocateCoreService {
         .findLearnUid(uuid)
         .orElseThrow(() -> new CustomApiException("NOT_FOUND_DATA", HttpStatus.NOT_FOUND));
   }
-
-  public List<AllocateInfoDto> fetchNextIdsAddStbltYn(
-      UUID uuid, LocalDate baseDate, Long lastId, Long totalCnt) {
-    return labelAllocateRepository.fetchNextIdsAddStbltYn(uuid, baseDate, lastId, totalCnt);
-  }
-
-  public Long findAllocateAddCnt(UUID uuid, LocalDate baseDate) {
-    return labelAllocateRepository.findAllocateAddCnt(uuid, baseDate);
-  }
 }

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

@@ -283,19 +283,11 @@ public class MapSheetMngCoreService {
 
     // 4) 파일 생성
     try {
-      log.info("create Directories outputPath: {}", outputPath);
-      log.info(
-          "activeEnv={}, inferenceDir={}, targetDir={}, filename={}",
-          activeEnv,
-          inferenceDir,
-          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());
@@ -305,7 +297,7 @@ public class MapSheetMngCoreService {
     } catch (IOException e) {
       log.error(
           "FAIL_CREATE_MAP_SHEET_FILE: yyyy={}, isAll={}, path={}", yyyy, isAll, outputPath, e);
-      throw new CustomApiException("INTERNAL_SERVER_ERROR", HttpStatus.INTERNAL_SERVER_ERROR, e);
+      throw new CustomApiException("FAIL_CREATE_MAP_SHEET_FILE", HttpStatus.INTERNAL_SERVER_ERROR);
     }
   }
 

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

@@ -35,17 +35,17 @@ public class MapSheetLearn5kRepositoryImpl implements MapSheetLearn5kRepositoryC
     final StringPath errorMsgPath;
 
     switch (type) {
-      case "G1" -> {
+      case "M1" -> {
         failPath = mapSheetLearn5kEntity.isM1Fail;
         jobIdPath = mapSheetLearn5kEntity.m1JobId;
         errorMsgPath = mapSheetLearn5kEntity.m1ErrorMessage;
       }
-      case "G2" -> {
+      case "M2" -> {
         failPath = mapSheetLearn5kEntity.isM2Fail;
         jobIdPath = mapSheetLearn5kEntity.m2JobId;
         errorMsgPath = mapSheetLearn5kEntity.m2ErrorMessage;
       }
-      case "G3" -> {
+      case "M3" -> {
         failPath = mapSheetLearn5kEntity.isM3Fail;
         jobIdPath = mapSheetLearn5kEntity.m3JobId;
         errorMsgPath = mapSheetLearn5kEntity.m3ErrorMessage;
@@ -85,15 +85,15 @@ public class MapSheetLearn5kRepositoryImpl implements MapSheetLearn5kRepositoryC
     final StringPath errorMsgPath;
 
     switch (type) {
-      case "G1" -> {
+      case "M1" -> {
         failPath = mapSheetLearn5kEntity.isM1Fail;
         jobIdPath = mapSheetLearn5kEntity.m1JobId;
       }
-      case "G2" -> {
+      case "M2" -> {
         failPath = mapSheetLearn5kEntity.isM2Fail;
         jobIdPath = mapSheetLearn5kEntity.m2JobId;
       }
-      case "G3" -> {
+      case "M3" -> {
         failPath = mapSheetLearn5kEntity.isM3Fail;
         jobIdPath = mapSheetLearn5kEntity.m3JobId;
       }
@@ -135,15 +135,15 @@ public class MapSheetLearn5kRepositoryImpl implements MapSheetLearn5kRepositoryC
     BooleanPath failPath;
 
     switch (type) {
-      case "G1" -> {
+      case "M1" -> {
         jobIdPath = mapSheetLearn5kEntity.m1JobId;
         failPath = mapSheetLearn5kEntity.isM1Fail;
       }
-      case "G2" -> {
+      case "M2" -> {
         jobIdPath = mapSheetLearn5kEntity.m2JobId;
         failPath = mapSheetLearn5kEntity.isM2Fail;
       }
-      case "G3" -> {
+      case "M3" -> {
         jobIdPath = mapSheetLearn5kEntity.m3JobId;
         failPath = mapSheetLearn5kEntity.isM3Fail;
       }
@@ -180,13 +180,13 @@ public class MapSheetLearn5kRepositoryImpl implements MapSheetLearn5kRepositoryC
     BooleanPath failPath;
 
     switch (type) {
-      case "G1" -> {
+      case "M1" -> {
         jobIdPath = mapSheetLearn5kEntity.m1JobId;
       }
-      case "G2" -> {
+      case "M2" -> {
         jobIdPath = mapSheetLearn5kEntity.m2JobId;
       }
-      case "G3" -> {
+      case "M3" -> {
         jobIdPath = mapSheetLearn5kEntity.m3JobId;
       }
       default -> {

src/main/java/com/kamco/cd/kamcoback/postgres/repository/label/LabelAllocateRepositoryCustom.java

@@ -110,9 +110,4 @@ public interface LabelAllocateRepositoryCustom {
   InferenceLearnDto findLabelingIngProcessId(UUID uuid);
 
   Optional<String> findLearnUid(UUID uuid);
-
-  List<AllocateInfoDto> fetchNextIdsAddStbltYn(
-      UUID uuid, LocalDate baseDate, Long lastId, Long totalCnt);
-
-  Long findAllocateAddCnt(UUID uuid, LocalDate baseDate);
 }

src/main/java/com/kamco/cd/kamcoback/postgres/repository/label/LabelAllocateRepositoryImpl.java

@@ -1856,56 +1856,4 @@ public class LabelAllocateRepositoryImpl implements LabelAllocateRepositoryCusto
             .where(mapSheetAnalInferenceEntity.uuid.eq(uuid))
             .fetchOne());
   }
-
-  @Override
-  public List<AllocateInfoDto> fetchNextIdsAddStbltYn(
-      UUID uuid, LocalDate baseDate, Long lastId, Long totalCnt) {
-    ZoneId zone = ZoneId.of("Asia/Seoul"); // 기준 타임존 명확히
-    ZonedDateTime nextDayStart = baseDate.plusDays(1).atStartOfDay(zone);
-
-    return queryFactory
-        .select(
-            Projections.constructor(
-                AllocateInfoDto.class,
-                mapSheetAnalDataInferenceGeomEntity.geoUid,
-                mapSheetAnalDataInferenceGeomEntity.mapSheetNum,
-                mapSheetAnalDataInferenceGeomEntity.pnu))
-        .from(mapSheetAnalInferenceEntity)
-        .innerJoin(mapSheetAnalDataInferenceEntity)
-        .on(mapSheetAnalInferenceEntity.id.eq(mapSheetAnalDataInferenceEntity.analUid))
-        .innerJoin(mapSheetAnalDataInferenceGeomEntity)
-        .on(
-            mapSheetAnalDataInferenceEntity.id.eq(mapSheetAnalDataInferenceGeomEntity.dataUid),
-            mapSheetAnalDataInferenceGeomEntity.pnu.gt(0),
-            mapSheetAnalDataInferenceGeomEntity.fitState.eq(ImageryFitStatus.UNFIT.getId()),
-            mapSheetAnalDataInferenceGeomEntity.fitStateDttm.lt(nextDayStart),
-            mapSheetAnalDataInferenceGeomEntity.labelState.isNull())
-        .where(
-            mapSheetAnalInferenceEntity.uuid.eq(uuid),
-            lastId == null ? null : mapSheetAnalDataInferenceGeomEntity.geoUid.gt(lastId))
-        .orderBy(mapSheetAnalDataInferenceGeomEntity.mapSheetNum.asc())
-        .limit(totalCnt)
-        .fetch();
-  }
-
-  @Override
-  public Long findAllocateAddCnt(UUID uuid, LocalDate baseDate) {
-    ZoneId zone = ZoneId.of("Asia/Seoul"); // 기준 타임존 명확히
-    ZonedDateTime nextDayStart = baseDate.plusDays(1).atStartOfDay(zone);
-
-    return queryFactory
-        .select(mapSheetAnalDataInferenceGeomEntity.geoUid.count())
-        .from(mapSheetAnalInferenceEntity)
-        .innerJoin(mapSheetAnalDataInferenceEntity)
-        .on(mapSheetAnalInferenceEntity.id.eq(mapSheetAnalDataInferenceEntity.analUid))
-        .innerJoin(mapSheetAnalDataInferenceGeomEntity)
-        .on(
-            mapSheetAnalDataInferenceEntity.id.eq(mapSheetAnalDataInferenceGeomEntity.dataUid),
-            mapSheetAnalDataInferenceGeomEntity.pnu.gt(0),
-            mapSheetAnalDataInferenceGeomEntity.fitState.eq(ImageryFitStatus.UNFIT.getId()),
-            mapSheetAnalDataInferenceGeomEntity.fitStateDttm.lt(nextDayStart),
-            mapSheetAnalDataInferenceGeomEntity.labelState.isNull())
-        .where(mapSheetAnalInferenceEntity.uuid.eq(uuid))
-        .fetchOne();
-  }
 }

src/main/java/com/kamco/cd/kamcoback/postgres/repository/scheduler/TrainingDataReviewJobRepositoryImpl.java

@@ -7,7 +7,6 @@ import static com.kamco.cd.kamcoback.postgres.entity.QMapSheetLearnEntity.mapShe
 
 import com.kamco.cd.kamcoback.label.dto.LabelAllocateDto.InspectState;
 import com.kamco.cd.kamcoback.label.dto.LabelAllocateDto.LabelMngState;
-import com.kamco.cd.kamcoback.model.dto.ModelMngDto.ModelType;
 import com.kamco.cd.kamcoback.postgres.entity.LabelingAssignmentEntity;
 import com.kamco.cd.kamcoback.scheduler.dto.TrainingDataReviewJobDto.AnalCntInfo;
 import com.kamco.cd.kamcoback.scheduler.dto.TrainingDataReviewJobDto.AnalMapSheetList;
@@ -59,10 +58,10 @@ public class TrainingDataReviewJobRepositoryImpl extends QuerydslRepositorySuppo
                     Properties.class,
                     new CaseBuilder()
                         .when(mapSheetLearnDataGeomEntity.classAfterCd.in("building", "container"))
-                        .then(ModelType.G1.getId())
+                        .then("M1")
                         .when(mapSheetLearnDataGeomEntity.classAfterCd.eq("waste"))
-                        .then(ModelType.G2.getId())
-                        .otherwise(ModelType.G3.getId()),
+                        .then("M2")
+                        .otherwise("M3"),
                     mapSheetLearnDataGeomEntity.classBeforeCd,
                     mapSheetLearnDataGeomEntity.classAfterCd)))
         .from(labelingAssignmentEntity)

src/main/java/com/kamco/cd/kamcoback/postgres/repository/trainingdata/TrainingDataLabelRepositoryImpl.java

@@ -120,7 +120,6 @@ public class TrainingDataLabelRepositoryImpl extends QuerydslRepositorySupport
             .orderBy(
                 mapSheetAnalInferenceEntity.targetYyyy.asc(),
                 mapSheetAnalInferenceEntity.compareYyyy.asc(),
-                labelingAssignmentEntity.assignGroupId.asc(),
                 labelingAssignmentEntity.createdDate.asc(),
                 labelingAssignmentEntity.inferenceGeomUid.asc())
             .fetch();
@@ -307,6 +306,10 @@ public class TrainingDataLabelRepositoryImpl extends QuerydslRepositorySupport
             queryFactory
                 .select(labelingAssignmentEntity.count())
                 .from(labelingAssignmentEntity)
+                .innerJoin(mapSheetAnalInferenceEntity)
+                .on(
+                    labelingAssignmentEntity.analUid.eq(mapSheetAnalInferenceEntity.id),
+                    mapSheetAnalInferenceEntity.analState.ne(LabelMngState.FINISH.getId()))
                 .where(labelingAssignmentEntity.workerUid.eq(userId))
                 .fetchOne();
 
@@ -327,6 +330,10 @@ public class TrainingDataLabelRepositoryImpl extends QuerydslRepositorySupport
             queryFactory
                 .select(labelingAssignmentEntity.count())
                 .from(labelingAssignmentEntity)
+                .innerJoin(mapSheetAnalInferenceEntity)
+                .on(
+                    labelingAssignmentEntity.analUid.eq(mapSheetAnalInferenceEntity.id),
+                    mapSheetAnalInferenceEntity.analState.ne(LabelMngState.FINISH.getId()))
                 .where(
                     labelingAssignmentEntity.workerUid.eq(userId),
                     labelingAssignmentEntity.workState.eq("ASSIGNED"))
@@ -355,6 +362,10 @@ public class TrainingDataLabelRepositoryImpl extends QuerydslRepositorySupport
             queryFactory
                 .select(labelingAssignmentEntity.count())
                 .from(labelingAssignmentEntity)
+                .innerJoin(mapSheetAnalInferenceEntity)
+                .on(
+                    labelingAssignmentEntity.analUid.eq(mapSheetAnalInferenceEntity.id),
+                    mapSheetAnalInferenceEntity.analState.ne(LabelMngState.FINISH.getId()))
                 .where(
                     labelingAssignmentEntity.workerUid.eq(userId),
                     labelingAssignmentEntity.workState.in(
@@ -642,7 +653,6 @@ public class TrainingDataLabelRepositoryImpl extends QuerydslRepositorySupport
         queryFactory
             .select(
                 labelingAssignmentEntity.assignmentUid,
-                labelingAssignmentEntity.assignGroupId,
                 labelingAssignmentEntity.createdDate,
                 labelingAssignmentEntity.inferenceGeomUid,
                 mapSheetAnalInferenceEntity.targetYyyy,
@@ -661,7 +671,6 @@ public class TrainingDataLabelRepositoryImpl extends QuerydslRepositorySupport
             .orderBy(
                 mapSheetAnalInferenceEntity.targetYyyy.asc(),
                 mapSheetAnalInferenceEntity.compareYyyy.asc(),
-                labelingAssignmentEntity.assignGroupId.asc(),
                 labelingAssignmentEntity.createdDate.asc(),
                 labelingAssignmentEntity.inferenceGeomUid.asc())
             .limit(1)
@@ -676,7 +685,6 @@ public class TrainingDataLabelRepositoryImpl extends QuerydslRepositorySupport
     Long inferenceGeomUid = firstAssigned.get(labelingAssignmentEntity.inferenceGeomUid);
     Integer targetYyyy = firstAssigned.get(mapSheetAnalInferenceEntity.targetYyyy);
     Integer compareYyyy = firstAssigned.get(mapSheetAnalInferenceEntity.compareYyyy);
-    String assignGroupId = firstAssigned.get(labelingAssignmentEntity.assignGroupId);
 
     BooleanExpression beforeCondition =
         mapSheetAnalInferenceEntity
@@ -692,20 +700,12 @@ public class TrainingDataLabelRepositoryImpl extends QuerydslRepositorySupport
                     .targetYyyy
                     .eq(targetYyyy)
                     .and(mapSheetAnalInferenceEntity.compareYyyy.eq(compareYyyy))
-                    .and(labelingAssignmentEntity.assignGroupId.lt(assignGroupId)))
-            .or(
-                mapSheetAnalInferenceEntity
-                    .targetYyyy
-                    .eq(targetYyyy)
-                    .and(mapSheetAnalInferenceEntity.compareYyyy.eq(compareYyyy))
-                    .and(labelingAssignmentEntity.assignGroupId.eq(assignGroupId))
                     .and(labelingAssignmentEntity.createdDate.lt(createdDttm)))
             .or(
                 mapSheetAnalInferenceEntity
                     .targetYyyy
                     .eq(targetYyyy)
                     .and(mapSheetAnalInferenceEntity.compareYyyy.eq(compareYyyy))
-                    .and(labelingAssignmentEntity.assignGroupId.eq(assignGroupId))
                     .and(labelingAssignmentEntity.createdDate.eq(createdDttm))
                     .and(labelingAssignmentEntity.inferenceGeomUid.lt(inferenceGeomUid)));
 

src/main/java/com/kamco/cd/kamcoback/postgres/repository/trainingdata/TrainingDataReviewRepositoryImpl.java

@@ -314,6 +314,10 @@ public class TrainingDataReviewRepositoryImpl extends QuerydslRepositorySupport
             queryFactory
                 .select(labelingAssignmentEntity.count())
                 .from(labelingAssignmentEntity)
+                .innerJoin(mapSheetAnalInferenceEntity)
+                .on(
+                    labelingAssignmentEntity.analUid.eq(mapSheetAnalInferenceEntity.id),
+                    mapSheetAnalInferenceEntity.analState.ne(LabelMngState.FINISH.getId()))
                 .where(labelingAssignmentEntity.inspectorUid.eq(userId))
                 .fetchOne();
 
@@ -334,6 +338,10 @@ public class TrainingDataReviewRepositoryImpl extends QuerydslRepositorySupport
             queryFactory
                 .select(labelingAssignmentEntity.count())
                 .from(labelingAssignmentEntity)
+                .innerJoin(mapSheetAnalInferenceEntity)
+                .on(
+                    labelingAssignmentEntity.analUid.eq(mapSheetAnalInferenceEntity.id),
+                    mapSheetAnalInferenceEntity.analState.ne(LabelMngState.FINISH.getId()))
                 .where(
                     labelingAssignmentEntity.inspectorUid.eq(userId),
                     labelingAssignmentEntity.inspectState.eq("UNCONFIRM"))
@@ -362,6 +370,10 @@ public class TrainingDataReviewRepositoryImpl extends QuerydslRepositorySupport
             queryFactory
                 .select(labelingAssignmentEntity.count())
                 .from(labelingAssignmentEntity)
+                .innerJoin(mapSheetAnalInferenceEntity)
+                .on(
+                    labelingAssignmentEntity.analUid.eq(mapSheetAnalInferenceEntity.id),
+                    mapSheetAnalInferenceEntity.analState.ne(LabelMngState.FINISH.getId()))
                 .where(
                     labelingAssignmentEntity.inspectorUid.eq(userId),
                     labelingAssignmentEntity.inspectState.in("COMPLETE", "EXCEPT"),

src/main/java/com/kamco/cd/kamcoback/scheduler/TRAINING_DATA_GEOJSON_QUERY.sql

@@ -60,10 +60,10 @@ select msldge1_0.geo_uid,
        st_asgeojson(msldge1_0.geom),
        case
          when (msldge1_0.class_after_cd in ('building', 'container'))
-           then cast('G1' as varchar)
+           then cast('M1' as varchar)
          when (msldge1_0.class_after_cd = 'waste')
-           then cast('G2' as varchar)
-         else 'G3'
+           then cast('M2' as varchar)
+         else 'M3'
          end,
        msldge1_0.class_before_cd,
        msldge1_0.class_after_cd

src/main/java/com/kamco/cd/kamcoback/scheduler/config/AsyncConfig.java

@@ -20,15 +20,4 @@ public class AsyncConfig {
     ex.initialize();
     return ex;
   }
-
-  @Bean(name = "auditLogExecutor")
-  public Executor auditLogExecutor() {
-    ThreadPoolTaskExecutor exec = new ThreadPoolTaskExecutor();
-    exec.setCorePoolSize(2);
-    exec.setMaxPoolSize(8);
-    exec.setQueueCapacity(2000);
-    exec.setThreadNamePrefix("auditlog-");
-    exec.initialize();
-    return exec;
-  }
 }

src/main/java/com/kamco/cd/kamcoback/scheduler/service/MapSheetInferenceJobService.java

@@ -11,7 +11,6 @@ import com.kamco.cd.kamcoback.inference.dto.InferenceProgressDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.SaveInferenceAiDto;
 import com.kamco.cd.kamcoback.inference.dto.InferenceResultDto.Status;
 import com.kamco.cd.kamcoback.inference.dto.InferenceSendDto;
-import com.kamco.cd.kamcoback.model.dto.ModelMngDto.ModelType;
 import com.kamco.cd.kamcoback.postgres.core.InferenceResultCoreService;
 import com.kamco.cd.kamcoback.scheduler.dto.BatchStatusDto;
 import com.kamco.cd.kamcoback.scheduler.dto.JobStatusDto;
@@ -123,7 +122,7 @@ public class MapSheetInferenceJobService {
    * @return
    */
   private Long resolveBatchId(InferenceBatchSheet sheet) {
-    // G3 > G2 > G1
+    // M3 > M2 > M1
     if (sheet.getM3BatchId() != null) {
       return sheet.getM3BatchId();
     }
@@ -217,12 +216,12 @@ public class MapSheetInferenceJobService {
     updateProcessingEndTimeByModel(job, sheet.getUuid(), now, currentType);
 
     // M3이면 전체 종료
-    if (ModelType.G3.getId().equals(currentType)) {
+    if ("M3".equals(currentType)) {
       endAll(sheet, now);
       return;
     }
 
-    // 다음 모델 실행 (G1->G2, G2->G3)
+    // 다음 모델 실행 (M1->M2, M2->M3)
     String nextType = nextModelType(currentType);
     UUID nextModelUuid = resolveModelUuid(sheet, nextType);
 
@@ -241,7 +240,7 @@ public class MapSheetInferenceJobService {
     save.setUuid(sheet.getUuid());
     save.setStatus(Status.END.getId());
     save.setInferEndDttm(now);
-    save.setType(ModelType.G3.getId()); // 마지막 모델 기준
+    save.setType("M3"); // 마지막 모델 기준
     inferenceResultCoreService.update(save);
 
     // 추론 종료일때 geom 데이터 저장
@@ -267,11 +266,11 @@ public class MapSheetInferenceJobService {
    * @return
    */
   private String nextModelType(String currentType) {
-    if (ModelType.G1.getId().equals(currentType)) {
-      return ModelType.G2.getId();
+    if ("M1".equals(currentType)) {
+      return "M2";
     }
-    if (ModelType.G2.getId().equals(currentType)) {
-      return ModelType.G3.getId();
+    if ("M2".equals(currentType)) {
+      return "M3";
     }
     throw new IllegalArgumentException("Unknown runningModelType: " + currentType);
   }
@@ -284,13 +283,13 @@ public class MapSheetInferenceJobService {
    * @return
    */
   private UUID resolveModelUuid(InferenceBatchSheet sheet, String type) {
-    if (ModelType.G1.getId().equals(type)) {
+    if ("M1".equals(type)) {
       return sheet.getM1ModelUuid();
     }
-    if (ModelType.G2.getId().equals(type)) {
+    if ("M2".equals(type)) {
       return sheet.getM2ModelUuid();
     }
-    if (ModelType.G3.getId().equals(type)) {
+    if ("M3".equals(type)) {
       return sheet.getM3ModelUuid();
     }
     throw new IllegalArgumentException("Unknown type: " + type);
@@ -333,6 +332,9 @@ public class MapSheetInferenceJobService {
     InferenceProgressDto progressDto =
         inferenceResultCoreService.getInferenceAiResultById(id, modelUuid);
 
+    // ai 에 맞는 모델 명으로 변경
+    String inferenceType = modelToInferenceType(type);
+
     InferenceSendDto.pred_requests_areas predRequestsAreas =
         new InferenceSendDto.pred_requests_areas();
     predRequestsAreas.setInput1_year(progressDto.getPred_requests_areas().getInput1_year());
@@ -353,7 +355,7 @@ public class MapSheetInferenceJobService {
     m.setCls_model_path(
         Paths.get(progressDto.getCdModelClsPath(), progressDto.getCdModelClsFileName()).toString());
     m.setCls_model_version(progressDto.getClsModelVersion());
-    m.setCd_model_type(type);
+    m.setCd_model_type(inferenceType);
     m.setPriority(progressDto.getPriority());
 
     //    log.info("InferenceSendDto={}", m);
@@ -370,6 +372,25 @@ public class MapSheetInferenceJobService {
     inferenceResultCoreService.update(saveInferenceAiDto);
   }
 
+  /**
+   * ai 에 맞는 모델 명으로 변경
+   *
+   * @param type 모델 타입
+   * @return String
+   */
+  private String modelToInferenceType(String type) {
+    if ("M1".equals(type)) {
+      return "G1";
+    }
+    if ("M2".equals(type)) {
+      return "G2";
+    }
+    if ("M3".equals(type)) {
+      return "G3";
+    }
+    throw new IllegalArgumentException("Unknown type: " + type);
+  }
+
   /**
    * api 호출
    *

src/main/java/com/kamco/cd/kamcoback/upload/UploadApiController.java

@@ -29,12 +29,27 @@ public class UploadApiController {
 
   private final UploadService uploadService;
 
+  @Value("${file.sync-root-dir}")
+  private String syncRootDir;
+
+  @Value("${file.sync-tmp-dir}")
+  private String syncTmpDir;
+
+  @Value("${file.sync-file-extention}")
+  private String syncFileExtention;
+
   @Value("${file.dataset-dir}")
   private String datasetDir;
 
   @Value("${file.dataset-tmp-dir}")
   private String datasetTmpDir;
 
+  @Value("${file.model-dir}")
+  private String modelDir;
+
+  @Value("${file.model-tmp-dir}")
+  private String modelTmpDir;
+
   /*
     @Operation(summary = "데이터셋 대용량 업로드 세션 시작", description = "데이터셋 대용량 파일 업로드 세션을 시작합니다.")
     @ApiResponses(

src/main/resources/application-dev.yml

@@ -16,10 +16,6 @@ spring:
         format_sql: true                  # ⚠️ 선택 - SQL 포맷팅 (가독성)
         jdbc:
           batch_size: 1000           # ✅ 추가 (JDBC batch)
-    open-in-view: false
-  mvc:
-    async:
-      request-timeout: 300s   # 5분 (예: 30s, 120s, 10m 등도 가능)
 
   datasource:
     url: jdbc:postgresql://192.168.2.127:15432/kamco_cds
@@ -87,25 +83,24 @@ mapsheet:
   upload:
     skipGdalValidation: true
   shp:
-    baseurl: /app/tmp/detect/result  #현재사용안함
+    baseurl: /app/tmp/detect/result
 
 
 
 file:
   #sync-root-dir: D:/kamco-nfs/images/
   sync-root-dir: /kamco-nfs/images/
-  sync-tmp-dir: /kamco-nfs/requests/temp              # image upload temp dir
-  #sync-tmp-dir: ${file.sync-root-dir}/tmp
+  sync-tmp-dir: ${file.sync-root-dir}/tmp
   sync-file-extention: tfw,tif
   sync-auto-exception-start-year: 2024
   sync-auto-exception-before-year-cnt: 3
 
-  #dataset-dir: D:/kamco-nfs/model_output/
-  dataset-dir: /kamco-nfs/model_output/export/        # 마운트경로 AI 추론결과
+  #dataset-dir: D:/kamco-nfs/dataset/
+  dataset-dir: /kamco-nfs/dataset/export/
   dataset-tmp-dir: ${file.dataset-dir}tmp/
 
   #model-dir: D:/kamco-nfs/ckpt/model/
-  model-dir: /kamco-nfs/ckpt/model/                   # 학습서버에서 트레이닝한 모델업로드경로
+  model-dir: /kamco-nfs/ckpt/model/
   model-tmp-dir: ${file.model-dir}tmp/
   model-file-extention: pth,json,py
 
@@ -117,8 +112,8 @@ file:
 inference:
   url: http://192.168.2.183:8000/jobs
   batch-url: http://192.168.2.183:8000/batches
-  geojson-dir: /kamco-nfs/requests/                   # 추론실행을 위한 파일생성경로
-  jar-path: /kamco-nfs/repo/jar/shp-exporter.jar
+  geojson-dir: /kamco-nfs/requests/
+  jar-path: /kamco-nfs/dataset/shp/shp-exporter.jar
   inference-server-name: server1,server2,server3,server4
 
 gukyuin:
@@ -127,12 +122,10 @@ gukyuin:
   cdi: ${gukyuin.url}/api/kcd/cdi
 
 training-data:
-  geojson-dir: /kamco-nfs/dataset/request/
+  geojson-dir: /kamco-nfs/model_output/labeling/
 
 layer:
   geoserver-url: https://kamco.geo-dev.gs.dabeeo.com
   wms-path: geoserver/cd
   wmts-path: geoserver/cd/gwc/service
   workspace: cd
-
-

src/main/resources/application-prod.yml

@@ -16,44 +16,14 @@ spring:
         format_sql: true                  # ⚠️ 선택 - SQL 포맷팅 (가독성)
         jdbc:
           batch_size: 1000           # ✅ 추가 (JDBC batch)
-    open-in-view: false
-  mvc:
-    async:
-      request-timeout: 300s   # 5분 (예: 30s, 120s, 10m 등도 가능)
 
   datasource:
-    url: jdbc:postgresql://127.0.0.1:15432/kamco_cds
-    #url: jdbc:postgresql://localhost:15432/kamco_cds
-    username: kamco_cds
-    password: kamco_cds_Q!W@E#R$
+    url: jdbc:postgresql://10.100.0.10:25432/temp
+    username: temp
+    password: temp123!
     hikari:
       minimum-idle: 10
       maximum-pool-size: 20
-      connection-timeout: 60000        # 60초 연결 타임아웃
-      idle-timeout: 300000            # 5분 유휴 타임아웃
-      max-lifetime: 1800000           # 30분 최대 수명
-      leak-detection-threshold: 60000  # 연결 누수 감지
-
-  transaction:
-    default-timeout: 300              # 5분 트랜잭션 타임아웃
-
-  data:
-    redis:
-      host: 127.0.0.1
-      port: 16379
-      password: kamco
-
-  servlet:
-    multipart:
-      enabled: true
-      max-file-size: 4GB
-      max-request-size: 4GB
-      file-size-threshold: 10MB
-
-server:
-  tomcat:
-    max-swallow-size: 4GB
-    max-http-form-post-size: 4GB
 
 jwt:
   secret: "kamco_token_9b71e778-19a3-4c1d-97bf-2d687de17d5b"
@@ -64,39 +34,28 @@ token:
   refresh-cookie-name: kamco   # 개발용 쿠키 이름
   refresh-cookie-secure: true   # 로컬 http 테스트면 false
 
-logging:
-  level:
-    root: INFO
-    org.springframework.web: DEBUG
-    org.springframework.security: DEBUG
-
-    # 헬스체크 노이즈 핵심만 다운
-    org.springframework.security.web.FilterChainProxy: INFO
-    org.springframework.security.web.authentication.AnonymousAuthenticationFilter: INFO
-    org.springframework.security.web.authentication.Http403ForbiddenEntryPoint: INFO
-    org.springframework.web.servlet.DispatcherServlet: INFO
-
-
 mapsheet:
   upload:
     skipGdalValidation: true
   shp:
-    baseurl: /app/detect/result #현재사용안함
+    baseurl: /app/detect/result
+
+
 
 file:
   #sync-root-dir: D:/kamco-nfs/images/
   sync-root-dir: /kamco-nfs/images/
-  sync-tmp-dir: ${file.sync-root-dir}/tmp       # image upload temp dir
+  sync-tmp-dir: ${file.sync-root-dir}/tmp
   sync-file-extention: tfw,tif
   sync-auto-exception-start-year: 2025
   sync-auto-exception-before-year-cnt: 3
 
-  #dataset-dir: D:/kamco-nfs/model_output/ #변경 model_output
-  dataset-dir: /kamco-nfs/model_output/export/  # 마운트경로 AI 추론결과
+  #dataset-dir: D:/kamco-nfs/dataset/
+  dataset-dir: /kamco-nfs/dataset/export/
   dataset-tmp-dir: ${file.dataset-dir}tmp/
 
   #model-dir: D:/kamco-nfs/ckpt/model/
-  model-dir: /kamco-nfs/ckpt/model/             # 학습서버에서 트레이닝한 모델업로드경로
+  model-dir: /kamco-nfs/ckpt/model/
   model-tmp-dir: ${file.model-dir}tmp/
   model-file-extention: pth,json,py
 
@@ -106,18 +65,19 @@ file:
   dataset-response: /kamco-nfs/dataset/response/
 
 inference:
-  url: http://127.0.0.1:8000/jobs
-  batch-url: http://127.0.0.1:8000/batches
-  geojson-dir: /kamco-nfs/requests/                 # 학습서버에서 트레이닝한 모델업로드경로
-  jar-path: /kamco-nfs/repo/jar/shp-exporter.jar    # 추론실행을 위한 파일생성경로
+  url: http://192.168.2.183:8000/jobs
+  batch-url: http://192.168.2.183:8000/batches
+  geojson-dir: /kamco-nfs/requests/
+  jar-path: /kamco-nfs/dataset/shp/shp-exporter.jar
   inference-server-name: server1,server2,server3,server4
 
 gukyuin:
-  url: http://127.0.0.1:5301
+  #url:  http://localhost:8080
+  url: http://192.168.2.129:5301
   cdi: ${gukyuin.url}/api/kcd/cdi
 
 training-data:
-  geojson-dir: /kamco-nfs/dataset/request/
+  geojson-dir: /kamco-nfs/model_output/labeling/
 
 layer:
   geoserver-url: https://kamco.geo-dev.gs.dabeeo.com

src/main/resources/static/download_progress_test.html

@@ -1,83 +0,0 @@
-<!doctype html>
-<html lang="ko">
-<head>
-  <meta charset="utf-8" />
-  <title>라벨 ZIP 다운로드</title>
-</head>
-<body>
-<h3>라벨 ZIP 다운로드</h3>
-
-UUID:
-<input id="uuid" value="6d8d49dc-0c9d-4124-adc7-b9ca610cc394" />
-<br><br>
-
-JWT Token:
-<input id="token" style="width:600px;" placeholder="Bearer 토큰 붙여넣기" />
-<br><br>
-
-<button onclick="download()">다운로드</button>
-
-<br><br>
-<progress id="bar" value="0" max="100" style="width:400px;"></progress>
-<div id="status"></div>
-
-<script>
-  async function download() {
-    const uuid = document.getElementById("uuid").value.trim();
-    const token = document.getElementById("token").value.trim();
-
-    if (!uuid) {
-      alert("UUID 입력하세요");
-      return;
-    }
-
-    if (!token) {
-      alert("토큰 입력하세요");
-      return;
-    }
-
-    const url = `/api/training-data/stage/download/${uuid}`;
-
-    const res = await fetch(url, {
-      headers: {
-        "Authorization": token.startsWith("Bearer ")
-          ? token
-          : `Bearer ${token}`,
-        "kamco-download-uuid": uuid
-      }
-    });
-
-    if (!res.ok) {
-      document.getElementById("status").innerText =
-        "실패: " + res.status;
-      return;
-    }
-
-    const total = parseInt(res.headers.get("Content-Length") || "0", 10);
-    const reader = res.body.getReader();
-    const chunks = [];
-    let received = 0;
-
-    while (true) {
-      const { done, value } = await reader.read();
-      if (done) break;
-      chunks.push(value);
-      received += value.length;
-
-      if (total) {
-        document.getElementById("bar").value =
-          (received / total) * 100;
-      }
-    }
-
-    const blob = new Blob(chunks);
-    const a = document.createElement("a");
-    a.href = URL.createObjectURL(blob);
-    a.download = uuid + ".zip";
-    a.click();
-
-    document.getElementById("status").innerText = "완료 ✅";
-  }
-</script>
-</body>
-</html>