81 lines
2.1 KiB
PHP
81 lines
2.1 KiB
PHP
<?php
|
||
// +----------------------------------------------------------------------
|
||
// | Niucloud-admin 企业快速开发的saas管理平台
|
||
// +----------------------------------------------------------------------
|
||
// | 官方网址：https://www.niucloud-admin.com
|
||
// +----------------------------------------------------------------------
|
||
// | niucloud团队 版权所有 开源版本可自由商用
|
||
// +----------------------------------------------------------------------
|
||
// | Author: Niucloud Team
|
||
// +----------------------------------------------------------------------
|
||
|
||
namespace core\base;
|
||
|
||
use core\job\Dispatch;
|
||
use think\queue\Job;
|
||
use Throwable;
|
||
|
||
/**
|
||
* 队列
|
||
*/
|
||
abstract class BaseJob extends Dispatch
|
||
{
|
||
|
||
/**
|
||
* 引导
|
||
* @param $name
|
||
* @param $arguments
|
||
*/
|
||
public function __call($name, $arguments)
|
||
{
|
||
$this->fire(...$arguments);
|
||
}
|
||
|
||
|
||
/**
|
||
* 消费任务
|
||
* @param Job $job
|
||
* @param $params
|
||
*/
|
||
public function fire(Job $job, $params): void
|
||
{
|
||
try {
|
||
$action = $params['do'] ?? 'doJob';//任务名
|
||
$data = $params['data'] ?? [];//数据
|
||
$error_count = $params['error_count'] ?? 0;//执行任务错误的最大重试次数
|
||
$this->runJob($action, $job, $data, $error_count);
|
||
} catch ( Throwable $e ) {
|
||
$job->delete();
|
||
}
|
||
}
|
||
|
||
|
||
/**
|
||
* 执行任务
|
||
* @param string $action
|
||
* @param Job $job
|
||
* @param array $data
|
||
* @param int $error_count
|
||
*/
|
||
protected function runJob(string $action, Job $job, array $data, int $error_count = 3)
|
||
{
|
||
$action = method_exists($this, $action) ? $action : 'handle';
|
||
if (!method_exists($this, $action)) {
|
||
$job->delete();
|
||
}
|
||
if ($this->{$action}(...$data)) {
|
||
//删除任务
|
||
$job->delete();
|
||
} else {
|
||
if ($job->attempts() >= $error_count && $error_count) {
|
||
//删除任务
|
||
$job->delete();
|
||
} else {
|
||
//重发任务
|
||
$job->release();
|
||
}
|
||
}
|
||
}
|
||
|
||
}
|