Upload 2 files

router_posts.py

@@ -24,10 +24,10 @@ async def get_posts(page: int = 1, limit: int = 20):
     获取帖子列表（分页，按时间倒序）
     """
     posts_db = db.load_data("posts.json", default_data=[])
-    users_db = db.load_data("users.json", default_data=[])
+    users_db = db.load_data("users.json", default_data={})
     
-    # 构建用户信息映射
-    user_map = {u["account"]: u for u in users_db}
+    # users_db 已经是 {account: user_info} 格式，直接使用
+    user_map = users_db
     
     # 按创建时间倒序
     sorted_posts = sorted(posts_db, key=lambda x: x.get("created_at", 0), reverse=True)
@@ -80,9 +80,10 @@ async def get_post_detail(post_id: str):
     获取帖子详情
     """
     posts_db = db.load_data("posts.json", default_data=[])
-    users_db = db.load_data("users.json", default_data=[])
+    users_db = db.load_data("users.json", default_data={})
     
-    user_map = {u["account"]: u for u in users_db}
+    # users_db 已经是 {account: user_info} 格式，直接使用
+    user_map = users_db
     
     for post in posts_db:
         if post["id"] == post_id:
@@ -245,7 +246,7 @@ async def tip_post(post_id: str, amount: int, is_anon: bool = False, current_use
         raise HTTPException(status_code=400, detail="打赏金额必须大于0")
     
     posts_db = db.load_data("posts.json", default_data=[])
-    users_db = db.load_data("users.json", default_data=[])
+    users_db = db.load_data("users.json", default_data={})
     
     # 查找帖子
     target_post = None
@@ -261,12 +262,8 @@ async def tip_post(post_id: str, amount: int, is_anon: bool = False, current_use
     if target_post.get("author") == current_user:
         raise HTTPException(status_code=400, detail="不能打赏自己的帖子")
     
-    # 检查余额
-    tipper = None
-    for u in users_db:
-        if u["account"] == current_user:
-            tipper = u
-            break
+    # 检查余额（users_db 是字典格式）
+    tipper = users_db.get(current_user)
     
     if not tipper or tipper.get("balance", 0) < amount:
         raise HTTPException(status_code=400, detail="余额不足")
@@ -275,10 +272,9 @@ async def tip_post(post_id: str, amount: int, is_anon: bool = False, current_use
     tipper["balance"] = tipper.get("balance", 0) - amount
     
     # 给作者加钱
-    for u in users_db:
-        if u["account"] == target_post.get("author"):
-            u["balance"] = u.get("balance", 0) + amount
-            break
+    author = users_db.get(target_post.get("author"))
+    if author:
+        author["balance"] = author.get("balance", 0) + amount
     
     # 更新打赏榜单
     tip_board = target_post.get("tip_board", [])
@@ -311,9 +307,10 @@ async def get_post_comments(post_id: str):
     获取帖子评论
     """
     comments_db = db.load_data("comments.json", default_data=[])
-    users_db = db.load_data("users.json", default_data=[])
+    users_db = db.load_data("users.json", default_data={})
     
-    user_map = {u["account"]: u for u in users_db}
+    # users_db 已经是 {account: user_info} 格式，直接使用
+    user_map = users_db
     
     # 过滤该帖子的评论
     post_comments = [c for c in comments_db if c.get("target_id") == post_id and c.get("target_type") == "post"]

router_tasks.py

@@ -173,13 +173,14 @@ async def get_tasks(
     - sort: latest(最新)/price(价格高)/deadline(截止日期近)
     """
     tasks_db = db.load_data("tasks.json", default_data=[])
-    users_db = db.load_data("users.json", default_data=[])
+    users_db = db.load_data("users.json", default_data={})
     
     # 自动检查并更新过期任务（带自动退款）
     if check_and_update_expired_tasks(tasks_db, db_session):
         db.save_data("tasks.json", tasks_db)
     
-    user_map = {u["account"]: u for u in users_db}
+    # users_db 已经是 {account: user_info} 格式，直接使用
+    user_map = users_db
     
     # 状态筛选（默认排除已取消和过期的）
     filtered = tasks_db
@@ -227,9 +228,10 @@ async def get_task_detail(task_id: str, current_user: str = None):
     获取任务详情
     """
     tasks_db = db.load_data("tasks.json", default_data=[])
-    users_db = db.load_data("users.json", default_data=[])
+    users_db = db.load_data("users.json", default_data={})
     
-    user_map = {u["account"]: u for u in users_db}
+    # users_db 已经是 {account: user_info} 格式，直接使用
+    user_map = users_db
     
     for task in tasks_db:
         if task["id"] == task_id:
@@ -757,9 +759,10 @@ async def get_dispute_detail(dispute_id: str):
     获取申诉详情
     """
     disputes_db = db.load_data("disputes.json", default_data=[])
-    users_db = db.load_data("users.json", default_data=[])
+    users_db = db.load_data("users.json", default_data={})
     
-    user_map = {u["account"]: u for u in users_db}
+    # users_db 已经是 {account: user_info} 格式，直接使用
+    user_map = users_db
     
     for dispute in disputes_db:
         if dispute["id"] == dispute_id:
@@ -828,9 +831,10 @@ async def get_admin_disputes(status: str = None, current_user: str = Depends(req
         raise HTTPException(status_code=403, detail="需要管理员权限")
     
     disputes_db = db.load_data("disputes.json", default_data=[])
-    users_db = db.load_data("users.json", default_data=[])
+    users_db = db.load_data("users.json", default_data={})
     
-    user_map = {u["account"]: u for u in users_db}
+    # users_db 已经是 {account: user_info} 格式，直接使用
+    user_map = users_db
     
     # 筛选
     filtered = disputes_db