NodeController.php 9.6 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293
  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\NodeAuth;
  12. use App\Models\NodeCertificate;
  13. use App\Models\NodePing;
  14. use App\Services\NodeService;
  15. use Exception;
  16. use Illuminate\Http\JsonResponse;
  17. use Illuminate\Http\Request;
  18. use Log;
  19. use Redirect;
  20. use Response;
  21. use Session;
  22. use Str;
  23. class NodeController extends Controller
  24. {
  25. // 节点列表
  26. public function index(Request $request)
  27. {
  28. $status = $request->input('status');
  29. $query = Node::with(['onlineLogs', 'dailyDataFlows']);
  30. if (isset($status)) {
  31. $query->whereStatus($status);
  32. }
  33. $nodeList = $query->orderByDesc('sort')->orderBy('id')->paginate(15)->appends($request->except('page'));
  34. foreach ($nodeList as $node) {
  35. // 在线人数
  36. $online_log = $node->onlineLogs()->where('log_time', '>=', strtotime('-5 minutes'))->latest('log_time')->first();
  37. $node->online_users = $online_log->online_user ?? 0;
  38. // 已产生流量
  39. $node->transfer = flowAutoShow($node->dailyDataFlows()->sum('total'));
  40. // 负载(10分钟以内)
  41. $node_info = $node->heartBeats()->recently()->first();
  42. $node->isOnline = empty($node_info) || empty($node_info->load) ? 0 : 1;
  43. $node->load = $node->isOnline ? $node_info->load : '离线';
  44. $node->uptime = empty($node_info) ? 0 : seconds2time($node_info->uptime);
  45. }
  46. $view['nodeList'] = $nodeList;
  47. return view('admin.node.index', $view);
  48. }
  49. // 添加节点页面
  50. public function create()
  51. {
  52. return view('admin.node.info', [
  53. 'countryList' => Country::orderBy('code')->get(),
  54. 'levelList' => Level::orderBy('level')->get(),
  55. 'labelList' => Label::orderByDesc('sort')->orderBy('id')->get(),
  56. 'dvList' => NodeCertificate::orderBy('id')->get(),
  57. ]);
  58. }
  59. // 添加节点
  60. public function store(NodeRequest $request): JsonResponse
  61. {
  62. try {
  63. $node = Node::create($request->except('_token', 'labels'));
  64. if ($node) {
  65. // 生成节点标签
  66. if ($request->exists('labels')) {
  67. (new NodeService())->makeLabels($node->id, $request->input('labels'));
  68. }
  69. return Response::json(['status' => 'success', 'message' => '添加成功']);
  70. }
  71. } catch (Exception $e) {
  72. Log::error('添加节点信息异常:'.$e->getMessage());
  73. return Response::json(['status' => 'fail', 'message' => '添加线路失败:'.$e->getMessage()]);
  74. }
  75. return Response::json(['status' => 'fail', 'message' => '添加线路失败']);
  76. }
  77. // 编辑节点页面
  78. public function edit($id)
  79. {
  80. return view('admin.node.info', [
  81. 'node' => Node::with('labels')->find($id),
  82. 'countryList' => Country::orderBy('code')->get(),
  83. 'levelList' => Level::orderBy('level')->get(),
  84. 'labelList' => Label::orderByDesc('sort')->orderBy('id')->get(),
  85. 'dvList' => NodeCertificate::orderBy('id')->get(),
  86. ]);
  87. }
  88. // 编辑节点
  89. public function update(NodeRequest $request, $id): JsonResponse
  90. {
  91. $node = Node::find($id);
  92. try {
  93. // 生成节点标签
  94. if ($request->exists('labels')) {
  95. (new NodeService())->makeLabels($node->id, $request->input('labels'));
  96. }
  97. if ($node->update($request->except('_token', 'labels'))) {
  98. return Response::json(['status' => 'success', 'message' => '编辑成功']);
  99. }
  100. } catch (Exception $e) {
  101. Log::error('编辑节点信息异常:'.$e->getMessage());
  102. return Response::json(['status' => 'fail', 'message' => '编辑失败:'.$e->getMessage()]);
  103. }
  104. return Response::json(['status' => 'fail', 'message' => '编辑失败']);
  105. }
  106. // 删除节点
  107. public function destroy($id): JsonResponse
  108. {
  109. $node = Node::findOrFail($id);
  110. try {
  111. if ($node->delete()) {
  112. return Response::json(['status' => 'success', 'message' => '删除成功']);
  113. }
  114. } catch (Exception $e) {
  115. Log::error('删除线路失败:'.$e->getMessage());
  116. return Response::json(['status' => 'fail', 'message' => '删除线路失败:'.$e->getMessage()]);
  117. }
  118. return Response::json(['status' => 'fail', 'message' => '删除线路失败']);
  119. }
  120. // 节点信息验证
  121. public function checkNode($id): JsonResponse
  122. {
  123. $node = Node::find($id);
  124. // 使用DDNS的node先获取ipv4地址
  125. if ($node->is_ddns) {
  126. $ip = gethostbyname($node->server);
  127. if (strcmp($ip, $node->server) !== 0) {
  128. $node->ip = $ip;
  129. } else {
  130. return Response::json(['status' => 'fail', 'title' => 'IP获取错误', 'message' => $node->name.'IP获取失败']);
  131. }
  132. }
  133. $data[0] = NetworkDetection::networkCheck($node->ip, true); //ICMP
  134. $data[1] = NetworkDetection::networkCheck($node->ip, false, $node->single ? $node->port : null); //TCP
  135. return Response::json(['status' => 'success', 'title' => '['.$node->name.']阻断信息', 'message' => $data]);
  136. }
  137. // 刷新节点地理位置
  138. public function refreshGeo($id): JsonResponse
  139. {
  140. if ((new NodeService())->getNodeGeo($id)) {
  141. return Response::json(['status' => 'success', 'message' => '获取地理位置更新成功!']);
  142. }
  143. return Response::json(['status' => 'fail', 'message' => '获取地理位置更新失败!']);
  144. }
  145. // 重载节点
  146. public function reload($id): JsonResponse
  147. {
  148. if (reloadNode::dispatchNow(Node::whereId($id)->get())) {
  149. return Response::json(['status' => 'success', 'message' => '重载成功!']);
  150. }
  151. return Response::json(['status' => 'fail', 'message' => '重载失败!']);
  152. }
  153. // 节点流量监控
  154. public function nodeMonitor($id)
  155. {
  156. $node = Node::find($id);
  157. if (! $node) {
  158. Session::flash('errorMsg', '节点不存在,请重试');
  159. return Redirect::back();
  160. }
  161. $view['nodeName'] = $node->name;
  162. $view['nodeServer'] = $node->server;
  163. $view = array_merge($view, $this->DataFlowChart($node->id, true));
  164. return view('admin.node.monitor', $view);
  165. }
  166. // Ping节点延迟
  167. public function pingNode($id): JsonResponse
  168. {
  169. $node = Node::findOrFail($id);
  170. $result = NetworkDetection::ping($node->is_ddns ? $node->server : $node->ip);
  171. if ($result) {
  172. return Response::json([
  173. 'status' => 'success',
  174. 'message' => [
  175. $result['telecom']['time'] ?: '无', //电信
  176. $result['Unicom']['time'] ?: '无', // 联通
  177. $result['move']['time'] ?: '无', // 移动
  178. $result['HongKong']['time'] ?: '无', // 香港
  179. ],
  180. ]);
  181. }
  182. return Response::json(['status' => 'fail', 'message' => 'Ping访问失败']);
  183. }
  184. // Ping节点延迟日志
  185. public function pingLog(Request $request)
  186. {
  187. $node_id = $request->input('nodeId');
  188. $query = NodePing::query();
  189. if (isset($node_id)) {
  190. $query->whereNodeId($node_id);
  191. }
  192. $view['nodeList'] = Node::orderBy('id')->get();
  193. $view['pingLogs'] = $query->latest()->paginate(15)->appends($request->except('page'));
  194. return view('admin.node.ping', $view);
  195. }
  196. // 节点授权列表
  197. public function authList(Request $request)
  198. {
  199. $view['list'] = NodeAuth::orderBy('node_id')->paginate(15)->appends($request->except('page'));
  200. return view('admin.node.auth', $view);
  201. }
  202. // 添加节点授权
  203. public function addAuth(): JsonResponse
  204. {
  205. $nodeArray = Node::whereStatus(1)->orderBy('id')->pluck('id')->toArray();
  206. $authArray = NodeAuth::orderBy('node_id')->pluck('node_id')->toArray();
  207. $arrayDifferent = array_diff($nodeArray, $authArray);
  208. if (empty($arrayDifferent)) {
  209. return Response::json(['status' => 'success', 'message' => '没有需要生成授权的节点']);
  210. }
  211. foreach ($arrayDifferent as $nodeId) {
  212. $obj = new NodeAuth();
  213. $obj->node_id = $nodeId;
  214. $obj->key = Str::random();
  215. $obj->secret = Str::random(8);
  216. $obj->save();
  217. }
  218. return Response::json(['status' => 'success', 'message' => '生成成功']);
  219. }
  220. // 删除节点授权
  221. public function delAuth($id): JsonResponse
  222. {
  223. try {
  224. NodeAuth::whereId($id)->delete();
  225. } catch (Exception $e) {
  226. return Response::json(['status' => 'fail', 'message' => '错误:'.var_export($e, true)]);
  227. }
  228. return Response::json(['status' => 'success', 'message' => '操作成功']);
  229. }
  230. // 重置节点授权
  231. public function refreshAuth($id): JsonResponse
  232. {
  233. $ret = NodeAuth::find($id)->update(['key' => Str::random(), 'secret' => Str::random(8)]);
  234. if ($ret) {
  235. return Response::json(['status' => 'success', 'message' => '操作成功']);
  236. }
  237. return Response::json(['status' => 'fail', 'message' => '操作失败']);
  238. }
  239. }