This commit is contained in:
wolin_liyujie
2026-09-22 19:22:46 +08:00
6 changed files with 94 additions and 43 deletions
+41 -24
View File
@@ -12,44 +12,61 @@ 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依赖于数据库会话的上下文管理器
):
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
return ClassResponse(total=t, data=r) # 返回成功响应,携带符合条件的数据给前端
return ClassResponse(code=404, detail='没有班级数据') # 如果 DAO 层返回的结果为False,返回404响应,提示没有符合条件的提示给前端
# ————定义班级表"删除"信息的接口函数————
@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 内部服务器错误 和提示
+44 -10
View File
@@ -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() # tatal变量接收满足当前所有过滤条件的数据总条数
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 # 提取班级编号
@@ -54,6 +54,40 @@ def get_classes_dao( class_id, class_no , class_name , page , page_size , db ):
]
# ————定义查询符合查询条件的班级的总学生人数信息的函数————
from sqlalchemy import func, and_ ,desc # 从sqlalchemy模块导入func聚合函数的类、and_函数,降序排序desc函数
from models.student import Student # 从models包下的student模块导入Student表模型类
def get_class_student_count_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.id.label('class_id') # 查询班级ID(别名class_id)
, Classes.class_no # 班级编号
, Classes.class_name # 班级名称
, func.count(Student.id).label('student_count') # 统计班级未删除的学生人数(别名student_count)
) .\
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') ) # 按学生人数(别名)进行降序排列
total = q.count() # total变量接收满足当前所有过滤条件的数据总条数
r = q.offset( ( page-1 ) * page_size ).limit( page_size ).all() # 变量r用来接收查询取出结果列表,计算分页偏移量(从第几行开始查),设置分页限制条数
return total,[ # 返回 total变量总条数 和 将查询结果列表转换为字典列表的数据
{
'class_id':i.class_id # 提取班级ID
, 'class_no':i.class_no # 提取班级编号
, 'class_name':i.class_name # 提取班级名称
, 'student_count':i.student_count # 提取开课日期
}
for i in r # 循环遍历查询出的每一行数据 i
]
# ————定义班级表"删除"信息的函数————
def delete_classes_dao( class_id , db ): # 定义函数,设置两个个形参class_id,db
try : # 执行以下可能报错的代码
+1 -1
View File
@@ -1,6 +1,6 @@
from schemas.statistics import NoExist
from sqlalchemy import func
from time import time
#`GET /statistics/students/age-over-30`
#查询所有超过 30 岁的学员信息
+1 -1
View File
@@ -16,7 +16,7 @@ def llm_func(input_user):
base_url="https://api.deepseek.com"
)
prom_path = Path(__file__).parent / "prom.txt"
prom_path = Path(__file__).parent / "prom.txt" #拼接路径
context = prom_path.read_text(encoding="utf-8")
+1 -1
View File
@@ -7,7 +7,7 @@ from api.student import student_router
from api.teacher import router as teacher_router,class_teacher_router
from api.magic import magic_router
app = FastAPI()
app = FastAPI(title='学生管理系统')
app.middleware("http")(log_middleware)
app.include_router(magic_router)
+6 -6
View File
@@ -6,11 +6,11 @@ from datetime import datetime,date # 导入datetime模块下的datetime,da
# ————定义"创建班级"的"请求体"模型————
class ClassCreate( BaseModel ): # "创建"班级信息的请求体模型
class_no: str # 班级编号",不可为空
class_name: str # 班级名字",不可为空
start_date : date|None = None # 班级开课日期",可以为空,默认为空
end_date : date|None = None # 班级结课日期",可以为空,默认为空
remark : str|None = None # 班级备注",可以为空,默认为空
class_no: str # 班级编号,不可为空
class_name: str # 班级名字,不可为空
start_date : date|None = None # 班级开课日期,可以为空,默认为空
end_date : date|None = None # 班级结课日期,可以为空,默认为空
remark : str|None = None # 班级备注,可以为空,默认为空
# ————定义"更新班级"的"请求体"模型————
class ClassUpdate( BaseModel ): # "更新"班级信息的请求体模型
@@ -25,4 +25,4 @@ class ClassResponse( BaseModel ): # 班级信息的响应体模型
code:int = 200 # 状态码,默认200
detail:str = '执行成功' # 提示信息
total:int = 0 # 数据总条数,默认为0
data:str|dict|list|tuple # 返回的数据
data:str|dict|list|tuple = '' # 返回的数据,默认为空字符串