From 4aa4eaee75b0363004638c9771bd131cf08a9595 Mon Sep 17 00:00:00 2001 From: wucongxing <815046773@qq.com> Date: Tue, 4 Apr 2023 20:04:59 +0800 Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E9=99=A4=E5=8F=96=E6=B6=88=E6=9C=AA?= =?UTF-8?q?=E6=8E=A5=E8=AF=8A=E8=AE=A2=E5=8D=95=E5=9B=9E=E5=A4=8D?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/Amqp/Consumer/AssignDoctorConsumer.php | 1 + app/Amqp/Consumer/CancelUnInquiryOrdersDelayDirectConsumer.php | 2 -- 2 files changed, 1 insertion(+), 2 deletions(-) diff --git a/app/Amqp/Consumer/AssignDoctorConsumer.php b/app/Amqp/Consumer/AssignDoctorConsumer.php index 136c9b4..8a56e50 100644 --- a/app/Amqp/Consumer/AssignDoctorConsumer.php +++ b/app/Amqp/Consumer/AssignDoctorConsumer.php @@ -166,6 +166,7 @@ class AssignDoctorConsumer extends ConsumerMessage Log::getInstance()->error("分配医生队列执行失败:加入未接诊取消订单延迟队列失败"); return Result::ACK; } + Log::getInstance()->info("分配医生队列执行:加入未接诊取消订单延迟队列成功"); Db::commit(); Log::getInstance()->error("分配医生 队列执行成功"); diff --git a/app/Amqp/Consumer/CancelUnInquiryOrdersDelayDirectConsumer.php b/app/Amqp/Consumer/CancelUnInquiryOrdersDelayDirectConsumer.php index 6693e60..0614619 100644 --- a/app/Amqp/Consumer/CancelUnInquiryOrdersDelayDirectConsumer.php +++ b/app/Amqp/Consumer/CancelUnInquiryOrdersDelayDirectConsumer.php @@ -135,8 +135,6 @@ class CancelUnInquiryOrdersDelayDirectConsumer extends ConsumerMessage } $InquiryService->inquiryRefund($order_inquiry['order_inquiry_id'], "医生未接诊"); - Db::commit(); - return Result::ACK; } Db::commit();