From 5a7e1cceb14fa0ea3b4c4d0049dd2d6ab9a08b7a Mon Sep 17 00:00:00 2001 From: wucongxing <815046773@qq.com> Date: Tue, 18 Apr 2023 16:01:11 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E9=99=A4=E5=88=86=E9=85=8D=E5=8C=BB?= =?UTF-8?q?=E7=94=9F=E6=89=93=E5=8D=B0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/Amqp/Consumer/AssignDoctorConsumer.php | 11 +++-------- 1 file changed, 3 insertions(+), 8 deletions(-) diff --git a/app/Amqp/Consumer/AssignDoctorConsumer.php b/app/Amqp/Consumer/AssignDoctorConsumer.php index adb20a4..9192846 100644 --- a/app/Amqp/Consumer/AssignDoctorConsumer.php +++ b/app/Amqp/Consumer/AssignDoctorConsumer.php @@ -76,7 +76,6 @@ class AssignDoctorConsumer extends ConsumerMessage return Result::DROP;// 销毁 } - dump("超出5分钟,执行退款"); // 超出5分钟,执行退款 if ($diff_time > 300) { Log::getInstance()->error("分配医生队列执行失败:超出5分钟,执行退款"); @@ -98,7 +97,6 @@ class AssignDoctorConsumer extends ConsumerMessage return Result::ACK; } - dump("检测当前是否符合系统问诊时间"); // 检测当前是否符合系统问诊时间 $inquiryService = new InquiryService(); $is_system_time_pass = $inquiryService->checkSystemInquiryTime($order_inquiry['inquiry_type']); @@ -124,22 +122,19 @@ class AssignDoctorConsumer extends ConsumerMessage } // 分配医生 - dump("分配医生"); $UserDoctorService = new UserDoctorService(); $doctor_id = $UserDoctorService->getInquiryAssignDoctor($order_inquiry['inquiry_type'],$order_inquiry['patient_id'],$is_system_time_pass); if (empty($doctor_id)){ // 无合适医生 Db::rollBack(); - dump("目前没有合适医生"); Log::getInstance()->info("分配医生队列执行:目前没有合适医生"); $redis_value = $this->checkAssignCount($order_inquiry['order_inquiry_id']); - dump("111"); - dump($redis_value); - Log::getInstance()->info("分配医生队列执行:目前没有合适医生" . $redis_value); + + Log::getInstance()->info("分配医生队列执行:目前没有合适医生,重试第" . $redis_value . "次"); // 执行睡眠,防止重复执行队列 // 执行规则,第一次30秒,第二次30秒。以30的倍数增加 sleep($redis_value * 5); - dump("重回队列"); + Log::getInstance()->info("分配医生队列执行:重回队列"); return Result::REQUEUE; // 重回队列 }