1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253 |
- <?php
- namespace App\Jobs\VNet;
- use App\Models\User;
- use Http;
- 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 = Http::baseUrl($host)->timeout(15)->withHeaders(['secret' => $secret]);
- $client->post('api/v2/user/add/list', $this->data);
- }
- }
|