From ee38fc8126d07d89f21610c37e36ac30f637179b Mon Sep 17 00:00:00 2001
From: UNGGU0704 <kyuhung1001@gmail.com>
Date: Wed, 18 Jun 2025 16:12:33 +0900
Subject: [PATCH] =?UTF-8?q?Update:=20Store=20MSA=20=EC=9D=B4=EB=B2=A4?=
 =?UTF-8?q?=ED=8A=B8=20=EC=86=A1=EC=8B=A0=20=EB=B0=A9=EC=96=B4=EB=A1=9C?=
 =?UTF-8?q?=EC=A7=81=20=EC=B6=94=EA=B0=80?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../biz/service/ExternalIntegrationInteractor.java     | 10 ++++++++++
 1 file changed, 10 insertions(+)

diff --git a/store/src/main/java/com/ktds/hi/store/biz/service/ExternalIntegrationInteractor.java b/store/src/main/java/com/ktds/hi/store/biz/service/ExternalIntegrationInteractor.java
index 4568bd9..26967d5 100644
--- a/store/src/main/java/com/ktds/hi/store/biz/service/ExternalIntegrationInteractor.java
+++ b/store/src/main/java/com/ktds/hi/store/biz/service/ExternalIntegrationInteractor.java
@@ -246,6 +246,10 @@ public class ExternalIntegrationInteractor implements ExternalIntegrationUseCase
 
             // Redis에서 실제 리뷰 데이터 조회
             Map<String, Object> eventPayload = createEventPayloadFromRedis(storeId, platform, syncedCount);
+
+            if (eventPayload == null)
+                throw new BusinessException("Review 데이터가 없습니다.");
+
             String payloadJson = objectMapper.writeValueAsString(eventPayload);
 
             EventData eventData = new EventData(payloadJson);
@@ -284,6 +288,12 @@ public class ExternalIntegrationInteractor implements ExternalIntegrationUseCase
 
         // Redis에서 실제 리뷰 데이터 조회
         List<Map<String, Object>> reviews = externalPlatformPort.getTempReviews(storeId, platform);
+        if (reviews == null || reviews.isEmpty()) {
+            log.warn("🚨 리뷰 데이터가 없어 이벤트 발행 중단: storeId={}, platform={}, syncedCount={}",
+                    storeId, platform, syncedCount);
+            return null;
+        }
+
         payload.put("reviews", reviews);
 
         return payload;