zm/tougao
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

20201112

Browse Source
This commit is contained in:
wangjinlei
2021-02-06 13:42:34 +08:00
parent e244529d34
commit d3b80b03c7
1 changed files with 19 additions and 17 deletions
Download Patch File Download Diff File Expand all files Collapse all files

36
application/api/job/review.php
View File

@@ -4,6 +4,7 @@ namespace app\api\job;
use think\queue\Job;
use think\Db;
use think\Queue;
/**
* Description of review
@@ -37,23 +38,24 @@ class review {
}
public function fire(Job $job, $data) {
$res = $this->checkrev($data);
// $res = $this->testemail($data);
if ($res) {
file_put_contents('/usr/local/1.txt', 'log_time:'.date('Y-m-d H:i:s').' success:'.$data['title'].PHP_EOL, FILE_APPEND);
$job->delete();
} else {
if ($job->attempts() > 3) {
file_put_contents('/usr/local/1.txt', 'log_time:'.date('Y-m-d H:i:s').' error:'.$data['title'].PHP_EOL, FILE_APPEND);
// 第1种处理方式：重新发布任务,该任务延迟10秒后再执行
//$job->release(10);
// 第2种处理方式：原任务的基础上1分钟执行一次并增加尝试次数
//$job->failed();
// 第3种处理方式：删除任务
$job->delete();
}
$job->delete();
}
echo "Temporarily Out of Service";
$job->delete();
// $res = $this->checkrev($data);
// if ($res) {
// file_put_contents('/usr/local/1.txt', 'log_time:'.date('Y-m-d H:i:s').' success:'.$data['title'].PHP_EOL, FILE_APPEND);
// $job->delete();
// } else {
// if ($job->attempts() > 3) {
// file_put_contents('/usr/local/1.txt', 'log_time:'.date('Y-m-d H:i:s').' error:'.$data['title'].PHP_EOL, FILE_APPEND);
// // 第1种处理方式：重新发布任务,该任务延迟10秒后再执行
// //$job->release(10);
// // 第2种处理方式：原任务的基础上1分钟执行一次并增加尝试次数
// //$job->failed();
// // 第3种处理方式：删除任务
// $job->delete();
// }
// $job->delete();
// }
}
public function testemail($data) {