shared-dg04-hi/hi-backend
7
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Update: Store MSA 이벤트 송신 방어로직 추가

Browse Source
This commit is contained in:
UNGGU0704 2025-06-18 16:12:33 +09:00
parent 52c7e7decc
commit ee38fc8126
1 changed files with 10 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
store/src/main/java/com/ktds/hi/store/biz/service/ExternalIntegrationInteractor.java
View File

@ -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;