Upload 2 files

models.py

@@ -68,4 +68,12 @@ class PrivacySettings(BaseModel):
     follows: bool
     likes: bool
     favorites: bool
-    downloads: bool
+    downloads: bool
+
+class ItemUpdate(BaseModel):
+    title: Optional[str] = None
+    shortDesc: Optional[str] = None
+    fullDesc: Optional[str] = None
+    link: Optional[str] = None
+    coverUrl: Optional[str] = None
+    price: Optional[float] = None

router_items.py

@@ -1,9 +1,10 @@
 # router_items.py
-from fastapi import APIRouter
+from fastapi import APIRouter, HTTPException
 import time
 import uuid
 import 数据库连接 as db
-from models import ItemCreate
+# 【核心修改】：在顶部引入我们刚才新增的 ItemUpdate 模型
+from models import ItemCreate, ItemUpdate
 
 router = APIRouter()
 
@@ -54,4 +55,52 @@ async def create_item(item: ItemCreate):
     }
     items_db.insert(0, new_item)
     db.save_data("items.json", items_db)
-    return {"status": "success", "data": new_item}
+    return {"status": "success", "data": new_item}
+
+# =========================================================
+# 【核心新增】：以下为修改与删除相关接口
+# =========================================================
+
+@router.put("/api/items/{item_id}")
+async def update_item(item_id: str, update_data: ItemUpdate, author: str):
+    items_db = db.load_data("items.json", default_data=[])
+    for item in items_db:
+        if item["id"] == item_id:
+            # 鉴权：只有作者本人可以修改
+            if item.get("author") != author: 
+                raise HTTPException(status_code=403, detail="无权修改他人发布的内容")
+            
+            # 只更新存在的字段，不影响浏览量点赞等数据
+            if update_data.title is not None: item["title"] = update_data.title
+            if update_data.shortDesc is not None: item["shortDesc"] = update_data.shortDesc
+            if update_data.fullDesc is not None: item["fullDesc"] = update_data.fullDesc
+            if update_data.link is not None: item["link"] = update_data.link
+            if update_data.coverUrl is not None: item["coverUrl"] = update_data.coverUrl
+            if update_data.price is not None: item["price"] = update_data.price
+            
+            db.save_data("items.json", items_db)
+            return {"status": "success"}
+            
+    raise HTTPException(status_code=404, detail="找不到该内容记录")
+
+@router.delete("/api/items/{item_id}")
+async def delete_item(item_id: str, author: str):
+    items_db = db.load_data("items.json", default_data=[])
+    target_idx = next((i for i, item in enumerate(items_db) if item["id"] == item_id), None)
+    
+    if target_idx is None: 
+        raise HTTPException(status_code=404, detail="找不到该内容记录")
+    if items_db[target_idx].get("author") != author: 
+        raise HTTPException(status_code=403, detail="无权删除他人发布的内容")
+    
+    # 1. 删除发布的内容
+    items_db.pop(target_idx)
+    db.save_data("items.json", items_db)
+    
+    # 2. 同步清理该内容下的所有关联评论记录
+    comments_db = db.load_data("comments.json", default_data={})
+    if item_id in comments_db:
+        del comments_db[item_id]
+        db.save_data("comments.json", comments_db)
+        
+    return {"status": "success"}