做网站的软件是什么,企业中层管理人员培训课程,建设个人网银网站,公司logo图标源码见#xff1a;fastapi_study_road-learning_system_online_courses: fastapi框架实战之--在线课程学习系统
在之前的文章#xff1a;FastAPI#xff08;六十九)实战开发《在线课程学习系统》接口开发--修改密码#xff0c;这次分享留言功能开发
我们梳理…源码见fastapi_study_road-learning_system_online_courses: fastapi框架实战之--在线课程学习系统
在之前的文章FastAPI六十九)实战开发《在线课程学习系统》接口开发--修改密码这次分享留言功能开发
我们梳理下对应的逻辑 1.校验用户是否登录 2.校验留言的用户是否存在 3.校验用户是否和留言的用户一致 4.校验留言长度是否符合要求 5.增加留言 从这里开始是留言相关的接口因此我新建了以下几个文件来单独维护留言相关接口逻辑 首先看下对应的pydantic参数模型 -*- encodingutf-8 -*-
Time: 2024/7/23 15:31
Author: lc
Email: 15101006331163.com
File: message_method.pyfrom pydantic import BaseModel, Fieldclass MessageContent(BaseModel):accept_uid: int # 接收留言用户idcontent: str Field(min_length5, max_length500)
接下来实现接口逻辑message_method.py -*- encodingutf-8 -*-
Time: 2024/7/23 15:31
Author: lc
Email: 15101006331163.com
File: message_method.pyimport traceback
from datetime import datetime
from sqlalchemy.orm import Sessionfrom methods.user_method import get_by_username, get_by_uid
from models.message_schemas import MessageContent
from models.models import Message
from models.user_schema import UsernameRole
from common.log import logger
from common.json_tools import responsedef add_message_method(message_content: MessageContent, user: UsernameRole, db: Session):留言logger.info(f用户:{user.username}来留言了)accept_user get_by_uid(db, message_content.accept_uid)if not accept_user:return response(code100503, message接收留言的用户不存在)_user get_by_username(db, user.username)if accept_user.id _user.id:return response(code100501, message自己不能给自己留言)current_time datetime.strftime(datetime.now(), %Y-%m_%d %H:%M:%S)try:message Message(send_user_user.id,accept_useraccept_user.id,contextmessage_content.content,send_timecurrent_time,add_timecurrent_time)db.add(message)db.commit()db.refresh(message)except:logger.warning(fmethod add_message_method error{traceback.format_exc()})return response(code100502, message留言失败)logger.info(f用户{user.username}留言成功)return response()
在message.py中实现接口 -*- encodingutf-8 -*-
Time: 2024/7/23 15:31
Author: lc
Email: 15101006331163.com
File: message_router.pyfrom fastapi import APIRouter, Depends
from sqlalchemy.orm import Sessionfrom middlewares.mysql.database import create_db
from models.message_schema import *
from models.user_schema import UsernameRole
from methods.user_method import get_current_user
from methods.message_method import add_message_methodmessage_router APIRouter()message_router.post(/, summary留言)
async def add_message(message_content: MessageContent,user: UsernameRole Depends(get_current_user),db: Session Depends(create_db)
):return add_message_method(message_content, user, db)
最后将留言相关路由注册到main.py中的app下
from routers.message import message_routerapp.include_router(message_router, prefix/message, tags[messages])
测试 至此留言接口完成。
