Feat/#139 광고 플랫폼 연동 해제 API 추가

src/main/java/com/whereyouad/WhereYouAd/domains/advertisement/persistence/repository/AdCampaignRepository.java

@@ -69,4 +69,15 @@ Long sumBudgetsByUserIdAndOrgIdAndProvider(@Param("userId") Long userId, @Param(
     Optional<AdCampaign> findByExternalCampaignIdAndPlatformAccount(String externalCampaignId, PlatformAccount platformAccount);
 
     Optional<AdCampaign> findByPlatformAccountAndExternalCampaignId(PlatformAccount platformAccount, String externalCampaignId);
+
+    // PlatformAccount 연동 해제 시 사용
+    List<AdCampaign> findByPlatformAccount(PlatformAccount platformAccount);
+
+    // 연동 해제 후 빈 Project 정리 대상 식별용 (project null 인 AdCampaign 은 제외)
+    @Query("SELECT DISTINCT c.project.id FROM AdCampaign c " +
+            "WHERE c.platformAccount.id = :platformAccountId AND c.project IS NOT NULL")
+    List<Long> findDistinctProjectIdsByPlatformAccountId(@Param("platformAccountId") Long platformAccountId);
+
+    // 특정 Project 에 남아있는 AdCampaign 수 (빈 Project 판단용)
+    long countByProject_Id(Long projectId);
 }

src/main/java/com/whereyouad/WhereYouAd/domains/advertisement/persistence/repository/MetricFactRepository.java

@@ -10,6 +10,7 @@
 import com.whereyouad.WhereYouAd.domains.advertisement.persistence.repository.projection.RoasProjection;
 import com.whereyouad.WhereYouAd.domains.project.application.dto.ProjectQueryDto;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
 import org.springframework.data.jpa.repository.Query;
 import org.springframework.data.repository.query.Param;
 
@@ -227,4 +228,15 @@ Optional<MetricFact> findByAdContentAndTimeBucketAndGrain(
     );
 
     Optional<MetricFact> findByPlatformAccount_IdAndAdContent_IdAndTimeBucket(Long platformAccountId, Long adContentId, LocalDateTime timeBucket);
+
+    // PlatformAccount 연동 해제 시 청크 단위 정리용
+    @Modifying
+    @Query(value = "DELETE FROM metric_fact " +
+            "WHERE platform_account_id = :platformAccountId " +
+            "LIMIT :batchSize",
+            nativeQuery = true)
+    int deleteByPlatformAccountIdInBatch(
+            @Param("platformAccountId") Long platformAccountId,
+            @Param("batchSize") int batchSize
+    );
 }

src/main/java/com/whereyouad/WhereYouAd/domains/click/persistence/repository/ClickLogRepository.java

@@ -2,6 +2,26 @@
 
 import com.whereyouad.WhereYouAd.domains.click.persistence.entity.ClickLog;
 import org.springframework.data.jpa.repository.JpaRepository;
+import org.springframework.data.jpa.repository.Modifying;
+import org.springframework.data.jpa.repository.Query;
+import org.springframework.data.repository.query.Param;
 
 public interface ClickLogRepository extends JpaRepository<ClickLog, Long> {
-}
+
+    // PlatformAccount 연동 해제 시 청크 단위 정리용
+    // ad_content_id → ad_group_id → ad_campaign_id → platform_account_id 경유
+    @Modifying
+    @Query(value = "DELETE FROM click_log " +
+            "WHERE ad_content_id IN (" +
+            "  SELECT ac.ad_content_id FROM ad_content ac " +
+            "  JOIN ad_group ag ON ac.ad_group_id = ag.ad_group_id " +
+            "  JOIN ad_campaign camp ON ag.ad_campaign_id = camp.ad_campaign_id " +
+            "  WHERE camp.platform_account_id = :platformAccountId" +
+            ") " +
+            "LIMIT :batchSize",
+            nativeQuery = true)
+    int deleteByPlatformAccountIdInBatch(
+            @Param("platformAccountId") Long platformAccountId,
+            @Param("batchSize") int batchSize
+    );
+}

src/main/java/com/whereyouad/WhereYouAd/domains/platform/domain/service/PlatformDataCleanupExecutor.java

@@ -0,0 +1,121 @@
+package com.whereyouad.WhereYouAd.domains.platform.domain.service;
+
+import com.whereyouad.WhereYouAd.domains.advertisement.persistence.entity.AdCampaign;
+import com.whereyouad.WhereYouAd.domains.advertisement.persistence.repository.AdCampaignRepository;
+import com.whereyouad.WhereYouAd.domains.advertisement.persistence.repository.MetricFactRepository;
+import com.whereyouad.WhereYouAd.domains.click.persistence.repository.ClickLogRepository;
+import com.whereyouad.WhereYouAd.domains.organization.domain.constant.OrgRole;
+import com.whereyouad.WhereYouAd.domains.organization.persistence.entity.OrgMember;
+import com.whereyouad.WhereYouAd.domains.organization.persistence.repository.OrgMemberRepository;
+import com.whereyouad.WhereYouAd.domains.platform.exception.PlatformHandler;
+import com.whereyouad.WhereYouAd.domains.platform.exception.code.PlatformErrorCode;
+import com.whereyouad.WhereYouAd.domains.platform.persistence.entity.PlatformAccount;
+import com.whereyouad.WhereYouAd.domains.platform.persistence.entity.PlatformConnection;
+import com.whereyouad.WhereYouAd.domains.platform.persistence.repository.PlatformAccountRepository;
+import com.whereyouad.WhereYouAd.domains.platform.persistence.repository.PlatformConnectionRepository;
+import com.whereyouad.WhereYouAd.domains.project.persistence.repository.ProjectRepository;
+import com.whereyouad.WhereYouAd.domains.user.exception.code.UserErrorCode;
+import com.whereyouad.WhereYouAd.domains.user.exception.handler.UserHandler;
+import com.whereyouad.WhereYouAd.domains.user.persistence.repository.UserRepository;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+import org.springframework.transaction.annotation.Propagation;
+import org.springframework.transaction.annotation.Transactional;
+
+import java.util.List;
+
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class PlatformDataCleanupExecutor {
+
+    private static final int BATCH_SIZE = 1000;
+
+    private final UserRepository userRepository;
+    private final OrgMemberRepository orgMemberRepository;
+    private final PlatformAccountRepository platformAccountRepository;
+    private final PlatformConnectionRepository platformConnectionRepository;
+    private final AdCampaignRepository adCampaignRepository;
+    private final ProjectRepository projectRepository;
+    private final ClickLogRepository clickLogRepository;
+    private final MetricFactRepository metricFactRepository;
+
+    // 권한 & 소유자 검증 + 삭제에 영향받는 projectId 반환 (read-only & 짧은 트랜잭션)
+    @Transactional(readOnly = true)
+    public List<Long> verifyAndCollectProjectIds(Long userId, Long orgId, Long accountId) {
+        userRepository.findById(userId)
+                .orElseThrow(() -> new UserHandler(UserErrorCode.USER_NOT_FOUND));
+
+        OrgMember orgMember = orgMemberRepository.findByUserIdAndOrgId(userId, orgId)
+                .orElseThrow(() -> new PlatformHandler(PlatformErrorCode.PLATFORM_ORG_MEMBER_NOT_FOUND));
+
+        if (orgMember.getRole() != OrgRole.ADMIN) {
+            throw new PlatformHandler(PlatformErrorCode.PLATFORM_FORBIDDEN);
+        }
+
+        PlatformAccount platformAccount = platformAccountRepository.findById(accountId)
+                .orElseThrow(() -> new PlatformHandler(PlatformErrorCode.PLATFORM_ACCOUNT_NOT_FOUND));
+
+        if (!platformAccount.getOrganization().getId().equals(orgId)) {
+            throw new PlatformHandler(PlatformErrorCode.PLATFORM_ACCOUNT_NOT_BELONG_TO_ORG);
+        }
+
+        platformConnectionRepository.findByUserIdAndPlatformAccountId(userId, accountId)
+                .orElseThrow(() -> new PlatformHandler(PlatformErrorCode.PLATFORM_NOT_ACCOUNT_OWNER));
+
+        return adCampaignRepository.findDistinctProjectIdsByPlatformAccountId(accountId);
+    }
+
+    // 청크 단위로 ClickLog 삭제 — 메인 트랜잭션과 분리
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    public int deleteClickLogChunk(Long platformAccountId) {
+        int deleted = clickLogRepository.deleteByPlatformAccountIdInBatch(platformAccountId, BATCH_SIZE);
+        if (deleted > 0) {
+            log.debug("ClickLog 청크 삭제 - platformAccountId={}, deleted={}", platformAccountId, deleted);
+        }
+        return deleted;
+    }
+
+    // 청크 단위로 MetricFact 삭제
+    @Transactional(propagation = Propagation.REQUIRES_NEW)
+    public int deleteMetricFactChunk(Long platformAccountId) {
+        int deleted = metricFactRepository.deleteByPlatformAccountIdInBatch(platformAccountId, BATCH_SIZE);
+        if (deleted > 0) {
+            log.debug("MetricFact 청크 삭제 - platformAccountId={}, deleted={}", platformAccountId, deleted);
+        }
+        return deleted;
+    }
+
+    // AdCampaign + PlatformConnection + PlatformAccount 원자적 삭제
+    @Transactional
+    public void deleteAccountAndRelations(Long accountId) {
+        PlatformAccount platformAccount = platformAccountRepository.findById(accountId)
+                .orElseThrow(() -> new PlatformHandler(PlatformErrorCode.PLATFORM_ACCOUNT_NOT_FOUND));
+
+        List<AdCampaign> campaigns = adCampaignRepository.findByPlatformAccount(platformAccount);
+
+        if (!campaigns.isEmpty()) {
+            adCampaignRepository.deleteAll(campaigns);
+            adCampaignRepository.flush();
+            //AdCampaign 삭제 시 CascadeType.ALL 로 인해 연관된 AdGroup, AdContent 도 함꼐 제거됨
+        }
+
+        List<PlatformConnection> connections = platformConnectionRepository.findAllByPlatformAccount_Id(accountId);
+
+        if (!connections.isEmpty()) {
+            platformConnectionRepository.deleteAll(connections);
+            platformConnectionRepository.flush();
+        }
+
+        platformAccountRepository.delete(platformAccount);
+    }
+
+    //빈 Project 1개 삭제
+    @Transactional
+    public void deleteEmptyProject(Long projectId) {
+        if (adCampaignRepository.countByProject_Id(projectId) == 0) {
+            projectRepository.deleteById(projectId);
+        }
+    }
+}

src/main/java/com/whereyouad/WhereYouAd/domains/platform/domain/service/PlatformService.java

@@ -11,5 +11,4 @@ public interface PlatformService {
     PlatformResponse.PlatformAccount updateNaverAdAccount(Long userId, Long orgId, PlatformRequest.PlatformAccount request);
 
     void disconnectPlatform(Long userId, Long orgId, Long accountId);
-
 }

src/main/java/com/whereyouad/WhereYouAd/domains/platform/domain/service/PlatformServiceImpl.java

@@ -27,6 +27,7 @@
 import lombok.RequiredArgsConstructor;
 import lombok.extern.slf4j.Slf4j;
 import org.springframework.stereotype.Service;
+import org.springframework.transaction.annotation.Propagation;
 import org.springframework.transaction.annotation.Transactional;
 
 import java.util.List;
@@ -42,6 +43,7 @@ public class PlatformServiceImpl implements PlatformService {
     private final OrgMemberRepository orgMemberRepository;
     private final PlatformAccountRepository platformAccountRepository;
     private final PlatformConnectionRepository platformConnectionRepository;
+    private final PlatformDataCleanupExecutor platformDataCleanupExecutor;
     private final NaverClient naverClient;
     private final NaverAdAuthStrategy naverAdAuthStrategy;
 
@@ -144,10 +146,40 @@ public PlatformResponse.PlatformAccount updateNaverAdAccount(Long userId, Long o
         return PlatformConverter.toPlatformAccountResponse(platformAccount);
     }
 
+    // 광고 플랫폼 연동 해제
+    // 대규모 엔티티 삭제를 위해 별도 처리 클래스 (PlatformDataCleanupExecutor) 에서 Chunk 단위 삭제 처리
     @Override
+    @Transactional(propagation = Propagation.NOT_SUPPORTED)
     public void disconnectPlatform(Long userId, Long orgId, Long accountId) {
-        // TODO: 관련된 PlatformConnection, PlatformAccount, 광고 도메인 엔티티 제거 로직 개발
-        return;
+        // 권한 검증 & 영향받는 projectId 수집 (짧은 read-only 트랜잭션)
+        List<Long> projectIds = platformDataCleanupExecutor.verifyAndCollectProjectIds(userId, orgId, accountId);
+
+        int chunkDeleted; // 하나의 청크 당 삭제 갯수
+        long totalClickLogDeleted = 0L; // ClickLog 전체 삭제 갯수
+        long totalMetricFactDeleted = 0L; // MetricFact 전체 삭제 갯수
+
+        // ClickLog 청크 정리 (REQUIRES_NEW)
+        do {
+            chunkDeleted = platformDataCleanupExecutor.deleteClickLogChunk(accountId);
+            totalClickLogDeleted += chunkDeleted;
+        } while (chunkDeleted > 0);
+        log.info("ClickLog 삭제 완료 - platformAccountId={}, totalCount={}", accountId, totalClickLogDeleted);
+
+        // MetricFact 청크 정리 (REQUIRES_NEW) — Project 삭제 단계에서 FK 위반 방지
+        do {
+            chunkDeleted = platformDataCleanupExecutor.deleteMetricFactChunk(accountId);
+            totalMetricFactDeleted += chunkDeleted;
+        } while (chunkDeleted > 0);
+        log.info("MetricFact 삭제 완료 - platformAccountId={}, totalCount={}", accountId, totalMetricFactDeleted);
+
+        // AdCampaign + PlatformConnection + PlatformAccount 삭제 진행
+        platformDataCleanupExecutor.deleteAccountAndRelations(accountId);
+
+        // 비어있는 Project 엔티티 삭제
+        // -> AdCampaign, AdGroup, AdContent 삭제로 인해 연관된 광고 객체가 없는 Project 엔티티 삭제
+        for (Long projectId : projectIds) {
+            platformDataCleanupExecutor.deleteEmptyProject(projectId);
+        }
     }
 
     private void validateNaverCredentials(String customerId, String encryptedApiKey, String encryptedSecretKey) {

src/main/java/com/whereyouad/WhereYouAd/domains/platform/exception/code/PlatformErrorCode.java

@@ -14,6 +14,8 @@ public enum PlatformErrorCode implements BaseErrorCode {
 
     // 403
     PLATFORM_FORBIDDEN(HttpStatus.FORBIDDEN, "PLATFORM_403_1", "API키 등록은 ADMIN 권한이 필요합니다."),
+    PLATFORM_ACCOUNT_NOT_BELONG_TO_ORG(HttpStatus.FORBIDDEN, "PLATFORM_403_2", "해당 광고 계정은 요청한 조직 소속이 아닙니다."),
+    PLATFORM_NOT_ACCOUNT_OWNER(HttpStatus.FORBIDDEN, "PLATFORM_403_3", "본인이 등록한 광고 계정만 연동 해제할 수 있습니다."),
 
     // 404
     PLATFORM_CONNECTION_NOT_FOUND(HttpStatus.NOT_FOUND, "PLATFORM_404_1", "조직과 연결된 인증 정보를 찾을 수 없습니다."),

src/main/java/com/whereyouad/WhereYouAd/domains/platform/persistence/repository/PlatformConnectionRepository.java

@@ -43,4 +43,7 @@ public interface PlatformConnectionRepository extends JpaRepository<PlatformConn
             "JOIN FETCH c.platformAccount pa " +
             "WHERE c.user.id = :userId AND pa.organization.id = :orgId")
     List<PlatformConnection> findByUserIdAndOrgId(@Param("userId") Long userId, @Param("orgId") Long orgId);
+
+    // PlatformAccount 연동 해제 시 해당 계정에 연결된 모든 connection 일괄 삭제를 위한 List 조회
+    List<PlatformConnection> findAllByPlatformAccount_Id(Long platformAccountId);
 }

src/main/java/com/whereyouad/WhereYouAd/domains/platform/presentation/PlatformController.java

@@ -5,7 +5,6 @@
 import com.whereyouad.WhereYouAd.domains.platform.domain.service.PlatformService;
 import com.whereyouad.WhereYouAd.domains.platform.presentation.docs.PlatformControllerDocs;
 import com.whereyouad.WhereYouAd.global.response.DataResponse;
-import io.swagger.v3.oas.annotations.Hidden;
 import jakarta.validation.Valid;
 import lombok.RequiredArgsConstructor;
 import org.springframework.http.HttpStatus;
@@ -61,8 +60,6 @@ public ResponseEntity<DataResponse<PlatformResponse.PlatformAccount>> updateNave
         );
     }
 
-
-    @Hidden
     @DeleteMapping("/{orgId}/accounts/{accountId}")
     public ResponseEntity<DataResponse<String>> disconnectPlatform(
             @AuthenticationPrincipal(expression = "userId") Long userId,

src/main/java/com/whereyouad/WhereYouAd/domains/platform/presentation/docs/PlatformControllerDocs.java

@@ -66,4 +66,25 @@ ResponseEntity<DataResponse<PlatformResponse.PlatformAccount>> updateNaverAdAcco
             @PathVariable Long orgId,
             @RequestBody PlatformRequest.PlatformAccount request
     );
+
+    @Operation(
+            summary = "광고 플랫폼 계정 연동 해제 API",
+            description = "본인이 등록한 광고 플랫폼 계정의 연동을 해제하고, 해당 계정에 종속된 모든 광고 데이터를 정리합니다. \n\n" +
+                    "**주의** : 삭제한 플랫폼 계정에 관련된 모든 광고 데이터가 삭제되며, 복구 불가합니다. 사용자에게 안내 필요\n\n" +
+                    "ADMIN 권한을 가진 조직 멤버 중 본인이 직접 등록한(광고 플랫폼 연동을 진행한 회원 본인만) 계정만 해제할 수 있습니다."
+    )
+    @ApiResponses({
+            @ApiResponse(responseCode = "200", description = "연동 해제 및 관련 광고 데이터 정리 성공"),
+            @ApiResponse(responseCode = "403_1", description = "PLATFORM_403_1 - ADMIN 권한 없음"),
+            @ApiResponse(responseCode = "403_2", description = "PLATFORM_403_2 - 해당 광고 계정이 요청한 조직 소속이 아님"),
+            @ApiResponse(responseCode = "403_3", description = "PLATFORM_403_3 - 본인이 등록한 광고 계정이 아님"),
+            @ApiResponse(responseCode = "404_1", description = "USER_404_1 - 회원 정보를 찾을 수 없음"),
+            @ApiResponse(responseCode = "404_2", description = "PLATFORM_404_2 - 해당 조직의 멤버가 아님"),
+            @ApiResponse(responseCode = "404_3", description = "PLATFORM_404_3 - 해당 광고 계정을 찾을 수 없음")
+    })
+    ResponseEntity<DataResponse<String>> disconnectPlatform(
+            @AuthenticationPrincipal(expression = "userId") Long userId,
+            @PathVariable(value = "orgId") Long orgId,
+            @PathVariable(value = "accountId") Long accountId
+    );
 }