fix: limit 1050 + 修复图片处理逻辑被移出循环的bug

image_daemon.py

@@ -58,7 +58,7 @@ def get_bot_chats(token):
         log(f"❌ get_bot_chats 异常: {type(e).__name__}: {e}")
         return []
 
-def get_recent_messages(token, chat_id, limit=10):
+def get_recent_messages(token, chat_id, limit=50):
     """获取聊天中最近的消息"""
     try:
         headers = {"Authorization": f"Bearer {token}"}
@@ -140,7 +140,6 @@ def upload_image(data):
 
     # 2. Telegraph (Telegra.ph) — 无需 API key
     try:
-        import base64
         # Telegraph 的图片上传接口
         resp = requests.post("https://telegra.ph/upload",
             files={"file": ("img.jpg", data, "image/jpeg")}, timeout=30)
@@ -288,9 +287,7 @@ def main():
 
             new_imgs = 0
             for chat_id in chats:
-                # 首轮用大 limit 获取更多历史消息
-                limit = 20 if cycle == 1 else 10
-                messages = get_recent_messages(token, chat_id, limit=limit)
+                messages = get_recent_messages(token, chat_id)
 
                 # 首轮打印所有消息类型统计
                 if cycle == 1:
@@ -301,11 +298,13 @@ def main():
                     log(f"📊 聊天 {chat_id[:12]}... 共 {len(messages)} 条消息")
                     log(f"   消息类型分布: {type_counts}")
 
+                new_in_chat = 0
                 for msg in messages:
                     msg_id = msg.get("message_id", "")
                     if msg_id in processed:
                         continue
                     processed.add(msg_id)
+                    new_in_chat += 1
 
                     msg_type = msg.get("msg_type", "")
                     sender_type = msg.get("sender", {}).get("sender_type", "")
@@ -319,6 +318,10 @@ def main():
                         process_message(token, chat_id, msg)
                         new_imgs += 1
 
+                if new_in_chat > 0 or cycle % 20 == 0:
+                    log(f"📊 chat={chat_id[:12]}... 拉取 {len(messages)} 条, 新 {new_in_chat} 条, 已知 {len(processed)} 条")
+
+
             if new_imgs > 0:
                 save_processed(processed)