From 136543e113c5ff72e7b88fd4e0d4cc868b41a7b2 Mon Sep 17 00:00:00 2001 From: teddy Date: Tue, 13 Jan 2026 09:41:17 +0900 Subject: [PATCH] =?UTF-8?q?[KC-108]=20=EC=B6=94=EB=A1=A0=EC=8B=A4=ED=96=89?= =?UTF-8?q?=20=ED=8C=8C=EB=9D=BC=EB=AF=B8=ED=84=B0=20=EB=B3=80=EA=B2=BD?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../repository/mapsheet/MapSheetMngRepositoryImpl.java | 2 +- .../scheduler/service/MapSheetInferenceJobService.java | 8 ++++++++ 2 files changed, 9 insertions(+), 1 deletion(-) diff --git a/src/main/java/com/kamco/cd/kamcoback/postgres/repository/mapsheet/MapSheetMngRepositoryImpl.java b/src/main/java/com/kamco/cd/kamcoback/postgres/repository/mapsheet/MapSheetMngRepositoryImpl.java index 74873c8b..3405e344 100644 --- a/src/main/java/com/kamco/cd/kamcoback/postgres/repository/mapsheet/MapSheetMngRepositoryImpl.java +++ b/src/main/java/com/kamco/cd/kamcoback/postgres/repository/mapsheet/MapSheetMngRepositoryImpl.java @@ -504,7 +504,7 @@ public class MapSheetMngRepositoryImpl extends QuerydslRepositorySupport whereBuilder.and(mapSheetMngHstEntity.mngYyyy.eq(mngYyyy)); whereBuilder.and(mapSheetMngHstEntity.mapSheetNum.in(mapIds)); whereBuilder.and(mapSheetMngHstEntity.dataState.eq("DONE")); - whereBuilder.and(mapSheetMngHstEntity.syncState.eq("DONE")); + whereBuilder.and(mapSheetMngHstEntity.syncState.eq("DONE")); // TODO 싱크체크 or조건 추가 whereBuilder.and(mapSheetMngHstEntity.useInference.eq("USE")); return queryFactory diff --git a/src/main/java/com/kamco/cd/kamcoback/scheduler/service/MapSheetInferenceJobService.java b/src/main/java/com/kamco/cd/kamcoback/scheduler/service/MapSheetInferenceJobService.java index c59e1703..824ab33c 100644 --- a/src/main/java/com/kamco/cd/kamcoback/scheduler/service/MapSheetInferenceJobService.java +++ b/src/main/java/com/kamco/cd/kamcoback/scheduler/service/MapSheetInferenceJobService.java @@ -113,10 +113,18 @@ public class MapSheetInferenceJobService { saveInferenceAiDto.setUuid(batchSheet.getUuid()); saveInferenceAiDto.setStatus(Status.END.getId()); saveInferenceAiDto.setInferEndDttm(ZonedDateTime.now()); + saveInferenceAiDto.setType(type); inferenceResultCoreService.update(saveInferenceAiDto); // 종료시간 this.updateProcessingEndTimeByModel(batchSheet.getUuid(), ZonedDateTime.now(), "M3"); } + } else if ("COMPLETED_WITH_FAILURES".equals(dto.getStatus())) { + SaveInferenceAiDto saveInferenceAiDto = new SaveInferenceAiDto(); + saveInferenceAiDto.setUuid(batchSheet.getUuid()); + saveInferenceAiDto.setStatus(Status.END.getId()); + saveInferenceAiDto.setInferEndDttm(ZonedDateTime.now()); + saveInferenceAiDto.setType(batchSheet.getRunningModelType()); + inferenceResultCoreService.update(saveInferenceAiDto); } else { SaveInferenceAiDto saveInferenceAiDto = new SaveInferenceAiDto(); saveInferenceAiDto.setUuid(batchSheet.getUuid());