123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293 |
- <?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
- {
- 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'));
- }
- 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, true));
- 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' => '操作失败']);
- }
- }
|