From c40fae39484313a475edfef256cb25e56b03e810 Mon Sep 17 00:00:00 2001 From: dddd <1163562824@qq.com> Date: Tue, 22 Sep 2026 17:56:23 +0800 Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=93=8D=E5=BA=94=E4=BD=93?= =?UTF-8?q?=E5=92=8C=E6=B3=A8=E9=87=8A?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- api/class_api.py | 61 ++++++++++++++++++++--------------------- dao/class_dao.py | 36 ++++++++++++------------ schemas/class_schema.py | 2 +- 3 files changed, 49 insertions(+), 50 deletions(-) diff --git a/api/class_api.py b/api/class_api.py index 69ce419..191e5f3 100644 --- a/api/class_api.py +++ b/api/class_api.py @@ -12,49 +12,48 @@ classes_router = APIRouter() # ————定义班级表"新增"信息的接口函数———— @classes_router.post('/',response_model=ClassResponse,summary='新增班级信息') # POST新增请求，指定返回数据格式为 ClassResponse -def post_classes(classes:ClassCreate,db=Depends(get_db)): # 定义更新接口函数，参数classes声明创建请求模型，参数db依赖于数据库会话的上下文管理器 - c = classes.model_dump() # 变量c用来接收通过model_dump将Pydantic模型对象解析为Python的字典，方便后续解包传参 - r = post_classes_dao( c , db ) # 变量r用来接收dao层post_classes_dao函数的返回值，执行函数时以变量c的数据和db依赖函数入参 - if r : # 判断 DAO 层的返回结果，如果为True - return ClassResponse( total=1,data=c ) # 返回成功响应，携带新增的数据给前端 - else : # 如果为False +def post_classes(classes:ClassCreate,db=Depends(get_db)): # 定义更新接口函数，参数classes声明创建请求模型，参数db依赖于数据库会话的上下文管理器 + c = classes.model_dump() # 变量c用来接收通过model_dump将Pydantic模型对象解析为Python的字典，方便后续解包传参 + r = post_classes_dao( c , db ) # 变量r用来接收dao层post_classes_dao函数的返回值，执行函数时以变量c的数据和db依赖函数入参 + if r : # 判断 DAO 层的返回结果，如果为True + return ClassResponse( total=1,data=c ) # 返回成功响应，携带新增的数据给前端 + else : # 如果为False raise HTTPException(status_code=500,detail='添加失败，服务器繁忙，请稍后添加！') # 抛出 500 内部服务器错误 和提示 # ————定义班级表"更新"信息的接口函数———— @classes_router.put('/{id}',response_model=ClassResponse,summary='更新班级信息') # put更新请求，指定返回数据格式为 ClassResponse def put_classes( classes:ClassUpdate , id:int , db=Depends( get_db ) ): # 定义更新接口函数，id参数接收前端输入的数据，参数classes声明更新请求体模型，参数db依赖于数据库会话的上下文管理器 - updates = classes.model_dump( exclude_unset=True ) # 变量updates用来接收通过model_dump将Pydantic模型对象解析为Python的字典(只解析输入的数据)，方便后续解包传参 - r = update_classes_dao( id, db, updates ) # 变量r用来接收dao层update_classes_dao函数的返回值，执行函数时以变量c的数据、db依赖函数、和前端更新的数据入参 - if r : # 判断 DAO 层的返回结果，如果为True + updates = classes.model_dump( exclude_unset=True ) # 变量updates用来接收通过model_dump将Pydantic模型对象解析为Python的字典(只解析输入的数据)，方便后续解包传参 + r = update_classes_dao( id, db, updates ) # 变量r用来接收dao层update_classes_dao函数的返回值，执行函数时以变量c的数据、db依赖函数、和前端更新的数据入参 + if r : # 判断 DAO 层的返回结果，如果为True return ClassResponse( detail='更新成功', total=1 ,data = updates ) # 返回成功响应，携带更新的数据给前端 raise HTTPException( status_code=500, detail='更新失败，该班级已不存在或服务器繁忙，请稍后更新！' ) # 如果为False，抛出 500 内部服务器错误 和提示 # ————定义班级表"查询"信息的接口函数———— -@classes_router.get('',summary='查询班级信息') # get查询请求 -def get_classes( id:int|None = None # id参数接收前端输入的数据，声明是整数，可以为空默认为空 - , class_no:str|None = None # class_no参数接收前端输入的数据，声明是字符串，可以为空默认为空 - , class_name:str|None = None # class_name参数接收前端输入的数据，声明是字符串，可以为空默认为空 - , page:int = 1 # page参数接收前端输入的数据，声明是整数，默认是1 - , page_size:int = 5 # page参数接收前端输入的数据，声明是整数，默认是5 - , db=Depends(get_db) # 参数db依赖于数据库会话的上下文管理器 +@classes_router.get('',summary='查询班级信息') # get查询请求 +def get_classes( id:int|None = None # id参数接收前端输入的数据，声明是整数，可以为空默认为空 + , class_no:str|None = None # class_no参数接收前端输入的数据，声明是字符串，可以为空默认为空 + , class_name:str|None = None # class_name参数接收前端输入的数据，声明是字符串，可以为空默认为空 + , page:int = 1 # page参数接收前端输入的数据，声明是整数，默认是1 + , page_size:int = 5 # page参数接收前端输入的数据，声明是整数，默认是5 + , db=Depends(get_db) # 参数db依赖于数据库会话的上下文管理器 ): t,r = get_classes_dao( id , class_no , class_name , page , page_size ,db ) # 变量t,r用来接收dao层get_classes_dao函数的返回值，执行函数时以前端输入的id , class_no , class_name , page , page_size 、db依赖函数入参 - if t != 0 : # 判断 DAO 层的返回结果，如果为条数不为0 - return ClassResponse( total = t, data = r ) # 返回成功响应，返回符合条件的总条数，携带符合条件的数据给前端 - else : # 判断 DAO 层的返回结果，如果为条数为0 - return ClassResponse( code = 404,detail = '没有符合条件的班级，请检查输入是否有误') # 返回404响应，提示没有符合条件的提示给前端 + if t != 0 : # 判断 DAO 层的返回结果，如果为条数不为0 + return ClassResponse( total = t, data = r ) # 返回成功响应，返回符合条件的总条数，携带符合条件的数据给前端 + return ClassResponse( code = 404,detail = '没有符合条件的班级，请检查输入是否有误') # 判断 DAO 层的返回结果，如果为条数为0，返回404响应，提示没有符合条件的提示给前端 # ————定定义查询符合查询条件的班级的总学生人数信息的接口函数———— -@classes_router.get('/student-count', summary='查询每个班级学生人数') # get查询请求 -def get_class_student_count( class_id:int|None = None # id参数接收前端输入的数据，声明是整数，可以为空默认为空 - , class_no:str|None = None # class_no参数接收前端输入的数据，声明是字符串，可以为空默认为空 - , class_name:str|None = None # class_name参数接收前端输入的数据，声明是字符串，可以为空默认为空 - , page:int = 1 # page参数接收前端输入的数据，声明是整数，默认是1 - , page_size:int = 5 # page参数接收前端输入的数据，声明是整数，默认是5 - , db=Depends(get_db) # 参数db依赖于数据库会话的上下文管理器 +@classes_router.get('/student-count', summary='查询每个班级学生人数') # get查询请求 +def get_class_student_count( class_id:int|None = None # id参数接收前端输入的数据，声明是整数，可以为空默认为空 + , class_no:str|None = None # class_no参数接收前端输入的数据，声明是字符串，可以为空默认为空 + , class_name:str|None = None # class_name参数接收前端输入的数据，声明是字符串，可以为空默认为空 + , page:int = 1 # page参数接收前端输入的数据，声明是整数，默认是1 + , page_size:int = 5 # page参数接收前端输入的数据，声明是整数，默认是5 + , db=Depends(get_db) # 参数db依赖于数据库会话的上下文管理器 ): t,r = get_class_student_count_dao(class_id,class_no,class_name,page,page_size,db) # 变量t,r用来接收dao层get_classes_dao函数的返回值，执行函数时以前端输入的id , class_no , class_name , page , page_size 、db依赖函数入参 if r: # 判断 DAO 层的返回结果，如果为True @@ -66,8 +65,8 @@ def get_class_student_count( class_id:int|None = None # ————定义班级表"删除"信息的接口函数———— @classes_router.delete('/{id}',response_model=ClassResponse,summary='删除班级信息') # delete删除请求，指定返回数据格式为 ClassResponse -def delete_classes(id:int,db=Depends(get_db)): # 定义删除接口函数，id参数接收前端输入的数据，参数db依赖于数据库会话的上下文管理器 - r = delete_classes_dao( id , db ) # 变量r用来接收dao层delete_classes_dao函数的返回值，执行函数时以以前端输入的id 数据、db依赖函数入参 - if r : # 判断 DAO 层的返回结果，如果是True - return ClassResponse( total=1,data='已成功删除班级信息' ) # 返回成功响应和提示给前端 # 如果是False +def delete_classes(id:int,db=Depends(get_db)): # 定义删除接口函数，id参数接收前端输入的数据，参数db依赖于数据库会话的上下文管理器 + r = delete_classes_dao( id , db ) # 变量r用来接收dao层delete_classes_dao函数的返回值，执行函数时以以前端输入的id 数据、db依赖函数入参 + if r : # 判断 DAO 层的返回结果，如果是True + return ClassResponse( total=1,data='已成功删除班级信息' ) # 返回成功响应和提示给前端 # 如果是False raise HTTPException(status_code=500, detail='删除失败，该班级信息已不存在或服务器繁忙，请稍后更新！') # 如果为False，抛出 500 内部服务器错误 和提示 \ No newline at end of file diff --git a/dao/class_dao.py b/dao/class_dao.py index 22ae1c3..21b6af9 100644 --- a/dao/class_dao.py +++ b/dao/class_dao.py @@ -30,16 +30,16 @@ def update_classes_dao( class_id , db , updates ): # 定义函数，设置 # ————定义班级表"查询"信息的函数———— def get_classes_dao( class_id, class_no , class_name , page , page_size , db ): # 定义函数，设置六个形参class_id, class_no , class_name , page , page_size , db - q = db.query( Classes ).filter( Classes.is_deleted == 0 ) # 初始化查询语句，基础过滤条件为筛选未删除的数据 (is_deleted=0) - if class_id : # 如果传入了班级id参数 - q = q.filter( Classes.id == class_id ) # 则追加id过滤条件 - if class_no : # 如果传入了班级no参数 - q = q.filter( Classes.class_no == class_no ) # 则追加no过滤条件 - if class_name : # 如果传入了班级name参数 - q = q.filter( Classes.class_name == class_name ) # 则追加name过滤条件 - total = q.count() # total变量接收满足当前所有过滤条件的数据总条数 - r = q.offset( ( page-1 ) * page_size ).limit( page_size ).all() # 变量r用来接收查询取出结果列表，计算分页偏移量（从第几行开始查），设置分页限制条数 - return total , [ # 返回 total变量总条数 和 将查询结果列表转换为字典列表的数据 + q = db.query( Classes ).filter( Classes.is_deleted == 0 ) # 初始化查询语句，基础过滤条件为筛选未删除的数据 (is_deleted=0) + if class_id : # 如果传入了班级id参数 + q = q.filter( Classes.id == class_id ) # 则追加id过滤条件 + if class_no : # 如果传入了班级no参数 + q = q.filter( Classes.class_no == class_no ) # 则追加no过滤条件 + if class_name : # 如果传入了班级name参数 + q = q.filter( Classes.class_name == class_name ) # 则追加name过滤条件 + total = q.count() # total变量接收满足当前所有过滤条件的数据总条数 + r = q.offset( ( page-1 ) * page_size ).limit( page_size ).all() # 变量r用来接收查询取出结果列表，计算分页偏移量（从第几行开始查），设置分页限制条数 + return total , [ # 返回 total变量总条数 和 将查询结果列表转换为字典列表的数据 { 'class_id':i.id # 提取班级ID , 'class_no':i.class_no # 提取班级编号 @@ -67,14 +67,14 @@ def get_class_student_count_dao(class_id,class_no,class_name,page,page_size,db): ) .\ outerjoin( Student, and_(Classes.id == Student.class_id,Student.is_deleted == 0)).\ filter(Classes.is_deleted == 0) # 左连接学生表，并指定连接条件（未删除的学生） - if class_id : # 如果传入了班级id参数 - q = q.filter( Classes.id == class_id ) # 则追加id过滤条件 - if class_no : # 如果传入了班级no参数 - q = q.filter( Classes.class_no == class_no ) # 则追加no过滤条件 - if class_name : # 如果传入了班级name参数 - q = q.filter( Classes.class_name == class_name ) # 则追加name过滤条件 - q = q.group_by(Classes.id, Classes.class_no, Classes.class_name) # 按班级ID、编号、名称进行分组聚合 - q = q.order_by( desc('student_count') ) # 按学生人数（别名）进行降序排列 + if class_id : # 如果传入了班级id参数 + q = q.filter( Classes.id == class_id ) # 则追加id过滤条件 + if class_no : # 如果传入了班级no参数 + q = q.filter( Classes.class_no == class_no ) # 则追加no过滤条件 + if class_name : # 如果传入了班级name参数 + q = q.filter( Classes.class_name == class_name ) # 则追加name过滤条件 + q = q.group_by(Classes.id, Classes.class_no, Classes.class_name) # 按班级ID、编号、名称进行分组聚合 + q = q.order_by( desc('student_count') ) # 按学生人数（别名）进行降序排列 total = q.count() # total变量接收满足当前所有过滤条件的数据总条数 r = q.offset( ( page-1 ) * page_size ).limit( page_size ).all() # 变量r用来接收查询取出结果列表，计算分页偏移量（从第几行开始查），设置分页限制条数 return total,[ # 返回 total变量总条数 和 将查询结果列表转换为字典列表的数据 diff --git a/schemas/class_schema.py b/schemas/class_schema.py index 6883c26..c43ec9f 100644 --- a/schemas/class_schema.py +++ b/schemas/class_schema.py @@ -25,4 +25,4 @@ class ClassResponse( BaseModel ): # 班级信息的响应体模型 code:int = 200 # 状态码，默认200 detail:str = '执行成功' # 提示信息 total:int = 0 # 数据总条数，默认为0 - data:str|dict|list|tuple|None = None # 返回的数据，默认为空 \ No newline at end of file + data:str|dict|list|tuple = '' # 返回的数据,默认为空字符串 \ No newline at end of file