zm/tougao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Ai 话术调整

Browse Source
This commit is contained in:
chengxl
2025-08-21 15:31:49 +08:00
parent ebe45a1e19
commit 4f076f5b04
1 changed files with 5 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

6
application/api/job/ArticleReview.php
View File

@@ -32,6 +32,10 @@ class ArticleReview
// 获取文章ID // 获取文章ID
$iArticleId = empty($data['article_id']) ? 0 : $data['article_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)) { if (empty($iArticleId)) {
$this->oQueueJob->log("无效的article_id，删除任务"); $this->oQueueJob->log("无效的article_id，删除任务");
$job->delete(); $job->delete();
@@ -41,7 +45,7 @@ class ArticleReview
// 生成Redis键并尝试获取锁 // 生成Redis键并尝试获取锁
$sClassName = get_class($this); $sClassName = get_class($this);
$sRedisKey = "queue_job:{$sClassName}:{$iArticleId}"; $sRedisKey = "queue_job:{$sClassName}:{$iArticleId}_{$sQuestionLevel}_{$sQuestionFields}";
$sRedisValue = uniqid() . '_' . getmypid(); $sRedisValue = uniqid() . '_' . getmypid();
if (!$this->oQueueJob->acquireLock($sRedisKey, $sRedisValue, $job)) { if (!$this->oQueueJob->acquireLock($sRedisKey, $sRedisValue, $job)) {
return; // 未获取到锁，已处理 return; // 未获取到锁，已处理