其他订单打印
This commit is contained in:
@@ -42,20 +42,18 @@ try {
|
||||
$data = $msg->body;
|
||||
Log::info('MQ收到消息[订单打印]--->' . $data . '--->' . $date_time . "\n");
|
||||
$order = json_decode($data, true);
|
||||
if(!is_array($order)) {
|
||||
return;
|
||||
}
|
||||
if(is_array($order)) {
|
||||
// 如果是数字。则打印订单
|
||||
$is_log = false;
|
||||
$curl_error = '';
|
||||
// $order_id_t = strpos($data, '_');
|
||||
// if($order_id_t !== false) {
|
||||
// $order_id = substr($data, 0, $order_id_t);
|
||||
// }else {
|
||||
// $order_id = $data;
|
||||
// }
|
||||
// $order = Db::table('tb_order_info')->where(['id' => $order_id])->find();
|
||||
// if($order) {
|
||||
// $order_id_t = strpos($data, '_');
|
||||
// if($order_id_t !== false) {
|
||||
// $order_id = substr($data, 0, $order_id_t);
|
||||
// }else {
|
||||
// $order_id = $data;
|
||||
// }
|
||||
// $order = Db::table('tb_order_info')->where(['id' => $order_id])->find();
|
||||
// if($order) {
|
||||
$rand = 'cashier_order' . Random::build();
|
||||
$send_id = 'cashier_'. $order['shopId'];
|
||||
// 收银机打印订单
|
||||
@@ -84,7 +82,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']);
|
||||
}
|
||||
if($is_log) {
|
||||
@@ -98,6 +96,7 @@ try {
|
||||
'err_info' => $curl_error,
|
||||
]);
|
||||
}
|
||||
}
|
||||
$msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
|
||||
};
|
||||
$rabbit_channel->basic_consume($queue, '', false, false, false, false, $callback);
|
||||
|
||||
Reference in New Issue
Block a user