From 2f82af0c1a4aa303089749143865f45535d70197 Mon Sep 17 00:00:00 2001 From: HYOJIN Date: Tue, 24 Mar 2026 13:22:55 +0900 Subject: [PATCH 1/2] =?UTF-8?q?refactor(risk):=20RiskDetailImportJob=20IMO?= =?UTF-8?q?=20=EC=A1=B0=ED=9A=8C=20=EB=8C=80=EC=83=81=EC=9D=84=20tb=5Fship?= =?UTF-8?q?=5Fdefault=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) --- .../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 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 Date: Tue, 24 Mar 2026 13:24:06 +0900 Subject: [PATCH 2/2] =?UTF-8?q?docs:=20=EB=A6=B4=EB=A6=AC=EC=A6=88=20?= =?UTF-8?q?=EB=85=B8=ED=8A=B8=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 --- docs/RELEASE-NOTES.md | 1 + 1 file changed, 1 insertion(+) diff --git a/docs/RELEASE-NOTES.md b/docs/RELEASE-NOTES.md index cd89be6..2bcc065 100644 --- a/docs/RELEASE-NOTES.md +++ b/docs/RELEASE-NOTES.md @@ -61,6 +61,7 @@ - 실패 건 수동 재수집 시 414 Request-URI Too Long 오류 수정 (#71) ### 변경 +- RiskDetailImportJob IMO 조회 대상을 tb_ship_default_info로 변경 (#81) - 파티션 스텝 프로세스 공통 모듈화 (StringListPartitioner, BasePartitionedJobConfig, LastExecutionUpdateTasklet) (#73) - 13개 Job Config의 인라인 LastExecutionUpdateTasklet을 공통 모듈로 교체 (#74) - 재수집 실패건 추적 기준 sourceStepExecutionId → sourceJobExecutionId로 변경 (#64)