Upload routers.py

routers.py

@@ -215,14 +215,14 @@ async def soft_delete_comment(item_id: str, comment_id: str, author: str):
         return {"status": "success"}
     raise HTTPException(status_code=404, detail="找不到该评论")
 
-# --- 4. 专属聊天信箱聚合 ---
+# --- 4. 专属聊天信箱聚合 (【核心更新】：已读超过7天自动释放) ---
 @router.post("/api/messages/private")
 async def send_private_message(msg: PrivateMessage):
     chats_db = db.load_data("chats.json", default_data={})
     conv_id = f"{min(msg.sender, msg.receiver)}_{max(msg.sender, msg.receiver)}"
     if conv_id not in chats_db: chats_db[conv_id] = []
     
-    chat_msg = {"id": f"chat_{int(time.time())}", "sender": msg.sender, "receiver": msg.receiver, "content": msg.content, "created_at": int(time.time()), "is_read": False}
+    chat_msg = {"id": f"chat_{int(time.time())}_{uuid.uuid4().hex[:6]}", "sender": msg.sender, "receiver": msg.receiver, "content": msg.content, "created_at": int(time.time()), "is_read": False}
     chats_db[conv_id].append(chat_msg)
     db.save_data("chats.json", chats_db)
     
@@ -234,16 +234,22 @@ async def get_chat_list(account: str):
     chats_db = db.load_data("chats.json", default_data={})
     users_db = db.load_data("users.json", default_data={})
     chat_list = []
+    now = int(time.time())
+    seven_days = 7 * 24 * 3600
+    
     for conv_id, msgs in chats_db.items():
         accs = conv_id.split("_")
         if account in accs and msgs:
-            target = accs[0] if accs[1] == account else accs[1]
-            target_info = users_db.get(target, {})
-            chat_list.append({
-                "target_account": target, "target_name": target_info.get("name", target),
-                "last_message": msgs[-1]["content"], "last_time": msgs[-1]["created_at"],
-                "unread": sum(1 for m in msgs if m["receiver"] == account and not m["is_read"])
-            })
+            # 列表中只统计有效消息
+            valid_msgs = [m for m in msgs if not m.get("is_read") or (now - m.get("created_at", 0) < seven_days)]
+            if valid_msgs:
+                target = accs[0] if accs[1] == account else accs[1]
+                target_info = users_db.get(target, {})
+                chat_list.append({
+                    "target_account": target, "target_name": target_info.get("name", target),
+                    "last_message": valid_msgs[-1]["content"], "last_time": valid_msgs[-1]["created_at"],
+                    "unread": sum(1 for m in valid_msgs if m["receiver"] == account and not m.get("is_read"))
+                })
     chat_list.sort(key=lambda x: x["last_time"], reverse=True)
     return {"status": "success", "data": chat_list}
 
@@ -253,17 +259,50 @@ async def get_chat_history(account: str, target: str):
     conv_id = f"{min(account, target)}_{max(account, target)}"
     msgs = chats_db.get(conv_id, [])
     
+    now = int(time.time())
+    seven_days = 7 * 24 * 3600
+    valid_msgs = []
     modified = False
+    
     for m in msgs:
-        if m["receiver"] == account and not m["is_read"]: m["is_read"] = True; modified = True
-    if modified: db.save_data("chats.json", chats_db)
-    return {"status": "success", "data": msgs}
+        # 【核心策略】：未读的永远保留，已读的超过 7 天直接抛弃
+        if not m.get("is_read") or (now - m.get("created_at", 0) < seven_days):
+            valid_msgs.append(m)
+        else:
+            modified = True
+            
+        # 本次访问即为已读
+        if m["receiver"] == account and not m.get("is_read"): 
+            m["is_read"] = True
+            modified = True
+            
+    if modified or len(valid_msgs) != len(msgs): 
+        chats_db[conv_id] = valid_msgs
+        db.save_data("chats.json", chats_db)
+        
+    return {"status": "success", "data": valid_msgs}
 
 @router.get("/api/messages/{account}")
 async def get_messages(account: str):
     msgs_db = db.load_data("messages.json", default_data={})
     user_msgs = msgs_db.get(account, [])
-    return {"status": "success", "data": user_msgs, "unread_count": sum(1 for m in user_msgs if not m.get("is_read"))}
+    
+    now = int(time.time())
+    seven_days = 7 * 24 * 3600
+    valid = []
+    modified = False
+    
+    for m in user_msgs:
+        if not m.get("is_read") or (now - m.get("created_at", 0) < seven_days):
+            valid.append(m)
+        else:
+            modified = True
+            
+    if modified:
+        msgs_db[account] = valid
+        db.save_data("messages.json", msgs_db)
+        
+    return {"status": "success", "data": valid, "unread_count": sum(1 for m in valid if not m.get("is_read"))}
 
 @router.post("/api/messages/{account}/read")
 async def mark_messages_read(account: str):