This commit is contained in:
chengxl
2025-10-13 16:50:19 +08:00
parent 80ac383a1e
commit 7f62f77777

View File

@@ -37,13 +37,11 @@ class ArticleProofRead
$job->delete(); $job->delete();
return; return;
} }
// 段落ID
$iAmId = empty($data['am_id']) ? 0 : $data['am_id'];
try { try {
// 生成Redis键并尝试获取锁 // 生成Redis键并尝试获取锁
$sClassName = get_class($this); $sClassName = get_class($this);
$sRedisKey = "queue_job:{$sClassName}:{$iArticleId}:{$iAmId}"; $sRedisKey = "queue_job:{$sClassName}:{$iArticleId}";
$sRedisValue = uniqid() . '_' . getmypid(); $sRedisValue = uniqid() . '_' . getmypid();
if (!$this->oQueueJob->acquireLock($sRedisKey, $sRedisValue, $job)) { if (!$this->oQueueJob->acquireLock($sRedisKey, $sRedisValue, $job)) {
return; // 未获取到锁,已处理 return; // 未获取到锁,已处理