delUser.php 1003 B

123456789101112131415161718192021222324252627282930313233343536373839404142
  1. <?php
  2. namespace App\Jobs\VNet;
  3. use GuzzleHttp\Client;
  4. use Illuminate\Bus\Queueable;
  5. use Illuminate\Contracts\Queue\ShouldQueue;
  6. use Illuminate\Foundation\Bus\Dispatchable;
  7. use Illuminate\Queue\InteractsWithQueue;
  8. use Illuminate\Queue\SerializesModels;
  9. class delUser implements ShouldQueue {
  10. use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
  11. private $userIds;
  12. private $nodes;
  13. public function __construct($userIds, $nodes) {
  14. $this->userIds = $userIds;
  15. $this->nodes = $nodes;
  16. }
  17. public function handle(): void {
  18. foreach($this->nodes as $node){
  19. $this->send(($node->server?: $node->ip).':'.$node->push_port, $node->auth->secret);
  20. }
  21. }
  22. private function send($host, $secret): void {
  23. $client = new Client([
  24. 'base_uri' => $host,
  25. 'timeout' => 15,
  26. 'headers' => ['secret' => $secret]
  27. ]);
  28. if(is_array($this->userIds)){
  29. $client->post('api/v2/user/del/list', ['json' => $this->userIds]);
  30. }else{
  31. $client->post('api/user/del/'.$this->userIds);
  32. }
  33. }
  34. }