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

redis

Browse Source
This commit is contained in:
ASUS
2025-10-17 13:30:38 +08:00
parent 094b308f6e
commit 0a4b66e38c
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -115,7 +115,6 @@ class Base extends Model
// 加入锁单分组 // 加入锁单分组
Gateway::joinGroup($client_id, $msg_id); Gateway::joinGroup($client_id, $msg_id);
$time = time(); $time = time();
$redis = self::$redis;
$_SESSION[$msg_id] = $time; $_SESSION[$msg_id] = $time;
//找到锁单分组中其他的人 //找到锁单分组中其他的人
$all = Gateway::getClientSessionsByGroup($msg_id); $all = Gateway::getClientSessionsByGroup($msg_id);
@@ -127,7 +126,7 @@ class Base extends Model
$result = Redis::get($redis_name); $result = Redis::get($redis_name);
if($result) { if($result) {
}else { }else {
$redis->set($redis_name, $msg_id, 3600); Redis::setEx($redis_name, 3600, $msg_id);
} }
} }
print_r('锁单的key-----' . $msg_id . "\r\n"); print_r('锁单的key-----' . $msg_id . "\r\n");
@@ -148,8 +147,6 @@ class Base extends Model
public static function payunlock(string $client_id, array $params) public static function payunlock(string $client_id, array $params)
{ {
$msg_id = self::get_shopping_save_lockname($params['shop_id'], $params['table_code']); $msg_id = self::get_shopping_save_lockname($params['shop_id'], $params['table_code']);
// 直接保存锁定
$redis = self::$redis;
// 自己先解锁 // 自己先解锁
$_SESSION[$msg_id] = ''; $_SESSION[$msg_id] = '';
// 找到他人并解锁 // 找到他人并解锁
@@ -161,7 +158,7 @@ class Base extends Model
$redis_name = $g_client_id . '_lock'; $redis_name = $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);
} }
} }
print_r('解锁的key-----' . $msg_id . "\r\n"); print_r('解锁的key-----' . $msg_id . "\r\n");