SubscribeController.php 10 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Helpers;
  4. use App\Http\Models\Device;
  5. use App\Http\Models\SsGroup;
  6. use App\Http\Models\SsNode;
  7. use App\Http\Models\User;
  8. use App\Http\Models\UserLabel;
  9. use App\Http\Models\UserSubscribe;
  10. use App\Http\Models\UserSubscribeLog;
  11. use Illuminate\Http\Request;
  12. use Redirect;
  13. use Response;
  14. /**
  15. * 订阅控制器
  16. *
  17. * Class SubscribeController
  18. *
  19. * @package App\Http\Controllers
  20. */
  21. class SubscribeController extends Controller
  22. {
  23. protected static $systemConfig;
  24. function __construct()
  25. {
  26. self::$systemConfig = Helpers::systemConfig();
  27. }
  28. // 订阅码列表
  29. public function subscribeList(Request $request)
  30. {
  31. $user_id = $request->input('user_id');
  32. $username = $request->input('username');
  33. $status = $request->input('status');
  34. $query = UserSubscribe::with(['User']);
  35. if (!empty($user_id)) {
  36. $query->where('user_id', $user_id);
  37. }
  38. if (!empty($username)) {
  39. $query->whereHas('user', function ($q) use ($username) {
  40. $q->where('username', 'like', '%' . $username . '%');
  41. });
  42. }
  43. if ($status != '') {
  44. $query->where('status', intval($status));
  45. }
  46. $view['subscribeList'] = $query->orderBy('id', 'desc')->paginate(20)->appends($request->except('page'));
  47. return Response::view('subscribe.subscribeList', $view);
  48. }
  49. // 订阅设备列表
  50. public function deviceList(Request $request)
  51. {
  52. $type = $request->input('type');
  53. $platform = $request->input('platform');
  54. $name = trim($request->input('name'));
  55. $status = $request->input('status');
  56. $query = Device::query();
  57. if (!empty($type)) {
  58. $query->where('type', $type);
  59. }
  60. if ($platform != '') {
  61. $query->where('platform', $platform);
  62. }
  63. if (!empty($name)) {
  64. $query->where('name', 'like', '%' . $name . '%');
  65. }
  66. if ($status != '') {
  67. $query->where('status', $status);
  68. }
  69. $view['deviceList'] = $query->paginate(20)->appends($request->except('page'));
  70. return Response::view('subscribe.deviceList', $view);
  71. }
  72. // 设置用户的订阅的状态
  73. public function setSubscribeStatus(Request $request)
  74. {
  75. $id = $request->get('id');
  76. $status = $request->get('status', 0);
  77. if (empty($id)) {
  78. return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作异常']);
  79. }
  80. if ($status) {
  81. UserSubscribe::query()->where('id', $id)->update(['status' => 1, 'ban_time' => 0, 'ban_desc' => '']);
  82. } else {
  83. UserSubscribe::query()->where('id', $id)->update(['status' => 0, 'ban_time' => time(), 'ban_desc' => '后台手动封禁']);
  84. }
  85. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  86. }
  87. // 设置设备是否允许订阅的状态
  88. public function setDeviceStatus(Request $request)
  89. {
  90. $id = $request->input('id');
  91. $status = $request->input('status', 0);
  92. if (empty($id)) {
  93. return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作异常']);
  94. }
  95. Device::query()->where('id', $id)->update(['status' => $status]);
  96. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  97. }
  98. // 通过订阅码获取订阅信息
  99. public function getSubscribeByCode(Request $request, $code)
  100. {
  101. // 校验合法性
  102. $subscribe = UserSubscribe::query()->with('user')->where('status', 1)->where('code', $code)->first();
  103. if (!$subscribe) {
  104. exit($this->noneNode());
  105. }
  106. $user = User::query()->whereIn('status', [0, 1])->where('enable', 1)->where('id', $subscribe->user_id)->first();
  107. if (!$user) {
  108. exit($this->noneNode());
  109. }
  110. // 更新访问次数
  111. $subscribe->increment('times', 1);
  112. // 记录每次请求
  113. $this->log($subscribe->id, getClientIp(), $request->headers);
  114. // 获取这个账号可用节点
  115. $userLabelIds = UserLabel::query()->where('user_id', $user->id)->pluck('label_id');
  116. if (empty($userLabelIds)) {
  117. exit($this->noneNode());
  118. }
  119. $query = SsNode::query()->selectRaw('ss_node.*')->leftjoin("ss_node_label", "ss_node.id", "=", "ss_node_label.node_id");
  120. // 启用混合订阅时,加入V2Ray节点,未启用时仅下发SSR节点信息
  121. if (!self::$systemConfig['mix_subscribe']) {
  122. $query->where('ss_node.type', 1);
  123. }
  124. $nodeList = $query->where('ss_node.status', 1)->where('ss_node.is_subscribe', 1)->whereIn('ss_node_label.label_id', $userLabelIds)->groupBy('ss_node.id')->orderBy('ss_node.sort', 'desc')->orderBy('ss_node.id', 'asc')->get()->toArray();
  125. if (empty($nodeList)) {
  126. exit($this->noneNode());
  127. }
  128. // 打乱数组
  129. if (self::$systemConfig['rand_subscribe']) {
  130. shuffle($nodeList);
  131. }
  132. // 控制客户端最多获取节点数
  133. $scheme = '';
  134. // 展示到期时间和剩余流量
  135. if (self::$systemConfig['is_custom_subscribe']) {
  136. $scheme .= $this->expireDate($user);
  137. $scheme .= $this->lastTraffic($user);
  138. }
  139. foreach ($nodeList as $key => $node) {
  140. // 控制显示的节点数
  141. if (self::$systemConfig['subscribe_max'] && $key >= self::$systemConfig['subscribe_max']) {
  142. break;
  143. }
  144. // 获取分组名称
  145. if ($node['type'] == 1) {
  146. $group = SsGroup::query()->where('id', $node['group_id'])->first();
  147. $obfs_param = $user->obfs_param ? $user->obfs_param : $node['obfs_param'];
  148. $protocol_param = $node['single'] ? $user->port . ':' . $user->passwd : $user->protocol_param;
  149. // 生成ssr scheme
  150. $ssr_str = ($node['server'] ? $node['server'] : $node['ip']) . ':' . ($node['single'] ? $node['single_port'] : $user->port);
  151. $ssr_str .= ':' . ($node['single'] ? $node['single_protocol'] : $user->protocol) . ':' . ($node['single'] ? $node['single_method'] : $user->method);
  152. $ssr_str .= ':' . ($node['single'] ? $node['single_obfs'] : $user->obfs) . ':' . ($node['single'] ? base64url_encode($node['single_passwd']) : base64url_encode($user->passwd));
  153. $ssr_str .= '/?obfsparam=' . base64url_encode($obfs_param);
  154. $ssr_str .= '&protoparam=' . ($node['single'] ? base64url_encode($user->port . ':' . $user->passwd) : base64url_encode($protocol_param));
  155. $ssr_str .= '&remarks=' . base64url_encode($node['name']);
  156. $ssr_str .= '&group=' . base64url_encode(empty($group) ? Helpers::systemConfig()['website_name'] : $group->name);
  157. $ssr_str .= '&udpport=0';
  158. $ssr_str .= '&uot=0';
  159. $ssr_str = base64url_encode($ssr_str);
  160. $scheme .= 'ssr://' . $ssr_str . "\n";
  161. } else {
  162. // 生成v2ray scheme
  163. $v2_json = [
  164. "v" => "2",
  165. "ps" => $node['name'],
  166. "add" => $node['server'] ? $node['server'] : $node['ip'],
  167. "port" => $node['v2_port'],
  168. "id" => $user->vmess_id,
  169. "aid" => $node['v2_alter_id'],
  170. "net" => $node['v2_net'],
  171. "type" => $node['v2_type'],
  172. "host" => $node['v2_host'],
  173. "path" => $node['v2_path'],
  174. "tls" => $node['v2_tls'] ? "tls" : ""
  175. ];
  176. $scheme .= 'vmess://' . base64url_encode(json_encode($v2_json, JSON_PRETTY_PRINT)) . "\n";
  177. }
  178. }
  179. // 适配Quantumult的自定义订阅头
  180. if (self::$systemConfig['is_custom_subscribe']) {
  181. $headers = [
  182. 'Content-type' => 'application/octet-stream; charset=utf-8',
  183. 'Cache-Control' => 'no-store, no-cache, must-revalidate',
  184. 'Subscription-Userinfo' => 'upload=' . $user->u . '; download=' . $user->d . '; total=' . $user->transfer_enable . '; expire=' . strtotime($user->expire_time)
  185. ];
  186. return Response::make(base64url_encode($scheme), 200, $headers);
  187. } else {
  188. return Response::make(base64url_encode($scheme));
  189. }
  190. }
  191. // 写入订阅访问日志
  192. private function log($subscribeId, $ip, $headers)
  193. {
  194. $log = new UserSubscribeLog();
  195. $log->sid = $subscribeId;
  196. $log->request_ip = $ip;
  197. $log->request_time = date('Y-m-d H:i:s');
  198. $log->request_header = $headers;
  199. $log->save();
  200. }
  201. // 抛出无可用的节点信息,用于兼容防止客户端订阅失败
  202. private function noneNode()
  203. {
  204. return base64url_encode('ssr://' . base64url_encode('0.0.0.0:1:origin:none:plain:' . base64url_encode('0000') . '/?obfsparam=&protoparam=&remarks=' . base64url_encode('无可用节点或账号被封禁或订阅被封禁') . '&group=' . base64url_encode('错误') . '&udpport=0&uot=0') . "\n");
  205. }
  206. /**
  207. * 过期时间
  208. *
  209. * @param object $user
  210. *
  211. * @return string
  212. */
  213. private function expireDate($user)
  214. {
  215. $text = '到期时间:' . $user->expire_time;
  216. return 'ssr://' . base64url_encode('0.0.0.1:1:origin:none:plain:' . base64url_encode('0000') . '/?obfsparam=&protoparam=&remarks=' . base64url_encode($text) . '&group=' . base64url_encode(Helpers::systemConfig()['website_name']) . '&udpport=0&uot=0') . "\n";
  217. }
  218. /**
  219. * 剩余流量
  220. *
  221. * @param object $user
  222. *
  223. * @return string
  224. */
  225. private function lastTraffic($user)
  226. {
  227. $text = '剩余流量:' . flowAutoShow($user->transfer_enable - $user->u - $user->d);
  228. return 'ssr://' . base64url_encode('0.0.0.2:1:origin:none:plain:' . base64url_encode('0000') . '/?obfsparam=&protoparam=&remarks=' . base64url_encode($text) . '&group=' . base64url_encode(Helpers::systemConfig()['website_name']) . '&udpport=0&uot=0') . "\n";
  229. }
  230. }