SubscribeController.php 4.8 KB

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