From 2b128195bf3416717dc0d38a66ac57ad4c998688 Mon Sep 17 00:00:00 2001
From: wong <106998207@qq.com>
Date: Thu, 8 Jan 2026 11:50:32 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BB=A3=E7=A0=81=E5=90=8C=E6=AD=A5?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../job/MessageChatroomListJob.php            | 20 ++++++++++++++-----
 .../application/job/MessageFriendsListJob.php | 18 +++++++++++++----
 2 files changed, 29 insertions(+), 9 deletions(-)

diff --git a/Server/application/job/MessageChatroomListJob.php b/Server/application/job/MessageChatroomListJob.php
index e3db929d..d66112d2 100644
--- a/Server/application/job/MessageChatroomListJob.php
+++ b/Server/application/job/MessageChatroomListJob.php
@@ -10,6 +10,11 @@ use app\api\controller\MessageController;
 
 class MessageChatroomListJob
 {
+    /**
+     * 最大同步页数
+     */
+    const MAX_SYNC_PAGES = 5;
+    
     /**
      * 队列任务处理
      * @param Job $job 队列任务
@@ -81,12 +86,17 @@ class MessageChatroomListJob
         if ($response['code'] == 200) {
             $data = $response['data'];
             
-            // 判断是否有下一页
-            if (!empty($data) && count($data['results']) > 0) {
-                // 有下一页，将下一页任务添加到队列
+            // 判断是否有下一页，且未超过最大同步页数
+            if (!empty($data) && count($data) > 0) {
                 $nextPageIndex = $pageIndex + 1;
-                $this->addNextPageToQueue($nextPageIndex, $pageSize);
-                Log::info('添加下一页任务到队列，页码：' . $nextPageIndex);
+                // 检查是否超过最大同步页数
+                if ($nextPageIndex < self::MAX_SYNC_PAGES) {
+                    // 有下一页且未超过最大页数，将下一页任务添加到队列
+                    $this->addNextPageToQueue($nextPageIndex, $pageSize);
+                    Log::info('添加下一页任务到队列，页码：' . $nextPageIndex);
+                } else {
+                    Log::info('已达到最大同步页数（' . self::MAX_SYNC_PAGES . '），停止添加下一页任务');
+                }
             }
             
             return true;
diff --git a/Server/application/job/MessageFriendsListJob.php b/Server/application/job/MessageFriendsListJob.php
index ee7c3092..408bfe00 100644
--- a/Server/application/job/MessageFriendsListJob.php
+++ b/Server/application/job/MessageFriendsListJob.php
@@ -10,6 +10,11 @@ use app\api\controller\MessageController;
 
 class MessageFriendsListJob
 {
+    /**
+     * 最大同步页数
+     */
+    const MAX_SYNC_PAGES = 5;
+    
     /**
      * 队列任务处理
      * @param Job $job 队列任务
@@ -83,12 +88,17 @@ class MessageFriendsListJob
         if ($response['code'] == 200) {
             $data = $response['data'];
             
-            // 判断是否有下一页
+            // 判断是否有下一页，且未超过最大同步页数
             if (!empty($data) && count($data) > 0) {
-                // 有下一页，将下一页任务添加到队列
                 $nextPageIndex = $pageIndex + 1;
-                $this->addNextPageToQueue($nextPageIndex, $pageSize);
-                Log::info('添加下一页任务到队列，页码：' . $nextPageIndex);
+                // 检查是否超过最大同步页数
+                if ($nextPageIndex < self::MAX_SYNC_PAGES) {
+                    // 有下一页且未超过最大页数，将下一页任务添加到队列
+                    $this->addNextPageToQueue($nextPageIndex, $pageSize);
+                    Log::info('添加下一页任务到队列，页码：' . $nextPageIndex);
+                } else {
+                    Log::info('已达到最大同步页数（' . self::MAX_SYNC_PAGES . '），停止添加下一页任务');
+                }
             }
             
             return true;