diff --git a/app/Services/CouponService.php b/app/Services/CouponService.php index 58a8906..7c47515 100644 --- a/app/Services/CouponService.php +++ b/app/Services/CouponService.php @@ -7,6 +7,7 @@ use App\Amqp\Producer\UserCouponExpiredDelayDirectProducer; use App\Constants\HttpEnumCode; use App\Model\Coupon; use App\Model\UserCoupon; +use App\Utils\Log; use Hyperf\Amqp\Producer; use Hyperf\DbConnection\Db; use Psr\Container\ContainerExceptionInterface; @@ -142,6 +143,15 @@ class CouponService extends BaseService if (!$res) { return false; } + + try { + // 患者-发送通知消息-优惠卷发放 + $MessagePush = new MessagePush($user_id); + $MessagePush->patientDistributeCoupon($value['coupon_name']); + }catch (\Exception $e){ + // 不做处理 + Log::getInstance()->error($e->getMessage()); + } } return true;