123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304 |
- <?php
- namespace App\Http\Controllers;
- use App\Components\Helpers;
- use App\Http\Models\Device;
- use App\Http\Models\SsGroup;
- use App\Http\Models\SsNode;
- use App\Http\Models\User;
- use App\Http\Models\UserLabel;
- use App\Http\Models\UserSubscribe;
- use App\Http\Models\UserSubscribeLog;
- use Illuminate\Http\Request;
- use Redirect;
- use Response;
- /**
- * 订阅控制器
- *
- * Class SubscribeController
- *
- * @package App\Http\Controllers
- */
- class SubscribeController extends Controller
- {
- protected static $systemConfig;
- function __construct()
- {
- self::$systemConfig = Helpers::systemConfig();
- }
- // 订阅码列表
- public function subscribeList(Request $request)
- {
- $user_id = $request->input('user_id');
- $username = $request->input('username');
- $status = $request->input('status');
- $query = UserSubscribe::with(['user:id,username']);
- if(isset($user_id)){
- $query->where('user_id', $user_id);
- }
- if(isset($username)){
- $query->whereHas('user', function($q) use ($username){
- $q->where('username', 'like', '%'.$username.'%');
- });
- }
- if(isset($status)){
- $query->where('status', $status);
- }
- $view['subscribeList'] = $query->orderBy('id', 'desc')->paginate(20)->appends($request->except('page'));
- return Response::view('subscribe.subscribeList', $view);
- }
- //订阅记录
- public function subscribeLog(Request $request)
- {
- $id = $request->input('id');
- $query = UserSubscribeLog::with('user:username');
- if(isset($id)){
- $query->where('sid', $id);
- }
- $view['subscribeLog'] = $query->orderBy('id', 'desc')->paginate(20)->appends($request->except('page'));
- return Response::view('subscribe.subscribeLog', $view);
- }
- // 订阅设备列表
- public function deviceList(Request $request)
- {
- $type = $request->input('type');
- $platform = $request->input('platform');
- $name = $request->input('name');
- $status = $request->input('status');
- $query = Device::query();
- if(isset($type)){
- $query->where('type', $type);
- }
- if(isset($platform)){
- $query->where('platform', $platform);
- }
- if(isset($name)){
- $query->where('name', 'like', '%'.$name.'%');
- }
- if(isset($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->input('id');
- $status = $request->input('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)
- {
- if(empty($code)){
- return Redirect::to('login');
- }
- // 校验合法性
- $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).$this->lastTraffic($user);
- }
- // 控制客户端最多获取节点数
- foreach($nodeList as $key => $node){
- // 控制显示的节点数
- if(self::$systemConfig['subscribe_max'] && $key >= self::$systemConfig['subscribe_max']){
- break;
- }
- // 获取分组名称
- $host = $node['server']? : $node['ip'];
- if($node['type'] == 1){
- $group = SsGroup::query()->where('id', $node['group_id'])->first();
- $group = empty($group)? Helpers::systemConfig()['website_name'] : $group->name;
- $obfs_param = $user->obfs_param? : $node['obfs_param'];
- if($node['single']){
- $port = $node['port'];
- $protocol = $node['protocol'];
- $method = $node['method'];
- $obfs = $node['obfs'];
- $passwd = $node['passwd'];
- $protocol_param = $user->port.':'.$user->passwd;
- }else{
- $port = $user->port;
- $protocol = $user->protocol;
- $method = $user->method;
- $obfs = $user->obfs;
- $passwd = $user->passwd;
- $protocol_param = $user->protocol_param;
- }
- // 生成ssr scheme
- $scheme .= 'ssr://'.base64url_encode($host.':'.$port.':'.$protocol.':'.$method.':'.$obfs.':'.base64url_encode($passwd).'/?obfsparam='.base64url_encode($obfs_param).'&protoparam='.base64url_encode($protocol_param).'&remarks='.base64url_encode($node['name']).'&group='.base64url_encode($group).'&udpport=0&uot=0')."\n";
- }else{
- // 生成v2ray scheme
- $v2_json = [
- "v" => "2",
- "ps" => $node['name'],
- "add" => $host,
- "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";
- }
- }
|