[Server] 카테고리 리마인드 푸쉬 알림 스케쥴링을 구현한다

src/main/java/Skeep/backend/category/domain/UserCategoryMostUserLocationProjection.java

@@ -0,0 +1,7 @@
+package Skeep.backend.category.domain;
+
+public interface UserCategoryMostUserLocationProjection {
+    Long getUserCategoryId();
+    String getUserCategoryName();
+    Long getUserLocationCount();
+}

src/main/java/Skeep/backend/category/domain/UserCategoryRepository.java

@@ -20,4 +20,16 @@ public interface UserCategoryRepository extends JpaRepository<UserCategory, Long
     @Modifying
     @Query("DELETE FROM UserCategory uc WHERE uc.user = :user")
     void deleteAllByUser(@Param(value = "user") User user);
+
+    @Query(
+            value = "SELECT uc.id as userCategoryId, uc.name as userCategoryName, COUNT(ul.id) as userLocationCount " +
+                    "FROM users_category uc " +
+                    "LEFT JOIN users_location ul ON ul.users_category_id = uc.id " +
+                    "WHERE uc.user_id = :userId " +
+                    "GROUP BY uc.id, uc.name " +
+                    "ORDER BY userLocationCount DESC " +
+                    "LIMIT 1",
+            nativeQuery = true
+    )
+    Optional<UserCategoryMostUserLocationProjection> findTopCategoryWithMostUserLocations(Long userId);
 }

src/main/java/Skeep/backend/category/service/UserCategoryRetriever.java

@@ -1,6 +1,7 @@
 package Skeep.backend.category.service;
 
 import Skeep.backend.category.domain.UserCategory;
+import Skeep.backend.category.domain.UserCategoryMostUserLocationProjection;
 import Skeep.backend.category.domain.UserCategoryRepository;
 import Skeep.backend.category.dto.response.UserCategoryList;
 import Skeep.backend.category.exception.UserCategoryErrorCode;
@@ -11,6 +12,7 @@
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
+import java.util.Optional;
 
 @Service
 @Transactional(readOnly = true)
@@ -41,4 +43,8 @@ public UserCategory findByUserAndName(User user,String name) {
     public List<UserCategory> findAllByUser(User user) {
         return userCategoryRepository.findAllByUserId(user.getId());
     }
+
+    public Optional<UserCategoryMostUserLocationProjection> findTopCategoryWithMostUserLocations(User user) {
+        return userCategoryRepository.findTopCategoryWithMostUserLocations(user.getId());
+    }
 }

src/main/java/Skeep/backend/notification/service/NotificationScheduleService.java

@@ -1,51 +1,64 @@
 package Skeep.backend.notification.service;
 
-import Skeep.backend.category.domain.UserCategory;
+import Skeep.backend.category.domain.UserCategoryMostUserLocationProjection;
 import Skeep.backend.category.service.UserCategoryRetriever;
-import Skeep.backend.location.userLocation.service.UserLocationRetriever;
+import Skeep.backend.fcm.constant.FcmConstants;
+import Skeep.backend.fcm.service.FcmService;
 import Skeep.backend.user.domain.User;
 import Skeep.backend.user.service.UserFindService;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.scheduling.annotation.Async;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
 
-import java.util.HashMap;
 import java.util.List;
-import java.util.Map;
+import java.util.Optional;
 
+@Slf4j
 @Component
 @RequiredArgsConstructor
 public class NotificationScheduleService {
+    private final FcmService fcmService;
     private final UserFindService userFindService;
     private final UserCategoryRetriever userCategoryRetriever;
-    private final UserLocationRetriever userLocationRetriever;
 
     @Async
     @Scheduled(cron = "0 0 9 * * *")
     public void sendCategoryNotification() {
         List<User> userList = userFindService.findAllByFcmTokenIsNotNull();
-        for (User user : userList) {
-            List<UserCategory> userCategoryList = userCategoryRetriever.findAllByUser(user);
-            List<Map<String, Long>> userCategoryLocationMapList
-                    = userCategoryList.stream().map(userCategory -> {
-                        Map<String, Long> tempMap = new HashMap<>();
-                        Long count = userLocationRetriever.countByUserCategory(userCategory);
 
-                        tempMap.put(userCategory.getName(), count);
-                        return tempMap;
-                    }).toList();
+        log.info("userList : {}", userList);
 
-//            userCategoryLocationMapList.stream().max(
-//                    Comparator.comparingLong(obj -> obj.)
-//            )
+        userList.forEach(user -> {
+            Optional<UserCategoryMostUserLocationProjection> userCategoryWithMostUserLocation
+                    = userCategoryRetriever.findTopCategoryWithMostUserLocations(user);
+            if (userCategoryWithMostUserLocation.isEmpty())
+                return;
+            UserCategoryMostUserLocationProjection userCategoryNameAndUserLocationCount
+                    = userCategoryWithMostUserLocation.get();
 
+            if (userCategoryNameAndUserLocationCount.getUserLocationCount() <= 0)
+                return;
+            String userCategoryName = userCategoryNameAndUserLocationCount.getUserCategoryName();
 
+            String title = user.getName() + FcmConstants.CATEGORY_TITLE_1
+                    + userCategoryName + FcmConstants.CATEGORY_TITLE_2;
+            String body = FcmConstants.CATEGORY_BODY;
+            String url = FcmConstants.CATEGORY_URL
+                    + userCategoryNameAndUserLocationCount.getUserCategoryId().toString();
 
-        }
-
-
+            log.info("user : {} fcm 호출", user.getName());
+            fcmService.sendNotification(
+                    Boolean.TRUE,
+                    user.getFcmToken(),
+                    title,
+                    body,
+                    userCategoryNameAndUserLocationCount.getUserCategoryId(),
+                    "category",
+                    url
+            );
+            log.info("user : {} fcm 끝", user.getName());
+        });
     }
-
-
 }