62 lines
1.7 KiB
PHP
62 lines
1.7 KiB
PHP
|
<?php
|
|||
|
|
|
|||
|
|
namespace App\Jobs;
|
|||
|
|
|
|||
|
|
use App\Models\InviteUser;
|
|||
|
|
use App\Models\User;
|
|||
|
|
use GuzzleHttp\Client;
|
|||
|
|
use Illuminate\Bus\Queueable;
|
|||
|
|
use Illuminate\Contracts\Queue\ShouldBeUnique;
|
|||
|
|
use Illuminate\Contracts\Queue\ShouldQueue;
|
|||
|
|
use Illuminate\Foundation\Bus\Dispatchable;
|
|||
|
|
use Illuminate\Queue\InteractsWithQueue;
|
|||
|
|
use Illuminate\Queue\SerializesModels;
|
|||
|
|
use Illuminate\Support\Facades\Log;
|
|||
|
|
|
|||
|
|
class SyncSaasUser implements ShouldQueue
|
|||
|
|
{
|
|||
|
|
use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
|
|||
|
|
|
|||
|
|
protected $user;
|
|||
|
|
/**
|
|||
|
|
* Create a new job instance.
|
|||
|
|
*
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
public function __construct($user)
|
|||
|
|
{
|
|||
|
|
$this->user = $user;
|
|||
|
|
}
|
|||
|
|
|
|||
|
|
/**
|
|||
|
|
* Execute the job.
|
|||
|
|
*
|
|||
|
|
* @return void
|
|||
|
|
*/
|
|||
|
|
public function handle()
|
|||
|
|
{
|
|||
|
|
Log::info("同步saas用户：".$this->user->id);
|
|||
|
|
$client = new Client();
|
|||
|
|
|
|||
|
|
$url = config('app.shop_url')."merchant/users";
|
|||
|
|
$headers = [
|
|||
|
|
'Key' => config('app.shop_key'), // 自定义头部参数（示例）
|
|||
|
|
];
|
|||
|
|
$from_user_id = $this->user->recommendUserLog?$this->user->recommendUserLog->recommend_user_id:null;
|
|||
|
|
$data = [
|
|||
|
|
'accid'=>User::SAAS_PREFIX.$this->user->id,
|
|||
|
|
'nickname'=>$this->user->name,
|
|||
|
|
'pic'=>$this->user->avatar,
|
|||
|
|
'mobile'=>$this->user->mobile,
|
|||
|
|
'from_accid'=>$from_user_id?User::SAAS_PREFIX.$from_user_id:null,
|
|||
|
|
];
|
|||
|
|
$response = $client->post($url, [
|
|||
|
|
'headers'=>$headers,
|
|||
|
|
'json'=>$data,
|
|||
|
|
]);
|
|||
|
|
$body = $response->getBody()->getContents(); // 获取响应内容
|
|||
|
|
$res = json_decode($body, true);
|
|||
|
|
if($res['code'] == 1) throw new \Exception($res['message']);
|
|||
|
|
}
|
|||
|
|
}
|