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();