|
@@ -241,7 +241,7 @@ class QappUserService
|
|
|
DB::commit();
|
|
|
$this->syncHandle($user, $data);
|
|
|
return $qapp_user;
|
|
|
-
|
|
|
+
|
|
|
} catch (Exception $e) {
|
|
|
DB::rollback();
|
|
|
myLog('create_user')->error($e->getMessage());
|
|
@@ -254,28 +254,33 @@ class QappUserService
|
|
|
private function syncHandle(User $user, array $data)
|
|
|
{
|
|
|
// 队列处理回传业务
|
|
|
- $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'));
|
|
|
+ try {
|
|
|
+ $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'));
|
|
|
+ // 回传业务
|
|
|
+ $job = new QappTikTokUser($tikTokRegisterRequest);
|
|
|
+ dispatch($job->onConnection('rabbitmq')->onQueue('qapp_tiktok_user_register_queue'));
|
|
|
|
|
|
- UserTaskService::addUserTaskQueue($user->id, BaseTask::register, UserTaskService::add_trigger);
|
|
|
+ UserTaskService::addUserTaskQueue($user->id, BaseTask::register, UserTaskService::add_trigger);
|
|
|
|
|
|
- $job = new NewUserPushMsgDelay($user->id);
|
|
|
- dispatch($job->onConnection('rabbitmq')->onQueue('new_user_push_msg'));
|
|
|
+ $job = new NewUserPushMsgDelay($user->id);
|
|
|
+ dispatch($job->onConnection('rabbitmq')->onQueue('new_user_push_msg'));
|
|
|
|
|
|
- // 同步数据
|
|
|
- $user->channel_id = $user->distribution_channel_id;
|
|
|
- ReportService::reportRegister($user);
|
|
|
+ // 同步数据
|
|
|
+ $user->channel_id = $user->distribution_channel_id;
|
|
|
+ ReportService::reportRegister($user);
|
|
|
+ }catch (Exception $exception){
|
|
|
+ \Log::info('login_fail_user_syncHandle_error_data:',$data);
|
|
|
+ \Log::info('login_fail_user_syncHandle_error_msg:'.$exception->getMessage());
|
|
|
+ }
|
|
|
}
|
|
|
|
|
|
private function findChannelId(string $package)
|