Merge remote-tracking branch 'origin/feat/dev_251201' into feat/dev_251201

# Conflicts:
#	src/main/java/com/kamco/cd/kamcoback/label/LabelAllocateApiController.java
#	src/main/java/com/kamco/cd/kamcoback/label/service/LabelAllocateService.java

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

@@ -8,8 +8,11 @@ import com.kamco.cd.kamcoback.label.dto.LabelAllocateDto.InferenceDetail;
 import com.kamco.cd.kamcoback.label.dto.LabelAllocateDto.LabelerDetail;
 import com.kamco.cd.kamcoback.label.dto.LabelAllocateDto.TargetUser;
 import com.kamco.cd.kamcoback.label.dto.LabelAllocateDto.UserList;
+import com.kamco.cd.kamcoback.label.dto.WorkerStatsDto.DailyHistory;
 import com.kamco.cd.kamcoback.label.dto.WorkerStatsDto.WorkerListResponse;
+import com.kamco.cd.kamcoback.label.dto.WorkerStatsDto.WorkerStatistics;
 import com.kamco.cd.kamcoback.postgres.core.LabelAllocateCoreService;
+import java.time.LocalDate;
 import java.util.List;
 import java.util.Objects;
 import lombok.extern.slf4j.Slf4j;
@@ -21,6 +24,8 @@ import org.springframework.transaction.annotation.Transactional;
 @Transactional
 public class LabelAllocateService {
 
+  private static final int STAGNATION_THRESHOLD = 10; // 정체 판단 기준 (3일 평균 처리량)
+  private static final int BATCH_SIZE = 100; // 배정 배치 크기
 
   private final LabelAllocateCoreService labelAllocateCoreService;
 
@@ -112,13 +117,17 @@ public class LabelAllocateService {
    * @param workerType 작업자 유형 (LABELER/INSPECTOR)
    * @param search 검색어 (이름 또는 사번)
    * @param sortType 정렬 조건
+   * @param page 페이지 번호 (0부터 시작)
+   * @param size 페이지 크기
    * @return 작업자 목록 및 통계
    */
   public WorkerListResponse getWorkerStatistics(
       Long analUid,
       String workerType,
       String search,
-      String sortType) {
+      String sortType,
+      Integer page,
+      Integer size) {
 
     // 프로젝트 정보 조회 (analUid가 있을 때만)
     var projectInfo = labelAllocateCoreService.findProjectInfo(analUid);
@@ -126,9 +135,59 @@ public class LabelAllocateService {
     // 작업 진행 현황 조회
     var progressInfo = labelAllocateCoreService.findWorkProgressInfo(analUid);
 
+    // 작업자 통계 조회
+    List<WorkerStatistics> workers =
+        labelAllocateCoreService.findWorkerStatistics(
+            analUid, workerType, search, sortType);
+
+    // 각 작업자별 3일치 처리량 조회
+    LocalDate today = LocalDate.now();
+    for (WorkerStatistics worker : workers) {
+      Long day1Count =
+          labelAllocateCoreService.findDailyProcessedCount(
+              worker.getWorkerId(), workerType, today.minusDays(1), analUid);
+      Long day2Count =
+          labelAllocateCoreService.findDailyProcessedCount(
+              worker.getWorkerId(), workerType, today.minusDays(2), analUid);
+      Long day3Count =
+          labelAllocateCoreService.findDailyProcessedCount(
+              worker.getWorkerId(), workerType, today.minusDays(3), analUid);
+
+      long average = (day1Count + day2Count + day3Count) / 3;
+
+      DailyHistory history =
+          DailyHistory.builder()
+              .day1Ago(day1Count)
+              .day2Ago(day2Count)
+              .day3Ago(day3Count)
+              .average(average)
+              .build();
+
+      worker.setHistory(history);
+
+      // 정체 여부 판단 (3일 평균이 STAGNATION_THRESHOLD 미만일 때)
+      if (average < STAGNATION_THRESHOLD) {
+        worker.setIsStagnated(true);
+      }
+    }
+
+    // 페이징 처리
+    long totalElements = workers.size();
+    int totalPages = (int) Math.ceil((double) totalElements / size);
+    int fromIndex = page * size;
+    int toIndex = Math.min(fromIndex + size, workers.size());
+
+    List<WorkerStatistics> pagedWorkers =
+        (fromIndex < workers.size()) ? workers.subList(fromIndex, toIndex) : List.of();
+
     return WorkerListResponse.builder()
         .projectInfo(projectInfo)
         .progressInfo(progressInfo)
+        .workers(pagedWorkers)
+        .currentPage(page)
+        .pageSize(size)
+        .totalElements(totalElements)
+        .totalPages(totalPages)
         .build();
   }
 

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

@@ -1,24 +1,52 @@
 package com.kamco.cd.kamcoback.label.service;
 
 import com.kamco.cd.kamcoback.label.dto.LabelWorkDto;
+import com.kamco.cd.kamcoback.label.dto.LabelWorkDto.ChangeDetectYear;
 import com.kamco.cd.kamcoback.label.dto.LabelWorkDto.LabelWorkMng;
+import com.kamco.cd.kamcoback.label.dto.LabelWorkDto.LabelWorkMngDetail;
 import com.kamco.cd.kamcoback.postgres.core.LabelWorkCoreService;
+import java.util.List;
+import java.util.UUID;
+import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.domain.Page;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
 
 @Slf4j
 @Service
+@RequiredArgsConstructor
+@Transactional(rollbackFor = Exception.class)
 public class LabelWorkService {
 
   private final LabelWorkCoreService labelWorkCoreService;
 
-  public LabelWorkService(LabelWorkCoreService labelWorkCoreService) {
-    this.labelWorkCoreService = labelWorkCoreService;
-  }
-
+  /**
+   * 라벨링작업 관리 목록조회
+   *
+   * @param searchReq
+   * @return
+   */
   public Page<LabelWorkMng> labelWorkMngList(LabelWorkDto.LabelWorkMngSearchReq searchReq) {
-
     return labelWorkCoreService.labelWorkMngList(searchReq);
   }
+
+  /**
+   * 작업배정 정보 조회
+   *
+   * @param uuid
+   * @return
+   */
+  public LabelWorkMngDetail findLabelWorkMngDetail(UUID uuid) {
+    return labelWorkCoreService.findLabelWorkMngDetail(uuid);
+  }
+
+  /**
+   * 변화탐지 셀렉트박스 조회
+   *
+   * @return
+   */
+  public List<ChangeDetectYear> getChangeDetectYear() {
+    return labelWorkCoreService.getChangeDetectYear();
+  }
 }