input('user_id'); $username = $request->input('username'); $status = $request->input('status'); $query = UserSubscribe::with(['User']); if (!empty($user_id)) { $query->where('user_id', $user_id); } if (!empty($username)) { $query->whereHas('user', function ($q) use ($username) { $q->where('username', 'like', '%' . $username . '%'); }); } if ($status != '') { $query->where('status', intval($status)); } $view['subscribeList'] = $query->orderBy('id', 'desc')->paginate(20)->appends($request->except('page')); return Response::view('subscribe.subscribeList', $view); } // 订阅设备列表 public function deviceList(Request $request) { $type = $request->input('type'); $platform = $request->input('platform'); $name = trim($request->input('name')); $status = $request->input('status'); $query = Device::query(); if (!empty($type)) { $query->where('type', $type); } if ($platform != '') { $query->where('platform', $platform); } if (!empty($name)) { $query->where('name', 'like', '%' . $name . '%'); } if ($status != '') { $query->where('status', $status); } $view['deviceList'] = $query->paginate(20)->appends($request->except('page')); return Response::view('subscribe.deviceList', $view); } // 设置用户的订阅的状态 public function setSubscribeStatus(Request $request) { $id = $request->get('id'); $status = $request->get('status', 0); if (empty($id)) { return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作异常']); } if ($status) { UserSubscribe::query()->where('id', $id)->update(['status' => 1, 'ban_time' => 0, 'ban_desc' => '']); } else { UserSubscribe::query()->where('id', $id)->update(['status' => 0, 'ban_time' => time(), 'ban_desc' => '后台手动封禁']); } return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']); } // 设置设备是否允许订阅的状态 public function setDeviceStatus(Request $request) { $id = $request->input('id'); $status = $request->input('status', 0); if (empty($id)) { return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作异常']); } Device::query()->where('id', $id)->update(['status' => $status]); return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']); } // 通过订阅码获取订阅信息 public function getSubscribeByCode(Request $request, $code) { // 校验合法性 $subscribe = UserSubscribe::query()->with('user')->where('status', 1)->where('code', $code)->first(); if (!$subscribe) { exit($this->noneNode()); } $user = User::query()->whereIn('status', [0, 1])->where('enable', 1)->where('id', $subscribe->user_id)->first(); if (!$user) { exit($this->noneNode()); } // 更新访问次数 $subscribe->increment('times', 1); // 记录每次请求 $this->log($subscribe->id, getClientIp(), $request->headers); // 获取这个账号可用节点 $userLabelIds = UserLabel::query()->where('user_id', $user->id)->pluck('label_id'); if (empty($userLabelIds)) { exit($this->noneNode()); } $query = SsNode::query()->selectRaw('ss_node.*')->leftjoin("ss_node_label", "ss_node.id", "=", "ss_node_label.node_id"); // 启用混合订阅时,加入V2Ray节点,未启用时仅下发SSR节点信息 if (!self::$systemConfig['mix_subscribe']) { $query->where('ss_node.type', 1); } $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(); if (empty($nodeList)) { exit($this->noneNode()); } // 打乱数组 if (self::$systemConfig['rand_subscribe']) { shuffle($nodeList); } // 控制客户端最多获取节点数 $scheme = ''; // 展示到期时间和剩余流量 if (self::$systemConfig['is_custom_subscribe']) { $scheme .= $this->expireDate($user); $scheme .= $this->lastTraffic($user); } foreach ($nodeList as $key => $node) { // 控制显示的节点数 if (self::$systemConfig['subscribe_max'] && $key >= self::$systemConfig['subscribe_max']) { break; } // 获取分组名称 if ($node['type'] == 1) { $group = SsGroup::query()->where('id', $node['group_id'])->first(); $obfs_param = $user->obfs_param ? $user->obfs_param : $node['obfs_param']; $protocol_param = $node['single'] ? $user->port . ':' . $user->passwd : $user->protocol_param; // 生成ssr scheme $ssr_str = ($node['server'] ? $node['server'] : $node['ip']) . ':' . ($node['single'] ? $node['single_port'] : $user->port); $ssr_str .= ':' . ($node['single'] ? $node['single_protocol'] : $user->protocol) . ':' . ($node['single'] ? $node['single_method'] : $user->method); $ssr_str .= ':' . ($node['single'] ? $node['single_obfs'] : $user->obfs) . ':' . ($node['single'] ? base64url_encode($node['single_passwd']) : base64url_encode($user->passwd)); $ssr_str .= '/?obfsparam=' . base64url_encode($obfs_param); $ssr_str .= '&protoparam=' . ($node['single'] ? base64url_encode($user->port . ':' . $user->passwd) : base64url_encode($protocol_param)); $ssr_str .= '&remarks=' . base64url_encode($node['name']); $ssr_str .= '&group=' . base64url_encode(empty($group) ? Helpers::systemConfig()['website_name'] : $group->name); $ssr_str .= '&udpport=0'; $ssr_str .= '&uot=0'; $ssr_str = base64url_encode($ssr_str); $scheme .= 'ssr://' . $ssr_str . "\n"; } else { // 生成v2ray scheme $v2_json = [ "v" => "2", "ps" => $node['name'], "add" => $node['server'] ? $node['server'] : $node['ip'], "port" => $node['v2_port'], "id" => $user->vmess_id, "aid" => $node['v2_alter_id'], "net" => $node['v2_net'], "type" => $node['v2_type'], "host" => $node['v2_host'], "path" => $node['v2_path'], "tls" => $node['v2_tls'] ? "tls" : "" ]; $scheme .= 'vmess://' . base64url_encode(json_encode($v2_json, JSON_PRETTY_PRINT)) . "\n"; } } // 适配Quantumult的自定义订阅头 if (self::$systemConfig['is_custom_subscribe']) { $headers = [ 'Content-type' => 'application/octet-stream; charset=utf-8', 'Cache-Control' => 'no-store, no-cache, must-revalidate', 'Subscription-Userinfo' => 'upload=' . $user->u . '; download=' . $user->d . '; total=' . $user->transfer_enable . '; expire=' . strtotime($user->expire_time) ]; return Response::make(base64url_encode($scheme), 200, $headers); } else { return Response::make(base64url_encode($scheme)); } } // 写入订阅访问日志 private function log($subscribeId, $ip, $headers) { $log = new UserSubscribeLog(); $log->sid = $subscribeId; $log->request_ip = $ip; $log->request_time = date('Y-m-d H:i:s'); $log->request_header = $headers; $log->save(); } // 抛出无可用的节点信息,用于兼容防止客户端订阅失败 private function noneNode() { 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"); } /** * 过期时间 * * @param object $user * * @return string */ private function expireDate($user) { $text = '到期时间:' . $user->expire_time; 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"; } /** * 剩余流量 * * @param object $user * * @return string */ private function lastTraffic($user) { $text = '剩余流量:' . flowAutoShow($user->transfer_enable - $user->u - $user->d); 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"; } }