SubscribeController.php 13 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381
  1. <?php
  2. namespace App\Http\Controllers\User;
  3. use App\Components\Client\Clash;
  4. use App\Components\Client\QuantumultX;
  5. use App\Components\Client\Shadowrocket;
  6. use App\Components\Client\Surfboard;
  7. use App\Components\Client\Surge;
  8. use App\Components\Client\URLSchemes;
  9. use App\Components\IP;
  10. use App\Http\Controllers\Controller;
  11. use App\Models\User;
  12. use App\Models\UserSubscribe;
  13. use App\Models\UserSubscribeLog;
  14. use Arr;
  15. use File;
  16. use Illuminate\Http\Request;
  17. use Redirect;
  18. use Response;
  19. use Symfony\Component\Yaml\Yaml;
  20. class SubscribeController extends Controller
  21. {
  22. private $subType;
  23. // 通过订阅码获取订阅信息
  24. public function getSubscribeByCode(Request $request, string $code)
  25. {
  26. if (empty($code)) {
  27. return Redirect::route('login');
  28. }
  29. $this->subType = $request->input('type');
  30. $target = strtolower($request->input('target') ?? (isset($_SERVER['HTTP_USER_AGENT']) ? $_SERVER['HTTP_USER_AGENT'] : ''));
  31. // 检查订阅码是否有效
  32. $subscribe = UserSubscribe::whereCode($code)->first();
  33. if (! $subscribe) {
  34. return $this->failed('使用链接错误!请重新获取!');
  35. }
  36. if ($subscribe->status !== 1) {
  37. return $this->failed('链接已被封禁,请前往官网查询原因!');
  38. }
  39. // 检查用户是否有效
  40. $user = $subscribe->user;
  41. if (! $user) {
  42. return $this->failed('错误链接,账号不存在!请重新获取链接');
  43. }
  44. if ($user->status === -1) {
  45. return $this->failed('账号被禁用!');
  46. }
  47. if ($user->enable !== 1) {
  48. if ($user->ban_time) {
  49. return $this->failed('账号封禁至'.$user->ban_time.',请解封后再更新!');
  50. }
  51. $unusedTraffic = $user->transfer_enable - $user->usedTraffic();
  52. if ($unusedTraffic <= 0) {
  53. return $this->failed('流量耗尽!请重新购买或重置流量!');
  54. }
  55. if ($user->expired_at < date('Y-m-d')) {
  56. return $this->failed('账号过期!请续费!');
  57. }
  58. return $this->failed('账号存在问题,请前往官网查询!');
  59. }
  60. // 更新访问次数
  61. $subscribe->increment('times', 1);
  62. // 记录每次请求
  63. $this->subscribeLog($subscribe->id, IP::getClientIp(), $request->headers);
  64. // 获取这个账号可用节点
  65. $query = $user->whereIsSubscribe(1)->nodes();
  66. if ($this->subType === 1) {
  67. $query = $query->whereIn('type', [1, 4]);
  68. } elseif ($this->subType) {
  69. $query = $query->whereType($this->subType);
  70. }
  71. $nodeList = $query->orderByDesc('sort')->orderBy('id')->get();
  72. if (empty($nodeList)) {
  73. return $this->failed('无可用节点');
  74. }
  75. $servers = [];
  76. foreach ($nodeList as $node) {
  77. $servers[] = $node->config($user);
  78. }
  79. // 打乱数组
  80. if (sysConfig('rand_subscribe')) {
  81. $servers = Arr::shuffle($servers);
  82. }
  83. if (sysConfig('subscribe_max')) {
  84. $servers = array_slice($servers, 0, (int) sysConfig('subscribe_max'));
  85. }
  86. if ($target) {
  87. if (strpos($target, 'quantumult%20x') !== false) {
  88. exit($this->quantumultX($user, $servers));
  89. }
  90. if (strpos($target, 'quantumult') !== false) {
  91. exit($this->quantumult($user, $servers));
  92. }
  93. if (strpos($target, 'clash') !== false) {
  94. exit($this->clash($servers));
  95. }
  96. if (strpos($target, 'surfboard') !== false) {
  97. exit($this->surfboard($user, $servers));
  98. }
  99. if (strpos($target, 'surge') !== false) {
  100. exit($this->surge($user, $servers));
  101. }
  102. if (strpos($target, 'shadowrocket') !== false) {
  103. exit($this->shadowrocket($user, $servers));
  104. }
  105. // if (strpos($target, 'shadowsocks') !== false) {
  106. // exit($this->shaodowsocksSIP008($servers));
  107. // }
  108. }
  109. exit($this->origin($servers));
  110. }
  111. // TODO 通过Token获取订阅信息
  112. // 抛出错误的节点信息,用于兼容防止客户端订阅失败
  113. private function failed($text)
  114. {
  115. return Response::make(base64url_encode($this->infoGenerator($text)), 200);
  116. }
  117. private function infoGenerator($text): string
  118. {
  119. $result = null;
  120. switch ($this->subType) {
  121. case 2:
  122. $result = 'vmess://'.base64url_encode(json_encode([
  123. 'v' => '2', 'ps' => $text, 'add' => '0.0.0.0', 'port' => 0, 'id' => 0, 'aid' => 0, 'net' => 'tcp',
  124. 'type' => 'none', 'host' => '', 'path' => '/', 'tls' => 'tls',
  125. ], JSON_PRETTY_PRINT));
  126. break;
  127. case 3:
  128. $result = 'trojan://0@0.0.0.0:0?peer=0.0.0.0#'.rawurlencode($text);
  129. break;
  130. case 1:
  131. case 4:
  132. default:
  133. $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');
  134. break;
  135. }
  136. return $result.PHP_EOL;
  137. }
  138. // 写入订阅访问日志
  139. private function subscribeLog($subscribeId, $ip, $headers): void
  140. {
  141. $log = new UserSubscribeLog();
  142. $log->user_subscribe_id = $subscribeId;
  143. $log->request_ip = $ip;
  144. $log->request_time = date('Y-m-d H:i:s');
  145. $log->request_header = $headers;
  146. $log->save();
  147. }
  148. private function quantumultX(User $user, array $servers = []): string
  149. {
  150. $uri = '';
  151. header("subscription-userinfo: upload={$user->u}; download={$user->d}; total={$user->transfer_enable}; expire={$user->expired_at}");
  152. foreach ($servers as $server) {
  153. if ($server['type'] === 'shadowsocks') {
  154. $uri .= QuantumultX::buildShadowsocks($server);
  155. }
  156. if ($server['type'] === 'shadowsocksr') {
  157. $uri .= QuantumultX::buildShadowsocksr($server);
  158. }
  159. if ($server['type'] === 'v2ray') {
  160. $uri .= QuantumultX::buildVmess($server);
  161. }
  162. if ($server['type'] === 'trojan') {
  163. $uri .= QuantumultX::buildTrojan($server);
  164. }
  165. }
  166. return base64_encode($uri);
  167. }
  168. private function quantumult(User $user, array $servers = []): string
  169. {
  170. header('subscription-userinfo: upload='.$user->u.'; download='.$user->d.';total='.$user->transfer_enable.'; expire='.strtotime($user->expired_at));
  171. return $this->origin($servers);
  172. }
  173. private function origin(array $servers = [], bool $encode = true): string
  174. {
  175. $uri = '';
  176. foreach ($servers as $server) {
  177. if ($server['type'] === 'shadowsocks') {
  178. $uri .= URLSchemes::buildShadowsocks($server);
  179. }
  180. if ($server['type'] === 'shadowsocksr') {
  181. $uri .= URLSchemes::buildShadowsocksr($server);
  182. }
  183. if ($server['type'] === 'v2ray') {
  184. $uri .= URLSchemes::buildVmess($server);
  185. }
  186. if ($server['type'] === 'trojan') {
  187. $uri .= URLSchemes::buildTrojan($server);
  188. }
  189. }
  190. return $encode ? base64_encode($uri) : $uri;
  191. }
  192. private function clash($servers)
  193. {
  194. $defaultConfig = base_path().'/resources/rules/default.clash.yaml';
  195. $customConfig = base_path().'/resources/rules/custom.clash.yaml';
  196. if (File::exists($customConfig)) {
  197. $config = Yaml::parseFile($customConfig);
  198. } else {
  199. $config = Yaml::parseFile($defaultConfig);
  200. }
  201. $proxy = [];
  202. $proxies = [];
  203. foreach ($servers as $server) {
  204. if ($server['type'] === 'shadowsocks') {
  205. $proxy[] = Clash::buildShadowsocks($server);
  206. $proxies[] = $server['name'];
  207. }
  208. if ($server['type'] === 'shadowsocksr') {
  209. $proxy[] = Clash::buildShadowsocksr($server);
  210. $proxies[] = $server['name'];
  211. }
  212. if ($server['type'] === 'v2ray') {
  213. $proxy[] = Clash::buildVmess($server);
  214. $proxies[] = $server['name'];
  215. }
  216. if ($server['type'] === 'trojan') {
  217. $proxy[] = Clash::buildTrojan($server);
  218. $proxies[] = $server['name'];
  219. }
  220. }
  221. $config['proxies'] = array_merge($config['proxies'] ?: [], $proxy);
  222. foreach ($config['proxy-groups'] as $k => $v) {
  223. if (! is_array($config['proxy-groups'][$k]['proxies'])) {
  224. continue;
  225. }
  226. $config['proxy-groups'][$k]['proxies'] = array_merge($config['proxy-groups'][$k]['proxies'], $proxies);
  227. }
  228. $yaml = Yaml::dump($config);
  229. $yaml = str_replace('$app_name', sysConfig('website_name'), $yaml);
  230. return $yaml;
  231. }
  232. private function surfboard(User $user, array $servers = [])
  233. {
  234. $proxies = '';
  235. $proxyGroup = '';
  236. foreach ($servers as $server) {
  237. if ($server['type'] === 'shadowsocks') {
  238. // [Proxy]
  239. $proxies .= Surfboard::buildShadowsocks($server);
  240. // [Proxy Group]
  241. $proxyGroup .= $server['name'].', ';
  242. }
  243. if ($server['type'] === 'v2ray') {
  244. // [Proxy]
  245. $proxies .= Surfboard::buildVmess($server);
  246. // [Proxy Group]
  247. $proxyGroup .= $server['name'].', ';
  248. }
  249. }
  250. $defaultConfig = base_path().'/resources/rules/default.surfboard.conf';
  251. $customConfig = base_path().'/resources/rules/custom.surfboard.conf';
  252. if (File::exists($customConfig)) {
  253. $config = file_get_contents("$customConfig");
  254. } else {
  255. $config = file_get_contents("$defaultConfig");
  256. }
  257. // Subscription link
  258. $subsURL = route('sub', $user->subscribe->code);
  259. $config = str_replace('$subs_link', $subsURL, $config);
  260. $config = str_replace('$proxies', $proxies, $config);
  261. $config = str_replace('$proxy_group', rtrim($proxyGroup, ', '), $config);
  262. return $config;
  263. }
  264. private function surge(User $user, array $servers = [])
  265. {
  266. $proxies = '';
  267. $proxyGroup = '';
  268. foreach ($servers as $server) {
  269. if ($server['type'] === 'shadowsocks') {
  270. // [Proxy]
  271. $proxies .= Surge::buildShadowsocks($server);
  272. // [Proxy Group]
  273. $proxyGroup .= $server['name'].', ';
  274. }
  275. if ($server['type'] === 'v2ray') {
  276. // [Proxy]
  277. $proxies .= Surge::buildVmess($server);
  278. // [Proxy Group]
  279. $proxyGroup .= $server['name'].', ';
  280. }
  281. if ($server['type'] === 'trojan') {
  282. // [Proxy]
  283. $proxies .= Surge::buildTrojan($server);
  284. // [Proxy Group]
  285. $proxyGroup .= $server['name'].', ';
  286. }
  287. }
  288. $defaultConfig = base_path().'/resources/rules/default.surge.conf';
  289. $customConfig = base_path().'/resources/rules/custom.surge.conf';
  290. if (File::exists($customConfig)) {
  291. $config = file_get_contents("$customConfig");
  292. } else {
  293. $config = file_get_contents("$defaultConfig");
  294. }
  295. // Subscription link
  296. $subsURL = route('sub', $user->subscribe->code);
  297. $config = str_replace('$subs_link', $subsURL, $config);
  298. $config = str_replace('$proxies', $proxies, $config);
  299. $config = str_replace('$proxy_group', rtrim($proxyGroup, ', '), $config);
  300. return $config;
  301. }
  302. private function shadowrocket(User $user, array $servers = []): string
  303. {
  304. //display remaining traffic and expire date
  305. $upload = flowAutoShow($user->u);
  306. $download = flowAutoShow($user->d);
  307. $totalTraffic = flowAutoShow($user->transfer_enable);
  308. $uri = "STATUS=🚀↑:{$upload},↓:{$download},TOT:{$totalTraffic}💡Expires:{$user->expired_at}\r\n";
  309. $uri .= $this->origin($servers, false);
  310. return base64_encode($uri);
  311. }
  312. private function shaodowsocksSIP008(array $servers = []): string
  313. {
  314. $configs = [];
  315. $subs = [];
  316. $subs['servers'] = [];
  317. foreach ($servers as $server) {
  318. if ($server['type'] === 'shadowsocks') {
  319. $configs[] = URLSchemes::buildShadowsocksSIP008($server);
  320. }
  321. }
  322. $subs['version'] = 1;
  323. $subs['remark'] = sysConfig('website_name');
  324. $subs['servers'] = array_merge($subs['servers'] ?: [], $configs);
  325. return json_encode($subs, JSON_UNESCAPED_SLASHES | JSON_PRETTY_PRINT);
  326. }
  327. }