czg_team
/
p_ysk
6
0
Fork 0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

redis edit

This commit is contained in:
ASUS 2025-10-13 15:11:11 +08:00
parent 0afa013649
commit 6c74bde8e1
1 changed files with 43 additions and 45 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

88
extend/workermans/model/Base.php
View File

@ -713,61 +713,59 @@ class Base extends Model
*/ */
public static function add_total_number(string $client_id, string $type = null, $total = null) public static function add_total_number(string $client_id, string $type = null, $total = null)
{ {
$redis = self::$redis;
$redis_name = date('Y-m-d') . '_online_number'; $redis_name = date('Y-m-d') . '_online_number';
$redis->get($redis_name, function ($result, $redis) use ($redis_name, $client_id, $type, $total) { $result = Redis::get($redis_name);
if($result) { if($result) {
$result_arr = json_decode($result, true); $result_arr = json_decode($result, true);
if($type) { if($type) {
if(isset($result_arr[$type])) { if(isset($result_arr[$type])) {
if (!in_array($client_id, $result_arr[$type])) { if (!in_array($client_id, $result_arr[$type])) {
// 新增 // 新增
array_push($result_arr[$type], $client_id); array_push($result_arr[$type], $client_id);
}
}else {
$result_arr[$type] = [$client_id];
} }
}else { }else {
foreach ($result_arr as $type_str => $client_arr) {
$key = array_search($client_id, $client_arr);
if($key !== false) {
// 关闭
unset($result_arr[$type_str][$key]);
$result_arr[$type_str] = array_values($result_arr[$type_str]);
}
}
if(!empty($result_arr['total'])) {
$key = array_search($client_id, $result_arr['total']);
if($key !== false) {
unset($result_arr['total'][$key]);
$result_arr['total'] = array_values($result_arr['total']);
}
}
}
if($total) {
if(isset($result_arr['total'])) {
if (!in_array($client_id, $result_arr['total'])) {
// 新增
array_push($result_arr['total'], $client_id);
}
}else {
$result_arr['total'] = [$client_id];
}
}
}else {
if($type) {
$result_arr[$type] = [$client_id]; $result_arr[$type] = [$client_id];
} }
if($total) { }else {
foreach ($result_arr as $type_str => $client_arr) {
$key = array_search($client_id, $client_arr);
if($key !== false) {
// 关闭
unset($result_arr[$type_str][$key]);
$result_arr[$type_str] = array_values($result_arr[$type_str]);
}
}
if(!empty($result_arr['total'])) {
$key = array_search($client_id, $result_arr['total']);
if($key !== false) {
unset($result_arr['total'][$key]);
$result_arr['total'] = array_values($result_arr['total']);
}
}
}
if($total) {
if(isset($result_arr['total'])) {
if (!in_array($client_id, $result_arr['total'])) {
// 新增
array_push($result_arr['total'], $client_id);
}
}else {
$result_arr['total'] = [$client_id]; $result_arr['total'] = [$client_id];
} }
} }
if(isset($result_arr)) { }else {
$redis->set($redis_name, json_encode($result_arr), 60 * 60 * 24); if($type) {
$result_arr[$type] = [$client_id];
} }
}); if($total) {
$result_arr['total'] = [$client_id];
}
}
if(isset($result_arr)) {
Redis::set($redis_name, json_encode($result_arr), 60 * 60 * 24);
}
if(!$type) { if(!$type) {
$redis->del($client_id); Redis::del($client_id);
} }
} }