Fix: 회원탈퇴 Hard Delete & 슬랙 알림 발송

src/main/java/in/koreatech/koin/domain/owner/repository/OwnerAttachmentRepository.java

@@ -9,4 +9,6 @@ public interface OwnerAttachmentRepository extends Repository<OwnerAttachment, L
     OwnerAttachment save(OwnerAttachment ownerAttachment);
 
     OwnerAttachment findById(Long id);
+
+    void deleteByOwnerId(Long ownerId);
 }

src/main/java/in/koreatech/koin/domain/owner/repository/OwnerRepository.java

@@ -18,4 +18,6 @@ default Owner getById(Long ownerId) {
     Owner save(Owner owner);
 
     Optional<Owner> findByCompanyRegistrationNumber(String companyRegistrationNumber);
+
+    void deleteByUserId(Long userId);
 }

src/main/java/in/koreatech/koin/domain/user/model/User.java

@@ -32,7 +32,6 @@
 @Entity
 @Table(name = "users")
 @Where(clause = "is_deleted=0")
-@SQLDelete(sql = "UPDATE users SET is_deleted = true WHERE id = ?")
 @NoArgsConstructor(access = PROTECTED)
 public class User extends BaseEntity {
 

src/main/java/in/koreatech/koin/domain/user/model/UserDeleteEvent.java

@@ -0,0 +1,7 @@
+package in.koreatech.koin.domain.user.model;
+
+public record UserDeleteEvent(
+    String email
+) {
+
+}

src/main/java/in/koreatech/koin/domain/user/model/UserEventListener.java

@@ -0,0 +1,27 @@
+package in.koreatech.koin.domain.user.model;
+
+import static org.springframework.transaction.event.TransactionPhase.AFTER_COMMIT;
+
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+import org.springframework.transaction.event.TransactionalEventListener;
+
+import in.koreatech.koin.global.domain.slack.SlackClient;
+import in.koreatech.koin.global.domain.slack.model.SlackNotificationFactory;
+import lombok.RequiredArgsConstructor;
+
+@Component
+@RequiredArgsConstructor
+@Transactional(propagation = Propagation.REQUIRES_NEW)
+public class UserEventListener {
+
+    private final SlackClient slackClient;
+    private final SlackNotificationFactory slackNotificationFactory;
+
+    @TransactionalEventListener(phase = AFTER_COMMIT)
+    public void onUserDeleteEvent(UserDeleteEvent event) {
+        var notification = slackNotificationFactory.generateUserDeleteNotification(event.email());
+        slackClient.sendMessage(notification);
+    }
+}

src/main/java/in/koreatech/koin/domain/user/repository/StudentRepository.java

@@ -17,4 +17,6 @@ default Student getById(Long userId) {
         return findById(userId)
             .orElseThrow(() -> UserNotFoundException.withDetail("userId: " + userId));
     }
+
+    void deleteByUserId(Long userId);
 }

src/main/java/in/koreatech/koin/domain/user/service/UserService.java

@@ -4,10 +4,13 @@
 import java.util.Objects;
 import java.util.UUID;
 
+import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.security.crypto.password.PasswordEncoder;
 import org.springframework.stereotype.Service;
 import org.springframework.transaction.annotation.Transactional;
 
+import in.koreatech.koin.domain.owner.repository.OwnerAttachmentRepository;
+import in.koreatech.koin.domain.owner.repository.OwnerRepository;
 import in.koreatech.koin.domain.user.dto.AuthResponse;
 import in.koreatech.koin.domain.user.dto.EmailCheckExistsRequest;
 import in.koreatech.koin.domain.user.dto.NicknameCheckExistsRequest;
@@ -16,7 +19,9 @@
 import in.koreatech.koin.domain.user.dto.UserTokenRefreshRequest;
 import in.koreatech.koin.domain.user.dto.UserTokenRefreshResponse;
 import in.koreatech.koin.domain.user.model.User;
+import in.koreatech.koin.domain.user.model.UserDeleteEvent;
 import in.koreatech.koin.domain.user.model.UserToken;
+import in.koreatech.koin.domain.user.repository.StudentRepository;
 import in.koreatech.koin.domain.user.repository.UserRepository;
 import in.koreatech.koin.domain.user.repository.UserTokenRepository;
 import in.koreatech.koin.global.auth.JwtProvider;
@@ -31,8 +36,12 @@ public class UserService {
 
     private final JwtProvider jwtProvider;
     private final UserRepository userRepository;
+    private final StudentRepository studentRepository;
+    private final OwnerRepository ownerRepository;
+    private final OwnerAttachmentRepository ownerAttachmentRepository;
     private final PasswordEncoder passwordEncoder;
     private final UserTokenRepository userTokenRepository;
+    private final ApplicationEventPublisher eventPublisher;
 
     @Transactional
     public UserLoginResponse login(UserLoginRequest request) {
@@ -80,6 +89,16 @@ private String getUserId(String refreshToken) {
     public void withdraw(Long userId) {
         User user = userRepository.getById(userId);
         userRepository.delete(user);
+
+        switch (user.getUserType()) {
+            case STUDENT:
+                studentRepository.deleteByUserId(userId);
+            case OWNER:
+                ownerRepository.deleteByUserId(userId);
+                ownerAttachmentRepository.deleteByOwnerId(userId);
+        }
+
+        eventPublisher.publishEvent(new UserDeleteEvent(user.getEmail()));
     }
 
     public void checkExistsEmail(EmailCheckExistsRequest request) {

src/main/java/in/koreatech/koin/global/domain/slack/model/SlackNotificationFactory.java

@@ -106,4 +106,19 @@ public SlackNotification generateStudentRegisterCompleteNotification(
             )
             .build();
     }
+
+    /**
+     * 유저 탈퇴 알림
+     */
+    public SlackNotification generateUserDeleteNotification(
+        String email
+    ) {
+        return SlackNotification.builder()
+            .slackUrl(eventNotificationUrl)
+            .text(String.format("""
+                `%s님이 탈퇴하셨습니다.`
+                """, email)
+            )
+            .build();
+    }
 }