추론결과 목록조회 수정

This commit is contained in:
2026-01-26 15:05:26 +09:00
parent 193d38e66d
commit 47f39daa88
4 changed files with 77 additions and 19 deletions

View File

@@ -5,7 +5,10 @@ import com.kamco.cd.kamcoback.inference.dto.InferenceResultShpDto;
import com.kamco.cd.kamcoback.postgres.core.InferenceResultCoreService;
import com.kamco.cd.kamcoback.postgres.core.InferenceResultShpCoreService;
import com.kamco.cd.kamcoback.scheduler.service.ShpPipelineService;
import java.util.Objects;
import java.util.UUID;
import java.util.stream.Collectors;
import java.util.stream.Stream;
import lombok.RequiredArgsConstructor;
import org.springframework.beans.factory.annotation.Value;
import org.springframework.stereotype.Service;
@@ -46,10 +49,12 @@ public class InferenceResultShpService {
if (dto == null) {
return;
}
Long m1BatchId = dto.getM1ModelBatchId();
Long m2BatchId = dto.getM2ModelBatchId();
Long m3BatchId = dto.getM3ModelBatchId();
String batchId = m1BatchId + "," + m2BatchId + "," + m3BatchId;
String batchId =
Stream.of(dto.getM1ModelBatchId(), dto.getM2ModelBatchId(), dto.getM3ModelBatchId())
.filter(Objects::nonNull)
.map(String::valueOf)
.collect(Collectors.joining(","));
// shp 파일 비동기 생성
shpPipelineService.runPipeline(jarPath, datasetDir, batchId, dto.getUid());