生日礼物队列不独创自己的消费者

common/components/rabbitmq/birthdayGiftConsumer.php

@@ -6,7 +6,6 @@ use bizHd\birthday\classes\BirthdayGiftClass;
 use common\components\noticeUtil;
 use mikemadisonweb\rabbitmq\components\ConsumerInterface;
 use PhpAmqpLib\Message\AMQPMessage;
-use Yii;
 
 class birthdayGiftConsumer extends baseConsumer
 {

common/components/rabbitmq/stockConsumer.php

@@ -7,6 +7,7 @@
 namespace common\components\rabbitmq;
 
 use bizGhs\product\classes\ProductClass;
+use bizHd\birthday\classes\BirthdayGiftClass;
 use bizHd\product\classes\ProductClass as hdProductClass;
 use common\components\noticeUtil;
 use mikemadisonweb\rabbitmq\components\ConsumerInterface;
@@ -53,6 +54,13 @@ class stockConsumer extends baseConsumer
                         return $this->clearOrderItemLimitBuy($data);
                     });
                     break;
+                case 'birthday_gift_expire':
+                    $giftId = intval($data['giftId']);
+                    echo 'birthday_gift_expire --- giftId=' . $giftId;
+                    $result = $this->runWithDbReconnect(function () use ($giftId) {
+                        return BirthdayGiftClass::expireById($giftId);
+                    });
+                    break;
                 default:
                     noticeUtil::push("库存的消费者报错，未知 type: {$type}");
                     $result = false;

common/config/rabbitMQ.php

@@ -160,6 +160,7 @@ $rabbitMQ = [
                 'stockQueue' => '\common\components\rabbitmq\stockConsumer',
                 //'limitBuyQueue' => '\common\components\rabbitmq\cancelLimitBuyConsumer',
                 'limitBuyQueue' => '\common\components\rabbitmq\stockConsumer',
+                'birthdayGiftQueue' => '\common\components\rabbitmq\stockConsumer', //生日礼物队列
             ]
         ],
         [
@@ -176,12 +177,12 @@ $rabbitMQ = [
                 'ptQueue' => '\common\components\rabbitmq\ptConsumer',
             ]
         ],
-        [
-            'name' => 'birthdayGiftConsumer',
-            'callbacks' => [
-                'birthdayGiftQueue' => '\common\components\rabbitmq\birthdayGiftConsumer',
-            ]
-        ]
+        // [ // 生日礼物队列不独创自己的消费者
+        //     'name' => 'birthdayGiftConsumer',
+        //     'callbacks' => [
+        //         'birthdayGiftQueue' => '\common\components\rabbitmq\birthdayGiftConsumer',
+        //     ]
+        // ]
     ],
 ];
 return $rabbitMQ;