From 2f82af0c1a4aa303089749143865f45535d70197 Mon Sep 17 00:00:00 2001
From: HYOJIN <hjkim4@gcsc.co.kr>
Date: Tue, 24 Mar 2026 13:22:55 +0900
Subject: [PATCH] =?UTF-8?q?refactor(risk):=20RiskDetailImportJob=20IMO=20?=
 =?UTF-8?q?=EC=A1=B0=ED=9A=8C=20=EB=8C=80=EC=83=81=EC=9D=84=20tb=5Fship=5F?=
 =?UTF-8?q?default=5Finfo=EB=A1=9C=20=EB=B3=80=EA=B2=BD?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

std_snp_svc.tb_ship_risk_info → std_snp_data.tb_ship_default_info

Closes #81

Co-Authored-By: Claude Opus 4.6 (1M context) <noreply@anthropic.com>
---
 .../batch/config/RiskDetailImoFetchTasklet.java  | 16 ++++++++--------
 .../batch/config/RiskDetailImportJobConfig.java  |  7 ++-----
 2 files changed, 10 insertions(+), 13 deletions(-)

diff --git a/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImoFetchTasklet.java b/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImoFetchTasklet.java
index 13a285c..a81763c 100644
--- a/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImoFetchTasklet.java
+++ b/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImoFetchTasklet.java
@@ -12,18 +12,18 @@ import java.util.List;
 
 /**
  * Risk 상세 데이터 수집을 위한 IMO 목록 조회 Tasklet.
- * std_snp_svc.tb_ship_risk_info 테이블에서 전체 imo_no를 오름차순으로 조회하여
+ * std_snp_data.tb_ship_default_info 테이블에서 전체 imo_no를 오름차순으로 조회하여
  * JobExecutionContext에 저장.
  */
 @Slf4j
 public class RiskDetailImoFetchTasklet implements Tasklet {
 
     private final JdbcTemplate jdbcTemplate;
-    private final String serviceSchema;
+    private final String targetSchema;
 
-    public RiskDetailImoFetchTasklet(JdbcTemplate jdbcTemplate, String serviceSchema) {
+    public RiskDetailImoFetchTasklet(JdbcTemplate jdbcTemplate, String targetSchema) {
         this.jdbcTemplate = jdbcTemplate;
-        this.serviceSchema = serviceSchema;
+        this.targetSchema = targetSchema;
     }
 
     @Override
@@ -32,8 +32,8 @@ public class RiskDetailImoFetchTasklet implements Tasklet {
                 .getStepExecution().getJobExecution();
 
         String sql = String.format(
-                "SELECT DISTINCT imo_no FROM %s.tb_ship_risk_info WHERE imo_no IS NOT NULL ORDER BY imo_no ASC",
-                serviceSchema);
+                "SELECT DISTINCT imo_no FROM %s.tb_ship_default_info WHERE imo_no IS NOT NULL ORDER BY imo_no ASC",
+                targetSchema);
 
         List<String> imoNumbers = jdbcTemplate.queryForList(sql, String.class);
 
@@ -42,8 +42,8 @@ public class RiskDetailImoFetchTasklet implements Tasklet {
             jobExecution.getExecutionContext().putString("allImoNumbers", String.join(",", imoNumbers));
         }
 
-        log.info("[RiskDetailImoFetchTasklet] IMO {} 건 조회 완료 (from {}.tb_ship_risk_info)",
-                imoNumbers.size(), serviceSchema);
+        log.info("[RiskDetailImoFetchTasklet] IMO {} 건 조회 완료 (from {}.tb_ship_default_info)",
+                imoNumbers.size(), targetSchema);
 
         return RepeatStatus.FINISHED;
     }
diff --git a/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImportJobConfig.java b/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImportJobConfig.java
index d9a351f..ad2e7f7 100644
--- a/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImportJobConfig.java
+++ b/src/main/java/com/snp/batch/jobs/risk/batch/config/RiskDetailImportJobConfig.java
@@ -47,9 +47,6 @@ public class RiskDetailImportJobConfig extends BasePartitionedJobConfig<RiskDto,
     @Value("${app.batch.target-schema.name}")
     private String targetSchema;
 
-    @Value("${app.batch.service-schema.name}")
-    private String serviceSchema;
-
     @Value("${app.batch.risk-detail.partition-count:4}")
     private int partitionCount;
 
@@ -94,7 +91,7 @@ public class RiskDetailImportJobConfig extends BasePartitionedJobConfig<RiskDto,
 
     @Override
     protected int getChunkSize() {
-        return 100;
+        return 5000;
     }
 
     // ========================================
@@ -119,7 +116,7 @@ public class RiskDetailImportJobConfig extends BasePartitionedJobConfig<RiskDto,
 
     @Bean
     public Tasklet riskDetailImoFetchTasklet() {
-        return new RiskDetailImoFetchTasklet(jdbcTemplate, serviceSchema);
+        return new RiskDetailImoFetchTasklet(jdbcTemplate, targetSchema);
     }
 
     @Bean(name = "RiskDetailImoFetchStep")