Compare commits

...
3 Commits
Author SHA1 Message Date
msj 9f87dd25d1 Merge remote-tracking branch 'origin/conding' into conding 2026-09-22 22:37:35 +08:00
msj 59f2139c63 1 2026-09-22 22:37:29 +08:00
he 9dc3fc6162 nb 2026-09-22 21:40:13 +08:00
5 changed files with 81 additions and 67 deletions
+7 -6
View File
@@ -19,6 +19,13 @@ def get_grade(stu_id: int,db=Depends(get_db)):
except Exception as e:
raise HTTPException(status_code=500,detail=f'数据库查询异常:{str(e)}')
@gradeAPI.delete('/{stu_id}',summary='删除成绩')
def delete_grade(stu_id:int,db=Depends(get_db)):
r = delete_grade_dao(stu_id=stu_id,db=db)
if not r:
raise HTTPException(status_code=404,detail='删除失败')
return {'code':200,'totals':r,'detail':'删除成功'}
@gradeAPI.post('/grade',summary='添加学生成绩')
def post_grade(o:GradeRequest,db=Depends(get_db)):
d=o.model_dump()
@@ -72,9 +79,3 @@ def put_grade(
return {"code": 200, "totals": rows, "detail": "更新成功"}
@gradeAPI.delete('/{score_id}',summary='删除成绩')
def delete_grade(score_id:int,db=Depends(get_db)):
r = delete_grade_dao(stu_id=score_id,db=db)
if not r:
raise HTTPException(status_code=404,detail='删除失败')
return {'code':200,'totals':r,'detail':'删除成功'}
+20 -20
View File
@@ -1,4 +1,4 @@
from fastapi import APIRouter,HTTPException,Depends
from fastapi import APIRouter,HTTPException,Depends,Query
from dao.student_dao import *
from schema.student_schema import *
from util.database import get_db
@@ -6,24 +6,6 @@ from util.database import get_db
StudentAPI = APIRouter(tags=['学生基本信息管理模块'])
@StudentAPI.get('/students',response_model=StuPageResponse,summary='学生信息查询接口',description='查询学生信息')
def get_students(stu_id:int|None=None
,stu_name:str|None=None
,class_id:int|None=None
,db=Depends(get_db)
,page:int=1
,page_size:int=10):
r, total = get_student_dao(stu_id=stu_id
,stu_name=stu_name
,class_id=class_id
,page=page
,page_size=page_size
,db=db)
return StuPageResponse(page=page,
page_size=page_size,
totals=total,
data=r)
@StudentAPI.post('/students',response_model=StugetResponse,summary='学生信息新增接口',description='新增学生信息')
def add_students(s:StudentRequest
,db=Depends(get_db)):
@@ -37,6 +19,24 @@ def add_students(s:StudentRequest
raise HTTPException(status_code=500, detail='添加失败,请稍后重试')
return r
@StudentAPI.get('/students',response_model=StuPageResponse,summary='学生信息查询接口',description='查询学生信息')
def get_students(stu_id:int=Query(None,description='学生id')
,stu_name:str=Query(None,description='学生姓名')
,class_id:int=Query(None,description='班级编号')
,db=Depends(get_db)
,page:int=Query(None,description='页数')
,page_size:int=Query(None,description='行数')):
r, total = get_student_dao(stu_id=stu_id
,stu_name=stu_name
,class_id=class_id
,page=page
,page_size=page_size
,db=db)
return StuPageResponse(page=page
,page_size=page_size
,totals=total
,data=r)
@StudentAPI.put('/students/{stu_id}',summary='学生信息更新接口',description='更新学生信息')
def update_students(stu_id:int
,s:StuUpdateRequest
@@ -53,7 +53,7 @@ def update_students(stu_id:int
return {'code':200,'totals':r,'detail':'更新成功'}
@StudentAPI.delete('/students/{stu_id}',response_model= StudelResponse,summary='学生信息删除接口',description='删除学生信息')
def del_students(stu_id:int
def del_students(stu_id:int=Query(None,description='班级编号')
,db=Depends(get_db)):
rows=delete_student_dao( stu_id=stu_id,db=db )
if not rows:
+14 -8
View File
@@ -19,14 +19,19 @@ def get_score_by_stu_exam_order_dao(stu_id:str,exam_order:int,db):
def get_grade_dao( stu_id:int , db):
r1 =(db.query( WlScore.score_id
,WlScore.stu_id
,Student_Model.stu_name
,WlScore.exam_order
,WlScore.score
r1 =(db.query( WlScore.score_id
,WlScore.stu_id
,Student_Model.stu_name
,WlScore.exam_order
,WlScore.score
,ClassManagement.class_name
)
.join(Student_Model,WlScore.stu_id == Student_Model.stu_id)
.filter(WlScore.stu_id == stu_id,WlScore.delete_status == 0,Student_Model.delete_status == 0)
.join( Student_Model,WlScore.stu_id == Student_Model.stu_id)
.join(ClassManagement,Student_Model.class_id==ClassManagement.class_id)
.filter( WlScore.stu_id == stu_id
,WlScore.delete_status == 0
,Student_Model.delete_status == 0
,ClassManagement.delete_status == 0)
.all())
if r1:
data_list = []
@@ -36,7 +41,8 @@ def get_grade_dao( stu_id:int , db):
"stu_id": row.stu_id,
"stu_name": row.stu_name,
"exam_order": row.exam_order,
"score": row.score
"score": row.score,
"class_name": row.class_name,
})
return data_list
else:
+31 -31
View File
@@ -5,11 +5,11 @@ from sqlalchemy.exc import IntegrityError
def add_student_dao(o,db):
if o.get('id_card'):
conflict = (db.query(Student_Model)
o1 = (db.query(Student_Model)
.filter(Student_Model.id_card == o['id_card'],
Student_Model.delete_status == 0)
.first())
if conflict:
if o1:
return 'conflict'
try:
o2 = Student_Model(**o)
@@ -23,35 +23,6 @@ def add_student_dao(o,db):
db.rollback()
return 'error'
def delete_student_dao(stu_id, db):
try:
rows = (db.query(Student_Model)
.filter(Student_Model.stu_id == stu_id,
Student_Model.delete_status == 0)
.update({'delete_status': 1, 'delete_time': datetime.now()}))
db.commit()
return rows
except Exception:
db.rollback()
raise
def update_student_dao(stu_id, update_data, db):
if not update_data:
return 0
try:
rows = (db.query(Student_Model)
.filter(Student_Model.stu_id == stu_id,
Student_Model.delete_status == 0)
.update(update_data))
db.commit()
except IntegrityError:
db.rollback()
return 'conflict'
except Exception:
db.rollback()
return 'error'
return rows
def get_student_dao(stu_id:Optional[int]
,stu_name:Optional[str]
,class_id:Optional[int]
@@ -69,3 +40,32 @@ def get_student_dao(stu_id:Optional[int]
total = q.count()
r = q.offset((page - 1) * page_size).limit(page_size).all()
return r, total
def update_student_dao(stu_id, update_data, db):
if not update_data:
return 0
try:
rows = (db.query(Student_Model)
.filter(Student_Model.stu_id == stu_id,
Student_Model.delete_status == 0)
.update(update_data))
db.commit()
except IntegrityError:
db.rollback()
return 'conflict'
except Exception:
db.rollback()
return 'error'
return rows
def delete_student_dao(stu_id, db):
try:
rows = (db.query(Student_Model)
.filter(Student_Model.stu_id == stu_id,
Student_Model.delete_status == 0)
.update({'delete_status': 1, 'delete_time': datetime.now()}))
db.commit()
return rows
except Exception:
db.rollback()
raise
+9 -2
View File
@@ -1,5 +1,5 @@
from datetime import date
from typing import Self,List
from typing import Self,List,Optional
from pydantic import BaseModel, field_serializer, field_validator,model_validator,ConfigDict
@@ -53,6 +53,13 @@ class StuUpdateRequest(BaseModel):
raise ValueError('年龄不能为负数')
return v
@field_validator('id_card')
@classmethod
def check_id_card(cls, v):
if len(v) != 18 or len(v) != 19 :
raise ValueError('身份证输入有误')
return v
@model_validator(mode='after')
def check_admission_graduation(self) -> Self:
if self.admission_date and self.graduation_date:
@@ -77,7 +84,7 @@ class StugetResponse(BaseModel):
degree: str | None = None
admission_date: date | None = None
graduation_date: date | None = None
progress: int
progress: Optional[int]
@field_serializer('progress')
def progress_to_label(self, progress):