From 131a7c8014458b0b706dfcb51be6447d20273546 Mon Sep 17 00:00:00 2001 From: chengxl Date: Fri, 22 Aug 2025 16:21:06 +0800 Subject: [PATCH] =?UTF-8?q?job=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- application/api/job/ArticleReviewForQueueChunk.php | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/application/api/job/ArticleReviewForQueueChunk.php b/application/api/job/ArticleReviewForQueueChunk.php index 9c8cc78..039e3c6 100644 --- a/application/api/job/ArticleReviewForQueueChunk.php +++ b/application/api/job/ArticleReviewForQueueChunk.php @@ -40,10 +40,10 @@ class ArticleReviewForQueueChunk $job->delete(); return; } - + $sQuestionFields = empty($data['queue_fields']) ? 0 : $data['queue_fields']; // 生成Redis键并尝试获取锁 $sClassName = get_class($this); - $sRedisKey = "queue_job:{$sClassName}:{$iRedisId}:{$sChunkIndex}"; + $sRedisKey = "queue_job:{$sClassName}:{$iRedisId}:{$sQuestionFields}:{$sChunkIndex}"; $sRedisValue = uniqid() . '_' . getmypid(); if (!$this->oQueueJob->acquireLock($sRedisKey, $sRedisValue, $job)) { return; // 未获取到锁,已处理