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('分发记录不存在');