支持退款功能

models.py

@@ -66,6 +66,7 @@ class ItemCreate(BaseModel):
     netdisk_password: Optional[str] = None  # ☁️ 网盘提取码（加密存储，购买后解密）
     is_netdisk: Optional[bool] = False      # ☁️ 是否为网盘资源
     is_original: Optional[bool] = False     # 🎨 是否为原创作品
+    allow_refund: Optional[bool] = True     # 💸 是否支持退款（默认支持）
 
 class ItemUpdate(BaseModel):
     title: Optional[str] = None
@@ -79,6 +80,7 @@ class ItemUpdate(BaseModel):
     netdisk_password: Optional[str] = None  # ☁️ 网盘提取码
     is_netdisk: Optional[bool] = None       # ☁️ 是否为网盘资源
     is_original: Optional[bool] = None      # 🎨 是否为原创作品
+    allow_refund: Optional[bool] = None     # 💸 是否支持退款
 
 class FollowToggle(BaseModel):
     user_id: str

router_items.py

@@ -215,6 +215,7 @@ async def create_item(item: ItemCreate):
         "netdisk_password": item.netdisk_password,  # ☁️ 网盘密码
         "is_netdisk": item.is_netdisk,              # ☁️ 是否网盘资源
         "is_original": item.is_original,            # 🎨 是否为原创作品
+        "allow_refund": item.allow_refund,          # 💸 是否支持退款
         "likes": 0, "favorites": 0, "comments": 0, "uses": 0, "use_history": {}, "created_at": int(time.time()), "liked_by": [], "favorited_by": [],
         "views": 0,
         "daily_views": 0,
@@ -285,6 +286,7 @@ async def update_item(item_id: str, update_data: ItemUpdate, current_user: str =
                 if update_data.netdisk_password is not None: item["netdisk_password"] = update_data.netdisk_password  # ☁️
                 if update_data.is_netdisk is not None: item["is_netdisk"] = update_data.is_netdisk  # ☁️
                 if update_data.is_original is not None: item["is_original"] = update_data.is_original  # 🎨
+                if update_data.allow_refund is not None: item["allow_refund"] = update_data.allow_refund  # 💸
                 
                 result_holder["success"] = True
                 result_holder["price_change_info"] = price_change_info

router_wallet.py

@@ -866,6 +866,11 @@ async def get_purchase_status(account: str, item_id: str, db: Session = Depends(
     if not ownership:
         return {"status": "success", "owned": False}
     
+    # 读取商品，获取 allow_refund（旧数据默认 True）
+    items_db = json_db.load_data("items.json", default_data=[])
+    item = next((i for i in items_db if i.get("id") == item_id), None)
+    allow_refund = item.get("allow_refund", True) if item else True
+    
     # 计算是否在退款窗口内
     purchased_at = ownership.purchased_at
     now = datetime.datetime.utcnow()
@@ -879,7 +884,8 @@ async def get_purchase_status(account: str, item_id: str, db: Session = Depends(
         "purchased_at": purchased_at.isoformat(),
         "price_paid": ownership.price_paid,
         "can_refund": can_refund,
-        "refund_hours_left": round(hours_left, 1)
+        "refund_hours_left": round(hours_left, 1),
+        "allow_refund": allow_refund
     }
 
 @router.post("/api/wallet/refund")
@@ -897,6 +903,10 @@ async def refund_purchase(request: Request, account: str, item_id: str, db: Sess
     if not item:
         raise HTTPException(status_code=404, detail="商品不存在")
     
+    # 检查资源是否支持退款
+    if not item.get("allow_refund", True):  # 默认支持退款（向后兼容）
+        raise HTTPException(status_code=400, detail="该资源不支持退款")
+    
     # 查找购买记录
     ownership = db.query(Ownership).filter(
         Ownership.account == account,