전남대 BE_나제법 5주차 과제(2단계)

README.md

@@ -10,4 +10,44 @@
 * 토큰 받기를 읽고 액세스 토큰을 추출한다.
 * 앱 키, 인가 코드가 절대 유출되지 않도록 한다.
   * 특히 시크릿 키는 GitHub나 클라이언트 코드 등 외부에서 볼 수 있는 곳에 추가하지 않는다.  
-* (선택) 인가 코드를 받는 방법이 불편한 경우 카카오 로그인 화면을 구현한다.
+* (선택) 인가 코드를 받는 방법이 불편한 경우 카카오 로그인 화면을 구현한다.
+
+### 🚀 2단계 - 주문하기
+***
+#### 기능 요구 사항
+카카오톡 메시지 API를 사용하여 주문하기 기능을 구현한다.
+
+* 주문할 때 수령인에게 보낼 메시지를 작성할 수 있다.
+* 상품 옵션과 해당 수량을 선택하여 주문하면 해당 상품 옵션의 수량이 차감된다.
+* 해당 상품이 위시 리스트에 있는 경우 위시 리스트에서 삭제한다.
+* 나에게 보내기를 읽고 주문 내역을 카카오톡 메시지로 전송한다.
+  * 메시지는 메시지 템플릿의 기본 템플릿이나 사용자 정의 템플릿을 사용하여 자유롭게 작성한다.  
+
+아래 예시와 같이 HTTP 메시지를 주고받도록 구현한다.
+
+##### Request
+```
+POST /api/orders HTTP/1.1
+Authorization: Bearer {token}
+Content-Type: application/json
+
+{
+    "optionId": 1,
+    "quantity": 2,
+    "message": "Please handle this order with care."
+}
+```
+
+##### Response
+```
+HTTP/1.1 201 Created
+Content-Type: application/json
+
+{
+"id": 1,
+"optionId": 1,
+"quantity": 2,
+"orderDateTime": "2024-07-21T10:00:00",
+"message": "Please handle this order with care."
+}
+```

src/main/java/gift/authentication/token/Token.java

@@ -15,6 +15,10 @@ public static Token from(String value) {
         return new Token(value);
     }
 
+    public static Token fromBearer(String value) {
+        return new Token(value.replace("Bearer ", ""));
+    }
+
     public String getValue() {
         return value;
     }

src/main/java/gift/config/KakaoProperties.java

@@ -1,5 +1,6 @@
 package gift.config;
 
+import java.net.URI;
 import org.springframework.boot.context.properties.ConfigurationProperties;
 import org.springframework.boot.context.properties.bind.ConstructorBinding;
 
@@ -13,17 +14,20 @@ public class KakaoProperties {
     private final String userInfoUrl;
     private final String tokenUrl;
     private final String responseType;
+    private final String messageUrl;
 
     @ConstructorBinding
     public KakaoProperties(String clientId, String redirectUri, String contentType,
-        String grantType, String userInfoUrl, String tokenUrl, String responseType) {
+        String grantType, String userInfoUrl, String tokenUrl, String responseType,
+        String messageUrl) {
         this.clientId = clientId;
         this.redirectUri = redirectUri;
         this.contentType = contentType;
         this.grantType = grantType;
         this.userInfoUrl = userInfoUrl;
         this.tokenUrl = tokenUrl;
         this.responseType = responseType;
+        this.messageUrl = messageUrl;
     }
 
     public String getClientId() {
@@ -53,4 +57,20 @@ public String getTokenUrl() {
     public String getResponseType() {
         return responseType;
     }
+
+    public String getMessageUrl() {
+        return messageUrl;
+    }
+
+    public URI getUserInfoUrlAsUri() {
+        return URI.create(userInfoUrl);
+    }
+
+    public URI getTokenUrlAsUri() {
+        return URI.create(tokenUrl);
+    }
+
+    public URI getMessageUrlAsUri() {
+        return URI.create(messageUrl);
+    }
 }

src/main/java/gift/service/LoginService.java

@@ -9,9 +9,6 @@
 import gift.web.client.dto.KakaoAccount;
 import gift.web.client.dto.KakaoInfo;
 import gift.web.dto.response.LoginResponse;
-import gift.web.validation.exception.client.InvalidCredentialsException;
-import java.net.URI;
-import java.net.URISyntaxException;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -47,30 +44,22 @@ public LoginResponse kakaoLogin(final String authorizationCode){
         return new LoginResponse(accessToken.getValue());
     }
 
-    private KakaoToken getToken(String authorizationCode) {
-        try {
-            return kakaoClient.getToken(
-                new URI(kakaoProperties.getTokenUrl()),
-                authorizationCode,
-                kakaoProperties.getClientId(),
-                kakaoProperties.getRedirectUri(),
-                kakaoProperties.getGrantType());
-        } catch (URISyntaxException e) {
-            throw new InvalidCredentialsException(e);
-        }
+    private KakaoToken getToken(final String authorizationCode) {
+        return kakaoClient.getToken(
+            kakaoProperties.getTokenUrlAsUri(),
+            authorizationCode,
+            kakaoProperties.getClientId(),
+            kakaoProperties.getRedirectUri(),
+            kakaoProperties.getGrantType());
     }
 
-    private KakaoInfo getInfo(KakaoToken kakaoToken) {
-        try {
-            return kakaoClient.getKakaoInfo(
-                new URI(kakaoProperties.getUserInfoUrl()),
-                getBearerToken(kakaoToken));
-        } catch (URISyntaxException e) {
-            throw new InvalidCredentialsException(e);
-        }
+    private KakaoInfo getInfo(final KakaoToken kakaoToken) {
+        return kakaoClient.getKakaoInfo(
+            kakaoProperties.getUserInfoUrlAsUri(),
+            getBearerToken(kakaoToken));
     }
 
-    private String getBearerToken(KakaoToken kakaoToken) {
+    private String getBearerToken(final KakaoToken kakaoToken) {
         return kakaoToken.getTokenType() + " " + kakaoToken.getAccessToken();
     }
 }

src/main/java/gift/service/OrderService.java

@@ -0,0 +1,71 @@
+package gift.service;
+
+import gift.authentication.token.JwtResolver;
+import gift.authentication.token.Token;
+import gift.config.KakaoProperties;
+import gift.web.client.KakaoClient;
+import gift.web.client.dto.KakaoCommerce;
+import gift.web.dto.request.order.CreateOrderRequest;
+import gift.web.dto.response.order.OrderResponse;
+import gift.web.dto.response.product.ReadProductResponse;
+import gift.web.dto.response.productoption.SubtractProductOptionQuantityResponse;
+import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Transactional;
+
+@Service
+@Transactional(readOnly = true)
+public class OrderService {
+
+    private final KakaoClient kakaoClient;
+    private final JwtResolver jwtResolver;
+    private final ProductOptionService productOptionService;
+    private final ProductService productService;
+    private final KakaoProperties kakaoProperties;
+
+    public OrderService(KakaoClient kakaoClient, JwtResolver jwtResolver, ProductOptionService productOptionService,
+        ProductService productService, KakaoProperties kakaoProperties) {
+        this.kakaoClient = kakaoClient;
+        this.jwtResolver = jwtResolver;
+        this.productOptionService = productOptionService;
+        this.productService = productService;
+        this.kakaoProperties = kakaoProperties;
+    }
+
+    @Transactional
+    public OrderResponse createOrder(String accessToken, Long productId, CreateOrderRequest request) {
+        //상품 옵션 수량 차감
+        SubtractProductOptionQuantityResponse subtractOptionStockResponse = productOptionService.subtractOptionStock(request);
+
+        ReadProductResponse product = productService.readProductById(productId);
+        KakaoCommerce kakaoCommerce = KakaoCommerce.of(product, request.getMessage());
+
+        sendOrderMessageIfSocialMember(accessToken, kakaoCommerce);
+        return new OrderResponse(
+            productId,
+            request.getOptionId(),
+            subtractOptionStockResponse.getStock(),
+            request.getQuantity(),
+            product.getName(),
+            request.getMessage());
+    }
+
+    /**
+     * 소셜 로그인을 통해 주문한 경우 카카오톡 메시지를 전송합니다
+     * @param accessToken Bearer Token
+     * @param kakaoCommerce 카카오 상거래 메시지
+     */
+    private void sendOrderMessageIfSocialMember(String accessToken, KakaoCommerce kakaoCommerce) {
+        jwtResolver.resolveSocialToken(Token.fromBearer(accessToken))
+            .ifPresent(socialToken -> {
+                String json = kakaoCommerce.toJson();
+                kakaoClient.sendMessage(
+                    kakaoProperties.getMessageUrlAsUri(),
+                    getBearerToken(socialToken),
+                    json);
+            });
+    }
+
+    private String getBearerToken(String token) {
+        return "Bearer " + token;
+    }
+}

src/main/java/gift/service/ProductOptionService.java

@@ -2,6 +2,8 @@
 
 import gift.domain.ProductOption;
 import gift.repository.ProductOptionRepository;
+import gift.repository.ProductRepository;
+import gift.web.dto.request.order.CreateOrderRequest;
 import gift.web.dto.request.productoption.CreateProductOptionRequest;
 import gift.web.dto.request.productoption.SubtractProductOptionQuantityRequest;
 import gift.web.dto.request.productoption.UpdateProductOptionRequest;
@@ -21,13 +23,17 @@
 public class ProductOptionService {
 
     private final ProductOptionRepository productOptionRepository;
+    private final ProductRepository productRepository;
 
-    public ProductOptionService(ProductOptionRepository productOptionRepository) {
+    public ProductOptionService(ProductOptionRepository productOptionRepository,
+        ProductRepository productRepository) {
         this.productOptionRepository = productOptionRepository;
+        this.productRepository = productRepository;
     }
 
     @Transactional
     public CreateProductOptionResponse createOption(Long productId, CreateProductOptionRequest request) {
+        validateExistsProduct(productId);
         String optionName = request.getName();
         validateOptionNameExists(productId, optionName);
 
@@ -36,6 +42,15 @@ public CreateProductOptionResponse createOption(Long productId, CreateProductOpt
         return CreateProductOptionResponse.fromEntity(createdOption);
     }
 
+    /**
+     * 상품이 존재하는지 확인합니다.
+     * @param productId 상품 아이디
+     */
+    private void validateExistsProduct(Long productId) {
+        productRepository.findById(productId)
+            .orElseThrow(() -> new ResourceNotFoundException("상품 아이디: ", productId.toString()));
+    }
+
     /**
      * 상품 옵션 이름이 이미 존재하는지 확인합니다.<br>
      * 이미 존재한다면 {@link AlreadyExistsException} 을 발생시킵니다.
@@ -131,6 +146,10 @@ public SubtractProductOptionQuantityResponse subtractOptionStock(Long optionId,
         return SubtractProductOptionQuantityResponse.fromEntity(option);
     }
 
+    public SubtractProductOptionQuantityResponse subtractOptionStock(CreateOrderRequest request) {
+        return subtractOptionStock(request.getOptionId(), new SubtractProductOptionQuantityRequest(request.getQuantity()));
+    }
+
     @Transactional
     public void deleteOption(Long optionId) {
         ProductOption option = productOptionRepository.findById(optionId)

src/main/java/gift/web/client/KakaoClient.java

@@ -1,10 +1,15 @@
 package gift.web.client;
 
+import static org.springframework.http.HttpHeaders.AUTHORIZATION;
+
 import gift.authentication.token.KakaoToken;
 import gift.web.client.dto.KakaoInfo;
+import gift.web.client.dto.KakaoMessageResult;
 import java.net.URI;
 import org.springframework.cloud.openfeign.FeignClient;
+import org.springframework.http.MediaType;
 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;
 
@@ -14,7 +19,7 @@ public interface KakaoClient {
     @PostMapping
     KakaoInfo getKakaoInfo(
         URI uri,
-        @RequestHeader("Authorization") String accessToken);
+        @RequestHeader(AUTHORIZATION) String accessToken);
 
     @PostMapping
     KakaoToken getToken(
@@ -23,4 +28,17 @@ KakaoToken getToken(
         @RequestParam("client_id") String clientId,
         @RequestParam("redirect_uri") String redirectUrl,
         @RequestParam("grant_type") String grantType);
+
+    /**
+     * 카카오톡 메시지 - 나에게 보내기
+     * @param uri {@link https://kapi.kakao.com/v2/api/talk/memo/default/send} 으로 고정
+     * @param accessToken Bearer Token
+     * @param templateObject 메시지 구성 요소를 담은 객체(Object) 피드, 리스트, 위치, 커머스, 텍스트, 캘린더 중 하나
+     */
+    @PostMapping(consumes = MediaType.APPLICATION_FORM_URLENCODED_VALUE)
+    KakaoMessageResult sendMessage(
+        URI uri,
+        @RequestHeader(AUTHORIZATION) String accessToken,
+        @RequestBody String templateObject
+    );
 }