feat : refund

app/Amqp/Consumer/CancelOrderConsumer.php

@@ -7,6 +7,7 @@ namespace App\Amqp\Consumer;
 use App\Constants\Common\OrderCode;
 use App\Lib\Log;
 use App\Model\Order;
+use App\Service\ServiceTrait\Api\OrderTrait;
 use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;
 use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
 use Hyperf\Amqp\Message\Type;
@@ -20,6 +21,7 @@ use PhpAmqpLib\Message\AMQPMessage;
 class CancelOrderConsumer extends ConsumerMessage
 {
     use ProducerDelayedMessageTrait,ConsumerDelayedMessageTrait;
+    use OrderTrait;
 
     /**
      * @var Type|string 消息类型
@@ -38,16 +40,6 @@ class CancelOrderConsumer extends ConsumerMessage
     #[Inject]
     protected Order $orderModel;
 
-    /**
-     * @var int
-     */
-    private int $orderId;
-
-    /**
-     * @var int
-     */
-    private int $orderType;
-
 
     public function consumeMessage($data, AMQPMessage $message): Result
     {
@@ -56,11 +48,11 @@ class CancelOrderConsumer extends ConsumerMessage
             return Result::ACK;
         }
 
-        $this->orderId = (int)$data['order_id'];
-        $this->orderType = (int)$data['type'];
+        $orderId = (int)$data['order_id'];
+        $orderType = (int)$data['type'];
 
-        $orderInfo = match ($this->orderType) {
-            OrderCode::ORDER_TYPE_GOOD => $this->orderModel->getInfoById($this->orderId),
+        $orderInfo = match ($orderType) {
+            OrderCode::ORDER_TYPE_GOOD => $this->orderModel->getInfoById($orderId),
             default => null,
         };
 
@@ -80,6 +72,7 @@ class CancelOrderConsumer extends ConsumerMessage
             return Result::ACK;
         }
 
+        $this->sendStockMq($orderInfo->id,OrderCode::CANCEL);
 
         return Result::ACK;
     }

app/Amqp/Consumer/RefundOrderConsumer.php

@@ -4,23 +4,107 @@ declare(strict_types=1);
 
 namespace App\Amqp\Consumer;
 
+use App\Constants\Common\OrderCode;
+use App\Lib\Log;
+use App\Model\Order;
+use App\Service\Amqp\Refund\GoodOrderAllRefundService;
+use App\Service\Amqp\Refund\RefundFactory;
+use App\Service\ServiceTrait\Api\OrderTrait;
+use Exception;
 use Hyperf\Amqp\Message\Type;
 use Hyperf\Amqp\Result;
 use Hyperf\Amqp\Annotation\Consumer;
 use Hyperf\Amqp\Message\ConsumerMessage;
+use Hyperf\Di\Annotation\Inject;
 use PhpAmqpLib\Message\AMQPMessage;
 
 #[Consumer(exchange: 'RefundOrder', routingKey: 'RefundOrder', queue: 'RefundOrder.direct', name: "RefundOrderConsumer", nums: 1)]
 class RefundOrderConsumer extends ConsumerMessage
 {
+    use OrderTrait;
 
     /**
      * @var Type|string 消息类型
      */
     protected Type|string $type = Type::DIRECT;
 
+
+    /**
+     * @var Log $log
+     */
+    #[Inject]
+    protected Log $log;
+
+    /**
+     * @var Order
+     */
+    #[Inject]
+    protected Order $orderModel;
+
+    /**
+     * @var RefundFactory
+     */
+    #[Inject]
+    protected RefundFactory $refundFactory;
+
     public function consumeMessage($data, AMQPMessage $message): Result
     {
+        if (!$data['order_id'] || !$data['type'] || !$data['amount']) {
+            $this->log->error('CancelOrderConsumer:error:NoData:'.json_encode($data));
+            return Result::ACK;
+        }
+
+        $orderId = (int)$data['order_id'];
+        $orderType = (int)$data['type'];
+        $amount = $data['amount'];
+
+        $orderInfo = match ($orderType) {
+            OrderCode::ORDER_TYPE_GOOD => $this->orderModel->getInfoById($orderId),
+            default => null,
+        };
+
+        if (empty($orderInfo)) {
+            $this->log->debug('RefundOrderConsumer:error:NoOrderData:'.json_encode($data));
+            return Result::ACK;
+        }
+
+        if (!in_array($orderInfo->status,OrderCode::CAN_REFUND_STATUS)) {
+            $this->log->debug('CancelOrderConsumer:error:orderStatusError:'.json_encode($orderInfo->toArray()));
+            return Result::ACK;
+        }
+
+        //余额订单必须退款全部金额
+        if ($orderType == OrderCode::ORDER_TYPE_BALANCE && $amount != 0) {
+            $this->log->debug('CancelOrderConsumer:error:orderStatusError:'.json_encode($orderInfo->toArray()));
+            return Result::ACK;
+        }
+
+
+        try {
+            $service = null;
+
+            switch ($orderType) {
+                case OrderCode::ORDER_TYPE_GOOD:
+                    if ($amount == 0) {
+                        $service = $this->refundFactory->newGoodOrderRefundAll();
+                    } else {
+                        $service = $this->refundFactory->newGoodOrderRefundPart();
+                    }
+                    break;
+                case OrderCode::ORDER_TYPE_BALANCE:
+                    $service = $this->refundFactory->newBalanceOrderRefund();
+                    break;
+                default:
+                    throw new Exception('service not found or orderType error');
+            }
+
+
+        } catch (Exception $e) {
+            $this->log->error('RefundOrderConsumer:error:'.$e->getMessage().':data:'.json_encode($data));
+        }
+
         return Result::ACK;
     }
+
+
 }