增加打分5星机制

models.py

@@ -1,5 +1,5 @@
 # models.py
-from pydantic import BaseModel
+from pydantic import BaseModel, validator
 from typing import Optional, List
 
 class SendCodeRequest(BaseModel):
@@ -105,6 +105,17 @@ class InteractionToggle(BaseModel):
     action_type: str
     is_active: bool
 
+class RatingRequest(BaseModel):
+    score: int  # 1-5
+
+    @validator("score")
+    def validate_score(cls, v):
+        if not isinstance(v, int):
+            raise ValueError("score must be an integer between 1 and 5")
+        if v < 1 or v > 5:
+            raise ValueError("score must be between 1 and 5")
+        return v
+
 class RechargeRequest(BaseModel):
     account: str
     amount: int

router_items.py

@@ -8,7 +8,7 @@ import urllib.request
 import urllib.error
 import json
 import 数据库连接 as db
-from models import ItemCreate, ItemUpdate
+from models import ItemCreate, ItemUpdate, RatingRequest
 from 安全认证 import require_auth, check_ownership
 from 数据库连接 import invalidate_cache
 from db_utils import record_view, sort_cache
@@ -59,6 +59,8 @@ async def get_items(type: str = "tool", sort: str = "time", limit: int = 50): #
             data.sort(key=lambda x: x.get("views", 0), reverse=True)
         elif sort == "daily_views": # 👁️ 按日访问量排序
             data.sort(key=lambda x: x.get("daily_views", 0), reverse=True)
+        elif sort == "rating": # ⭐ 按评分排序
+            data.sort(key=lambda x: (x.get("rating_avg", 0), x.get("rating_count", 0)), reverse=True)
         else: # time 或其他默认
             data.sort(key=lambda x: x.get("created_at", 0), reverse=True)
     
@@ -293,7 +295,11 @@ async def create_item(item: ItemCreate):
         "views": 0,
         "daily_views": 0,
         "viewed_by": [],
-        "daily_views_date": ""
+        "daily_views_date": "",
+        "rating_avg": 0.0,
+        "rating_count": 0,
+        "rating_dist": {"1": 0, "2": 0, "3": 0, "4": 0, "5": 0},
+        "rated_by": {}
     }
     items_db.insert(0, new_item)
     db.save_data("items.json", items_db)
@@ -598,6 +604,80 @@ async def record_item_use(item_id: str, current_user: str = Depends(require_auth
 # ❤️ 互动接口（点赞/收藏）
 # ==========================================
 
+@router.post("/api/items/{item_id}/rating")
+async def rate_item(item_id: str, request: RatingRequest, current_user: str = Depends(require_auth)):
+    """
+    为资源评分（原子操作，并发安全）
+    ⭐ score: 1-5
+    """
+    score = request.score
+    if score < 1 or score > 5:
+        raise HTTPException(status_code=400, detail="评分必须在1-5之间")
+    
+    result_container = [None]
+    
+    def updater(data):
+        for item in data:
+            if item["id"] == item_id:
+                # 禁止自评
+                if item.get("author") == current_user:
+                    result_container[0] = {"error": "self_rating"}
+                    return
+                # 初始化评分字段
+                if "rating_avg" not in item:
+                    item["rating_avg"] = 0.0
+                if "rating_count" not in item:
+                    item["rating_count"] = 0
+                if "rating_dist" not in item:
+                    item["rating_dist"] = {"1": 0, "2": 0, "3": 0, "4": 0, "5": 0}
+                if "rated_by" not in item:
+                    item["rated_by"] = {}
+                
+                rated_by = item["rated_by"]
+                rating_dist = item["rating_dist"]
+                old_score = None
+                if current_user in rated_by:
+                    old_score = rated_by[current_user]["score"]
+                
+                if old_score is not None:
+                    # 已评分，先减去旧分数分布
+                    rating_dist[str(old_score)] = max(0, rating_dist.get(str(old_score), 0) - 1)
+                    rating_dist[str(score)] = rating_dist.get(str(score), 0) + 1
+                else:
+                    # 未评分，增加计数
+                    item["rating_count"] = item.get("rating_count", 0) + 1
+                    rating_dist[str(score)] = rating_dist.get(str(score), 0) + 1
+                
+                rated_by[current_user] = {"score": score, "time": int(time.time())}
+                
+                # 重新计算平均分
+                total = sum(int(k) * v for k, v in rating_dist.items())
+                count = item["rating_count"]
+                item["rating_avg"] = round(total / count, 2) if count > 0 else 0.0
+                
+                result_container[0] = {
+                    "status": "success",
+                    "rating_avg": item["rating_avg"],
+                    "rating_count": item["rating_count"],
+                    "rating_dist": item["rating_dist"],
+                    "user_score": score
+                }
+                return
+        result_container[0] = None  # 未找到资源
+    
+    db.atomic_update("items.json", updater, default_data=[])
+    
+    if result_container[0] is None:
+        raise HTTPException(status_code=404, detail="资源不存在")
+    if result_container[0].get("error") == "self_rating":
+        raise HTTPException(status_code=400, detail="不能给自己发布的资源评分")
+    
+    # 🗂️ 清除排序缓存（评分变化可能影响排序）
+    sort_cache.invalidate("items:")
+    
+    return result_container[0]
+
+
 @router.post("/api/items/{item_id}/like")
 async def toggle_item_like(item_id: str, current_user: str = Depends(require_auth)):
     """

router_posts.py

@@ -7,7 +7,7 @@
 
 from fastapi import APIRouter, HTTPException, Depends
 from sqlalchemy.orm import Session
-from models import PostCreate, PostUpdate
+from models import PostCreate, PostUpdate, RatingRequest
 import 数据库连接 as db
 from 安全认证 import require_auth
 from db_utils import record_view, sort_cache
@@ -57,6 +57,8 @@ async def get_posts(page: int = 1, limit: int = 20, sort: str = "latest"):
             data.sort(key=lambda x: x.get("daily_views", 0), reverse=True)
         elif sort == "tips":
             data.sort(key=lambda x: sum(t.get("amount", 0) for t in x.get("tip_board", [])), reverse=True)
+        elif sort == "rating":  # ⭐ 按评分排序
+            data.sort(key=lambda x: (x.get("rating_avg", 0), x.get("rating_count", 0)), reverse=True)
         else:  # latest 或其他默认
             data.sort(key=lambda x: x.get("created_at", 0), reverse=True)
     
@@ -76,12 +78,10 @@ async def get_posts(page: int = 1, limit: int = 20, sort: str = "latest"):
             "author_name": author_info.get("name", post.get("author")),
             "author_avatar": author_info.get("avatarDataUrl", "")
         }
-        # 过滤敏感字段（列表接口过滤 viewed_by、liked_by、favorited_by）
+        # 过滤敏感字段（列表接口仅过滤 viewed_by，保留 liked_by 和 favorited_by）
         post_data.pop("viewed_by", None)
-        post_data.pop("liked_by", None)
-        post_data.pop("favorited_by", None)
         result.append(post_data)
-    
+
     return {
         "status": "success",
         "data": result,
@@ -103,15 +103,13 @@ async def get_my_posts(current_user: str = Depends(require_auth)):
     # 按创建时间倒序
     my_posts = sorted(my_posts, key=lambda x: x.get("created_at", 0), reverse=True)
     
-    # 过滤敏感字段（列表接口过滤 viewed_by、liked_by、favorited_by）
+    # 过滤敏感字段（列表接口仅过滤 viewed_by，保留 liked_by 和 favorited_by）
     result = []
     for post in my_posts:
         post_data = dict(post)
         post_data.pop("viewed_by", None)
-        post_data.pop("liked_by", None)
-        post_data.pop("favorited_by", None)
         result.append(post_data)
-    
+
     return {
         "status": "success",
         "data": result
@@ -174,7 +172,11 @@ async def create_post(post: PostCreate, current_user: str = Depends(require_auth
         "views": 0,
         "daily_views": 0,
         "viewed_by": [],
-        "daily_views_date": ""
+        "daily_views_date": "",
+        "rating_avg": 0.0,
+        "rating_count": 0,
+        "rating_dist": {"1": 0, "2": 0, "3": 0, "4": 0, "5": 0},
+        "rated_by": {}
     }
     
     posts_db.insert(0, new_post)
@@ -248,6 +250,80 @@ async def delete_post(post_id: str, current_user: str = Depends(require_auth)):
 # ❤️ 互动接口（点赞/收藏）
 # ==========================================
 
+@router.post("/api/posts/{post_id}/rating")
+async def rate_post(post_id: str, request: RatingRequest, current_user: str = Depends(require_auth)):
+    """
+    为帖子评分（原子操作，并发安全）
+    ⭐ score: 1-5
+    """
+    score = request.score
+    if score < 1 or score > 5:
+        raise HTTPException(status_code=400, detail="评分必须在1-5之间")
+    
+    result_container = [None]
+    
+    def updater(data):
+        for post in data:
+            if post["id"] == post_id:
+                # 禁止自评
+                if post.get("author") == current_user:
+                    result_container[0] = {"error": "self_rating"}
+                    return
+                # 初始化评分字段
+                if "rating_avg" not in post:
+                    post["rating_avg"] = 0.0
+                if "rating_count" not in post:
+                    post["rating_count"] = 0
+                if "rating_dist" not in post:
+                    post["rating_dist"] = {"1": 0, "2": 0, "3": 0, "4": 0, "5": 0}
+                if "rated_by" not in post:
+                    post["rated_by"] = {}
+                
+                rated_by = post["rated_by"]
+                rating_dist = post["rating_dist"]
+                old_score = None
+                if current_user in rated_by:
+                    old_score = rated_by[current_user]["score"]
+                
+                if old_score is not None:
+                    # 已评分，先减去旧分数分布
+                    rating_dist[str(old_score)] = max(0, rating_dist.get(str(old_score), 0) - 1)
+                    rating_dist[str(score)] = rating_dist.get(str(score), 0) + 1
+                else:
+                    # 未评分，增加计数
+                    post["rating_count"] = post.get("rating_count", 0) + 1
+                    rating_dist[str(score)] = rating_dist.get(str(score), 0) + 1
+                
+                rated_by[current_user] = {"score": score, "time": int(time.time())}
+                
+                # 重新计算平均��
+                total = sum(int(k) * v for k, v in rating_dist.items())
+                count = post["rating_count"]
+                post["rating_avg"] = round(total / count, 2) if count > 0 else 0.0
+                
+                result_container[0] = {
+                    "status": "success",
+                    "rating_avg": post["rating_avg"],
+                    "rating_count": post["rating_count"],
+                    "rating_dist": post["rating_dist"],
+                    "user_score": score
+                }
+                return
+        result_container[0] = None  # 未找到帖子
+    
+    db.atomic_update("posts.json", updater, default_data=[])
+    
+    if result_container[0] is None:
+        raise HTTPException(status_code=404, detail="帖子不存在")
+    if result_container[0].get("error") == "self_rating":
+        raise HTTPException(status_code=400, detail="不能给自己发布的帖子评分")
+    
+    # 🗂️ 清除排序缓存（评分变化可能影响排序）
+    sort_cache.invalidate("posts:")
+    
+    return result_container[0]
+
+
 @router.post("/api/posts/{post_id}/like")
 async def toggle_like(post_id: str, current_user: str = Depends(require_auth)):
     """