You cannot select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
84 lines
2.5 KiB
PHTML
84 lines
2.5 KiB
PHTML
2 years ago
|
<?php
|
||
|
|
|
||
|
|
declare(strict_types=1);
|
||
|
|
/**
|
||
|
|
* This file is part of Hyperf.
|
||
|
|
*
|
||
|
|
* @link https://www.hyperf.io
|
||
|
|
* @document https://hyperf.wiki
|
||
|
|
* @contact group@hyperf.io
|
||
|
|
* @license https://github.com/hyperf/hyperf/blob/master/LICENSE
|
||
|
|
*/
|
||
|
|
namespace App\Listener;
|
||
|
|
|
||
|
|
use Hyperf\AsyncQueue\AnnotationJob;
|
||
|
|
use Hyperf\AsyncQueue\Event\AfterHandle;
|
||
|
|
use Hyperf\AsyncQueue\Event\BeforeHandle;
|
||
|
|
use Hyperf\AsyncQueue\Event\Event;
|
||
|
|
use Hyperf\AsyncQueue\Event\FailedHandle;
|
||
|
|
use Hyperf\AsyncQueue\Event\RetryHandle;
|
||
|
|
use Hyperf\Event\Annotation\Listener;
|
||
|
|
use Hyperf\Event\Contract\ListenerInterface;
|
||
|
|
use Hyperf\ExceptionHandler\Formatter\FormatterInterface;
|
||
|
|
use Hyperf\Logger\LoggerFactory;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @Listener
|
||
|
|
*/
|
||
|
|
class QueueHandleListener implements ListenerInterface
|
||
|
|
{
|
||
|
|
/**
|
||
|
|
* @var \Psr\Log\LoggerInterface
|
||
|
|
*/
|
||
|
|
protected $logger;
|
||
|
|
|
||
|
|
/**
|
||
|
|
* @var FormatterInterface
|
||
|
|
*/
|
||
|
|
protected $formatter;
|
||
|
|
|
||
|
|
public function __construct(LoggerFactory $loggerFactory, FormatterInterface $formatter)
|
||
|
|
{
|
||
|
|
$this->logger = $loggerFactory->get('queue');
|
||
|
|
$this->formatter = $formatter;
|
||
|
|
}
|
||
|
|
|
||
|
|
public function listen(): array
|
||
|
|
{
|
||
|
|
return [
|
||
|
|
AfterHandle::class,
|
||
|
|
BeforeHandle::class,
|
||
|
|
FailedHandle::class,
|
||
|
|
RetryHandle::class,
|
||
|
|
];
|
||
|
|
}
|
||
|
|
|
||
|
|
public function process(object $event)
|
||
|
|
{
|
||
|
|
if ($event instanceof Event && $event->message->job()) {
|
||
|
|
$job = $event->message->job();
|
||
|
|
$jobClass = get_class($job);
|
||
|
|
if ($job instanceof AnnotationJob) {
|
||
|
|
$jobClass = sprintf('Job[%s@%s]', $job->class, $job->method);
|
||
|
|
}
|
||
|
|
$date = date('Y-m-d H:i:s');
|
||
|
|
|
||
|
|
switch (true) {
|
||
|
|
case $event instanceof BeforeHandle:
|
||
|
|
$this->logger->info(sprintf('[%s] Processing %s.', $date, $jobClass));
|
||
|
|
break;
|
||
|
|
case $event instanceof AfterHandle:
|
||
|
|
$this->logger->info(sprintf('[%s] Processed %s.', $date, $jobClass));
|
||
|
|
break;
|
||
|
|
case $event instanceof FailedHandle:
|
||
|
|
$this->logger->error(sprintf('[%s] Failed %s.', $date, $jobClass));
|
||
|
|
$this->logger->error($this->formatter->format($event->getThrowable()));
|
||
|
|
break;
|
||
|
|
case $event instanceof RetryHandle:
|
||
|
|
$this->logger->warning(sprintf('[%s] Retried %s.', $date, $jobClass));
|
||
|
|
break;
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|
||
|
|
}
|