update code

This commit is contained in:
全栈小学生
2023-09-06 14:52:30 +08:00
parent 8f2e36cfa4
commit 36967076d4
1706 changed files with 63614 additions and 17748 deletions

View File

@@ -13,6 +13,7 @@ namespace core\base;
use core\job\Dispatch;
use think\queue\Job;
use Throwable;
/**
* 队列
@@ -43,7 +44,7 @@ abstract class BaseJob extends Dispatch
$data = $params['data'] ?? [];//数据
$error_count = $params['error_count'] ?? 0;//执行任务错误的最大重试次数
$this->runJob($action, $job, $data, $error_count);
} catch ( \Throwable $e ) {
} catch ( Throwable $e ) {
$job->delete();
}
}