feat: 이벤트 퍼블리셔, 리스너 추가

Author: whale22

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

@@ -10,7 +10,6 @@
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
-import java.util.List;
 import java.util.Set;
 import java.util.concurrent.TimeUnit;
 import java.util.concurrent.atomic.AtomicInteger;
@@ -30,25 +29,19 @@ public void updateUserCommits() {
         log.info("🔍 updateUserCommits 실행중");
         int count = counter.incrementAndGet();
 
-        if (count % 10 == 0) {
-            List<User> allUsers = userRepository.findAll();
-            log.info("🔍 All User Count: {}", allUsers.size());
+        // 최근 로그인이 이루어진 (접근 가능성이 높은) 유저만 실시간으로 커밋 수 변경 추적 후 갱신
+        // 최근 로그인이 이루어지지 않은 유저는 페이지 최초 로그인 시 갱신이 발생한다.
+        Set<String> activeUsers = redisTemplate.keys("commit_active:*");
+        log.info("🔍 Active User Count: {}", activeUsers.size());
 
-            for (User user : allUsers) {
+        for (String key : activeUsers) {
+            String username = key.replace("commit_active:", "");
+            User user = userRepository.findByUsername(username).orElse(null);
+            if (user != null) {
                 processUserCommit(user);
             }
-        } else {
-            Set<String> activeUsers = redisTemplate.keys("commit_active:*");
-            log.info("🔍 Active User Count: {}", activeUsers.size());
-
-            for (String key : activeUsers) {
-                String username = key.replace("commit_active:", "");
-                User user = userRepository.findByUsername(username).orElse(null);
-                if (user != null) {
-                    processUserCommit(user);
-                }
-            }
         }
+
     }
 
     // 🔹 유저 커밋 검사 및 반영

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

@@ -0,0 +1,22 @@
+package cmf.commitField.domain.commit.scheduler;
+
+import org.springframework.context.ApplicationEvent;
+
+public class CommitUpdateEvent extends ApplicationEvent {
+    private final Long userId;
+    private final int commitCount;
+
+    public CommitUpdateEvent(Object source, Long userId, int commitCount) {
+        super(source);
+        this.userId = userId;
+        this.commitCount = commitCount;
+    }
+
+    public Long getUserId() {
+        return userId;
+    }
+
+    public int getCommitCount() {
+        return commitCount;
+    }
+}

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

@@ -0,0 +1,18 @@
+package cmf.commitField.domain.commit.scheduler;
+
+import org.springframework.context.event.EventListener;
+import org.springframework.stereotype.Service;
+
+@Service
+public class CommitUpdateListener {
+
+    @EventListener
+    public void handleCommitUpdateEvent(CommitUpdateEvent event) {
+        // 이벤트 처리 로직
+        Long userId = event.getUserId();
+        int commitCount = event.getCommitCount();
+
+        // 커밋 갱신 후에 다른 서비스에서 필요한 작업 수행 (예: DB 업데이트, 상태 갱신 등)
+        System.out.println("User ID: " + userId + " has updated " + commitCount + " commits.");
+    }
+}

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

@@ -6,6 +6,7 @@
 import cmf.commitField.domain.user.entity.User;
 import cmf.commitField.domain.user.repository.UserRepository;
 import lombok.RequiredArgsConstructor;
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
@@ -17,6 +18,8 @@ public class CommitUpdateService {
     private final UserRepository userRepository;
     private final PetService petService;
 
+    private final ApplicationEventPublisher eventPublisher;
+
     public UserInfoDto updateUserTier(String username){
         User user = userRepository.findByUsername(username).get();
         long seasonCommitCount;