# 班级api模块
from fastapi import APIRouter,Depends,HTTPException    # 导入fastapi模块下的APIRouter,Depends,HTTPException
from schemas.class_schema import *                     # 从schemas包下的class_schema模块导入所有请求体、响应体
from core.database import get_db                       # 从core包下的database模块导入get_db上下文管理器，调用get_db函数可以自动开启关闭与数据库的会话
from dao.class_dao import *                            # 从dao包下的class_dao模块导入所有函数

# 实例化班级路由对象
classes_router = APIRouter()


#以下分别定义增、删、改、查的路由的接口函数，以便api接口函数中执行

# ————定义班级表"更新"信息的"接口"函数————
@classes_router.post('/',response_model=ClassResponse,summary='新增班级信息')        # 定义班级创建路由，POST请求，指定返回数据格式为 ClassResponse
def post_classes(classes:ClassCreate,db=Depends(get_db)):          # 定义更新接口函数，参数classes声明创建请求模型，参数db依赖于数据库会话的上下文管理器
    c = classes.model_dump()                                       # 变量c用来接收通过model_dump将Pydantic模型对象解析为Python的字典，方便后续解包传参
    r = post_classes_dao( c , db )                                 # 变量r用来接收dao层post_classes_dao函数的返回值，执行函数时以变量c的数据和db依赖函数入参
    if r :                                                         # 判断 DAO 层的返回结果，如果为True
        return ClassResponse( total=1,data=c )                     # 返回成功响应，携带新增的数据给前端
    else :                                                         # 如果为False
        raise HTTPException(status_code=500,detail='添加失败，服务器繁忙，请稍后添加！') # 抛出 500 内部服务器错误 和提示


@classes_router.put('/{id}',response_model=ClassResponse,summary='更新班级信息')
def put_classes(id:int,classes:ClassUpdate,db=Depends(get_db)):
    updates = classes.model_dump( exclude_unset=True )
    r = update_classes_dao( id , db , updates )
    if not r :
        raise HTTPException(status_code=500, detail='更新失败，该班级已不存在或服务器繁忙，请稍后更新！')
    else :
        return ClassResponse(detail='更新成功', total=1)


@classes_router.get('',summary='查询班级信息')
def get_classes( id:int|None = None
               , class_no:str|None = None
               , class_name:str|None = None
               , page:int = 1
               , page_size:int = 5
               , db=Depends(get_db)
               ):
    t,r = get_classes_dao( id , class_no , class_name , page , page_size ,db )
    if t != 0 :
        return ClassResponse( total = t, data = r )
    else :
        return ClassResponse( code = 404,detail = '没有符合条件的班级，请检查输入是否有误')


@classes_router.delete('/{id}',response_model=ClassResponse,summary='删除班级信息')
def delete_classes(id:int,db=Depends(get_db)):
    r = update_classes_dao( id , db )
    if r :
        return ClassResponse( total=1,data='已成功删除班级信息' )
    else :
        raise HTTPException(status_code=500, detail='删除失败，该班级信息已不存在或服务器繁忙，请稍后更新！')