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