20201112
This commit is contained in:
@@ -11,9 +11,11 @@ class mail {
|
|||||||
public function fire(Job $job, $data) {
|
public function fire(Job $job, $data) {
|
||||||
$res = $this->send($data);
|
$res = $this->send($data);
|
||||||
if($res){
|
if($res){
|
||||||
|
file_put_contents('/usr/local/email.txt', 'log_time:'.date('Y-m-d H:i:s').' success:to '.$data['email'].PHP_EOL, FILE_APPEND);
|
||||||
$job->delete();
|
$job->delete();
|
||||||
}else{
|
}else{
|
||||||
if($job->attempts()>3){
|
if($job->attempts()>3){
|
||||||
|
file_put_contents('/usr/local/email.txt', 'log_time:'.date('Y-m-d H:i:s').' error:to '.$data['email'].PHP_EOL, FILE_APPEND);
|
||||||
// 第1种处理方式:重新发布任务,该任务延迟10秒后再执行
|
// 第1种处理方式:重新发布任务,该任务延迟10秒后再执行
|
||||||
//$job->release(10);
|
//$job->release(10);
|
||||||
// 第2种处理方式:原任务的基础上1分钟执行一次并增加尝试次数
|
// 第2种处理方式:原任务的基础上1分钟执行一次并增加尝试次数
|
||||||
|
|||||||
Reference in New Issue
Block a user