feat : 유저 삭제 시 가상친구, 대화방, 메시지 삭제 구현

yhj0214 · yhj0214 · commit 2f4eea4e4204 · 2025-04-29T23:15:24.000+09:00
diff --git a/api/src/main/java/com/mbtips/domain/conversation/service/ConversationService.java b/api/src/main/java/com/mbtips/domain/conversation/service/ConversationService.java
@@ -4,6 +4,7 @@
 import com.mbtips.domain.converstation.Conversation;
 import com.mbtips.domain.user.User;
 import com.mbtips.domain.virtualfriend.VirtualFriend;
+import com.mbtips.message.interfaces.MessageRepository;
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
diff --git a/api/src/main/java/com/mbtips/domain/virtualfriend/VirtualFriendController.java b/api/src/main/java/com/mbtips/domain/virtualfriend/VirtualFriendController.java
@@ -49,7 +49,7 @@ public ApiResponse<VirtualFriendResponse> createVirtualFriend(@Valid @RequestBod
     @DeleteMapping("/{friendId}")
     @Operation(summary = "가상친구 삭제", description = "가상친구가 삭제되며, 채팅방이 삭제됩니다.")
     public ApiResponse<Void> deleteVirtualFriend(@PathVariable Long friendId, @LoginUser User user){
-        virtualFriendService.deleteVirtualFriend(friendId, user);
+        virtualFriendService.deleteVirtualFriend(friendId);
         return ApiResponse.success();
     }
 
diff --git a/api/src/main/java/com/mbtips/domain/virtualfriend/VirtualFriendService.java b/api/src/main/java/com/mbtips/domain/virtualfriend/VirtualFriendService.java
@@ -9,6 +9,7 @@
 import com.mbtips.domain.virtualfriend.request.VirtualFriendRequest;
 import com.mbtips.domain.virtualfriend.response.VirtualFriendInfoResponse;
 import com.mbtips.domain.virtualfriend.response.VirtualFriendResponse;
+import com.mbtips.message.interfaces.MessageRepository;
 import com.mbtips.virtualfriend.entity.InterestEntity;
 import com.mbtips.virtualfriend.entity.VirtualFriendEntity;
 import com.mbtips.virtualfriend.interfaces.InterestRepository;
@@ -31,6 +32,7 @@ public class VirtualFriendService {
     private final ConversationService conversationService;
     private final InterestRepository interestRepository;
     private final ConversationRepository conversationRepository;
+    private final MessageRepository messageRepository;
 
     @Transactional(readOnly = true)
     public List<VirtualFriendResponse> getVirtualFriendsByUserId(User user) {
@@ -73,16 +75,27 @@ public VirtualFriendResponse createVirtualFriend(VirtualFriendRequest req, User
 
 
     @Transactional
-    public void deleteVirtualFriend(Long virtualFriendId, User user) {
+    public void deleteVirtualFriend(Long virtualFriendId) {
 
         VirtualFriend virtualFriend = virtualFriendRepository.findById(virtualFriendId);
 
         interestRepository.deleteInterestByVirtualFriend(virtualFriend);
+
         conversationService.deleteConversation(virtualFriend);
         virtualFriendRepository.delete(virtualFriend);
 
     }
 
+    public void deleteVirtualFriendByUserId(String userId){
+        List<Long> virtualFriendIds = virtualFriendRepository.findVirtualFriendIds(userId);
+        log.debug("가상친구 {} 명을 조회하였습니다.", virtualFriendIds.size());
+
+        for(long idx : virtualFriendIds){
+            deleteVirtualFriend(idx);
+        }
+        log.debug("가상친구의 관심사, 대화방, 메시지를 모두 삭제하였습니다. 삭제된 가상친구 : {}", virtualFriendIds.size());
+    }
+
 
     @Transactional(readOnly = true)
     public VirtualFriendInfoResponse findFriendInfoById(Long virtualFriendId) {
diff --git a/api/src/main/java/com/mbtips/user/application/manager/UserManager.java b/api/src/main/java/com/mbtips/user/application/manager/UserManager.java
@@ -5,8 +5,11 @@
 import com.mbtips.common.exception.CustomException;
 import com.mbtips.common.exception.enums.CommonException;
 import com.mbtips.common.provider.JwtProvider;
+import com.mbtips.domain.conversation.service.ConversationService;
 import com.mbtips.domain.user.User;
 import com.mbtips.domain.user.utils.UserUtils;
+import com.mbtips.domain.virtualfriend.VirtualFriendService;
+import com.mbtips.message.application.service.MessageService;
 import com.mbtips.user.application.dto.LoginUserRequestDto;
 import com.mbtips.user.application.service.UserService;
 import lombok.RequiredArgsConstructor;
@@ -20,6 +23,9 @@ public class UserManager {
     private final UserService userService;
     private final ObjectMapper objectMapper;
     private final JwtProvider jwtProvider;
+    private final VirtualFriendService virtualFriendService;
+    private final ConversationService conversationService;
+    private final MessageService messageService;
 
     @Transactional
     public String login(LoginUserRequestDto requestDto) {
@@ -34,7 +40,7 @@ public String login(LoginUserRequestDto requestDto) {
 
     @Transactional
     public void deleteUser(String userId) {
+        virtualFriendService.deleteVirtualFriendByUserId(userId);
         userService.delete(userId);
-        // TODO : 회원 탈퇴시 진행되어야 하는 구조를 여기 넣으면 됩니다.
     }
 }
diff --git a/repository/src/main/java/com/mbtips/conversation/repository/impl/ConversationRepositoryImpl.java b/repository/src/main/java/com/mbtips/conversation/repository/impl/ConversationRepositoryImpl.java
@@ -7,6 +7,7 @@
 import com.mbtips.domain.converstation.Conversation;
 import com.mbtips.domain.converstation.exception.ConversationException;
 import com.mbtips.domain.virtualfriend.VirtualFriend;
+import com.mbtips.message.repository.jpa.MessageJpaRepository;
 import com.mbtips.virtualfriend.entity.VirtualFriendEntity;
 import lombok.RequiredArgsConstructor;
 import org.springframework.stereotype.Repository;
@@ -20,6 +21,7 @@
 public class ConversationRepositoryImpl implements ConversationRepository {
 
     private final ConversationJpaRepository conversationJpaRepository;
+    private final MessageJpaRepository messageJpaRepository;
 
 
     @Override
@@ -34,6 +36,7 @@ public Conversation save(Conversation conversation) {
     @Transactional
     public void delete(Conversation conversation) {
         ConversationEntity conversationEntity = new ConversationEntity(conversation);
+        messageJpaRepository.deleteAllByConversationEntity(conversationEntity);
         conversationJpaRepository.delete(conversationEntity);
     }
 
diff --git a/repository/src/main/java/com/mbtips/message/interfaces/MessageRepository.java b/repository/src/main/java/com/mbtips/message/interfaces/MessageRepository.java
@@ -2,6 +2,7 @@
 
 import com.mbtips.domain.message.Message;
 import com.mbtips.domain.message.dto.response.GetMessageResponseDto;
+import com.mbtips.domain.virtualfriend.VirtualFriend;
 
 import java.util.List;
 
@@ -12,4 +13,5 @@ public interface MessageRepository {
     void createMessage(Message message);
 
     List<GetMessageResponseDto> findRecentMessagesByConversationId(Long conversationId);
+
 }
diff --git a/repository/src/main/java/com/mbtips/message/repository/impl/MessageRepositoryImpl.java b/repository/src/main/java/com/mbtips/message/repository/impl/MessageRepositoryImpl.java
@@ -2,6 +2,7 @@
 
 import com.mbtips.domain.message.Message;
 import com.mbtips.domain.message.dto.response.GetMessageResponseDto;
+import com.mbtips.domain.virtualfriend.VirtualFriend;
 import com.mbtips.message.entity.MessageEntity;
 import com.mbtips.message.interfaces.MessageRepository;
 import com.mbtips.message.repository.jpa.MessageJpaRepository;
@@ -52,4 +53,5 @@ public List<GetMessageResponseDto> findRecentMessagesByConversationId(Long conve
     }
 
 
+
 }
diff --git a/repository/src/main/java/com/mbtips/message/repository/jpa/MessageJpaRepository.java b/repository/src/main/java/com/mbtips/message/repository/jpa/MessageJpaRepository.java
@@ -1,7 +1,9 @@
 package com.mbtips.message.repository.jpa;
 
 
+import com.mbtips.conversation.entity.ConversationEntity;
 import com.mbtips.domain.message.dto.response.GetMessageResponseDto;
+import com.mbtips.domain.virtualfriend.VirtualFriend;
 import com.mbtips.message.entity.MessageEntity;
 import org.springframework.data.domain.PageRequest;
 import org.springframework.data.jpa.repository.JpaRepository;
@@ -13,21 +15,24 @@
 @Repository
 public interface MessageJpaRepository extends JpaRepository<MessageEntity, Long> {
 
-    @Query("select new com.mbtips.domain.message.dto.response.GetMessageResponseDto(" +
-                "m.messageId, " +
-                "m.messageContent, " +
-                "m.sentAt, " +
-                "m.user.userId, " +
-                "m.virtualFriendEntity.virtualFriendId) " +
+    @Query("select new com.mbtips.domain.message.dto.response.GetMessageResponseDto( " +
+                "m.messageId , " +
+                "m.messageContent , " +
+                "m.sentAt , " +
+                "m.user.userId , " +
+                "m.virtualFriendEntity.virtualFriendId ) " +
             "from MessageEntity m " +
             "where m.conversationEntity.conversationId = :conversationId " +
-            "ORDER BY m.sentAt asc")
+            "ORDER BY m.sentAt asc ")
     List<GetMessageResponseDto> findByConversationId(Long conversationId);
 
-    @Query("SELECT new com.mbtips.domain.message.dto.response.GetMessageResponseDto(" +
+    @Query("SELECT new com.mbtips.domain.message.dto.response.GetMessageResponseDto( " +
             "m.messageId, m.messageContent, m.sentAt, m.user.userId, m.virtualFriendEntity.virtualFriendId) " +
             "FROM MessageEntity m " +
             "WHERE m.conversationEntity.conversationId = :conversationId " +
             "ORDER BY m.sentAt DESC")
     List<GetMessageResponseDto> findRecentMessagesByConversationId(Long conversationId, PageRequest of);
+
+
+    void deleteAllByConversationEntity(ConversationEntity conversationEntity);
 }
diff --git a/repository/src/main/java/com/mbtips/virtualfriend/interfaces/VirtualFriendRepository.java b/repository/src/main/java/com/mbtips/virtualfriend/interfaces/VirtualFriendRepository.java
@@ -15,4 +15,6 @@ public interface VirtualFriendRepository {
     List<Object[]> findVirtualFriendAndConversation(String userId);
 
     VirtualFriend update(Long virtualFriendId, VirtualFriend virtualFriend);
+
+    List<Long> findVirtualFriendIds(String userId);
 }
diff --git a/repository/src/main/java/com/mbtips/virtualfriend/repository/impl/VirtualFriendRepositoryImpl.java b/repository/src/main/java/com/mbtips/virtualfriend/repository/impl/VirtualFriendRepositoryImpl.java
@@ -8,12 +8,14 @@
 import com.mbtips.virtualfriend.interfaces.VirtualFriendRepository;
 import com.mbtips.virtualfriend.repository.jpa.VirtualFriendJpaRepository;
 import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Repository;
 
 import java.util.List;
 
 @Repository
 @RequiredArgsConstructor
+@Slf4j
 public class VirtualFriendRepositoryImpl implements VirtualFriendRepository {
 
     private final VirtualFriendJpaRepository virtualFriendJpaRepository;
@@ -59,5 +61,12 @@ public VirtualFriend update(Long virtualFriendId, VirtualFriend virtualFriend) {
         return updateEntity.toDomain();
     }
 
+    @Override
+    public List<Long> findVirtualFriendIds(String userId) {
+        List<Long> result = virtualFriendJpaRepository.findIdsByUserId(userId);
+
+        return result;
+    }
+
 
 }
diff --git a/repository/src/main/java/com/mbtips/virtualfriend/repository/jpa/VirtualFriendJpaRepository.java b/repository/src/main/java/com/mbtips/virtualfriend/repository/jpa/VirtualFriendJpaRepository.java
@@ -16,4 +16,8 @@ public interface VirtualFriendJpaRepository extends JpaRepository<VirtualFriendE
             "WHERE v.user.userId = :userId")
     List<Object[]> findVirtualFriendAndConversation(String userId);
 
+    @Query("SELECT v.virtualFriendId " +
+            "FROM VirtualFriendEntity v " +
+            "WHERE v.user.userId = :userId")
+    List<Long> findIdsByUserId(String userId);
 }

Original file line number	Diff line number	Diff line change
`@@ -49,7 +49,7 @@ public ApiResponse<VirtualFriendResponse> createVirtualFriend(@Valid @RequestBod`
`49`	`49`	`@DeleteMapping("/{friendId}")`
`50`	`50`	`@Operation(summary = "가상친구 삭제", description = "가상친구가 삭제되며, 채팅방이 삭제됩니다.")`
`51`	`51`	`public ApiResponse<Void> deleteVirtualFriend(@PathVariable Long friendId, @LoginUser User user){`
`52`		`- virtualFriendService.deleteVirtualFriend(friendId, user);`
	`52`	`+ virtualFriendService.deleteVirtualFriend(friendId);`
`53`	`53`	`return ApiResponse.success();`
`54`	`54`	`}`
`55`	`55`
Original file line number	Diff line number	Diff line change
`@@ -2,6 +2,7 @@`
`2`	`2`
`3`	`3`	`import com.mbtips.domain.message.Message;`
`4`	`4`	`import com.mbtips.domain.message.dto.response.GetMessageResponseDto;`
	`5`	`+import com.mbtips.domain.virtualfriend.VirtualFriend;`
`5`	`6`
`6`	`7`	`import java.util.List;`
`7`	`8`
`@@ -12,4 +13,5 @@ public interface MessageRepository {`
`12`	`13`	`void createMessage(Message message);`
`13`	`14`
`14`	`15`	`List<GetMessageResponseDto> findRecentMessagesByConversationId(Long conversationId);`
	`16`	`+`
`15`	`17`	`}`
Original file line number	Diff line number	Diff line change
`@@ -15,4 +15,6 @@ public interface VirtualFriendRepository {`
`15`	`15`	`List<Object[]> findVirtualFriendAndConversation(String userId);`
`16`	`16`
`17`	`17`	`VirtualFriend update(Long virtualFriendId, VirtualFriend virtualFriend);`
	`18`	`+`
	`19`	`+ List<Long> findVirtualFriendIds(String userId);`
`18`	`20`	`}`