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; // 未获取到锁,已处理