Merge pull request #227 from 9uttery/feat/create-joy-v2-#221

[Feature] Phase 3.0 앨범/소확행 관련 API 구현

Author: hojeong2747

src/main/java/com/guttery/madii/domain/albums/application/service/AlbumService.java

@@ -25,8 +25,10 @@
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.domain.Slice;
 import org.springframework.data.domain.SliceImpl;
+import org.springframework.data.redis.core.Cursor;
 import org.springframework.data.redis.core.ListOperations;
 import org.springframework.data.redis.core.RedisTemplate;
+import org.springframework.data.redis.core.ScanOptions;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
@@ -360,19 +362,68 @@ public void deleteAlbum(Long albumId, UserPrincipal userPrincipal) {
         savingJoyRepository.deleteByAlbumAlbumId(albumId);
         albumRepository.deleteById(albumId);
     }
+//
+//    public void deleteAlbums(List<Long> albumIds, UserPrincipal userPrincipal) {
+//        final User user = UserServiceHelper.findExistingUser(userRepository, userPrincipal);
+//
+//        Set<String> keys = redisTemplate.keys(KEY_PREFIX + "*");
+//        ListOperations<String, String> listOps = redisTemplate.opsForList();
+//
+//        // 실패한 albumId와 예외 메시지를 저장
+//        Map<Long, String> failedAlbumMap = new HashMap<>();
+//
+//        // 먼저 모든 유효성 및 권한 체크를 먼저 한 후, 삭제는 그 다음에 수행
+//        List<Album> albumsToDelete = new ArrayList<>();
+//
+//        for (Long albumId : albumIds) {
+//            try {
+//                Album album = albumRepository.findById(albumId)
+//                        .orElseThrow(() -> CustomException.of(ErrorDetails.ALBUM_NOT_FOUND));
+//
+//                if (!album.getUser().getUserId().equals(user.getUserId())) {
+//                    throw CustomException.of(ErrorDetails.NOT_MY_ALBUM);
+//                }
+//
+//                albumsToDelete.add(album);
+//            } catch (Exception e) {
+//                failedAlbumMap.put(albumId, e.getMessage());
+//            }
+//        }
+//
+//        // 하나라도 실패한 경우 전체 중단 및 rollback
+//        if (!failedAlbumMap.isEmpty()) {
+//            for (Map.Entry<Long, String> entry : failedAlbumMap.entrySet()) {
+//                log.warn("앨범 삭제 실패 - albumId: {}, 이유: {}", entry.getKey(), entry.getValue());
+//            }
+//            throw CustomException.of(ErrorDetails.DELETE_ALBUM_FAILED);  // 커스텀 예외 처리
+//        }
+//
+//        // 실제 삭제 (캐시, 연관 엔티티, 앨범)
+//        for (Album album : albumsToDelete) {
+//            Long albumId = album.getAlbumId();
+//
+//            for (String key : keys) {
+//                List<String> cachedAlbumIds = listOps.range(key, 0, -1);
+//                if (cachedAlbumIds != null && cachedAlbumIds.contains("albumId:" + albumId)) {
+//                    listOps.remove(key, 0, "albumId:" + albumId);
+//                }
+//            }
+//
+//            savingAlbumRepository.deleteByAlbumAlbumId(albumId);
+//            savingJoyRepository.deleteByAlbumAlbumId(albumId);
+//            albumRepository.deleteById(albumId);
+//        }
+//    }
 
     public void deleteAlbums(List<Long> albumIds, UserPrincipal userPrincipal) {
         final User user = UserServiceHelper.findExistingUser(userRepository, userPrincipal);
 
-        Set<String> keys = redisTemplate.keys(KEY_PREFIX + "*");
-        ListOperations<String, String> listOps = redisTemplate.opsForList();
+        // 먼저 모든 유효성 및 권한 체크를 먼저 한 후, 삭제는 그 다음에 수행
+        List<Album> albumsToDelete = new ArrayList<>();
 
         // 실패한 albumId와 예외 메시지를 저장
         Map<Long, String> failedAlbumMap = new HashMap<>();
 
-        // 먼저 모든 유효성 및 권한 체크를 먼저 한 후, 삭제는 그 다음에 수행
-        List<Album> albumsToDelete = new ArrayList<>();
-
         for (Long albumId : albumIds) {
             try {
                 Album album = albumRepository.findById(albumId)
@@ -396,23 +447,35 @@ public void deleteAlbums(List<Long> albumIds, UserPrincipal userPrincipal) {
             throw CustomException.of(ErrorDetails.DELETE_ALBUM_FAILED);  // 커스텀 예외 처리
         }
 
-        // 실제 삭제 (캐시, 연관 엔티티, 앨범)
-        for (Album album : albumsToDelete) {
-            Long albumId = album.getAlbumId();
+        // Redis 삭제 (SCAN 사용)
+        try (Cursor<byte[]> cursor = redisTemplate.getConnectionFactory()
+                .getConnection()
+                .scan(ScanOptions.scanOptions().match(KEY_PREFIX + "*").count(100).build())) {
+
+            ListOperations<String, String> listOps = redisTemplate.opsForList();
 
-            for (String key : keys) {
-                List<String> cachedAlbumIds = listOps.range(key, 0, -1);
-                if (cachedAlbumIds != null && cachedAlbumIds.contains("albumId:" + albumId)) {
-                    listOps.remove(key, 0, "albumId:" + albumId);
+            while (cursor.hasNext()) {
+                String key = new String(cursor.next());
+                for (Album album : albumsToDelete) {
+                    String target = "albumId:" + album.getAlbumId();
+                    listOps.remove(key, 0, target);
                 }
             }
 
-            savingAlbumRepository.deleteByAlbumAlbumId(albumId);
-            savingJoyRepository.deleteByAlbumAlbumId(albumId);
-            albumRepository.deleteById(albumId);
+        } catch (Exception e) {
+            log.error("Redis 삭제 중 오류 발생", e);
+            // 필요 시 fallback 로직 추가
+        }
+
+        // DB 삭제 (트랜잭션 보장)
+        for (Album album : albumsToDelete) {
+            savingAlbumRepository.deleteByAlbumAlbumId(album.getAlbumId());
+            savingJoyRepository.deleteByAlbumAlbumId(album.getAlbumId());
+            albumRepository.deleteById(album.getAlbumId());
         }
     }
 
+
     public List<AlbumGetCreatedResponse> getCreatedAlbums(UserPrincipal userPrincipal) {
         final User user = UserServiceHelper.findExistingUser(userRepository, userPrincipal);