From 573da5b53a5aaa7baeaa26e09736535a3e1a2b9a Mon Sep 17 00:00:00 2001 From: teddy Date: Fri, 6 Mar 2026 19:21:08 +0900 Subject: [PATCH] =?UTF-8?q?shp=20=ED=8C=8C=EC=9D=BC=20=EC=83=9D=EC=84=B1?= =?UTF-8?q?=EC=A4=91=20=EC=98=A4=EB=A5=98=20=EB=B0=9C=EC=83=9D=EC=8B=9C=20?= =?UTF-8?q?=EC=A4=91=EC=A7=80=EB=90=98=EA=B2=8C=20=EC=88=98=EC=A0=95?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../kamcoback/common/service/ExternalJarRunner.java | 1 + .../scheduler/service/ShpPipelineService.java | 11 ++++++++--- 2 files changed, 9 insertions(+), 3 deletions(-) diff --git a/src/main/java/com/kamco/cd/kamcoback/common/service/ExternalJarRunner.java b/src/main/java/com/kamco/cd/kamcoback/common/service/ExternalJarRunner.java index 5caaa5ba..6cfd3f76 100644 --- a/src/main/java/com/kamco/cd/kamcoback/common/service/ExternalJarRunner.java +++ b/src/main/java/com/kamco/cd/kamcoback/common/service/ExternalJarRunner.java @@ -104,6 +104,7 @@ public class ExternalJarRunner { } catch (Exception e) { log.error("jar execution error. output=\n{}", out, e); + throw new RuntimeException("jar execution error\n" + out, e); } } diff --git a/src/main/java/com/kamco/cd/kamcoback/scheduler/service/ShpPipelineService.java b/src/main/java/com/kamco/cd/kamcoback/scheduler/service/ShpPipelineService.java index b1c15e65..d6355927 100644 --- a/src/main/java/com/kamco/cd/kamcoback/scheduler/service/ShpPipelineService.java +++ b/src/main/java/com/kamco/cd/kamcoback/scheduler/service/ShpPipelineService.java @@ -18,11 +18,16 @@ public class ShpPipelineService { private final ExternalJarRunner externalJarRunner; private final ShpKeyLock shpKeyLock; + /** + * shp 파일 생성 1. merge 생성 2. 생성된 merge shp 파일로 geoserver 등록, 3.도엽별로 shp 생성 + * + * @param jarPath 실행 jar 파일 경로 + * @param datasetDir shp 파일이 생성될 경로 + * @param batchIds 추론 batch id = 12,13,14 + * @param inferenceId 추론 uid 32자 + */ @Async("shpExecutor") public void runPipeline(String jarPath, String datasetDir, String batchIds, String inferenceId) { - // - // batchIds.split(",") - // inferenceResultCoreService.getInferenceResultCnt(); // inferenceId 기준 동시 실행 제한 if (!shpKeyLock.tryLock(inferenceId)) { -- 2.49.1