From c4f64e73bea23673d201f14b37abf407869643c0 Mon Sep 17 00:00:00 2001
From: ASUS <515617283@qq.com>
Date: Wed, 3 Dec 2025 13:57:20 +0800
Subject: [PATCH] MQ edit

---
 scripts/orderDetailUpdate.php | 58 ++++++++++++++++++-----------------
 1 file changed, 30 insertions(+), 28 deletions(-)

diff --git a/scripts/orderDetailUpdate.php b/scripts/orderDetailUpdate.php
index ca6d340..71db8ca 100644
--- a/scripts/orderDetailUpdate.php
+++ b/scripts/orderDetailUpdate.php
@@ -39,35 +39,37 @@ use support\Redis;
                 $data = $msg->body;
                 Log::info('MQ收到消息[商品状态更新]--->' . $data .  '--->' . $date_time . "\n");
                 $datInfo= json_decode($data, true);
-                // 如果是数字。则打印订单
-                $is_log = false;
-                $curl_error = '';
-                $rand = 'product_update' . Random::build();
-                $send_id = Base::get_shopping_save_uid($datInfo['shopId'], 'all');
-                $snd_data =[
-                    'msg' => '购物车刷新',
-                    'operate_type' => 'reload',
-                    'msg_id' => $rand,
-                    'type' => $datInfo['type'],
-                    'data_type' => 'cart',
-                    'status' => 1
-                ];
-                Log::info('推送组'.$send_id.'内容'.json_encode($snd_data));
-                $snd_data_json = json_encode($snd_data);
-                Gateway::$registerAddress = '127.0.0.1:1238';
-                $res = Gateway::sendToGroup($send_id, $snd_data_json);
-                Log::info('商品状态更新推送结果-->' . $res);
+                if(is_array($datInfo)) {
+                    // 如果是数字。则打印订单
+                    $is_log = false;
+                    $curl_error = '';
+                    $rand = 'product_update' . Random::build();
+                    $send_id = Base::get_shopping_save_uid($datInfo['shopId'], 'all');
+                    $snd_data =[
+                        'msg' => '购物车刷新',
+                        'operate_type' => 'reload',
+                        'msg_id' => $rand,
+                        'type' => $datInfo['type'],
+                        'data_type' => 'cart',
+                        'status' => 1
+                    ];
+                    Log::info('推送组'.$send_id.'内容'.json_encode($snd_data));
+                    $snd_data_json = json_encode($snd_data);
+                    Gateway::$registerAddress = '127.0.0.1:1238';
+                    $res = Gateway::sendToGroup($send_id, $snd_data_json);
+                    Log::info('商品状态更新推送结果-->' . $res);
 
-                if($is_log) {
-                    Db::table('tb_mq_log')->insert([
-                        'queue' => $queue,
-                        'msg' => $data,
-                        'type' => 'product_update',
-                        'plat' => 'product',
-                        'create_time' => date('Y-m-d H:i:s'),
-                        'fail_time' => date('Y-m-d H:i:s'),
-                        'err_info' => $curl_error,
-                    ]);
+                    if($is_log) {
+                        Db::table('tb_mq_log')->insert([
+                            'queue' => $queue,
+                            'msg' => $data,
+                            'type' => 'product_update',
+                            'plat' => 'product',
+                            'create_time' => date('Y-m-d H:i:s'),
+                            'fail_time' => date('Y-m-d H:i:s'),
+                            'err_info' => $curl_error,
+                        ]);
+                    }
                 }
                 $msg->delivery_info['channel']->basic_ack($msg->delivery_info['delivery_tag']);
             };