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

feat : coupon

Browse Source
This commit is contained in:
ctexthuang
2025-03-21 15:14:43 +08:00
parent a0dd51fc68
commit 11a36ece80
14 changed files with 644 additions and 16 deletions
Download Patch File Download Diff File Expand all files Collapse all files

19
app/Amqp/Consumer/RefundOrderConsumer.php
View File

@@ -4,8 +4,11 @@ declare(strict_types=1);
namespace App\Amqp\Consumer;
use App\Constants\Common\RefundCode;
use App\Lib\Log;
use App\Model\Order;
use App\Service\Amqp\Refund\FullRefundOrderService;
use App\Service\Amqp\Refund\PartialRefundOrderService;
use App\Service\Amqp\Refund\RefundService;
use App\Service\ServiceTrait\Api\OrderTrait;
use Exception;
@@ -41,7 +44,6 @@ class RefundOrderConsumer extends ConsumerMessage
#[Inject]
protected Order $orderModel;
/**
* @param $data
* @param AMQPMessage $message
@@ -51,21 +53,24 @@ class RefundOrderConsumer extends ConsumerMessage
*/
public function consumeMessage($data, AMQPMessage $message): Result
{
if (!$data['order_id'] || !$data['type'] || !$data['amount'] || !$data['reason']) {
$this->log->error('CancelOrderConsumer:error:NoData:'.json_encode($data));
if (!$data['order_id'] || !$data['type'] || !$data['reason']) {
$this->log->error('RefundOrderConsumer:error:NoData:'.json_encode($data));
return Result::ACK;
}
try {
$service = new RefundService();
$service = match ($data['type']) {
RefundCode::FULL_GOOD_REFUND => new FullRefundOrderService(),
// RefundCode::PARTIAL_GOOD_REFUND => new PartialRefundOrderService(),
RefundCode::PARTIAL_GOOD_REFUND => throw new Exception('部分退款直接调用后台退款接口'),
// RefundCode::BALANCE_REFUND => $service = new RefundService(),
};
$service->orderId = (int)$data['order_id'];
$service->type = (int)$data['type'];
$service->refundAmount = $data['amount'];
$service->reason = $data['reason'];
$service->type = $data['type'];
$service->handle();
} catch (Exception $e) {
$this->log->error('RefundOrderConsumer:error:'.$e->getMessage().':data:'.json_encode($data));
}