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

feat : check

Browse Source
This commit is contained in:
ctexthuang
2025-04-01 16:31:23 +08:00
parent 9c73d966d3
commit fa3bdda5fa
2 changed files with 2 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
app/Amqp/Consumer/CouponAutoDispenseConsumer.php
View File

@@ -49,7 +49,7 @@ class CouponAutoDispenseConsumer extends ConsumerMessage
$service->couponDispenseId = $data['coupon_dispense_id']; $service->couponDispenseId = $data['coupon_dispense_id'];
$service->userId = $data['user_id']; $service->userId = $data['user_id'];
$this->log->debug('data2:'.json_encode($data));
$service->handle(); $service->handle();
} catch (Exception $e) { } catch (Exception $e) {

1
app/Service/Amqp/Coupon/AutoDispenseService.php
View File

@@ -84,6 +84,7 @@ class AutoDispenseService
*/ */
public function handle(): void public function handle(): void
{ {
$this->log->debug('data3:'.$this->couponDispenseId);
$dispenseInfo = $this->couponDispenseLogModel->getInfoById($this->couponDispenseId); $dispenseInfo = $this->couponDispenseLogModel->getInfoById($this->couponDispenseId);
if (empty($dispenseInfo)) throw new Exception('分发记录不存在'); if (empty($dispenseInfo)) throw new Exception('分发记录不存在');