forked from wolin_ck666_999/StuManagerSys
38 lines
1.3 KiB
Python
38 lines
1.3 KiB
Python
from fastapi import APIRouter,HTTPException,Depends
|
|
from database import Session
|
|
from model.e_model import Employment
|
|
from schema.e_schema import EmploymentRequest
|
|
from dao.e_dao import get_employment_dao,wq_employment_dao,upd_employment_dao,del_employment_dao
|
|
employment_api = APIRouter()
|
|
|
|
|
|
def get_db():
|
|
db = Session()
|
|
try:
|
|
yield db
|
|
finally:
|
|
db.close()
|
|
@employment_api.get('/',summary='查询就业信息')
|
|
def get_employment(db=Depends(get_db)):
|
|
r = get_employment_dao(db)
|
|
return {'code':200,'detail':'查询成功!','data':r}
|
|
|
|
|
|
@employment_api.post('/',summary='新增就业信息')
|
|
def add_employment(e:EmploymentRequest,db=Depends(get_db)):
|
|
d= e.model_dump()
|
|
r = wq_employment_dao(d,db)
|
|
return {'code':200,'detail':'添加成功!','total':r}
|
|
#
|
|
#
|
|
@employment_api.put('/',summary='更新就业信息')
|
|
def update_employment(e:EmploymentRequest,db=Depends(get_db)):
|
|
e1 = e.model_dump()
|
|
r = upd_employment_dao(e1,db)
|
|
return {'code':200,'msg':'更新成功','total':r}
|
|
#
|
|
@employment_api.delete('/',summary='删除就业信息')
|
|
def delete_employment(stu_id:str,db=Depends(get_db)):
|
|
r =del_employment_dao(stu_id,db)
|
|
return {'code':200,'totals':r,'detail':'删除成功!'}
|