Merge branch 'main' of http://47.106.207.27:3000/lookerZz/DoubaoTeam into LI_YUJIE
This commit is contained in:
wolin_liyujie
+30
-29
@@ -10,8 +10,8 @@ classes_router = APIRouter()
|
||||
|
||||
#以下分别定义增、删、改、查的路由的接口函数，以便api接口函数中执行
|
||||
|
||||
# ————定义班级表"更新"信息的"接口"函数————
|
||||
@classes_router.post('/',response_model=ClassResponse,summary='新增班级信息') # 定义班级创建路由，POST请求，指定返回数据格式为 ClassResponse
|
||||
# ————定义班级表"新增"信息的接口函数————
|
||||
@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依赖函数入参
|
||||
@@ -21,34 +21,35 @@ def post_classes(classes:ClassCreate,db=Depends(get_db)): # 定义更
|
||||
raise HTTPException(status_code=500,detail='添加失败，服务器繁忙，请稍后添加！') # 抛出 500 内部服务器错误 和提示
|
||||
|
||||
|
||||
@classes_router.put('/{id}',response_model=ClassResponse,summary='更新班级信息')
|
||||
def put_classes(classes:ClassUpdate,id:int,db=Depends(get_db)):
|
||||
updates = classes.model_dump( exclude_unset=True )
|
||||
r = update_classes_dao( id, db, updates )
|
||||
if not r :
|
||||
raise HTTPException(status_code=500, detail='更新失败，该班级已不存在或服务器繁忙，请稍后更新！')
|
||||
return ClassResponse(detail='更新成功', total=1 ,data = updates )
|
||||
# ————定义班级表"更新"信息的接口函数————
|
||||
@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
|
||||
return ClassResponse( detail='更新成功', total=1 ,data = updates ) # 返回成功响应，携带更新的数据给前端
|
||||
raise HTTPException( status_code=500, detail='更新失败，该班级已不存在或服务器繁忙，请稍后更新！' ) # 如果为False，抛出 500 内部服务器错误 和提示
|
||||
|
||||
|
||||
@classes_router.get('',summary='查询班级信息')
|
||||
def get_classes( id:int|None = None
|
||||
, class_no:str|None = None
|
||||
, class_name:str|None = None
|
||||
, page:int = 1
|
||||
, page_size:int = 5
|
||||
, db=Depends(get_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 )
|
||||
if t != 0 :
|
||||
return ClassResponse( total = t, data = r )
|
||||
else :
|
||||
return ClassResponse( code = 404,detail = '没有符合条件的班级，请检查输入是否有误')
|
||||
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响应，提示没有符合条件的提示给前端
|
||||
|
||||
|
||||
@classes_router.delete('/{id}',response_model=ClassResponse,summary='删除班级信息')
|
||||
def delete_classes(id:int,db=Depends(get_db)):
|
||||
r = delete_classes_dao( id , db )
|
||||
if r :
|
||||
return ClassResponse( total=1,data='已成功删除班级信息' )
|
||||
else :
|
||||
raise HTTPException(status_code=500, detail='删除失败，该班级信息已不存在或服务器繁忙，请稍后更新！')
|
||||
# ————定义班级表"删除"信息的接口函数————
|
||||
@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
|
||||
raise HTTPException(status_code=500, detail='删除失败，该班级信息已不存在或服务器繁忙，请稍后更新！') # 如果为False，抛出 500 内部服务器错误 和提示
|
||||
+12
-3
@@ -1,7 +1,7 @@
|
||||
from fastapi import APIRouter, Depends, HTTPException, Query
|
||||
from sqlalchemy.orm import Session
|
||||
from core.database import get_db
|
||||
from dao.score import post_score_dao, update_score_dao, get_score_dao, delete_score_dao, exist_student_exam_dao
|
||||
from dao.score import post_score_dao, update_score_dao, get_score_dao, get_all_scores_dao,delete_score_dao, exist_student_exam_dao
|
||||
from schemas.score import ScoreCreate, ScoreUpdate, ScorePageResp
|
||||
|
||||
scores_router = APIRouter(prefix="/scores", tags=["成绩接口"])
|
||||
@@ -12,14 +12,13 @@ def create_score(req: ScoreCreate, db: Session = Depends(get_db)):
|
||||
# 业务校验：联合唯一
|
||||
if exist_student_exam_dao(req.student_id, req.exam_seq, db):
|
||||
raise HTTPException(status_code=400, detail="该学生本次考试成绩已存在，不能重复录入")
|
||||
|
||||
ok = post_score_dao(req.model_dump(), db)
|
||||
if not ok:
|
||||
raise HTTPException(status_code=400, detail="新增成绩失败，请检查学生id是否存在")
|
||||
return {"msg": "新增成功"}
|
||||
|
||||
|
||||
@scores_router.get("", response_model=ScorePageResp, summary="查询成绩接口")
|
||||
@scores_router.get("", response_model=ScorePageResp, summary="个人成绩查询接口")
|
||||
def list_score(
|
||||
score_id: int|None=None,
|
||||
student_id: int |None=None,
|
||||
@@ -32,6 +31,16 @@ def list_score(
|
||||
return {"total": total, "data": data_list}
|
||||
|
||||
|
||||
|
||||
@scores_router.get("/all", response_model=ScorePageResp,
|
||||
summary="所有学生成绩接口",
|
||||
)
|
||||
def list_all_scores(page: int = Query(1, ge=1),
|
||||
page_size: int = Query(10, ge=1, le=100),
|
||||
db: Session = Depends(get_db)):
|
||||
total, data_list = get_all_scores_dao(page, page_size, db)
|
||||
return {"total": total, "data": data_list}
|
||||
|
||||
@scores_router.put("{score_id}", summary="更新成绩接口")
|
||||
def modify_score(score_id: int, req: ScoreUpdate, db: Session = Depends(get_db)):
|
||||
update_dict = req.model_dump(exclude_unset=True)
|
||||
|
||||
+45
-40
@@ -15,47 +15,52 @@ def post_classes_dao( c , db ): # 定义函数，设置两个
|
||||
db.commit() # 提交事务：将数据真正持久化写入到数据库中
|
||||
return True # 返回 True，返回接口，表示操作成功
|
||||
|
||||
def update_classes_dao( class_id , db , updates ):
|
||||
try :
|
||||
r = db.query(Classes).filter(Classes.id ==class_id , Classes.is_deleted == 0 ).update(updates)
|
||||
except :
|
||||
db.rollback()
|
||||
return False
|
||||
else :
|
||||
db.commit()
|
||||
return r
|
||||
|
||||
# ————定义班级表"更新"信息的函数————
|
||||
def update_classes_dao( class_id , db , updates ): # 定义函数，设置三个形参class_id，db ，updates
|
||||
try : # 执行以下可能报错的代码
|
||||
db.query(Classes).filter(Classes.id ==class_id , Classes.is_deleted == 0 ).update(updates) # 将接口函数接收的更新数据更新到Classes模型对象，条件是未删除且前端输入的id和数据库id可以匹配上的
|
||||
except : # 捕获异常：
|
||||
db.rollback() # 如果中间出错，回滚事务，防止产生脏数据
|
||||
return False # 返回 False，返回接口，表示操作失败
|
||||
else : # 执行成功：
|
||||
db.commit() # 提交事务：将数据真正持久化写入到数据库中
|
||||
return True # 返回 True，返回接口，表示操作成功
|
||||
|
||||
|
||||
def get_classes_dao( class_id, class_no , class_name , page , page_size , db ):
|
||||
q = db.query( Classes ).filter( Classes.is_deleted == 0 )
|
||||
if class_id :
|
||||
q = q.filter( Classes.id == class_id )
|
||||
if class_no :
|
||||
q = q.filter( Classes.class_no == class_no )
|
||||
if class_name :
|
||||
q = q.filter( Classes.class_name == class_name )
|
||||
total = q.count()
|
||||
r = q.offset( ( page-1 ) * page_size ).limit( page_size ).all()
|
||||
return total,[ { 'class_id':i.id
|
||||
, 'class_no':i.class_no
|
||||
, 'class_name':i.class_name
|
||||
, 'start_date':i.start_date
|
||||
, 'end_date':i.end_date
|
||||
, 'created_at':i.created_at
|
||||
, 'update_at':i.update_at
|
||||
, 'remark':i.remark
|
||||
}
|
||||
for i in r
|
||||
]
|
||||
# ————定义班级表"查询"信息的函数————
|
||||
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变量总条数 和 将查询结果列表转换为字典列表的数据
|
||||
{
|
||||
'class_id':i.id # 提取班级ID
|
||||
, 'class_no':i.class_no # 提取班级编号
|
||||
, 'class_name':i.class_name # 提取班级名称
|
||||
, 'start_date':i.start_date # 提取开课日期
|
||||
, 'end_date':i.end_date # 提取结课日期
|
||||
, 'created_at':i.created_at # 提取创建时间
|
||||
, 'update_at':i.update_at # 提取更新时间
|
||||
, 'remark':i.remark # 提取备注信息
|
||||
}
|
||||
for i in r # 循环遍历查询出的每一行数据 i
|
||||
]
|
||||
|
||||
|
||||
|
||||
def delete_classes_dao( class_id , db ):
|
||||
try :
|
||||
db.query( Classes ).filter( Classes.id == class_id , Classes.is_deleted == 0 ).update( {"is_deleted": 1} )
|
||||
except :
|
||||
db.rollback()
|
||||
return False
|
||||
else :
|
||||
db.commit()
|
||||
return True
|
||||
# ————定义班级表"删除"信息的函数————
|
||||
def delete_classes_dao( class_id , db ): # 定义函数，设置两个个形参class_id，db
|
||||
try : # 执行以下可能报错的代码
|
||||
db.query( Classes ).filter( Classes.id == class_id , Classes.is_deleted == 0 ).update( {"is_deleted": 1} ) # 将未删除且前端输入的id和数据库id可以匹配上的数据更新is_deleted字段为1，表示已逻辑删除
|
||||
except : # 捕获异常：
|
||||
db.rollback() # 如果中间出错，回滚事务，防止产生脏数据
|
||||
return False # 返回 False，返回接口，表示操作失败
|
||||
else : # 执行成功：
|
||||
db.commit() # 提交事务：更新is_deleted字段为1，表示已逻辑删除，前端无法查询到已逻辑删除的数据
|
||||
return True # 返回 True，返回接口，表示操作成功
|
||||
|
||||
+22
-1
@@ -1,4 +1,3 @@
|
||||
from sqlalchemy import DECIMAL
|
||||
from models.score import Score
|
||||
|
||||
def post_score_dao(data_dict, db):
|
||||
@@ -59,6 +58,28 @@ def get_score_dao(score_id, student_id, exam_seq, page, page_size, db):
|
||||
]
|
||||
return total, res_list
|
||||
|
||||
def get_all_scores_dao(page, page_size, db):
|
||||
r = db.query(Score).filter(Score.is_deleted == 0)\
|
||||
.order_by(Score.student_id, Score.exam_seq)
|
||||
total = r.count() # 总条数
|
||||
rows = r.offset((page-1)*page_size).limit(page_size).all()# 分页
|
||||
res_list_all = [
|
||||
{
|
||||
"id": i.id,
|
||||
"student_id": i.student_id,
|
||||
"score": i.score,
|
||||
"exam_seq": i.exam_seq,
|
||||
"exam_date": i.exam_date,
|
||||
"remark": i.remark,
|
||||
"created_at": i.created_at,
|
||||
"updated_at": i.updated_at,
|
||||
"is_deleted": i.is_deleted
|
||||
}
|
||||
for i in rows
|
||||
]
|
||||
return total,res_list_all
|
||||
|
||||
|
||||
|
||||
def delete_score_dao(score_id, db):
|
||||
"""逻辑删除，更新is_deleted=1"""
|
||||
|
||||
Reference in New Issue
Block a user