From 441ff06d703cb2dd64ea9e9e3ee00673fcc07de8 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Tue, 2 Dec 2025 15:21:20 +0800 Subject: [PATCH 1/3] =?UTF-8?q?=E4=B8=8A=E8=8F=9C=E7=8A=B6=E6=80=81?= =?UTF-8?q?=E6=8E=A8=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- scripts/orderDetailUpdate.php | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/scripts/orderDetailUpdate.php b/scripts/orderDetailUpdate.php index 55699d1..7453d45 100644 --- a/scripts/orderDetailUpdate.php +++ b/scripts/orderDetailUpdate.php @@ -37,16 +37,17 @@ use support\Redis; $date_time = date('Y-m-d H:i:s'); $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 = 'cart_update' . $data . '_all' ; + $send_id = 'cart_update' . $datInfo['shopId'] . '_all' ; $snd_data =[ 'msg' => '购物车刷新', 'operate_type' => 'reload', 'msg_id' => $rand, - 'type' => 'bc', + 'type' => $datInfo['type'], 'data_type' => 'cart', 'status' => 1 ]; From fe2b53b245aa29b3075bb8b5d652c7d4106ce68e Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Tue, 2 Dec 2025 15:35:24 +0800 Subject: [PATCH 2/3] =?UTF-8?q?=E4=B8=8A=E8=8F=9C=E7=8A=B6=E6=80=81?= =?UTF-8?q?=E6=8E=A8=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- scripts/orderDetailUpdate.php | 1 + 1 file changed, 1 insertion(+) diff --git a/scripts/orderDetailUpdate.php b/scripts/orderDetailUpdate.php index 7453d45..43382e5 100644 --- a/scripts/orderDetailUpdate.php +++ b/scripts/orderDetailUpdate.php @@ -51,6 +51,7 @@ use support\Redis; '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); From e896546b5608a474c027c5554326f9987ddfa76d Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E5=BC=A0=E6=9D=BE?= <8605635+zhang3064194730@user.noreply.gitee.com> Date: Tue, 2 Dec 2025 15:38:40 +0800 Subject: [PATCH 3/3] =?UTF-8?q?=E4=B8=8A=E8=8F=9C=E7=8A=B6=E6=80=81?= =?UTF-8?q?=E6=8E=A8=E9=80=81?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- scripts/orderDetailUpdate.php | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/scripts/orderDetailUpdate.php b/scripts/orderDetailUpdate.php index 43382e5..ca6d340 100644 --- a/scripts/orderDetailUpdate.php +++ b/scripts/orderDetailUpdate.php @@ -4,6 +4,7 @@ require_once __DIR__ . '/../vendor/autoload.php'; require_once __DIR__ . '/../support/bootstrap.php'; use ba\Random; +use extend\workermans\model\Base; use PhpAmqpLib\Connection\AMQPStreamConnection; use support\think\Db; use support\Log; @@ -42,7 +43,7 @@ use support\Redis; $is_log = false; $curl_error = ''; $rand = 'product_update' . Random::build(); - $send_id = 'cart_update' . $datInfo['shopId'] . '_all' ; + $send_id = Base::get_shopping_save_uid($datInfo['shopId'], 'all'); $snd_data =[ 'msg' => '购物车刷新', 'operate_type' => 'reload',