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;