From 75cfe472d408a4b8021bbb2b22930cd9c5fadb34 Mon Sep 17 00:00:00 2001
From: UNGGU0704 <kyuhung1001@gmail.com>
Date: Wed, 18 Jun 2025 17:30:55 +0900
Subject: [PATCH] =?UTF-8?q?Fix:=20store=EC=9D=98=20=EC=A0=84=EC=86=A1=20?=
 =?UTF-8?q?=EA=B2=80=EC=A6=9D=20=EB=A1=9C=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

---
 .../ExternalIntegrationInteractor.java        | 63 -------------------
 .../gateway/ExternalPlatformAdapter.java      |  7 ++-
 2 files changed, 5 insertions(+), 65 deletions(-)

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 26967d5..8938c1f 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
@@ -247,8 +247,6 @@ 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);
 
@@ -288,73 +286,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;
     }
 
-    /**
-     * Redis에서 처리 완료 표시 (새로 추가)
-     */
-    private void markAsProcessedInRedis(Long storeId, String platform) {
-        try {
-            String pattern = String.format("external:reviews:pending:%d:%s:*", storeId, platform);
-            Set<String> keys = redisTemplate.keys(pattern);
-
-            if (keys != null) {
-                for (String key : keys) {
-                    redisTemplate.delete(key);
-                }
-            }
-
-            log.info("Redis에서 처리 완료된 데이터 삭제: storeId={}, platform={}", storeId, platform);
-
-        } catch (Exception e) {
-            log.warn("Redis 데이터 정리 실패: storeId={}, platform={}", storeId, platform);
-        }
-    }
-
-    /**
-     * 재시도 큐로 이동 (새로 추가)
-     */
-    private void moveToRetryQueue(Long storeId, String platform, String errorMessage) {
-        try {
-            String pattern = String.format("external:reviews:pending:%d:%s:*", storeId, platform);
-            Set<String> keys = redisTemplate.keys(pattern);
-
-            if (keys != null && !keys.isEmpty()) {
-                String pendingKey = keys.iterator().next();
-                Map<String, Object> cacheData = (Map<String, Object>) redisTemplate.opsForValue().get(pendingKey);
-
-                if (cacheData != null) {
-                    // 재시도 횟수 증가
-                    Integer retryCount = (Integer) cacheData.getOrDefault("retryCount", 0);
-                    cacheData.put("retryCount", retryCount + 1);
-                    cacheData.put("lastError", errorMessage);
-                    cacheData.put("status", "RETRY");
-
-                    // 재시도 큐로 이동
-                    String retryKey = pendingKey.replace("pending", "retry");
-                    redisTemplate.opsForValue().set(retryKey, cacheData, Duration.ofHours(12));
-
-                    // 원본 삭제
-                    redisTemplate.delete(pendingKey);
-
-                    log.info("재시도 큐로 이동: retryKey={}, retryCount={}", retryKey, retryCount + 1);
-                }
-            }
-
-        } catch (Exception e) {
-            log.error("재시도 큐 이동 실패: storeId={}, platform={}", storeId, platform);
-        }
-    }
-
     private void publishConnectEvent(Long storeId, String platform) {
         try {
             // 연동 이벤트 발행 로직
diff --git a/store/src/main/java/com/ktds/hi/store/infra/gateway/ExternalPlatformAdapter.java b/store/src/main/java/com/ktds/hi/store/infra/gateway/ExternalPlatformAdapter.java
index 18ad7ea..22b075f 100644
--- a/store/src/main/java/com/ktds/hi/store/infra/gateway/ExternalPlatformAdapter.java
+++ b/store/src/main/java/com/ktds/hi/store/infra/gateway/ExternalPlatformAdapter.java
@@ -157,6 +157,8 @@ public class ExternalPlatformAdapter implements ExternalPlatformPort {
         try {
             log.info("카카오 API 응답 파싱 시작: storeId={}", storeId);
 
+
+
             if (responseBody == null || responseBody.trim().isEmpty()) {
                 log.warn("카카오 응답이 비어있음: storeId={}", storeId);
                 return 0;
@@ -173,12 +175,13 @@ public class ExternalPlatformAdapter implements ExternalPlatformPort {
 
             // reviews 배열 직접 접근
             JsonNode reviewsNode = root.get("reviews");
-            if (reviewsNode == null || !reviewsNode.isArray()) {
-                log.warn("카카오 응답에 reviews 배열이 없음");
+            if (reviewsNode == null || !reviewsNode.isArray() || reviewsNode.size() == 0) {
+                log.warn("카카오 응답에 reviews 배열이 없거나, 리뷰 목록이 없음!");
                 updateSyncStatusWithCache(storeId, platform, "SUCCESS", 0);
                 return 0;
             }
 
+
             // 매장 정보 파싱 (옵션)
             Map<String, Object> storeInfo = null;
             if (root.has("store_info")) {