라벨링툴 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/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/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/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(
+  public boolean preHandle(
-      HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) {
+      HttpServletRequest request, HttpServletResponse response, Object handler) {
 
-    String uri = request.getRequestURI();
+    if (!request.getRequestURI().contains("/download")) return true;
-    if (uri == null || !uri.contains("/download")) return;
-    if (request.getDispatcherType() != DispatcherType.REQUEST) return;
 
-    Long userId;
+    if (request.getDispatcherType() != jakarta.servlet.DispatcherType.REQUEST) {
-    try {
+      return true;
-      userId = userUtil.getId();
+    }
-      if (userId == null) return; // userId null 불가면 스킵
+
-    } catch (Exception e) {
+    saveLog(request, response);
-      log.warn("Download audit userId resolve failed. uri={}, err={}", uri, e.toString());
+
+    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);
+    List<?> list = menuService.getFindAll();
-    if (downloadUuid == null) {
+    List<MenuDto.Basic> result =
-      log.warn("Download UUID parse failed. uri={}", uri);
+        list.stream()
-      return; // downloadUuid null 불가 -> 스킵
+            .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(
+    String normalizedUri = request.getRequestURI().replace("/api", "");
-        new DownloadAuditEvent(userId, uri, normalizedUri, ip, status, downloadUuid));
+    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) {
+    AuditLogEntity log =
-    try {
+        AuditLogEntity.forFileDownload(
-      String[] parts = uri.split("/");
+            userId,
-      String last = parts[parts.length - 1];
+            request.getRequestURI(),
-      return UUID.fromString(last);
+            Objects.requireNonNull(basic).getMenuUid(),
-    } catch (Exception e) {
+            ip,
-      return null;
+            response.getStatus(),
-    }
+            UUID.fromString(HeaderUtil.get(request, "kamco-download-uuid")));
+
+    auditLogRepository.save(log);
   }
 }

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

@@ -98,7 +98,6 @@ public class SecurityConfig {
                         "/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",

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(
@@ -356,8 +356,9 @@ public class InferenceResultApiController {
         @ApiResponse(responseCode = "404", description = "파일 없음", content = @Content),
         @ApiResponse(responseCode = "500", description = "서버 오류", content = @Content)
       })
-  @GetMapping("/download/{uuid}")
+  @GetMapping(value = "/download/{uuid}")
-  public ResponseEntity<?> download(@PathVariable UUID uuid, HttpServletRequest request)
+  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 downloadExecutor.stream(
-    return rangeDownloadResponder.buildZipResponse(zipPath, uid + ".zip", request);
+        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/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,10 +23,8 @@ 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.util.List;
@@ -35,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;
@@ -43,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")
@@ -52,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;
@@ -381,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)) {
+    return downloadExecutor.stream(
-      throw new BadRequestException();
+        new DownloadSpec(uuid, zipPath, uid + ".zip", MediaType.APPLICATION_OCTET_STREAM));
-    }
-
-    return rangeDownloadResponder.buildZipResponse(zipPath, uid + ".zip", request);
   }
 
   @Operation(summary = "라벨 파일 다운로드 이력 조회", description = "라벨 파일 다운로드 이력 조회")

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

@@ -27,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 {
 
@@ -277,7 +276,6 @@ public class LabelAllocateService {
     return labelAllocateCoreService.findLabelingIngProcessCnt();
   }
 
-  @Transactional(propagation = Propagation.NOT_SUPPORTED)
   public String findLearnUid(UUID uuid) {
     return labelAllocateCoreService.findLearnUid(uuid);
   }

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/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/LabelAllocateCoreService.java

@@ -257,16 +257,16 @@ public class LabelAllocateCoreService {
 
     // 파일이 있는지만 확인
     Path path = Paths.get(responsePath).resolve(dto.getLearnUid() + ".zip");
-    if (!Files.isRegularFile(path)) return false; // exists 포함
 
-    String state = dto.getAnalState();
+    if (!Files.exists(path) || !Files.isRegularFile(path)) {
-    boolean isLabelingIng =
+      // 실제 파일만 true (디렉터리는 제외)
-        LabelMngState.ASSIGNED.getId().equals(state) || LabelMngState.ING.getId().equals(state);
+      return false;
+    }
 
-    if (isLabelingIng) {
+    // 다운로드 확인할 학습데이터가 라벨링중인 경우 파일 생성여부가 정상인지 확인
-      Long analId = dto.getAnalId();
+    if (dto.getAnalState().equals(LabelMngState.ASSIGNED.getId())
-      if (analId == null) return false;
+        || dto.getAnalState().equals(LabelMngState.ING.getId())) {
-      return batchStepHistoryRepository.isDownloadable(analId);
+      return batchStepHistoryRepository.isDownloadable(dto.getAnalId());
     }
 
     return true;

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

@@ -306,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();
 
@@ -326,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"))
@@ -354,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(

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/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/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,9 +16,6 @@ spring:
         format_sql: true                  # ⚠️ 선택 - SQL 포맷팅 (가독성)
         jdbc:
           batch_size: 1000           # ✅ 추가 (JDBC batch)
-  mvc:
-    async:
-      request-timeout: 300s   # 5분 (예: 30s, 120s, 10m 등도 가능)
 
   datasource:
     url: jdbc:postgresql://192.168.2.127:15432/kamco_cds
@@ -86,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: D:/kamco-nfs/dataset/
-  dataset-dir: /kamco-nfs/model_output/export/        # 마운트경로 AI 추론결과
+  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
 
@@ -116,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/                   # 추론실행을 위한 파일생성경로
+  geojson-dir: /kamco-nfs/requests/
-  jar-path: /kamco-nfs/repo/jar/shp-exporter.jar
+  jar-path: /kamco-nfs/dataset/shp/shp-exporter.jar
   inference-server-name: server1,server2,server3,server4
 
 gukyuin:
@@ -126,7 +122,7 @@ 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

src/main/resources/application-prod.yml

@@ -16,43 +16,14 @@ spring:
         format_sql: true                  # ⚠️ 선택 - SQL 포맷팅 (가독성)
         jdbc:
           batch_size: 1000           # ✅ 추가 (JDBC batch)
-  mvc:
-    async:
-      request-timeout: 300s   # 5분 (예: 30s, 120s, 10m 등도 가능)
 
   datasource:
-    url: jdbc:postgresql://127.0.0.1:15432/kamco_cds
+    url: jdbc:postgresql://10.100.0.10:25432/temp
-    #url: jdbc:postgresql://localhost:15432/kamco_cds
+    username: temp
-    username: kamco_cds
+    password: temp123!
-    password: kamco_cds_Q!W@E#R$
     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"
@@ -63,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: D:/kamco-nfs/dataset/
-  dataset-dir: /kamco-nfs/model_output/export/  # 마운트경로 AI 추론결과
+  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
 
@@ -105,18 +65,19 @@ file:
   dataset-response: /kamco-nfs/dataset/response/
 
 inference:
-  url: http://127.0.0.1:8000/jobs
+  url: http://192.168.2.183:8000/jobs
-  batch-url: http://127.0.0.1:8000/batches
+  batch-url: http://192.168.2.183:8000/batches
-  geojson-dir: /kamco-nfs/requests/                 # 학습서버에서 트레이닝한 모델업로드경로
+  geojson-dir: /kamco-nfs/requests/
-  jar-path: /kamco-nfs/repo/jar/shp-exporter.jar    # 추론실행을 위한 파일생성경로
+  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>