Upload app.py

app.py

@@ -102,6 +102,12 @@ class ItemCreate(BaseModel):
     author: str 
     price: float = 0.0  # 标价/积分字段
 
+# 【新增】：关注功能的数据模型
+class FollowToggle(BaseModel):
+    user_id: str
+    target_account: str
+    is_active: bool
+
 # --- 1. 用户系统 ---
 @app.post("/api/users/register")
 async def register_user(user: UserRegister):
@@ -121,7 +127,9 @@ async def register_user(user: UserRegister):
     # 构建用户档案，初始化各项统计为 0
     new_user = user.dict()
     new_user.update({
-        "receivedLikes": 0, "receivedFollows": 0,
+        "created_at": int(time.time()), 
+        "followers": [], 
+        "following": [],
         "privacy": {"follows": False, "likes": False, "favorites": False, "downloads": False}
     })
     
@@ -159,9 +167,40 @@ async def get_user_profile(account: str):
         raise HTTPException(status_code=404, detail="用户不存在")
     
     user_data = users_db[account]
+    
+    # 【核心】：动态聚合该用户的作品收到的点赞、收藏和被使用总数
+    items_db = db.load_data("items.json", default_data=[])
+    user_items = [item for item in items_db if item.get("author") == account]
+    
+    user_data["receivedLikes"] = sum(item.get("likes", 0) for item in user_items)
+    user_data["receivedFavorites"] = sum(item.get("favorites", 0) for item in user_items)
+    user_data["receivedUses"] = sum(item.get("uses", 0) for item in user_items)
+    
     safe_user_data = {k: v for k, v in user_data.items() if k != "password"}
     return {"status": "success", "data": safe_user_data}
 
+@app.post("/api/users/follow")
+async def toggle_follow(follow: FollowToggle):
+    users_db = db.load_data("users.json", default_data={})
+    if follow.target_account not in users_db or follow.user_id not in users_db:
+        raise HTTPException(status_code=404, detail="用户不存在")
+        
+    target_user = users_db[follow.target_account]
+    current_user = users_db[follow.user_id]
+    
+    target_followers = target_user.setdefault("followers", [])
+    current_following = current_user.setdefault("following", [])
+    
+    if follow.is_active:
+        if follow.user_id not in target_followers: target_followers.append(follow.user_id)
+        if follow.target_account not in current_following: current_following.append(follow.target_account)
+    else:
+        if follow.user_id in target_followers: target_followers.remove(follow.user_id)
+        if follow.target_account in current_following: current_following.remove(follow.target_account)
+        
+    db.save_data("users.json", users_db)
+    return {"status": "success"}
+
 # --- 2. 排行榜核心数据流 ---
 @app.get("/api/items")
 async def get_items(type: str = "tool", sort: str = "time", limit: int = 20):
@@ -180,6 +219,44 @@ async def get_items(type: str = "tool", sort: str = "time", limit: int = 20):
         
     return {"status": "success", "data": filtered_items[:limit]}
 
+# 【新增】：创作者排行榜动态聚合与排序接口
+@app.get("/api/creators")
+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=[])
+    
+    creators = []
+    for account, u in users_db.items():
+        u_items = [i for i in items_db if i.get("author") == account]
+        likes = sum(i.get("likes", 0) for i in u_items)
+        favorites = sum(i.get("favorites", 0) for i in u_items)
+        uses = sum(i.get("uses", 0) for i in u_items)
+        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")
+        
+        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": likes,
+            "favorites": favorites,
+            "downloads": uses,
+            "toolsCount": tools_count,
+            "appsCount": apps_count,
+            "followers": len(u.get("followers", [])),
+            "created_at": u.get("created_at", 0),
+            "trendData": {"tools": [0,0,0,0,0, tools_count], "apps": [0,0,0,0,0, apps_count]}
+        })
+        
+    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)
+    else: creators.sort(key=lambda x: x.get("created_at", 0), reverse=True)
+        
+    return {"status": "success", "data": creators[:limit]}
+
 # 【核心修改】：处理前端发布的新插件/应用请求
 @app.post("/api/items")
 async def create_item(item: ItemCreate):