gdxz/hospital-applets-api
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

修复队列

Browse Source
This commit is contained in:
wucongxing 2023-03-27 20:10:03 +08:00
parent 872e53fb47
commit f4d8428b9e
4 changed files with 0 additions and 166 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

91
app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php
View File

@ -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; // 重回队列
}
}
}

24
app/Amqp/Consumer/PrescriptionDistributePhConsumer.php
View File

@ -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;
}
}

30
app/Amqp/Producer/CancelUnpayOrdersDelayDirectProducer.php
View File

@ -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;
}
}

21
app/Amqp/Producer/PrescriptionDistributePhProducer.php
View File

@ -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;
}
}