From 91c5c0c116d887f5ebcd906ac4c28af5a2e1ef9a Mon Sep 17 00:00:00 2001 From: "gayoun.park" Date: Tue, 20 Jan 2026 12:15:26 +0900 Subject: [PATCH] =?UTF-8?q?=EA=B2=80=EC=88=98=ED=95=A0=EB=8B=B9=20?= =?UTF-8?q?=EC=8B=9C,=20geom=20=ED=85=8C=EC=9D=B4=EB=B8=94=EB=8F=84=20?= =?UTF-8?q?=EC=83=81=ED=83=9C=20=EC=97=85=EB=8D=B0=EC=9D=B4=ED=8A=B8?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../core/TrainingDataReviewJobCoreService.java | 4 ++++ .../TrainingDataReviewJobRepositoryCustom.java | 2 ++ .../TrainingDataReviewJobRepositoryImpl.java | 11 +++++++++++ .../service/TrainingDataReviewJobService.java | 8 +++++++- 4 files changed, 24 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/kamco/cd/kamcoback/postgres/core/TrainingDataReviewJobCoreService.java b/src/main/java/com/kamco/cd/kamcoback/postgres/core/TrainingDataReviewJobCoreService.java index 5260f7af..bc47eeff 100644 --- a/src/main/java/com/kamco/cd/kamcoback/postgres/core/TrainingDataReviewJobCoreService.java +++ b/src/main/java/com/kamco/cd/kamcoback/postgres/core/TrainingDataReviewJobCoreService.java @@ -37,4 +37,8 @@ public class TrainingDataReviewJobCoreService { public void lockInspectors(Long analUid, List reviewerIds) { trainingDataReviewJobRepository.lockInspectors(analUid, reviewerIds); } + + public void updateGeomUidTestState(List geomUids) { + trainingDataReviewJobRepository.updateGeomUidTestState(geomUids); + } } diff --git a/src/main/java/com/kamco/cd/kamcoback/postgres/repository/scheduler/TrainingDataReviewJobRepositoryCustom.java b/src/main/java/com/kamco/cd/kamcoback/postgres/repository/scheduler/TrainingDataReviewJobRepositoryCustom.java index f83b2f77..f3030013 100644 --- a/src/main/java/com/kamco/cd/kamcoback/postgres/repository/scheduler/TrainingDataReviewJobRepositoryCustom.java +++ b/src/main/java/com/kamco/cd/kamcoback/postgres/repository/scheduler/TrainingDataReviewJobRepositoryCustom.java @@ -16,4 +16,6 @@ public interface TrainingDataReviewJobRepositoryCustom { void assignReviewerBatch(List assignmentUids, String reviewerId); Tasks findAssignmentTask(String assignmentUid); + + void updateGeomUidTestState(List geomUids); } diff --git a/src/main/java/com/kamco/cd/kamcoback/postgres/repository/scheduler/TrainingDataReviewJobRepositoryImpl.java b/src/main/java/com/kamco/cd/kamcoback/postgres/repository/scheduler/TrainingDataReviewJobRepositoryImpl.java index a4cf4f63..a7316cee 100644 --- a/src/main/java/com/kamco/cd/kamcoback/postgres/repository/scheduler/TrainingDataReviewJobRepositoryImpl.java +++ b/src/main/java/com/kamco/cd/kamcoback/postgres/repository/scheduler/TrainingDataReviewJobRepositoryImpl.java @@ -2,6 +2,7 @@ package com.kamco.cd.kamcoback.postgres.repository.scheduler; import static com.kamco.cd.kamcoback.postgres.entity.QLabelingAssignmentEntity.labelingAssignmentEntity; import static com.kamco.cd.kamcoback.postgres.entity.QLabelingInspectorEntity.labelingInspectorEntity; +import static com.kamco.cd.kamcoback.postgres.entity.QMapSheetAnalDataInferenceGeomEntity.mapSheetAnalDataInferenceGeomEntity; import com.kamco.cd.kamcoback.label.dto.LabelAllocateDto.InspectState; import com.kamco.cd.kamcoback.label.dto.LabelAllocateDto.LabelState; @@ -134,4 +135,14 @@ public class TrainingDataReviewJobRepositoryImpl extends QuerydslRepositorySuppo .where(labelingAssignmentEntity.assignmentUid.eq(UUID.fromString(assignmentUid))) .fetchOne(); } + + @Override + public void updateGeomUidTestState(List geomUids) { + queryFactory + .update(mapSheetAnalDataInferenceGeomEntity) + .set(mapSheetAnalDataInferenceGeomEntity.testState, InspectState.UNCONFIRM.getId()) + .set(mapSheetAnalDataInferenceGeomEntity.updatedDttm, ZonedDateTime.now()) + .where(mapSheetAnalDataInferenceGeomEntity.geoUid.in(geomUids)) + .execute(); + } } diff --git a/src/main/java/com/kamco/cd/kamcoback/scheduler/service/TrainingDataReviewJobService.java b/src/main/java/com/kamco/cd/kamcoback/scheduler/service/TrainingDataReviewJobService.java index 25bf791b..6b2dc85a 100644 --- a/src/main/java/com/kamco/cd/kamcoback/scheduler/service/TrainingDataReviewJobService.java +++ b/src/main/java/com/kamco/cd/kamcoback/scheduler/service/TrainingDataReviewJobService.java @@ -80,8 +80,10 @@ public class TrainingDataReviewJobService { List assignmentUids = assignedTasks.stream().map(Tasks::getAssignmentUid).toList(); - trainingDataReviewJobCoreService.assignReviewerBatch(assignmentUids, reviewerId); + + List geomUids = assignedTasks.stream().map(Tasks::getInferenceUid).toList(); + trainingDataReviewJobCoreService.updateGeomUidTestState(geomUids); }); } } catch (Exception e) { @@ -127,5 +129,9 @@ public class TrainingDataReviewJobService { trainingDataReviewJobCoreService.lockInspectors(analUid, order); trainingDataReviewJobCoreService.assignReviewer(task.getAssignmentUid(), order.getFirst()); + + List geomUids = new ArrayList<>(); + geomUids.add(task.getInferenceUid()); + trainingDataReviewJobCoreService.updateGeomUidTestState(geomUids); } }