优化消息系统

router_comments.py

@@ -57,9 +57,13 @@ async def post_comment(comment: CommentCreate):
     else: 
         item_comments.append(new_comment)
         items_db = db.load_data("items.json", default_data=[])
+        posts_db = db.load_data("posts.json", default_data=[])
         target_item = next((item for item in items_db if item["id"] == comment.item_id), None)
+        target_post = next((post for post in posts_db if post["id"] == comment.item_id), None)
         if target_item:
             add_notification(target_item.get("author", ""), {"type": "comment", "from_user": comment.author, "target_item_id": comment.item_id, "target_item_title": target_item["title"], "content": comment.content})
+        elif target_post:
+            add_notification(target_post.get("author", ""), {"type": "comment", "from_user": comment.author, "target_item_id": comment.item_id, "target_item_title": target_post.get("title", "") or "", "content": comment.content})
         elif comment.item_id in users_db:
             add_notification(comment.item_id, {"type": "comment", "from_user": comment.author, "target_item_id": comment.item_id, "target_item_title": "您的个人留言板", "content": comment.content})
 

router_wallet.py

@@ -472,12 +472,13 @@ async def tip_user(request: Request, req: TipRequest, db: Session = Depends(get_
         
         # 🔔 打赏通知（考虑匿名）
         if not req.is_anonymous:
+            sender_display = sender_user_name if sender_user_name else req.sender_account
             add_notification(req.target_account, {
                 "type": "tip",
                 "from_user": req.sender_account,
                 "target_item_id": req.item_id or "",
-                "target_item_title": "",
-                "content": f"您收到来自 {req.sender_account} 的 {req.amount} 积分打赏"
+                "target_item_title": item_title or "",
+                "content": f"您收到来自 {sender_display} 的 {req.amount} 积分打赏"
             })
         else:
             add_notification(req.target_account, {

数据库连接.py

@@ -55,6 +55,9 @@ _dirty_files = set()                  # 记录自上次同步以来有变更的
 _dirty_files_lock = threading.Lock()
 _BATCH_SYNC_INTERVAL = 30             # 批量同步间隔（秒），默认30秒（HF限制128 commits/hour，30秒间隔=最多120 commits/hour）
 _batch_sync_timer = None              # 定时器引用
+_sync_backoff_seconds = 0             # 当前退避秒数（0=正常）
+_sync_consecutive_failures = 0        # 连续失败次数
+_SYNC_MAX_BACKOFF = 300               # 最大退避：5分钟
 
 # 确保目录存在
 os.makedirs(LOCAL_DB_DIR, exist_ok=True)
@@ -428,6 +431,8 @@ def _mark_dirty(file_name: str):
 
 def _batch_sync_to_hf(schedule_next=True):
     """批量同步所有脏文件到 HF Dataset（单次 commit）"""
+    global _sync_consecutive_failures, _sync_backoff_seconds
+
     # 取出脏文件列表并清空
     with _dirty_files_lock:
         files_to_sync = list(_dirty_files)
@@ -459,6 +464,9 @@ def _batch_sync_to_hf(schedule_next=True):
                 commit_message=f"batch sync: {', '.join(files_to_sync)}"
             )
             logger.info(f"✅ 批量同步成功: {len(operations)} 个文件 ({', '.join(files_to_sync)})")
+            # 同步成功：重置退避状态
+            _sync_consecutive_failures = 0
+            _sync_backoff_seconds = 0
         else:
             logger.info("⏭️ 批量同步: 脏文件均不存在，跳过")
     except Exception as e:
@@ -466,6 +474,14 @@ def _batch_sync_to_hf(schedule_next=True):
         # 失败的文件重新标记为脏，下次重试
         with _dirty_files_lock:
             _dirty_files.update(files_to_sync)
+        # 429 限流：启用指数退避
+        if "429" in str(e) or "Too Many Requests" in str(e):
+            _sync_consecutive_failures += 1
+            _sync_backoff_seconds = min(
+                _BATCH_SYNC_INTERVAL * (2 ** _sync_consecutive_failures),
+                _SYNC_MAX_BACKOFF
+            )
+            logger.warning(f"⚠️ HF 限流，退避 {_sync_backoff_seconds} 秒后重试")
     finally:
         if schedule_next:
             _schedule_next_sync()
@@ -473,8 +489,9 @@ def _batch_sync_to_hf(schedule_next=True):
 
 def _schedule_next_sync():
     """调度下一轮批量同步"""
-    global _batch_sync_timer
-    _batch_sync_timer = threading.Timer(_BATCH_SYNC_INTERVAL, _batch_sync_to_hf)
+    global _batch_sync_timer, _sync_backoff_seconds
+    interval = _sync_backoff_seconds if _sync_backoff_seconds > 0 else _BATCH_SYNC_INTERVAL
+    _batch_sync_timer = threading.Timer(interval, _batch_sync_to_hf)
     _batch_sync_timer.daemon = True
     _batch_sync_timer.start()