上次我们分享了，FastAPI（七十四）实战开发《在线课程学习系统》接口开发-- 删除留言
还是按照惯例，我们去梳理下对应的逻辑
1.判断用户是否登陆 2.校验是否有权限 3.校验参数是否完整 4.查询课程是否存在 5.创建课程
课程我们需要单独创建一个新的路由来管理
我们在routers去创建course.py
from fastapi import APIRouter from models.crud import * from models.get_db import get_db courseRouter = APIRouter()
接着我们的main.py去引入
from routers.course import courseRouter app.include_router(courseRouter,prefix='/course',tags=['course'])
这样我们的新的路由就生效了。
我们去看下是如何实现创建课程？
首先我们去创建课程创建的pydantic 类。
class Courses(BaseModel): name: str icon: Optional[str] desc: Optional[str] catalog: Optional[str] onsale: Optional[int] owner: str likenum: int
那么我们去实现对应的crud
#创建课程 def db_create_course(db: Session, course: Courses, user: int): course = Course(**course.dict()) course.owner=user db.add(course) db.commit() # 提交保存到数据库中 db.refresh(course) # 刷新 return course #根据课程名称获取 def db_get_course_name(db:Session,name:str): return db.query(Course).filter(Course.name==name,Course.status==False).first()
根据开发中，我们发现之前设计的状态码需要补充
| 101004 | 只有老师才能创建课程 |
| 101005 | 课程名长度应该在2-50 |
| 101006 | 课程上架状态不对 |
那么对应的业务代码最后实现如下
@courseRouter.post(path='/create') async def create(coursescreate:Courses, db: Session = Depends(get_db),user: UsernameRole = Depends(get_cure_user)): user_=get_user_username(db,user.username) user_role=get_role_name(db,user_.role) if not user_role or user_role.mame =="学生": return reponse(code=101004,message='只有老师才能创建课程',data='只有老师才能创建课程') if len(coursescreate.name)>50 or len(coursescreate.name)<2: return reponse(code=101005,message='课程名长度应该在2-50',data='') if coursescreate.onsale !=0 or coursescreate.onsale !=1: return reponse(code=101006,message='课程上架状态不对',data='') name=db_get_course_name(db,coursescreate.name) if name: return reponse(code=101002,message='课程名称不能重复',data='课程名称不能重复') couse=db_create_course(db,coursescreate,user_.id) return reponse(code=200,message='成功',data=couse)
