ZZZ - AI 페르소나 & 실시간 상태 공유

┌────────────────────────────────────────────────────────────────────────┐
│                        Client Layer (Flutter App)                      │
│  - Presentation: Riverpod (MVVM StateNotifier), Dynamic Island UI      │
│  - Native Bridge: Android Foreground Service, iOS Live Activity Widget │
└───────────────────────────────────┬────────────────────────────────────┘
                                    │ HTTP / REST API & FCM Push
                                    ▼
┌────────────────────────────────────────────────────────────────────────┐
│                   Core Backend (Spring Boot 3.4)                       │
│  - Auth & User Domain (JWT, Native Token Refresh, Status FSM)          │
│  - Couple & Chat Domain (Message Persistence, Event Publishing)        │
│  - Status Scheduler (Timezone / Battery Inactive Detection)            │
└──────────────┬───────────────────┬───────────────────┬─────────────────┘
               │ (JPA / SQL)       │ (Lettuce)         │ (AMQP Producer)
               ▼                   ▼                   ▼
┌────────────────────────┐  ┌─────────────┐  ┌───────────────────────────┐
│       MySQL 8.0        │  │  Redis 7.0  │  │   RabbitMQ Event Broker   │
│  (Users, Couples, Chat)│  │ (Status,TTL)│  │  (zzz.exchange / DLX /    │
└────────────────────────┘  └─────────────┘  │   ai.request / response)  │
                                             └─────────────┬─────────────┘
                                                           │ (AMQP Consumer)
                                                           ▼
┌────────────────────────────────────────────────────────────────────────┐
│                   AI Service (Python FastAPI)                          │
│  - RAG Pipeline: Vector Search (Chroma / Pinecone Embeddings)          │
│  - LLM Engine: Gemini / GPT Multi-Provider, Persona Cloning & Recap    │
└────────────────────────────────────────────────────────────────────────┘

// app/android/app/src/main/kotlin/.../service/HeartbeatService.kt (오프라인 큐잉 및 토큰 리프레시)
private suspend fun performHeartbeat(userId: Long): Boolean {
    val batteryLevel = getBatteryLevel()
    val isScreenOn = isScreenOn()
    val timestamp = System.currentTimeMillis()
    var authToken = tokenManager.getAuthToken() ?: return false

    val pendingLogs = heartbeatDao.getAll()
    val hasPending = pendingLogs.isNotEmpty()

    try {
        var responseCode = executeNetworkCall(authToken, pendingLogs, batteryLevel, isScreenOn, timestamp)
        
        // 토큰 만료 시 네이티브 레벨에서 자동 리프레시 후 재시도
        if (responseCode == 401) {
            val refreshToken = tokenManager.getRefreshToken()
            if (refreshToken != null) {
                val newTokens = heartbeatClient.refreshAccessToken(refreshToken)
                if (newTokens != null) {
                    tokenManager.saveTokens(newTokens.first, newTokens.second)
                    responseCode = executeNetworkCall(newTokens.first, pendingLogs, batteryLevel, isScreenOn, timestamp)
                }
            }
        }

        if (responseCode == 200) {
            if (hasPending) heartbeatDao.deleteAll()
            return true
        }

        // 네트워크 전송 실패 시 로컬 DB에 보존
        heartbeatDao.insert(HeartbeatEntity(timestamp = timestamp, batteryLevel = batteryLevel, isScreenOn = isScreenOn))
        return true
    } catch (e: Exception) {
        heartbeatDao.insert(HeartbeatEntity(timestamp = timestamp, batteryLevel = batteryLevel, isScreenOn = isScreenOn))
        return true
    }
}

// backend/.../chat/event/ChatEventListener.java (부재 상태 감지 및 비동기 AMQP 이벤트 발행)
@Async
@EventListener
public void handleMessageSent(MessageSentEvent event) {
    publishChatNotification(event);

    if (isUserUnavailable(event.getReceiverStatus())) {
        AIRequestEvent aiEvent = AIRequestEvent.builder()
                .requestId(UUID.randomUUID().toString())
                .userId(String.valueOf(event.getSenderId()))
                .partnerId(String.valueOf(event.getReceiverId()))
                .partnerName(event.getReceiverNickname())
                .content(event.getContent())
                .type("CHAT")
                .build();
        
        aiEventPublisher.publishChatRequest(aiEvent);
    }
}

private boolean isUserUnavailable(UserStatus status) {
    return status == UserStatus.SLEEP || status == UserStatus.STUDY || status == UserStatus.BUSY;
}

# backend/ai-service/app/services/rag_service.py (Namespace 기반 RAG 검색 및 페르소나 프롬프트 생성)
def get_persona_response(self, target_persona_id: str, message: str, partner_name: str) -> str:
    # 1. 사용자 질문 임베딩
    query_vector = llm_service.get_embedding(message)
    if not query_vector:
        return "AI 서비스를 사용할 수 없습니다. (Embedding 실패)"

    # 2. Namespace 기준 과거 대화 유사도 검색
    search_results = vector_store.query_similar(
        vector=query_vector,
        top_k=3,
        namespace=target_persona_id
    )
    context_texts = [match['metadata']['text'] for match in search_results if 'metadata' in match]
    context_str = "\n".join(context_texts)

    # 3. 페르소나 모방 시스템 프롬프트 구성
    system_prompt = f"""
    당신은 '{partner_name}'의 AI 페르소나입니다. 
    아래 제공되는 '과거 대화 스타일'을 참고하여, 사용자의 말에 연인처럼 다정하게 답변하세요.
    
    [과거 대화 스타일]
    {context_str}
    
    [지시사항]
    - 말투, 어조, 이모티콘 사용 패턴을 위 데이터를 통해 모방하세요.
    - 사용자의 현재 상황을 고려하여 공감해주세요.
    - 너무 길게 말하지 마세요 (3문장 이내).
    """
    return llm_service.generate_response(system_prompt, message)

// backend/.../user/UserStatusScheduler.java (Timezone 인식 수면/방전 FSM)
@Scheduled(cron = "0 * * * * *")
@Transactional
public void autoDetectSleepMode() {
    LocalDateTime threshold = LocalDateTime.now().minusMinutes(INACTIVE_THRESHOLD_MINUTES);
    List<User> inactiveUsers = userRepository.findByStatusAndLastActiveAtBefore(UserStatus.ONLINE, threshold);
    
    for (User user : inactiveUsers) {
        Map<Object, Object> metadata = userStatusService.getUserMetadata(user.getId());
        int battery = parseBattery(metadata.get("battery"));

        if (battery >= 0 && battery < 5) {
            updateUserStatus(user, UserStatus.DISCHARGED, "Battery low (" + battery + "%)");
            continue;
        }

        ZoneId zoneId = ZoneId.of(user.getTimezone() != null ? user.getTimezone() : "Asia/Seoul");
        int hour = ZonedDateTime.now(zoneId).getHour();

        if (hour >= 23 || hour < 6) {
            updateUserStatus(user, UserStatus.SLEEP, "Night time (" + hour + "h)");
            continue;
        }

        updateUserStatus(user, UserStatus.UNKNOWN, "Inactive");
    }
}

// backend/.../global/config/RabbitMqConfig.java (Dead Letter Queue & DLX 바인딩)
@Bean
public Queue aiResponseQueue() {
    return QueueBuilder.durable(AI_RESPONSE_QUEUE)
            .withArgument("x-dead-letter-exchange", DLX_NAME)
            .withArgument("x-dead-letter-routing-key", "dead.letter.ai.response")
            .build();
}

// backend/.../ai/event/AIResponseListener.java (독성 메시지 Requeue 방지)
catch (NumberFormatException e) {
    log.error("Invalid format in AI Response: partnerId={} userId={}. Sending to DLQ.", 
              event.getPartnerId(), event.getUserId(), e);
    throw new AmqpRejectAndDontRequeueException("Invalid number format in AI response", e);
}