⚰️ 불필요한 주석 제거
This commit is contained in:
부모
084be88b98
커밋
270b2a0b55
@ -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<FlagCodeDto, FlagCodeEntity> {
|
||||
|
||||
@ -7,12 +7,6 @@ import lombok.EqualsAndHashCode;
|
||||
import lombok.NoArgsConstructor;
|
||||
import lombok.experimental.SuperBuilder;
|
||||
|
||||
/**
|
||||
* 선박 엔티티 - JDBC 전용
|
||||
* Maritime API 데이터 저장
|
||||
*
|
||||
* 테이블: ship_data
|
||||
*/
|
||||
@Data
|
||||
@SuperBuilder
|
||||
@NoArgsConstructor
|
||||
|
||||
@ -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;
|
||||
|
||||
@ -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<FlagCodeDto, FlagCodeEntity> {
|
||||
|
||||
|
||||
@ -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<Stat5CodeDto, Stat5CodeEntity> {
|
||||
|
||||
@ -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<FlagCodeDto> {
|
||||
|
||||
|
||||
@ -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<FlagCodeEntity> items);
|
||||
|
||||
@ -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<FlagCodeEntity, String> implements FlagCodeRepository {
|
||||
|
||||
@ -7,10 +7,6 @@ import lombok.extern.slf4j.Slf4j;
|
||||
|
||||
import java.util.List;
|
||||
|
||||
/**
|
||||
* ShipEntity를 DB에 저장하는 ItemWriter
|
||||
* BaseWriter를 상속하여 공통 저장 패턴 적용
|
||||
*/
|
||||
@Slf4j
|
||||
public class FlagCodeDataWriter extends BaseWriter<FlagCodeEntity> {
|
||||
|
||||
|
||||
불러오는 중...
Reference in New Issue
Block a user