Feign client 이용하여 tour API 호출

build.gradle

@@ -21,10 +21,16 @@ repositories {
     mavenCentral()
 }
 
+ext {
+    set('springCloudVersion', "2022.0.4")
+}
+
 dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-web'
     implementation 'org.springframework.boot:spring-boot-starter-batch'
+    implementation 'org.springframework.cloud:spring-cloud-starter'
     implementation 'org.springframework.cloud:spring-cloud-starter-openfeign'
+    runtimeOnly 'org.mariadb.jdbc:mariadb-java-client:3.1.2'
     compileOnly 'org.projectlombok:lombok'
     developmentOnly 'org.springframework.boot:spring-boot-devtools'
     annotationProcessor 'org.projectlombok:lombok'
@@ -33,7 +39,7 @@ dependencies {
 
 dependencyManagement {
     imports {
-        mavenBom "org.springframework.cloud:spring-cloud-dependencies:2022.0.3"
+        mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
     }
 }
 

src/main/java/com/catcher/batch/BatchApplication.java

@@ -1,9 +1,15 @@
 package com.catcher.batch;
 
+import org.springframework.batch.core.configuration.annotation.EnableBatchProcessing;
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
+@EnableBatchProcessing
+@EnableScheduling
+@EnableFeignClients(basePackages = "com.catcher.batch.external")
 public class BatchApplication {
 
     public static void main(String[] args) {

src/main/java/com/catcher/batch/external/TourApiServiceExternalCallService.java

@@ -0,0 +1,14 @@
+package com.catcher.batch.external;
+
+import com.catcher.batch.external.vo.request.TourApiRequest;
+import com.catcher.batch.external.vo.response.TourApiResponse;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.cloud.openfeign.SpringQueryMap;
+import org.springframework.web.bind.annotation.GetMapping;
+
+@FeignClient(name = "TOUR-API-SERVICE", url = "http://apis.data.go.kr/${your_app_key}/KorService1")
+public interface TourApiServiceExternalCallService {
+
+    @GetMapping("/searchFestival1")
+    TourApiResponse callTourList(@SpringQueryMap TourApiRequest request);
+}

src/main/java/com/catcher/batch/external/vo/request/TourApiRequest.java

@@ -0,0 +1,27 @@
+package com.catcher.batch.external.vo.request;
+
+import lombok.Getter;
+
+/* TODO: 하드코딩된 값 바꾸기 */
+
+@Getter
+public class TourApiRequest {
+
+    private Integer numOfRows = 100;
+
+    private Integer pageNo = 1;
+
+    private String MobileOS = "ETC";
+
+    private String MobileApp = "AppTest";
+
+    private String _type = "json";
+
+    private String listYN = "Y";
+
+    private String arrange = "A";
+
+    private String eventStartDate = "20230901";
+
+    private String serviceKey = "your_service_key";
+}

src/main/java/com/catcher/batch/external/vo/response/TourApiResponse.java

@@ -0,0 +1,66 @@
+package com.catcher.batch.external.vo.response;
+
+import lombok.Getter;
+
+import java.util.List;
+
+@Getter
+public class TourApiResponse {
+
+    private InnerTourAPiResponse response;
+
+    @Getter
+    public static class InnerTourAPiResponse {
+
+        private TourApiHeader header;
+
+        private TourApiBody body;
+    }
+
+    @Getter
+    public static class TourApiHeader {
+        private String resultCode;
+        private String resultMsg;
+    }
+
+    @Getter
+    public static class TourApiBody {
+
+        private TourApiItems items;
+        private Integer numOfRows;
+        private Integer pageNo;
+        private Integer totalCount;
+    }
+
+    @Getter
+    public static class TourApiItems {
+        private List<TourApiItem> item;
+    }
+
+    /* TODO: JsonProperty 어노테이션 이용하여 적당한 변수명으로 바꾸기 */
+    @Getter
+    public static class TourApiItem {
+        private String addr1;
+        private String addr2;
+        private String booktour;
+        private String cat1;
+        private String cat2;
+        private String cat3;
+        private String contentid;
+        private String contenttypeid;
+        private String createdtime;
+        private String eventstartdate;
+        private String eventenddate;
+        private String firstimage;
+        private String firstimage2;
+        private String cpyrhtDivCd;
+        private String mapx;
+        private String mapy;
+        private String mlevel;
+        private String modifiedtime;
+        private String areacode;
+        private String sigungucode;
+        private String tel;
+        private String title;
+    }
+}

src/main/java/com/catcher/batch/job/config/CommonJobConfig.java

@@ -0,0 +1,10 @@
+package com.catcher.batch.job.config;
+
+import lombok.RequiredArgsConstructor;
+import org.springframework.batch.core.launch.JobLauncher;
+
+@RequiredArgsConstructor
+public class CommonJobConfig {
+
+    protected final JobLauncher jobLauncher;
+}

src/main/java/com/catcher/batch/job/config/TourApiJob.java

@@ -0,0 +1,22 @@
+package com.catcher.batch.job.config;
+
+import com.catcher.batch.external.TourApiServiceExternalCallService;
+import com.catcher.batch.external.vo.request.TourApiRequest;
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class TourApiJob {
+
+    private final TourApiServiceExternalCallService tourApiServiceExternalCallService;
+
+    /* TODO: Spring batch 이용하도록 변경? */
+    @Scheduled(fixedDelay = 1000000) //TODO: 시간대 정해서 하루에 1번으로 변경
+    public void tourApiJob() {
+
+        final var response = tourApiServiceExternalCallService.callTourList(new TourApiRequest());
+    }
+
+}

src/main/resources/application-dev.properties

@@ -0,0 +1,27 @@
+spring.datasource.driver-class-name=org.mariadb.jdbc.Driver
+
+## spring datasource
+spring.datasource.url=${DATASOURCE_URL}
+spring.datasource.username=${DATASOURCE_USERNAME}
+spring.datasource.password=${DATASOURCE_PASSWORD}
+
+
+## ssh
+ssh.host=${SSH_HOST}
+ssh.port=${SSH_PORT}
+ssh.username=${SSH_USERNAME}
+ssh.password=${SSH_PASSWORD}
+ssh.local-port=${SSH_LOCAL_PORT}
+ssh.datasource.origin=${SSH_DATASOURCE_ORIGIN}
+
+#update the schema with the given values.
+spring.jpa.hibernate.ddl-auto=update
+#To beautify or pretty print the SQL
+spring.jpa.properties.hibernate.format_sql=true
+#show sql
+spring.jpa.properties.hibernate.show-sql=true
+#show parameter binding
+logging.level.org.hibernate.type.descriptor.sql=DEBUG
+
+logging.level.org.hibernate.SQL=DEBUG
+spring.jpa.properties.hibernate.dialect= org.hibernate.dialect.MariaDBDialect

src/main/resources/application-local.properties

@@ -0,0 +1,27 @@
+spring.datasource.driver-class-name=org.mariadb.jdbc.Driver
+
+## spring datasource
+spring.datasource.url=${DATASOURCE_URL}
+spring.datasource.username=${DATASOURCE_USERNAME}
+spring.datasource.password=${DATASOURCE_PASSWORD}
+
+
+## ssh
+ssh.host=${SSH_HOST}
+ssh.port=${SSH_PORT}
+ssh.username=${SSH_USERNAME}
+ssh.password=${SSH_PASSWORD}
+ssh.local-port=${SSH_LOCAL_PORT}
+ssh.datasource.origin=${SSH_DATASOURCE_ORIGIN}
+
+#update the schema with the given values.
+spring.jpa.hibernate.ddl-auto=update
+#To beautify or pretty print the SQL
+spring.jpa.properties.hibernate.format_sql=true
+#show sql
+spring.jpa.properties.hibernate.show-sql=true
+#show parameter binding
+logging.level.org.hibernate.type.descriptor.sql=DEBUG
+
+logging.level.org.hibernate.SQL=DEBUG
+spring.jpa.properties.hibernate.dialect= org.hibernate.dialect.MariaDBDialect

src/main/resources/application-prod.properties

@@ -0,0 +1,27 @@
+spring.datasource.driver-class-name=org.mariadb.jdbc.Driver
+
+## spring datasource
+spring.datasource.url=${DATASOURCE_URL}
+spring.datasource.username=${DATASOURCE_USERNAME}
+spring.datasource.password=${DATASOURCE_PASSWORD}
+
+
+## ssh
+ssh.host=${SSH_HOST}
+ssh.port=${SSH_PORT}
+ssh.username=${SSH_USERNAME}
+ssh.password=${SSH_PASSWORD}
+ssh.local-port=${SSH_LOCAL_PORT}
+ssh.datasource.origin=${SSH_DATASOURCE_ORIGIN}
+
+#update the schema with the given values.
+spring.jpa.hibernate.ddl-auto=update
+#To beautify or pretty print the SQL
+spring.jpa.properties.hibernate.format_sql=true
+#show sql
+spring.jpa.properties.hibernate.show-sql=true
+#show parameter binding
+logging.level.org.hibernate.type.descriptor.sql=DEBUG
+
+logging.level.org.hibernate.SQL=DEBUG
+spring.jpa.properties.hibernate.dialect= org.hibernate.dialect.MariaDBDialect

src/main/resources/application.properties

@@ -1 +1,27 @@
+spring.datasource.driver-class-name=org.mariadb.jdbc.Driver
 
+## spring datasource
+spring.datasource.url=${DATASOURCE_URL}
+spring.datasource.username=${DATASOURCE_USERNAME}
+spring.datasource.password=${DATASOURCE_PASSWORD}
+
+
+## ssh
+ssh.host=${SSH_HOST}
+ssh.port=${SSH_PORT}
+ssh.username=${SSH_USERNAME}
+ssh.password=${SSH_PASSWORD}
+ssh.local-port=${SSH_LOCAL_PORT}
+ssh.datasource.origin=${SSH_DATASOURCE_ORIGIN}
+
+#update the schema with the given values.
+spring.jpa.hibernate.ddl-auto=update
+#To beautify or pretty print the SQL
+spring.jpa.properties.hibernate.format_sql=true
+#show sql
+spring.jpa.properties.hibernate.show-sql=true
+#show parameter binding
+logging.level.org.hibernate.type.descriptor.sql=DEBUG
+
+logging.level.org.hibernate.SQL=DEBUG
+spring.jpa.properties.hibernate.dialect= org.hibernate.dialect.MariaDBDialect