账户回传队分开

app/Http/Controllers/QuickApp/Book/BookController.php

@@ -4,6 +4,8 @@ namespace App\Http\Controllers\QuickApp\Book;
 
 use App\Cache\Home\HomeCache;
 use App\Consts\BaseConst;
+use App\Jobs\QappTikTok\QappTikTokUserChargeAccount;
+use App\Jobs\QappTikTok\QappTikTokUserChargeAccountRequest;
 use App\Libs\Utils;
 use App\Modules\Activity\Services\ActivityService;
 use App\Modules\Book\Models\RecoBanner;
@@ -192,6 +194,23 @@ class BookController extends BaseController
      */
     public function getBookLists(Request $request, $sex)
     {
+    
+        $tikTokChargeRequest                = new QappTikTokUserChargeAccountRequest();
+        $tikTokChargeRequest->uid           = '295486715';
+        $tikTokChargeRequest->amount        = '88';
+        $tikTokChargeRequest->order_no      = '202206220000341736260697762225';
+        $tikTokChargeRequest->pay_time      = '2022-06-22 00:00:34';
+        $tikTokChargeRequest->book_id       = 59857;
+        $tikTokChargeRequest->book_name     = '龙战于野';
+        $tikTokChargeRequest->send_order_id = '3377366';
+        $tikTokChargeRequest->account = 'ceshi1qm';
+        $tikTokChargeRequest->account_id = DB::table('qapp_channel_accounts')->where('account','ceshi1qm')->value('id');
+        myLog('qapp_user_charge')->info('addQueue', compact('tikTokChargeRequest'));
+        // 需要跟派单设置的回传类型一致才上报
+        $obj = new QappTikTokUserChargeAccount($tikTokChargeRequest);
+          dispatch($obj->onConnection('redis_queue')->onQueue('{qapp_tiktok_account_user_charge_queue}'));
+        
+        die();
         // 获取基本数据
         $package = $request->header('x-package', '');
         $brand = $request->header('x-nbrand', '');

app/Jobs/QappTikTok/QappTikTokUserChargeAccount.php

@@ -20,12 +20,12 @@ class QappTikTokUserChargeAccount implements ShouldQueue
     private $reportParams;
 
     protected $url;
-
+    
     /**
      * QappTikTokUserCharge constructor.
-     * @param QappTikTokUserChargeRequest $reportParams
+     * @param QappTikTokUserChargeAccountRequest $reportParams
      */
-    public function __construct(QappTikTokUserChargeRequest $reportParams)
+    public function __construct(QappTikTokUserChargeAccountRequest $reportParams)
     {
         $this->reportParams = $reportParams;
         $this->url = env('TIKTOK_API_URL'). 'api/qappuser/new_charge';

app/Modules/Trade/Pay/PaySuccessAbstract.php

@@ -116,7 +116,6 @@ abstract class PaySuccessAbstract
         $reportRate     = (int)getProp($quickSendOrder, 'report_rate', 100);
         // 默认走派单回传配置
         switch ($return_type){
-            // 头条账户级回传
             case "tiktok_account":
                 $tikTokChargeRequest                = new QappTikTokUserChargeAccountRequest();
                 $tikTokChargeRequest->uid           = $this->order->uid;