Upload router_items.py

router_items.py

@@ -23,6 +23,20 @@ def _get_version_str(versions_db: dict, item_id: str) -> str:
         return val.get("hash", "") or ""
     return val or ""
 
+def _apply_effective_price(item: dict) -> None:
+    """检查 pending_price 是否已过生效时间，若是则更新 price 字段供前端显示"""
+    pending_price = item.get("pending_price")
+    pending_effective = item.get("pending_price_effective_at")
+    if pending_price is not None and pending_effective:
+        try:
+            effective_time = datetime.datetime.fromisoformat(pending_effective)
+            if datetime.datetime.now() >= effective_time:
+                item["price"] = pending_price
+                item["pending_price"] = None
+                item["pending_price_effective_at"] = None
+        except (ValueError, TypeError):
+            pass
+
 def get_last_6_months():
     res = []
     today = datetime.date.today()
@@ -74,17 +88,29 @@ async def get_items(type: str = "tool", sort: str = "time", limit: int = 50): #
     
     filtered_items = sort_cache.get_sorted(cache_key, filtered_items, sort_fn)
         
+    price_updated = False
     for item in filtered_items:
         item["commentsData"] = comments_db.get(item["id"], [])
         item["comments"] = len(item["commentsData"])
         item["latest_version"] = _get_version_str(versions_db, item["id"])
         
+        # 💰 检查延迟价格是否已生效
+        old_price = item.get("price", 0)
+        _apply_effective_price(item)
+        if item.get("price", 0) != old_price:
+            price_updated = True
+        
         # 🔴 【绝对核心防线】：在下发给前端前，强行在内存中抹除敏感信息！
         item["has_private_token"] = bool(item.get("github_token"))
         item.pop("github_token", None)
         item.pop("netdisk_password", None)  # ☁️ 网盘密码不在列表中显示
         item.pop("viewed_by", None)  # 👁️ 访问者列表不暴露给前端
     
+    # 如果有价格生效了，持久化回 items.json
+    if price_updated:
+        db.save_data("items.json", items_db)
+        invalidate_cache("items.json")
+    
     return {"status": "success", "data": filtered_items[:limit]}
 
 def _build_creator_trend_data(account: str, u_items: list, months: list) -> dict:
@@ -554,6 +580,13 @@ async def get_item_by_id(item_id: str):
             item["comments"] = len(item["commentsData"])
             item["latest_version"] = _get_version_str(versions_db, item_id)
             
+            # 💰 检查延迟价格是否已生效
+            old_price = item.get("price", 0)
+            _apply_effective_price(item)
+            if item.get("price", 0) != old_price:
+                db.save_data("items.json", items_db)
+                invalidate_cache("items.json")
+            
             # 🔴 【安全防线】：抹除敏感信息
             item["has_private_token"] = bool(item.get("github_token"))
             item.pop("github_token", None)