新增了微信支付 关闭订单。在取消未支付订单中。
This commit is contained in:
@@ -19,6 +19,7 @@ use App\Services\OrderProductService;
|
||||
use App\Services\OrderService;
|
||||
use App\Utils\Log;
|
||||
use App\Utils\Utils;
|
||||
use Extend\Wechat\WechatPay;
|
||||
use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;
|
||||
use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
|
||||
use Hyperf\Amqp\Result;
|
||||
@@ -96,6 +97,12 @@ class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage
|
||||
return Result::ACK;
|
||||
}
|
||||
|
||||
// 关闭支付订单
|
||||
$WechatPay = new WechatPay("1", 1);
|
||||
|
||||
// 关闭订单
|
||||
$WechatPay->closeOrder($data['order_no']);
|
||||
|
||||
Db::commit();
|
||||
Log::getInstance("queue-CancelUnpayOrders")->info("成功");
|
||||
return Result::ACK;
|
||||
|
||||
Reference in New Issue
Block a user