SubscribeController.php 4.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141
  1. <?php
  2. namespace App\Http\Controllers\User;
  3. use App\Components\IP;
  4. use App\Http\Controllers\ClientController;
  5. use App\Http\Controllers\Controller;
  6. use App\Models\UserSubscribe;
  7. use App\Models\UserSubscribeLog;
  8. use Arr;
  9. use Illuminate\Http\Request;
  10. use Redirect;
  11. use Response;
  12. class SubscribeController extends Controller
  13. {
  14. private $subType;
  15. // 通过订阅码获取订阅信息
  16. public function getSubscribeByCode(Request $request, string $code)
  17. {
  18. if (empty($code)) {
  19. return Redirect::route('login');
  20. }
  21. $this->subType = $request->input('type');
  22. $target = strtolower($request->input('target') ?? ($request->userAgent() ?? ''));
  23. // 检查订阅码是否有效
  24. $subscribe = UserSubscribe::whereCode($code)->first();
  25. if (! $subscribe) {
  26. return $this->failed(trans('error.subscribe.unknown'));
  27. }
  28. if ($subscribe->status !== 1) {
  29. return $this->failed(trans('error.subscribe.sub_baned'));
  30. }
  31. // 检查用户是否有效
  32. $user = $subscribe->user;
  33. if (! $user) {
  34. return $this->failed(trans('error.subscribe.user'));
  35. }
  36. if ($user->status === -1) {
  37. return $this->failed(trans('error.subscribe.user_disable'));
  38. }
  39. if ($user->enable !== 1) {
  40. if ($user->ban_time) {
  41. return $this->failed(trans('error.subscribe.baned_until', ['time' => $user->ban_time]));
  42. }
  43. $unusedTraffic = $user->transfer_enable - $user->usedTraffic();
  44. if ($unusedTraffic <= 0) {
  45. return $this->failed(trans('error.subscribe.out'));
  46. }
  47. if ($user->expired_at < date('Y-m-d')) {
  48. return $this->failed(trans('error.subscribe.expired'));
  49. }
  50. return $this->failed(trans('error.subscribe.question'));
  51. }
  52. // 更新访问次数
  53. $subscribe->increment('times', 1);
  54. // 记录每次请求
  55. $this->subscribeLog($subscribe->id, IP::getClientIp(), $request->headers);
  56. // 获取这个账号可用节点
  57. $query = $user->nodes()->whereIsSubscribe(1);
  58. if ($this->subType === 1) {
  59. $query = $query->whereIn('type', [1, 4]);
  60. } elseif ($this->subType) {
  61. $query = $query->whereType($this->subType);
  62. }
  63. $nodeList = $query->orderByDesc('sort')->orderBy('id')->get();
  64. if (empty($nodeList)) {
  65. return $this->failed(trans('error.subscribe.none'));
  66. }
  67. $servers = [];
  68. foreach ($nodeList as $node) {
  69. $servers[] = $node->config($user);
  70. }
  71. // 打乱数组
  72. if (sysConfig('rand_subscribe')) {
  73. $servers = Arr::shuffle($servers);
  74. }
  75. if (sysConfig('subscribe_max')) {
  76. $servers = array_slice($servers, 0, (int) sysConfig('subscribe_max'));
  77. }
  78. return (new ClientController)->config($target, $user, $servers);
  79. }
  80. // 抛出错误的节点信息,用于兼容防止客户端订阅失败
  81. private function failed($text)
  82. {
  83. return Response::make(base64url_encode($this->infoGenerator($text)));
  84. }
  85. private function infoGenerator($text): string
  86. {
  87. $result = null;
  88. switch ($this->subType) {
  89. case 2:
  90. $result = 'vmess://'.base64url_encode(json_encode([
  91. 'v' => '2', 'ps' => $text, 'add' => '0.0.0.0', 'port' => 0, 'id' => 0, 'aid' => 0, 'net' => 'tcp',
  92. 'type' => 'none', 'host' => '', 'path' => '/', 'tls' => 'tls',
  93. ], JSON_PRETTY_PRINT));
  94. break;
  95. case 3:
  96. $result = 'trojan://0@0.0.0.0:0?peer=0.0.0.0#'.rawurlencode($text);
  97. break;
  98. case 1:
  99. case 4:
  100. default:
  101. $result = 'ssr://'.base64url_encode('0.0.0.0:0:origin:none:plain:'.base64url_encode('0000').'/?obfsparam=&protoparam=&remarks='.base64url_encode($text).'&group='.base64url_encode(sysConfig('website_name')).'&udpport=0&uot=0');
  102. break;
  103. }
  104. return $result.PHP_EOL;
  105. }
  106. // 写入订阅访问日志
  107. private function subscribeLog($subscribeId, $ip, $headers): void
  108. {
  109. $log = new UserSubscribeLog();
  110. $log->user_subscribe_id = $subscribeId;
  111. $log->request_ip = $ip;
  112. $log->request_time = date('Y-m-d H:i:s');
  113. $log->request_header = $headers;
  114. $log->save();
  115. }
  116. }