sequenceDiagram
    participant U as 사용자 (카카오톡)
    participant K as 카카오 오픈빌더
    participant S as FastAPI 서버
    participant AI as AI 에이전트
    participant BIZ as 업무 시스템
 
    U->>K: "이번 달 매출 현황 알려줘"
    K->>S: POST /webhook (JSON payload)
    S->>AI: 의도 분류 + 파라미터 추출
    AI->>BIZ: query_sales(month="2026-02")
    BIZ-->>AI: {total: 52000000, ...}
    AI-->>S: 응답 텍스트 생성
    S-->>K: JSON 응답 (SimpleText)
    K-->>U: "2월 매출 현황: 5,200만원 (전월 대비 +12%)"

from fastapi import FastAPI, Request
from pydantic import BaseModel
import json
 
app = FastAPI()
 
class KakaoRequest(BaseModel):
    """카카오 오픈빌더 스킬 요청 구조"""
    intent: dict
    userRequest: dict
    bot: dict
    action: dict
 
@app.post("/webhook")
async def kakao_webhook(request: Request):
    body = await request.json()
 
    # 사용자 메시지 추출
    user_message = body["userRequest"]["utterance"]
    user_id = body["userRequest"]["user"]["id"]
 
    # AI 에이전트로 처리
    response_text = await process_with_agent(user_message, user_id)
 
    # 카카오 응답 포맷
    return {
        "version": "2.0",
        "template": {
            "outputs": [
                {
                    "simpleText": {
                        "text": response_text
                    }
                }
            ]
        }
    }

from openai import OpenAI
 
client = OpenAI()
 
# 업무 도구 정의
tools = [
    {
        "type": "function",
        "function": {
            "name": "query_sales",
            "description": "월별 매출 현황을 조회합니다",
            "parameters": {
                "type": "object",
                "properties": {
                    "month": {
                        "type": "string",
                        "description": "조회할 월 (YYYY-MM 형식)"
                    }
                },
                "required": ["month"]
            }
        }
    },
    {
        "type": "function",
        "function": {
            "name": "schedule_meeting",
            "description": "미팅을 예약합니다",
            "parameters": {
                "type": "object",
                "properties": {
                    "date": {"type": "string", "description": "날짜 (YYYY-MM-DD)"},
                    "time": {"type": "string", "description": "시간 (HH:MM)"},
                    "attendees": {
                        "type": "array",
                        "items": {"type": "string"},
                        "description": "참석자 목록"
                    }
                },
                "required": ["date", "time"]
            }
        }
    }
]
 
async def process_with_agent(user_message: str, user_id: str) -> str:
    """AI 에이전트: 의도 분류 → 도구 호출 → 응답 생성"""
 
    messages = [
        {
            "role": "system",
            "content": (
                "당신은 회사 업무를 돕는 AI 비서입니다. "
                "카카오톡으로 들어온 요청을 분석하고 적절한 도구를 호출하세요. "
                "응답은 카카오톡에 표시되므로 간결하게 작성하세요 (200자 이내)."
            )
        },
        {"role": "user", "content": user_message}
    ]
 
    response = client.chat.completions.create(
        model="gpt-4o",
        messages=messages,
        tools=tools,
        tool_choice="auto"
    )
 
    message = response.choices[0].message
 
    # 도구 호출이 필요한 경우
    if message.tool_calls:
        for tool_call in message.tool_calls:
            func_name = tool_call.function.name
            func_args = json.loads(tool_call.function.arguments)
 
            # 실제 업무 시스템 호출
            result = await execute_business_function(func_name, func_args)
 
            messages.append(message)
            messages.append({
                "role": "tool",
                "tool_call_id": tool_call.id,
                "content": json.dumps(result, ensure_ascii=False)
            })
 
        # 결과를 기반으로 최종 응답 생성
        final_response = client.chat.completions.create(
            model="gpt-4o",
            messages=messages
        )
        return final_response.choices[0].message.content
 
    return message.content

async def execute_business_function(func_name: str, args: dict) -> dict:
    """실제 업무 시스템(DB, API 등) 호출"""
 
    if func_name == "query_sales":
        # 예시: DB에서 매출 조회
        # result = await db.query("SELECT ... WHERE month = ?", args["month"])
        return {
            "month": args["month"],
            "total": 52000000,
            "prev_month_change": "+12%",
            "top_product": "클라우드 컨설팅"
        }
 
    elif func_name == "schedule_meeting":
        # 예시: Google Calendar API 호출
        return {
            "status": "scheduled",
            "date": args["date"],
            "time": args["time"],
            "meeting_link": "https://meet.google.com/xxx-yyy-zzz"
        }
 
    return {"error": "알 수 없는 기능입니다"}

@app.post("/webhook")
async def kakao_webhook(request: Request):
    try:
        body = await request.json()
        user_message = body["userRequest"]["utterance"]
        response_text = await process_with_agent(user_message, "user")
    except Exception as e:
        logger.error(f"처리 실패: {e}")
        response_text = "죄송합니다. 일시적인 오류가 발생했습니다. 잠시 후 다시 시도해주세요."
 
    return {"version": "2.0", "template": {"outputs": [{"simpleText": {"text": response_text}}]}}