fix: 명확하게 비동기를 통해 트랙잭션 처리하도록 수정 (WR9-144) #248

Author: LeeVell

src/main/java/io/crops/warmletter/domain/report/service/ReportService.java

@@ -17,6 +17,7 @@
 import io.crops.warmletter.domain.report.dto.response.ReportsResponse;
 import io.crops.warmletter.domain.report.dto.response.UpdateReportResponse;
 import io.crops.warmletter.domain.report.entity.Report;
+import io.crops.warmletter.domain.report.enums.ReasonType;
 import io.crops.warmletter.domain.report.enums.ReportStatus;
 import io.crops.warmletter.domain.report.enums.ReportType;
 import io.crops.warmletter.domain.report.exception.DuplicateReportException;
@@ -30,20 +31,19 @@
 import io.crops.warmletter.domain.share.repository.ShareProposalRepository;
 import io.crops.warmletter.domain.timeline.dto.request.NotificationRequest;
 import io.crops.warmletter.domain.timeline.enums.AlarmType;
-import io.crops.warmletter.domain.timeline.facade.NotificationFacade;
 import jakarta.transaction.Transactional;
 import lombok.RequiredArgsConstructor;
 import org.springframework.context.ApplicationEventPublisher;
 import org.springframework.data.domain.Page;
 import org.springframework.data.domain.Pageable;
+import org.springframework.scheduling.annotation.Async;
 import org.springframework.stereotype.Service;
 
 import java.time.LocalDateTime;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
 import java.util.Optional;
-import java.util.concurrent.CompletableFuture;
 
 @Service
 @RequiredArgsConstructor
@@ -101,6 +101,7 @@ public Page<ReportsResponse> getAllReports(String reportType, String status, Pag
     @Transactional
     public ReportResponse createReport(CreateReportRequest request) {
         Long memberId = authFacde.getCurrentUserId();
+        //Long memberId = 1L;
         Map<String, String> reportedContentMap = new HashMap<>();
         validateRequest(request, memberId, reportedContentMap);
         String reportedContent = reportedContentMap.get("content");
@@ -124,13 +125,19 @@ public ReportResponse createReport(CreateReportRequest request) {
         }
         Report report = builder.build();
         Report savedReport = reportRepository.save(report);
-        CompletableFuture.runAsync(() -> {
-            Map<String, String> moderationResult = reportModerationService.moderateText(reportedContent, request.getReasonType(), request.getReason());
-            updateReportWithAIResult(savedReport.getId(), moderationResult);
-        });
+
+        processReportInBackground(savedReport.getId(), reportedContent, request.getReasonType(), request.getReason());
+
         return new ReportResponse(savedReport);
     }
 
+    // 신고 AI 판별 비동기 처리
+    @Async
+    public void processReportInBackground(Long reportId, String reportedContent, ReasonType reasonType, String reason) {
+        Map<String, String> moderationResult = reportModerationService.moderateText(reportedContent, reasonType, reason);
+        updateReportWithAIResult(reportId, moderationResult);
+    }
+
     @Transactional
     public void updateReportWithAIResult(Long reportId, Map<String, String> moderationResult) {
         Report report = reportRepository.findById(reportId)