feat : coupon

app/Amqp/Consumer/CancelOrderConsumer.php

@@ -4,16 +4,20 @@ declare(strict_types=1);
 
 namespace App\Amqp\Consumer;
 
+use App\Constants\Common\CouponCode;
 use App\Constants\Common\OrderCode;
 use App\Lib\Log;
 use App\Model\Order;
+use App\Model\UserCoupon;
 use App\Service\ServiceTrait\Api\OrderTrait;
+use Exception;
 use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;
 use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
 use Hyperf\Amqp\Message\Type;
 use Hyperf\Amqp\Result;
 use Hyperf\Amqp\Annotation\Consumer;
 use Hyperf\Amqp\Message\ConsumerMessage;
+use Hyperf\DbConnection\Db;
 use Hyperf\Di\Annotation\Inject;
 use PhpAmqpLib\Message\AMQPMessage;
 
@@ -40,6 +44,12 @@ class CancelOrderConsumer extends ConsumerMessage
     #[Inject]
     protected Order $orderModel;
 
+    /**
+     * @var UserCoupon
+     */
+    #[Inject]
+    protected UserCoupon $userCouponModel;
+
 
     public function consumeMessage($data, AMQPMessage $message): Result
     {
@@ -66,9 +76,18 @@ class CancelOrderConsumer extends ConsumerMessage
             return Result::ACK;
         }
 
-        $orderInfo->status = OrderCode::CANCEL;
-        if (!$orderInfo->save()) {
-            $this->log->debug('CancelOrderConsumer:error:orderStatusSaveError:'.json_encode($orderInfo->toArray()));
+        try {
+            Db::beginTransaction();
+
+            $this->rollbackCoupon($orderType, $orderInfo);
+
+            $orderInfo->status = OrderCode::CANCEL;
+            if (!$orderInfo->save()) throw new Exception('CancelOrderConsumer:error:orderStatusSaveError:'.json_encode($orderInfo->toArray()));
+
+            Db::commit();
+        }catch (Exception $e){
+            Db::rollback();
+            $this->log->debug($e->getMessage());
             return Result::ACK;
         }
 
@@ -76,4 +95,27 @@ class CancelOrderConsumer extends ConsumerMessage
 
         return Result::ACK;
     }
+
+    /**
+     * @param $orderType
+     * @param $orderInfo
+     * @return void
+     * @throws Exception
+     */
+    private function rollbackCoupon($orderType,$orderInfo): void
+    {
+        if ($orderType != OrderCode::ORDER_TYPE_GOOD) return;
+
+        if ($orderInfo->coupon_id <= 0) return;
+
+        $couponInfo = $this->userCouponModel->where('coupon_id', $orderInfo->coupon_id)->where('user_id',$orderInfo->user_id)->first();
+
+        if (empty($couponInfo)) return;
+
+        $couponInfo->status = CouponCode::COUPON_STATUS_UNUSED;
+
+        if (date('Y-m-d H:i:s') > $couponInfo->validity_end_time) $couponInfo->status = CouponCode::COUPON_STATUS_EXPIRE;
+
+        if (!$couponInfo->save()) throw new Exception('CancelOrderConsumer:error:couponStatusUpdateError:'.json_encode($orderInfo->toArray()));
+    }
 }