From 347f5d2891cf654c00be59d1e3f608b3ca398963 Mon Sep 17 00:00:00 2001 From: wucongxing8150 <815046773@qq.com> Date: Wed, 26 Jun 2024 14:58:30 +0800 Subject: [PATCH] 2 --- .../CancelUnpayOrdersDelayDirectConsumer.php | 12 +++++++++--- 1 file changed, 9 insertions(+), 3 deletions(-) diff --git a/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php b/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php index 6e9e1d9..3591f5b 100644 --- a/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php +++ b/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php @@ -98,10 +98,16 @@ class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage } // 关闭支付订单 - $WechatPay = new WechatPay("1", 1); + try { + $WechatPay = new WechatPay("1", 1); + + // 关闭订单 + $WechatPay->closeOrder($data['order_no']); + }catch (\Throwable $e){ + Log::getInstance("queue-CancelUnpayOrders")->error($e->getMessage()); + } + - // 关闭订单 - $WechatPay->closeOrder($data['order_no']); Db::commit(); Log::getInstance("queue-CancelUnpayOrders")->info("成功");