✨ [FEAT] 주가 예측 게임 CRUD 구현 및 마이페이지 api(GET /api/v1/users) 수정

.github/pull_request_template.md

@@ -6,4 +6,4 @@
 - 어떤 작업을 했는지 요약해서 적어주세요.
 - ex) Spring Boot Security 설정 변경
 # 📸 결과 캡쳐화면
-- 실행한 결과를 캡쳐하여 올려주세요.
+- 실행한 결과를 캡쳐하여 올려주세요. / 확인

build.gradle

@@ -18,6 +18,12 @@ repositories {
     mavenCentral()
 }
 
+dependencyManagement {
+    imports {
+        mavenBom "org.springframework.cloud:spring-cloud-dependencies:2025.0.0"
+    }
+}
+
 dependencies {
     implementation 'org.springframework.boot:spring-boot-starter-web'
     implementation 'org.springframework.boot:spring-boot-starter-data-jpa'
@@ -38,6 +44,16 @@ dependencies {
     // Redis
     implementation 'org.springframework.boot:spring-boot-starter-data-redis'
 
+    // FeignClient
+    implementation 'org.springframework.cloud:spring-cloud-starter-openfeign'
+
+    // Excel
+    implementation 'org.apache.poi:poi-ooxml:5.5.1'
+
+    // AWS S3
+    implementation 'software.amazon.awssdk:s3:2.25.26'
+    implementation 'software.amazon.awssdk:url-connection-client:2.25.26'
+
     runtimeOnly 'com.mysql:mysql-connector-j'
 
     compileOnly 'org.projectlombok:lombok'

src/main/java/com/example/demo/DemoApplication.java

@@ -2,8 +2,12 @@
 
 import org.springframework.boot.SpringApplication;
 import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.cloud.openfeign.EnableFeignClients;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @SpringBootApplication
+@EnableFeignClients
+@EnableScheduling
 public class DemoApplication {
 
     public static void main(String[] args) {

src/main/java/com/example/demo/api/favoriteStock/dto/FavoriteStockRequestDto.java

@@ -7,6 +7,5 @@
 @Builder
 public class FavoriteStockRequestDto {
     private String stockCode;
-    private String ticker;
-    private Integer days;
+    private String stockName;
 }

src/main/java/com/example/demo/api/favoriteStock/dto/FavoriteStockResponseDto.java

@@ -17,7 +17,7 @@ public static class FavoriteStockDto {
         private Long favoriteStockId;
         private Long userId;
         private String stockCode;
-        private String ticker;
+        private String stockName;
         private Boolean isAlertEnabled;
     }
 

src/main/java/com/example/demo/api/favoriteStock/mapper/FavoriteStockConverter.java

@@ -14,8 +14,7 @@ public static FavoriteStock toFavoriteStock(User user, FavoriteStockRequestDto r
         return FavoriteStock.builder()
                 .user(user)
                 .stockCode(request.getStockCode())
-                .ticker(request.getTicker())
-                .days(request.getDays())
+                .stockName(request.getStockName())
                 .isAlertEnabled(false)
                 .build();
     }
@@ -25,7 +24,7 @@ public static FavoriteStockDto toFavoriteStockDto(FavoriteStock favoriteStock) {
                 .favoriteStockId(favoriteStock.getId())
                 .userId(favoriteStock.getUser().getId())
                 .stockCode(favoriteStock.getStockCode())
-                .ticker(favoriteStock.getTicker())
+                .stockName(favoriteStock.getStockName())
                 .isAlertEnabled(favoriteStock.getIsAlertEnabled())
                 .build();
     }

src/main/java/com/example/demo/api/kis/client/KisFeignClient.java

@@ -0,0 +1,32 @@
+package com.example.demo.api.kis.client;
+
+import com.example.demo.api.kis.dto.KisResponseDto;
+import com.example.demo.api.kis.dto.KisTokenRequestDto;
+import com.example.demo.api.kis.dto.KisTokenResponseDto;
+import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestHeader;
+import org.springframework.web.bind.annotation.RequestParam;
+
+@FeignClient(name = "kisClient", url = "${kis.base-url}")
+public interface KisFeignClient {
+
+    @PostMapping("/oauth2/tokenP")
+    KisTokenResponseDto issueToken(@RequestBody KisTokenRequestDto request);
+
+    @GetMapping("/uapi/domestic-stock/v1/quotations/inquire-daily-itemchartprice")
+    KisResponseDto getDailyStockPrice(
+            @RequestHeader("authorization") String authorization,
+            @RequestHeader("appkey")        String appKey,
+            @RequestHeader("appsecret")     String appSecret,
+            @RequestHeader("tr_id")         String trId,
+            @RequestParam("FID_COND_MRKT_DIV_CODE") String fidCondMrktDivCode,
+            @RequestParam("FID_INPUT_ISCD")          String fidInputIscd,
+            @RequestParam("FID_INPUT_DATE_1")        String fidInputDate1,
+            @RequestParam("FID_INPUT_DATE_2")        String fidInputDate2,
+            @RequestParam("FID_PERIOD_DIV_CODE")     String fidPeriodDivCode,
+            @RequestParam("FID_ORG_ADJ_PRC")         String fidOrgAdjPrc
+    );
+}

src/main/java/com/example/demo/api/kis/dto/KisResponseDto.java

@@ -0,0 +1,34 @@
+package com.example.demo.api.kis.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Getter
+@NoArgsConstructor
+public class KisResponseDto {
+
+    @JsonProperty("rt_cd")
+    private String rtCd;
+
+    @JsonProperty("msg1")
+    private String msg1;
+
+    @JsonProperty("output2")
+    private List<DailyData> output2;
+
+    @Getter
+    @NoArgsConstructor
+    public static class DailyData {
+        @JsonProperty("stck_bsop_date")
+        private String date;
+
+        @JsonProperty("stck_oprc")
+        private String openPrice;
+
+        @JsonProperty("stck_clpr")
+        private String closePrice;
+    }
+}

src/main/java/com/example/demo/api/kis/dto/KisTokenRequestDto.java

@@ -0,0 +1,19 @@
+package com.example.demo.api.kis.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+
+@Getter
+@AllArgsConstructor
+public class KisTokenRequestDto {
+
+    @JsonProperty("grant_type")
+    private String grantType;
+
+    @JsonProperty("appkey")
+    private String appKey;
+
+    @JsonProperty("appsecret")
+    private String appSecret;
+}

src/main/java/com/example/demo/api/kis/dto/KisTokenResponseDto.java

@@ -0,0 +1,22 @@
+package com.example.demo.api.kis.dto;
+
+import com.fasterxml.jackson.annotation.JsonProperty;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+public class KisTokenResponseDto {
+
+    @JsonProperty("access_token")
+    private String accessToken;
+
+    @JsonProperty("token_type")
+    private String tokenType;
+
+    @JsonProperty("expires_in")
+    private Long expiresIn;
+
+    @JsonProperty("access_token_token_expired")
+    private String accessTokenTokenExpired;
+}

src/main/java/com/example/demo/api/kis/service/KisService.java

@@ -0,0 +1,57 @@
+package com.example.demo.api.kis.service;
+
+import com.example.demo.api.kis.client.KisFeignClient;
+import com.example.demo.api.kis.dto.KisResponseDto;
+import com.example.demo.domain.stock.exception.StockHandler;
+import feign.FeignException;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.util.Objects;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class KisService {
+
+    private final KisFeignClient kisFeignClient;
+    private final KisTokenService kisTokenService;
+
+    @Value("${kis.app-key}")
+    private String appKey;
+
+    @Value("${kis.app-secret}")
+    private String appSecret;
+
+    public KisResponseDto getDailyStockPrice(String stockCode, String startDate, String endDate) {
+        String token = kisTokenService.getAccessToken();
+
+        try {
+            KisResponseDto response = kisFeignClient.getDailyStockPrice(
+                    "Bearer " + token,
+                    appKey,
+                    appSecret,
+                    "FHKST03010100",
+                    "J",
+                    stockCode,
+                    startDate,
+                    endDate,
+                    "D",
+                    "0"
+            );
+
+            if (response == null || !"0".equals(response.getRtCd())) {
+                log.error("KIS API 응답 오류. rt_cd={}, msg={}", Objects.requireNonNull(response).getRtCd(), response.getMsg1());
+                throw StockHandler.kisApiError();
+            }
+
+            return response;
+
+        } catch (FeignException e) {
+            log.error("KIS API 호출 실패. status={}, stockCode={}", e.status(), stockCode);
+            throw StockHandler.kisApiError();
+        }
+    }
+}

src/main/java/com/example/demo/api/kis/service/KisTokenService.java

@@ -0,0 +1,76 @@
+package com.example.demo.api.kis.service;
+
+import com.example.demo.api.kis.client.KisFeignClient;
+import com.example.demo.api.kis.dto.KisTokenRequestDto;
+import com.example.demo.api.kis.dto.KisTokenResponseDto;
+import com.example.demo.common.service.RedisService;
+import com.example.demo.common.util.RedisUtil;
+import com.example.demo.domain.stock.exception.StockHandler;
+import feign.FeignException;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.stereotype.Service;
+
+import java.time.Duration;
+
+import static com.example.demo.common.consts.StaticVariable.GRANT_TYPE;
+import static com.example.demo.common.consts.StaticVariable.TOKEN_KEY;
+
+@Slf4j
+@Service
+@RequiredArgsConstructor
+public class KisTokenService {
+
+    private final KisFeignClient kisFeignClient;
+    private final RedisService redisService;
+    private final RedisUtil redisUtil;
+
+    @Value("${kis.app-key}")
+    private String appKey;
+
+    @Value("${kis.app-secret}")
+    private String appSecret;
+
+    public String getAccessToken() {
+        log.info("[KIS 토큰] 1. Redis 캐시 조회 시작. key={}", TOKEN_KEY);
+        String cached = redisService.getValue(TOKEN_KEY);
+
+        if (cached != null && !cached.isBlank()) {
+            log.info("[KIS 토큰] 2. 캐시 히트 - 저장된 토큰 반환");
+            return cached;
+        }
+        log.info("[KIS 토큰] 2. 캐시 미스 - 신규 발급 시작");
+
+        log.info("[KIS 토큰] 3. KIS API 토큰 발급 요청. appKey={}", appKey);
+        try {
+            KisTokenResponseDto tokenResponse = kisFeignClient.issueToken(
+                    new KisTokenRequestDto(GRANT_TYPE, appKey, appSecret)
+            );
+            log.info("[KIS 토큰] 4. KIS API 응답 수신. response={}", tokenResponse);
+
+            if (tokenResponse == null || tokenResponse.getAccessToken() == null
+                    || tokenResponse.getAccessToken().isBlank()) {
+                log.error("[KIS 토큰] 5. 응답 토큰 값 없음 (null 또는 blank)");
+                throw StockHandler.kisApiError();
+            }
+            log.info("[KIS 토큰] 5. 응답 토큰 정상 확인. expiredAt={}", tokenResponse.getAccessTokenTokenExpired());
+
+            String token = tokenResponse.getAccessToken();
+
+            log.info("[KIS 토큰] 6. TTL 계산 시작. expiredAt={}", tokenResponse.getAccessTokenTokenExpired());
+            Duration ttl = redisUtil.calculateTtl(tokenResponse.getAccessTokenTokenExpired());
+            log.info("[KIS 토큰] 7. TTL 계산 완료. ttl={}s", ttl.getSeconds());
+
+            log.info("[KIS 토큰] 8. Redis 저장 시작. key={}, ttl={}s", TOKEN_KEY, ttl.getSeconds());
+            redisService.setKisTokenExpiresValueWithTtl(TOKEN_KEY, token, ttl);
+            log.info("[KIS 토큰] 9. Redis 저장 완료");
+
+            return token;
+
+        } catch (FeignException e) {
+            log.error("[KIS 토큰] FeignException 발생. status={}, message={}", e.status(), e.getMessage());
+            throw StockHandler.kisApiError();
+        }
+    }
+}