diff --git a/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php b/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php index cfb658c..4475285 100644 --- a/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php +++ b/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php @@ -55,15 +55,6 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage return Result::ACK; } - // 获取缓存 - $redis = $this->container->get(Redis::class); - $redis_key = "user_im_online_" . $data['user_id']; - $res = $redis->get($redis_key); - if ($res){ - Log::getInstance("queue-UserImOff")->info("用户刚上线未满30分钟,无需处理"); - return Result::ACK; - } - $im_login_at = strtotime($user['im_login_at']); $diff_time = time() - $im_login_at;