Merge pull request #51 from flowbit-team/feature/50-total-subscriber

Feature/50 total subscriber

Author: minwoo1999

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

@@ -1,8 +1,11 @@
 package com.example.userservice.domain.subscriber.controller;
 
 
+import com.example.userservice.domain.member.dto.response.MemberRenewAccessTokenResponseDto;
 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;
@@ -22,12 +25,20 @@ public class SubscriberController {
     @PostMapping("/subscribe")
     public ResponseEntity<?> subscribe(@Valid @RequestBody SubscribeRequestDto subscribeRequestDto) {
         subscriberService.subscribe(subscribeRequestDto.getEmail(), subscribeRequestDto.getKeywords());
-        return ResponseEntity.status(HttpStatus.CREATED).body("구독 완료: " + subscribeRequestDto.getEmail());
+        return new ResponseEntity<>(new CommonResDto<>(1, "구독이 완료되었습니다",""), HttpStatus.OK);
     }
 
     @DeleteMapping("/unsubscribe")
     public ResponseEntity<?> unsubscribe(@RequestParam String email) {
         subscriberService.unsubscribe(email);
-        return ResponseEntity.status(HttpStatus.OK).body("구독 취소 완료: " + email);
+        return new ResponseEntity<>(new CommonResDto<>(1, "구독이 취소되었습니다.",""), HttpStatus.OK);
+    }
+
+    @GetMapping("/count")
+    public ResponseEntity<?> getSubscriberCount() {
+        long count = subscriberService.countSubscribers();
+        return new ResponseEntity<>(new CommonResDto<>(1, "총 구독자 수 조회 성공", count), HttpStatus.OK);
     }
+
+
 }

src/main/java/com/example/userservice/domain/subscriber/repository/SubscriberRepository.java

@@ -8,4 +8,5 @@
 
 public interface SubscriberRepository extends JpaRepository<Subscriber, Long> {
     Optional<Subscriber> findByEmail(String email);
+    long count();
 }

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

@@ -5,4 +5,6 @@
 public interface SubscriberService {
     void subscribe(String email, List<String> keywords);
     void unsubscribe(String email);
+
+    long countSubscribers();
 }

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

@@ -22,6 +22,11 @@ public class SubscriberServiceImpl implements SubscriberService {
     private final SubscriberRepository subscriberRepository;
     private final EmailRedisUtil emailRedisUtil;
 
+
+    public long countSubscribers() {
+        return subscriberRepository.count();
+    }
+
     @Override
     @Transactional
     public void subscribe(String email, List<String> keywords) {