70 lines
2.4 KiB
Python
70 lines
2.4 KiB
Python
from fastapi import APIRouter, Depends, HTTPException
|
|
from schema.score_request import ScoreRequest, ScoreUpdateRequest, ScoreResponse
|
|
from database import get_db
|
|
from dao.score_dao import (
|
|
calc_level, calc_pass,
|
|
add_score_dao, update_score_dao, delete_score_dao, get_scores_dao
|
|
)
|
|
|
|
score_api = APIRouter()
|
|
|
|
|
|
# ========== 1. 添加成绩（按考核序次录入） ==========
|
|
@score_api.post('', response_model=ScoreResponse, summary='添加成绩')
|
|
def add_score(score: ScoreRequest, db=Depends(get_db)):
|
|
d = score.model_dump()
|
|
d['score_level'] = calc_level(d['score']) # ← 调 DAO 的工具函数
|
|
d['is_pass'] = calc_pass(d['score'])
|
|
|
|
r = add_score_dao(o=d, db=db)
|
|
if not r:
|
|
raise HTTPException(
|
|
status_code=500,
|
|
detail='添加失败！'
|
|
)
|
|
return ScoreResponse(totals=1, data=d)
|
|
|
|
|
|
# ========== 2. 查询成绩（动态条件 + 分页） ==========
|
|
@score_api.get('', summary='查询成绩（支持多条件+分页）')
|
|
def get_scores(
|
|
score_id: int = None,
|
|
student_id: str = None,
|
|
course_id: str = None,
|
|
teacher_id: str = None,
|
|
exam_order: int = None,
|
|
page: int = 1,
|
|
page_size: int = 10,
|
|
db=Depends(get_db)
|
|
):
|
|
r = get_scores_dao(
|
|
score_id=score_id, student_id=student_id, course_id=course_id,
|
|
teacher_id=teacher_id, exam_order=exam_order,
|
|
page=page, page_size=page_size, db=db
|
|
)
|
|
if r:
|
|
return r
|
|
raise HTTPException(status_code=404, detail='成绩不存在！')
|
|
|
|
|
|
# ========== 3. 修改成绩 ==========
|
|
@score_api.put('/{score_id}', summary='修改成绩')
|
|
def update_score(score_id: int, score: ScoreUpdateRequest, db=Depends(get_db)):
|
|
d = score.model_dump(exclude_unset=True)
|
|
if 'score' in d:
|
|
d['score_level'] = calc_level(d['score'])
|
|
d['is_pass'] = calc_pass(d['score'])
|
|
|
|
r = update_score_dao(score_id=score_id, update_data=d, db=db)
|
|
if not r:
|
|
raise HTTPException(status_code=500, detail='没有更新！')
|
|
return {'code': 200, 'totals': r, 'detail': '更新成功'}
|
|
|
|
|
|
# ========== 4. 删除成绩（逻辑删除） ==========
|
|
@score_api.delete('/{score_id}', summary='删除成绩(逻辑删除)')
|
|
def delete_score(score_id: int, db=Depends(get_db)):
|
|
r = delete_score_dao(score_id=score_id, db=db)
|
|
if not r:
|
|
raise HTTPException(status_code=500, detail='删除异常，稍后操作！')
|
|
return {'code': 200, 'totals': r, 'detail': '删除成功'} |