diff --git a/crmeb/app/listener/order/OrderShippingListener.php b/crmeb/app/listener/order/OrderShippingListener.php index 02230dd5e..288f9b0a3 100644 --- a/crmeb/app/listener/order/OrderShippingListener.php +++ b/crmeb/app/listener/order/OrderShippingListener.php @@ -102,9 +102,10 @@ class OrderShippingListener implements ListenerInterface throw new AdminException('订单支付人异常'); } if ($secs) { - sleep($secs); + MiniOrderJob::dispatchSecs($secs, 'doJob', [$out_trade_no, $logistics_type, $shipping_list, $payer_openid, $path, $delivery_mode, $is_all_delivered]); + } else { + MiniOrderJob::dispatch('doJob', [$out_trade_no, $logistics_type, $shipping_list, $payer_openid, $path, $delivery_mode, $is_all_delivered]); } - MiniOrderJob::dispatch('doJob', [$out_trade_no, $logistics_type, $shipping_list, $payer_openid, $path, $delivery_mode, $is_all_delivered]); } } } diff --git a/crmeb/crmeb/traits/QueueTrait.php b/crmeb/crmeb/traits/QueueTrait.php index 8baa40eb1..eca335067 100644 --- a/crmeb/crmeb/traits/QueueTrait.php +++ b/crmeb/crmeb/traits/QueueTrait.php @@ -60,7 +60,6 @@ trait QueueTrait } else { $res->$action(...$data); } - } }