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