diff --git a/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php b/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php index fc050ce..02ea769 100644 --- a/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php +++ b/app/Amqp/Consumer/UserImOffDelayDirectConsumer.php @@ -34,7 +34,7 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage public function consumeMessage($data, AMQPMessage $message): string { - Log::getInstance("queue-UserImOff")->info("开始:" . json_encode($data, JSON_UNESCAPED_UNICODE)); +// Log::getInstance("queue-UserImOff")->info("开始:" . json_encode($data, JSON_UNESCAPED_UNICODE)); // 检测参数 if (!isset($data['user_id'])){ @@ -47,14 +47,14 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage $params['user_id'] = $data['user_id']; $user = User::getOne($params); if (empty($user)){ - Log::getInstance("queue-UserImOff")->error("无该用户"); +// Log::getInstance("queue-UserImOff")->error("无该用户"); return Result::DROP; } try { // 检测用户状态 if ($user['is_online'] == 0){ - Log::getInstance("queue-UserImOff")->info("用户目前已下线,无需处理"); +// Log::getInstance("queue-UserImOff")->info("用户目前已下线,无需处理"); return Result::ACK; } @@ -63,7 +63,7 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage $diff_time = time() - $im_login_at; if ($diff_time <= (30 * 60 + 10)){ // if ($diff_time <= (2 * 50)){ - Log::getInstance("queue-UserImOff")->info("用户刚上线未满30分钟,无需处理"); +// Log::getInstance("queue-UserImOff")->info("用户刚上线未满30分钟,无需处理"); return Result::ACK; } @@ -83,7 +83,7 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage return Result::DROP; } - Log::getInstance("queue-UserImOff")->info("结束:" . $user['user_name'] . "已下线"); +// Log::getInstance("queue-UserImOff")->info("结束:" . $user['user_name'] . "已下线"); return Result::ACK; } }