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

1

Browse Source
This commit is contained in:
wucongxing 2023-11-27 13:51:25 +08:00
parent d3e819eb42
commit f68a8438c1
2 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

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

10
app/Services/UserService.php
View File

@ -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();