editUser.php 3.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899
  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. if ($node->type == 0){
  36. $host = ($node->server ?: $node->ip).':'.$node->push_port;
  37. $secret = $node->auth->secret;
  38. // 如果用户已存在节点内,则执行修改;否者为添加
  39. $list = $this->list($host, $secret);
  40. if ($list && in_array($this->data['uid'], $list)) {
  41. //$this->send(($node->server ?: $node->ip).':'.$node->push_port, $node->auth->secret);
  42. $this->send($host, $secret);
  43. } else {
  44. addUser::dispatch($this->data['uid'], $node->id);
  45. }
  46. //$this->send(($node->server ?: $node->ip).':'.$node->push_port, $node->auth->secret);
  47. }
  48. }
  49. }
  50. private function list($host, $secret)
  51. {
  52. $request = Http::baseUrl($host)->withoutVerifying()->timeout(20)->withHeaders(['secret' => $secret]);
  53. $response = $request->get('api/user/list');
  54. $message = $response->json();
  55. if ($message && $response->ok()) {
  56. return Arr::pluck($message, 'uid');
  57. }
  58. Log::warning('【用户列表】获取失败(推送地址:'.$host.')');
  59. return false;
  60. }
  61. private function send($host, $secret): void
  62. {
  63. $request = Http::baseUrl($host)->withoutVerifying()->timeout(20)->withHeaders(['secret' => $secret]);
  64. $response = $request->post('api/user/edit', $this->data);
  65. $message = $response->json();
  66. if ($message && Arr::has($message, ['success', 'content']) && $response->ok()) {
  67. if ($message['success'] === 'false') {
  68. Log::warning('【编辑用户】推送失败(推送地址:'.$host.',返回内容:'.$message['content'].')');
  69. } else {
  70. Log::info('【编辑用户】推送成功(推送地址:'.$host.',内容:'.json_encode($this->data, true).')');
  71. }
  72. }
  73. }
  74. // 队列失败处理
  75. public function failed(Throwable $exception)
  76. {
  77. Log::warning('【编辑用户】推送异常:'.$exception->getMessage());
  78. }
  79. }