mirror of
https://github.com/ProxyPanel/ProxyPanel.git
synced 2026-04-06 20:50:01 +00:00
66b0f7a561
1. 修复节点信息获取错误的问题 2. 优化首页公告显示 3. 修复回复工单时按回车导致报错的问题 4. 修改用户编辑与添加排版 5. 修复潜在的IE兼容问题 6. 统一Table元素格式 7. 优化返利界面 8. 添加了封禁时间倒计时 9. 对非付费用户，首页添加提示购买宣传语
286 lines
8.7 KiB
PHP
286 lines
8.7 KiB
PHP
<?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']);
|
||
|
||
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 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);
|
||
$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";
|
||
}
|
||
}
|