diff --git a/application/common/QueueJob.php b/application/common/QueueJob.php index b336fb7..d4b194f 100644 --- a/application/common/QueueJob.php +++ b/application/common/QueueJob.php @@ -300,11 +300,11 @@ class QueueJob $attempts = $job->attempts(); if ($attempts >= $this->maxRetries) { - $this->log("超过最大重试次数({$this->maxRetries}),停止重试"); + $this->log("超过最大重试次数({$this->maxRetries}),停止重试 | 执行日志:{$sMsg}"); $job->delete(); } else { $delay = $this->getRetryDelay($sMsg); - $this->log("{$delay}秒后重试({$attempts}/{$this->maxRetries})"); + $this->log("{$delay}秒后重试({$attempts}/{$this->maxRetries}) | 执行日志:{$sMsg}"); $job->release($delay); } } @@ -331,7 +331,7 @@ class QueueJob } $this->QueueRedis->finishJob($sRedisKey, 'failed', 3600); - $this->log("不可重试错误,直接删除任务"); + $this->log("不可重试错误,直接删除任务 | 执行日志:{$sMsg}"); $job->delete(); }