112 lines
4.0 KiB

8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
8 months ago
  1. from fastapi import Depends, APIRouter, status, Query, Path, HTTPException
  2. from internal.models import *
  3. from internal.database import fetch_one, fetch_all, execute_query, response_success, raise_if_exists, raise_if_not_found
  4. from dependencies import get_current_active_user
  5. from collections import defaultdict
  6. router = APIRouter(
  7. prefix="/statistics",
  8. tags=['统计']
  9. )
  10. # 统计编辑量
  11. @router.get("/list")
  12. async def statistic_list():
  13. select_query = """SELECT DATE(create_at) AS date,COUNT(*) AS writCount FROM
  14. (SELECT create_at FROM diarys
  15. UNION ALL
  16. SELECT create_at FROM blogs) AS combined
  17. GROUP BY DATE
  18. ORDER BY DATE DESC;"""
  19. statistic_list = fetch_all(select_query)
  20. return response_success(statistic_list, "statistic get list success")
  21. # 记录所有blog和diary数据
  22. # 获取首页数据
  23. @router.get("/homepage")
  24. async def get_homepage_data():
  25. # 获取博客数据
  26. select_blog = """
  27. SELECT blogs.id, blogs.blogtitle, blogs.blogcontent, blogs.create_at, blogs.imglink,
  28. blogs.wordcount, blogtypes.typename, JSON_ARRAYAGG(labels.labelname) AS labelnames
  29. FROM blogs
  30. LEFT JOIN `blogtypes` ON blogs.typeid = blogtypes.id
  31. LEFT JOIN blog_label ON blog_label.blogid = blogs.id
  32. LEFT JOIN labels ON blog_label.labelid = labels.id
  33. GROUP BY blogs.id, blogs.blogtitle, blogs.blogcontent, blogs.create_at, blogs.imglink,
  34. blogs.wordcount, blogtypes.typename
  35. ORDER BY create_at DESC
  36. """
  37. blog_list = fetch_all(select_blog)
  38. # 获取日记数据
  39. select_diary = """
  40. SELECT diarys.id, diarys.diarytitle, diarys.diarycontent, diarys.imglink,
  41. diarytypes.typename, diarys.create_at, diarys.update_at
  42. FROM diarys
  43. LEFT JOIN diarytypes ON diarys.typeid = diarytypes.id
  44. ORDER BY create_at DESC
  45. """
  46. diary_list = fetch_all(select_diary)
  47. # 合并博客和日记数据,按照创建日期降序排序
  48. combined_data = sorted(blog_list + diary_list, key=lambda x: x['create_at'], reverse=True)
  49. return {"data": combined_data}
  50. @router.get("/searchtitle")
  51. async def search_homepage_data(title: str = Query("", description="Title to search for")):
  52. # 查询博客数据
  53. select_blog = """
  54. SELECT
  55. blogs.id,
  56. blogs.blogtitle,
  57. blogs.blogcontent,
  58. blogs.create_at,
  59. blogs.imglink,
  60. blogs.readnum,
  61. blogs.wordcount,
  62. blogtypes.typename,
  63. JSON_ARRAYAGG(labels.labelname) AS labelnames
  64. FROM blogs
  65. LEFT JOIN blogtypes ON blogs.typeid = blogtypes.id
  66. LEFT JOIN blog_label ON blog_label.blogid = blogs.id
  67. LEFT JOIN labels ON blog_label.labelid = labels.id
  68. WHERE blogs.blogtitle LIKE %s
  69. GROUP BY
  70. blogs.id,
  71. blogs.blogtitle,
  72. blogs.blogcontent,
  73. blogs.create_at,
  74. blogs.imglink,
  75. blogs.wordcount,
  76. blogtypes.typename
  77. ORDER BY create_at DESC
  78. """
  79. blog_list =fetch_all(select_blog, ('%' + title + '%',))
  80. # 查询日记数据
  81. select_diary = """
  82. SELECT
  83. diarys.id,
  84. diarys.diarytitle,
  85. diarys.diarycontent,
  86. diarys.readnum,
  87. diarys.imglink,
  88. diarytypes.typename,
  89. diarys.create_at,
  90. diarys.update_at
  91. FROM diarys
  92. LEFT JOIN diarytypes ON diarys.typeid = diarytypes.id
  93. WHERE diarys.diarytitle LIKE %s
  94. ORDER BY create_at DESC
  95. """
  96. diary_list =fetch_all(select_diary, ('%' + title + '%',))
  97. # 合并博客和日记数据,按照创建日期降序排序
  98. filtered_blog_list = [item for item in blog_list if item.get('create_at')]
  99. filtered_diary_list = [item for item in diary_list if item.get('create_at')]
  100. combined_list = filtered_blog_list + filtered_diary_list
  101. combined_data = sorted(combined_list, key=lambda x: x['create_at'], reverse=True)
  102. return {"data": combined_data}