智能玩具 WebSocket通讯好友列表聊天列表

太过爱你忘了你带给我的痛 2021-11-10 13:56 291阅读 0赞

项目 智能玩具

一、需求分析  
1外形美观大方  
2功能：1语音的实时通讯  
2积极正面内容  
\-播放音频（播放 父母选定的儿歌,故事,百科,英语）  
\-语音识别 （通过语音识别内容名称 玩具可以主动点播内容）  
3陪孩子聊天  
4解答问题（十万个为什么）  
5家长通过玩具查看社交圈

二、具体实施  
第一天：  
获取音频资源  
1从喜马拉雅采集幼教内容，存入文件  
分别获取封面/音乐 文件  
将数据写入数据库  
  
app 获取内容 /content\_list  
\-信息以列表的形式返回  
  
接口功能实现  
根据前端的需求返回相应的数据  
App /get\_cover 获取内容的图片信息  
App /get\_music 获取音频信息  
  
  
2用户的注册 、登录 、自动登录  
App /reg 注册用户  
App /login 用户登录 返回的用户信息  
App /auto\_login 用户打开APP后自动登录 返回的用户信息  
  
3创建设备的DeviceKey(联图网创建二维码）  
保证唯一性  
\-hashlib.md5((f"\{uuid4()\}\{time.time()\}\{uuid4()\}".encode("utf8")).hexdigest()

第二天：  
App 绑定一个设备 扫描二维码，设备必须有一个符合我们数据库中的二维码  
设备 一旦和App进行绑定 由App创建玩具  
  
1扫码  
通过 \{device\_key:""\} 去数据库中查找 是否有该二维码信息  
  
1.二维码扫描成功并且设备未进行绑定  
2.二维码扫描失败,扫描的条码不是设备库中存在的  
  
3.二维码扫描成功, 但设备已经进行绑定  
（还未实现）

2绑定玩具  
按照数据库要求 构建玩具的基本信息  
  
先创建一个空的Chats 表  
\-chat\_id = MDB.Chats.insert\_one(\{"user\_list": \[\], "chat\_list": \[\]\})  
  
  
1创建toy （结合数据库结构和API文档，获取信息）  
toy 绑定 user  
先给toy 添加第一个好友 app  
  
注意 friend\_chat 的写法  
\- "friend\_chat": str(chat\_id.inserted\_id)  
  
  
追加  
\-toy\_info\["friend\_list"\].append(toy\_add\_user)  
toy\_id = MDB.Toys.insert\_one(toy\_info)  
  
2.User表数据补充  
app 也要同时 增加toy为好友  
  
user\_add\_toy = \{  
"friend\_id": toy\_id.inserted\_id, \# toy\_id str  
"friend\_nick": toy\_info.get("baby\_name"), \# baby\_name  
"friend\_remark": toy\_info.get("toy\_name"), \# toy\_name  
"friend\_avatar": "toy.jpg", \#  
"friend\_chat": str(chat\_id.inserted\_id), \# chat\_id  
"friend\_type": "toy" \# 好友的类型 toy  
\}  
  
添加到表结构中  
user\_info\["bind\_toys"\].append(str(toy\_id.inserted\_id))  
user\_info\["friend\_list"\].append(user\_add\_toy)  
  
整体修改数据  
\# 修改 Users 的全部数据  
MDB.Users.update\_one(\{"\_id": ObjectId(user\_id)\}, \{"$set": user\_info\})

\# Chats 数据也会变化 user\_list 将 toy\_id 和 user\_id 加入  
MDB.Chats.update\_one(\{"\_id":chat\_id.inserted\_id\}, \{"$set": \{"user\_list": \[user\_id,str(toy\_id.inserted\_id)\]\}\})

数据结构

3 toy\_list 展示  
从toys 表中查找对应数据，返回（参考表中的数据）

第三天：  
1 智能玩具WebSocket通讯  
Websocket 连接 OpenToy 开机  
按照格式 开启wevbsocket  
  
解决跨域问题  
App通讯 向toy 发送音乐  
ws://10.0.0.1:9528/app/<user\_id>  
Toys通讯 接收App推送音乐  
ws://10.0.0.1:9528/toy/<toy\_id>  
  
1 /get\_qr 接口 获取QRCODE 图片  
\-获取图片/音乐/二维码图片等原理是相通的  
2 /friend\_list 查询好友列表  
  
3 /chat\_list 查询聊天记录  
  
4 /app\_uploader app 上传语音消息  
  
5 /toy\_uploader toy 上传语音消息  
  
  
注意事项：  
前端发送请求所携带的数据 和后端响应的数据

app/toy 上传语音消息 注意 文件格式的转化  
跨域问题的解决（安装包）  
  
获取数据--保存文件--转化格式--聊天记录--更新聊天记录--返回RET

/get\_qr 接口

# 返回二维码信息图片
    @content_bp.route("/get_qr/<filename>",methods=["GET"])
    def get_qr(filename):
        qr_path=os.path.join(QRCODE_PATH,filename)
        return send_file(qr_path)

/friend\_list 接口          /chat\_list 接口

from bson import ObjectId
    from flask import Blueprint, request, jsonify
    
    from settings import MDB, RET
    
    friend_bp = Blueprint("friend_bp", __name__)
    
    
    @friend_bp.route("/friend_list", methods=["POST"])
    def friend_list():
        user_id = request.form.get("_id")
        user_info = MDB.Users.find_one({
        "_id": ObjectId(user_id)})
    
        RET["CODE"] = 0
        RET["MSG"] = "好友查询"
        RET["DATA"] = user_info.get("friend_list")
    
        print(user_info, "+++++++++")
        return jsonify(RET)
    
    
    @friend_bp.route("/chat_list", methods=["POST"])
    def chat_list():
        chat = request.form.to_dict()
        chat_window = MDB.Chats.find_one({
        "_id": ObjectId(chat.get("chat_id"))})
    
        RET["CODE"] = 0
        RET["MSG"] = "查询聊天记录"
        RET["DATA"] = chat_window.get("chat_list")
    
        return jsonify(RET)

实现 /app\_uploader 接口 App上传语音消息  
实现 /toy\_uploader 接口 Toy上传语音消息

import os
    import time
    
    from bson import ObjectId
    from flask import Blueprint, request, jsonify
    
    from settings import MDB, RET, CHAT_PATH
    
    uploader_bp = Blueprint("uploader_bp", __name__)
    
    
    @uploader_bp.route("/app_uploader", methods=["POST"])
    def app_uploader():
        to_user = request.form.get("to_user")
        from_user = request.form.get("user_id")
        reco_file = request.files.get("reco_file")
    
        reco_file_path = os.path.join(CHAT_PATH, reco_file.filename)
        # 保存的文件格式为amr
        reco_file.save(reco_file_path)
        # 转化格式
        os.system(f"ffmpeg -i {reco_file_path} {reco_file_path}.mp3")
    
        user_list = [to_user, from_user]
        # 聊天信息记录
        chat_info = {
            "from_user": from_user,
            "to_user": to_user,
            "chat": f"{reco_file.filename}.mp3",
            "createTime": time.time()
        }
        # 更新聊天数据
        MDB.Chats.update_one({
         "user_list": {
        "$all": user_list}}, {
        "$push": {
        "chat_list": chat_info}})
    
        RET["CODE"] = 0
        RET["MSG"] = "上传成功"
        RET["DATA"] = {
            "filename": f"{reco_file.filename}.mp3",
            "friend_type": "app"
        }
        return jsonify(RET)
    
    
    from uuid import uuid4
    
    
    @uploader_bp.route("/toy_uploader", methods=["POST"])
    def toy_uploader():
        to_user = request.form.get("to_user")
        from_user = request.form.get("user_id")
        reco_file = request.files.get("reco")
         # 与app_uploader 不同    文件名   blob   reco_file.filename  是文件类型
        # print(reco_file.filename, "++++++")
    
        filename = f"{uuid4()}.wav"
        reco_file_path = os.path.join(CHAT_PATH, filename)
    
        reco_file.save(reco_file_path)
    
        user_list = [to_user, from_user]
        # 聊天信息记录
        chat_info = {
            "from_user": from_user,
            "to_user": to_user,
            "chat": filename,
            "createTime": time.time()
        }
        # 更新聊天数据
        MDB.Chats.update_one({
         "user_list": {
        "$all": user_list}}, {
        "$push": {
        "chat_list": chat_info}})
    
        RET["CODE"] = 0
        RET["MSG"] = "上传成功"
        RET["DATA"] = {
            "filename": filename,
            "friend_type": "toy"
        }
        return jsonify(RET)

wap\_ws   websocket 连接

import json
    from flask import Flask, request, render_template
    
    from geventwebsocket.handler import WebSocketHandler
    
    from geventwebsocket.server import WSGIServer
    
    from geventwebsocket.websocket import WebSocket
    
    ws_app = Flask(__name__)
    user_socket_dict = {}
    
    
    # 建立websocket连接
    @ws_app.route("/app/<user_id>")
    def app(user_id):
        # print(user_id,"user_id")
        # 获得wesocket 连接
        app_socket = request.environ.get("wsgi.websocket")  # type: WebSocket
        if app_socket:
            user_socket_dict[user_id] = app_socket
    
        while True:
            app_data = app_socket.receive()
            app_data_dict = json.loads(app_data)
            to_user = app_data_dict.get("to_user")
            usocket = user_socket_dict.get(to_user)
            try:
                usocket.send(app_data)
            except:
                continue
    
    
    @ws_app.route("/toy/<toy_id>")
    def toy(toy_id):
        # 获得wesocket 连接
        toy_socket = request.environ.get("wsgi.websocket")  # type: WebSocket
        if toy_socket:
            user_socket_dict[toy_id] = toy_socket
    
        while True:
            toy_data = toy_socket.receive()
            toy_data_dict = json.loads(toy_data)
            to_user = toy_data_dict.get("to_user")
            usocket = user_socket_dict.get(to_user)
            # usocket.send(toy_data)
            try:
                usocket.send(toy_data)
            except:
                continue
    
    
    @ws_app.route("/get_toy")
    def get_toy():
        return render_template("WebToy.html")
    
    
    if __name__ == '__main__':
        http_serve = WSGIServer(("0.0.0.0", 9528), ws_app, handler_class=WebSocketHandler)
        http_serve.serve_forever()

转载于:https://www.cnblogs.com/XLHIT/p/11234397.html