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

job修改

Browse Source
This commit is contained in:
chengxl
2025-08-22 16:21:06 +08:00
parent fd5817348a
commit 131a7c8014
1 changed files with 2 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
application/api/job/ArticleReviewForQueueChunk.php
View File

@@ -40,10 +40,10 @@ class ArticleReviewForQueueChunk
$job->delete(); $job->delete();
return; return;
} }
$sQuestionFields = empty($data['queue_fields']) ? 0 : $data['queue_fields'];
// 生成Redis键并尝试获取锁 // 生成Redis键并尝试获取锁
$sClassName = get_class($this); $sClassName = get_class($this);
$sRedisKey = "queue_job:{$sClassName}:{$iRedisId}:{$sChunkIndex}"; $sRedisKey = "queue_job:{$sClassName}:{$iRedisId}:{$sQuestionFields}:{$sChunkIndex}";
$sRedisValue = uniqid() . '_' . getmypid(); $sRedisValue = uniqid() . '_' . getmypid();
if (!$this->oQueueJob->acquireLock($sRedisKey, $sRedisValue, $job)) { if (!$this->oQueueJob->acquireLock($sRedisKey, $sRedisValue, $job)) {
return; // 未获取到锁，已处理 return; // 未获取到锁，已处理