gdxz/hospital-applets-api
4
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

去除im在线状态日志

Browse Source
This commit is contained in:
wucongxing8150 2024-04-12 14:04:17 +08:00
parent 1b2bff7b0a
commit 646802a2ab
1 changed files with 5 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
app/Amqp/Consumer/UserImOffDelayDirectConsumer.php
View File

@ -34,7 +34,7 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage
public function consumeMessage($data, AMQPMessage $message): string 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'])){ if (!isset($data['user_id'])){
@ -47,14 +47,14 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage
$params['user_id'] = $data['user_id']; $params['user_id'] = $data['user_id'];
$user = User::getOne($params); $user = User::getOne($params);
if (empty($user)){ if (empty($user)){
Log::getInstance("queue-UserImOff")->error("无该用户"); // Log::getInstance("queue-UserImOff")->error("无该用户");
return Result::DROP; return Result::DROP;
} }
try { try {
// 检测用户状态 // 检测用户状态
if ($user['is_online'] == 0){ if ($user['is_online'] == 0){
Log::getInstance("queue-UserImOff")->info("用户目前已下线，无需处理"); // Log::getInstance("queue-UserImOff")->info("用户目前已下线，无需处理");
return Result::ACK; return Result::ACK;
} }
@ -63,7 +63,7 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage
$diff_time = time() - $im_login_at; $diff_time = time() - $im_login_at;
if ($diff_time <= (30 * 60 + 10)){ if ($diff_time <= (30 * 60 + 10)){
// if ($diff_time <= (2 * 50)){ // if ($diff_time <= (2 * 50)){
Log::getInstance("queue-UserImOff")->info("用户刚上线未满30分钟，无需处理"); // Log::getInstance("queue-UserImOff")->info("用户刚上线未满30分钟，无需处理");
return Result::ACK; return Result::ACK;
} }
@ -83,7 +83,7 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage
return Result::DROP; return Result::DROP;
} }
Log::getInstance("queue-UserImOff")->info("结束：" . $user['user_name'] . "已下线"); // Log::getInstance("queue-UserImOff")->info("结束：" . $user['user_name'] . "已下线");
return Result::ACK; return Result::ACK;
} }
} }