hotfix: add redis log

Author: 2ghrms

src/main/java/com/haru/api/infra/redis/RedisReportConsumer.java

@@ -25,20 +25,34 @@ public class RedisReportConsumer {
     private static final long BATCH_SIZE = 20;
 
     @Scheduled(cron = "0 0/5 * * * *") // 정각부터 5분 마다 실행
-    public void pollQueueEvery30Minutes() {
+    public void pollQueueEvery5Minutes() {
         long now = Instant.now().getEpochSecond();
+        log.info("[RedisReportConsumer] pollQueueEvery5Minutes 실행됨 (now = {})", now);
 
         while (true) {
             Set<String> dueIds = redisTemplate.opsForZSet()
                     .rangeByScore(QUEUE_KEY, 0, now, 0, BATCH_SIZE);
 
-            if (dueIds == null || dueIds.isEmpty()) break;
+            if (dueIds == null || dueIds.isEmpty()) {
+                log.info("[RedisReportConsumer] dueIds 없음 → 반복 종료");
+                break;
+            }
+
+            log.info("[RedisReportConsumer] 처리할 dueIds: {}", dueIds);
 
             for (String id : dueIds) {
-                // Worker Queue로 push
-                redisTemplate.opsForList().leftPush("REPORT_WORKER_QUEUE", id);
-                // ZSET에서는 제거
-                redisTemplate.opsForZSet().remove(QUEUE_KEY, id);
+                try {
+                    // Worker Queue로 push
+                    redisTemplate.opsForList().leftPush("REPORT_WORKER_QUEUE", id);
+                    log.info("[RedisReportConsumer] REPORT_WORKER_QUEUE에 추가됨 → {}", id);
+
+                    // ZSET에서 제거
+                    redisTemplate.opsForZSet().remove(QUEUE_KEY, id);
+                    log.info("[RedisReportConsumer] ZSET({})에서 제거됨 → {}", QUEUE_KEY, id);
+
+                } catch (Exception e) {
+                    log.error("[RedisReportConsumer] id={} 처리 중 에러", id, e);
+                }
             }
         }
     }
@@ -48,12 +62,12 @@ public void removeFromQueue(Long moodTrackerId) {
         try {
             Long removed = redisTemplate.opsForZSet().remove(QUEUE_KEY, moodTrackerId.toString());
             if (removed != null && removed > 0) {
-                log.info("즉시 생성 API 호출로 큐에서 제거됨: {}", moodTrackerId);
+                log.info("[RedisReportConsumer] 즉시 생성 API → 큐에서 제거됨: {}", moodTrackerId);
             } else {
-                log.info("큐에 존재하지 않아 제거할 항목 없음: {}", moodTrackerId);
+                log.info("[RedisReportConsumer] 즉시 생성 API → 큐에 없음: {}", moodTrackerId);
             }
         } catch (Exception e) {
-            log.error("큐 제거 실패: {}", moodTrackerId, e);
+            log.error("[RedisReportConsumer] 즉시 생성 API → 큐 제거 실패: {}", moodTrackerId, e);
         }
     }
 }