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

1.判断用户是否登陆
2.校验是否有权限
3.校验参数是否完整
4.查询课程是否存在
5.创建课程

from fastapi import APIRouter
from models.crud import *
from models.get_db import get_db
courseRouter = APIRouter()

from routers.course import courseRouter
app.include_router(courseRouter,prefix='/course',tags=['course'])

class Courses(BaseModel):
    name: str
    icon: Optional[str]
    desc: Optional[str]
    catalog: Optional[str]
    onsale: Optional[int]
    owner: str
    likenum: int

#创建课程
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()

@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)