From 2523d50e6cec1a9e557641caec17b5ac5f9db8ca Mon Sep 17 00:00:00 2001 From: wucongxing <815046773@qq.com> Date: Wed, 26 Apr 2023 16:12:05 +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=E9=94=81=E5=AE=9A=E7=8A=B6=E6=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../AssignDoctorDelayDirectConsumer.php | 18 ------------------ 1 file changed, 18 deletions(-) diff --git a/app/Amqp/Consumer/AssignDoctorDelayDirectConsumer.php b/app/Amqp/Consumer/AssignDoctorDelayDirectConsumer.php index 6dcf7b0..cf7f480 100644 --- a/app/Amqp/Consumer/AssignDoctorDelayDirectConsumer.php +++ b/app/Amqp/Consumer/AssignDoctorDelayDirectConsumer.php @@ -67,24 +67,6 @@ class AssignDoctorDelayDirectConsumer extends ConsumerMessage return Result::DROP;// 销毁 } - try { - // 检测锁定状态 - $redis = $this->container->get(Redis::class); - $redis_key = "assign_doctor_lock_" . $data['order_inquiry_id']; - $redis_lock = $redis->setnx($redis_key,1); - - // 设置过期时间-10s - $redis->expire($redis_key,10); - if (!$redis_lock){ - // 设置失败,表示已经设置该值 - Log::getInstance('queue-AssignDoctor')->info("锁定中,重回队列"); - return Result::REQUEUE; - } - }catch (\Exception $e){ - Log::getInstance('queue-AssignDoctor')->error("错误:" . $e->getMessage()); - return Result::ACK; - } - Db::beginTransaction(); try { // 检测分配时间