拼团

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();