Upload router_items.py

router_items.py

@@ -2,12 +2,25 @@
 from fastapi import APIRouter, HTTPException
 import time
 import uuid
+import datetime  # 【新增】：处理时间序列
 import 数据库连接 as db
-# 【核心修改】：在顶部引入我们刚才新增的 ItemUpdate 模型
 from models import ItemCreate, ItemUpdate
 
 router = APIRouter()
 
+# 【新增】：获取最近 6 个月的年月字符串列表 (例如: ['2025-10', '2025-11', ..., '2026-03'])
+def get_last_6_months():
+    res = []
+    today = datetime.date.today()
+    for i in range(5, -1, -1):
+        m = today.month - i
+        y = today.year
+        while m <= 0:
+            m += 12
+            y -= 1
+        res.append(f"{y}-{m:02d}")
+    return res
+
 @router.get("/api/items")
 async def get_items(type: str = "tool", sort: str = "time", limit: int = 20):
     items_db = db.load_data("items.json", default_data=[])
@@ -27,18 +40,43 @@ async def get_creators(sort: str = "downloads", limit: int = 20):
     users_db = db.load_data("users.json", default_data={})
     items_db = db.load_data("items.json", default_data=[])
     comments_db = db.load_data("comments.json", default_data={})
+    
     creators = []
+    months = get_last_6_months()
+    
     for account, u in users_db.items():
         u_items = [i for i in items_db if i.get("author") == account]
-        tools_count = sum(1 for i in u_items if i.get("type") == "tool")
-        apps_count = sum(1 for i in u_items if i.get("type") == "app")
+        
+        # 【核心修正】：计算真实的聚合增长曲线
+        trend_tools = {m: 0 for m in months}
+        trend_apps = {m: 0 for m in months}
+        tools_count = 0
+        apps_count = 0
+        
+        for i in u_items:
+            itype = i.get("type")
+            history = i.get("use_history", {})
+            if itype == "tool": 
+                tools_count += 1
+                for m in months: trend_tools[m] += history.get(m, 0)
+            elif itype == "app": 
+                apps_count += 1
+                for m in months: trend_apps[m] += history.get(m, 0)
+
         creators.append({
             "account": account, "name": u.get("name", account), "avatar": u.get("avatarDataUrl", "https://via.placeholder.com/150"),
             "shortDesc": u.get("intro", "这个人很懒，什么都没写..."), "fullDesc": u.get("intro", "这个人很懒，什么都没写..."),
-            "likes": sum(i.get("likes", 0) for i in u_items), "favorites": sum(i.get("favorites", 0) for i in u_items), "downloads": sum(i.get("uses", 0) for i in u_items), 
+            "likes": sum(i.get("likes", 0) for i in u_items), "favorites": sum(i.get("favorites", 0) for i in u_items), 
+            "downloads": sum(i.get("uses", 0) for i in u_items), # 创作者总下载量
             "toolsCount": tools_count, "appsCount": apps_count, "followers": len(u.get("followers", [])), "created_at": u.get("created_at", 0),
-            "commentsData": comments_db.get(account, []), "trendData": {"tools": [0,0,0,0,0, tools_count], "apps": [0,0,0,0,0, apps_count]}
+            "commentsData": comments_db.get(account, []), 
+            "trendData": {
+                "months": months,
+                "tools": [trend_tools[m] for m in months], 
+                "apps": [trend_apps[m] for m in months]
+            }
         })
+        
     if sort == "likes": creators.sort(key=lambda x: x.get("likes", 0), reverse=True)
     elif sort == "favorites": creators.sort(key=lambda x: x.get("favorites", 0), reverse=True)
     elif sort == "downloads": creators.sort(key=lambda x: x.get("downloads", 0), reverse=True)
@@ -51,72 +89,58 @@ async def create_item(item: ItemCreate):
     new_item = {
         "id": f"{item.type}_{int(time.time())}_{uuid.uuid4().hex[:6]}", "type": item.type, "title": item.title, "author": item.author,
         "shortDesc": item.shortDesc, "fullDesc": item.fullDesc, "link": item.link, "coverUrl": item.coverUrl, "price": item.price, 
-        "likes": 0, "favorites": 0, "comments": 0, "uses": 0, "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": []
     }
     items_db.insert(0, new_item)
     db.save_data("items.json", items_db)
     return {"status": "success", "data": new_item}
 
-# =========================================================
-# 【核心新增】：以下为修改与删除相关接口
-# =========================================================
-
 @router.put("/api/items/{item_id}")
 async def update_item(item_id: str, update_data: ItemUpdate, author: str):
     items_db = db.load_data("items.json", default_data=[])
     for item in items_db:
         if item["id"] == item_id:
-            # 鉴权：只有作者本人可以修改
-            if item.get("author") != author: 
-                raise HTTPException(status_code=403, detail="无权修改他人发布的内容")
-            
-            # 只更新存在的字段，不影响浏览量点赞等数据
+            if item.get("author") != author: raise HTTPException(status_code=403, detail="无权修改他人发布的内容")
             if update_data.title is not None: item["title"] = update_data.title
             if update_data.shortDesc is not None: item["shortDesc"] = update_data.shortDesc
             if update_data.fullDesc is not None: item["fullDesc"] = update_data.fullDesc
             if update_data.link is not None: item["link"] = update_data.link
             if update_data.coverUrl is not None: item["coverUrl"] = update_data.coverUrl
             if update_data.price is not None: item["price"] = update_data.price
-            
             db.save_data("items.json", items_db)
             return {"status": "success"}
-            
     raise HTTPException(status_code=404, detail="找不到该内容记录")
 
 @router.delete("/api/items/{item_id}")
 async def delete_item(item_id: str, author: str):
     items_db = db.load_data("items.json", default_data=[])
     target_idx = next((i for i, item in enumerate(items_db) if item["id"] == item_id), None)
+    if target_idx is None: raise HTTPException(status_code=404, detail="找不到该内容记录")
+    if items_db[target_idx].get("author") != author: raise HTTPException(status_code=403, detail="无权删除他人发布的内容")
     
-    if target_idx is None: 
-        raise HTTPException(status_code=404, detail="找不到该内容记录")
-    if items_db[target_idx].get("author") != author: 
-        raise HTTPException(status_code=403, detail="无权删除他人发布的内容")
-    
-    # 1. 删除发布的内容
     items_db.pop(target_idx)
     db.save_data("items.json", items_db)
     
-    # 2. 同步清理该内容下的所有关联评论记录
     comments_db = db.load_data("comments.json", default_data={})
     if item_id in comments_db:
         del comments_db[item_id]
         db.save_data("comments.json", comments_db)
-        
     return {"status": "success"}
 
-# =========================================================
-# 【核心新增】：使用量累加同步接口
-# =========================================================
 @router.post("/api/items/{item_id}/use")
 async def record_item_use(item_id: str):
-    """记录资源被获取/使用的次数"""
+    """记录资源被获取/使用的次数，并计入时间序列"""
     items_db = db.load_data("items.json", default_data=[])
+    current_month = datetime.date.today().strftime("%Y-%m")
     
     for item in items_db:
         if item["id"] == item_id:
-            # 原有的使用量 + 1 (如果没有则默认为0再+1)
             item["uses"] = item.get("uses", 0) + 1
+            # 初始化时间序列历史并累加
+            if "use_history" not in item:
+                item["use_history"] = {}
+            item["use_history"][current_month] = item["use_history"].get(current_month, 0) + 1
+            
             db.save_data("items.json", items_db)
             return {"status": "success", "uses": item["uses"]}