| 123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657 | 
							- <?php
 
- namespace App\Jobs\VNet;
 
- use App\Models\User;
 
- 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 addUser implements ShouldQueue
 
- {
 
-     use Dispatchable;
 
-     use InteractsWithQueue;
 
-     use Queueable;
 
-     use SerializesModels;
 
-     private $data;
 
-     private $nodes;
 
-     public function __construct($userIds, $nodes)
 
-     {
 
-         $this->nodes = $nodes;
 
-         $data = [];
 
-         foreach (User::findMany($userIds) as $user) {
 
-             $data[] = [
 
-                 'uid'         => $user->id,
 
-                 'port'        => $user->port,
 
-                 'passwd'      => $user->passwd,
 
-                 'speed_limit' => $user->speed_limit,
 
-                 'enable'      => $user->enable,
 
-             ];
 
-         }
 
-         $this->data = $data;
 
-     }
 
-     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],
 
-         ]);
 
-         $client->post('api/v2/user/add/list', ['json' => $this->data]);
 
-     }
 
- }
 
 
  |