diff --git a/api/e_api.py b/api/e_api.py new file mode 100644 index 0000000..68db826 --- /dev/null +++ b/api/e_api.py @@ -0,0 +1,37 @@ +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':'删除成功!'}