diff --git a/app/Amqp/Consumer/AssignDoctorDelayDirectConsumer.php b/app/Amqp/Consumer/AssignDoctorDelayDirectConsumer.php index e27953f..6dcf7b0 100644 --- a/app/Amqp/Consumer/AssignDoctorDelayDirectConsumer.php +++ b/app/Amqp/Consumer/AssignDoctorDelayDirectConsumer.php @@ -70,7 +70,7 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage try { // 检测锁定状态 $redis = $this->container->get(Redis::class); - $redis_key = "assign_octor_lock_" . $data['order_inquiry_id']; + $redis_key = "assign_doctor_lock_" . $data['order_inquiry_id']; $redis_lock = $redis->setnx($redis_key,1); // 设置过期时间-10s @@ -183,7 +183,7 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage $params['order_inquiry_id'] = $order_inquiry['order_inquiry_id']; OrderInquiry::edit($params, $save_data); - Log::getInstance("queue-AssignDoctor")->info("结束"); + Log::getInstance("queue-AssignDoctor")->info("结束:已退款"); Db::commit(); return Result::ACK; } @@ -210,7 +210,7 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage return Result::REQUEUE; } - Log::getInstance("queue-AssignDoctor")->info("结束"); + Log::getInstance("queue-AssignDoctor")->info("重回队列"); return Result::ACK; }