[WTH-415] 파일 삭제 구현

src/main/kotlin/com/weeth/domain/account/application/usecase/command/ManageAccountTransactionUseCase.kt

@@ -161,11 +161,7 @@ class ManageAccountTransactionUseCase(
     }
 
     private fun deleteTransactionReceipts(transactionId: Long) {
-        val receipts = findTransactionReceipts(transactionId)
-        if (receipts.isNotEmpty()) {
-            fileRepository.deleteAll(receipts)
-            fileRepository.flush()
-        }
+        fileRepository.hardDeleteActiveByOwnerTypeAndOwnerId(FileOwnerType.ACCOUNT_TRANSACTION, transactionId)
     }
 
     private fun findTransactionReceipts(transactionId: Long): List<File> =

src/main/kotlin/com/weeth/domain/board/application/usecase/command/ManagePostUseCase.kt

@@ -18,7 +18,6 @@ import com.weeth.domain.club.domain.service.ClubMemberPolicy
 import com.weeth.domain.file.application.dto.request.FileSaveRequest
 import com.weeth.domain.file.application.mapper.FileMapper
 import com.weeth.domain.file.domain.enums.FileOwnerType
-import com.weeth.domain.file.domain.repository.FileReader
 import com.weeth.domain.file.domain.repository.FileRepository
 import org.springframework.stereotype.Service
 import org.springframework.transaction.annotation.Transactional
@@ -30,7 +29,6 @@ class ManagePostUseCase(
     private val clubMemberPolicy: ClubMemberPolicy,
     private val clubMemberCardinalReader: ClubMemberCardinalReader,
     private val fileRepository: FileRepository,
-    private val fileReader: FileReader,
     private val fileMapper: FileMapper,
     private val postMapper: PostMapper,
 ) {
@@ -111,8 +109,7 @@ class ManagePostUseCase(
         clubId: Long,
     ): Board = boardRepository.findByIdAndClubIdAndIsDeletedFalse(boardId, clubId) ?: throw BoardNotFoundException()
 
-    private fun findPost(postId: Long): Post =
-        postRepository.findActivePostById(postId) ?: throw PostNotFoundException()
+    private fun findPost(postId: Long): Post = postRepository.findByIdWithLock(postId) ?: throw PostNotFoundException()
 
     private fun validateOwner(
         post: Post,
@@ -154,11 +151,6 @@ class ManagePostUseCase(
     }
 
     private fun deletePostFiles(postId: Long) {
-        val files = fileReader.findAll(FileOwnerType.POST, postId)
-
-        if (files.isNotEmpty()) {
-            fileRepository.deleteAll(files)
-            fileRepository.flush()
-        }
+        fileRepository.hardDeleteActiveByOwnerTypeAndOwnerId(FileOwnerType.POST, postId)
     }
 }

src/main/kotlin/com/weeth/domain/board/domain/repository/PostLikeRepository.kt

@@ -37,6 +37,24 @@ interface PostLikeRepository :
         @Param("clubId") clubId: Long,
     ): List<Long>
 
+    @Query(
+        """
+        SELECT p.id
+        FROM PostLike pl
+        JOIN pl.post p
+        JOIN p.board b
+        WHERE pl.userId = :userId
+          AND b.club.id IN :clubIds
+          AND pl.isActive = true
+          AND pl.deletedAt IS NULL
+        ORDER BY p.id ASC
+        """,
+    )
+    fun findActivePostIdsByUserIdAndClubIdIn(
+        @Param("userId") userId: Long,
+        @Param("clubIds") clubIds: List<Long>,
+    ): List<Long>
+
     @Query(
         """
         SELECT pl

src/main/kotlin/com/weeth/domain/board/domain/repository/PostRepository.kt

@@ -217,4 +217,18 @@ interface PostRepository :
     fun countActivePostsByBoardIds(
         @Param("boardIds") boardIds: List<Long>,
     ): List<BoardPostCount>
+
+    @Query(
+        """
+        SELECT p.id
+        FROM Post p
+        WHERE p.clubMember.id IN :clubMemberIds
+          AND p.isDeleted = false
+          AND p.board.isDeleted = false
+        ORDER BY p.id ASC
+        """,
+    )
+    fun findActiveIdsByClubMemberIdIn(
+        @Param("clubMemberIds") clubMemberIds: List<Long>,
+    ): List<Long>
 }

src/main/kotlin/com/weeth/domain/club/application/usecase/command/ManageClubMemberUsecase.kt

@@ -22,8 +22,6 @@ import com.weeth.domain.club.domain.service.ClubJoinPolicy
 import com.weeth.domain.club.domain.service.ClubMemberPolicy
 import com.weeth.domain.file.domain.entity.File
 import com.weeth.domain.file.domain.enums.FileOwnerType
-import com.weeth.domain.file.domain.enums.FileStatus
-import com.weeth.domain.file.domain.port.FileAccessUrlPort
 import com.weeth.domain.file.domain.repository.FileRepository
 import com.weeth.domain.user.application.exception.UserInActiveException
 import com.weeth.domain.user.domain.repository.UserReader
@@ -47,7 +45,6 @@ class ManageClubMemberUsecase(
     private val clubJoinPolicy: ClubJoinPolicy,
     private val clubActivityDeletionPolicy: ClubActivityDeletionPolicy,
     private val fileRepository: FileRepository,
-    private val fileAccessUrlPort: FileAccessUrlPort,
     private val clock: Clock,
 ) {
     /**
@@ -92,19 +89,11 @@ class ManageClubMemberUsecase(
         userId: Long,
         request: UpdateMemberProfileRequest,
     ) {
-        val members = clubMemberRepository.findActiveByUserId(userId)
+        val members = clubMemberRepository.findAllActiveByUserIdWithLock(userId)
         if (members.isEmpty()) throw ClubMemberNotFoundException()
 
         request.profileImage?.let { profileImage ->
-            val existingFiles =
-                fileRepository.findAllByOwnerTypeAndOwnerIdAndStatus(
-                    FileOwnerType.CLUB_MEMBER_PROFILE,
-                    userId,
-                    FileStatus.UPLOADED,
-                )
-            if (existingFiles.isNotEmpty()) {
-                fileRepository.deleteAll(existingFiles)
-            }
+            markFilesDeleted(userId)
 
             val file =
                 File.createUploaded(
@@ -125,18 +114,10 @@ class ManageClubMemberUsecase(
 
     @Transactional
     fun deleteProfileImage(userId: Long) {
-        val members = clubMemberRepository.findActiveByUserId(userId)
+        val members = clubMemberRepository.findAllActiveByUserIdWithLock(userId)
         if (members.isEmpty()) throw ClubMemberNotFoundException()
 
-        val existingFiles =
-            fileRepository.findAllByOwnerTypeAndOwnerIdAndStatus(
-                FileOwnerType.CLUB_MEMBER_PROFILE,
-                userId,
-                FileStatus.UPLOADED,
-            )
-        if (existingFiles.isNotEmpty()) {
-            fileRepository.deleteAll(existingFiles)
-        }
+        markFilesDeleted(userId)
 
         members.forEach { it.removeProfileImage() }
     }
@@ -186,4 +167,8 @@ class ManageClubMemberUsecase(
         clubActivityDeletionPolicy.markMemberActivitiesDeleted(member, now)
         member.leave(now)
     }
+
+    private fun markFilesDeleted(userId: Long) {
+        fileRepository.hardDeleteActiveByOwnerTypeAndOwnerId(FileOwnerType.CLUB_MEMBER_PROFILE, userId)
+    }
 }

src/main/kotlin/com/weeth/domain/club/application/usecase/command/ManageClubUseCase.kt

@@ -28,7 +28,6 @@ import com.weeth.domain.club.domain.vo.ClubContact
 import com.weeth.domain.file.application.dto.request.FileSaveRequest
 import com.weeth.domain.file.domain.entity.File
 import com.weeth.domain.file.domain.enums.FileOwnerType
-import com.weeth.domain.file.domain.enums.FileStatus
 import com.weeth.domain.file.domain.repository.FileRepository
 import com.weeth.domain.user.application.exception.UserInActiveException
 import com.weeth.domain.user.domain.repository.UserReader
@@ -143,7 +142,7 @@ class ManageClubUseCase(
     ) {
         clubPermissionPolicy.requireAdmin(clubId, userId)
 
-        val club = clubRepository.getClubById(clubId)
+        val club = clubRepository.getClubByIdForUpdate(clubId)
 
         if (request.primaryContact == PrimaryContact.EMAIL) {
             val resolvedEmail = request.contactEmail ?: club.clubContact.email
@@ -181,7 +180,7 @@ class ManageClubUseCase(
     ) {
         clubPermissionPolicy.requireAdmin(clubId, userId)
 
-        val club = clubRepository.getClubById(clubId)
+        val club = clubRepository.getClubByIdForUpdate(clubId)
         val newCode = ClubCodePolicy.generateCode()
         club.regenerateCode(newCode)
     }
@@ -193,7 +192,7 @@ class ManageClubUseCase(
     ) {
         clubPermissionPolicy.requireAdmin(clubId, userId)
 
-        val club = clubRepository.getClubById(clubId)
+        val club = clubRepository.getClubByIdForUpdate(clubId)
         deleteExistingFiles(FileOwnerType.CLUB_PROFILE, clubId)
         club.removeProfileImage()
     }
@@ -205,7 +204,7 @@ class ManageClubUseCase(
     ) {
         clubPermissionPolicy.requireAdmin(clubId, userId)
 
-        val club = clubRepository.getClubById(clubId)
+        val club = clubRepository.getClubByIdForUpdate(clubId)
         deleteExistingFiles(FileOwnerType.CLUB_BACKGROUND, clubId)
         club.removeBackgroundImage()
     }
@@ -239,11 +238,7 @@ class ManageClubUseCase(
         ownerType: FileOwnerType,
         ownerId: Long,
     ) {
-        val files = fileRepository.findAllByOwnerTypeAndOwnerIdAndStatus(ownerType, ownerId, FileStatus.UPLOADED)
-
-        if (files.isNotEmpty()) {
-            fileRepository.deleteAll(files)
-        }
+        fileRepository.hardDeleteActiveByOwnerTypeAndOwnerId(ownerType, ownerId)
     }
 
     private fun validatePrimaryContactEmail(

src/main/kotlin/com/weeth/domain/club/domain/service/ClubActivityDeletionPolicy.kt

@@ -3,6 +3,9 @@ package com.weeth.domain.club.domain.service
 import com.weeth.domain.board.domain.repository.PostLikeRepository
 import com.weeth.domain.board.domain.repository.PostRepository
 import com.weeth.domain.club.domain.entity.ClubMember
+import com.weeth.domain.comment.domain.repository.CommentRepository
+import com.weeth.domain.file.domain.enums.FileOwnerType
+import com.weeth.domain.file.domain.repository.FileRepository
 import org.springframework.stereotype.Service
 import java.time.LocalDateTime
 
@@ -19,31 +22,74 @@ import java.time.LocalDateTime
 class ClubActivityDeletionPolicy(
     private val postLikeRepository: PostLikeRepository,
     private val postRepository: PostRepository,
+    private val commentRepository: CommentRepository,
+    private val fileRepository: FileRepository,
 ) {
     fun markMemberActivitiesDeleted(
         member: ClubMember,
         now: LocalDateTime,
     ) {
-        val postIds =
-            postLikeRepository
-                .findActivePostIdsByUserIdAndClubId(
-                    userId = member.user.id,
-                    clubId = member.club.id,
-                ).distinct()
-                .sorted()
-
-        if (postIds.isEmpty()) return
-
-        val postsById = postRepository.findAllByIdsWithLock(postIds).associateBy { it.id }
-        if (postsById.isEmpty()) return
-
-        postLikeRepository
-            .findAllActiveByUserIdAndPostIds(
-                userId = member.user.id,
-                postIds = postsById.keys.toList(),
-            ).forEach { like ->
-                if (!like.markDeleted(now)) return@forEach
-                postsById.getValue(like.post.id).decreaseLikeCount()
+        markMembersActivitiesDeleted(listOf(member), now)
+    }
+
+    fun markMembersActivitiesDeleted(
+        members: List<ClubMember>,
+        now: LocalDateTime,
+    ) {
+        if (members.isEmpty()) return
+
+        deleteMembersFiles(members)
+        markMembersPostLikesDeleted(members, now)
+    }
+
+    private fun deleteMembersFiles(members: List<ClubMember>) {
+        val memberIds = members.map { it.id }.distinct().sorted()
+        val postIds = postRepository.findActiveIdsByClubMemberIdIn(memberIds)
+        val commentIds = commentRepository.findActiveIdsByClubMemberIdIn(memberIds)
+
+        deleteFiles(FileOwnerType.POST, postIds)
+        deleteFiles(FileOwnerType.COMMENT, commentIds)
+    }
+
+    private fun deleteFiles(
+        ownerType: FileOwnerType,
+        ownerIds: List<Long>,
+    ) {
+        if (ownerIds.isEmpty()) return
+
+        fileRepository.hardDeleteActiveByOwnerTypeAndOwnerIdIn(ownerType, ownerIds)
+    }
+
+    private fun markMembersPostLikesDeleted(
+        members: List<ClubMember>,
+        now: LocalDateTime,
+    ) {
+        members
+            .groupBy { it.user.id }
+            .forEach { (userId, userMembers) ->
+                val clubIds = userMembers.map { it.club.id }.distinct().sorted()
+                val postIds =
+                    postLikeRepository
+                        .findActivePostIdsByUserIdAndClubIdIn(
+                            userId = userId,
+                            clubIds = clubIds,
+                        ).distinct()
+                        .sorted()
+
+                if (postIds.isEmpty()) return@forEach
+
+                val postsById = postRepository.findAllByIdsWithLock(postIds).associateBy { it.id }
+
+                val likes =
+                    postLikeRepository.findAllActiveByUserIdAndPostIds(
+                        userId = userId,
+                        postIds = postIds,
+                    )
+
+                for (like in likes) {
+                    if (!like.markDeleted(now)) continue
+                    postsById[like.post.id]?.decreaseLikeCount()
+                }
             }
     }
 }

src/main/kotlin/com/weeth/domain/comment/application/usecase/command/ManageCommentUseCase.kt

@@ -15,7 +15,6 @@ import com.weeth.domain.comment.domain.repository.CommentRepository
 import com.weeth.domain.file.application.dto.request.FileSaveRequest
 import com.weeth.domain.file.application.mapper.FileMapper
 import com.weeth.domain.file.domain.enums.FileOwnerType
-import com.weeth.domain.file.domain.repository.FileReader
 import com.weeth.domain.file.domain.repository.FileRepository
 import org.springframework.stereotype.Service
 import org.springframework.transaction.annotation.Transactional
@@ -25,7 +24,6 @@ class ManageCommentUseCase(
     private val commentRepository: CommentRepository,
     private val postRepository: PostRepository, // 타 도메인 이므로 Reader 사용 검토
     private val clubMemberPolicy: ClubMemberPolicy,
-    private val fileReader: FileReader,
     private val fileRepository: FileRepository,
     private val fileMapper: FileMapper,
 ) : PostCommentUsecase {
@@ -64,7 +62,7 @@ class ManageCommentUseCase(
         commentId: Long,
         userId: Long,
     ) {
-        val comment = commentRepository.findByIdAndPostId(commentId, postId) ?: throw CommentNotFoundException()
+        val comment = findCommentWithLock(commentId, postId)
         ensureOwner(comment, userId)
         ensureNotDeleted(comment)
 
@@ -79,7 +77,7 @@ class ManageCommentUseCase(
         userId: Long,
     ) {
         val post = findPostWithLock(postId)
-        val comment = commentRepository.findByIdAndPostId(commentId, postId) ?: throw CommentNotFoundException()
+        val comment = findCommentWithLock(commentId, postId)
         ensureOwner(comment, userId)
 
         deleteComment(comment)
@@ -137,11 +135,7 @@ class ManageCommentUseCase(
     }
 
     private fun deleteCommentFiles(commentId: Long) {
-        val files = fileReader.findAll(FileOwnerType.COMMENT, commentId)
-
-        if (files.isNotEmpty()) {
-            fileRepository.deleteAll(files)
-        }
+        fileRepository.hardDeleteActiveByOwnerTypeAndOwnerId(FileOwnerType.COMMENT, commentId)
     }
 
     private fun ensureOwner(
@@ -167,4 +161,9 @@ class ManageCommentUseCase(
 
     private fun findPostWithLock(postId: Long): Post =
         postRepository.findByIdWithLock(postId) ?: throw PostNotFoundException()
+
+    private fun findCommentWithLock(
+        commentId: Long,
+        postId: Long,
+    ): Comment = commentRepository.findByIdAndPostIdWithLock(commentId, postId) ?: throw CommentNotFoundException()
 }