zhuchengjie 3 年之前
父节点
当前提交
cfbbc913ac
共有 1 个文件被更改,包括 21 次插入2 次删除
  1. 21 2
      app/Console/Commands/Test.php

+ 21 - 2
app/Console/Commands/Test.php

@@ -5,8 +5,11 @@ namespace App\Console\Commands;
 
 
 use App\Consts\SysConsts;
+use App\Jobs\QappTikTok\QappTikTokUser;
+use App\Jobs\QappTikTok\QappTikTokUserRequest;
 use App\Libs\Push\OPPOPush\OPPOPushCommon;
 use App\Libs\Utils;
+use App\Modules\User\Models\QappUser;
 use App\Modules\User\Services\UserService;
 use Hashids;
 use Illuminate\Console\Command;
@@ -34,8 +37,24 @@ class Test extends Command
      */
     public function handle()
     {
-        UserService::qappAddDesktop(206594704, 1);
-        UserService::qappAddDesktop(5555, 1);
+        $user = UserService::find(278217244);
+        $data = QappUser::find(11954352);
+        if(is_object($data)){
+            $data = json_decode($data,true);
+        }
+        $tikTokRegisterRequest                = new QappTikTokUserRequest();
+        $tikTokRegisterRequest->ip            = $user->register_ip;
+        $tikTokRegisterRequest->device_no     = $data['device_no'];
+        $tikTokRegisterRequest->mac           = $data['mac'];
+        $tikTokRegisterRequest->channel_id    = $user->distribution_channel_id;
+        $tikTokRegisterRequest->uid           = $user->id;
+        $tikTokRegisterRequest->register_time = $user->created_at->format('Y-m-d H:i:s');
+        $tikTokRegisterRequest->send_order_id = $data['send_order_id'];
+        myLog('qapp_register')->info('', compact('tikTokRegisterRequest'));
+
+        // 回传业务
+        $job = new QappTikTokUser($tikTokRegisterRequest);
+        dispatch($job->onConnection('rabbitmq')->onQueue('qapp_tiktok_user_register_queue'));
         dd('success');
 
         $sign      = 'd1192936959b3c79be1e1582f7b7c27f';