Ai 话术调整
This commit is contained in:
@@ -37,11 +37,12 @@ class ArticleAiCreateContent
|
|||||||
$job->delete();
|
$job->delete();
|
||||||
return;
|
return;
|
||||||
}
|
}
|
||||||
|
$iPArticleId = empty($data['p_article_id']) ? 0 : $data['p_article_id'];
|
||||||
try {
|
try {
|
||||||
|
|
||||||
// 生成Redis键并尝试获取锁
|
// 生成Redis键并尝试获取锁
|
||||||
$sClassName = get_class($this);
|
$sClassName = get_class($this);
|
||||||
$sRedisKey = "queue_job:{$sClassName}:{$iArticleId}";
|
$sRedisKey = "queue_job:{$sClassName}:{$iArticleId}:{$iPArticleId}";
|
||||||
$sRedisValue = uniqid() . '_' . getmypid();
|
$sRedisValue = uniqid() . '_' . getmypid();
|
||||||
if (!$this->oQueueJob->acquireLock($sRedisKey, $sRedisValue, $job)) {
|
if (!$this->oQueueJob->acquireLock($sRedisKey, $sRedisValue, $job)) {
|
||||||
return; // 未获取到锁,已处理
|
return; // 未获取到锁,已处理
|
||||||
|
|||||||
Reference in New Issue
Block a user