[feat] 알림 100개 유지 및 최근 30일만 표시

Author: k3vin7

src/main/java/com/daramg/server/notification/application/NotificationQueryService.java

@@ -12,6 +12,7 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.time.LocalDateTime;
 import java.util.List;
 
 @Service
@@ -37,6 +38,6 @@ public PageResponseDto<NotificationResponseDto> getNotifications(User user, Page
     }
 
     public long getUnreadCount(User user) {
-        return notificationRepository.countByReceiverIdAndIsReadFalse(user.getId());
+        return notificationRepository.countUnreadByReceiverIdSince(user.getId(), LocalDateTime.now().minusDays(30));
     }
 }

src/main/java/com/daramg/server/notification/event/NotificationEventListener.java

@@ -28,5 +28,9 @@ public void handleNotificationEvent(NotificationEvent event) {
         );
 
         notificationRepository.save(notification);
+
+        if (notificationRepository.countByReceiverId(event.receiver().getId()) > 100) {
+            notificationRepository.deleteOldestByReceiverIdExceedingLimit(event.receiver().getId());
+        }
     }
 }

src/main/java/com/daramg/server/notification/repository/NotificationQueryRepositoryImpl.java

@@ -8,6 +8,7 @@
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
 
+import java.time.LocalDateTime;
 import java.util.List;
 
 import static com.daramg.server.notification.domain.QNotification.notification;
@@ -27,7 +28,10 @@ public List<Notification> getNotificationsWithPaging(Long receiverId, PageReques
                 .selectFrom(notification)
                 .leftJoin(notification.sender, user).fetchJoin()
                 .leftJoin(notification.post, post).fetchJoin()
-                .where(notification.receiver.id.eq(receiverId));
+                .where(
+                        notification.receiver.id.eq(receiverId),
+                        notification.createdAt.goe(LocalDateTime.now().minusDays(30))
+                );
 
         return pagingUtils.applyCursorPagination(
                 query,

src/main/java/com/daramg/server/notification/repository/NotificationRepository.java

@@ -5,11 +5,21 @@
 import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 
+import java.time.LocalDateTime;
+
 public interface NotificationRepository extends JpaRepository<Notification, Long> {
 
-    long countByReceiverIdAndIsReadFalse(Long receiverId);
+    @Query("SELECT COUNT(n) FROM Notification n WHERE n.receiver.id = :receiverId AND n.isRead = false AND n.createdAt >= :since")
+    long countUnreadByReceiverIdSince(Long receiverId, LocalDateTime since);
+
+    long countByReceiverId(Long receiverId);
 
     @Modifying
     @Query("UPDATE Notification n SET n.isRead = true WHERE n.receiver.id = :receiverId AND n.isRead = false")
     void markAllAsReadByReceiverId(Long receiverId);
+
+    @Modifying
+    @Query("DELETE FROM Notification n WHERE n.receiver.id = :receiverId AND n.id NOT IN " +
+            "(SELECT n2.id FROM Notification n2 WHERE n2.receiver.id = :receiverId ORDER BY n2.createdAt DESC LIMIT 100)")
+    void deleteOldestByReceiverIdExceedingLimit(Long receiverId);
 }