yanzong/cores/BaseJob.php

82 lines
2.7 KiB

11 months ago
<?php
// +----------------------------------------------------------------------
// | 萤火商城系统 [ 致力于通过产品和服务,帮助商家高效化开拓市场 ]
// +----------------------------------------------------------------------
// | Copyright (c) 2017~2023 https://www.yiovo.com All rights reserved.
// +----------------------------------------------------------------------
// | Licensed 这不是一个自由软件,不允许对程序代码以任何形式任何目的的再发行
// +----------------------------------------------------------------------
// | Author: 萤火科技 <admin@yiovo.com>
// +----------------------------------------------------------------------
declare (strict_types=1);
namespace cores;
use app\common\library\Log;
use app\common\service\system\Process as SystemProcessService;
use think\queue\Job;
/**
* 队列任务基类
* Class BaseJob
* @package cores\job
*/
abstract class BaseJob
{
/**
* 队列任务初始化
*/
public function __construct()
{
// 记录定时任务最后执行时间
SystemProcessService::setLastWorkingTime('queue');
}
// 执行具体的任务 (消费者)
abstract public function handle(array $data): bool;
/**
* 队列任务线程 (消费者)
* @param Job $job 当前的任务对象
* @param array $data 发布任务时自定义的数据
*/
public function fire(Job $job, array $data)
{
try {
// ....这里执行具体的任务
// 任务中如果要中断当前进程比如exit die,那么需要在这之前执行$job->delete(),否则会一直重复
$this->handle($data);
tre('队列任务成功');
// 成功删除任务
$job->delete();
} catch (\Throwable $e) {
tre('队列任务出错');
tre('当前执行次数:' . $job->attempts());
tre('错误信息:' . $e->getMessage());
tre('trace:' . $e->getTraceAsString());
// 记录日志
Log::error([
'name' => '队列任务出错',
'jobClass' => get_called_class(),
'attempts' => $job->attempts(),
'errMessage' => $e->getMessage(),
'trace' => $e->getTraceAsString(),
]);
// 任务有报错 重试执行3次后删除
if (is_debug() || $job->attempts() >= 3) {
$job->delete();
} else {
// 不成功延迟10秒再次发布
$job->release(10);
}
}
}
/**
* 发布失败
* @param $data
*/
public function failed($data)
{
}
}