小智AI音箱MCP开发实战：30分钟搭建自定义语音技能，附完整教程

# 安装核心依赖库
pip install requests pyyaml flask
# 安装小智MCP SDK（需从官方渠道下载后本地安装）
pip install ./secretflow-mcp-sdk-1.0.0.tar.gz

from secretflow_mcp import MCPClient

# 初始化客户端
client = MCPClient(
    app_id="你的AppID",
    app_secret="你的AppSecret",
    device_sn="你的音箱SN码"
)

# 测试设备连接
try:
    response = client.get_device_status()
    print("设备状态：", response["status"])
    print("环境搭建成功！")
except Exception as e:
    print("环境搭建失败：", str(e))

def recognize_intent(text):
    """
    识别用户指令意图
    返回：intent（意图）、params（参数）
    """
    text = text.lower().strip()
    if any(keyword in text for keyword in ["笔记", "记录", "写下"]):
        # 提取笔记内容（例：“记录会议要点：明天下午3点评审”→“会议要点：明天下午3点评审”）
        content = text.replace("笔记", "").replace("记录", "").replace("写下", "").strip()
        return "note", {"content": content}
    elif any(keyword in text for keyword in ["提醒", "闹钟", "记得"]):
        # 提取提醒时间与内容（例：“明天上午10点提醒提交报告”→时间：明天上午10点，内容：提交报告）
        import re
        time_pattern = r"(\d+[点分])([上下]午)?"
        time_match = re.search(time_pattern, text)
        time = time_match.group() if time_match else ""
        content = re.sub(time_pattern, "", text).replace("提醒", "").replace("闹钟", "").replace("记得", "").strip()
        return "reminder", {"time": time, "content": content}
    elif any(keyword in text for keyword in ["换算", "转换", "等于"]):
        # 提取换算参数（例：“100美元等于多少人民币”→100，美元，人民币）
        import re
        num_pattern = r"\d+(\.\d+)?"
        num_match = re.search(num_pattern, text)
        num = num_match.group() if num_match else ""
        from_unit = "美元" if "美元" in text else "人民币" if "人民币" in text else ""
        to_unit = "人民币" if "人民币" in text and "美元" in text else "美元" if "美元" in text and "人民币" in text else ""
        return "conversion", {"num": num, "from_unit": from_unit, "to_unit": to_unit}
    else:
        return "unknown", {"text": text}

import json
import time
from datetime import datetime

# 笔记模块：存储笔记到本地文件
def handle_note(params):
    content = params["content"]
    if not content:
        return "请告诉我要记录的内容~"
    # 按日期创建笔记文件
    date_str = datetime.now().strftime("%Y-%m-%d")
    with open(f"notes_{date_str}.txt", "a", encoding="utf-8") as f:
        timestamp = datetime.now().strftime("%H:%M:%S")
        f.write(f"[{timestamp}] {content}\n")
    return f"笔记已记录：{content}"

# 提醒模块：存储提醒到JSON文件（实际可对接系统闹钟）
def handle_reminder(params):
    time_str = params["time"]
    content = params["content"]
    if not time_str or not content:
        return "请告诉我提醒时间和内容，例如：明天上午10点提醒提交报告"
    # 存储提醒
    reminder = {
        "time": time_str,
        "content": content,
        "create_time": datetime.now().strftime("%Y-%m-%d %H:%M:%S"),
        "status": "pending"
    }
    with open("reminders.json", "a", encoding="utf-8") as f:
        json.dump(reminder, f, ensure_ascii=False)
        f.write("\n")
    return f"已设置提醒：{time_str} {content}"

# 换算模块：美元-人民币简单换算（实际可对接汇率API）
def handle_conversion(params):
    try:
        num = float(params["num"])
        from_unit = params["from_unit"]
        to_unit = params["to_unit"]
        exchange_rate = 7.2  # 示例汇率，实际可通过API获取实时汇率
        if from_unit == "美元" and to_unit == "人民币":
            result = num * exchange_rate
            return f"{num}美元等于{result:.2f}人民币"
        elif from_unit == "人民币" and to_unit == "美元":
            result = num / exchange_rate
            return f"{num}人民币等于{result:.2f}美元"
        else:
            return "目前仅支持美元与人民币换算~"
    except Exception as e:
        return "换算失败，请检查输入格式，例如：100美元等于多少人民币"

from flask import Flask, request, jsonify
from intent_recognizer import recognize_intent
from function_modules import handle_note, handle_reminder, handle_conversion
from secretflow_mcp import MCPClient

app = Flask(__name__)

# 初始化MCP客户端
client = MCPClient(
    app_id="你的AppID",
    app_secret="你的AppSecret",
    device_sn="你的音箱SN码"
)

@app.route("/mcp/intent", methods=["POST"])
def handle_intent():
    data = request.json
    user_text = data.get("text", "")
    if not user_text:
        return jsonify({"response": "请再说一遍~"})
    
    # 识别意图
    intent, params = recognize_intent(user_text)
    
    # 分发处理
    if intent == "note":
        response = handle_note(params)
    elif intent == "reminder":
        response = handle_reminder(params)
    elif intent == "conversion":
        response = handle_conversion(params)
    else:
        response = "我还没学会这个功能，试试让我记笔记、设提醒或换算货币吧~"
    
    # 通过音箱语音反馈
    client.send_voice_response(response)
    return jsonify({"response": response})

if __name__ == "__main__":
    app.run(host="0.0.0.0", port=5000)