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

feat : 분석api 개발

Browse Source
This commit is contained in:
lsh9672 2025-06-16 15:09:03 +09:00
parent 1ddcfc3ad3
commit 707694f8f7
1 changed files with 23 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
analytics/src/main/java/com/ktds/hi/analytics/biz/service/AnalyticsService.java
View File

@ -43,8 +43,15 @@ public class AnalyticsService implements AnalyticsUseCase {
String cacheKey = "analytics:store:" + storeId;
var cachedResult = cachePort.getAnalyticsCache(cacheKey);
if (cachedResult.isPresent()) {
log.info("캐시에서 분석 데이터 반환: storeId={}", storeId);
return (StoreAnalyticsResponse) cachedResult.get();
Object cached = cachedResult.get();
// StoreAnalyticsResponse 타입인지 확인
if (cached instanceof StoreAnalyticsResponse) {
log.info("캐시에서 분석 데이터 반환: storeId={}", storeId);
return (StoreAnalyticsResponse) cached;
}
// LinkedHashMap인 경우 스킵하고 DB에서 조회
log.debug("캐시 데이터 타입 불일치, DB에서 조회: storeId={}, type={}",
storeId, cached.getClass().getSimpleName());
}
// 2. 데이터베이스에서 기존 분석 데이터 조회
@ -124,11 +131,15 @@ public class AnalyticsService implements AnalyticsUseCase {
try {
// 1. 캐시 키 생성
// 1. 캐시 키 생성 및 확인
String cacheKey = String.format("statistics:store:%d:%s:%s", storeId, startDate, endDate);
var cachedResult = cachePort.getAnalyticsCache(cacheKey);
if (cachedResult.isPresent()) {
log.info("캐시에서 통계 데이터 반환: storeId={}", storeId);
return (StoreStatisticsResponse) cachedResult.get();
Object cached = cachedResult.get();
if (cached instanceof StoreStatisticsResponse) {
log.info("캐시에서 통계 데이터 반환: storeId={}", storeId);
return (StoreStatisticsResponse) cached;
}
}
// 2. 주문 통계 데이터 조회 (실제 OrderStatistics 도메인 필드 사용)
@ -168,7 +179,10 @@ public class AnalyticsService implements AnalyticsUseCase {
String cacheKey = "ai_feedback_summary:store:" + storeId;
var cachedResult = cachePort.getAnalyticsCache(cacheKey);
if (cachedResult.isPresent()) {
return (AiFeedbackSummaryResponse) cachedResult.get();
Object cached = cachedResult.get();
if (cached instanceof AiFeedbackSummaryResponse) {
return (AiFeedbackSummaryResponse) cached;
}
}
// 2. AI 피드백 조회
@ -219,7 +233,10 @@ public class AnalyticsService implements AnalyticsUseCase {
String cacheKey = "review_analysis:store:" + storeId;
var cachedResult = cachePort.getAnalyticsCache(cacheKey);
if (cachedResult.isPresent()) {
return (ReviewAnalysisResponse) cachedResult.get();
Object cached = cachedResult.get();
if (cached instanceof ReviewAnalysisResponse) {
return (ReviewAnalysisResponse) cached;
}
}
// 2. 최근 리뷰 데이터 조회 (30일)