[NAYB-154] feat : Redis에 있는 평균 별점과 리뷰 수를 주기적으로 DB 데이터와 맞춰준다.

src/main/java/com/prgrms/nabmart/domain/review/service/RedisCacheService.java

@@ -108,4 +108,37 @@ public void updateAverageRatingByItemId(
         listOperations.rightPushAll(cacheKey, String.valueOf(dbAverageRating),
             String.valueOf(dbNumberOfReviews));
     }
+
+    public void synchronizeNumberOfReview(
+        final Long itemId,
+        final String cacheKey
+    ) {
+        long dbCount = reviewRepository.countByItem_ItemId(itemId);
+
+        numberOfReviewsRedisTemplate.opsForValue().set(cacheKey, dbCount);
+    }
+
+    public void synchronizeAverageRating(
+        final Long itemId,
+        final String cacheKey
+    ) {
+        String averageRating = listOperations.index(cacheKey, 0);
+        String totalNumberOfReviews = listOperations.index(cacheKey, 1);
+
+        if (averageRating != null && totalNumberOfReviews != null) {
+            double dbAverageRating = reviewRepository.findAverageRatingByItemId(itemId);
+            long dbNumberOfReviews = reviewRepository.countByItem_ItemId(itemId);
+
+            listOperations.set(cacheKey, 0, String.valueOf(dbAverageRating));
+            listOperations.set(cacheKey, 1, String.valueOf(dbNumberOfReviews));
+
+            return;
+        }
+
+        double dbAverageRating = reviewRepository.findAverageRatingByItemId(itemId);
+        long dbNumberOfReviews = reviewRepository.countByItem_ItemId(itemId);
+
+        listOperations.rightPushAll(cacheKey, String.valueOf(dbAverageRating),
+            String.valueOf(dbNumberOfReviews));
+    }
 }

src/main/java/com/prgrms/nabmart/domain/review/service/ReviewSchedulerService.java

@@ -0,0 +1,37 @@
+package com.prgrms.nabmart.domain.review.service;
+
+import com.prgrms.nabmart.domain.review.repository.ReviewRepository;
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Service;
+
+@Service
+@RequiredArgsConstructor
+public class ReviewSchedulerService {
+
+    private final RedisCacheService redisCacheService;
+    private final ReviewRepository reviewRepository;
+
+    private static final String AVERAGE_RATE_CACHE_KEY = "averageRating:Item:";
+    private static final String REVIEW_COUNT_CACHE_KEY = "reviewCount:Item:";
+
+    @Scheduled(cron = "0 0 * * 1 *")
+    public void synchronizeAverageRating() {
+        reviewRepository.findAll()
+            .forEach(review -> redisCacheService.synchronizeAverageRating(
+                review.getItem().getItemId(),
+                AVERAGE_RATE_CACHE_KEY + review.getItem().getItemId()
+            ));
+    }
+
+    @Scheduled(cron = "0 0 * * 1 *")
+    public void synchronizeNumberOfReview() {
+        reviewRepository.findAll()
+            .forEach(
+                review -> redisCacheService.synchronizeNumberOfReview(
+                    review.getItem().getItemId(),
+                    REVIEW_COUNT_CACHE_KEY + review.getItem().getItemId()
+                )
+            );
+    }
+}