mirror of
https://github.com/ProxyPanel/ProxyPanel.git
synced 2026-04-05 12:08:58 +00:00
ce9618236f
1. 全面改写项目-管理面板的路由； 2. 拆分过于Contoller； 3. 优化了按钮过多的图表的显示； 4. 初步应用 Laravel的 表单验证功能； 5. 初步应用 Laravel的 component 功能 拆分/模块化前端代码； 6. 优化部分系统的判断逻辑； 7. 针对2.4.0以前的面板，追加辅助矫正数据库的sql文件；
296 lines
9.9 KiB
PHP
296 lines
9.9 KiB
PHP
<?php
|
||
|
||
namespace App\Http\Controllers\Admin;
|
||
|
||
use App\Components\NetworkDetection;
|
||
use App\Http\Controllers\Controller;
|
||
use App\Http\Requests\Admin\NodeRequest;
|
||
use App\Jobs\VNet\reloadNode;
|
||
use App\Models\Country;
|
||
use App\Models\Label;
|
||
use App\Models\Level;
|
||
use App\Models\Node;
|
||
use App\Models\NodeAuth;
|
||
use App\Models\NodeCertificate;
|
||
use App\Models\NodePing;
|
||
use App\Services\NodeService;
|
||
use Exception;
|
||
use Illuminate\Http\JsonResponse;
|
||
use Illuminate\Http\Request;
|
||
use Log;
|
||
use Redirect;
|
||
use Response;
|
||
use Session;
|
||
use Str;
|
||
|
||
class NodeController extends Controller
|
||
{
|
||
// 节点列表
|
||
public function index(Request $request)
|
||
{
|
||
$status = $request->input('status');
|
||
|
||
$query = Node::with(['onlineLogs', 'dailyDataFlows']);
|
||
|
||
if (isset($status)) {
|
||
$query->whereStatus($status);
|
||
}
|
||
|
||
$nodeList = $query->orderByDesc('sort')->orderBy('id')->paginate(15)->appends($request->except('page'));
|
||
foreach ($nodeList as $node) {
|
||
// 在线人数
|
||
$online_log = $node->onlineLogs()->where('log_time', '>=', strtotime("-5 minutes"))->latest('log_time')->first();
|
||
$node->online_users = $online_log->online_user ?? 0;
|
||
|
||
// 已产生流量
|
||
$node->transfer = flowAutoShow($node->dailyDataFlows()->sum('total'));
|
||
|
||
// 负载（10分钟以内）
|
||
$node_info = $node->heartBeats()->recently()->first();
|
||
$node->isOnline = empty($node_info) || empty($node_info->load) ? 0 : 1;
|
||
$node->load = $node->isOnline ? $node_info->load : '离线';
|
||
$node->uptime = empty($node_info) ? 0 : seconds2time($node_info->uptime);
|
||
}
|
||
|
||
$view['nodeList'] = $nodeList;
|
||
|
||
return view('admin.node.index', $view);
|
||
}
|
||
|
||
// 添加节点页面
|
||
public function create()
|
||
{
|
||
return view('admin.node.info', [
|
||
'countryList' => Country::orderBy('code')->get(),
|
||
'levelList' => Level::orderBy('level')->get(),
|
||
'labelList' => Label::orderByDesc('sort')->orderBy('id')->get(),
|
||
'dvList' => NodeCertificate::orderBy('id')->get(),
|
||
]);
|
||
}
|
||
|
||
// 添加节点
|
||
public function store(NodeRequest $request): JsonResponse
|
||
{
|
||
// TODO：判断是否已存在绑定了相同域名的节点，提示是否要强制替换，或者不提示之前强制将其他节点的绑定域名置为空，然后发起域名绑定请求，或者请求进入队列
|
||
try {
|
||
$node = Node::create($request->except('_token', 'labels'));
|
||
|
||
if ($node) {
|
||
// 生成节点标签
|
||
if ($request->exists('labels')) {
|
||
(new NodeService())->makeLabels($node->id, $request->input('labels'));
|
||
}
|
||
|
||
return Response::json(['status' => 'success', 'message' => '添加成功']);
|
||
}
|
||
} catch (Exception $e) {
|
||
Log::error('添加节点信息异常：'.$e->getMessage());
|
||
|
||
return Response::json(['status' => 'fail', 'message' => '添加线路失败：'.$e->getMessage()]);
|
||
}
|
||
|
||
return Response::json(['status' => 'fail', 'message' => '添加线路失败']);
|
||
}
|
||
|
||
// 编辑节点页面
|
||
public function edit($id)
|
||
{
|
||
return view('admin.node.info', [
|
||
'node' => Node::with('labels')->find($id),
|
||
'countryList' => Country::orderBy('code')->get(),
|
||
'levelList' => Level::orderBy('level')->get(),
|
||
'labelList' => Label::orderByDesc('sort')->orderBy('id')->get(),
|
||
'dvList' => NodeCertificate::orderBy('id')->get(),
|
||
]);
|
||
}
|
||
|
||
// 编辑节点
|
||
public function update(NodeRequest $request, $id): JsonResponse
|
||
{
|
||
$node = Node::find($id);
|
||
|
||
try {
|
||
// 生成节点标签
|
||
if ($request->exists('labels')) {
|
||
(new NodeService())->makeLabels($node->id, $request->input('labels'));
|
||
}
|
||
|
||
// TODO:更新节点绑定的域名DNS（将节点IP更新到域名DNS 的A记录）
|
||
if ($node->update($request->except('_token', 'labels'))) {
|
||
return Response::json(['status' => 'success', 'message' => '编辑成功']);
|
||
}
|
||
} catch (Exception $e) {
|
||
Log::error('编辑节点信息异常：'.$e->getMessage());
|
||
|
||
return Response::json(['status' => 'fail', 'message' => '编辑失败：'.$e->getMessage()]);
|
||
}
|
||
|
||
return Response::json(['status' => 'fail', 'message' => '编辑失败']);
|
||
}
|
||
|
||
// 删除节点
|
||
public function destroy($id): JsonResponse
|
||
{
|
||
$node = Node::findOrFail($id);
|
||
|
||
try {
|
||
if ($node->delete()) {
|
||
return Response::json(['status' => 'success', 'message' => '删除成功']);
|
||
}
|
||
} catch (Exception $e) {
|
||
Log::error('删除线路失败：'.$e->getMessage());
|
||
|
||
return Response::json(['status' => 'fail', 'message' => '删除线路失败：'.$e->getMessage()]);
|
||
}
|
||
|
||
return Response::json(['status' => 'fail', 'message' => '删除线路失败']);
|
||
}
|
||
|
||
// 节点信息验证
|
||
public function checkNode($id): JsonResponse
|
||
{
|
||
$node = Node::find($id);
|
||
// 使用DDNS的node先获取ipv4地址
|
||
if ($node->is_ddns) {
|
||
$ip = gethostbyname($node->server);
|
||
if (strcmp($ip, $node->server) !== 0) {
|
||
$node->ip = $ip;
|
||
} else {
|
||
return Response::json(['status' => 'fail', 'title' => 'IP获取错误', 'message' => $node->name.'IP获取失败',]);
|
||
}
|
||
}
|
||
$data[0] = NetworkDetection::networkCheck($node->ip, true); //ICMP
|
||
$data[1] = NetworkDetection::networkCheck($node->ip, false, $node->single ? $node->port : null); //TCP
|
||
|
||
return Response::json(['status' => 'success', 'title' => '['.$node->name.']阻断信息', 'message' => $data,]);
|
||
}
|
||
|
||
// 刷新节点地理位置
|
||
public function refreshGeo($id): JsonResponse
|
||
{
|
||
if ((new NodeService())->getNodeGeo($id)) {
|
||
return Response::json(['status' => 'success', 'message' => '获取地理位置更新成功！']);
|
||
}
|
||
|
||
return Response::json(['status' => 'fail', 'message' => '获取地理位置更新失败！']);
|
||
}
|
||
|
||
// 重载节点
|
||
public function reload($id): JsonResponse
|
||
{
|
||
if (reloadNode::dispatchNow(Node::whereId($id)->get())) {
|
||
return Response::json(['status' => 'success', 'message' => '重载成功！']);
|
||
}
|
||
|
||
return Response::json(['status' => 'fail', 'message' => '重载失败！']);
|
||
}
|
||
|
||
// 节点流量监控
|
||
public function nodeMonitor($id)
|
||
{
|
||
$node = Node::find($id);
|
||
if (!$node) {
|
||
Session::flash('errorMsg', '节点不存在，请重试');
|
||
|
||
return Redirect::back();
|
||
}
|
||
|
||
$view['nodeName'] = $node->name;
|
||
$view['nodeServer'] = $node->server;
|
||
$view = array_merge($view, $this->DataFlowChart($node->id, 1));
|
||
|
||
return view('admin.node.monitor', $view);
|
||
}
|
||
|
||
// Ping节点延迟
|
||
public function pingNode($id): JsonResponse
|
||
{
|
||
$node = Node::findOrFail($id);
|
||
|
||
$result = NetworkDetection::ping($node->is_ddns ? $node->server : $node->ip);
|
||
|
||
if ($result) {
|
||
return Response::json([
|
||
'status' => 'success',
|
||
'message' => [
|
||
$result['telecom']['time'] ?: '无',//电信
|
||
$result['Unicom']['time'] ?: '无',// 联通
|
||
$result['move']['time'] ?: '无',// 移动
|
||
$result['HongKong']['time'] ?: '无'// 香港
|
||
],
|
||
]);
|
||
}
|
||
|
||
return Response::json(['status' => 'fail', 'message' => 'Ping访问失败']);
|
||
}
|
||
|
||
// Ping节点延迟日志
|
||
public function pingLog(Request $request)
|
||
{
|
||
$node_id = $request->input('nodeId');
|
||
$query = NodePing::query();
|
||
if (isset($node_id)) {
|
||
$query->whereNodeId($node_id);
|
||
}
|
||
|
||
$view['nodeList'] = Node::orderBy('id')->get();
|
||
$view['pingLogs'] = $query->latest()->paginate(15)->appends($request->except('page'));
|
||
|
||
return view('admin.node.ping', $view);
|
||
}
|
||
|
||
// 节点授权列表
|
||
public function authList(Request $request)
|
||
{
|
||
$view['list'] = NodeAuth::orderBy('node_id')->paginate(15)->appends($request->except('page'));
|
||
|
||
return view('admin.node.auth', $view);
|
||
}
|
||
|
||
// 添加节点授权
|
||
public function addAuth(): JsonResponse
|
||
{
|
||
$nodeArray = Node::whereStatus(1)->orderBy('id')->pluck('id')->toArray();
|
||
$authArray = NodeAuth::orderBy('node_id')->pluck('node_id')->toArray();
|
||
|
||
$arrayDifferent = array_diff($nodeArray, $authArray);
|
||
|
||
if (empty($arrayDifferent)) {
|
||
return Response::json(['status' => 'success', 'message' => '没有需要生成授权的节点']);
|
||
}
|
||
|
||
foreach ($arrayDifferent as $nodeId) {
|
||
$obj = new NodeAuth();
|
||
$obj->node_id = $nodeId;
|
||
$obj->key = Str::random();
|
||
$obj->secret = Str::random(8);
|
||
$obj->save();
|
||
}
|
||
|
||
return Response::json(['status' => 'success', 'message' => '生成成功']);
|
||
}
|
||
|
||
// 删除节点授权
|
||
public function delAuth($id): JsonResponse
|
||
{
|
||
try {
|
||
NodeAuth::whereId($id)->delete();
|
||
} catch (Exception $e) {
|
||
return Response::json(['status' => 'fail', 'message' => '错误：'.var_export($e, true)]);
|
||
}
|
||
|
||
return Response::json(['status' => 'success', 'message' => '操作成功']);
|
||
}
|
||
|
||
// 重置节点授权
|
||
public function refreshAuth($id): JsonResponse
|
||
{
|
||
$ret = NodeAuth::find($id)->update(['key' => Str::random(), 'secret' => Str::random(8)]);
|
||
if ($ret) {
|
||
return Response::json(['status' => 'success', 'message' => '操作成功']);
|
||
}
|
||
|
||
return Response::json(['status' => 'fail', 'message' => '操作失败']);
|
||
}
|
||
}
|