add:新增定时任务基类
This commit is contained in:
parent
42ffcb75c7
commit
a98fbdc7a1
@ -8,3 +8,95 @@
|
|||||||
// +----------------------------------------------------------------------
|
// +----------------------------------------------------------------------
|
||||||
// | Author: JaguarJack [ njphper@gmail.com ]
|
// | Author: JaguarJack [ njphper@gmail.com ]
|
||||||
// +----------------------------------------------------------------------
|
// +----------------------------------------------------------------------
|
||||||
|
namespace catcher\base;
|
||||||
|
|
||||||
|
use catchAdmin\monitor\model\CrontabLog;
|
||||||
|
|
||||||
|
abstract class CatchCronTask
|
||||||
|
{
|
||||||
|
protected $exceptionHappenTimes = 0;
|
||||||
|
|
||||||
|
protected $exitTimes = 1;
|
||||||
|
|
||||||
|
protected $crontab;
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @time 2020年07月29日
|
||||||
|
* @return mixed
|
||||||
|
*/
|
||||||
|
public abstract function deal();
|
||||||
|
|
||||||
|
/**
|
||||||
|
* @time 2020年07月29日
|
||||||
|
* @param \Throwable $e
|
||||||
|
* @return mixed
|
||||||
|
*/
|
||||||
|
public abstract function dealWithException(\Throwable $e);
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 执行
|
||||||
|
*
|
||||||
|
* @time 2020年07月23日
|
||||||
|
* @return void|bool
|
||||||
|
*/
|
||||||
|
public function run()
|
||||||
|
{
|
||||||
|
$startAt = round(microtime(true) * 1000);
|
||||||
|
try {
|
||||||
|
if ($this->deal() === false) {
|
||||||
|
return false;
|
||||||
|
}
|
||||||
|
$this->recordLog($startAt);
|
||||||
|
return true;
|
||||||
|
} catch (\Throwable $e) {
|
||||||
|
$this->dealWithException($e);
|
||||||
|
echo 'File:' . $e->getFile() . ', Lines: '. $e->getLine() .'行,Exception Message: ' . $e->getMessage() . PHP_EOL;
|
||||||
|
// 输出堆栈信息
|
||||||
|
echo $e->getTraceAsString() . PHP_EOL;
|
||||||
|
// 日志记录
|
||||||
|
$this->recordLog($startAt, 'File:' . $e->getFile() . ', Lines: '. $e->getLine() .'行,Exception Message: ' . $e->getMessage());
|
||||||
|
$this->exceptionHappenTimes += 1;
|
||||||
|
}
|
||||||
|
|
||||||
|
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 退出
|
||||||
|
*
|
||||||
|
* @time 2020年07月29日
|
||||||
|
* @return bool
|
||||||
|
*/
|
||||||
|
public function shouldExit()
|
||||||
|
{
|
||||||
|
// var_dump($this->exceptionHappenTimes);
|
||||||
|
return $this->exceptionHappenTimes > $this->exitTimes;
|
||||||
|
}
|
||||||
|
|
||||||
|
/**
|
||||||
|
* 设置 crontab
|
||||||
|
*
|
||||||
|
* @time 2020年09月15日
|
||||||
|
* @param array $crontab
|
||||||
|
* @return $this
|
||||||
|
*/
|
||||||
|
public function setCrontab(array $crontab)
|
||||||
|
{
|
||||||
|
$this->crontab = $crontab;
|
||||||
|
|
||||||
|
return $this;
|
||||||
|
}
|
||||||
|
|
||||||
|
protected function recordLog($startAt, $message = '')
|
||||||
|
{
|
||||||
|
$endAt = round(microtime(true) * 1000);
|
||||||
|
CrontabLog::insert([
|
||||||
|
'crontab_id' => $this->crontab['id'],
|
||||||
|
'used_time' => $endAt - $startAt,
|
||||||
|
'error_message' => $message,
|
||||||
|
'status' => $message ? CrontabLog::FAILED : CrontabLog::SUCCESS,
|
||||||
|
'created_at' => time(),
|
||||||
|
'updated_at' => time(),
|
||||||
|
]);
|
||||||
|
}
|
||||||
|
}
|
Loading…
x
Reference in New Issue
Block a user