feat: 회원 탈퇴 시 사용자 연관 데이터 정리 범위 확장

Author: pooreumjung

src/main/java/com/semosan/api/domain/hiking/repository/HikingMemberRepository.java

@@ -0,0 +1,14 @@
+package com.semosan.api.domain.hiking.repository;
+
+import com.semosan.api.domain.hiking.entity.HikingMember;
+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;
+
+public interface HikingMemberRepository extends JpaRepository<HikingMember, Long> {
+
+    @Modifying(clearAutomatically = true)
+    @Query("DELETE FROM HikingMember hm WHERE hm.user.id = :userId")
+    void deleteByUser_Id(@Param("userId") Long userId);
+}

src/main/java/com/semosan/api/domain/hiking/repository/HikingRecordRepository.java

@@ -10,8 +10,26 @@
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
 
+import java.util.List;
+
 public interface HikingRecordRepository extends JpaRepository<HikingRecord, Long> {
 
+    @Query(
+            value = """
+                    SELECT hm.hiking_record_id
+                    FROM hiking_members hm
+                    WHERE hm.user_id = :userId
+                      AND NOT EXISTS (
+                          SELECT 1
+                          FROM hiking_members other_hm
+                          WHERE other_hm.hiking_record_id = hm.hiking_record_id
+                            AND other_hm.user_id <> :userId
+                      )
+                    """,
+            nativeQuery = true
+    )
+    List<Long> findRecordIdsOnlyParticipatedByUser(@Param("userId") Long userId);
+
     @Query(
             value = """
                     SELECT

src/main/java/com/semosan/api/domain/mountain/repository/MountainLikeRepository.java

@@ -5,6 +5,7 @@
 import org.springframework.data.domain.Pageable;
 import org.springframework.data.jpa.repository.EntityGraph;
 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;
 
@@ -16,6 +17,10 @@ public interface MountainLikeRepository extends JpaRepository<MountainLike, Long
 
     Optional<MountainLike> findByUser_IdAndMountain_Id(Long userId, Long mountainId);
 
+    @Modifying(clearAutomatically = true)
+    @Query("DELETE FROM MountainLike ml WHERE ml.user.id = :userId")
+    void deleteByUser_Id(@Param("userId") Long userId);
+
     @EntityGraph(attributePaths = "mountain")
     @Query(
             value = "SELECT ml FROM MountainLike ml WHERE ml.user.id = :userId",

src/main/java/com/semosan/api/domain/notification/repository/NotificationRepository.java

@@ -2,10 +2,17 @@
 
 import com.semosan.api.domain.notification.entity.Notification;
 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;
 
 import java.util.List;
 
 // TODO: 알림판 구현할 때 쓸 예정
 public interface NotificationRepository extends JpaRepository<Notification, Long> {
     List<Notification> findAllByUserIdOrderByCreatedAtDesc(Long userId);
+
+    @Modifying(clearAutomatically = true)
+    @Query("DELETE FROM Notification n WHERE n.userId = :userId")
+    void deleteAllByUserId(@Param("userId") Long userId);
 }

src/main/java/com/semosan/api/domain/review/repository/ReviewRepository.java

@@ -3,13 +3,18 @@
 import com.semosan.api.domain.review.entity.Review;
 import org.springframework.data.jpa.repository.EntityGraph;
 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;
 
 import java.util.List;
 
 public interface ReviewRepository extends JpaRepository<Review, Long> {
 
+    @Modifying(clearAutomatically = true)
+    @Query("DELETE FROM Review r WHERE r.user.id = :userId")
+    void deleteByUser_Id(@Param("userId") Long userId);
+
     @EntityGraph(attributePaths = {"user", "course"})
     @Query("SELECT r FROM Review r WHERE r.mountain.id = :mountainId ORDER BY r.createdAt DESC LIMIT :limit")
     List<Review> findRecentByMountainId(@Param("mountainId") Long mountainId, @Param("limit") int limit);

src/main/java/com/semosan/api/domain/user/service/UserService.java

@@ -2,6 +2,11 @@
 
 import com.semosan.api.common.exception.GeneralException;
 import com.semosan.api.common.status.ErrorStatus;
+import com.semosan.api.domain.hiking.repository.HikingMemberRepository;
+import com.semosan.api.domain.hiking.repository.HikingRecordRepository;
+import com.semosan.api.domain.mountain.repository.MountainLikeRepository;
+import com.semosan.api.domain.notification.repository.NotificationRepository;
+import com.semosan.api.domain.review.repository.ReviewRepository;
 import com.semosan.api.domain.user.dto.command.UpdateUserProfileCommand;
 import com.semosan.api.domain.user.dto.request.UpdateUserProfileRequest;
 import com.semosan.api.domain.user.entity.User;
@@ -17,13 +22,20 @@
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import java.util.List;
+
 @Service
 @RequiredArgsConstructor
 public class UserService {
 
     private final UserRepository userRepository;
     private final UserNotificationSettingRepository userNotificationSettingRepository;
     private final UserOnboardingRepository userOnboardingRepository;
+    private final MountainLikeRepository mountainLikeRepository;
+    private final ReviewRepository reviewRepository;
+    private final HikingMemberRepository hikingMemberRepository;
+    private final HikingRecordRepository hikingRecordRepository;
+    private final NotificationRepository notificationRepository;
     private final NicknamePolicy nicknamePolicy;
     private final UserReader userReader;
 
@@ -148,6 +160,14 @@ public void withdrawUser(User user) {
     }
 
     private void deleteUserChildRecords(Long userId) {
+        mountainLikeRepository.deleteByUser_Id(userId);
+        reviewRepository.deleteByUser_Id(userId);
+        List<Long> recordIdsToDelete = hikingRecordRepository.findRecordIdsOnlyParticipatedByUser(userId);
+        hikingMemberRepository.deleteByUser_Id(userId);
+        if (!recordIdsToDelete.isEmpty()) {
+            hikingRecordRepository.deleteAllByIdInBatch(recordIdsToDelete);
+        }
+        notificationRepository.deleteAllByUserId(userId);
         userOnboardingRepository.deleteByUser_Id(userId);
         userNotificationSettingRepository.deleteByUser_Id(userId);
     }

src/test/java/com/semosan/api/domain/user/service/UserServiceTest.java

@@ -0,0 +1,86 @@
+package com.semosan.api.domain.user.service;
+
+import com.semosan.api.domain.hiking.repository.HikingMemberRepository;
+import com.semosan.api.domain.hiking.repository.HikingRecordRepository;
+import com.semosan.api.domain.mountain.repository.MountainLikeRepository;
+import com.semosan.api.domain.notification.repository.NotificationRepository;
+import com.semosan.api.domain.review.repository.ReviewRepository;
+import com.semosan.api.domain.user.entity.User;
+import com.semosan.api.domain.user.enums.user.DeviceType;
+import com.semosan.api.domain.user.enums.user.OnboardingStatus;
+import com.semosan.api.domain.user.policy.NicknamePolicy;
+import com.semosan.api.domain.user.repository.UserNotificationSettingRepository;
+import com.semosan.api.domain.user.repository.UserOnboardingRepository;
+import com.semosan.api.domain.user.repository.UserRepository;
+import org.junit.jupiter.api.Test;
+import org.junit.jupiter.api.extension.ExtendWith;
+import org.mockito.InjectMocks;
+import org.mockito.Mock;
+import org.mockito.junit.jupiter.MockitoExtension;
+import org.springframework.test.util.ReflectionTestUtils;
+
+import java.util.List;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.mockito.Mockito.verify;
+import static org.mockito.Mockito.when;
+
+@ExtendWith(MockitoExtension.class)
+class UserServiceTest {
+
+    @Mock
+    private UserRepository userRepository;
+
+    @Mock
+    private UserNotificationSettingRepository userNotificationSettingRepository;
+
+    @Mock
+    private UserOnboardingRepository userOnboardingRepository;
+
+    @Mock
+    private MountainLikeRepository mountainLikeRepository;
+
+    @Mock
+    private ReviewRepository reviewRepository;
+
+    @Mock
+    private HikingMemberRepository hikingMemberRepository;
+
+    @Mock
+    private HikingRecordRepository hikingRecordRepository;
+
+    @Mock
+    private NotificationRepository notificationRepository;
+
+    @Mock
+    private NicknamePolicy nicknamePolicy;
+
+    @Mock
+    private UserReader userReader;
+
+    @InjectMocks
+    private UserService userService;
+
+    @Test
+    void withdrawUserDeletesUserChildRecordsAndSoftDeletesUser() {
+        User user = User.createTestUser("withdraw-test-user", DeviceType.IOS);
+        ReflectionTestUtils.setField(user, "id", 1L);
+        when(hikingRecordRepository.findRecordIdsOnlyParticipatedByUser(1L)).thenReturn(List.of(10L, 11L));
+
+        userService.withdrawUser(user);
+
+        verify(mountainLikeRepository).deleteByUser_Id(1L);
+        verify(reviewRepository).deleteByUser_Id(1L);
+        verify(hikingRecordRepository).findRecordIdsOnlyParticipatedByUser(1L);
+        verify(hikingMemberRepository).deleteByUser_Id(1L);
+        verify(hikingRecordRepository).deleteAllByIdInBatch(List.of(10L, 11L));
+        verify(notificationRepository).deleteAllByUserId(1L);
+        verify(userOnboardingRepository).deleteByUser_Id(1L);
+        verify(userNotificationSettingRepository).deleteByUser_Id(1L);
+
+        assertThat(user.isDeleted()).isTrue();
+        assertThat(user.getEmail()).isNull();
+        assertThat(user.getName()).isNull();
+        assertThat(user.getOnboardingStatus()).isEqualTo(OnboardingStatus.INCOMPLETE);
+    }
+}