diff --git a/application/api/job/ArticleReview.php b/application/api/job/ArticleReview.php index 64cc707..acdfa6a 100644 --- a/application/api/job/ArticleReview.php +++ b/application/api/job/ArticleReview.php @@ -32,6 +32,10 @@ class ArticleReview // 获取文章ID $iArticleId = empty($data['article_id']) ? 0 : $data['article_id']; + //问题等级 + $sQuestionLevel = empty($data['question_level']) ? 'A' : $data['question_level']; + //需要处理的AI问题字段 + $sQuestionFields = empty($data['queue_fields']) ? 'journal_scope' : $data['queue_fields']; if (empty($iArticleId)) { $this->oQueueJob->log("无效的article_id,删除任务"); $job->delete(); @@ -41,7 +45,7 @@ class ArticleReview // 生成Redis键并尝试获取锁 $sClassName = get_class($this); - $sRedisKey = "queue_job:{$sClassName}:{$iArticleId}"; + $sRedisKey = "queue_job:{$sClassName}:{$iArticleId}_{$sQuestionLevel}_{$sQuestionFields}"; $sRedisValue = uniqid() . '_' . getmypid(); if (!$this->oQueueJob->acquireLock($sRedisKey, $sRedisValue, $job)) { return; // 未获取到锁,已处理