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

del print

Browse Source
This commit is contained in:
ASUS
2025-11-14 10:58:53 +08:00
parent dea933503e
commit c5548e6c0f
3 changed files with 26 additions and 31 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -127,7 +127,7 @@ class Base extends Model
Redis::setEx($redis_name, 3600, $msg_id);
}
}
print_r('锁单的key-----' . $msg_id . "\r\n");
// print_r('锁单的key-----' . $msg_id . "\r\n");
// 直接保存锁定
$rand = 'pay_lock' . Random::build();
$snd_data = [
@@ -159,7 +159,7 @@ class Base extends Model
Redis::del($redis_name);
}
}
print_r('解锁的key-----' . $msg_id . "\r\n");
// print_r('解锁的key-----' . $msg_id . "\r\n");
$rand = 'pay_unlock' . Random::build();
$snd_data = [
'msg' => '支付解锁',
@@ -184,9 +184,9 @@ class Base extends Model
$lock_name = self::get_shopping_save_lockname($params['shop_id'], $params['table_code']);
// 先加入锁单分组
Gateway::joinGroup($client_id, $lock_name);
print_r('查询的key-----' . $lock_name . "\r\n");
// print_r('查询的key-----' . $lock_name . "\r\n");
if(!empty($_SESSION[$lock_name])) {
print_r('查询的session-----' . $_SESSION[$lock_name] . "\r\n");
// print_r('查询的session-----' . $_SESSION[$lock_name] . "\r\n");
$snd_data['status'] = 0;
}else {
$other_clinet = false;
@@ -234,11 +234,11 @@ class Base extends Model
// 添加redis 新
public static function setredis_new(string $data, string $client_id)
{
print_r('redis保存client_id---->' . $client_id . "\r\n");
print_r('redis保存值---->' . $data . "\r\n");
print_r('redis保存时间---->' . self::REDIS_TIME . "\r\n");
// print_r('redis保存client_id---->' . $client_id . "\r\n");
// print_r('redis保存值---->' . $data . "\r\n");
// print_r('redis保存时间---->' . self::REDIS_TIME . "\r\n");
$res = Redis::setex($client_id, self::REDIS_TIME, $data);
print_r('redis保存结果---->' . $res . "\r\n");
// print_r('redis保存结果---->' . $res . "\r\n");
}
// 消息回执
@@ -246,12 +246,12 @@ class Base extends Model
{
// 处理普通消息
Redis::del($client_id);
print_r('回执---》' . $msg_id . date('Y-m-d H:i:s') . "\r\n");
// print_r('回执---》' . $msg_id . date('Y-m-d H:i:s') . "\r\n");
// 如果是订单打印回执，直接删除
if(strstr($msg_id, 'cashier_order')) {
print_r('打印回执---》' . $msg_id . date('Y-m-d H:i:s') . "\r\n");
// print_r('打印回执---》' . $msg_id . date('Y-m-d H:i:s') . "\r\n");
$uid = Gateway::getUidByClientId($client_id);
print_r('UID---》' . $uid . date('Y-m-d H:i:s') . "\r\n");
// print_r('UID---》' . $uid . date('Y-m-d H:i:s') . "\r\n");
Redis::del($uid);
}
}
@@ -260,7 +260,7 @@ class Base extends Model
// 定时器处理消息回执/在线列表/折扣信息
public static function geteventredis_new()
{
print_r('定时器' . "\r\n");
// print_r('定时器' . "\r\n");
$gateway = Gateway::class;
// 处理折扣消息
self::savetimediscount();
@@ -287,7 +287,7 @@ class Base extends Model
if($method && call_user_func_array([$gateway, $method], [$msg_info_arr['send_id']])) {
// 再次推送
call_user_func_array([$gateway, $msg_info_arr['method']], [$msg_info_arr['send_id'], $result]);
print_r('推送了-----' . "\r\n");
// print_r('推送了-----' . "\r\n");
// 推送以后新增推送次数
$msg_info_arr['send_num'] += 1;
Redis::setex($client_id, self::REDIS_TIME, json_encode($msg_info_arr), );
@@ -302,14 +302,14 @@ class Base extends Model
$result = Redis::get($r_name);
if($result) {
$session = $gateway::getSession($client_id);
print_r('session的内容-----' . json_encode($session) . "\r\n");
// print_r('session的内容-----' . json_encode($session) . "\r\n");
if($session && isset($session[$result])) {
// 如果大于五秒没有更新，解除锁定
if(time() - $session[$result] > 10) {
unset($session[$result]);
$gateway::setSession($client_id, $session);
Redis::del($r_name);
print_r('解除锁定了-----' . json_encode($session) . "\r\n");
// print_r('解除锁定了-----' . json_encode($session) . "\r\n");
return true;
}
}
@@ -362,7 +362,7 @@ class Base extends Model
if(is_array($table_arr)) {
foreach ($table_arr as $k => $v) {
if(!Gateway::getClientCountByGroup(str_replace(':time_discount', '', $v))) {
print_r($v . '过期' ."\r\n");
// print_r($v . '过期' ."\r\n");
unset($table_arr[$k]);
Redis::del($v);
}
@@ -370,7 +370,7 @@ class Base extends Model
Redis::set('time_discount:info', implode(',', $table_arr));
}
if(empty($table_arr)){
print_r(json_encode($table_arr) . '过期' ."\r\n");
// print_r(json_encode($table_arr) . '过期' ."\r\n");
Redis::del('time_discount:info');
}
}
@@ -421,7 +421,7 @@ class Base extends Model
});
// 收银机打印回执
if(strstr($msg_id,'cashier_order') && $error) {
$redis->get($msg_id, function ($result) use ($redis_name, $msg_id, $error, $db){
$redis->get($msg_id, function ($result) use ($redis_name, $msg_id, $error){
$result = json_decode($result, true);
$serviceLog = [
'queue' => 'test-order.print.queue',