94 lines
4.0 KiB
Python
94 lines
4.0 KiB
Python
from typing import List
|
|
|
|
from fastapi import APIRouter, Depends, Query, Request
|
|
from sqlalchemy.orm import Session
|
|
|
|
from config.auth import verify_token
|
|
from schemas.blog import BlogResponse, BlogQuery, BlogCategoryResponse, BlogStatsResponse, \
|
|
BlogLatestResponse, BlogCommentCreate, BlogCommentResponse, BlogVisitResponse, BlogCreate, BlogUpdate
|
|
from schemas.blog_elastic import BlogSearch
|
|
from schemas.pagination import PageResult
|
|
from config.database import get_db
|
|
from service import blog_service, blog_elastic_service
|
|
|
|
router = APIRouter(
|
|
prefix="/blog",
|
|
tags=["博客管理"],
|
|
responses={404: {"description": "Not found"}}
|
|
)
|
|
|
|
|
|
@router.get("/sync", summary="同步博客到elastic", response_model=bool)
|
|
def sync_all_blog(db: Session = Depends(get_db)):
|
|
return blog_elastic_service.sync_all_blog(db)
|
|
|
|
|
|
@router.get("/search", summary="搜索elastic", response_model=List[BlogSearch])
|
|
def search_blog(keyword: str):
|
|
return blog_elastic_service.search_blog(keyword)
|
|
|
|
|
|
@router.get("/page", summary="分页查询博客", response_model=PageResult[BlogResponse])
|
|
def query_blog_by_page(current_page: int = Query(1, ge=1, alias="currentPage", description="当前页码"),
|
|
page_size: int = Query(10, ge=1, le=100, alias="pageSize", description="每页数量"),
|
|
db: Session = Depends(get_db)):
|
|
return blog_service.query_blog_by_page(db, current_page, page_size)
|
|
|
|
|
|
@router.get("/condition", summary="条件查询博客", response_model=List[BlogResponse])
|
|
def query_blog_by_condition(query: BlogQuery = Depends(),
|
|
db: Session = Depends(get_db)):
|
|
return blog_service.query_blog_by_condition(db, query)
|
|
|
|
|
|
@router.get("/content/{blog_id}", summary="查询博客内容", response_model=BlogResponse)
|
|
def query_blog_by_id(blog_id: int, db: Session = Depends(get_db)):
|
|
return blog_service.query_blog_by_id(db, blog_id)
|
|
|
|
|
|
@router.post("", summary="新增博客内容", response_model=bool)
|
|
def add_blog(blog: BlogCreate, db: Session = Depends(get_db), _=Depends(verify_token)):
|
|
return blog_service.add_blog(db, blog)
|
|
|
|
|
|
@router.put("/{blog_id}", summary="更新博客内容", response_model=bool)
|
|
def update_blog(blog_id: int, blog: BlogUpdate, db: Session = Depends(get_db), _=Depends(verify_token)):
|
|
return blog_service.update_blog(db, blog_id, blog)
|
|
|
|
|
|
@router.delete("/{blog_id}", summary="删除博客内容", response_model=bool)
|
|
def delete_blog(blog_id: int, db: Session = Depends(get_db), _=Depends(verify_token)):
|
|
return blog_service.delete_blog(db, blog_id)
|
|
|
|
|
|
@router.get("/category", summary="查询博客分类", response_model=List[BlogCategoryResponse])
|
|
def query_blog_category(db: Session = Depends(get_db)):
|
|
return blog_service.query_blog_category(db)
|
|
|
|
|
|
@router.get("/stats", summary="查询博客统计信息", response_model=BlogStatsResponse)
|
|
def query_blog_stats(db: Session = Depends(get_db)):
|
|
return blog_service.query_blog_stats(db)
|
|
|
|
|
|
@router.get("/visit", summary="查询博客访问信息", response_model=PageResult[BlogVisitResponse])
|
|
def query_blog_visit(current_page: int = Query(1, ge=1, alias="currentPage", description="当前页码"),
|
|
page_size: int = Query(10, ge=1, le=100, alias="pageSize", description="每页数量"),
|
|
db: Session = Depends(get_db)):
|
|
return blog_service.query_blog_visit(db, current_page, page_size)
|
|
|
|
|
|
@router.get("/latest", summary="查询近期博客", response_model=list[BlogLatestResponse])
|
|
def query_blog_latest(db: Session = Depends(get_db)):
|
|
return blog_service.query_blog_latest(db)
|
|
|
|
|
|
@router.put("/comment", summary="新增博客评论", response_model=bool)
|
|
def add_blog_comment(blog_comment: BlogCommentCreate, request: Request, db: Session = Depends(get_db)):
|
|
return blog_service.add_blog_comment(db, request, blog_comment)
|
|
|
|
|
|
@router.get("/comment/{blog_id}", summary="查询博客评论", response_model=list[BlogCommentResponse])
|
|
def query_blog_comment(blog_id: int, db: Session = Depends(get_db)):
|
|
return blog_service.query_blog_comment(db, blog_id)
|