diff --git a/src/main/java/com/snp/batch/jobs/common/batch/config/FlagCodeImportJobConfig.java b/src/main/java/com/snp/batch/jobs/common/batch/config/FlagCodeImportJobConfig.java index 3938b45..a920d7e 100644 --- a/src/main/java/com/snp/batch/jobs/common/batch/config/FlagCodeImportJobConfig.java +++ b/src/main/java/com/snp/batch/jobs/common/batch/config/FlagCodeImportJobConfig.java @@ -21,15 +21,6 @@ import org.springframework.context.annotation.Configuration; import org.springframework.transaction.PlatformTransactionManager; import org.springframework.web.reactive.function.client.WebClient; -/** - * Ship Data Import Job 설정 - * BaseJobConfig를 상속하여 구현 - * - * Maritime API에서 선박 데이터를 받아 PostgreSQL에 저장하는 배치 작업: - * - Maritime API에서 170,000+ 선박 IMO 번호 조회 - * - 중복 체크 및 업데이트 로직 - * - PostgreSQL에 저장 - */ @Slf4j @Configuration public class FlagCodeImportJobConfig extends BaseJobConfig { diff --git a/src/main/java/com/snp/batch/jobs/common/batch/entity/FlagCodeEntity.java b/src/main/java/com/snp/batch/jobs/common/batch/entity/FlagCodeEntity.java index b35435c..995d108 100644 --- a/src/main/java/com/snp/batch/jobs/common/batch/entity/FlagCodeEntity.java +++ b/src/main/java/com/snp/batch/jobs/common/batch/entity/FlagCodeEntity.java @@ -7,12 +7,6 @@ import lombok.EqualsAndHashCode; import lombok.NoArgsConstructor; import lombok.experimental.SuperBuilder; -/** - * 선박 엔티티 - JDBC 전용 - * Maritime API 데이터 저장 - * - * 테이블: ship_data - */ @Data @SuperBuilder @NoArgsConstructor diff --git a/src/main/java/com/snp/batch/jobs/common/batch/entity/Stat5CodeEntity.java b/src/main/java/com/snp/batch/jobs/common/batch/entity/Stat5CodeEntity.java index a633f75..b5e2d76 100644 --- a/src/main/java/com/snp/batch/jobs/common/batch/entity/Stat5CodeEntity.java +++ b/src/main/java/com/snp/batch/jobs/common/batch/entity/Stat5CodeEntity.java @@ -1,6 +1,5 @@ package com.snp.batch.jobs.common.batch.entity; -import com.fasterxml.jackson.annotation.JsonProperty; import com.snp.batch.common.batch.entity.BaseEntity; import lombok.AllArgsConstructor; import lombok.Data; diff --git a/src/main/java/com/snp/batch/jobs/common/batch/processor/FlagCodeDataProcessor.java b/src/main/java/com/snp/batch/jobs/common/batch/processor/FlagCodeDataProcessor.java index 0b1cb9b..fb6966b 100644 --- a/src/main/java/com/snp/batch/jobs/common/batch/processor/FlagCodeDataProcessor.java +++ b/src/main/java/com/snp/batch/jobs/common/batch/processor/FlagCodeDataProcessor.java @@ -6,11 +6,6 @@ import com.snp.batch.jobs.common.batch.entity.FlagCodeEntity; import com.snp.batch.jobs.common.batch.repository.FlagCodeRepository; import lombok.extern.slf4j.Slf4j; -/** - * ShipDto를 ShipEntity로 변환하는 Processor - * BaseProcessor를 상속하여 공통 변환 패턴 적용 - * 중복 체크 및 업데이트 로직 포함 - */ @Slf4j public class FlagCodeDataProcessor extends BaseProcessor { diff --git a/src/main/java/com/snp/batch/jobs/common/batch/processor/Stat5CodeDataProcessor.java b/src/main/java/com/snp/batch/jobs/common/batch/processor/Stat5CodeDataProcessor.java index 46a56c0..fd5c1b7 100644 --- a/src/main/java/com/snp/batch/jobs/common/batch/processor/Stat5CodeDataProcessor.java +++ b/src/main/java/com/snp/batch/jobs/common/batch/processor/Stat5CodeDataProcessor.java @@ -6,7 +6,6 @@ import com.snp.batch.jobs.common.batch.entity.Stat5CodeEntity; import com.snp.batch.jobs.common.batch.repository.Stat5CodeRepository; import lombok.extern.slf4j.Slf4j; -import java.sql.PreparedStatement; @Slf4j public class Stat5CodeDataProcessor extends BaseProcessor { diff --git a/src/main/java/com/snp/batch/jobs/common/batch/reader/FlagCodeDataReader.java b/src/main/java/com/snp/batch/jobs/common/batch/reader/FlagCodeDataReader.java index 4684b4b..08802af 100644 --- a/src/main/java/com/snp/batch/jobs/common/batch/reader/FlagCodeDataReader.java +++ b/src/main/java/com/snp/batch/jobs/common/batch/reader/FlagCodeDataReader.java @@ -9,10 +9,6 @@ import org.springframework.web.reactive.function.client.WebClient; import java.util.ArrayList; import java.util.List; -/** - * Maritime API에서 선박 데이터를 읽어오는 ItemReader - * BaseApiReader v2.0을 상속하여 공통 API 호출 패턴 적용 - */ @Slf4j public class FlagCodeDataReader extends BaseApiReader { diff --git a/src/main/java/com/snp/batch/jobs/common/batch/repository/FlagCodeRepository.java b/src/main/java/com/snp/batch/jobs/common/batch/repository/FlagCodeRepository.java index bfdfbdf..304bb8b 100644 --- a/src/main/java/com/snp/batch/jobs/common/batch/repository/FlagCodeRepository.java +++ b/src/main/java/com/snp/batch/jobs/common/batch/repository/FlagCodeRepository.java @@ -4,10 +4,6 @@ import com.snp.batch.jobs.common.batch.entity.FlagCodeEntity; import java.util.List; -/** - * ShipEntity Repository 인터페이스 - * 구현체: ShipRepositoryImpl (JdbcTemplate 기반) - */ public interface FlagCodeRepository { void saveAllFlagCode(List items); diff --git a/src/main/java/com/snp/batch/jobs/common/batch/repository/FlagCodeRepositoryImpl.java b/src/main/java/com/snp/batch/jobs/common/batch/repository/FlagCodeRepositoryImpl.java index 8d46128..ee2e3ab 100644 --- a/src/main/java/com/snp/batch/jobs/common/batch/repository/FlagCodeRepositoryImpl.java +++ b/src/main/java/com/snp/batch/jobs/common/batch/repository/FlagCodeRepositoryImpl.java @@ -10,9 +10,6 @@ import org.springframework.stereotype.Repository; import java.sql.PreparedStatement; import java.util.List; -/** - * ShipEntity Repository (JdbcTemplate 기반) - */ @Slf4j @Repository("FlagCodeRepository") public class FlagCodeRepositoryImpl extends BaseJdbcRepository implements FlagCodeRepository { diff --git a/src/main/java/com/snp/batch/jobs/common/batch/writer/FlagCodeDataWriter.java b/src/main/java/com/snp/batch/jobs/common/batch/writer/FlagCodeDataWriter.java index 9bf0b6d..5c5b82e 100644 --- a/src/main/java/com/snp/batch/jobs/common/batch/writer/FlagCodeDataWriter.java +++ b/src/main/java/com/snp/batch/jobs/common/batch/writer/FlagCodeDataWriter.java @@ -7,10 +7,6 @@ import lombok.extern.slf4j.Slf4j; import java.util.List; -/** - * ShipEntity를 DB에 저장하는 ItemWriter - * BaseWriter를 상속하여 공통 저장 패턴 적용 - */ @Slf4j public class FlagCodeDataWriter extends BaseWriter {