fix: 탈퇴한 사용자가 물리적 삭제가 되지 않았던 문제를 해결한다

src/main/java/com/example/solidconnection/application/repository/ApplicationRepository.java

@@ -40,4 +40,6 @@ default Application getApplicationBySiteUserIdAndTermId(long siteUserId, long te
         return findBySiteUserIdAndTermId(siteUserId, termId)
                 .orElseThrow(() -> new CustomException(APPLICATION_NOT_FOUND));
     }
+
+    void deleteAllBySiteUserId(long siteUserId);
 }

src/main/java/com/example/solidconnection/chat/repository/ChatParticipantRepository.java

@@ -1,12 +1,20 @@
 package com.example.solidconnection.chat.repository;
 
 import com.example.solidconnection.chat.domain.ChatParticipant;
+import java.util.List;
 import java.util.Optional;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 
 public interface ChatParticipantRepository extends JpaRepository<ChatParticipant, Long> {
 
     boolean existsByChatRoomIdAndSiteUserId(long chatRoomId, long siteUserId);
 
     Optional<ChatParticipant> findByChatRoomIdAndSiteUserId(long chatRoomId, long siteUserId);
+
+    void deleteAllBySiteUserId(long siteUserId);
+
+    @Query("SELECT cp.id FROM ChatParticipant cp WHERE cp.siteUserId = :siteUserId")
+    List<Long> findAllIdsBySiteUserId(@Param("siteUserId") long siteUserId);
 }

src/main/java/com/example/solidconnection/chat/repository/ChatReadStatusRepository.java

@@ -1,6 +1,7 @@
 package com.example.solidconnection.chat.repository;
 
 import com.example.solidconnection.chat.domain.ChatReadStatus;
+import java.util.List;
 import org.springframework.data.jpa.repository.JpaRepository;
 import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
@@ -15,4 +16,6 @@ INSERT INTO chat_read_status (chat_room_id, chat_participant_id, created_at, upd
                    ON DUPLICATE KEY UPDATE updated_at = NOW(6)
                    """, nativeQuery = true)
     void upsertReadStatus(@Param("chatRoomId") long chatRoomId, @Param("chatParticipantId") long chatParticipantId);
+
+    void deleteAllByChatParticipantIdIn(List<Long> chatParticipantIds);
 }

src/main/java/com/example/solidconnection/community/comment/repository/CommentRepository.java

@@ -42,4 +42,6 @@ default Comment getById(Long id) {
         return findById(id)
                 .orElseThrow(() -> new CustomException(INVALID_COMMENT_ID));
     }
+
+    void deleteAllBySiteUserId(long siteUserId);
 }

src/main/java/com/example/solidconnection/community/post/repository/PostLikeRepository.java

@@ -16,4 +16,6 @@ default PostLike getByPostAndSiteUserId(Post post, long siteUserId) {
         return findPostLikeByPostAndSiteUserId(post, siteUserId)
                 .orElseThrow(() -> new CustomException(INVALID_POST_LIKE));
     }
+
+    void deleteAllBySiteUserId(long siteUserId);
 }

src/main/java/com/example/solidconnection/community/post/repository/PostRepository.java

@@ -59,4 +59,6 @@ default Post getById(Long id) {
         return findById(id)
                 .orElseThrow(() -> new CustomException(INVALID_POST_ID));
     }
+
+    void deleteAllBySiteUserId(long siteUserId);
 }

src/main/java/com/example/solidconnection/mentor/repository/MentorApplicationRepository.java

@@ -8,4 +8,6 @@
 public interface MentorApplicationRepository extends JpaRepository<MentorApplication, Long> {
 
     boolean existsBySiteUserIdAndMentorApplicationStatusIn(long siteUserId, List<MentorApplicationStatus> mentorApplicationStatuses);
+
+    void deleteAllBySiteUserId(long siteUserId);
 }

src/main/java/com/example/solidconnection/mentor/repository/MentorRepository.java

@@ -27,4 +27,6 @@ public interface MentorRepository extends JpaRepository<Mentor, Long> {
     Slice<Mentor> findAllByRegion(@Param("region") Region region, Pageable pageable);
 
     List<Mentor> findAllBySiteUserIdIn(Set<Long> siteUserIds);
+
+    void deleteAllBySiteUserId(long siteUserId);
 }

src/main/java/com/example/solidconnection/mentor/repository/MentoringRepository.java

@@ -39,4 +39,6 @@ public interface MentoringRepository extends JpaRepository<Mentoring, Long> {
 
     @Query("SELECT m FROM Mentoring m WHERE m.menteeId = :menteeId AND m.verifyStatus = :verifyStatus")
     Slice<Mentoring> findApprovedMentoringsByMenteeId(long menteeId, @Param("verifyStatus") VerifyStatus verifyStatus, Pageable pageable);
+
+    void deleteAllByMenteeId(long menteeId);
 }

src/main/java/com/example/solidconnection/news/repository/LikedNewsRepository.java

@@ -9,4 +9,6 @@ public interface LikedNewsRepository extends JpaRepository<LikedNews, Long> {
     boolean existsByNewsIdAndSiteUserId(long newsId, long siteUserId);
 
     Optional<LikedNews> findByNewsIdAndSiteUserId(long newsId, long siteUserId);
+
+    void deleteAllBySiteUserId(long siteUserId);
 }

src/main/java/com/example/solidconnection/news/repository/NewsRepository.java

@@ -8,4 +8,6 @@
 public interface NewsRepository extends JpaRepository<News, Long>, NewsCustomRepository {
 
     List<News> findAllBySiteUserIdOrderByUpdatedAtDesc(long siteUserId);
+
+    void deleteAllBySiteUserId(long siteUserId);
 }

src/main/java/com/example/solidconnection/report/repository/ReportRepository.java

@@ -7,4 +7,6 @@
 public interface ReportRepository extends JpaRepository<Report, Long> {
 
     boolean existsByReporterIdAndTargetTypeAndTargetId(long reporterId, TargetType targetType, long targetId);
+
+    void deleteAllByReporterId(long reporterId);
 }

src/main/java/com/example/solidconnection/scheduler/UserRemovalScheduler.java

@@ -1,12 +1,32 @@
 package com.example.solidconnection.scheduler;
 
+import com.example.solidconnection.application.repository.ApplicationRepository;
+import com.example.solidconnection.chat.repository.ChatParticipantRepository;
+import com.example.solidconnection.chat.repository.ChatReadStatusRepository;
+import com.example.solidconnection.community.comment.repository.CommentRepository;
+import com.example.solidconnection.community.post.repository.PostLikeRepository;
+import com.example.solidconnection.community.post.repository.PostRepository;
+import com.example.solidconnection.location.country.repository.InterestedCountryRepository;
+import com.example.solidconnection.location.region.repository.InterestedRegionRepository;
+import com.example.solidconnection.mentor.repository.MentorApplicationRepository;
+import com.example.solidconnection.mentor.repository.MentorRepository;
+import com.example.solidconnection.mentor.repository.MentoringRepository;
+import com.example.solidconnection.news.repository.LikedNewsRepository;
+import com.example.solidconnection.news.repository.NewsRepository;
+import com.example.solidconnection.report.repository.ReportRepository;
+import com.example.solidconnection.s3.service.S3Service;
+import com.example.solidconnection.score.repository.GpaScoreRepository;
+import com.example.solidconnection.score.repository.LanguageTestScoreRepository;
 import com.example.solidconnection.siteuser.domain.SiteUser;
 import com.example.solidconnection.siteuser.repository.SiteUserRepository;
+import com.example.solidconnection.siteuser.repository.UserBlockRepository;
+import com.example.solidconnection.university.repository.LikedUnivApplyInfoRepository;
 import java.time.LocalDate;
 import java.util.List;
 import lombok.RequiredArgsConstructor;
 import org.springframework.scheduling.annotation.Scheduled;
 import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
 
 @RequiredArgsConstructor
 @Component
@@ -16,14 +36,67 @@ public class UserRemovalScheduler {
     public static final int ACCOUNT_RECOVER_DURATION = 30;
 
     private final SiteUserRepository siteUserRepository;
+    private final InterestedCountryRepository interestedCountryRepository;
+    private final InterestedRegionRepository interestedRegionRepository;
+    private final CommentRepository commentRepository;
+    private final PostRepository postRepository;
+    private final PostLikeRepository postLikeRepository;
+    private final LikedUnivApplyInfoRepository likedUnivApplyInfoRepository;
+    private final ApplicationRepository applicationRepository;
+    private final GpaScoreRepository gpaScoreRepository;
+    private final LanguageTestScoreRepository languageTestScoreRepository;
+    private final MentorRepository mentorRepository;
+    private final MentoringRepository mentoringRepository;
+    private final NewsRepository newsRepository;
+    private final LikedNewsRepository likedNewsRepository;
+    private final ChatParticipantRepository chatParticipantRepository;
+    private final ChatReadStatusRepository chatReadStatusRepository;
+    private final ReportRepository reportRepository;
+    private final UserBlockRepository userBlockRepository;
+    private final MentorApplicationRepository mentorApplicationRepository;
+    private final S3Service s3Service;
 
     /*
      * 탈퇴 후 계정 복구 기한까지 방문하지 않은 사용자를 삭제한다.
      * */
     @Scheduled(cron = EVERY_MIDNIGHT)
+    @Transactional
     public void scheduledUserRemoval() {
         LocalDate cutoffDate = LocalDate.now().minusDays(ACCOUNT_RECOVER_DURATION);
         List<SiteUser> usersToRemove = siteUserRepository.findUsersToBeRemoved(cutoffDate);
-        siteUserRepository.deleteAll(usersToRemove);
+
+        usersToRemove.forEach(this::deleteUserAndRelatedData);
+    }
+
+    private void deleteUserAndRelatedData(SiteUser user) {
+        long siteUserId = user.getId();
+
+        likedNewsRepository.deleteAllBySiteUserId(siteUserId);
+        newsRepository.deleteAllBySiteUserId(siteUserId);
+
+        postLikeRepository.deleteAllBySiteUserId(siteUserId);
+        commentRepository.deleteAllBySiteUserId(siteUserId);
+        postRepository.deleteAllBySiteUserId(siteUserId);
+
+        mentoringRepository.deleteAllByMenteeId(siteUserId);
+        mentorRepository.deleteAllBySiteUserId(siteUserId);
+        mentorApplicationRepository.deleteAllBySiteUserId(siteUserId);
+
+        List<Long> chatParticipantIds = chatParticipantRepository.findAllIdsBySiteUserId(siteUserId);
+        chatReadStatusRepository.deleteAllByChatParticipantIdIn(chatParticipantIds);
+        chatParticipantRepository.deleteAllBySiteUserId(siteUserId);
+        reportRepository.deleteAllByReporterId(siteUserId);
+        userBlockRepository.deleteAllByBlockerIdOrBlockedId(siteUserId, siteUserId);
+
+        applicationRepository.deleteAllBySiteUserId(siteUserId);
+        gpaScoreRepository.deleteAllBySiteUserId(siteUserId);
+        languageTestScoreRepository.deleteAllBySiteUserId(siteUserId);
+        likedUnivApplyInfoRepository.deleteAllBySiteUserId(siteUserId);
+        interestedCountryRepository.deleteAllBySiteUserId(siteUserId);
+        interestedRegionRepository.deleteAllBySiteUserId(siteUserId);
+
+        s3Service.deleteExProfile(siteUserId);
+
+        siteUserRepository.delete(user);
     }
 }

src/main/java/com/example/solidconnection/score/repository/GpaScoreRepository.java

@@ -13,4 +13,6 @@ public interface GpaScoreRepository extends JpaRepository<GpaScore, Long>, GpaSc
     Optional<GpaScore> findGpaScoreBySiteUserIdAndId(long siteUserId, Long id);
 
     List<GpaScore> findBySiteUserId(long siteUserId);
+
+    void deleteAllBySiteUserId(long siteUserId);
 }

src/main/java/com/example/solidconnection/score/repository/LanguageTestScoreRepository.java

@@ -14,4 +14,6 @@ public interface LanguageTestScoreRepository extends JpaRepository<LanguageTestS
     Optional<LanguageTestScore> findLanguageTestScoreBySiteUserIdAndId(long siteUserId, Long id);
 
     List<LanguageTestScore> findBySiteUserId(long siteUserId);
+
+    void deleteAllBySiteUserId(long siteUserId);
 }

src/main/java/com/example/solidconnection/siteuser/repository/UserBlockRepository.java

@@ -24,4 +24,6 @@ public interface UserBlockRepository extends JpaRepository<UserBlock, Long> {
            WHERE ub.blockerId = :blockerId
            """)
     Slice<UserBlockResponse> findBlockedUsersWithNickname(@Param("blockerId") long blockerId, Pageable pageable);
+
+    void deleteAllByBlockerIdOrBlockedId(long blockerId, long blockedId);
 }

src/main/java/com/example/solidconnection/university/repository/LikedUnivApplyInfoRepository.java

@@ -25,4 +25,6 @@ public interface LikedUnivApplyInfoRepository extends JpaRepository<LikedUnivApp
     List<UnivApplyInfo> findUnivApplyInfosBySiteUserId(@Param("siteUserId") long siteUserId);
 
     boolean existsBySiteUserIdAndUnivApplyInfoId(long siteUserId, long univApplyInfoId);
+
+    void deleteAllBySiteUserId(long siteUserId);
 }