좋아요 수 및 좋아요 변경 이력 캐싱

backend/src/main/java/hanglog/community/service/CommunityService.java

@@ -14,10 +14,14 @@
 import hanglog.community.dto.response.CommunityTripResponse;
 import hanglog.community.dto.response.RecommendTripListResponse;
 import hanglog.global.exception.BadRequestException;
+import hanglog.like.domain.LikeCount;
 import hanglog.like.domain.LikeInfo;
+import hanglog.like.domain.MemberLike;
 import hanglog.like.dto.LikeElement;
 import hanglog.like.dto.LikeElements;
+import hanglog.like.repository.LikeCountRepository;
 import hanglog.like.repository.LikeRepository;
+import hanglog.like.repository.MemberLikeRepository;
 import hanglog.trip.domain.Trip;
 import hanglog.trip.domain.repository.TripCityRepository;
 import hanglog.trip.domain.repository.TripRepository;
@@ -26,6 +30,7 @@
 import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Map;
+import java.util.Optional;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.data.domain.Pageable;
@@ -46,6 +51,8 @@ public class CommunityService {
     private final CityRepository cityRepository;
     private final RecommendStrategies recommendStrategies;
     private final PublishedTripRepository publishedTripRepository;
+    private final LikeCountRepository likeCountRepository;
+    private final MemberLikeRepository memberLikeRepository;
 
     @Transactional(readOnly = true)
     public CommunityTripListResponse getCommunityTripsByPage(final Accessor accessor, final Pageable pageable) {
@@ -120,8 +127,8 @@ public TripDetailResponse getTripDetail(final Accessor accessor, final Long trip
         final LocalDateTime publishedDate = publishedTripRepository.findByTripId(tripId)
                 .orElseThrow(() -> new BadRequestException(NOT_FOUND_TRIP_ID))
                 .getCreatedAt();
-        final LikeElement likeElement = likeRepository.findLikeCountAndIsLikeByTripId(accessor.getMemberId(), tripId)
-                .orElseGet(() -> new LikeElement(tripId, 0, false));
+
+        final LikeElement likeElement = getLikeElement(accessor.getMemberId(), tripId);
         final Boolean isWriter = trip.isWriter(accessor.getMemberId());
 
         return TripDetailResponse.publishedTrip(
@@ -133,4 +140,18 @@ public TripDetailResponse getTripDetail(final Accessor accessor, final Long trip
                 publishedDate
         );
     }
+
+    private LikeElement getLikeElement(final Long memberId, final Long tripId) {
+        final Optional<LikeCount> likeCount = likeCountRepository.findById(tripId);
+        final Optional<MemberLike> memberLike = memberLikeRepository.findById(memberId);
+        if (likeCount.isPresent() && memberLike.isPresent()) {
+            final Map<Long, Boolean> tripLikeStatusMap = memberLike.get().getTripLikeStatusMap();
+            if (tripLikeStatusMap.containsKey(tripId)) {
+                return new LikeElement(tripId, likeCount.get().getCount(), tripLikeStatusMap.get(tripId));
+            }
+            return new LikeElement(tripId, likeCount.get().getCount(), false);
+        }
+        return likeRepository.findLikeCountAndIsLikeByTripId(memberId, tripId)
+                .orElseGet(() -> new LikeElement(tripId, 0, false));
+    }
 }

backend/src/main/java/hanglog/like/domain/LikeCount.java

@@ -0,0 +1,17 @@
+package hanglog.like.domain;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.springframework.data.annotation.Id;
+import org.springframework.data.redis.core.RedisHash;
+
+@Getter
+@AllArgsConstructor
+@RedisHash(value = "likeCount")
+public class LikeCount {
+
+    @Id
+    private Long tripId;
+
+    private Long count;
+}

backend/src/main/java/hanglog/like/dto/TripLikeCount.java

@@ -0,0 +1,12 @@
+package hanglog.like.dto;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+@Getter
+@RequiredArgsConstructor
+public class TripLikeCount {
+
+    private final long tripId;
+    private final long count;
+}

backend/src/main/java/hanglog/like/repository/LikeCountRepository.java

@@ -0,0 +1,10 @@
+package hanglog.like.repository;
+
+import hanglog.like.domain.LikeCount;
+import java.util.List;
+import org.springframework.data.repository.CrudRepository;
+
+public interface LikeCountRepository extends CrudRepository<LikeCount, Long> {
+
+    List<LikeCount> findLikeCountsByTripIdIn(final List<Long> tripIds);
+}

backend/src/main/java/hanglog/like/repository/LikeRepository.java

@@ -2,6 +2,7 @@
 
 import hanglog.like.domain.Likes;
 import hanglog.like.dto.LikeElement;
+import hanglog.like.dto.TripLikeCount;
 import java.util.List;
 import java.util.Optional;
 import org.springframework.data.jpa.repository.JpaRepository;
@@ -29,4 +30,11 @@ List<LikeElement> findLikeCountAndIsLikeByTripIds(@Param("memberId") final Long
              """)
     Optional<LikeElement> findLikeCountAndIsLikeByTripId(@Param("memberId") final Long memberId,
                                                          @Param("tripId") final Long tripId);
+
+    @Query("""
+            SELECT new hanglog.like.dto.TripLikeCount(l.tripId, COUNT(l.memberId))
+            FROM Likes l
+            GROUP BY l.tripId
+             """)
+    List<TripLikeCount> findCountByAllTrips();
 }

backend/src/main/java/hanglog/like/service/LikeService.java

@@ -1,14 +1,21 @@
 package hanglog.like.service;
 
+import hanglog.like.domain.LikeCount;
+import hanglog.like.domain.Likes;
 import hanglog.like.domain.MemberLike;
-import hanglog.like.dto.MemberLikeCacheEvent;
+import hanglog.like.dto.TripLikeCount;
 import hanglog.like.dto.request.LikeRequest;
+import hanglog.like.repository.CustomLikeRepository;
+import hanglog.like.repository.LikeCountRepository;
+import hanglog.like.repository.LikeRepository;
 import hanglog.like.repository.MemberLikeRepository;
+import hanglog.member.domain.repository.MemberRepository;
 import java.util.HashMap;
+import java.util.List;
 import java.util.Map;
 import java.util.Optional;
+import java.util.stream.Stream;
 import lombok.RequiredArgsConstructor;
-import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
@@ -18,8 +25,11 @@
 @Transactional
 public class LikeService {
 
+    private final LikeRepository likeRepository;
     private final MemberLikeRepository memberLikeRepository;
-    private final ApplicationEventPublisher publisher;
+    private final LikeCountRepository likeCountRepository;
+    private final MemberRepository memberRepository;
+    private final CustomLikeRepository customLikeRepository;
 
     public void update(final Long memberId, final Long tripId, final LikeRequest likeRequest) {
         Map<Long, Boolean> tripLikeStatusMap = new HashMap<>();
@@ -39,8 +49,24 @@ public boolean check(final Long memberId, final Long tripId) {
         return false;
     }
 
-    @Scheduled(fixedRate = 3600000)
+    @Scheduled(cron = "0 0 * * * *")
     public void writeBackMemberLikeCache() {
-        publisher.publishEvent(new MemberLikeCacheEvent());
+        final List<Likes> likes = memberRepository.findAll().stream()
+                .flatMap(member -> memberLikeRepository.findById(member.getId())
+                        .map(memberLike -> memberLike.getTripLikeStatusMap()
+                                .entrySet().stream()
+                                .filter(Map.Entry::getValue)
+                                .map(entry -> new Likes(entry.getKey(), member.getId())))
+                        .orElseGet(Stream::empty))
+                .toList();
+        customLikeRepository.saveAll(likes);
+    }
+
+    @Scheduled(cron = "0 0 0 * * *")
+    public void cacheLikeCount() {
+        final List<TripLikeCount> tripLikeCounts = likeRepository.findCountByAllTrips();
+        for (final TripLikeCount tripLikeCount : tripLikeCounts) {
+            likeCountRepository.save(new LikeCount(tripLikeCount.getTripId(), tripLikeCount.getCount()));
+        }
     }
 }

backend/src/test/java/hanglog/integration/service/CommunityServiceIntegrationTest.java

@@ -26,16 +26,7 @@
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.domain.Pageable;
 
-@Import({
-        TripService.class,
-        CommunityService.class,
-        LedgerService.class,
-        RecommendStrategies.class,
-        CustomDayLogRepositoryImpl.class,
-        CustomTripCityRepositoryImpl.class,
-        EventListenerTestConfig.class
-})
-class CommunityServiceIntegrationTest extends ServiceIntegrationTest {
+class CommunityServiceIntegrationTest extends RedisServiceIntegrationTest {
 
     @Autowired
     private TripService tripService;