diff --git a/extend/workermans/model/Cashier.php b/extend/workermans/model/Cashier.php index b3a800c..56f4650 100644 --- a/extend/workermans/model/Cashier.php +++ b/extend/workermans/model/Cashier.php @@ -4,6 +4,7 @@ namespace extend\workermans\model; use ba\Exception; use ba\Random; +use support\Redis; use support\think\Db; use GatewayWorker\Lib\Gateway; Use support\Log; @@ -67,27 +68,25 @@ class Cashier extends Base self::gateway_query('sendToClient', [$client_id, json_encode($snd_data)]); $uid = $message['account']; - $redis = self::$redis; $gateway = Gateway::class; // 处理打印消息 - $redis->get($uid, function ($result, $redis) use($gateway, $uid){ - if($result) { - $msg_info_arr = json_decode($result, true); - $arr_n = []; - foreach ($msg_info_arr as $k => $arr) { - if($arr['send_num'] < self::RETRYCOUNT) { - $arr['send_num'] += 1; - $arr_json = json_encode($arr); - call_user_func_array([$gateway, $arr['method']], [$arr['send_id'], $arr_json]); - // 推送以后新增推送次数 - self::add_log_file('离线后推送收银机订单打印--->' .date('Y-m-d H:i:s'). '--->' . $arr_json, 'cashier'); - } - self::add_log_file('----离线后推送收银机订单打印无回执--' .date('Y-m-d H:i:s'). '--->' . $arr_json, 'cashier'); - $arr_n[] = $arr; + $result = Redis::get($uid); + if($result) { + $msg_info_arr = json_decode($result, true); + $arr_n = []; + foreach ($msg_info_arr as $k => $arr) { + if($arr['send_num'] < self::RETRYCOUNT) { + $arr['send_num'] += 1; + $arr_json = json_encode($arr); + call_user_func_array([$gateway, $arr['method']], [$arr['send_id'], $arr_json]); + // 推送以后新增推送次数 + self::add_log_file('离线后推送收银机订单打印--->' .date('Y-m-d H:i:s'). '--->' . $arr_json, 'cashier'); } - $redis->set($uid, json_encode($arr_n), self::REDIS_TIME); + self::add_log_file('----离线后推送收银机订单打印无回执--' .date('Y-m-d H:i:s'). '--->' . $arr_json, 'cashier'); + $arr_n[] = $arr; } - }); + Redis::set($uid, json_encode($arr_n), self::REDIS_TIME); + } break; // 新增 case 'add':