From 646802a2abbd96c672e06f6646b2b5f7099f75c9 Mon Sep 17 00:00:00 2001
From: wucongxing8150 <815046773@qq.com>
Date: Fri, 12 Apr 2024 14:04:17 +0800
Subject: [PATCH] =?UTF-8?q?=E5=8E=BB=E9=99=A4im=E5=9C=A8=E7=BA=BF=E7=8A=B6?=
 =?UTF-8?q?=E6=80=81=E6=97=A5=E5=BF=97?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 app/Amqp/Consumer/UserImOffDelayDirectConsumer.php | 10 +++++-----
 1 file changed, 5 insertions(+), 5 deletions(-)

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;
     }
 }