马睿智牛逼!

This commit is contained in:
test1
2026-09-21 20:40:35 +08:00
parent 85c3cc6508
commit ab36fa1868
2 changed files with 19 additions and 13 deletions
+11 -8
View File
@@ -2,18 +2,21 @@ from fastapi import APIRouter,HTTPException,Depends
from schema.teacher_schema import Teacher_ResponseModel, Teacher_RequestModel from schema.teacher_schema import Teacher_ResponseModel, Teacher_RequestModel
from dao.teacher_dao import add_teacher from dao.teacher_dao import add_teacher
from util.database import get_db 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() teacher_api=APIRouter()
@teacher_api.post("/teachers",response_model=Teacher_ResponseModel,tags=['教师基本信息管理模块'],summary='新增教师接口') @teacher_api.post("/teachers",response_model=Teacher_ResponseModel,tags=['教师基本信息管理模块'],summary='新增教师接口')
def get_teacher(x1:Teacher_RequestModel,session=Depends(get_db)): def add_teacher1(x1:Teacher_RequestModel,session=Depends(get_db)):
y=add_teacher(x1.model_dump(),session) y=add_teacher(x1.model_dump(),session)
if not y: if not y:
raise HTTPException(status_code=500,detail='添加异常!') raise HTTPException(status_code=500,detail='添加异常!')
return x1 return x1
@teacher_api.get("/teachers",tags=['教师基本信息管理模块'],summary='查询教师接口') @teacher_api.get("/teachers",tags=['教师基本信息管理模块'],summary='查询教师接口')
def get_teacher(teacid:int, session=Depends(get_db)): def get_teacher1(teacid:int, session=Depends(get_db)):
# r = get_teacher(id=id,session=session) # r = get_teacher(id=id,session=session)
# if not r: # if not r:
# raise HTTPException(status_code=500, detail='查询异常!') # raise HTTPException(status_code=500, detail='查询异常!')
@@ -24,17 +27,17 @@ def get_teacher(teacid:int, session=Depends(get_db)):
raise HTTPException(status_code=500,detail='数据库查询异常!') raise HTTPException(status_code=500,detail='数据库查询异常!')
@teacher_api.put("/teachers",response_model=Teacher_ResponseModel,tags=['教师基本信息管理模块'],summary='更新教师接口') @teacher_api.put("/teachers/{t_id}",tags=['教师基本信息管理模块'],summary='更新教师接口')
def update_teacher(id:int,teacher:Teacher_RequestModel,session=Depends(get_db)): def update_teacher1(t_id:int,teacher:Teacher_RequestModel,session=Depends(get_db)):
d=teacher.model_dump() d=teacher.model_dump(exclude_unset=True)
r=update_teacher(id=id,req=d,session=session) r=update_teacher(id=t_id,req=d,session=session)
if not r: if not r:
raise HTTPException(status_code=500, detail='更新异常!') raise HTTPException(status_code=500, detail='更新异常!')
return {'code': 200, 'totals': r, 'detail': '更新成功'} return {'code':200,'detail':'cg'}
@teacher_api.delete("/teachers",response_model=Teacher_ResponseModel,tags=['教师基本信息管理模块'],summary='删除教师接口') @teacher_api.delete("/teachers",response_model=Teacher_ResponseModel,tags=['教师基本信息管理模块'],summary='删除教师接口')
def delete_teacher(id:int,session=Depends(get_db)): def delete_teacher1(id:int,session=Depends(get_db)):
r=delete_teacher(id=id,session=session) r=delete_teacher(id=id,session=session)
if not r: if not r:
raise HTTPException(status_code=500,detail='删除异常!') raise HTTPException(status_code=500,detail='删除异常!')
+8 -5
View File
@@ -25,13 +25,16 @@ def get_teacher(id,session):
else: else:
raise HTTPException(status_code=404,detail='该老师不存在!') raise HTTPException(status_code=404,detail='该老师不存在!')
def update_teacher(teac_id:int,req:Teacher_RequestModel,session): def update_teacher(id:int,req,session):
try: try:
session.query(Teacher_Model).filter(Teacher_Model.teac_id==id)\ r=session.query(Teacher_Model).filter(Teacher_Model.teac_id==id) \
.filter(Teacher_Model.delete_status==0).update(req.model_dump(exclude_unset=True)) .filter(Teacher_Model.delete_status==0).update(req)
session.commit()
except: except:
raise HTTPException(status_code=500,detail="更新异常!") session.rollback()
return False
else:
session.commit()
return r
def delete_teacher(id:int,session): def delete_teacher(id:int,session):
try: try: