优化消息

router_messages.py

@@ -203,12 +203,48 @@ async def get_chat_history(account: str, target_account: str):
 # ==========================================
 # 改造：获取通知列表 (加入系统公告懒加载注入)
 # 使用 atomic_update 避免并发覆盖问题
+# 🔥 性能优化：先用只读方式检查是否有实际变更，避免无意义的写入和HF上传
 # ==========================================
 @router.get("/api/messages/{account}")
 async def get_messages(account: str):
-    # 公告是只读的，在 atomic_update 外加载
+    # 公告是只读的，先加载
     announcements_db = db.load_data("announcements.json", default_data=[])
     
+    # 🔥 性能优化：先用只读方式检查是否有实际变更需要写入
+    messages_db = db.load_data("messages.json", default_data={})
+    user_msgs = messages_db.get(account, [])
+    
+    now = int(time.time())
+    seven_days = 7 * 24 * 3600
+    
+    # 检查三个条件判断是否需要写入
+    # 1. 是否有新公告需要注入
+    user_msg_ids = {m.get("id") for m in user_msgs}
+    has_new_announcements = any(
+        ann.get("id") not in user_msg_ids 
+        for ann in announcements_db
+    )
+    
+    # 2. 是否有未读消息需要标记已读
+    has_unread = any(not m.get("is_read") for m in user_msgs)
+    
+    # 3. 是否有已读超过7天的消息需要清理
+    has_expired = any(
+        m.get("is_read") and (now - m.get("created_at", 0) >= seven_days)
+        for m in user_msgs
+    )
+    
+    needs_update = has_new_announcements or has_unread or has_expired
+    
+    if not needs_update:
+        # 无变更，直接返回只读数据，不触发写入和HF上传
+        return {
+            "status": "success",
+            "data": user_msgs,
+            "unread_count": 0  # 用户已查看消息列表，未读数设为0
+        }
+    
+    # 有变更需要写入，使用 atomic_update 保证并发安全
     result_container = [None]
     
     def updater(data):
@@ -248,7 +284,6 @@ async def get_messages(account: str):
             if not m.get("is_read"):
                 m["is_read"] = True
                 modified = True
-        
         # 原地修改 data，atomic_update 会自动保存
         data[account] = valid