hehele/hyperf_service
1
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

feat : spu

Browse Source
This commit is contained in:
ctexthuang
2025-03-25 16:11:52 +08:00
parent 3687147ffe
commit 6fca649c86
3 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

3
app/Amqp/Consumer/Pay/GoodOrderPayFinishConsumer.php
View File

@@ -41,7 +41,7 @@ class GoodOrderPayFinishConsumer extends ConsumerMessage
*/ */
public function consumeMessage($data, AMQPMessage $message): Result public function consumeMessage($data, AMQPMessage $message): Result
{ {
if (!$data['order_sno'] || !$data['pay_type']) { if (!$data['order_sno'] || !$data['pay_type'] || !$data['callback_data']) {
$this->log->error('GoodOrderPayFinishConsumer:error:NoData:'.json_encode($data)); $this->log->error('GoodOrderPayFinishConsumer:error:NoData:'.json_encode($data));
return Result::ACK; return Result::ACK;
} }
@@ -53,6 +53,7 @@ class GoodOrderPayFinishConsumer extends ConsumerMessage
$service->orderNo = $data['order_sno']; $service->orderNo = $data['order_sno'];
$service->payType = (int)$data['pay_type']; $service->payType = (int)$data['pay_type'];
$service->callbackData = $data['callback_data'];
$service->orderType = OrderCode::ORDER_TYPE_GOOD; $service->orderType = OrderCode::ORDER_TYPE_GOOD;
$service->handle(); $service->handle();

5
app/Service/Amqp/Pay/PayGoodOrderFinishService.php
View File

@@ -43,6 +43,11 @@ class PayGoodOrderFinishService
*/ */
public int $orderType; public int $orderType;
/**
* @var array
*/
public array $callbackData;
/** /**
* @var Order * @var Order
*/ */

1
app/Service/Common/Pay/Wx/WxJsRechargeOrderService.php
View File

@@ -89,6 +89,7 @@ class WxJsRechargeOrderService extends WxJsRechargeBaseService
$message = new GoodOrderPayFinishProducer([ $message = new GoodOrderPayFinishProducer([
'order_sno' => $this->orderNo, 'order_sno' => $this->orderNo,
'pay_type' => self::PayType, 'pay_type' => self::PayType,
'callback_data' => $this->callbackData,
]); ]);
$this->producer->produce($message); $this->producer->produce($message);