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:
wucongxing 2023-11-27 13:19:56 +08:00
parent f57f1905a8
commit 1dcf99798e
2 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -57,7 +57,7 @@ class UserImOffDelayDirectConsumer extends ConsumerMessage
// 获取缓存 // 获取缓存
$redis = $this->container->get(Redis::class); $redis = $this->container->get(Redis::class);
$redis_key = "user_im_online" . $data['user_id']; $redis_key = "user_im_online_" . $data['user_id'];
$res = $redis->get($redis_key); $res = $redis->get($redis_key);
if ($res){ if ($res){
Log::getInstance("queue-UserImOff")->info("用户刚上线未满30分钟，无需处理"); Log::getInstance("queue-UserImOff")->info("用户刚上线未满30分钟，无需处理");

4
app/Services/UserService.php
View File

@ -1009,7 +1009,7 @@ class UserService extends BaseService
// 添加缓存 // 添加缓存
$redis = $this->container->get(Redis::class); $redis = $this->container->get(Redis::class);
$redis_key = "user_im_online" . $user['user_id']; $redis_key = "user_im_online_" . $user['user_id'];
$redis->set($redis_key,$msg_data['RequestTime'],30*60); $redis->set($redis_key,$msg_data['RequestTime'],30*60);
} elseif ($msg_data['Info']['Action'] == "Disconnect"){ } elseif ($msg_data['Info']['Action'] == "Disconnect"){
@ -1045,7 +1045,7 @@ class UserService extends BaseService
// 删除缓存 // 删除缓存
$redis = $this->container->get(Redis::class); $redis = $this->container->get(Redis::class);
$redis_key = "user_im_online" . $user['user_id']; $redis_key = "user_im_online_" . $user['user_id'];
$redis->del($redis_key); $redis->del($redis_key);
} }