FastAPI（七十五）实战开发《在线课程学习系统》接口开发-- 创建课程

Posted 2022-04-04 北漂的雷子

上次我们分享了，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)