diff --git a/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php b/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php
index 3591f5b..e94d409 100644
--- a/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php
+++ b/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php
@@ -99,7 +99,7 @@ class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage
 
             // 关闭支付订单
             try {
-                $WechatPay = new WechatPay("1", 1);
+                $WechatPay = new WechatPay("1", $data['order_type']);
 
                 // 关闭订单
                 $WechatPay->closeOrder($data['order_no']);
@@ -107,8 +107,6 @@ class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage
                 Log::getInstance("queue-CancelUnpayOrders")->error($e->getMessage());
             }
 
-
-
             Db::commit();
             Log::getInstance("queue-CancelUnpayOrders")->info("成功");
             return Result::ACK;