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

lock

Browse Source
This commit is contained in:
ASUS
2025-12-18 11:43:12 +08:00
parent 9c6370dd02
commit 88de7488bf
2 changed files with 7 additions and 3 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -142,7 +142,7 @@ class Base extends Model
$session = Gateway::getSession($g_client_id); $session = Gateway::getSession($g_client_id);
$session[$msg_id] = $time; $session[$msg_id] = $time;
Gateway::setSession($g_client_id, $session); Gateway::setSession($g_client_id, $session);
$redis_name = $g_client_id . '_lock'; $redis_name = 'lock:' . $g_client_id . '_lock';
$result = Redis::get($redis_name); $result = Redis::get($redis_name);
if($result) { if($result) {
}else { }else {
@@ -175,7 +175,7 @@ class Base extends Model
$session = Gateway::getSession($g_client_id); $session = Gateway::getSession($g_client_id);
unset($session[$msg_id]); unset($session[$msg_id]);
Gateway::setSession($g_client_id, $session); Gateway::setSession($g_client_id, $session);
$redis_name = $g_client_id . '_lock'; $redis_name = 'lock:' . $g_client_id . '_lock';
$result = Redis::get($redis_name); $result = Redis::get($redis_name);
if($result) { if($result) {
Redis::del($redis_name); Redis::del($redis_name);
@@ -319,7 +319,7 @@ class Base extends Model
self::add_log_file('----无回执--' .date('Y-m-d H:i:s'). '--->' . $result); self::add_log_file('----无回执--' .date('Y-m-d H:i:s'). '--->' . $result);
} }
$r_name = $client_id . '_lock'; $r_name = 'lock:' . $client_id . '_lock';
// 处理锁单消息 // 处理锁单消息
$result = Redis::get($r_name); $result = Redis::get($r_name);
if($result) { if($result) {

4
plugin/webman/gateway/Events.php
View File

@@ -278,6 +278,10 @@ class Events
$number = $red_number; $number = $red_number;
$message['number'] = $red_number; $message['number'] = $red_number;
} }
if($number < $data[0]['number'] && $red_number == 0) {
$number = 0;
$message['number'] = 0;
}
} }
} }
$d_data = false; $d_data = false;