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("成功");