feat: 스프링 이벤트 / 웹소켓 연결 완료

Author: whale22

src/main/java/cmf/commitField/CommitFieldApplication.java

@@ -7,8 +7,6 @@
 
 @SpringBootApplication
 @EnableJpaAuditing
-// 스케쥴링 활성화
-// 테스트시에만 주석 풀기
 @EnableScheduling
 public class CommitFieldApplication {
 	public static void main(String[] args) {

src/main/java/cmf/commitField/domain/commit/scheduler/CommitUpdateListener.java

@@ -4,6 +4,7 @@
 import cmf.commitField.domain.user.service.UserService;
 import lombok.RequiredArgsConstructor;
 import org.springframework.context.event.EventListener;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.stereotype.Component;
 
 @Component
@@ -12,6 +13,7 @@ public class CommitUpdateListener {
     private final UserService userService;
     private final PetService petService;
     private final CommitUpdateService commitUpdateService;
+    private final SimpMessagingTemplate messagingTemplate;
 
     @EventListener
     public void handleCommitUserUpdateEvent(CommitUpdateEvent event) {
@@ -41,4 +43,14 @@ public void handleCommitPetUpdateEvent(CommitUpdateEvent event) {
         // 커밋 갱신 후에 다른 서비스에서 필요한 작업 수행 (예: DB 업데이트, 상태 갱신 등)
         System.out.println("유저명: " + username + "'s pet has updated " + commitCount + " commits.");
     }
+
+    @EventListener
+    public void onCommitCountUpdate(CommitUpdateEvent event) {
+        // 커밋 수 업데이트가 있을 때 메시지 발송
+        String username = event.getUsername();
+        long newCommitCount = event.getNewCommitCount();
+
+        // 메시지를 WebSocket을 통해 전송
+        messagingTemplate.convertAndSend("/topic/commit/" + username, newCommitCount);
+    }
 }

src/main/java/cmf/commitField/domain/commit/scheduler/CommitUpdateService.java

@@ -1,11 +1,11 @@
 package cmf.commitField.domain.commit.scheduler;
 
 import cmf.commitField.domain.commit.totalCommit.service.TotalCommitService;
-import cmf.commitField.domain.pet.service.PetService;
 import cmf.commitField.domain.user.dto.UserInfoDto;
 import cmf.commitField.domain.user.entity.User;
 import cmf.commitField.domain.user.repository.UserRepository;
 import lombok.RequiredArgsConstructor;
+import org.springframework.messaging.simp.SimpMessagingTemplate;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
@@ -15,8 +15,9 @@
 public class CommitUpdateService {
     private final TotalCommitService totalCommitService;
     private final UserRepository userRepository;
-    private final PetService petService;
+    private final SimpMessagingTemplate messagingTemplate;
 
+    // 유저 랭킹 상승 로짓
     public UserInfoDto updateUserTier(String username){
         User user = userRepository.findByUsername(username).get();
         long seasonCommitCount;
@@ -35,4 +36,5 @@ public UserInfoDto updateUserTier(String username){
                 .tier(user.getTier().name())
                 .build();
     }
+
 }