From 4f076f5b04e5bfeec074646369871c27dfc8a8b9 Mon Sep 17 00:00:00 2001 From: chengxl Date: Thu, 21 Aug 2025 15:31:49 +0800 Subject: [PATCH] =?UTF-8?q?Ai=20=E8=AF=9D=E6=9C=AF=E8=B0=83=E6=95=B4?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- application/api/job/ArticleReview.php | 6 +++++- 1 file changed, 5 insertions(+), 1 deletion(-) 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; // 未获取到锁，已处理