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

feat : coupon

Browse Source
This commit is contained in:
ctexthuang
2025-03-05 14:34:40 +08:00
parent 75f649676d
commit e60f28fe9a
1 changed files with 9 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
app/Amqp/Consumer/CancelOrderConsumer.php
View File

@@ -20,6 +20,8 @@ use Hyperf\Amqp\Message\ConsumerMessage;
use Hyperf\DbConnection\Db; use Hyperf\DbConnection\Db;
use Hyperf\Di\Annotation\Inject; use Hyperf\Di\Annotation\Inject;
use PhpAmqpLib\Message\AMQPMessage; use PhpAmqpLib\Message\AMQPMessage;
use Psr\Container\ContainerExceptionInterface;
use Psr\Container\NotFoundExceptionInterface;
#[Consumer(exchange: 'OrderCancel', routingKey: 'OrderCancel', queue: 'OrderCancel.delay', name: "CancelOrderConsumer", nums: 1)] #[Consumer(exchange: 'OrderCancel', routingKey: 'OrderCancel', queue: 'OrderCancel.delay', name: "CancelOrderConsumer", nums: 1)]
class CancelOrderConsumer extends ConsumerMessage class CancelOrderConsumer extends ConsumerMessage
@@ -50,7 +52,13 @@ class CancelOrderConsumer extends ConsumerMessage
#[Inject] #[Inject]
protected UserCoupon $userCouponModel; protected UserCoupon $userCouponModel;
/**
* @param $data
* @param AMQPMessage $message
* @return Result
* @throws ContainerExceptionInterface
* @throws NotFoundExceptionInterface
*/
public function consumeMessage($data, AMQPMessage $message): Result public function consumeMessage($data, AMQPMessage $message): Result
{ {
if (!$data['order_id'] || !$data['type']) { if (!$data['order_id'] || !$data['type']) {