浏览代码

'加卓逻辑调整'

zhuchengjie 3 年之前
父节点
当前提交
67ba5a08d9
共有 2 个文件被更改,包括 12 次插入5 次删除
  1. 12 1
      app/Jobs/UserAddDeskJob.php
  2. 0 4
      app/Modules/User/Services/UserService.php

+ 12 - 1
app/Jobs/UserAddDeskJob.php

@@ -4,6 +4,7 @@ namespace App\Jobs;
 
 
 use App\Consts\SysConsts;
 use App\Consts\SysConsts;
 use App\Modules\User\Models\QappUserAddDestop;
 use App\Modules\User\Models\QappUserAddDestop;
+use App\Modules\User\Models\QappUserRententionLog;
 use GuzzleHttp\Client;
 use GuzzleHttp\Client;
 use Illuminate\Bus\Queueable;
 use Illuminate\Bus\Queueable;
 use Illuminate\Queue\SerializesModels;
 use Illuminate\Queue\SerializesModels;
@@ -49,6 +50,16 @@ class UserAddDeskJob implements ShouldQueue
         $params['sign'] = _sign($params, SysConsts::TIKTOK_KEY);
         $params['sign'] = _sign($params, SysConsts::TIKTOK_KEY);
         $url = 'https://newtrackapi.zhuishuyun.com/api/qappuser/addDesk';
         $url = 'https://newtrackapi.zhuishuyun.com/api/qappuser/addDesk';
         $response =  $client->post($url, ['form_params' => $params])->getBody()->getContents();
         $response =  $client->post($url, ['form_params' => $params])->getBody()->getContents();
-        myLog('new_user_rentention')->info($response);
+        myLog('user_add_desk')->info($response);
+        $result =  json_decode($response);
+        if ($result) {
+            if ($result->code == 0) {
+                QappUserAddDestop::create([
+                    'uid' => $this->uid,
+                    'status' => 1,
+                ]);
+            }
+            myLog('new_user_rentention')->info(json_encode(['code' => $result->code,'msg' => $result->msg,'uid' => $this->uid]));
+        }
     }
     }
 }
 }

+ 0 - 4
app/Modules/User/Services/UserService.php

@@ -63,10 +63,6 @@ class UserService
                 $job = new UserAddDeskJob($uid);
                 $job = new UserAddDeskJob($uid);
                 dispatch($job)->onConnection('rabbitmq')->onQueue('qapp_user_add_desk')->delay(now()->addMinutes(3));
                 dispatch($job)->onConnection('rabbitmq')->onQueue('qapp_user_add_desk')->delay(now()->addMinutes(3));
             }
             }
-            QappUserAddDestop::create([
-                'uid'    => $uid,
-                'status' => $status
-            ]);
         }
         }
 
 
         // 加桌统计
         // 加桌统计