addUser.php 1.2 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950
  1. <?php
  2. namespace App\Jobs\VNet;
  3. use App\Models\User;
  4. use GuzzleHttp\Client;
  5. use Illuminate\Bus\Queueable;
  6. use Illuminate\Contracts\Queue\ShouldQueue;
  7. use Illuminate\Foundation\Bus\Dispatchable;
  8. use Illuminate\Queue\InteractsWithQueue;
  9. use Illuminate\Queue\SerializesModels;
  10. class addUser implements ShouldQueue {
  11. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  12. private $data;
  13. private $nodes;
  14. public function __construct($userIds, $nodes) {
  15. $this->nodes = $nodes;
  16. $data = [];
  17. foreach(User::findMany($userIds) as $user){
  18. $data[] = [
  19. 'uid' => $user->id,
  20. 'port' => $user->port,
  21. 'passwd' => $user->passwd,
  22. 'speed_limit' => $user->speed_limit,
  23. 'enable' => $user->enable
  24. ];
  25. }
  26. $this->data = $data;
  27. }
  28. public function handle(): void {
  29. foreach($this->nodes as $node){
  30. $this->send(($node->server?: $node->ip).':'.$node->push_port, $node->auth->secret);
  31. }
  32. }
  33. private function send($host, $secret): void {
  34. $client = new Client([
  35. 'base_uri' => $host,
  36. 'timeout' => 15,
  37. 'headers' => ['secret' => $secret]
  38. ]);
  39. $client->post('api/v2/user/add/list', ['json' => $this->data]);
  40. }
  41. }