diff --git a/app/queue/redis/SendWechatTemp.php b/app/queue/redis/SendWechatTemp.php
index 1d3c591..cc7354d 100644
--- a/app/queue/redis/SendWechatTemp.php
+++ b/app/queue/redis/SendWechatTemp.php
@@ -211,8 +211,9 @@ class SendWechatTemp implements Consumer
                         ->alias('order_d')
                         ->join('tb_user_info ui', 'order_d.user_id = ui.id')
                         ->where('order_d.is_del', 0)
+                        ->where('order_d.group_order_no', $sms_push_event_id)
                         ->where('order_d.status', '<>', '已退款')
-                        ->field('ui.wechat_open_id,ui.id,ui.phone,ui.id as u_user_id, order_d.create_time')
+                        ->field('ui.wechat_open_id,ui.id,ui.phone,ui.id as u_user_id,order_d.create_time,order_d.group_order_no')
                         ->select();
                     Log::info('需要发送拼团成功订阅消息' . json_encode($user_list));
                     $shop = Db::name('tb_shop_info')->where(['id' => $shop_id])->find();