From f68a8438c1e9b3300a8873836ec4140e659ab494 Mon Sep 17 00:00:00 2001 From: wucongxing <815046773@qq.com> Date: Mon, 27 Nov 2023 13:51:25 +0800 Subject: [PATCH] 1 --- app/Amqp/Consumer/UserImOffDelayDirectConsumer.php | 2 +- app/Services/UserService.php | 10 +++++----- 2 files changed, 6 insertions(+), 6 deletions(-) diff --git a/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php b/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php index a83ea66..cfb658c 100644 --- a/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php +++ b/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php @@ -67,7 +67,7 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage $im_login_at = strtotime($user['im_login_at']); $diff_time = time() - $im_login_at; - if ($diff_time <= 3 * 60){ + if ($diff_time <= (30 * 60 + 10)){ Log::getInstance("queue-UserImOff")->info("用户刚上线未满30分钟,无需处理"); return Result::ACK; } diff --git a/app/Services/UserService.php b/app/Services/UserService.php index 9724e41..dfde661 100644 --- a/app/Services/UserService.php +++ b/app/Services/UserService.php @@ -1006,9 +1006,11 @@ class UserService extends BaseService $result['message'] = "在线状态存储失败"; return $result; } + + Log::getInstance("UserService-userImLoginStatus")->info("用户已设上线"); } elseif ($msg_data['Info']['Action'] == "Disconnect"){ // 点右上角退出/断网(如手机开启飞行模式)/微信切后台/杀掉微信进程 - $time = strtotime($msg_data['RequestTime']) + 3*60; + $time = strtotime($msg_data['RequestTime']) + 30*60; $data = array(); $data['user_id'] = $user['user_id']; @@ -1021,6 +1023,7 @@ class UserService extends BaseService $result['message'] = "添加下线队列失败"; return $result; } + Log::getInstance("UserService-userImLoginStatus")->info("已添加延迟下线队列"); } elseif ($msg_data['Info']['Action'] == "Logout"){ // 主动退出 // 修改用户表在线状态 @@ -1037,10 +1040,7 @@ class UserService extends BaseService } } - // 删除缓存 - $redis = $this->container->get(Redis::class); - $redis_key = "user_im_online_" . $user['user_id']; - $redis->del($redis_key); + Log::getInstance("UserService-userImLoginStatus")->info("用户已设下线"); } Db::commit();