[FEATURE] 탈퇴 유저 정보 삭제 스케쥴링 구현 (#152)

* feat : 탈퇴 유저 정보 삭제 스케쥴링 구현 #147 * feat : 탈퇴 유저 정보 삭제 스케쥴링 구현 #147 * spotless apply #147
Team-TIFY · Jan 20, 2024 · 6d79596 · 6d79596
1 parent 9503786
commit 6d79596
Show file tree

Hide file tree

Showing 10 changed files with 96 additions and 3 deletions.
diff --git a/Api/src/main/java/tify/server/TifyApiApplication.java b/Api/src/main/java/tify/server/TifyApiApplication.java
@@ -11,10 +11,14 @@
 import org.springframework.boot.context.event.ApplicationReadyEvent;
 import org.springframework.context.ApplicationListener;
 import org.springframework.core.env.Environment;
+import org.springframework.scheduling.annotation.EnableAsync;
+import org.springframework.scheduling.annotation.EnableScheduling;
 
 @EntityScan("tify.server.domain")
 @RequiredArgsConstructor
 @SpringBootApplication
+@EnableScheduling
+@EnableAsync
 @Slf4j
 public class TifyApiApplication implements ApplicationListener<ApplicationReadyEvent> {
 

diff --git a/.../src/main/java/tify/server/domain/domains/question/repository/AnswerReportRepository.java b/.../src/main/java/tify/server/domain/domains/question/repository/AnswerReportRepository.java
@@ -8,4 +8,6 @@
 public interface AnswerReportRepository extends JpaRepository<AnswerReport, Long> {
 
     Optional<AnswerReport> findByAnswerIdAndReportUserId(Long answerId, Long reportUserId);
+
+    void deleteAllByReportUserId(Long userId);
 }
diff --git a/Domain/src/main/java/tify/server/domain/domains/question/repository/AnswerRepository.java b/Domain/src/main/java/tify/server/domain/domains/question/repository/AnswerRepository.java
@@ -10,4 +10,6 @@ public interface AnswerRepository extends JpaRepository<Answer, Long>, AnswerCus
     Optional<Answer> findByQuestionIdAndUserId(Long questionId, Long userId);
 
     Long countAllByUserId(Long userId);
+
+    void deleteAllByUserId(Long userId);
 }
diff --git a/...n/src/main/java/tify/server/domain/domains/question/repository/FavorAnswerRepository.java b/...n/src/main/java/tify/server/domain/domains/question/repository/FavorAnswerRepository.java
@@ -13,4 +13,6 @@ boolean existsByFavorQuestion_FavorQuestionCategoryAndUserId(
 
     boolean existsByFavorQuestion_FavorQuestionCategory_DetailCategoryAndUserId(
             DetailCategory detailCategory, Long userId);
+
+    void deleteAllByUserId(Long userId);
 }
diff --git a/Domain/src/main/java/tify/server/domain/domains/question/repository/KnockRepository.java b/Domain/src/main/java/tify/server/domain/domains/question/repository/KnockRepository.java
@@ -15,4 +15,6 @@ List<Knock> findAllByDailyQuestionIdAndUserIdAndKnockedUserId(
     List<Knock> findDistinctByDailyQuestionIdAndKnockedUserId(Long questionId, Long knockedUserId);
 
     List<Knock> findAllByKnockedUserIdAndDailyQuestionId(Long knockedUserId, Long dailyQuestionId);
+
+    void deleteAllByUserIdOrKnockedUserId(Long userId, Long knockedUserId);
 }
diff --git a/Domain/src/main/java/tify/server/domain/domains/user/repository/NeighborRepository.java b/Domain/src/main/java/tify/server/domain/domains/user/repository/NeighborRepository.java
@@ -21,4 +21,6 @@ public interface NeighborRepository
     List<Neighbor> findAllByFromUserIdAndIsView(Long fromUserId, boolean isView);
 
     List<Neighbor> findAllByFromUserIdOrderByOrder(Long fromUserId);
+
+    void deleteAllByFromUserIdOrToUserId(Long fromUserId, Long toUserId);
 }
diff --git a/Domain/src/main/java/tify/server/domain/domains/user/repository/UserBlockRepository.java b/Domain/src/main/java/tify/server/domain/domains/user/repository/UserBlockRepository.java
@@ -8,9 +8,11 @@
 
 public interface UserBlockRepository extends JpaRepository<UserBlock, Long> {
 
-    public Optional<UserBlock> findByFromUserIdAndToUserId(Long fromUserId, Long toUserId);
+    Optional<UserBlock> findByFromUserIdAndToUserId(Long fromUserId, Long toUserId);
 
-    public boolean existsByFromUserIdAndToUserId(Long fromUserId, Long toUserId);
+    boolean existsByFromUserIdAndToUserId(Long fromUserId, Long toUserId);
 
-    public List<UserBlock> findAllByFromUserId(Long fromUserId);
+    List<UserBlock> findAllByFromUserId(Long fromUserId);
+
+    void deleteAllByFromUserIdOrToUserId(Long fromUserId, Long toUserId);
 }
diff --git a/Domain/src/main/java/tify/server/domain/domains/user/repository/UserReportRepository.java b/Domain/src/main/java/tify/server/domain/domains/user/repository/UserReportRepository.java
@@ -11,4 +11,6 @@ public interface UserReportRepository extends JpaRepository<UserReport, Long> {
     List<UserReport> findAllByToUserId(Long userId);
 
     Optional<UserReport> findByFromUserIdAndToUserId(Long fromUserId, Long toUserId);
+
+    void deleteAllByFromUserIdOrToUserId(Long fromUserId, Long toUserId);
 }
diff --git a/Domain/src/main/java/tify/server/domain/domains/user/service/UserDomainService.java b/Domain/src/main/java/tify/server/domain/domains/user/service/UserDomainService.java
@@ -1,6 +1,9 @@
 package tify.server.domain.domains.user.service;
 
 
+import java.time.LocalDateTime;
+import java.util.List;
+import java.util.Objects;
 import lombok.RequiredArgsConstructor;
 import org.springframework.transaction.annotation.Transactional;
 import tify.server.core.annotation.DomainService;
@@ -63,4 +66,24 @@ public boolean userCanRegister(OauthInfo oauthInfo) {
         return !userAdaptor.existByOauthInfo(oauthInfo)
                 || userResignAdaptor.existByOauthInfo(oauthInfo);
     }
+
+    public List<User> getResignedUsers() {
+        return userResignAdaptor.queryAll().stream()
+                .map(
+                        resign -> {
+                            LocalDateTime resignedTime =
+                                    resign.getCreatedAt()
+                                            .toLocalDateTime()
+                                            .withHour(0)
+                                            .withMinute(0)
+                                            .withSecond(0)
+                                            .withNano(0);
+                            if (resignedTime.isEqual(LocalDateTime.now().minusMonths(6))) {
+                                return userAdaptor.query(resign.getUserId());
+                            }
+                            return null;
+                        })
+                .filter(Objects::nonNull)
+                .toList();
+    }
 }
diff --git a/Domain/src/main/java/tify/server/domain/scheduler/user/UserResignScheduler.java b/Domain/src/main/java/tify/server/domain/scheduler/user/UserResignScheduler.java
@@ -0,0 +1,52 @@
+package tify.server.domain.scheduler.user;
+
+
+import java.util.List;
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Transactional;
+import tify.server.domain.domains.question.repository.AnswerReportRepository;
+import tify.server.domain.domains.question.repository.AnswerRepository;
+import tify.server.domain.domains.question.repository.FavorAnswerRepository;
+import tify.server.domain.domains.question.repository.KnockRepository;
+import tify.server.domain.domains.user.domain.User;
+import tify.server.domain.domains.user.repository.NeighborRepository;
+import tify.server.domain.domains.user.repository.UserBlockRepository;
+import tify.server.domain.domains.user.repository.UserReportRepository;
+import tify.server.domain.domains.user.repository.UserRepository;
+import tify.server.domain.domains.user.service.UserDomainService;
+
+@Component
+@RequiredArgsConstructor
+public class UserResignScheduler {
+
+    private final UserDomainService userDomainService;
+
+    private final UserRepository userRepository;
+    private final AnswerRepository answerRepository;
+    private final AnswerReportRepository answerReportRepository;
+    private final FavorAnswerRepository favorAnswerRepository;
+    private final KnockRepository knockRepository;
+    private final NeighborRepository neighborRepository;
+    private final UserBlockRepository userBlockRepository;
+    private final UserReportRepository userReportRepository;
+
+    @Transactional
+    @Scheduled(cron = "0 0 0 * * *", zone = "Asia/Seoul")
+    public void deleteResignedUsers() {
+        List<User> resignedUserList = userDomainService.getResignedUsers();
+        resignedUserList.forEach(
+                user -> {
+                    answerRepository.deleteAllByUserId(user.getId());
+                    answerReportRepository.deleteAllByReportUserId(user.getId());
+                    favorAnswerRepository.deleteAllByUserId(user.getId());
+                    knockRepository.deleteAllByUserIdOrKnockedUserId(user.getId(), user.getId());
+                    neighborRepository.deleteAllByFromUserIdOrToUserId(user.getId(), user.getId());
+                    userBlockRepository.deleteAllByFromUserIdOrToUserId(user.getId(), user.getId());
+                    userReportRepository.deleteAllByFromUserIdOrToUserId(
+                            user.getId(), user.getId());
+                    userRepository.delete(user);
+                });
+    }
+}