蒋立建
This commit is contained in:
@@ -1,7 +1,7 @@
|
|||||||
from fastapi import APIRouter, Depends
|
from fastapi import APIRouter, Depends
|
||||||
from util.database import get_db
|
from util.database import get_db
|
||||||
from schema.cla_schema import claRequest
|
from schema.cla_schema import claRequest
|
||||||
from dao.cla_dao import add_class_dao,get_class_dao,update_class_dao,delete_class_dao,get_class_for_delete,hard_delete_class
|
from dao.cla_dao import add_class_dao,get_class_dao,update_class_dao,delete_class_dao
|
||||||
|
|
||||||
claAPI = APIRouter(prefix="/class", tags=["班级管理"])
|
claAPI = APIRouter(prefix="/class", tags=["班级管理"])
|
||||||
|
|
||||||
@@ -21,12 +21,5 @@ def update_class(class_id: int, data: claRequest, Session = Depends(get_db)):
|
|||||||
def delete_class(class_id: int, Session = Depends(get_db)):
|
def delete_class(class_id: int, Session = Depends(get_db)):
|
||||||
return delete_class_dao(class_id, Session)
|
return delete_class_dao(class_id, Session)
|
||||||
|
|
||||||
@claAPI.get("/delete/check/{class_id}", summary="硬删除前查询")
|
|
||||||
def check_delete(class_id: int, Session = Depends(get_db)):
|
|
||||||
return get_class_for_delete(class_id, Session)
|
|
||||||
|
|
||||||
@claAPI.delete("/delete/confirm/{class_id}", summary="删除班级信息")
|
|
||||||
def confirm_delete(class_id: int, Session = Depends(get_db)):
|
|
||||||
return hard_delete_class(class_id, Session)
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
@@ -40,44 +40,7 @@ def delete_class_dao(id:int,session):
|
|||||||
raise HTTPException(status_code=404, detail="删除异常,请重新核对之后删除!")
|
raise HTTPException(status_code=404, detail="删除异常,请重新核对之后删除!")
|
||||||
return '删除成功,请核对信息!'
|
return '删除成功,请核对信息!'
|
||||||
|
|
||||||
def get_class_for_delete(id: int, session):
|
|
||||||
try:
|
|
||||||
obj = (
|
|
||||||
session.query(ClassManagement).filter(ClassManagement.class_id == id,ClassManagement.delete_status == 0).first()
|
|
||||||
)
|
|
||||||
if not obj:
|
|
||||||
raise HTTPException(status_code=404, detail="班级不存在")
|
|
||||||
except HTTPException:
|
|
||||||
raise
|
|
||||||
except Exception:
|
|
||||||
raise HTTPException(status_code=500, detail="查询异常,请重新核对!")
|
|
||||||
|
|
||||||
return {
|
|
||||||
"class_id": obj.class_id,
|
|
||||||
"class_name": obj.class_name,
|
|
||||||
"start_class_date": obj.start_class_date,
|
|
||||||
"head_teacher_id": obj.head_teacher_id,
|
|
||||||
"class_teacher_id": obj.class_teacher_id,
|
|
||||||
}
|
|
||||||
|
|
||||||
def hard_delete_class(id: int, session):
|
|
||||||
try:
|
|
||||||
obj = (
|
|
||||||
session.query(ClassManagement).filter(ClassManagement.class_id == id,ClassManagement.delete_status == 0)
|
|
||||||
.first()
|
|
||||||
)
|
|
||||||
if not obj:
|
|
||||||
raise HTTPException(status_code=404, detail="班级不存在")
|
|
||||||
|
|
||||||
session.delete(obj)
|
|
||||||
session.commit()
|
|
||||||
except HTTPException:
|
|
||||||
raise
|
|
||||||
except Exception:
|
|
||||||
session.rollback()
|
|
||||||
raise HTTPException(status_code=500, detail="删除异常,请重新核对之后删除!")
|
|
||||||
|
|
||||||
return '删除成功,请核对信息!'
|
|
||||||
|
|
||||||
|
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user