NodeController.php 7.8 KB

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