update DaoDaoBackend

DaoDaoBackend/StartBackend.py

@@ -1,11 +1,50 @@
 
 from app.app import create_app
-#前面app指的是项目文件夹app，后面app指的是app文件夹下面的初始化文件__init__.py中创建的实例，实例名app
+from flask_socketio import SocketIO, emit
+from werkzeug.middleware.proxy_fix import ProxyFix
+from app.app import mongo
+
  
 app = create_app()
-#print(app)
- 
+# print(app)
+
+
+app.wsgi_app = ProxyFix(
+    app.wsgi_app, x_for=1, x_proto=1, x_host=1, x_prefix=1
+)
+
+# 初始化SocketIO
+socketio = SocketIO(app, cors_allowed_origins="*")
+
+
+# 定义集合
+rooms_collection = {
+    "all": mongo.db.chatAll,  # 所有人聊天
+    "one2one": mongo.db.chatOne2One,  # 一对一聊天
+    "more2more": mongo.db.chatMore2More  # 多对多聊天
+}
+
+@socketio.on('message')
+def handle_message(data):
+    print(data)
+    room_id = data["roomId"]
+    if room_id in rooms_collection:
+        collection = rooms_collection[room_id]
+        collection.insert_one(data)
+        
+        response_event = f'responseMsg_{room_id}'
+        # broadcast_flag = room_id != 'one2one'
+        broadcast_flag = True
+
+        if '_id' in data:
+            del data['_id']
+        emit(response_event, data, broadcast=broadcast_flag)
+    else:
+        print(f"Unsupported room: {room_id}")
+
+
 if __name__ == '__main__':
     #app.run(debug=True)#若调试，可考虑开启debug模式，修改代码后服务自动重启，使修改生效，方便调试，生产环境
-	app.run(host="0.0.0.0", port=5569, debug=True)
+	# app.run(host="0.0.0.0", port=5569, debug=True)
+    socketio.run(app, host="0.0.0.0", port=5569, debug=True)  # 使用 socketio.run 替换 app.run
 	

DaoDaoBackend/app/api/v1/__init__.py

@@ -1,6 +1,6 @@
  
 from flask import Blueprint
-from app.api.v1 import user, book
+from app.api.v1 import user, book, chatMsg, video
  
  
 def create_blueprint_v1():
@@ -9,4 +9,6 @@ def create_blueprint_v1():
     # 将红图注册到蓝图当中
     user.api.register(bp_v1)
     book.api.register(bp_v1)
+    chatMsg.api.register(bp_v1)
+    video.api.register(bp_v1)
     return bp_v1

DaoDaoBackend/app/api/v1/chatMsg.py

@@ -0,0 +1,134 @@
+from app.app import mongo
+from app.libs.redprint import Redprint
+from flask import jsonify, request
+from bson.objectid import ObjectId
+from pymongo.errors import PyMongoError
+import traceback
+
+api = Redprint('chatMsg')
+
+
+@api.route('/get/all')
+def get_all_msg():
+    # mongo.db.chatAll.delete_many({})
+    msg_infos = list(mongo.db.chatAll.find())
+    for msg_info in msg_infos:
+        msg_info["_id"] = str(msg_info["_id"])
+    return jsonify(msg_infos)
+
+
+@api.route('/get/one2one/<sendId>/<rspId>')
+def get_o2o_msg(sendId, rspId):
+    # mongo.db.chatOne2One.delete_many({})
+    msg_infos = list(mongo.db.chatOne2One.find())
+    # 使用列表推导式过滤掉 resUserId 等于 chaterId 的元素
+    msg_infos = [msg_info for msg_info in msg_infos if (sendId == msg_info["sendUserId"] and rspId == msg_info["resUserId"] or rspId == msg_info["sendUserId"] and sendId == msg_info["resUserId"])]
+
+    for msg_info in msg_infos:
+        msg_info["_id"] = str(msg_info["_id"])
+
+    return jsonify(msg_infos)
+
+
+@api.route('/get/more2more')
+def get_m2m_msg():
+    msg_infos = list(mongo.db.chatMore2More.find())
+    for msg_info in msg_infos:
+        msg_info["_id"] = str(msg_info["_id"])
+    return jsonify(msg_infos)
+
+
+def InitItem(item, id):
+    user_id_obj = ObjectId(id)
+    user = mongo.db.users.find_one({"_id": user_id_obj})
+    if user:
+        item["userId"] = id
+        item["username"] = user["username"]
+        item["avatar"] = user["avatar_url"]
+        item["lastMsgContent"] = "您有一条新信息..."
+        item["time"] = "2024-09-18 12:36:09"
+        item["unreadCount"] = 1
+
+
+@api.route('/get/chatItems/<user_id>')
+def get_msg_list(user_id):
+    user_id_obj = ObjectId(user_id)  # 尝试将user_id转化为ObjectId
+    # mongo.db.chatList.delete_many({})
+    try:
+        # 从chatUsers数组中找到对应的用户聊天信息
+        result = mongo.db.chatList.find_one(
+            {"userId": user_id_obj},
+        )
+    except Exception as e:
+        return jsonify({"message": f"Database error: {str(e)}"}), 500
+
+    if result is None:
+        # 文档未找到或用户未找到，返回 404 和提示信息
+        return jsonify({"message": f"Chat items for user {user_id} do not exist."}), 404
+
+    # 从结果中提取用户的聊天列表
+    user_chat_info_ids = result.get('chatUsers', [])
+
+    user_chat_list_info = []
+    for user_chat_info_id in user_chat_info_ids:
+        item = {}
+        InitItem(item, user_chat_info_id)
+        user_chat_list_info.append(item)
+
+    # 返回数组
+    return jsonify(user_chat_list_info), 200
+
+
+@api.route('/appendChatUser', methods=['POST'])
+def append_msg_list():
+    data = request.get_json()
+
+    user_id = data["userId"]
+    to_append_id = data["id"]
+
+    # 将字符串形式的user_id转换为ObjectId
+    user_id_obj = ObjectId(user_id)
+
+    try:
+        # 使用update_one，如果文档存在则更新，不存在则插入
+        result = mongo.db.chatList.update_one(
+            {"userId": user_id_obj},
+            {
+                "$addToSet": {"chatUsers": to_append_id},
+                "$setOnInsert": {"userId": user_id_obj}
+            },
+            upsert=True
+        )
+        
+        if result.matched_count > 0:
+            return jsonify({"message": "ID added successfully to existing user."}), 201
+        else:
+            return jsonify({"message": "New user created and ID added."}), 201
+    
+    except PyMongoError as e:
+        return jsonify({"error": f"Database error: {str(e)}", "traceback": traceback.format_exc()}), 500
+
+# id: obj.a2bId,
+# name: obj.username,
+# avatarList: obj.avatar,
+# note: obj.lastMsgContent,
+# time: obj.time,
+# unreadCount: obj.unreadCount
+
+
+# {
+#     {
+#       "userId": ObjectId("61d679a12e4d4e348a103c79"),
+#       "chatUsers": [
+#         ObjectId("61d679a12e4d4e348a103c7a"),
+#         ObjectId("61d679a12e4d4e348a103c7b")
+#       ]
+#     },
+#     {
+#       "userId": ObjectId("61d679a12e4d4e348a103c7c"),
+#       "chatUsers": [
+#         ObjectId("61d679a12e4d4e348a103c7a"),
+#         ObjectId("61d679a12e4d4e348a103c7d")
+#       ]
+#     }
+# }

DaoDaoBackend/app/api/v1/user.py

@@ -1,41 +1,158 @@
 #user.py
  
 from app.libs.redprint import Redprint
-from app.app import db
 from flask import jsonify, request
+from app.app import mongo
+from app.app import jwt
+from bson.json_util import dumps
+from bson.objectid import ObjectId
+from flask_jwt_extended import create_access_token, jwt_required, get_jwt_identity
+import bcrypt
+from pymongo.errors import DuplicateKeyError
+from werkzeug.exceptions import BadRequest
  
 # 初始化红图
 api = Redprint('user')
- 
+
  
 @api.route('/get')
 def get_user2():
     return "I am user get method"
- 
- 
-@api.route('/create', methods=['POST'])
-def get_create_user():
-	user_info = request.get_json()
-	result = db.users.insert_one(user_info)
-    return jsonify({"_id": str(result.inserted_id)})
+
+
+def check_password(username, password):
+    # 找到用户
+    user = mongo.db.users.find_one({"username": username})
+    if user is None:
+        # 返回一个更泛化的错误信息
+        return {"error": "此用户名不存在."}, 404
+    # 验证密码
+    if bcrypt.checkpw(password.encode('utf-8'), user['password_hash']):
+        return {"message": "Password correct"}, 200
+    else:
+        return {"error": "密码错误."}, 401
+        
+
+def make_jwt_info(user):
+    # 使用flask_jwt_extended的create_access_token函数创建JWT
+    access_token = create_access_token(identity=str(user['_id']), additional_claims={
+        'email': user['email'],
+        'username': user['username'],
+        'avatar_url': user['avatar_url'],
+        'bio': user['bio']
+    })
+    return access_token
+
+
+@api.route('/pwdlogin', methods=['POST'])
+def user_pwd_login():
+    username = request.json.get('username')
+    password = request.json.get('password')
+    result, status_code = check_password(username, password)  # 解包元组
+    # 根据check_password的返回结果处理
+    if result.get('message') == "Password correct":
+        # access_token = create_access_token(identity=username)
+        user = mongo.db.users.find_one({"username": username})
+        access_token = make_jwt_info(user)
+        return jsonify({'token': access_token}), 200
+    else:
+        return jsonify(result), status_code  # 使用从check_password返回的状态码
+
+
+def InitUserInfo(user_info):
+    user_info["avatar_url"] = "https://afanai.top:8088/imgs/default_avatar_1.jpeg"
+    user_info["bio"] = "永远不要降低心灵飞翔的高度"
+    user_info["password_hash"] = bcrypt.hashpw(user_info["password"].encode('utf-8'), bcrypt.gensalt())
+
+
+@api.route('/register', methods=['POST'])
+def user_pwd_register():
+    user_info = request.get_json()
+    InitUserInfo(user_info)
+    try:
+        mongo.db.users.insert_one(user_info)
+        username = user_info["username"]
+        return jsonify({"message": f"User {username} registered successfully."}), 201
+    except DuplicateKeyError as e:
+        # 处理DuplicateKeyError
+        # 从异常信息中解析出冲突的字段
+        error_message = str(e)
+        if 'username' in error_message:
+            return jsonify({"error": "此用户名已存在."}), 409
+        if 'email' in error_message:
+            return jsonify({"error": "此邮箱已被注册."}), 409
+        # 如果异常信息中没有明确的字段信息，可以考虑更详细的异常处理或日志记录
+        return jsonify({"error": "未知错误."}), 500
 	
 	
 @api.route('/getall')
 def get_all_user():
-	user_infos = list(db.users.find())
-	# 将ObjectId转换为字符串，以便于JSON序列化
-	for user_info in user_infos:
-		user_info['_id'] = str(user_info['_id'])
-	return jsonify(user_infos)
+    user_infos = list(mongo.db.users.find())
+    # 将ObjectId转换为字符串，以便于JSON序列化
+    # 使用bson的json_util来序列化包含ObjectId的对象
+    # json_string = dumps(user_infos)
+    for user_info in user_infos:
+        user_info["_id"] = str(user_info["_id"])
+        user_info["password_hash"] = "******"
+    return jsonify(user_infos)
 	
 	
 @api.route('/modify/<user_id>', methods=['PUT'])
-def get_all_user(user_id):
-	item = request.get_json()
-	result = db.users.update_one({"_id": ObjectId(user_id)}, {"$set": item})
-	return jsonify({"modified_count": result.modified_count})
+def modify_specify_user(user_id):
+    try:
+        item = request.get_json()
+        # print(item)
+        if not item:
+            raise BadRequest("请求体为空")
+        # 将user_id转换为ObjectId
+        user_id_obj = ObjectId(user_id)
+        result = mongo.db.users.update_one({"_id": user_id_obj}, {"$set": item})
+        # 如果没有找到或修改任何文档
+        if result.modified_count == 0:
+            return jsonify({"error": "未找到用户或没有数据被修改"}), 404
+        
+        user = mongo.db.users.find_one({"_id": user_id_obj})
+        access_token = make_jwt_info(user)
+        return jsonify({'token': access_token}), 201
+    except BadRequest as e:
+        return jsonify({"error": str(e)}), 400
+    except Exception as e:
+        return jsonify({"error": "内部服务器错误"}), 500
 	
 
+@api.route('/search', methods=['GET'])
+def search_specify_user():
+    try:
+        # 从查询字符串中获取参数
+        query = request.args.get('query')
+        print(query)
+        if not query:
+            raise BadRequest("查询参数为空")
+
+        # 搜索用户名
+        user = mongo.db.users.find_one({"username": query})
+        # print(user)
+        queryUser = {}
+        queryRes = []
+        if user:
+            queryUser["userId"] = str(user["_id"])
+            queryUser["username"] = user["username"]
+            queryUser["avatar_url"] = user["avatar_url"]
+            queryUser["bio"] = user["bio"]
+            queryRes.append(queryUser)
+        print(queryRes)
+
+        if len(queryRes):
+            return jsonify({'queryRes': queryRes}), 200
+        else:
+            return jsonify({'queryRes': "None Result"}), 404
+        
+    except BadRequest as e:
+        return jsonify({"error": str(e)}), 400
+    except Exception as e:
+        return jsonify({"error": "内部服务器错误"}), 500
+
+
 # @api.route('/items', methods=['POST'])
 # def add_item():
 #     item = request.get_json()

DaoDaoBackend/app/api/v1/video.py

@@ -0,0 +1,113 @@
+#video.py
+ 
+from app.libs.redprint import Redprint
+from flask import jsonify, request
+from app.app import mongo
+from app.app import jwt
+from bson.json_util import dumps
+from bson.objectid import ObjectId
+from flask_jwt_extended import create_access_token, jwt_required, get_jwt_identity
+import bcrypt
+import re
+from pymongo.errors import DuplicateKeyError
+from werkzeug.exceptions import BadRequest
+ 
+# 初始化红图
+api = Redprint('video')
+
+ 
+@api.route('/get')
+def get_video():
+    return "I am video get method"
+
+
+@api.route('/getall')
+def get_all_video():
+    video_infos = list(mongo.db.videos.find())
+    # 将ObjectId转换为字符串，以便于JSON序列化
+    # 使用bson的json_util来序列化包含ObjectId的对象
+    # json_string = dumps(user_infos)
+    for video_info in video_infos:
+        video_info["_id"] = str(video_info["_id"])
+    return jsonify(video_infos)
+
+
+@api.route('/getBlobUrl', methods=['GET'])
+def get_blob_url_video():
+    try:
+        # 从查询字符串中获取参数
+        query = ObjectId(request.args.get('query'))
+        print(query)
+        
+        if not query:
+            raise BadRequest("查询参数为空")
+        
+        video = mongo.db.videos.find_one({"_id": query})
+        if video:
+            bolb_url = video["video_url"]
+            print(bolb_url)
+
+        if bolb_url:
+            return jsonify({'queryRes': bolb_url}), 200
+        else:
+            return jsonify({'queryRes': "None Result"}), 404
+        
+    except BadRequest as e:
+        return jsonify({"error": str(e)}), 400
+    except Exception as e:
+        return jsonify({"error": "内部服务器错误"}), 500
+
+
+@api.route('/search', methods=['GET'])
+def search_specify_video():
+    try:
+        # 从查询字符串中获取参数
+        query = request.args.get('query')
+        print(query)
+        if not query:
+            raise BadRequest("查询参数为空")
+        
+
+        # 搜索视频 如果由#开头则搜索id，否则搜索视频名称
+        video = {}
+        videos = []
+        if query[0] == '#' :
+            if (query == "#1000001#") :
+                videos = mongo.db.videos.find()
+            else:
+                video = mongo.db.videos.find_one({"video_id": query})
+        else :
+            paQuery = {"video_name": {"$regex": query, "$options": "i"}}
+            videos = mongo.db.videos.find(paQuery)
+        
+        # queryVideo = {}
+        queryRes = []
+        if video:
+            queryVideo = {}
+            queryVideo["duration"] = video["duration"]
+            queryVideo["cover_url"] = video["cover_url"]
+            queryVideo["video_name"] = video["video_name"]
+            queryVideo["uploader_id"] = video["uploader_id"]
+            # queryVideo["video_url"] = video["video_url"]
+            queryVideo["video_id"] = str(video["_id"])
+            queryRes.append(queryVideo)
+        
+        for videoItem in videos:
+            queryVideo = {}
+            queryVideo["duration"] = videoItem["duration"]
+            queryVideo["cover_url"] = videoItem["cover_url"]
+            queryVideo["video_name"] = videoItem["video_name"]
+            queryVideo["uploader_id"] = videoItem["uploader_id"]
+            # queryVideo["video_url"] = video["video_url"]
+            queryVideo["video_id"] = str(videoItem["_id"])
+            queryRes.append(queryVideo)
+
+        if len(queryRes):
+            return jsonify({'queryRes': queryRes}), 200
+        else:
+            return jsonify({'queryRes': "None Result"}), 200
+        
+    except BadRequest as e:
+        return jsonify({"error": str(e)}), 400
+    except Exception as e:
+        return jsonify({"error": "内部服务器错误"}), 500

DaoDaoBackend/app/app.py

@@ -1,6 +1,13 @@
 from flask import Flask
 from pymongo import MongoClient
- 
+from flask_pymongo import PyMongo
+from flask_jwt_extended import JWTManager
+from flask_cors import CORS
+
+
+mongo = PyMongo()
+jwt = JWTManager()
+
  
 def register_blueprints(app):
     from app.api.v1 import create_blueprint_v1
@@ -11,10 +18,18 @@ def create_app():
     app = Flask(__name__)
     app.config.from_object('app.config.setting')
     app.config.from_object('app.config.secure')
-	
-	# 初始化MongoDB连接
-	app.db = MongoClient(app.config['MONGO_URI']).get_database(app.config['MONGO_DBNAME'])
-	
+    
+    # 初始化MongoDB连接
+    #app.db = MongoClient(app.config['MONGO_URI']).get_database(app.config['MONGO_DBNAME'])
+    mongo.init_app(app)
+    jwt.init_app(app)
+
+    
+    # 初始化 CORS，允许所有源访问, 调试解决跨域问题，项目完成后删除
+    CORS(app)
+
+    # app.config['JSON_AS_ASCLL'] = False
+    
     # 将蓝图注册到app 上
     register_blueprints(app)
     return app

DaoDaoBackend/app/config/setting.py

@@ -1,6 +1,16 @@
 # app/config/setting.py
 #MONGO_URI = 'mongodb://username:password@host:port'
 #MONGO_DBNAME = 'your_db_name'
+#MONGODB_SETTINGS = {
+#    'db': 'your_db_name',
+#    'host': 'your_db_host',
+#    'port': 27017,
+#    'username': 'your_db_username',
+#    'password': 'your_db_password',
+#}
 
-MONGO_URI = 'mongodb://127.0.0.1:27017/'
-MONGO_DBNAME = 'starter_db'
+MONGO_URI = 'mongodb://127.0.0.1:27017/starter_db'
+MONGO_DBNAME = 'starter_db'
+JSON_AS_ASCII = False
+
+JWT_SECRET_KEY = 'heweidabangzi77!'

DaoDaoBackend/gunicorn/gunicorn.conf.py

@@ -0,0 +1,14 @@
+import multiprocessing
+
+bind = '127.0.0.1:5569' #要绑定的socket（配置nginx后，需要把0.0.0.0改为127.0.0.1）
+#workers = multiprocessing.cpu_count() * 2 + 1 #处理请求的工作进程数，官方推荐（2 * cpu核数 + 1）
+workers = 1
+reload = True #代码改变后自动重启工作进程
+worker_class = 'eventlet' #工作进程的类型，分别是sync, eventlet, gevent, tornado, gthread
+#threads = 2 #工作类型为gthread时才生效
+worker_connections = 1000 #默认1000，每个worker同时处理的最大客户端连接数，gthread\eventlet\gevent模式生效
+pidfile = './gunicorn/gunicorn.pid' #进程文件目录，不设置就没有进程文件
+accesslog = './gunicorn/gunicorn_acess.log' #访问日志路径
+errorlog = './gunicorn/gunicorn_error.log' #错误信息日志路径
+loglevel = 'warning' #错误日志级别，'debug'\'info'\'warning'\'error'\'critical'
+daemon = True #在后台运行

DaoDaoBackend/gunicorn/gunicorn.pid

@@ -0,0 +1 @@
+429506

DaoDaoBackend/gunicorn/readme

@@ -0,0 +1,4 @@
+���������ļ� gunicorn -c gunicorn.conf.py hello:app
+�鿴 pid ��kill����
+
+(starter_env) root@debian:/usr/environments/StartBackend# gunicorn -c ./gunicorn/gunicorn.conf.py StartBackend:app

DaoDaoBackend/other/CreatUniqueIndex.py

@@ -0,0 +1,19 @@
+# coding: utf-8
+from pymongo import MongoClient
+
+# MongoDB的连接信息
+MONGO_URI = 'mongodb://127.0.0.1:27017'
+MONGO_DBNAME = 'starter_db'
+
+# 创建MongoDB的连接
+client = MongoClient(MONGO_URI)
+
+# 选择或创建数据库
+db = client[MONGO_DBNAME]
+
+# 选择或创建集合（类似关系数据库中的表）
+users_collection = db['users']
+
+# 创建唯一索引
+users_collection.create_index('username', unique=True)
+users_collection.create_index('email', unique=True)

DaoDaoBackend/other/InitUserInfo.py

@@ -0,0 +1,37 @@
+# coding: utf-8
+from pymongo import MongoClient
+import bcrypt
+
+# MongoDB的连接信息
+MONGO_URI = 'mongodb://127.0.0.1:27017'
+MONGO_DBNAME = 'starter_db'
+
+# 创建MongoDB的连接
+client = MongoClient(MONGO_URI)
+
+# 选择或创建数据库
+db = client[MONGO_DBNAME]
+
+# 选择或创建集合（类似关系数据库中的表）
+users_collection = db['users']
+
+# 清空集合，如果集合已经存在并有数据
+users_collection.delete_many({})
+
+
+# 插入一些示例数据
+sample_users = [
+    {"username": "developuser", "email": "developuser@example.com", "avatar_url": "https://afanai.top:8088/imgs/default_avatar_1.jpeg", "bio": "This account is for develop", "password_hash": bcrypt.hashpw("super123".encode('utf-8'), bcrypt.gensalt())}
+]
+
+for i in sample_users:
+    print(i)
+
+# 执行插入操作
+result = users_collection.insert_many(sample_users)
+
+# 打印插入的文档ID
+print("Inserted document IDs:", result.inserted_ids)
+
+# 关闭数据库连接
+client.close()

DaoDaoBackend/other/InitVideoInfo.py

@@ -0,0 +1,38 @@
+# coding: utf-8
+from pymongo import MongoClient
+import bcrypt
+
+# MongoDB的连接信息
+MONGO_URI = 'mongodb://127.0.0.1:27017'
+MONGO_DBNAME = 'starter_db'
+
+# 创建MongoDB的连接
+client = MongoClient(MONGO_URI)
+
+# 选择或创建数据库
+db = client[MONGO_DBNAME]
+
+# 选择或创建集合（类似关系数据库中的表）
+users_collection = db['videos']
+
+# 清空集合，如果集合已经存在并有数据
+users_collection.delete_many({})
+
+
+# 插入一些示例数据
+sample_video = [
+    {"video_id": "#00000", "duration": "65", "cover_url": "https://afanai.top:8088/video/982789760frame.jpg", "video_name": "鞠婧祎视频1", "uploader_id": "00001", "video_url": "https://afanai.top:8088/video/982789760.mp4"},
+    {"video_id": "#00001", "duration": "65", "cover_url": "https://afanai.top:8088/video/428743782frame.jpg", "video_name": "鞠婧祎视频2", "uploader_id": "00001", "video_url": "https://afanai.top:8088/video/428743782.mp4"}
+]
+
+for i in sample_video:
+    print(i)
+
+# 执行插入操作
+result = users_collection.insert_many(sample_video)
+
+# 打印插入的文档ID
+print("Inserted document IDs:", result.inserted_ids)
+
+# 关闭数据库连接
+client.close()

DaoDaoBackend/other/InsertVideo.py

@@ -0,0 +1,40 @@
+# coding: utf-8
+from pymongo import MongoClient
+import bcrypt
+
+# MongoDB的连接信息
+MONGO_URI = 'mongodb://127.0.0.1:27017'
+MONGO_DBNAME = 'starter_db'
+
+# 创建MongoDB的连接
+client = MongoClient(MONGO_URI)
+
+# 选择或创建数据库
+db = client[MONGO_DBNAME]
+
+# 选择或创建集合（类似关系数据库中的表）
+users_collection = db['videos']
+
+# 清空集合，如果集合已经存在并有数据
+# users_collection.delete_many({})
+
+
+# 插入一些示例数据
+sample_video = [
+    {"video_id": "#70007", "duration": "65", "cover_url": "https://afanai.top:8088/video/567645453frame.jpg", "video_name": "hp_0", "uploader_id": "00001", "video_url": "https://afanai.top:8088/video/567645453.mp4"}
+    # {"video_id": "#00001", "duration": "65", "cover_url": "https://afanai.top:8088/video/428743782frame.jpg", "video_name": "鞠婧祎视频2", "uploader_id": "00001", "video_url": "https://afanai.top:8088/video/428743782.mp4"}
+]
+
+for i in sample_video:
+    print(i)
+
+# 执行插入操作
+result = users_collection.insert_many(sample_video)
+# result = users_collection.insert_one(sample_video)
+
+
+# 打印插入的文档ID
+print("Inserted document IDs:", result.inserted_ids)
+
+# 关闭数据库连接
+client.close()

DaoDaoBackend/other/testSocketIo.py

@@ -0,0 +1,20 @@
+from flask import Flask
+from flask_socketio import SocketIO, emit
+from flask_cors import CORS
+
+app = Flask(__name__)
+
+# 初始化CORS，允许所有源
+CORS(app, cors_allowed_origins="*")  # 显式指定所有资源允许所有源
+
+socketio = SocketIO(app, cors_allowed_origins="*")  # SocketIO也允许所有源
+
+@socketio.on('message')
+def handle_message(data):
+    # print('received message: ' + str(data))
+    if not data.roomId == "all":
+        return
+    emit('responseMsg', data, broadcast=True)
+
+if __name__ == '__main__':
+    socketio.run(app, host="0.0.0.0", port=8089, debug=True)

DaoDaoBackend/readme

@@ -0,0 +1,35 @@
+/my_flask_app
+│
+├── app/                # 主要的 Flask 应用代码目录
+│   ├── __init__.py     # 初始化 Flask 应用
+│   ├── config.py       # 配置文件
+│   ├── api/            # API 蓝图目录
+│   │   ├── __init__.py 
+│   │   └── v1/         # v1 版本的 API
+│   │       ├── __init__.py
+│   │       └── endpoints.py
+│   ├── models.py       # 数据模型
+│   └── views.py        # 视图函数
+│
+├── socketio/           # SocketIO 相关代码的目录
+│   ├── __init__.py     # 初始化 SocketIO
+│   └── events.py       # SocketIO 事件处理器
+│
+├── requirements.txt    # 项目依赖
+├── manage.py           # 主启动文件
+│
+└── README.md           # 项目说明文件
+
+
+�ӿ�˵��
+
+1. �û����
+  1.1 �û��������¼
+    https://ip:port/v1/user/pwdlogin
+  1.2 �û�ע��
+    https://ip:port/v1/user/register
+
+
+run 
+  1. 切换到虚拟环境 source ../starter_env/bin/activate
+  2. 运行python 

DaoDaoBackend/run.log

@@ -0,0 +1,8 @@
+nohup: ignoring input
+Traceback (most recent call last):
+  File "/usr/environments/StartBackend/StartBackend.py", line 31, in <module>
+    socketio.run(app, host="0.0.0.0", port=5569, debug=True)  # 使用 socketio.run 替换 app.run
+    ^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^^
+  File "/usr/environments/starter_env/lib/python3.11/site-packages/flask_socketio/__init__.py", line 646, in run
+    raise RuntimeError('The Werkzeug web server is not '
+RuntimeError: The Werkzeug web server is not designed to run in production. Pass allow_unsafe_werkzeug=True to the run() method to disable this error.