pay push

app/Http/Controllers/Wap/Pay/OrdersController.php

@@ -1160,7 +1160,7 @@ class OrdersController extends Controller
     protected function successPayPushMsg($uid, $product_info, $order_id)
     {
         try {
-            $force_sub_info = $this->getSubscribe($uid);
+            $force_sub_info = $this->getSubscribeV2($uid);
             $data = UserService::getById($uid);
             if (!in_array($data->distribution_channel_id, [5, 123])) {
                 //return false;
@@ -1186,22 +1186,24 @@ class OrdersController extends Controller
                 $delay = 0;
                 $url = env('PROTOCOL') . '://site' . encodeDistributionChannelId($data->distribution_channel_id) . '.' . env('CUSTOM_HOST') . '.com/continue';;
                 $content = sprintf($content_format, $data->nickname ? $data->nickname : '匿名', $uid, $money_text, $url);
-                $res['openid'] = $force_sub_info->openid;
-                $res['appid'] = $force_sub_info->appid;
-                $res['content'] = $content;
-                $res['type'] = 'one_task';
-                $res['send_time'] = date("Y-m-d H:i:s");
-                $res['task_id'] = md5('pay_success_push');
-                $send_data = array(
-                    'send_time' => date("Y-m-d H:i:s"),
-                    'data' => $res
-                );
-                dispatch((new SendTexts($send_data))->onConnection('rabbitmq')->delay($delay)->onQueue('send_texts_list'));
+                foreach ($force_sub_info as $item){
+                    $res['openid'] = $item->openid;
+                    $res['appid'] = $item->appid;
+                    $res['content'] = $content;
+                    $res['type'] = 'one_task';
+                    $res['send_time'] = date("Y-m-d H:i:s");
+                    $res['task_id'] = md5('pay_success_push');
+                    $send_data = array(
+                        'send_time' => date("Y-m-d H:i:s"),
+                        'data' => $res
+                    );
+                    dispatch((new SendTexts($send_data))->onConnection('rabbitmq')->delay($delay)->onQueue('send_texts_list'));
+                }
             }
         } catch (\Exception $e) {
-
+            Log::info('pay_success_push error');
+            Log::info($e);
         }
-
         return true;
     }
 
@@ -1248,6 +1250,11 @@ class OrdersController extends Controller
         return ForceSubscribeService::forceSubscribeUsersByUid(['uid' => $uid]);
     }
 
+    private function getSubscribeV2($uid)
+    {
+        return DB::table('force_subscribe_users')->where('uid',$uid)->where('is_subscribed', 1)->get();
+    }
+
     public function getSubscribeOfficialName($uid)
     {
         $subscribe = $this->getSubscribe($uid);