editUser.php 2.6 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889
  1. <?php
  2. namespace App\Jobs\VNet;
  3. use App\Models\User;
  4. use Arr;
  5. use Http;
  6. use Illuminate\Bus\Queueable;
  7. use Illuminate\Contracts\Queue\ShouldQueue;
  8. use Illuminate\Foundation\Bus\Dispatchable;
  9. use Illuminate\Queue\InteractsWithQueue;
  10. use Illuminate\Queue\SerializesModels;
  11. use Log;
  12. use Throwable;
  13. class editUser implements ShouldQueue
  14. {
  15. use Dispatchable;
  16. use InteractsWithQueue;
  17. use Queueable;
  18. use SerializesModels;
  19. private $data;
  20. private $nodes;
  21. public function __construct(User $user, $nodes)
  22. {
  23. $this->nodes = $nodes;
  24. $this->data = [
  25. 'uid' => $user->id,
  26. 'port' => (int) $user->port,
  27. 'passwd' => $user->passwd,
  28. 'speed_limit' => $user->speed_limit,
  29. 'enable' => (int) $user->enable,
  30. ];
  31. }
  32. public function handle(): void
  33. {
  34. foreach ($this->nodes as $node) {
  35. $host = ($node->server ?: $node->ip).':'.$node->push_port;
  36. $secret = $node->auth->secret;
  37. // 如果用户已存在节点内,则执行修改;否者为添加
  38. $list = $this->list($host, $secret);
  39. if ($list && in_array($this->data['uid'], $list)) {
  40. $this->send($host, $secret);
  41. } else {
  42. addUser::dispatch($this->data['uid'], $node);
  43. }
  44. }
  45. }
  46. private function list($host, $secret)
  47. {
  48. $request = Http::baseUrl($host)->timeout(20)->withHeaders(['secret' => $secret]);
  49. $response = $request->get('api/user/list');
  50. $message = $response->json();
  51. if ($message && $response->ok()) {
  52. return Arr::pluck($message, 'uid');
  53. }
  54. Log::warning('【用户列表】获取失败(推送地址:'.$host.')');
  55. return false;
  56. }
  57. private function send($host, $secret): void
  58. {
  59. $request = Http::baseUrl($host)->timeout(20)->withHeaders(['secret' => $secret]);
  60. $response = $request->post('api/user/edit', $this->data);
  61. $message = $response->json();
  62. if ($message && Arr::has($message, ['success', 'content']) && $response->ok()) {
  63. if ($message['success'] === 'false') {
  64. Log::warning('【编辑用户】推送失败(推送地址:'.$host.',返回内容:'.$message['content'].')');
  65. } else {
  66. Log::info('【编辑用户】推送成功(推送地址:'.$host.',内容:'.json_encode($this->data, true).')');
  67. }
  68. }
  69. }
  70. // 队列失败处理
  71. public function failed(Throwable $exception)
  72. {
  73. Log::warning('【编辑用户】推送异常:'.$exception->getMessage());
  74. }
  75. }