闪烁MCP编排器
这项服务是 大脑 在您的Blink语音助手后面。
它连接：
- 用户语音（来自listen_channel小部件）
- OpenAI LLM（用于意图+实体提取）
- n8n工作流程（菜单、电话验证、订单处理）
- POS MCP编排器（占位符切换）
- 分析（记录到n8n）
______________________________________________________________________
🧠 高水位流量
- 用户对着 listen_client小部件
- 小部件发送STT文本→
/orchestrate在此服务器上 - 编排者：
- 从加载会话上下文 MemoryStore - 用途 LLMBasedIntentRouter 分类： - get_menu - provide_phone - provide_address - place_order - chitchat / unknown - 通过拨打n8n N8NGateway （菜单、电话、订单） - 通过以下方式验证项目与菜单 MenuValidator - 通过向POS MCP发送订单摘要 POSGateway （占位符） - 通过向n8n发送分析 AnalyticsGateway
- 返回自然语言回复→ 小部件
- Widget向ElevenLabs TTS发送回复并播放音频
______________________________________________________________________
📁 项目结构
mcp_orchestrator/
├─ app.py # FastAPI entrypoint
├─ orchestration/
│ ├─ agent_core.py # Main orchestrator brain
│ ├─ llm_router.py # LLM-based intent + entity extraction
│ ├─ menu_validator.py # Fuzzy menu item validation
│ ├─ n8n_gateway.py # All calls to n8n webhooks
│ ├─ pos_gateway.py # Handoff to POS MCP (placeholder)
│ ├─ analytics_gateway.py # Analytics logs to n8n
│ ├─ session_context.py # SessionContext, state, short-term memory
│ ├─ memory_store.py # In-memory session store
│ ├─ models.py # Pydantic models
│ └─ config.py # Environment-based settings
├─ requirements.txt
├─ Procfile
└─ .env.example