42 lines
981 B
PHP
42 lines
981 B
PHP
<?php
|
||
|
||
namespace app\api\job;
|
||
|
||
use think\queue\Job;
|
||
|
||
class imgFile {
|
||
|
||
//put your code here
|
||
|
||
public function fire(Job $job, $data) {
|
||
$res = $this->send($data);
|
||
$job->delete();
|
||
if($res){
|
||
$job->delete();
|
||
}else{
|
||
if($job->attempts()>3){
|
||
// 第1种处理方式：重新发布任务,该任务延迟10秒后再执行
|
||
//$job->release(10);
|
||
// 第2种处理方式：原任务的基础上1分钟执行一次并增加尝试次数
|
||
//$job->failed();
|
||
// 第3种处理方式：删除任务
|
||
$job->delete();
|
||
}
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 保存图片逻辑
|
||
* @param type $data
|
||
*/
|
||
public function send($data){
|
||
$res = file_put_contents($data['mubiao'], file_get_contents($data['yum']));
|
||
if($res){
|
||
return true;
|
||
}else{
|
||
return false;
|
||
}
|
||
}
|
||
|
||
}
|