diff --git a/extend/workermans/model/Base.php b/extend/workermans/model/Base.php index f3c6e87..58a2c46 100644 --- a/extend/workermans/model/Base.php +++ b/extend/workermans/model/Base.php @@ -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', diff --git a/plugin/webman/gateway/Events.php b/plugin/webman/gateway/Events.php index 1e5bdf2..2c42bff 100644 --- a/plugin/webman/gateway/Events.php +++ b/plugin/webman/gateway/Events.php @@ -54,7 +54,7 @@ class Events // }; // $http_worker->listen(); if($worker->id == 1) { - print_r('定时器'); +// print_r('定时器'); // 启动定时器 定时器处理消息回执/在线列表 $_SESSION['auth_timer_id'] = Timer::add(10, function (){ Base::geteventredis_new(); @@ -64,7 +64,7 @@ class Events public static function onConnect($client_id) { - print_r('连接--我是' . $client_id . "\r\n"); +// print_r('连接--我是' . $client_id . "\r\n"); Base::add_log_file('当前在线连接总数：' . Gateway::getAllClientCount()); Base::add_total_number($client_id, null, 'total'); } @@ -223,9 +223,9 @@ class Events Redis::select(3); $red_number = Redis::get('shop:' . $message['shop_id'] . ':product-stock:' . $message['product_id']); }catch (\Exception $e) { - print_r( "Redis 错误: " . $e->getMessage() . "\r\n"); +// print_r( "Redis 错误: " . $e->getMessage() . "\r\n"); } - print_r('库存数量-->' . $red_number . "\r\n" . date('Y-m-d H:i:s')); +// print_r('库存数量-->' . $red_number . "\r\n" . date('Y-m-d H:i:s')); if(is_numeric($red_number)) { // 起售数量和库存之间的处理 if(!empty($message['suitNum']) && $message['suitNum'] > 1) { @@ -241,7 +241,7 @@ class Events 'status' => 0, 'data' => [] ]; - print_r('此商品库存不足起售数量' . "\r\n" . date('Y-m-d H:i:s')); +// print_r('此商品库存不足起售数量' . "\r\n" . date('Y-m-d H:i:s')); $gate_way::sendToClient($client_id, json_encode($snd_data)); return; } @@ -292,14 +292,14 @@ class Events `table_code`='{$message['table_code']}' "); if($data_number) { - print_r('已有数量' . $data_number[0]['number'] . "\r\n" . date('Y-m-d H:i:s')); +// print_r('已有数量' . $data_number[0]['number'] . "\r\n" . date('Y-m-d H:i:s')); $number += $data_number[0]['number']; if($data && $number > $data[0]['number']) { $number -= $data[0]['number']; } } } - print_r('实际数量' . $number . "\r\n" . date('Y-m-d H:i:s')); +// print_r('实际数量' . $number . "\r\n" . date('Y-m-d H:i:s')); if($red_number < $number) { $snd_data = [ 'msg' => '此商品库存不足', diff --git a/scripts/rabborderprint.php b/scripts/rabborderprint.php index 8d7bf37..10b3d8b 100644 --- a/scripts/rabborderprint.php +++ b/scripts/rabborderprint.php @@ -44,17 +44,12 @@ try { // 如果是数字。则打印订单 $is_log = false; $curl_error = ''; - print_r($data . "\r\n"); $order_id_t = strpos($data, '_'); - print_r($order_id_t . "嘿嘿\r\n"); if($order_id_t !== false) { - print_r($order_id_t . "\r\n"); $order_id = substr($data, 0, $order_id_t); }else { - print_r( "无下划线\r\n"); $order_id = $data; } - print_r($order_id . "\r\n"); $order = Db::table('tb_order_info')->where(['id' => $order_id])->find(); if($order) { $rand = 'cashier_order' . Random::build(); @@ -85,7 +80,7 @@ try { Base::setredis_new($result_n, $snd_data['send_id']); }else { $params_arr_n[] = $snd_data; - print_r('数组-------->' . json_encode($params_arr_n)) . "\r\n"; +// print_r('数组-------->' . json_encode($params_arr_n)) . "\r\n"; Base::setredis_new(json_encode($params_arr_n), $snd_data['send_id']); } //