系统级优化

app.py

@@ -29,7 +29,7 @@ logging.basicConfig(
 logger = logging.getLogger("ComfyUI-Ranking")
 
 
-from 云端_定时版本检测引擎 import daily_version_check_task
+from 云端_定时版本检测引擎 import daily_version_check_task, reset_daily_views_task
 
 # ==========================================
 # 👥 用户模块 (拆分为3个子模块)
@@ -222,6 +222,9 @@ async def on_startup():
     asyncio.create_task(daily_version_check_task())
     logger.info("✅ 定时版本检测任务已挂载")
     
+    asyncio.create_task(reset_daily_views_task())
+    logger.info("✅ daily_views 每日重置任务已挂载")
+    
     # ========== 启动 HF 批量同步定时器 ==========
     db.start_batch_sync()
     logger.info("✅ HF 批量同步定时器已启动")

router_items.py

@@ -166,7 +166,11 @@ async def create_item(item: ItemCreate):
         "netdisk_password": item.netdisk_password,  # ☁️ 网盘密码
         "is_netdisk": item.is_netdisk,              # ☁️ 是否网盘资源
         "is_original": item.is_original,            # 🎨 是否为原创作品
-        "likes": 0, "favorites": 0, "comments": 0, "uses": 0, "use_history": {}, "created_at": int(time.time()), "liked_by": [], "favorited_by": []
+        "likes": 0, "favorites": 0, "comments": 0, "uses": 0, "use_history": {}, "created_at": int(time.time()), "liked_by": [], "favorited_by": [],
+        "views": 0,
+        "daily_views": 0,
+        "viewed_by": [],
+        "daily_views_date": ""
     }
     items_db.insert(0, new_item)
     db.save_data("items.json", items_db)
@@ -395,6 +399,9 @@ async def record_item_view(item_id: str, current_user: str = Depends(require_aut
     if result is None:
         raise HTTPException(status_code=404, detail="找不到该内容记录")
     
+    # 🗂️ 清除排序缓存（浏览量变化可能影响排序）
+    sort_cache.invalidate("items:")
+    
     return {"status": "success", "views": result["views"], "daily_views": result["daily_views"]}
 
 

router_posts.py

@@ -163,7 +163,11 @@ async def create_post(post: PostCreate, current_user: str = Depends(require_auth
         "comments": 0,
         "liked_by": [],
         "favorited_by": [],
-        "tip_board": []  # 打赏榜单
+        "tip_board": [],  # 打赏榜单
+        "views": 0,
+        "daily_views": 0,
+        "viewed_by": [],
+        "daily_views_date": ""
     }
     
     posts_db.insert(0, new_post)
@@ -458,4 +462,7 @@ async def record_post_view(post_id: str, current_user: str = Depends(require_aut
     if result is None:
         raise HTTPException(status_code=404, detail="帖子不存在")
     
+    # 🗂️ 清除排序缓存（浏览量变化可能影响排序）
+    sort_cache.invalidate("posts:")
+    
     return {"status": "success", "views": result["views"], "daily_views": result["daily_views"]}

router_tasks.py

@@ -396,7 +396,11 @@ async def create_task(task: TaskCreate, current_user: str = Depends(require_auth
         "comments": 0,
         "liked_by": [],
         "favorited_by": [],
-        "tip_board": []  # 打赏榜单
+        "tip_board": [],  # 打赏榜单
+        "views": 0,
+        "daily_views": 0,
+        "viewed_by": [],
+        "daily_views_date": ""
     }
     
     tasks_db.insert(0, new_task)
@@ -1223,6 +1227,9 @@ async def record_task_view(task_id: str, current_user: str = Depends(require_aut
     if result is None:
         raise HTTPException(status_code=404, detail="任务不存在")
     
+    # 🗂️ 清除排序缓存（浏览量变化可能影响排序）
+    sort_cache.invalidate("tasks:")
+    
     return {"status": "success", "views": result["views"], "daily_views": result["daily_views"]}
 
 # ==========================================

云端_定时版本检测引擎.py

@@ -1,6 +1,7 @@
 # 云端_定时版本检测引擎.py
 import asyncio
 import datetime
+from datetime import date
 import httpx
 import logging
 import 数据库连接 as db
@@ -75,4 +76,63 @@ async def daily_version_check_task():
             db.save_data("versions.json", versions_db)
             print(f"✅ 版本检测任务完成，共发现并更新了 {updated_count} 个资源的新版本。")
         else:
-            print("✅ 版本检测任务完成，暂无任何新版本发现。")
+            print("✅ 版本检测任务完成，暂无任何新版本发现。")
+
+
+async def reset_daily_views_task():
+    """
+    每日重置 daily_views 计数器的守护进程
+    - 每小时检查一次，在 UTC+8 00:00 执行重置
+    - 使用 atomic_update 保证并发安全
+    """
+    # 需要处理的数据文件
+    data_files = ["items.json", "tasks.json", "posts.json"]
+    
+    while True:
+        now = datetime.datetime.utcnow() + datetime.timedelta(hours=8)
+        today = date.today().isoformat()
+        
+        # 计算距离今天 00:00 (UTC+8) 的秒数，如果过了就定在明天 00:00
+        next_run = now.replace(hour=0, minute=0, second=0, microsecond=0)
+        if now >= next_run:
+            next_run += datetime.timedelta(days=1)
+        sleep_seconds = (next_run - now).total_seconds()
+        
+        print(f"📊 daily_views 重置引擎已挂载，距离下次 00:00 执行还有 {sleep_seconds} 秒...")
+        await asyncio.sleep(sleep_seconds)
+        
+        print(f"🚀 [00:00] 开始执行 daily_views 每日重置任务 (日期: {today})...")
+        
+        total_reset_count = 0
+        
+        for file_name in data_files:
+            reset_count = 0
+            
+            def reset_updater(data):
+                nonlocal reset_count
+                if not isinstance(data, list):
+                    return
+                
+                for record in data:
+                    if not isinstance(record, dict):
+                        continue
+                    
+                    # 仅在 daily_views_date 不是今天时才重置
+                    record_date = record.get("daily_views_date")
+                    if record_date != today:
+                        record["daily_views"] = 0
+                        record["daily_views_date"] = today
+                        reset_count += 1
+            
+            try:
+                db.atomic_update(file_name, reset_updater, default_data=[])
+                total_reset_count += reset_count
+                if reset_count > 0:
+                    print(f"  ✓ {file_name}: 重置了 {reset_count} 条记录的 daily_views")
+            except Exception as e:
+                logger.error(f"重置 {file_name} 的 daily_views 失败: {e}")
+        
+        if total_reset_count > 0:
+            print(f"✅ daily_views 重置任务完成，共重置 {total_reset_count} 条记录。")
+        else:
+            print("✅ daily_views 重置任务完成，没有需要重置的记录。")