효드림 - 실버 세대 맞춤형 헬스케어 커머스

┌────────────────────────────────────────────────────────┐
│              Client / Swagger OpenAPI                  │
└──────────────────────────┬─────────────────────────────┘
                           │ HTTP / JSON
                           ▼
┌────────────────────────────────────────────────────────┐
│     Spring Boot 3.4 Core Backend (Modular Monolith)     │
│  - User Domain (Disease, Allergy, Health Goal)         │
│  - Product Domain (SearchLog, Naver Import, DB Upsert) │
│  - Order Domain (Real-time Sales Sync)                 │
└──────────────┬───────────────────┬─────────────────────┘
               │ (OpenFeign)       │ (OpenFeign)
               ▼                   ▼
┌────────────────────────┐  ┌────────────────────────────┐
│  AI Recommender Server │  │ AI Review Sentiment Server │
│   (FastAPI + GPT-4o)   │  │   (FastAPI + TF/Keras)     │
└────────────────────────┘  └──────────────┬─────────────┘
                                           │ (OpenFeign)
                                           ▼
                            ┌────────────────────────────┐
                            │    SmartStore Crawler      │
                            │ (undetected-chromedriver)  │
                            └────────────────────────────┘
               ▲
               │ Streams (XADD / XREAD) & Caching
               ▼
┌────────────────────────────────────────────────────────┐
│             MySQL 8.0 & Redis 7.0 In-Memory            │
│       (Domain DB / Streams / ZSet / 24h Cache)         │
└────────────────────────────────────────────────────────┘

# ai-server/app/gpt_recommender.py (후보군 요약 및 JSON 스키마 강제 프롬프트)
prompt = f"""
너는 헬스케어 쇼핑몰의 추천 AI다.
[사용자 정보] 질병: {', '.join(req.diseases)}, 알레르기: {', '.join(req.allergies)}, 목표: {', '.join(req.goals)}
[후보 상품 목록] (총 100개)
{candidates_text}

[추천 규칙]
1. 사용자의 알레르기 성분이 포함된 상품은 절대 제외할 것
2. 질병 및 개선 목표와 관련된 효능이 있는 상품을 우선 선택하여 정확히 5개 선정
[출력 형식] {{"product_ids": [ID1, ID2, ID3, ID4, ID5]}}
"""

// backend/.../product/service/StreamConsumer.java (Stream 이벤트 컨슈밍 및 ZSet 누적)
@Scheduled(fixedRate = 1000)
public void processClickEvents() {
    List<MapRecord<String, Object, Object>> records = redisTemplate.opsForStream()
            .read(Consumer.from("rec-group", "consumer-1"),
                  StreamReadOptions.empty().count(100),
                  StreamOffset.create("product-events", ReadOffset.lastConsumed()));

    for (var record : records) {
        String category = (String) record.getValue().get("category");
        String userId = (String) record.getValue().get("userId");
        // 사용자별 실시간 관심 카테고리 점수 누적
        redisTemplate.opsForZSet().incrementScore("user:interest:" + userId, category, 1.0);
        redisTemplate.opsForStream().acknowledge("product-events", "rec-group", record.getId());
    }
}

# crawler/app/crawler.py (SSR window.__PRELOADED_STATE__ JSON 정규식 직접 추출)
def extract_preloaded_state(html: str) -> Optional[dict]:
    pattern = r'window\.__PRELOADED_STATE__\s*=\s*({.*?});?\s*</script>'
    match = re.search(pattern, html, re.DOTALL)
    return json.loads(match.group(1)) if match else None

// backend/.../product/service/ProductService.java (24시간 캐싱 & 외부 API 호출 제어)
SearchLog log = searchLogRepository.findById(keyword).orElse(null);
boolean needApiCall = (log == null) || 
    (log.getLastApiCallAt() != null && log.getLastApiCallAt().isBefore(LocalDateTime.now().minusHours(24)));

if (needApiCall) {
    naverShoppingService.importNaverProducts(keyword);
    if (log == null) log = new SearchLog(keyword, LocalDateTime.now(), LocalDateTime.now());
    else log.recordApiCall();
    searchLogRepository.save(log);
}

// backend/.../order/service/OrderService.java (단일 IN 절 쿼리 & In-Memory Map 매핑)
Set<Long> productIds = orders.stream()
        .flatMap(o -> o.getOrderItems().stream())
        .map(OrderItem::getProductId)
        .collect(Collectors.toSet());

// N번 개별 쿼리 대신 1번의 IN 절 쿼리로 일괄 조회 후 메모리 매핑
Map<Long, String> productNameMap = productRepository.findAllById(productIds).stream()
        .collect(Collectors.toMap(Product::getId, Product::getName));

// backend/.../product/service/ProductSyncService.java (트랜잭션 분리 및 DB 원자적 선점)
@Async
public void updateProductDetailsAsync(Long productId) {
    TransactionTemplate txTemplate = new TransactionTemplate(transactionManager);
    txTemplate.setPropagationBehavior(TransactionDefinition.PROPAGATION_REQUIRES_NEW);

    // 1. [DB 원자적 선점] Native Query로 PROGRESS 상태 원자적 선점 (영향 행 0이면 즉시 스킵)
    int updatedRows = txTemplate.execute(status -> productRepository.startSyncNative(productId));
    if (updatedRows == 0) return;

    // 2. [Non-Transaction] 수 초 이상 걸리는 외부 I/O 동안 DB 커넥션 미점유
    CrawlerResponseDto crawledData = crawlerClient.crawlProduct(new CrawlRequest(itemUrl, 5));

    // 3. [비관적 락 결과 저장] PESSIMISTIC_WRITE(SELECT FOR UPDATE)로 안전하게 최종 갱신
    txTemplate.execute(status -> {
        Product product = productRepository.findByIdWithLock(productId)
                .orElseThrow(() -> new RuntimeException("상품 없음"));
        product.getDetail().updateCrawledData(...);
        product.getDetail().setStatus(AnalysisStatus.COMPLETED);
        productRepository.saveAndFlush(product);
        return null;
    });
}