From f4d8428b9e8532ebfbf914aec0bb97c836ba6f20 Mon Sep 17 00:00:00 2001
From: wucongxing <815046773@qq.com>
Date: Mon, 27 Mar 2023 20:10:03 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E5=A4=8D=E9=98=9F=E5=88=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../CancelUnpayOrdersDelayDirectConsumer.php  | 91 -------------------
 .../PrescriptionDistributePhConsumer.php      | 24 -----
 .../CancelUnpayOrdersDelayDirectProducer.php  | 30 ------
 .../PrescriptionDistributePhProducer.php      | 21 -----
 4 files changed, 166 deletions(-)
 delete mode 100644 app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php
 delete mode 100644 app/Amqp/Consumer/PrescriptionDistributePhConsumer.php
 delete mode 100644 app/Amqp/Producer/CancelUnpayOrdersDelayDirectProducer.php
 delete mode 100644 app/Amqp/Producer/PrescriptionDistributePhProducer.php

diff --git a/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php b/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php
deleted file mode 100644
index e651e6b..0000000
--- a/app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php
+++ /dev/null
@@ -1,91 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace App\Amqp\Consumer;
-
-use App\Model\OrderInquiry;
-use App\Model\OrderInquiryCoupon;
-use App\Model\OrderPrescription;
-use App\Model\OrderPrescriptionProduct;
-use App\Model\OrderProduct;
-use App\Model\OrderProductItem;
-use App\Model\Product;
-use App\Model\ProductPlatformAmount;
-use App\Model\UserCoupon;
-use App\Services\InquiryService;
-use App\Services\OrderProductService;
-use App\Utils\Log;
-use Hyperf\Amqp\Message\ConsumerDelayedMessageTrait;
-use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
-use Hyperf\Amqp\Result;
-use Hyperf\Amqp\Annotation\Consumer;
-use Hyperf\Amqp\Message\ConsumerMessage;
-use Hyperf\DbConnection\Db;
-use Hyperf\Snowflake\IdGeneratorInterface;
-use PhpAmqpLib\Message\AMQPMessage;
-use Hyperf\Amqp\Message\Type;
-use Psr\Container\ContainerExceptionInterface;
-use Psr\Container\NotFoundExceptionInterface;
-
-/**
- * 取消未支付订单消费者-延迟队列
- */
-#[Consumer(nums: 1)]
-class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage
-{
-    use ProducerDelayedMessageTrait;
-    use ConsumerDelayedMessageTrait;
-
-    protected string $exchange = 'amqp.delay.direct';
-
-    protected ?string $queue = 'cancel.unpay.orders.delay.queue';
-
-    protected string $type = Type::DIRECT; //Type::FANOUT;
-
-    protected string|array $routingKey = 'CancelUnpayOrders';
-
-    public function consumeMessage($data, AMQPMessage $message): string
-    {
-        Log::getInstance()->error("开始执行 取消未支付订单 队列：" . json_encode($data, JSON_UNESCAPED_UNICODE));
-
-        Db::beginTransaction();
-
-        try {
-            if ($data['order_type'] == 1) {
-                // 问诊订单取消
-                $InquiryService = new InquiryService();
-                $result = $InquiryService->cancelUnpayInquiryOrder($data['order_no'], 5, "支付超时");
-
-            } elseif ($data['order_type'] == 2) {
-                // 药品订单取消
-                $OrderProductService = new OrderProductService();
-                $result = $OrderProductService->cancelUnpayProductOrder($data['order_no'], 3, "支付超时");
-                
-            } else {
-                Log::getInstance()->error("取消未支付订单失败：order_type类型错误");
-                return Result::DROP;// 销毁
-            }
-
-            if ($result['status'] == 0) {
-                Db::rollBack();
-                Log::getInstance()->error("取消未支付订单失败：" . $result['message']);
-                return Result::DROP;// 销毁
-            } elseif ($result['status'] == 2) {
-                Db::rollBack();
-                Log::getInstance()->error("取消未支付订单失败：" . $result['message']);
-                return Result::ACK;// 销毁
-            }
-
-            Db::commit();
-            Log::getInstance()->error("取消未支付订单 队列执行成功");
-            return Result::ACK;
-        } catch (\Exception $e) {
-            Db::rollBack();
-            Log::getInstance()->error("取消未支付订单执行失败：" . $e->getMessage());
-            return Result::ACK; // 重回队列
-        }
-    }
-
-
-}
diff --git a/app/Amqp/Consumer/PrescriptionDistributePhConsumer.php b/app/Amqp/Consumer/PrescriptionDistributePhConsumer.php
deleted file mode 100644
index 1b680e8..0000000
--- a/app/Amqp/Consumer/PrescriptionDistributePhConsumer.php
+++ /dev/null
@@ -1,24 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace App\Amqp\Consumer;
-
-use Hyperf\Amqp\Message\Type;
-use Hyperf\Amqp\Result;
-use Hyperf\Amqp\Annotation\Consumer;
-use Hyperf\Amqp\Message\ConsumerMessage;
-use PhpAmqpLib\Message\AMQPMessage;
-
-/**
- * 药师处方分配队列
- */
-#[Consumer(exchange: 'amqp.direct', routingKey: 'PrescriptionDistribute', queue: 'prescription.distribute.pharmacist.queue', nums: 1)]
-class PrescriptionDistributePhConsumer extends ConsumerMessage
-{
-    public function consumeMessage($data, AMQPMessage $message): string
-    {
-        dump($data);
-        return Result::ACK;
-    }
-}
diff --git a/app/Amqp/Producer/CancelUnpayOrdersDelayDirectProducer.php b/app/Amqp/Producer/CancelUnpayOrdersDelayDirectProducer.php
deleted file mode 100644
index 04e8737..0000000
--- a/app/Amqp/Producer/CancelUnpayOrdersDelayDirectProducer.php
+++ /dev/null
@@ -1,30 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace App\Amqp\Producer;
-
-use Hyperf\Amqp\Annotation\Producer;
-use Hyperf\Amqp\Message\ProducerDelayedMessageTrait;
-use Hyperf\Amqp\Message\ProducerMessage;
-use Hyperf\Amqp\Message\Type;
-
-/**
- * 取消未支付订单生产者-延迟队列
- */
-#[Producer]
-class CancelUnpayOrdersDelayDirectProducer extends ProducerMessage
-{
-    use ProducerDelayedMessageTrait;
-
-    protected string $exchange = 'amqp.delay.direct';
-
-    protected string $type = Type::DIRECT;
-
-    protected string|array $routingKey = 'CancelUnpayOrders';
-
-    public function __construct($data)
-    {
-        $this->payload = $data;
-    }
-}
diff --git a/app/Amqp/Producer/PrescriptionDistributePhProducer.php b/app/Amqp/Producer/PrescriptionDistributePhProducer.php
deleted file mode 100644
index 112652a..0000000
--- a/app/Amqp/Producer/PrescriptionDistributePhProducer.php
+++ /dev/null
@@ -1,21 +0,0 @@
-<?php
-
-declare(strict_types=1);
-
-namespace App\Amqp\Producer;
-
-use Hyperf\Amqp\Annotation\Producer;
-use Hyperf\Amqp\Message\ProducerMessage;
-use Hyperf\Amqp\Message\Type;
-
-/**
- * 药师处方分配队列
- */
-#[Producer(exchange: 'amqp.direct', routingKey: 'PrescriptionDistribute')]
-class PrescriptionDistributePhProducer extends ProducerMessage
-{
-    public function __construct($data)
-    {
-        $this->payload = $data;
-    }
-}