83 lines
1.8 KiB
PHP
83 lines
1.8 KiB
PHP
<?php
|
|
|
|
namespace App\Traits;
|
|
|
|
use Exception;
|
|
use Illuminate\Contracts\Bus\Dispatcher;
|
|
use Throwable;
|
|
|
|
trait Jobs
|
|
{
|
|
/**
|
|
* Dispatch a job to its appropriate handler.
|
|
*
|
|
* @param mixed $job
|
|
* @return mixed
|
|
*/
|
|
public function dispatch($job)
|
|
{
|
|
$function = $this->getDispatchFunction();
|
|
|
|
return $this->$function($job);
|
|
}
|
|
|
|
/**
|
|
* Dispatch a job to its appropriate handler.
|
|
*
|
|
* @param mixed $command
|
|
* @return mixed
|
|
*/
|
|
public function dispatchQueue($job)
|
|
{
|
|
return app(Dispatcher::class)->dispatch($job);
|
|
}
|
|
|
|
/**
|
|
* Dispatch a command to its appropriate handler in the current process.
|
|
*
|
|
* Queuable jobs will be dispatched to the "sync" queue.
|
|
*
|
|
* @param mixed $command
|
|
* @param mixed $handler
|
|
* @return mixed
|
|
*/
|
|
public function dispatchSync($job, $handler = null)
|
|
{
|
|
return app(Dispatcher::class)->dispatchSync($job, $handler);
|
|
}
|
|
|
|
/**
|
|
* Dispatch a job to its appropriate handler and return a response array for ajax calls.
|
|
*
|
|
* @param mixed $job
|
|
* @return mixed
|
|
*/
|
|
public function ajaxDispatch($job)
|
|
{
|
|
try {
|
|
$data = $this->dispatch($job);
|
|
|
|
$response = [
|
|
'success' => true,
|
|
'error' => false,
|
|
'data' => $data,
|
|
'message' => '',
|
|
];
|
|
} catch (Exception | Throwable $e) {
|
|
$response = [
|
|
'success' => false,
|
|
'error' => true,
|
|
'data' => null,
|
|
'message' => $e->getMessage(),
|
|
];
|
|
}
|
|
|
|
return $response;
|
|
}
|
|
|
|
public function getDispatchFunction()
|
|
{
|
|
return should_queue() ? 'dispatchQueue' : 'dispatchSync';
|
|
}
|
|
}
|