hehele/hyperf_service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat : deliver

Browse Source
This commit is contained in:
ctexthuang
2025-04-03 10:52:03 +08:00
parent 2fb997fb3b
commit 41b9993f36
9 changed files with 190 additions and 142 deletions
Download Patch File Download Diff File Expand all files Collapse all files

25
app/Amqp/Consumer/Statement/DriverConsumer.php
View File

@@ -1,25 +0,0 @@
<?php
declare(strict_types=1);
namespace App\Amqp\Consumer\Statement;
use Hyperf\Amqp\Message\Type;
use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use PhpAmqpLib\Message\AMQPMessage;
#[Consumer(exchange: 'hyperf', routingKey: 'hyperf', queue: 'hyperf', name: "DriverConsumer", nums: 1)]
class DriverConsumer extends ConsumerMessage
{
/**
* @var Type|string 消息类型
*/
protected Type|string $type = Type::DIRECT;
public function consumeMessage($data, AMQPMessage $message): Result
{
return Result::ACK;
}
}

40
app/Amqp/Consumer/Statement/RefundFinishConsumer.php
View File

@@ -1,40 +0,0 @@
<?php
declare(strict_types=1);
namespace App\Amqp\Consumer\Statement;
use App\Lib\Log;
use Hyperf\Amqp\Message\Type;
use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\Di\Annotation\Inject;
use PhpAmqpLib\Message\AMQPMessage;
#[Consumer(exchange: 'RefundStatement', routingKey: 'RefundStatement', queue: 'RefundStatement.count', name: "RefundFinishConsumer", nums: 1)]
class RefundFinishConsumer extends ConsumerMessage
{
/**
* @var Type|string 消息类型
*/
protected Type|string $type = Type::DIRECT;
/**
* @var Log
*/
#[Inject]
protected Log $log;
public function consumeMessage($data, AMQPMessage $message): Result
{
if (!$data['order_id'] || !$data['refund_order_id']) {
$this->log->error('RefundFinishConsumer:error:NoData:'.json_encode($data));
return Result::ACK;
}
return Result::ACK;
}
}

25
app/Amqp/Consumer/Statement/SiteConsumer.php
View File

@@ -1,25 +0,0 @@
<?php
declare(strict_types=1);
namespace App\Amqp\Consumer\Statement;
use Hyperf\Amqp\Message\Type;
use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use PhpAmqpLib\Message\AMQPMessage;
#[Consumer(exchange: 'hyperf', routingKey: 'hyperf', queue: 'hyperf', name: "SiteConsumer", nums: 1)]
class SiteConsumer extends ConsumerMessage
{
/**
* @var Type|string 消息类型
*/
protected Type|string $type = Type::DIRECT;
public function consumeMessage($data, AMQPMessage $message): Result
{
return Result::ACK;
}
}

52
app/Amqp/Consumer/Statement/SiteDriverConsumer.php Normal file
View File

@@ -0,0 +1,52 @@
<?php
declare(strict_types=1);
namespace App\Amqp\Consumer\Statement;
use App\Lib\Log;
use App\Service\Amqp\Statement\DeliverStatementService;
use Exception;
use Hyperf\Amqp\Message\Type;
use Hyperf\Amqp\Result;
use Hyperf\Amqp\Annotation\Consumer;
use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\Di\Annotation\Inject;
use PhpAmqpLib\Message\AMQPMessage;
#[Consumer(exchange: 'SiteDriver', routingKey: 'SiteDriver', queue: 'SiteDriver.statement', name: "SiteDriverConsumer", nums: 1)]
class SiteDriverConsumer extends ConsumerMessage
{
/**
* @var Type|string 消息类型
*/
protected Type|string $type = Type::DIRECT;
/**
* @var Log
*/
#[Inject]
protected Log $log;
public function consumeMessage($data, AMQPMessage $message): Result
{
if (!$data['site_id'] || !$data['cycle_id']) {
$this->log->error('SiteDriverConsumer:error:NoData:'.json_encode($data));
return Result::ACK;
}
try {
$service = new DeliverStatementService();
$service->siteId = (int)$data['site_id'];
$service->cycleId = (int)$data['cycle_id'];
$service->handle();
} catch (Exception $e) {
$this->log->error('SiteDriverConsumer:error:'.$e->getMessage().':data:'.json_encode($data));
}
return Result::ACK;
}
}