优化任务榜

router_posts.py

@@ -306,14 +306,14 @@ async def get_post_comments(post_id: str):
     """
     获取帖子评论
     """
-    comments_db = db.load_data("comments.json", default_data=[])
+    comments_db = db.load_data("comments.json", default_data={})
     users_db = db.load_data("users.json", default_data={})
     
     # 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"]
+    # comments_db 是 {item_id: [comments]} 格式
+    post_comments = comments_db.get(post_id, [])
     
     # 附加用户信息
     result = []
@@ -336,7 +336,7 @@ async def add_post_comment(post_id: str, content: str, current_user: str = Depen
         raise HTTPException(status_code=400, detail="评论内容不能为空")
     
     posts_db = db.load_data("posts.json", default_data=[])
-    comments_db = db.load_data("comments.json", default_data=[])
+    comments_db = db.load_data("comments.json", default_data={})
     
     # 检查帖子是否存在
     post_exists = any(p["id"] == post_id for p in posts_db)
@@ -345,14 +345,15 @@ async def add_post_comment(post_id: str, content: str, current_user: str = Depen
     
     new_comment = {
         "id": f"comment_{int(time.time())}_{uuid.uuid4().hex[:6]}",
-        "target_id": post_id,
-        "target_type": "post",
         "author": current_user,
         "content": content.strip(),
         "created_at": int(time.time())
     }
     
-    comments_db.insert(0, new_comment)
+    # comments_db 是 {item_id: [comments]} 格式
+    post_comments = comments_db.get(post_id, [])
+    post_comments.insert(0, new_comment)
+    comments_db[post_id] = post_comments
     db.save_data("comments.json", comments_db)
     
     # 更新帖子评论数

router_tasks.py

@@ -345,7 +345,9 @@ async def create_task(task: TaskCreate, current_user: str = Depends(require_auth
 @router.put("/api/tasks/{task_id}")
 async def update_task(task_id: str, update_data: TaskUpdate, current_user: str = Depends(require_auth)):
     """
-    更新任务（仅发布者可操作，且仅在 open 状态时可修改）
+    更新任务（仅发布者可操作）
+    - open状态：可修改所有字段
+    - in_progress/submitted状态：只能修改标题/描述/参考图/链接，不能改价格，并通知接单人
     """
     tasks_db = db.load_data("tasks.json", default_data=[])
     
@@ -354,27 +356,52 @@ async def update_task(task_id: str, update_data: TaskUpdate, current_user: str =
             if task.get("publisher") != current_user:
                 raise HTTPException(status_code=403, detail="无权修改他人任务")
             
-            if task.get("status") != "open":
-                raise HTTPException(status_code=400, detail="只能修改开放状态的任务")
+            status = task.get("status")
+            if status not in ["open", "in_progress", "submitted"]:
+                raise HTTPException(status_code=400, detail="当前状态不允许修改")
+            
+            # 记录修改内容（用于通知）
+            changes = []
             
-            if update_data.title is not None:
+            if update_data.title is not None and update_data.title != task.get("title"):
                 task["title"] = update_data.title
-            if update_data.description is not None:
+                changes.append("标题")
+            if update_data.description is not None and update_data.description != task.get("description"):
                 task["description"] = update_data.description
+                changes.append("描述")
             if update_data.referenceImages is not None:
                 task["reference_images"] = update_data.referenceImages[:6]
-            if update_data.referenceLink is not None:
+                changes.append("参考图")
+            if update_data.referenceLink is not None and update_data.referenceLink != task.get("reference_link"):
                 task["reference_link"] = update_data.referenceLink
-            if update_data.totalPrice is not None:
-                task["total_price"] = update_data.totalPrice
-                task["deposit_amount"] = int(update_data.totalPrice * task["deposit_ratio"] / 100)
-            if update_data.depositRatio is not None and update_data.depositRatio in [10, 20, 30, 50]:
-                task["deposit_ratio"] = update_data.depositRatio
-                task["deposit_amount"] = int(task["total_price"] * update_data.depositRatio / 100)
-            if update_data.deadline is not None:
-                task["deadline"] = update_data.deadline
+                changes.append("参考链接")
+            
+            # 价格和订金只能在open状态修改
+            if status == "open":
+                if update_data.totalPrice is not None:
+                    task["total_price"] = update_data.totalPrice
+                    task["deposit_amount"] = int(update_data.totalPrice * task["deposit_ratio"] / 100)
+                    changes.append("价格")
+                if update_data.depositRatio is not None and update_data.depositRatio in [10, 20, 30, 50]:
+                    task["deposit_ratio"] = update_data.depositRatio
+                    task["deposit_amount"] = int(task["total_price"] * update_data.depositRatio / 100)
+                    changes.append("订金比例")
+                if update_data.deadline is not None:
+                    task["deadline"] = update_data.deadline
+                    changes.append("截止日期")
             
             db.save_data("tasks.json", tasks_db)
+            
+            # 📢 如果有接单人，发送通知
+            if task.get("assignee") and changes:
+                add_notification(
+                    task["assignee"],
+                    "task_updated",
+                    f"任务「{task['title']}」已更新：{'、'.join(changes)}",
+                    related_id=task_id,
+                    sender=current_user
+                )
+            
             return {"status": "success"}
     
     raise HTTPException(status_code=404, detail="任务不存在")