1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556 |
- <?php
- namespace App\Jobs\VNet;
- use GuzzleHttp\Client;
- use Illuminate\Bus\Queueable;
- use Illuminate\Contracts\Queue\ShouldQueue;
- use Illuminate\Foundation\Bus\Dispatchable;
- use Illuminate\Queue\InteractsWithQueue;
- use Illuminate\Queue\SerializesModels;
- class delUser implements ShouldQueue
- {
- use Dispatchable;
- use InteractsWithQueue;
- use Queueable;
- use SerializesModels;
- private $userIds;
- private $nodes;
- public function __construct($userIds, $nodes)
- {
- $this->userIds = $userIds;
- $this->nodes = $nodes;
- }
- public function handle(): void
- {
- foreach ($this->nodes as $node) {
- $this->send(
- ($node->server ?: $node->ip) . ':' . $node->push_port,
- $node->auth->secret
- );
- }
- }
- private function send($host, $secret): void
- {
- $client = new Client(
- [
- 'base_uri' => $host,
- 'timeout' => 15,
- 'headers' => ['secret' => $secret],
- ]
- );
- if (is_array($this->userIds)) {
- $client->post('api/v2/user/del/list', ['json' => $this->userIds]);
- } else {
- $client->post('api/user/del/' . $this->userIds);
- }
- }
- }
|