sendEmail($data['email'], $data['title'], $data['subject']); if ($bool) { $success = true; break; } trace($job->getJobId().'---重试-----'.$times, 'info'); } // 任务失败 if (!$success) { trace($job->getJobId().'---失败-------'.json_encode($data), 'info'); } // 删除任务 $job->delete(); } public function failed($data) { // 失败任务 $dataStr = json_encode($data); trace('queue job 任务失败---'.$dataStr, 'error'); } }