✨ feat(batch): recommend music based on real time weather

backend/streetdrop-batch/build.gradle

@@ -13,13 +13,18 @@ jar {
     enabled = false
 }
 
+ext {
+    set('springCloudVersion', "2022.0.3")
+}
+
 dependencies {
     implementation project(':streetdrop-domain')
     implementation project(':streetdrop-common')
     implementation 'org.springframework.boot:spring-boot-starter-batch'
     implementation 'org.springframework.boot:spring-boot-starter-quartz'
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
     implementation 'org.springframework.boot:spring-boot-starter-security'
+    implementation 'org.springframework.cloud:spring-cloud-starter-openfeign'
 
     runtimeOnly 'com.mysql:mysql-connector-j'
 
@@ -34,6 +39,12 @@ dependencies {
     testAnnotationProcessor 'org.projectlombok:lombok'
 }
 
+dependencyManagement {
+    imports {
+        mavenBom "org.springframework.cloud:spring-cloud-dependencies:${springCloudVersion}"
+    }
+}
+
 test {
     useJUnitPlatform()
 }

backend/streetdrop-batch/src/main/java/com/depromeet/config/FeignConfig.java

@@ -0,0 +1,11 @@
+package com.depromeet.config;
+
+import com.depromeet.external.feign.client.OpenApiFeignClient;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.context.annotation.Configuration;
+
+@Configuration
+@EnableFeignClients(clients = OpenApiFeignClient.class)
+public class FeignConfig {
+
+}

backend/streetdrop-batch/src/main/java/com/depromeet/domains/weather/jobs/RealTimeWeatherJob.java

@@ -0,0 +1,17 @@
+package com.depromeet.domains.weather.jobs;
+
+import com.depromeet.domains.weather.service.WeatherService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class RealTimeWeatherJob {
+
+	private final WeatherService weatherService;
+
+	public void run() {
+		weatherService.getRealTimeWeather();
+	}
+
+}

backend/streetdrop-batch/src/main/java/com/depromeet/domains/weather/response/dto/BodyDto.java

@@ -0,0 +1,10 @@
+package com.depromeet.domains.weather.response.dto;
+
+public record BodyDto(
+        String dataType,
+        ItemsDto items,
+        int pageNo,
+        int numOfRows,
+        int totalCount
+) {
+}

backend/streetdrop-batch/src/main/java/com/depromeet/domains/weather/response/dto/HeaderDto.java

@@ -0,0 +1,7 @@
+package com.depromeet.domains.weather.response.dto;
+
+public record HeaderDto(
+    String resultCode,
+    String resultMsg
+) {
+}

backend/streetdrop-batch/src/main/java/com/depromeet/domains/weather/response/dto/ItemDto.java

@@ -0,0 +1,11 @@
+package com.depromeet.domains.weather.response.dto;
+
+public record ItemDto(
+        String baseDate,
+        String baseTime,
+        String category,
+        int nx,
+        int ny,
+        String obsrValue
+) {
+}

backend/streetdrop-batch/src/main/java/com/depromeet/domains/weather/response/dto/ItemsDto.java

@@ -0,0 +1,8 @@
+package com.depromeet.domains.weather.response.dto;
+
+import java.util.List;
+
+public record ItemsDto(
+        List<ItemDto> item
+) {
+}

backend/streetdrop-batch/src/main/java/com/depromeet/domains/weather/response/dto/ResponseDto.java

@@ -0,0 +1,7 @@
+package com.depromeet.domains.weather.response.dto;
+
+public record ResponseDto(
+        HeaderDto header,
+        BodyDto body
+) {
+}

backend/streetdrop-batch/src/main/java/com/depromeet/domains/weather/response/dto/WeatherResponseDto.java

@@ -0,0 +1,6 @@
+package com.depromeet.domains.weather.response.dto;
+
+public record WeatherResponseDto(
+    ResponseDto response
+) {
+}

backend/streetdrop-batch/src/main/java/com/depromeet/domains/weather/scheduler/RealTimeWeatherBatchScheduler.java

@@ -0,0 +1,19 @@
+package com.depromeet.domains.weather.scheduler;
+
+import com.depromeet.domains.weather.jobs.RealTimeWeatherJob;
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+@Component
+@RequiredArgsConstructor
+public class RealTimeWeatherBatchScheduler {
+
+	private final RealTimeWeatherJob realTimeWeatherJob;
+
+	@Scheduled(cron = "0 0 */3 * * *")
+	public void runWeatherJob() {
+		realTimeWeatherJob.run();
+	}
+
+}

backend/streetdrop-batch/src/main/java/com/depromeet/domains/weather/service/WeatherService.java

@@ -0,0 +1,28 @@
+package com.depromeet.domains.weather.service;
+
+import com.depromeet.external.feign.client.OpenApiFeignClient;
+import com.depromeet.domains.weather.response.dto.WeatherResponseDto;
+import java.time.LocalDate;
+import java.time.LocalTime;
+import java.time.format.DateTimeFormatter;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class WeatherService {
+
+    @Value("${open-api.secret-key}")
+    private String openApiKey;
+
+    private final OpenApiFeignClient openApiFeignClient;
+
+    public WeatherResponseDto getRealTimeWeather() {
+        String date = LocalDate.now().format(DateTimeFormatter.ofPattern("yyyyMMdd"));
+        String time = LocalTime.now().format(DateTimeFormatter.ofPattern("HHmm"));
+
+        return openApiFeignClient.getRealTimeWeather(openApiKey, 1, 8, "json", date, time, 60, 125);
+    }
+
+}

backend/streetdrop-batch/src/main/java/com/depromeet/external/feign/client/OpenApiFeignClient.java

@@ -0,0 +1,24 @@
+package com.depromeet.external.feign.client;
+
+import com.depromeet.config.FeignConfig;
+import com.depromeet.domains.weather.response.dto.WeatherResponseDto;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.http.MediaType;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+
+@FeignClient(name = "openApiFeignClient", url = "${open-api.base-url}", configuration = FeignConfig.class)
+public interface OpenApiFeignClient {
+
+    @GetMapping(value = "${open-api.weather-api-url}", produces = MediaType.APPLICATION_JSON_VALUE)
+    WeatherResponseDto getRealTimeWeather(
+            @RequestParam("serviceKey") String serviceKey,
+            @RequestParam("pageNo") int pageNo,
+            @RequestParam("numOfRows") int numOfRows,
+            @RequestParam("dataType") String dataType,
+            @RequestParam("base_date") String baseDate,
+            @RequestParam("base_time") String baseTime,
+            @RequestParam("nx") int nx,
+            @RequestParam("ny") int ny);
+
+}

backend/streetdrop-batch/src/main/resources/application-prod.yml

@@ -18,4 +18,8 @@ auth:
   header: ${AUTH_HEADER}
   secret-key: ${AUTH_SECRET_KEY}
 fcm:
-  value: streetdrop-notification-fcm.json
+  value: streetdrop-notification-fcm.json
+open-api:
+  secret-key: ${OPEN_API_SECRET_KEY}
+  base-url: ${OPEN_API_BASE_URL}
+  weather-api-url: ${WEATHER_API_URL}