From 1dcf99798e17328ce96308dbdad5532823a3bd08 Mon Sep 17 00:00:00 2001 From: wucongxing <815046773@qq.com> Date: Mon, 27 Nov 2023 13:19:56 +0800 Subject: [PATCH] =?UTF-8?q?=E6=96=B0=E5=A2=9Eim=E6=B6=88=E6=81=AF=E5=9B=9E?= =?UTF-8?q?=E8=B0=83=E4=BF=AE=E6=94=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- app/Amqp/Consumer/UserImOffDelayDirectConsumer.php | 2 +- app/Services/UserService.php | 4 ++-- 2 files changed, 3 insertions(+), 3 deletions(-) diff --git a/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php b/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php index 3caf1b5..eb679b2 100644 --- a/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php +++ b/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php @@ -57,7 +57,7 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage // 获取缓存 $redis = $this->container->get(Redis::class); - $redis_key = "user_im_online" . $data['user_id']; + $redis_key = "user_im_online_" . $data['user_id']; $res = $redis->get($redis_key); if ($res){ Log::getInstance("queue-UserImOff")->info("用户刚上线未满30分钟，无需处理"); diff --git a/app/Services/UserService.php b/app/Services/UserService.php index 2163698..e68ad8e 100644 --- a/app/Services/UserService.php +++ b/app/Services/UserService.php @@ -1009,7 +1009,7 @@ class UserService extends BaseService // 添加缓存 $redis = $this->container->get(Redis::class); - $redis_key = "user_im_online" . $user['user_id']; + $redis_key = "user_im_online_" . $user['user_id']; $redis->set($redis_key,$msg_data['RequestTime'],30*60); } elseif ($msg_data['Info']['Action'] == "Disconnect"){ @@ -1045,7 +1045,7 @@ class UserService extends BaseService // 删除缓存 $redis = $this->container->get(Redis::class); - $redis_key = "user_im_online" . $user['user_id']; + $redis_key = "user_im_online_" . $user['user_id']; $redis->del($redis_key); }