fnvtk/cunkebao_v3
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

代码同步

Browse Source
This commit is contained in:
wong
2026-01-08 11:50:32 +08:00
parent e469537ac5
commit 2b128195bf
2 changed files with 29 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

20
Server/application/job/MessageChatroomListJob.php
View File

@@ -10,6 +10,11 @@ use app\api\controller\MessageController;
class MessageChatroomListJob class MessageChatroomListJob
{ {
/**
* 最大同步页数
*/
const MAX_SYNC_PAGES = 5;
/** /**
* 队列任务处理 * 队列任务处理
* @param Job $job 队列任务 * @param Job $job 队列任务
@@ -81,12 +86,17 @@ class MessageChatroomListJob
if ($response['code'] == 200) { if ($response['code'] == 200) {
$data = $response['data']; $data = $response['data'];
// 判断是否有下一页 // 判断是否有下一页，且未超过最大同步页数
if (!empty($data) && count($data['results']) > 0) { if (!empty($data) && count($data) > 0) {
// 有下一页，将下一页任务添加到队列
$nextPageIndex = $pageIndex + 1; $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; return true;

18
Server/application/job/MessageFriendsListJob.php
View File

@@ -10,6 +10,11 @@ use app\api\controller\MessageController;
class MessageFriendsListJob class MessageFriendsListJob
{ {
/**
* 最大同步页数
*/
const MAX_SYNC_PAGES = 5;
/** /**
* 队列任务处理 * 队列任务处理
* @param Job $job 队列任务 * @param Job $job 队列任务
@@ -83,12 +88,17 @@ class MessageFriendsListJob
if ($response['code'] == 200) { if ($response['code'] == 200) {
$data = $response['data']; $data = $response['data'];
// 判断是否有下一页 // 判断是否有下一页，且未超过最大同步页数
if (!empty($data) && count($data) > 0) { if (!empty($data) && count($data) > 0) {
// 有下一页，将下一页任务添加到队列
$nextPageIndex = $pageIndex + 1; $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; return true;