[BACKEND] 로그아웃, 상품 검색, 커스텀 관심사 기능 추가 (#35)

ddoed · web-flow · commit 1a7741e9bab2 · 2025-09-26T13:34:22.000+09:00
diff --git a/backend/src/main/java/com/cmg/comtogether/common/exception/ErrorCode.java b/backend/src/main/java/com/cmg/comtogether/common/exception/ErrorCode.java
@@ -23,7 +23,10 @@ public enum ErrorCode {
 
     // 카카오 API
     OAUTH_INVALID_CODE(400, "OAUTH-000", "유효하지 않은 인가 코드입니다."),
-    OAUTH_PROVIDER_ERROR(502, "OAUTH-999", "카카오 서버와 통신 중 오류가 발생했습니다.");
+    OAUTH_PROVIDER_ERROR(502, "OAUTH-999", "카카오 서버와 통신 중 오류가 발생했습니다."),
+
+    // 네이버 상품 API
+    NAVER_API_ERROR(502, "NAVER-999", "네이버 서버와 통신 중 오류가 발생했습니다.");
 
     private final int status;
     private final String code;
diff --git a/backend/src/main/java/com/cmg/comtogether/common/exception/GlobalExceptionHandler.java b/backend/src/main/java/com/cmg/comtogether/common/exception/GlobalExceptionHandler.java
@@ -1,23 +1,42 @@
 package com.cmg.comtogether.common.exception;
 
 import com.cmg.comtogether.common.response.ErrorResponse;
-import io.jsonwebtoken.ExpiredJwtException;
-import io.jsonwebtoken.MalformedJwtException;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.ResponseEntity;
 import org.springframework.http.converter.HttpMessageNotReadableException;
 import org.springframework.validation.FieldError;
 import org.springframework.web.bind.MethodArgumentNotValidException;
+import org.springframework.web.bind.MissingServletRequestParameterException;
 import org.springframework.web.bind.annotation.ExceptionHandler;
 import org.springframework.web.bind.annotation.RestControllerAdvice;
-import org.springframework.web.client.HttpClientErrorException;
-
-import java.security.SignatureException;
+import org.springframework.web.method.annotation.HandlerMethodValidationException;
 
 @Slf4j
 @RestControllerAdvice
 public class GlobalExceptionHandler {
 
+    @ExceptionHandler(HandlerMethodValidationException.class)
+    public ResponseEntity<ErrorResponse> handleHandlerMethodValidation(HandlerMethodValidationException e) {
+        String message = e.getAllErrors().stream()
+                .map(error -> error.getDefaultMessage())
+                .findFirst()
+                .orElse(ErrorCode.INVALID_INPUT.getMessage());
+
+        return ResponseEntity
+                .status(ErrorCode.INVALID_INPUT.getStatus())
+                .body(ErrorResponse.of(ErrorCode.INVALID_INPUT, message));
+    }
+
+    @ExceptionHandler(MissingServletRequestParameterException.class)
+    public ResponseEntity<ErrorResponse> handleMissingParams(MissingServletRequestParameterException ex) {
+        String paramName = ex.getParameterName();
+        String errorMessage = String.format("필수 파라미터 '%s' 가 누락되었습니다.", paramName);
+
+        return ResponseEntity
+                .status(ErrorCode.INVALID_INPUT.getStatus())
+                .body(ErrorResponse.of(ErrorCode.INVALID_INPUT, errorMessage));
+    }
+
     @ExceptionHandler(MethodArgumentNotValidException.class)
     public ResponseEntity<ErrorResponse> handleValidationException(MethodArgumentNotValidException e) {
         FieldError fieldError = e.getBindingResult().getFieldError();
diff --git a/backend/src/main/java/com/cmg/comtogether/common/security/config/SecurityConfig.java b/backend/src/main/java/com/cmg/comtogether/common/security/config/SecurityConfig.java
@@ -37,7 +37,8 @@ public SecurityFilterChain securityFilterChain(HttpSecurity http, CorsConfigurat
                                 "/oauth/**",
                                 "/refresh/**",
                                 "/swagger-ui/**",
-                                "/v3/api-docs/**"
+                                "/v3/api-docs/**",
+                                "/products/**"
                         ).permitAll()
                         .anyRequest().authenticated()
                 )
diff --git a/backend/src/main/java/com/cmg/comtogether/interest/controller/InterestController.java b/backend/src/main/java/com/cmg/comtogether/interest/controller/InterestController.java
@@ -19,8 +19,8 @@ public class InterestController {
     private final InterestService interestService;
 
     @GetMapping
-    private ResponseEntity<ApiResponse<List<InterestDto>>> getInterests() {
-        List<InterestDto> allInterest = interestService.getAllInterest();
+    private ResponseEntity<ApiResponse<List<InterestDto>>> getCommonInterests() {
+        List<InterestDto> allInterest = interestService.getCommonInterests();
         return ResponseEntity.ok(ApiResponse.success(allInterest));
     }
 }
diff --git a/backend/src/main/java/com/cmg/comtogether/interest/entity/Interest.java b/backend/src/main/java/com/cmg/comtogether/interest/entity/Interest.java
@@ -14,6 +14,9 @@ public class Interest {
     @GeneratedValue(strategy = GenerationType.IDENTITY)
     private Long interestId;
 
-    @Column(nullable = false, unique = true)
+    @Column(nullable = false)
     private String name;
+
+    @Builder.Default
+    private Boolean isCustom = false;
 }
diff --git a/backend/src/main/java/com/cmg/comtogether/interest/repository/InterestRepository.java b/backend/src/main/java/com/cmg/comtogether/interest/repository/InterestRepository.java
@@ -3,5 +3,8 @@
 import com.cmg.comtogether.interest.entity.Interest;
 import org.springframework.data.jpa.repository.JpaRepository;
 
+import java.util.List;
+
 public interface InterestRepository extends JpaRepository<Interest, Long> {
+    List<Interest> findByIsCustomFalse();
 }
diff --git a/backend/src/main/java/com/cmg/comtogether/interest/service/InterestService.java b/backend/src/main/java/com/cmg/comtogether/interest/service/InterestService.java
@@ -14,10 +14,30 @@ public class InterestService {
 
     private final InterestRepository interestRepository;
 
-    public List<InterestDto> getAllInterest(){
-        return interestRepository.findAll()
+    public List<InterestDto> getCommonInterests(){
+        return interestRepository.findByIsCustomFalse()
                 .stream()
-                .map(interest -> new InterestDto(interest.getInterestId(), interest.getName()))
+                .map(this::toDto)
                 .toList();
     }
+
+    public List<Interest> findAllById(List<Long> ids){
+        return interestRepository.findAllById(ids)
+                .stream()
+                .toList();
+    }
+
+    public List<Interest> saveCustomInterests(List<String> interestNames){
+        return interestNames.stream()
+                .map(interestName -> Interest.builder()
+                        .name(interestName)
+                        .isCustom(true)
+                        .build())
+                .map(interestRepository::save)
+                .toList();
+    }
+
+    private InterestDto toDto(Interest interest) {
+        return new InterestDto(interest.getInterestId(), interest.getName());
+    }
 }
diff --git a/backend/src/main/java/com/cmg/comtogether/jwt/entity/RefreshToken.java b/backend/src/main/java/com/cmg/comtogether/jwt/entity/RefreshToken.java
@@ -2,11 +2,13 @@
 
 import jakarta.persistence.*;
 import lombok.AllArgsConstructor;
+import lombok.Builder;
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 
 @Entity
 @Getter
+@Builder
 @NoArgsConstructor
 @AllArgsConstructor
 public class RefreshToken {
diff --git a/backend/src/main/java/com/cmg/comtogether/jwt/service/JwtService.java b/backend/src/main/java/com/cmg/comtogether/jwt/service/JwtService.java
@@ -50,5 +50,9 @@ public TokenDto refreshAccessToken(String refreshToken) {
                 .refreshToken(newRefreshToken)
                 .build();
     }
+
+    public void deleteRefreshToken(Long userId) {
+        refreshTokenRepository.findByUserId(userId).ifPresent(refreshTokenRepository::delete);
+    }
 }
 
diff --git a/backend/src/main/java/com/cmg/comtogether/product/controller/ProductController.java b/backend/src/main/java/com/cmg/comtogether/product/controller/ProductController.java
@@ -0,0 +1,56 @@
+package com.cmg.comtogether.product.controller;
+
+import com.cmg.comtogether.common.response.ApiResponse;
+import com.cmg.comtogether.common.security.CustomUserDetails;
+import com.cmg.comtogether.product.dto.NaverProductResponseDto;
+import com.cmg.comtogether.product.service.ProductService;
+import com.cmg.comtogether.user.entity.User;
+import jakarta.validation.constraints.Min;
+import jakarta.validation.constraints.NotBlank;
+import jakarta.validation.constraints.Pattern;
+import lombok.RequiredArgsConstructor;
+import org.springframework.http.ResponseEntity;
+import org.springframework.security.core.annotation.AuthenticationPrincipal;
+import org.springframework.validation.annotation.Validated;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+@RestController
+@RequestMapping("/products")
+@RequiredArgsConstructor
+public class ProductController {
+
+    private final ProductService productService;
+
+    @GetMapping
+    @Validated
+    public ResponseEntity<ApiResponse<NaverProductResponseDto>> searchProducts(
+            @RequestParam @NotBlank(message = "카테고리는 필수입니다.") String category,
+            @RequestParam(defaultValue = "") String query,
+            @RequestParam(defaultValue = "10") @Min(1) int display,
+            @RequestParam(defaultValue = "1") @Min(1) int start,
+            @RequestParam(defaultValue = "sim") @Pattern(regexp = "sim|date|asc|dsc", message = "sort 값이 유효하지 않습니다.") String sort,
+            @RequestParam(required = false) String exclude
+    ) {
+        NaverProductResponseDto responseDto = productService.searchProducts(category, query, display, start, sort, exclude);
+        return ResponseEntity.ok(ApiResponse.success(responseDto));
+    }
+
+    @GetMapping("/recommend")
+    @Validated
+    public ResponseEntity<ApiResponse<NaverProductResponseDto>> recommendProducts(
+            @RequestParam @NotBlank(message = "카테고리는 필수입니다.") String category,
+            @RequestParam(defaultValue = "") String query,
+            @RequestParam(defaultValue = "10") @Min(1) int display,
+            @RequestParam(defaultValue = "1") @Min(1) int start,
+            @RequestParam(defaultValue = "sim") @Pattern(regexp = "sim|date|asc|dsc", message = "sort 값이 유효하지 않습니다.") String sort,
+            @RequestParam(required = false) String exclude,
+            @AuthenticationPrincipal CustomUserDetails userDetails
+    ) {
+        User user = userDetails.getUser();
+        NaverProductResponseDto responseDto = productService.recommendProducts(user.getUserId(), category, query, display, start, sort, exclude);
+        return ResponseEntity.ok(ApiResponse.success(responseDto));
+    }
+}
diff --git a/backend/src/main/java/com/cmg/comtogether/product/dto/NaverProductDto.java b/backend/src/main/java/com/cmg/comtogether/product/dto/NaverProductDto.java
@@ -0,0 +1,27 @@
+package com.cmg.comtogether.product.dto;
+
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class NaverProductDto {
+    private Long productId;
+    private String title;
+    private Integer lprice;
+    private Integer hprice;
+    private String image;
+    private String link;
+    private String mallName;
+    private String productType;
+    private String maker;
+    private String brand;
+    private String category1;
+    private String category2;
+    private String category3;
+    private String category4;
+}
diff --git a/backend/src/main/java/com/cmg/comtogether/product/dto/NaverProductResponseDto.java b/backend/src/main/java/com/cmg/comtogether/product/dto/NaverProductResponseDto.java
@@ -0,0 +1,19 @@
+package com.cmg.comtogether.product.dto;
+
+import com.fasterxml.jackson.annotation.JsonIgnoreProperties;
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+import java.util.List;
+
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+@JsonIgnoreProperties(ignoreUnknown = true)
+public class NaverProductResponseDto {
+    private int total;
+    private int start;
+    private int display;
+    private List<NaverProductDto> items;
+}
diff --git a/backend/src/main/java/com/cmg/comtogether/product/entity/Product.java b/backend/src/main/java/com/cmg/comtogether/product/entity/Product.java
@@ -0,0 +1,46 @@
+package com.cmg.comtogether.product.entity;
+
+import jakarta.persistence.Column;
+import jakarta.persistence.Entity;
+import jakarta.persistence.Id;
+import lombok.AllArgsConstructor;
+import lombok.Builder;
+import lombok.Getter;
+import lombok.NoArgsConstructor;
+
+@Entity
+@Getter
+@NoArgsConstructor
+@AllArgsConstructor
+@Builder
+public class Product {
+
+    @Id
+    private Long productId;
+
+    @Column(nullable = false)
+    private String title;
+
+    @Column(nullable = false)
+    private String link;
+
+    private String image;
+
+    private Integer lprice;
+    private Integer hprice;
+
+    @Column(nullable = false)
+    private String mallName;
+
+    @Column(nullable = false)
+    private String productType;
+
+    private String maker;
+    private String brand;
+
+    private String category1;
+    private String category2;
+    private String category3;
+    private String category4;
+}
+
diff --git a/backend/src/main/java/com/cmg/comtogether/product/service/ProductService.java b/backend/src/main/java/com/cmg/comtogether/product/service/ProductService.java
@@ -0,0 +1,75 @@
+package com.cmg.comtogether.product.service;
+
+import com.cmg.comtogether.common.exception.BusinessException;
+import com.cmg.comtogether.common.exception.ErrorCode;
+import com.cmg.comtogether.interest.entity.Interest;
+import com.cmg.comtogether.product.dto.NaverProductResponseDto;
+import com.cmg.comtogether.user.entity.User;
+import com.cmg.comtogether.user.entity.UserInterest;
+import com.cmg.comtogether.user.repository.UserRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.http.HttpStatusCode;
+import org.springframework.stereotype.Service;
+import org.springframework.web.client.RestClient;
+import org.springframework.web.util.UriComponentsBuilder;
+
+import java.util.Optional;
+import java.util.stream.Collectors;
+
+@Service
+@RequiredArgsConstructor
+public class ProductService {
+
+    private final RestClient restClient;
+    private final UserRepository userRepository;
+
+    @Value("${naver.shopping.client-id}")
+    private String clientId;
+
+    @Value("${naver.shopping.client-secret}")
+    private String clientSecret;
+
+    @Value("${naver.shopping.base-url}")
+    private String baseUrl;
+
+    public NaverProductResponseDto searchProducts(String category, String query, int display, int start, String sort, String exclude) {
+        String searchQuery = category + " " + query;
+        return getNaverProducts(searchQuery, display, start, sort, exclude);
+    }
+
+    public NaverProductResponseDto recommendProducts(Long userId, String category, String query, int display, int start, String sort, String exclude) {
+        User user = userRepository.findByIdWithInterests(userId)
+                .orElseThrow(() -> new BusinessException(ErrorCode.USER_NOT_FOUND));
+
+        String interestString = user.getInterests().stream()
+                .map(UserInterest::getInterest)
+                .map(Interest::getName)
+                .collect(Collectors.joining(" "));
+        String searchQuery = category + " " + interestString + query;
+        return getNaverProducts(searchQuery, display, start, sort, exclude);
+    }
+
+    private NaverProductResponseDto getNaverProducts(String searchQuery, int display, int start, String sort, String exclude) {
+        return restClient.get()
+                .uri(UriComponentsBuilder
+                        .fromUriString(baseUrl)
+                        .queryParam("query", searchQuery)
+                        .queryParam("display", display)
+                        .queryParam("start", start)
+                        .queryParam("sort", sort)
+                        .queryParamIfPresent("exclude", Optional.ofNullable(exclude))
+                        .build()
+                        .toUri())
+                .header("X-Naver-Client-Id", clientId)
+                .header("X-Naver-Client-Secret", clientSecret)
+                .retrieve()
+                .onStatus(HttpStatusCode::is4xxClientError, (req, res) -> {
+                    throw new BusinessException(ErrorCode.INTERNAL_SERVER_ERROR);
+                })
+                .onStatus(HttpStatusCode::is5xxServerError, (req, res) -> {
+                    throw new BusinessException(ErrorCode.NAVER_API_ERROR);
+                })
+                .body(NaverProductResponseDto.class);
+    }
+}
diff --git a/backend/src/main/java/com/cmg/comtogether/user/controller/UserController.java b/backend/src/main/java/com/cmg/comtogether/user/controller/UserController.java
@@ -21,6 +21,12 @@ public class UserController {
 
     private final UserService userService;
 
+    @PostMapping("/logout")
+    public ResponseEntity<ApiResponse<Void>> logout(@AuthenticationPrincipal CustomUserDetails userDetails) {
+        userService.logout(userDetails.getUser().getUserId());
+        return ResponseEntity.ok(ApiResponse.success(null));
+    }
+
     @GetMapping("/me")
     public ResponseEntity<ApiResponse<UserResponseDto>> getUserInfo(@AuthenticationPrincipal CustomUserDetails userDetails) {
         User user = userDetails.getUser();
diff --git a/backend/src/main/java/com/cmg/comtogether/user/dto/UserInitializeRequestDto.java b/backend/src/main/java/com/cmg/comtogether/user/dto/UserInitializeRequestDto.java
diff --git a/backend/src/main/java/com/cmg/comtogether/user/repository/UserRepository.java b/backend/src/main/java/com/cmg/comtogether/user/repository/UserRepository.java
diff --git a/backend/src/main/java/com/cmg/comtogether/user/service/UserService.java b/backend/src/main/java/com/cmg/comtogether/user/service/UserService.java
diff --git a/backend/src/main/resources/application.yaml b/backend/src/main/resources/application.yaml
diff --git a/backend/src/main/resources/data.sql b/backend/src/main/resources/data.sql
diff --git a/backend/src/test/java/com/cmg/comtogether/product/service/ProductServiceTest.java b/backend/src/test/java/com/cmg/comtogether/product/service/ProductServiceTest.java
diff --git a/backend/src/test/java/com/cmg/comtogether/user/service/UserServiceTest.java b/backend/src/test/java/com/cmg/comtogether/user/service/UserServiceTest.java

Original file line number	Diff line number	Diff line change
`@@ -19,8 +19,8 @@ public class InterestController {`
`19`	`19`	`private final InterestService interestService;`
`20`	`20`
`21`	`21`	`@GetMapping`
`22`		`- private ResponseEntity<ApiResponse<List<InterestDto>>> getInterests() {`
`23`		`- List<InterestDto> allInterest = interestService.getAllInterest();`
	`22`	`+ private ResponseEntity<ApiResponse<List<InterestDto>>> getCommonInterests() {`
	`23`	`+ List<InterestDto> allInterest = interestService.getCommonInterests();`
`24`	`24`	`return ResponseEntity.ok(ApiResponse.success(allInterest));`
`25`	`25`	`}`
`26`	`26`	`}`
Original file line number	Diff line number	Diff line change
`@@ -3,5 +3,8 @@`
`3`	`3`	`import com.cmg.comtogether.interest.entity.Interest;`
`4`	`4`	`import org.springframework.data.jpa.repository.JpaRepository;`
`5`	`5`
	`6`	`+import java.util.List;`
	`7`	`+`
`6`	`8`	`public interface InterestRepository extends JpaRepository<Interest, Long> {`
	`9`	`+ List<Interest> findByIsCustomFalse();`
`7`	`10`	`}`
Original file line number	Diff line number	Diff line change
`@@ -50,5 +50,9 @@ public TokenDto refreshAccessToken(String refreshToken) {`
`50`	`50`	`.refreshToken(newRefreshToken)`
`51`	`51`	`.build();`
`52`	`52`	`}`
	`53`	`+`
	`54`	`+ public void deleteRefreshToken(Long userId) {`
	`55`	`+ refreshTokenRepository.findByUserId(userId).ifPresent(refreshTokenRepository::delete);`
	`56`	`+ }`
`53`	`57`	`}`
`54`	`58`