SubscribeController.php 5.3 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158
  1. <?php
  2. namespace App\Http\Controllers\User;
  3. use App\Components\IP;
  4. use App\Http\Controllers\Controller;
  5. use App\Models\UserSubscribe;
  6. use App\Models\UserSubscribeLog;
  7. use Arr;
  8. use Illuminate\Http\Request;
  9. use Redirect;
  10. use Response;
  11. class SubscribeController extends Controller
  12. {
  13. private $subType;
  14. // 通过订阅码获取订阅信息
  15. public function getSubscribeByCode(Request $request, $code)
  16. {
  17. if (empty($code)) {
  18. return Redirect::route('login');
  19. }
  20. $this->subType = $request->input('type');
  21. // 检查订阅码是否有效
  22. $subscribe = UserSubscribe::whereCode($code)->first();
  23. if (! $subscribe) {
  24. return $this->failed('使用链接错误!请重新获取!');
  25. }
  26. if ($subscribe->status !== 1) {
  27. return $this->failed('链接已被封禁,请前往官网查询原因!');
  28. }
  29. // 检查用户是否有效
  30. $user = $subscribe->user;
  31. if (! $user) {
  32. return $this->failed('错误链接,账号不存在!请重新获取链接');
  33. }
  34. if ($user->status === -1) {
  35. return $this->failed('账号被禁用!');
  36. }
  37. if ($user->enable !== 1) {
  38. if ($user->ban_time) {
  39. return $this->failed('账号封禁至'.$user->ban_time.',请解封后再更新!');
  40. }
  41. $unusedTraffic = $user->transfer_enable - $user->usedTraffic();
  42. if ($unusedTraffic <= 0) {
  43. return $this->failed('流量耗尽!请重新购买或重置流量!');
  44. }
  45. if ($user->expired_at < date('Y-m-d')) {
  46. return $this->failed('账号过期!请续费!');
  47. }
  48. return $this->failed('账号存在问题,请前往官网查询!');
  49. }
  50. // 更新访问次数
  51. $subscribe->increment('times', 1);
  52. // 记录每次请求
  53. $this->subscribeLog($subscribe->id, IP::getClientIp(), $request->headers);
  54. // 获取这个账号可用节点
  55. $query = $user->whereIsSubscribe(1)->userAccessNodes();
  56. if ($this->subType === 1) {
  57. $query = $query->whereIn('type', [1, 4]);
  58. } elseif ($this->subType) {
  59. $query = $query->whereType($this->subType);
  60. }
  61. $nodeList = $query->orderByDesc('sort')->orderBy('id')->get()->toArray();
  62. if (empty($nodeList)) {
  63. return $this->failed('无可用节点');
  64. }
  65. // 打乱数组
  66. if (sysConfig('rand_subscribe')) {
  67. $nodeList = Arr::shuffle($nodeList);
  68. }
  69. $scheme = null;
  70. // 展示到期时间和剩余流量
  71. if (sysConfig('is_custom_subscribe')) {
  72. $scheme .= $this->infoGenerator('到期时间: '.$user->expired_at).$this->infoGenerator('剩余流量: '.flowAutoShow($user->transfer_enable - $user->usedTraffic()));
  73. }
  74. // 控制客户端最多获取节点数
  75. foreach ($nodeList as $key => $node) {
  76. // 控制显示的节点数
  77. if (sysConfig('subscribe_max') && $key >= sysConfig('subscribe_max')) {
  78. break;
  79. }
  80. $scheme .= $this->getUserNodeInfo($user->id, $node['id'], 0).PHP_EOL;
  81. }
  82. $headers = [
  83. 'Content-type' => 'application/octet-stream; charset=utf-8',
  84. 'Cache-Control' => 'no-store, no-cache, must-revalidate',
  85. //'Content-Disposition' => 'attachment; filename='.$filename
  86. ];
  87. // 适配Quantumult的自定义订阅头
  88. if (sysConfig('is_custom_subscribe')) {
  89. $headers['Subscription-Userinfo'] = 'upload='.$user->u.'; download='.$user->d.'; total='.$user->transfer_enable.'; expire='.strtotime($user->expired_at);
  90. }
  91. return Response::make(base64url_encode($scheme), 200, $headers);
  92. }
  93. // 抛出错误的节点信息,用于兼容防止客户端订阅失败
  94. private function failed($text)
  95. {
  96. return Response::make(base64url_encode($this->infoGenerator($text)), 200);
  97. }
  98. private function infoGenerator($text): string
  99. {
  100. $result = null;
  101. switch ($this->subType) {
  102. case 2:
  103. $result = 'vmess://'.base64url_encode(json_encode([
  104. 'v' => '2', 'ps' => $text, 'add' => '0.0.0.0', 'port' => 0, 'id' => 0, 'aid' => 0, 'net' => 'tcp',
  105. 'type' => 'none', 'host' => '', 'path' => '/', 'tls' => 'tls',
  106. ], JSON_PRETTY_PRINT));
  107. break;
  108. case 3:
  109. $result = 'trojan://0@0.0.0.0:0?peer=0.0.0.0#'.rawurlencode($text);
  110. break;
  111. case 1:
  112. case 4:
  113. default:
  114. $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');
  115. break;
  116. }
  117. return $result.PHP_EOL;
  118. }
  119. // 写入订阅访问日志
  120. private function subscribeLog($subscribeId, $ip, $headers): void
  121. {
  122. $log = new UserSubscribeLog();
  123. $log->user_subscribe_id = $subscribeId;
  124. $log->request_ip = $ip;
  125. $log->request_time = date('Y-m-d H:i:s');
  126. $log->request_header = $headers;
  127. $log->save();
  128. }
  129. }