feat: subscribe interest keyword

src/main/java/com/example/userservice/domain/subscriber/controller/SubscriberController.java

@@ -1,16 +1,16 @@
 package com.example.userservice.domain.subscriber.controller;
 
 
-import com.example.userservice.domain.member.dto.response.CreateMemberResponseDto;
 import com.example.userservice.domain.subscriber.dto.request.SubscribeRequestDto;
 import com.example.userservice.domain.subscriber.service.SubscriberService;
-import com.example.userservice.global.common.CommonResDto;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.http.HttpStatus;
 import org.springframework.http.ResponseEntity;
 import org.springframework.web.bind.annotation.*;
 
+import javax.validation.Valid;
+
 @RestController
 @RequiredArgsConstructor
 @Slf4j
@@ -20,8 +20,8 @@ public class SubscriberController {
     private final SubscriberService subscriberService;
 
     @PostMapping("/subscribe")
-    public ResponseEntity<?> subscribe(@RequestBody SubscribeRequestDto subscribeRequestDto) {
-        subscriberService.subscribe(subscribeRequestDto.getEmail());
+    public ResponseEntity<?> subscribe(@Valid @RequestBody SubscribeRequestDto subscribeRequestDto) {
+        subscriberService.subscribe(subscribeRequestDto.getEmail(), subscribeRequestDto.getKeywords());
         return ResponseEntity.status(HttpStatus.CREATED).body("구독 완료: " + subscribeRequestDto.getEmail());
     }
 

src/main/java/com/example/userservice/domain/subscriber/dto/request/SubscribeRequestDto.java

@@ -3,8 +3,18 @@
 import lombok.Getter;
 import lombok.NoArgsConstructor;
 
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.Size;
+import java.util.List;
+
 @NoArgsConstructor
 @Getter
 public class SubscribeRequestDto {
     private String email;
+
+    @Size(min=1, max = 3, message = "You must provide 1 to 3 keywords.")
+    private List<
+            @NotBlank(message = "Each keyword must not be blank.")
+            @Size(min = 2, max = 20, message = "Keyword must be between 2 and 20 characters.")
+                    String> keywords;
 }

src/main/java/com/example/userservice/domain/subscriber/entity/Interest.java

@@ -0,0 +1,31 @@
+package com.example.userservice.domain.subscriber.entity;
+
+import com.example.userservice.global.entity.BaseTimeEntity;
+import lombok.*;
+
+import javax.persistence.*;
+
+@Getter
+@NoArgsConstructor(access = AccessLevel.PROTECTED)
+@Entity
+public class Interest extends BaseTimeEntity {
+
+    @Id
+    @GeneratedValue(strategy = GenerationType.IDENTITY)
+    private Long id;
+
+    @Column(nullable = false)
+    private String keyword;
+
+    @ManyToOne
+    @JoinColumn(name = "subscriber_id")
+    private Subscriber subscriber;
+
+    public Interest(String keyword) {
+        this.keyword = keyword;
+    }
+
+    public void setSubscriber(Subscriber subscriber) {
+        this.subscriber = subscriber;
+    }
+}

src/main/java/com/example/userservice/domain/subscriber/entity/Subscriber.java

@@ -2,11 +2,11 @@
 
 import com.example.userservice.global.entity.BaseTimeEntity;
 import lombok.*;
-import org.hibernate.annotations.SQLDelete;
-import org.hibernate.annotations.Where;
 
 import javax.persistence.*;
-import java.util.Objects;
+import java.util.ArrayList;
+import java.util.List;
+import java.util.stream.Collectors;
 
 @Getter
 @NoArgsConstructor(access = AccessLevel.PROTECTED)
@@ -27,12 +27,30 @@ public class Subscriber extends BaseTimeEntity {
     @Column(nullable = false)
     private boolean subscribed = true; // 구독 상태 (true: 구독 중, false: 구독 취소)
 
+    @OneToMany(mappedBy = "subscriber", cascade = CascadeType.ALL, orphanRemoval = true)
+    private List<Interest> interests = new ArrayList<>();
+
     public Subscriber(String email) {
         this.email = email;
     }
 
+    public Subscriber(String email, List<String> keywords) {
+        this.email = email;
+
+        keywords.stream()
+                .distinct()
+                .map(Interest::new)
+                .forEach(this::add);
+    }
+
     public void unsubscribe() {
         this.subscribed = false;
     }
 
+    // 연관관계 메서드
+    public void add(Interest interest) {
+        interests.add(interest);
+        interest.setSubscriber(this);
+    }
+
 }

src/main/java/com/example/userservice/domain/subscriber/service/SubscriberService.java

@@ -1,6 +1,8 @@
 package com.example.userservice.domain.subscriber.service;
 
+import java.util.List;
+
 public interface SubscriberService {
-    void subscribe(String email);
+    void subscribe(String email, List<String> keywords);
     void unsubscribe(String email);
 }

src/main/java/com/example/userservice/domain/subscriber/service/impl/SubscriberServiceImpl.java

@@ -1,6 +1,5 @@
 package com.example.userservice.domain.subscriber.service.impl;
 
-import com.example.userservice.domain.member.dto.request.SignUpRequestDto;
 import com.example.userservice.domain.subscriber.entity.Subscriber;
 import com.example.userservice.domain.subscriber.repository.SubscriberRepository;
 import com.example.userservice.domain.subscriber.service.SubscriberService;
@@ -25,15 +24,15 @@ public class SubscriberServiceImpl implements SubscriberService {
 
     @Override
     @Transactional
-    public void subscribe(String email) {
+    public void subscribe(String email, List<String> keywords) {
         // 이메일 중복 체크
         subscriberRepository.findByEmail(email).ifPresent(subscriber -> {
             throw new IllegalArgumentException("이미 구독된 이메일입니다.");
         });
         emailVerifyCheck(email);
 
-        // 새 구독자 저장
-        Subscriber subscriber = new Subscriber(email);
+        // 관심 키워드와 함께 새 구독자 저장
+        Subscriber subscriber = new Subscriber(email, keywords);
         subscriberRepository.save(subscriber);
     }