新增 医生xx时间未接诊提醒队列

app/Amqp/Consumer/AssignDoctorDelayDirectConsumer.php

@@ -6,6 +6,7 @@ namespace App\Amqp\Consumer;
 
 use App\Amqp\Producer\AssignDoctorDelayDirectProducer;
 use App\Amqp\Producer\CancelUnInquiryOrdersDelayDirectProducer;
+use App\Amqp\Producer\DoctorNotYetInquiryDelayDirectProducer;
 use App\Amqp\Producer\UserCouponExpiredDelayDirectProducer;
 use App\Constants\HttpEnumCode;
 use App\Model\OrderInquiry;
@@ -131,8 +132,8 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage
             }
 
             // 检测分配时间
-            if ($diff_time > 300) {
-                Log::getInstance("queue-AssignDoctor")->info("信息：超出5分钟，执行退款");
+            if ($diff_time > 600) {
+                Log::getInstance("queue-AssignDoctor")->info("信息：超出10分钟，执行退款");
 
                 $InquiryService = new InquiryService();
 
@@ -284,6 +285,16 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage
             // 医生-医生有新问诊 站内、订阅失败发送短信
             $MessagePush = new MessagePush($user_doctor['user_id'],$order_inquiry['order_inquiry_id']);
             $MessagePush->doctorHaveNewInquiry();
+
+            // 加入xx时间未接诊通知队列
+            $data = array();
+            $data['order_inquiry_id'] = $order_inquiry['order_inquiry_id'];
+
+            $time = 1000 * 60 * 3;
+            $message = new DoctorNotYetInquiryDelayDirectProducer($data);
+            $message->setDelayMs($time);
+            $producer = $this->container->get(Producer::class);
+            $producer->produce($message);
         }catch (\Throwable $e){
             Log::getInstance("queue-AssignDoctor")->error("发送消息异常错误：" . $e->getMessage());
             return Result::ACK;
@@ -355,7 +366,7 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage
             }
 
             // 执行次数过多
-            if ($redis_value > 3) {
+            if ($redis_value > 4) {
                 // 加入短信队列,通知管理员
 
                 return false;

app/Amqp/Consumer/CancelUnInquiryOrdersDelayDirectConsumer.php

@@ -151,6 +151,7 @@ class CancelUnInquiryOrdersDelayDirectConsumer extends ConsumerMessage
             $user_doctor = UserDoctor::getOne($params);
             if (empty($user_doctor)) {
                 Log::getInstance()->info("取消未接诊问诊订单成功,发送IM消息失败：医生数据错误");
+                return Result::ACK;
             }
 
             // 发送IM消息-医生未接诊

app/Amqp/Consumer/CancelUnpayOrdersDelayDirectConsumer.php

@@ -49,7 +49,7 @@ class CancelUnpayOrdersDelayDirectConsumer extends ConsumerMessage
 
     public function consumeMessage($data, AMQPMessage $message): string
     {
-        Log::getInstance("queue-CancelUnpayOrders")->error("开始执行 取消未支付订单 队列：" . json_encode($data, JSON_UNESCAPED_UNICODE));
+        Log::getInstance("queue-CancelUnpayOrders")->info("开始执行 取消未支付订单 队列：" . json_encode($data, JSON_UNESCAPED_UNICODE));
 
         Db::beginTransaction();
 

app/Amqp/Consumer/DoctorNotYetInquiryDelayDirectConsumer.php

@@ -0,0 +1,80 @@
+<?php
+
+declare(strict_types=1);
+
+namespace App\Amqp\Consumer;
+
+use App\Model\OrderInquiry;
+use App\Model\UserDoctor;
+use App\Services\MessagePush;
+use App\Utils\Log;
+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 PhpAmqpLib\Message\AMQPMessage;
+
+/**
+ * 医生xx时间未接诊提醒
+ */
+#[Consumer(nums: 1)]
+class DoctorNotYetInquiryDelayDirectConsumer extends ConsumerMessage
+{
+    use ProducerDelayedMessageTrait;
+    use ConsumerDelayedMessageTrait;
+
+    protected string $exchange = 'amqp.delay.direct';
+
+    protected ?string $queue = 'doctor.not.uet.inquiry.delay.queue';
+
+    protected string $type = Type::DIRECT; //Type::FANOUT;
+
+    protected string|array $routingKey = 'DoctorNotYetInquiry';
+
+    public function consumeMessage($data, AMQPMessage $message): string
+    {
+        Log::getInstance("queue-DoctorNotYetInquiry")->info("开始：" . json_encode($data, JSON_UNESCAPED_UNICODE));
+
+        if (!isset($data['order_inquiry_id'])){
+            Log::getInstance("queue-DoctorNotYetInquiry")->error("缺少参数");
+            return Result::ACK;
+        }
+
+        try {
+            // 获取问诊订单数据
+            $params = array();
+            $params['order_inquiry_id'] = $data['order_inquiry_id'];
+            $order_inquiry = OrderInquiry::getOne($params);
+            if (empty($order_inquiry)){
+                Log::getInstance("queue-DoctorNotYetInquiry")->error("未找到对应问诊订单");
+                return Result::ACK;
+            }
+
+            // 检测问诊订单状态
+            if ($order_inquiry['inquiry_status'] != 3){
+                Log::getInstance("queue-DoctorNotYetInquiry")->error("状态非待接诊，无需发送");
+                return Result::ACK;
+            }
+
+            // 获取订单医生数据
+            $params = array();
+            $params['doctor_id'] = $order_inquiry['doctor_id'];
+            $user_doctor = UserDoctor::getOne($params);
+            if (empty($user_doctor)) {
+                Log::getInstance("queue-DoctorNotYetInquiry")->error("医生数据错误");
+            }
+
+            // 发送站内、订阅消息-医生-超时未接诊
+            $MessagePush = new MessagePush($user_doctor['user_id'],$order_inquiry['order_inquiry_id']);
+            $MessagePush->doctorNotYetInquiry();
+        }catch (\Throwable $e){
+            Log::getInstance("queue-DoctorNotYetInquiry")->error("失败：" . $e->getMessage());
+            return Result::ACK;
+        }
+
+        return Result::ACK;
+    }
+}

app/Amqp/Producer/DoctorNotYetInquiryDelayDirectProducer.php

@@ -0,0 +1,30 @@
+<?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;
+
+/**
+ * 医生xx时间未接诊提醒
+ */
+#[Producer]
+class DoctorNotYetInquiryDelayDirectProducer extends ProducerMessage
+{
+    use ProducerDelayedMessageTrait;
+
+    protected string $exchange = 'amqp.delay.direct';
+
+    protected string $type = Type::DIRECT;
+
+    protected string|array $routingKey = 'DoctorNotYetInquiry';
+
+    public function __construct($data)
+    {
+        $this->payload = $data;
+    }
+}