Merge branch 'dev_ship_movement' into dev_ship_detail

# Conflicts:
#	src/main/java/com/snp/batch/global/config/MaritimeApiWebClientConfig.java
This commit is contained in:
hyojin kim 2025-11-27 22:20:21 +09:00
부모 e44637e1f3
커밋 4ed1070a37
2개의 변경된 파일10개의 추가작업 그리고 9개의 파일을 삭제

파일 보기

@ -29,11 +29,12 @@ public class MaritimeApiWebClientConfig {
@Value("${app.batch.ship-api.url}") @Value("${app.batch.ship-api.url}")
private String maritimeApiUrl; private String maritimeApiUrl;
@Value("https://aisapi.maritime.spglobal.com") @Value("${app.batch.ais-api.url}")
private String maritimeAisApiUrl; private String maritimeAisApiUrl;
@Value("https://webservices.maritime.spglobal.com") @Value("${app.batch.webservice-api.url}")
private String maritimeWebSerivcesUrl; private String maritimeServiceApiUrl;
@Value("${app.batch.ship-api.username}") @Value("${app.batch.ship-api.username}")
private String maritimeApiUsername; private String maritimeApiUsername;
@ -83,15 +84,15 @@ public class MaritimeApiWebClientConfig {
.build(); .build();
} }
@Bean(name = "maritimeWebServicesWebClient") @Bean(name = "maritimeServiceApiWebClient")
public WebClient maritimeWebServicesWebClient(){ public WebClient maritimeServiceApiWebClient(){
log.info("========================================"); log.info("========================================");
log.info("Maritime WebSerivces WebClient 생성"); log.info("Maritime AIS API WebClient 생성");
log.info("Base URL: {}", maritimeWebSerivcesUrl); log.info("Base URL: {}", maritimeServiceApiUrl);
log.info("========================================"); log.info("========================================");
return WebClient.builder() return WebClient.builder()
.baseUrl(maritimeWebSerivcesUrl) .baseUrl(maritimeServiceApiUrl)
.defaultHeaders(headers -> headers.setBasicAuth(maritimeApiUsername, maritimeApiPassword)) .defaultHeaders(headers -> headers.setBasicAuth(maritimeApiUsername, maritimeApiPassword))
.codecs(configurer -> configurer .codecs(configurer -> configurer
.defaultCodecs() .defaultCodecs()

파일 보기

@ -60,7 +60,7 @@ public class ShipMovementJobConfig extends BaseJobConfig<PortCallDto, ShipMoveme
PlatformTransactionManager transactionManager, PlatformTransactionManager transactionManager,
ShipMovementProcessor shipMovementProcessor, ShipMovementProcessor shipMovementProcessor,
ShipMovementWriter shipMovementWriter, JdbcTemplate jdbcTemplate, ShipMovementWriter shipMovementWriter, JdbcTemplate jdbcTemplate,
@Qualifier("maritimeWebServicesWebClient") WebClient maritimeApiWebClient, @Qualifier("maritimeServiceApiWebClient") WebClient maritimeApiWebClient,
ObjectMapper objectMapper) { // ObjectMapper 주입 추가 ObjectMapper objectMapper) { // ObjectMapper 주입 추가
super(jobRepository, transactionManager); super(jobRepository, transactionManager);
this.shipMovementProcessor = shipMovementProcessor; this.shipMovementProcessor = shipMovementProcessor;