lt
277b13eaae
优化内容: 1. 表格布局: - 使用 calc(100vw - 160px) 确保表格不超出视口 - 操作列 fixed='right' 固定在右侧，宽度 300px - 按钮 3 个后自动换行 (max-width: 200px) - 恢复合理列宽，不再过度压缩 2. 批量操作区域: - 容器改为 inline-block，宽度自适应按钮内容 - 背景宽度与按钮总宽度匹配 3. 分类标签: - 显示数量 (如 '待处理 (20)') - 点击切换筛选，去掉误导的 'X' 图标 4. 删除功能: - 操作列增加删除按钮 - 删除前弹出确认对话框 5. 系统日志: - 修复后端日志路径 (parents[4]) - 404 时显示友好提示 6. 其他: - 左侧菜单宽度 160px - 所有功能保留 (登录、用户管理、批量操作等)
90 lines
2.7 KiB
Python
90 lines
2.7 KiB
Python
# 宇之然内容创作平台 - 系统管理API
|
|
|
|
from datetime import datetime, date
|
|
from fastapi import APIRouter, Depends
|
|
from sqlalchemy.orm import Session
|
|
import os
|
|
|
|
from ..database import get_db
|
|
|
|
router = APIRouter()
|
|
|
|
@router.get("/status")
|
|
async def get_system_status(db: Session = Depends(get_db)):
|
|
"""获取系统概览状态"""
|
|
today = date.today()
|
|
|
|
# 统计总数
|
|
total_topics = db.query(func.count(Topic.id)).scalar()
|
|
|
|
# 今日新选题数
|
|
today_articles = db.query(func.count(Topic.id)).filter(
|
|
func.date(Topic.created_at) == today
|
|
).scalar()
|
|
|
|
# 各状态选题数量
|
|
topics_by_status = {}
|
|
for status in ["待处理", "待审查", "待发布", "已发布"]:
|
|
count = db.query(func.count(Topic.id)).filter(
|
|
Topic.status == status
|
|
).scalar()
|
|
topics_by_status[status] = count
|
|
|
|
return {
|
|
"total_topics": total_topics,
|
|
"today_articles": today_articles,
|
|
"topics_by_status": topics_by_status,
|
|
"generated_count": db.query(func.count(Topic.id)).filter(
|
|
Topic.generated_at.isnot(None)
|
|
).scalar(),
|
|
"published_count": db.query(func.count(Topic.id)).filter(
|
|
Topic.published_at.isnot(None)
|
|
).scalar()
|
|
}
|
|
|
|
@router.get("/pipeline/status")
|
|
async def get_pipeline_status():
|
|
"""获取流水线状态"""
|
|
import subprocess
|
|
import json
|
|
|
|
# 检查各个模块的运行状态
|
|
pipeline_modules = {
|
|
"creator": {
|
|
"exists": os.path.exists("modules/creator"),
|
|
"has_error": False, # 简化实现，实际应检查日志或进程状态
|
|
"last_run": get_last_run_time("creator"),
|
|
"error": None
|
|
},
|
|
"collector": {
|
|
"exists": os.path.exists("modules/collector"),
|
|
"has_error": False,
|
|
"last_run": get_last_run_time("collector"),
|
|
"error": None
|
|
}
|
|
}
|
|
|
|
# 统计分布（这里应该从数据库查询，简化为静态数据）
|
|
status_distribution = {
|
|
"待处理": 0,
|
|
"待审查": 0,
|
|
"待发布": 0
|
|
}
|
|
|
|
# 实际实现中应该从数据库查询真实数据
|
|
# for status in ["待处理", "待审查", "待发布"]:
|
|
# count = db.query(func.count(Topic.id)).filter(
|
|
# Topic.status == status
|
|
# ).scalar()
|
|
# status_distribution[status] = count
|
|
|
|
return {
|
|
"status_distribution": status_distribution,
|
|
"pipeline_modules": pipeline_modules,
|
|
"topics_count": 0 # 简化实现
|
|
}
|
|
|
|
def get_last_run_time(module_name: str) -> str:
|
|
"""获取模块最后运行时间（简化实现）"""
|
|
# 实际实现应检查日志文件或数据库记录
|
|
return "2026-04-26 15:30:00" |