feat: 알림 스케줄러 적용

Author: noeyoes

src/main/java/com/example/Tokkit_server/notification/repository/MerchantNotificationRepository.java

@@ -5,8 +5,10 @@
 import com.example.Tokkit_server.notification.enums.NotificationCategory;
 import io.lettuce.core.dynamic.annotation.Param;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Optional;
 
@@ -20,4 +22,8 @@ public interface MerchantNotificationRepository extends JpaRepository<MerchantNo
     Optional<MerchantNotification> findByIdAndMerchant(Long id, Merchant merchant);
 
     List<MerchantNotification> findByMerchantAndDeletedFalse(Merchant merchant);
+
+    @Modifying
+    @Query("UPDATE MerchantNotification n SET n.deleted = true WHERE n.deleted = false AND n.createdAt < :cutoff")
+    int softDeleteOldNotifications(@org.springframework.data.repository.query.Param("cutoff") LocalDateTime cutoff);
 }

src/main/java/com/example/Tokkit_server/notification/repository/NotificationRepository.java

@@ -1,12 +1,14 @@
 package com.example.Tokkit_server.notification.repository;
 
+import java.time.LocalDateTime;
 import java.util.List;
 import java.util.Optional;
 
 import com.example.Tokkit_server.notification.entity.Notification;
 import com.example.Tokkit_server.notification.enums.NotificationCategory;
 import com.example.Tokkit_server.user.entity.User;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
 
@@ -23,4 +25,8 @@ public interface NotificationRepository extends JpaRepository<Notification, Long
     Optional<Notification> findByIdAndUser(Long id, User user);
 
     List<Notification> findByUserAndDeletedFalse(User user);
+
+    @Modifying
+    @Query("UPDATE Notification n SET n.deleted = true WHERE n.deleted = false AND n.createdAt < :cutoff")
+    int softDeleteOldNotifications(@Param("cutoff") LocalDateTime cutoff);
 }

src/main/java/com/example/Tokkit_server/notification/scheduler/NotificationCleanupScheduler.java

@@ -0,0 +1,31 @@
+package com.example.Tokkit_server.notification.scheduler;
+
+import com.example.Tokkit_server.notification.repository.MerchantNotificationRepository;
+import com.example.Tokkit_server.notification.repository.NotificationRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.time.LocalDate;
+import java.time.LocalDateTime;
+
+@Slf4j
+@RequiredArgsConstructor
+@Component
+public class NotificationCleanupScheduler {
+
+    private final NotificationRepository notificationRepository;
+    private final MerchantNotificationRepository merchantNotificationRepository;
+
+    @Scheduled(cron = "0 0 0 * * *")
+    @Transactional
+    public void cleanOldNotifications() {
+        LocalDateTime cutoff = LocalDate.now().minusDays(7).atStartOfDay();
+        int updatedCount = notificationRepository.softDeleteOldNotifications(cutoff);
+        int updatedMerchantCount = merchantNotificationRepository.softDeleteOldNotifications(cutoff);
+        log.info("🧹 [유저 알림 정리] {}개의 알림 soft delete 처리 완료", updatedCount);
+        log.info("🧹 [가맹점주 알림 정리] {}개의 알림 soft delete 처리 완료", updatedMerchantCount);
+    }
+}