已优化get方法以及修改delete删除过后还显示删除成功的问题

Reviewed-on: #43

api/class_api.py

@@ -47,18 +47,19 @@ def get_classes( id:int|None = None                                  # id参数
         return ClassResponse( code = 404,detail = '没有符合条件的班级，请检查输入是否有误')    # 返回404响应，提示没有符合条件的提示给前端
 
 
-@classes_router.get('/student-count', summary='查询每个班级学生人数')
-def get_class_student_count( class_id:int|None = None
+# ————定定义查询符合查询条件的班级的总学生人数信息的接口函数————
+@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)
-    if r:
-        return ClassResponse(total=t, data=r)
-    return ClassResponse(code=404, detail='没有班级数据')
+    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响应，提示没有符合条件的提示给前端
 
 
 

api/score.py

@@ -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, get_all_scores_dao,delete_score_dao, exist_student_exam_dao
+from dao.score import post_score_dao, update_score_dao, get_score_dao,delete_score_dao, exist_student_exam_dao
 from schemas.score import ScoreCreate, ScoreUpdate, ScorePageResp
 
 scores_router = APIRouter(prefix="/scores", tags=["成绩接口"])
@@ -32,14 +32,6 @@ def list_score(
 
 
 
-@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)):

dao/class_dao.py

@@ -37,7 +37,7 @@ def get_classes_dao( class_id, class_no , class_name , page , page_size , db ):
         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变量接收满足当前所有过滤条件的数据总条数
+    total = q.count()                                                             # total变量接收满足当前所有过滤条件的数据总条数
     r = q.offset( ( page-1 ) * page_size  ).limit( page_size ).all()              # 变量r用来接收查询取出结果列表，计算分页偏移量（从第几行开始查），设置分页限制条数
     return total , [                                                              # 返回 total变量总条数 和 将查询结果列表转换为字典列表的数据
                      {
@@ -54,28 +54,30 @@ def get_classes_dao( class_id, class_no , class_name , page , page_size , db ):
                     ]
 
 
-from sqlalchemy import func, and_,desc
-from models.student import Student
 
-def get_class_student_count_dao(class_id,class_no,class_name,page,page_size,db):
-    q = db.query (  Classes.id.label('class_id')
-                  , Classes.class_no
-                  , Classes.class_name
-                  , func.count(Student.id).label('student_count')
+# ————定义查询符合查询条件的班级的总学生人数信息的函数————
+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)
-    q = q.order_by(  desc('student_count') )
-    total = q.count()                                                             # tatal变量接收满足当前所有过滤条件的数据总条数
-    r = q.offset( ( page-1 ) * page_size  ).limit( page_size ).all()
-    return total,[                                                              # 返回 total变量总条数 和 将查询结果列表转换为字典列表的数据
+                  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                  # 提取班级编号

dao/score.py

@@ -5,23 +5,27 @@ def post_score_dao(data_dict, db):
     try:
         obj = Score(**data_dict)
         db.add(obj)
+        db.commit()
     except Exception as e:
         print("新增成绩异常：", e)
         db.rollback()
         return False
     else:
-        db.commit()
         return True
 
 
 def update_score_dao(score_id, db, updates):
     """修改成绩，query.update方式"""
     try:
-        db.query(Score).filter(
+        cnt = db.query(Score).filter(
             Score.id == score_id,
             Score.is_deleted == 0
         ).update(updates)
-    except Exception:
+        if cnt == 0:
+            db.rollback()
+            return False
+    except Exception as e:
+        print("修改成绩异常：", e)
         db.rollback()
         return False
     else:
@@ -30,14 +34,25 @@ def update_score_dao(score_id, db, updates):
 
 
 def get_score_dao(score_id, student_id, exam_seq, page, page_size, db):
-    """分页查询成绩，多条件过滤，只查未删除"""
+    """分页查询成绩，多条件过滤，只查未删除
+    规则：
+      - score_id == 0                → 查所有学生成绩（仅分页，不加 id 过滤）
+      - 三个筛选条件全为空（None）   → 直接返回空，不查库
+      - 其他情况                     → 按传入条件过滤
+    """
     q = db.query(Score).filter(Score.is_deleted == 0)
-    if score_id:
-        q = q.filter(Score.id == score_id)
-    if student_id:
-        q = q.filter(Score.student_id == student_id)
-    if exam_seq:
-        q = q.filter(Score.exam_seq == exam_seq)
+
+    if score_id == 0:
+        pass                                  # score_id=0 → 查全部（分页）
+    elif score_id is None and not student_id and not exam_seq:
+        return 0, []                          # 三个参数都没传 → 返回空
+    else:
+        if score_id:
+            q = q.filter(Score.id == score_id)
+        if student_id:
+            q = q.filter(Score.student_id == student_id)
+        if exam_seq:
+            q = q.filter(Score.exam_seq == exam_seq)
 
     total = q.count()
     rows = q.offset((page - 1) * page_size).limit(page_size).all()
@@ -58,36 +73,20 @@ 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"""
     try:
-        db.query(Score).filter(
+        cnt = db.query(Score).filter(
             Score.id == score_id,
             Score.is_deleted == 0
-        ).update({"is_deleted": 1})
+        ).update({"is_deleted": 1})     # ← 接住返回值
+        if cnt == 0:                    # ← 关键：一行都没匹配到
+            db.rollback()
+            return False
     except Exception as err:
         print("删除成绩异常：", err)
         db.rollback()