NodeController.php 6.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Components\NetworkDetection;
  4. use App\Http\Controllers\Controller;
  5. use App\Http\Requests\Admin\NodeRequest;
  6. use App\Jobs\VNet\reloadNode;
  7. use App\Models\Country;
  8. use App\Models\Label;
  9. use App\Models\Level;
  10. use App\Models\Node;
  11. use App\Models\NodeCertificate;
  12. use App\Models\RuleGroup;
  13. use Arr;
  14. use Exception;
  15. use Illuminate\Http\JsonResponse;
  16. use Illuminate\Http\Request;
  17. use Log;
  18. use Response;
  19. class NodeController extends Controller
  20. {
  21. // 节点列表
  22. public function index(Request $request)
  23. {
  24. $status = $request->input('status');
  25. $query = Node::with(['onlineLogs', 'dailyDataFlows']);
  26. if (isset($status)) {
  27. $query->whereStatus($status);
  28. }
  29. $nodeList = $query->orderByDesc('sort')->orderBy('id')->paginate(15)->appends($request->except('page'));
  30. foreach ($nodeList as $node) {
  31. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-5 minutes'))->latest('log_time')->first(); // 在线人数
  32. $node->online_users = $online_log->online_user ?? 0;
  33. $node->transfer = flowAutoShow($node->dailyDataFlows()->sum('total')); // 已产生流量
  34. $node_info = $node->heartbeats()->recently()->first(); // 近期负载
  35. $node->isOnline = empty($node_info) || empty($node_info->load) ? 0 : 1;
  36. $node->load = $node->isOnline ? $node_info->load : '离线';
  37. $node->uptime = empty($node_info) ? 0 : seconds2time($node_info->uptime);
  38. }
  39. return view('admin.node.index', ['nodeList' => $nodeList]);
  40. }
  41. // 添加节点页面
  42. public function create()
  43. {
  44. return view('admin.node.info', [
  45. 'countries' => Country::orderBy('code')->get(),
  46. 'levels' => Level::orderBy('level')->get(),
  47. 'ruleGroups' => RuleGroup::orderBy('id')->get(),
  48. 'labels' => Label::orderByDesc('sort')->orderBy('id')->get(),
  49. 'certs' => NodeCertificate::orderBy('id')->get(),
  50. ]);
  51. }
  52. // 添加节点
  53. public function store(NodeRequest $request): JsonResponse
  54. {
  55. $array = $request->validated();
  56. Arr::forget($array, ['labels']);
  57. try {
  58. if ($node = Node::create($array)) {
  59. // 生成节点标签
  60. if ($request->has('labels')) {
  61. $node->labels()->attach($request->input('labels'));
  62. }
  63. return Response::json(['status' => 'success', 'message' => '添加成功']);
  64. }
  65. } catch (Exception $e) {
  66. Log::error('添加节点信息异常:'.$e->getMessage());
  67. return Response::json(['status' => 'fail', 'message' => '添加线路失败:'.$e->getMessage()]);
  68. }
  69. return Response::json(['status' => 'fail', 'message' => '添加线路失败']);
  70. }
  71. // 编辑节点页面
  72. public function edit(Node $node)
  73. {
  74. return view('admin.node.info', [
  75. 'node' => $node,
  76. 'countries' => Country::orderBy('code')->get(),
  77. 'levels' => Level::orderBy('level')->get(),
  78. 'ruleGroups' => RuleGroup::orderBy('id')->get(),
  79. 'labels' => Label::orderByDesc('sort')->orderBy('id')->get(),
  80. 'certs' => NodeCertificate::orderBy('id')->get(),
  81. ]);
  82. }
  83. // 编辑节点
  84. public function update(NodeRequest $request, Node $node): JsonResponse
  85. {
  86. try {
  87. $array = $request->validated();
  88. Arr::forget($array, ['labels']);
  89. if ($node->update($array)) {
  90. // 更新节点标签
  91. $node->labels()->sync($request->input('labels'));
  92. return Response::json(['status' => 'success', 'message' => '编辑成功']);
  93. }
  94. } catch (Exception $e) {
  95. Log::error('编辑节点信息异常:'.$e->getMessage());
  96. return Response::json(['status' => 'fail', 'message' => '编辑失败:'.$e->getMessage()]);
  97. }
  98. return Response::json(['status' => 'fail', 'message' => '编辑失败']);
  99. }
  100. // 删除节点
  101. public function destroy(Node $node): JsonResponse
  102. {
  103. try {
  104. if ($node->delete()) {
  105. return Response::json(['status' => 'success', 'message' => '删除成功']);
  106. }
  107. } catch (Exception $e) {
  108. Log::error('删除线路失败:'.$e->getMessage());
  109. return Response::json(['status' => 'fail', 'message' => '删除线路失败:'.$e->getMessage()]);
  110. }
  111. return Response::json(['status' => 'fail', 'message' => '删除线路失败']);
  112. }
  113. // 节点信息验证
  114. public function checkNode(Node $node): JsonResponse
  115. {
  116. // 使用DDNS的node先获取ipv4地址
  117. if ($node->is_ddns) {
  118. $ip = gethostbyname($node->server);
  119. if (strcmp($ip, $node->server) !== 0) {
  120. $node->ip = $ip;
  121. } else {
  122. return Response::json(['status' => 'fail', 'title' => 'IP获取错误', 'message' => $node->name.'IP获取失败']);
  123. }
  124. }
  125. $data[0] = (new NetworkDetection)->networkCheck($node->ip, true); //ICMP
  126. $data[1] = (new NetworkDetection)->networkCheck($node->ip, false, $node->single ? $node->port : 22); //TCP
  127. return Response::json(['status' => 'success', 'title' => '['.$node->name.']阻断信息', 'message' => $data]);
  128. }
  129. // 刷新节点地理位置
  130. public function refreshGeo($id): JsonResponse
  131. {
  132. if ($id) {
  133. $ret = Node::findOrFail($id)->refresh_geo();
  134. } else {
  135. foreach (Node::whereStatus(1)->get() as $node) {
  136. $ret = $node->refresh_geo();
  137. }
  138. }
  139. if ($ret) {
  140. return Response::json(['status' => 'success', 'message' => '获取地理位置更新成功!']);
  141. }
  142. return Response::json(['status' => 'fail', 'message' => '获取地理位置更新失败!']);
  143. }
  144. // 重载节点
  145. public function reload(Node $node): JsonResponse
  146. {
  147. if (reloadNode::dispatchNow($node)) {
  148. return Response::json(['status' => 'success', 'message' => '重载成功!']);
  149. }
  150. return Response::json(['status' => 'fail', 'message' => '重载失败!']);
  151. }
  152. // 节点流量监控
  153. public function nodeMonitor(Node $node)
  154. {
  155. return view('admin.node.monitor', array_merge(['nodeName' => $node->name, 'nodeServer' => $node->server], $this->DataFlowChart($node->id, true)));
  156. }
  157. // Ping节点延迟
  158. public function pingNode(Node $node): JsonResponse
  159. {
  160. if ($result = (new NetworkDetection)->ping($node->is_ddns ? $node->server : $node->ip)) {
  161. return Response::json([
  162. 'status' => 'success',
  163. 'message' => $result,
  164. ]);
  165. }
  166. return Response::json(['status' => 'fail', 'message' => 'Ping访问失败']);
  167. }
  168. }