44 lines
1.8 KiB
Python
44 lines
1.8 KiB
Python
from fastapi import APIRouter,HTTPException,Depends
|
|
from schema.teacher_schema import Teacher_ResponseModel, Teacher_RequestModel
|
|
from dao.teacher_dao import add_teacher
|
|
from util.database import get_db
|
|
from dao.teacher_dao import update_teacher
|
|
from dao.teacher_dao import delete_teacher
|
|
from dao.teacher_dao import get_teacher
|
|
|
|
teacher_api=APIRouter(tags=['教师基本信息管理模块'])
|
|
|
|
@teacher_api.post("/teachers",response_model=Teacher_ResponseModel,summary='新增教师接口')
|
|
def add_teacher1(x1:Teacher_RequestModel,session=Depends(get_db)):
|
|
y=add_teacher(x1.model_dump(),session)
|
|
if not y:
|
|
raise HTTPException(status_code=500,detail='添加异常！')
|
|
return x1
|
|
|
|
@teacher_api.get("/teachers",summary='查询教师接口')
|
|
def get_teacher1(teacid:int, session=Depends(get_db)):
|
|
# r = get_teacher(id=id,session=session)
|
|
# if not r:
|
|
# raise HTTPException(status_code=500, detail='查询异常！')
|
|
try:
|
|
l=get_teacher(teacid,session)
|
|
return {'code': 200,'msg':'查询成功','data':l}
|
|
except:
|
|
raise HTTPException(status_code=500,detail='数据库查询异常!')
|
|
|
|
|
|
@teacher_api.put("/teachers/{t_id}",summary='更新教师接口')
|
|
def update_teacher1(t_id:int,teacher:Teacher_RequestModel,session=Depends(get_db)):
|
|
d=teacher.model_dump(exclude_unset=True)
|
|
r=update_teacher(id=t_id,req=d,session=session)
|
|
if not r:
|
|
raise HTTPException(status_code=500, detail='更新异常！')
|
|
return {'code':200,'detail':'更新成功！','data':teacher}
|
|
|
|
|
|
@teacher_api.delete("/teachers/{t_id}",summary='删除教师接口')
|
|
def delete_teacher1(t_id:int,session=Depends(get_db)):
|
|
r=delete_teacher(id=t_id,session=session)
|
|
if not r:
|
|
raise HTTPException(status_code=500,detail='删除异常！')
|
|
return {'code': 200, 'detail':'删除成功！'} |