上菜状态推送

This commit is contained in:
张松
2025-12-02 15:21:20 +08:00
parent b197eb24c3
commit 441ff06d70

View File

@@ -37,16 +37,17 @@ use support\Redis;
$date_time = date('Y-m-d H:i:s'); $date_time = date('Y-m-d H:i:s');
$data = $msg->body; $data = $msg->body;
Log::info('MQ收到消息[商品状态更新]--->' . $data . '--->' . $date_time . "\n"); Log::info('MQ收到消息[商品状态更新]--->' . $data . '--->' . $date_time . "\n");
$datInfo= json_decode($data, true);
// 如果是数字。则打印订单 // 如果是数字。则打印订单
$is_log = false; $is_log = false;
$curl_error = ''; $curl_error = '';
$rand = 'product_update' . Random::build(); $rand = 'product_update' . Random::build();
$send_id = 'cart_update' . $data . '_all' ; $send_id = 'cart_update' . $datInfo['shopId'] . '_all' ;
$snd_data =[ $snd_data =[
'msg' => '购物车刷新', 'msg' => '购物车刷新',
'operate_type' => 'reload', 'operate_type' => 'reload',
'msg_id' => $rand, 'msg_id' => $rand,
'type' => 'bc', 'type' => $datInfo['type'],
'data_type' => 'cart', 'data_type' => 'cart',
'status' => 1 'status' => 1
]; ];