From fa3bdda5fac141b9c06be730a162033807b59d35 Mon Sep 17 00:00:00 2001 From: ctexthuang Date: Tue, 1 Apr 2025 16:31:23 +0800 Subject: [PATCH] feat : check --- app/Amqp/Consumer/CouponAutoDispenseConsumer.php | 2 +- app/Service/Amqp/Coupon/AutoDispenseService.php | 1 + 2 files changed, 2 insertions(+), 1 deletion(-) diff --git a/app/Amqp/Consumer/CouponAutoDispenseConsumer.php b/app/Amqp/Consumer/CouponAutoDispenseConsumer.php index ca0bdd7..23fa671 100644 --- a/app/Amqp/Consumer/CouponAutoDispenseConsumer.php +++ b/app/Amqp/Consumer/CouponAutoDispenseConsumer.php @@ -49,7 +49,7 @@ class CouponAutoDispenseConsumer extends ConsumerMessage $service->couponDispenseId = $data['coupon_dispense_id']; $service->userId = $data['user_id']; - + $this->log->debug('data2:'.json_encode($data)); $service->handle(); } catch (Exception $e) { diff --git a/app/Service/Amqp/Coupon/AutoDispenseService.php b/app/Service/Amqp/Coupon/AutoDispenseService.php index 9653d8b..8ae5fe2 100644 --- a/app/Service/Amqp/Coupon/AutoDispenseService.php +++ b/app/Service/Amqp/Coupon/AutoDispenseService.php @@ -84,6 +84,7 @@ class AutoDispenseService */ public function handle(): void { + $this->log->debug('data3:'.$this->couponDispenseId); $dispenseInfo = $this->couponDispenseLogModel->getInfoById($this->couponDispenseId); if (empty($dispenseInfo)) throw new Exception('分发记录不存在');