addUser.php 2.2 KB

12345678910111213141516171819202122232425262728293031323334353637383940414243444546474849505152535455565758596061626364656667686970717273747576
  1. <?php
  2. namespace App\Jobs\VNet;
  3. use App\Models\Node;
  4. use App\Models\User;
  5. use Arr;
  6. use Http;
  7. use Illuminate\Bus\Queueable;
  8. use Illuminate\Contracts\Queue\ShouldQueue;
  9. use Illuminate\Foundation\Bus\Dispatchable;
  10. use Illuminate\Queue\InteractsWithQueue;
  11. use Illuminate\Queue\SerializesModels;
  12. use Log;
  13. use Throwable;
  14. class addUser implements ShouldQueue
  15. {
  16. use Dispatchable;
  17. use InteractsWithQueue;
  18. use Queueable;
  19. use SerializesModels;
  20. private $data;
  21. private $nodes;
  22. public function __construct($userIds, $nodeIds)
  23. {
  24. $this->nodes = Node::findMany($nodeIds);
  25. $data = [];
  26. foreach (User::findMany($userIds) as $user) {
  27. $data[] = [
  28. 'uid' => $user->id,
  29. 'port' => $user->port,
  30. 'passwd' => $user->passwd,
  31. 'speed_limit' => $user->speed_limit,
  32. 'enable' => $user->enable,
  33. ];
  34. }
  35. $this->data = $data;
  36. }
  37. public function handle(): void
  38. {
  39. foreach ($this->nodes as $node) {
  40. if ($node->type == 0){
  41. Log::info('【新增用户】推送成功 这个是SS 后端不一样不用推送');
  42. } else {
  43. $this->send(($node->server ?: $node->ip).':'.$node->push_port, $node->auth->secret);
  44. }
  45. }
  46. }
  47. private function send($host, $secret): void
  48. {
  49. $request = Http::baseUrl($host)->withoutVerifying()->timeout(20)->withHeaders(['secret' => $secret]);
  50. $response = $request->post('api/v2/user/add/list', $this->data);
  51. $message = $response->json();
  52. if ($message && Arr::has($message, ['success', 'content']) && $response->ok()) {
  53. if ($message['success'] === 'false') {
  54. Log::warning('【新增用户】推送失败(推送地址:'.$host.',返回内容:'.$message['content'].')');
  55. } else {
  56. Log::info('【新增用户】推送成功(推送地址:'.$host.',内容:'.json_encode($this->data, true).')');
  57. }
  58. }
  59. }
  60. // 队列失败处理
  61. public function failed(Throwable $exception)
  62. {
  63. Log::error('【新增用户】推送异常:'.$exception->getMessage());
  64. }
  65. }