NodeController.php 17 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Helpers;
  4. use App\Components\NetworkDetection;
  5. use App\Jobs\VNet\reloadNode;
  6. use App\Models\Country;
  7. use App\Models\Label;
  8. use App\Models\Level;
  9. use App\Models\Node;
  10. use App\Models\NodeAuth;
  11. use App\Models\NodeCertificate;
  12. use App\Models\NodePing;
  13. use App\Services\NodeService;
  14. use DB;
  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. use Validator;
  24. class NodeController extends Controller {
  25. // 节点列表
  26. public function nodeList(Request $request) {
  27. $status = $request->input('status');
  28. $query = Node::with(['onlineLogs', 'dailyDataFlows']);
  29. if(isset($status)){
  30. $query->whereStatus($status);
  31. }
  32. $nodeList = $query->orderByDesc('sort')->orderBy('id')->paginate(15)->appends($request->except('page'));
  33. foreach($nodeList as $node){
  34. // 在线人数
  35. $online_log = $node->onlineLogs()
  36. ->where('log_time', '>=', strtotime("-5 minutes"))
  37. ->latest('log_time')
  38. ->first();
  39. $node->online_users = empty($online_log)? 0 : $online_log->online_user;
  40. // 已产生流量
  41. $node->transfer = flowAutoShow($node->dailyDataFlows()->sum('total'));
  42. // 负载(10分钟以内)
  43. $node_info = $node->heartBeats()->recently()->first();
  44. $node->isOnline = empty($node_info) || empty($node_info->load)? 0 : 1;
  45. $node->load = $node->isOnline? $node_info->load : '离线';
  46. $node->uptime = empty($node_info)? 0 : seconds2time($node_info->uptime);
  47. }
  48. $view['nodeList'] = $nodeList;
  49. return view('admin.node.nodeList', $view);
  50. }
  51. public function checkNode($id): JsonResponse {
  52. $node = Node::find($id);
  53. // 使用DDNS的node先获取ipv4地址
  54. if($node->is_ddns){
  55. $ip = gethostbyname($node->server);
  56. if(strcmp($ip, $node->server) != 0){
  57. $node->ip = $ip;
  58. }else{
  59. return Response::json(['status' => 'fail', 'title' => 'IP获取错误', 'message' => $node->name.'IP获取失败']);
  60. }
  61. }
  62. $data[0] = NetworkDetection::networkCheck($node->ip, true); //ICMP
  63. $data[1] = NetworkDetection::networkCheck($node->ip, false, $node->single? $node->port : null); //TCP
  64. return Response::json(['status' => 'success', 'title' => '['.$node->name.']阻断信息', 'message' => $data]);
  65. }
  66. // 添加节点
  67. public function addNode(Request $request) {
  68. if($request->isMethod('POST')){
  69. $validator = $this->nodeValidation($request);
  70. if($validator){
  71. return $validator;
  72. }
  73. // TODO:判断是否已存在绑定了相同域名的节点,提示是否要强制替换,或者不提示之前强制将其他节点的绑定域名置为空,然后发起域名绑定请求,或者请求进入队列
  74. try{
  75. DB::beginTransaction();
  76. $node = new Node();
  77. $node->type = $request->input('type');
  78. $node->name = $request->input('name');
  79. $node->country_code = $request->input('country_code');
  80. $node->server = $request->input('server');
  81. $node->ip = $request->input('ip');
  82. $node->ipv6 = $request->input('ipv6');
  83. $node->relay_server = $request->input('relay_server');
  84. $node->relay_port = $request->input('relay_port');
  85. $node->level = $request->input('level');
  86. $node->speed_limit = (int) $request->input('speed_limit') * Mbps;
  87. $node->client_limit = $request->input('client_limit');
  88. $node->description = $request->input('description');
  89. $node->method = $request->input('method');
  90. $node->protocol = $request->input('protocol');
  91. $node->protocol_param = $request->input('protocol_param');
  92. $node->obfs = $request->input('obfs');
  93. $node->obfs_param = $request->input('obfs_param');
  94. $node->traffic_rate = $request->input('traffic_rate');
  95. $node->is_subscribe = (int) $request->input('is_subscribe');
  96. $node->is_ddns = (int) $request->input('is_ddns');
  97. $node->is_relay = (int) $request->input('is_relay');
  98. $node->is_udp = (int) $request->input('is_udp');
  99. $node->push_port = $request->input('push_port');
  100. $node->detection_type = $request->input('detection_type');
  101. $node->compatible = (int) $request->input('compatible');
  102. $node->single = (int) $request->input('single');
  103. $node->port = $request->input('port');
  104. $node->passwd = $request->input('passwd');
  105. $node->sort = $request->input('sort');
  106. $node->status = (int) $request->input('status');
  107. $node->v2_alter_id = $request->input('v2_alter_id');
  108. $node->v2_port = $request->input('v2_port');
  109. $node->v2_method = $request->input('v2_method');
  110. $node->v2_net = $request->input('v2_net');
  111. $node->v2_type = $request->input('v2_type');
  112. $node->v2_host = $request->input('v2_host')?: '';
  113. $node->v2_path = $request->input('v2_path');
  114. $node->v2_tls = (int) $request->input('v2_tls');
  115. $node->tls_provider = $request->input('tls_provider');
  116. $node->save();
  117. DB::commit();
  118. // 生成节点标签
  119. (new NodeService())->makeLabels($node->id, $request->input('labels'));
  120. return Response::json(['status' => 'success', 'message' => '添加成功']);
  121. }catch(Exception $e){
  122. DB::rollBack();
  123. Log::error('添加节点信息异常:'.$e->getMessage());
  124. return Response::json(['status' => 'fail', 'message' => '添加失败:'.$e->getMessage()]);
  125. }
  126. }else{
  127. $view['methodList'] = Helpers::methodList();
  128. $view['protocolList'] = Helpers::protocolList();
  129. $view['obfsList'] = Helpers::obfsList();
  130. $view['countryList'] = Country::orderBy('code')->get();
  131. $view['levelList'] = Level::orderBy('level')->get();
  132. $view['labelList'] = Label::orderByDesc('sort')->orderBy('id')->get();
  133. $view['dvList'] = NodeCertificate::orderBy('id')->get();
  134. return view('admin.node.nodeInfo', $view);
  135. }
  136. }
  137. // 节点信息验证
  138. private function nodeValidation(Request $request) {
  139. if($request->input('server')){
  140. $domain = $request->input('server');
  141. $domain = explode('.', $domain);
  142. $domainSuffix = end($domain); // 取得域名后缀
  143. if(!in_array($domainSuffix, config('domains'), true)){
  144. return Response::json(['status' => 'fail', 'message' => '绑定域名不合法']);
  145. }
  146. }
  147. $validator = Validator::make($request->all(), [
  148. 'type' => 'required|between:1,3',
  149. 'name' => 'required',
  150. 'country_code' => 'required',
  151. 'server' => 'required_if:is_ddns,1',
  152. 'push_port' => 'numeric|between:0,65535',
  153. 'traffic_rate' => 'required|numeric|min:0',
  154. 'level' => 'required|numeric|between:0,255',
  155. 'speed_limit' => 'required|numeric|min:0',
  156. 'client_limit' => 'required|numeric|min:0',
  157. 'port' => 'nullable|numeric|between:0,65535',
  158. 'ip' => 'ipv4',
  159. 'ipv6' => 'nullable|ipv6',
  160. 'relay_server' => 'required_if:is_relay,1',
  161. 'relay_port' => 'required_if:is_relay,1|numeric|between:0,65535',
  162. 'method' => 'required_if:type,1',
  163. 'protocol' => 'required_if:type,1',
  164. 'obfs' => 'required_if:type,1',
  165. 'is_subscribe' => 'boolean',
  166. 'is_ddns' => 'boolean',
  167. 'is_relay' => 'boolean',
  168. 'is_udp' => 'boolean',
  169. 'detection_type' => 'between:0,3',
  170. 'compatible' => 'boolean',
  171. 'single' => 'boolean',
  172. 'sort' => 'required|numeric|between:0,255',
  173. 'status' => 'boolean',
  174. 'v2_alter_id' => 'required_if:type,2|numeric|between:0,65535',
  175. 'v2_port' => 'required_if:type,2|numeric|between:0,65535',
  176. 'v2_method' => 'required_if:type,2',
  177. 'v2_net' => 'required_if:type,2',
  178. 'v2_type' => 'required_if:type,2',
  179. 'v2_tls' => 'boolean'
  180. ], [
  181. 'server.required_unless' => '开启DDNS, 域名不能为空',
  182. ]);
  183. if($validator->fails()){
  184. return Response::json(['status' => 'fail', 'message' => $validator->errors()->all()]);
  185. }
  186. return false;
  187. }
  188. // 刷新节点地理位置
  189. public function refreshGeo(Request $request): JsonResponse {
  190. if((new NodeService())->getNodeGeo($request->input('id', 0))){
  191. return Response::json(['status' => 'success', 'message' => '获取地理位置更新成功!']);
  192. }
  193. return Response::json(['status' => 'fail', 'message' => '获取地理位置更新失败!']);
  194. }
  195. // 重载节点
  196. public function reload($id): JsonResponse {
  197. if(reloadNode::dispatchNow(Node::whereId($id)->get())){
  198. return Response::json(['status' => 'success', 'message' => '重载成功!']);
  199. }
  200. return Response::json(['status' => 'fail', 'message' => '重载失败!']);
  201. }
  202. // 编辑节点
  203. public function editNode(Request $request) {
  204. $id = $request->input('id');
  205. if($request->isMethod('POST')){
  206. $validator = $this->nodeValidation($request);
  207. if($validator){
  208. return $validator;
  209. }
  210. $node = Node::find($id);
  211. try{
  212. DB::beginTransaction();
  213. // 生成节点标签
  214. (new NodeService())->makeLabels($node->id, $request->input('labels'));
  215. $node->update([
  216. 'type' => $request->input('type'),
  217. 'name' => $request->input('name'),
  218. 'country_code' => $request->input('country_code'),
  219. 'server' => $request->input('server'),
  220. 'ip' => $request->input('ip'),
  221. 'ipv6' => $request->input('ipv6'),
  222. 'relay_server' => $request->input('relay_server'),
  223. 'relay_port' => $request->input('relay_port'),
  224. 'level' => $request->input('level'),
  225. 'speed_limit' => (int) $request->input('speed_limit') * Mbps,
  226. 'client_limit' => $request->input('client_limit'),
  227. 'description' => $request->input('description'),
  228. 'method' => $request->input('method'),
  229. 'protocol' => $request->input('protocol'),
  230. 'protocol_param' => $request->input('protocol_param'),
  231. 'obfs' => $request->input('obfs'),
  232. 'obfs_param' => $request->input('obfs_param'),
  233. 'traffic_rate' => $request->input('traffic_rate'),
  234. 'is_subscribe' => (int) $request->input('is_subscribe'),
  235. 'is_ddns' => (int) $request->input('is_ddns'),
  236. 'is_relay' => (int) $request->input('is_relay'),
  237. 'is_udp' => (int) $request->input('is_udp'),
  238. 'push_port' => $request->input('push_port'),
  239. 'detection_type' => $request->input('detection_type'),
  240. 'compatible' => (int) $request->input('compatible'),
  241. 'single' => (int) $request->input('single'),
  242. 'port' => $request->input('port'),
  243. 'passwd' => $request->input('passwd'),
  244. 'sort' => $request->input('sort'),
  245. 'status' => (int) $request->input('status'),
  246. 'v2_alter_id' => $request->input('v2_alter_id'),
  247. 'v2_port' => $request->input('v2_port'),
  248. 'v2_method' => $request->input('v2_method'),
  249. 'v2_net' => $request->input('v2_net'),
  250. 'v2_type' => $request->input('v2_type'),
  251. 'v2_host' => $request->input('v2_host')?: '',
  252. 'v2_path' => $request->input('v2_path'),
  253. 'v2_tls' => (int) $request->input('v2_tls'),
  254. 'tls_provider' => $request->input('tls_provider')
  255. ]);
  256. // TODO:更新节点绑定的域名DNS(将节点IP更新到域名DNS 的A记录)
  257. DB::commit();
  258. return Response::json(['status' => 'success', 'message' => '编辑成功']);
  259. }catch(Exception $e){
  260. DB::rollBack();
  261. Log::error('编辑节点信息异常:'.$e->getMessage());
  262. return Response::json(['status' => 'fail', 'message' => '编辑失败:'.$e->getMessage()]);
  263. }
  264. }
  265. $view['node'] = Node::with('labels')->find($id);
  266. $view['methodList'] = Helpers::methodList();
  267. $view['protocolList'] = Helpers::protocolList();
  268. $view['obfsList'] = Helpers::obfsList();
  269. $view['countryList'] = Country::orderBy('code')->get();
  270. $view['levelList'] = Level::orderBy('level')->get();
  271. $view['labelList'] = Label::orderByDesc('sort')->orderBy('id')->get();
  272. $view['dvList'] = NodeCertificate::orderBy('id')->get();
  273. return view('admin.node.nodeInfo', $view);
  274. }
  275. // 删除节点
  276. public function delNode(Request $request): ?JsonResponse {
  277. $id = $request->input('id');
  278. $node = Node::find($id);
  279. if(!$node){
  280. return Response::json(['status' => 'fail', 'message' => '节点不存在,请重试']);
  281. }
  282. try{
  283. DB::beginTransaction();
  284. $node->delete();
  285. DB::commit();
  286. return Response::json(['status' => 'success', 'message' => '删除成功']);
  287. }catch(Exception $e){
  288. DB::rollBack();
  289. Log::error('删除节点信息异常:'.$e->getMessage());
  290. return Response::json(['status' => 'fail', 'message' => '删除失败:'.$e->getMessage()]);
  291. }
  292. }
  293. // 节点流量监控
  294. public function nodeMonitor(Request $request) {
  295. $node = Node::find($request->input('id'));
  296. if(!$node){
  297. Session::flash('errorMsg', '节点不存在,请重试');
  298. return Redirect::back();
  299. }
  300. $view['nodeName'] = $node->name;
  301. $view['nodeServer'] = $node->server;
  302. $view = array_merge($view, $this->DataFlowChart($node->id, 1));
  303. return view('admin.node.nodeMonitor', $view);
  304. }
  305. // Ping节点延迟
  306. public function pingNode($id): ?JsonResponse {
  307. $node = Node::find($id);
  308. if(!$node){
  309. return Response::json(['status' => 'fail', 'message' => '节点不存在,请重试']);
  310. }
  311. $result = NetworkDetection::ping($node->is_ddns? $node->server : $node->ip);
  312. if($result){
  313. return Response::json([
  314. 'status' => 'success',
  315. 'message' => [
  316. $result['telecom']['time']?: '无',//电信
  317. $result['Unicom']['time']?: '无',// 联通
  318. $result['move']['time']?: '无',// 移动
  319. $result['HongKong']['time']?: '无'// 香港
  320. ]
  321. ]);
  322. }
  323. return Response::json(['status' => 'fail', 'message' => 'Ping访问失败']);
  324. }
  325. // Ping节点延迟日志
  326. public function pingLog(Request $request) {
  327. $node_id = $request->input('nodeId');
  328. $query = NodePing::query();
  329. if(isset($node_id)){
  330. $query->whereNodeId($node_id);
  331. }
  332. $view['nodeList'] = Node::orderBy('id')->get();
  333. $view['pingLogs'] = $query->latest()->paginate(15)->appends($request->except('page'));
  334. return view('admin.logs.nodePingLog', $view);
  335. }
  336. // 节点授权列表
  337. public function authList(Request $request) {
  338. $view['list'] = NodeAuth::orderBy('node_id')->paginate(15)->appends($request->except('page'));
  339. return view('admin.node.authList', $view);
  340. }
  341. // 添加节点授权
  342. public function addAuth(): JsonResponse {
  343. $nodeArray = Node::whereStatus(1)->orderBy('id')->pluck('id')->toArray();
  344. $authArray = NodeAuth::orderBy('id')->pluck('node_id')->toArray();
  345. if($nodeArray == $authArray){
  346. return Response::json(['status' => 'success', 'message' => '没有需要生成授权的节点']);
  347. }
  348. foreach(array_diff($nodeArray, $authArray) as $nodeId){
  349. $obj = new NodeAuth();
  350. $obj->node_id = $nodeId;
  351. $obj->key = Str::random();
  352. $obj->secret = Str::random(8);
  353. $obj->save();
  354. }
  355. return Response::json(['status' => 'success', 'message' => '生成成功']);
  356. }
  357. // 删除节点授权
  358. public function delAuth(Request $request): JsonResponse {
  359. try{
  360. NodeAuth::whereId($request->input('id'))->delete();
  361. }catch(Exception $e){
  362. return Response::json(['status' => 'fail', 'message' => '错误:'.var_export($e, true)]);
  363. }
  364. return Response::json(['status' => 'success', 'message' => '操作成功']);
  365. }
  366. // 重置节点授权
  367. public function refreshAuth(Request $request): ?JsonResponse {
  368. $ret = NodeAuth::whereId($request->input('id'))->update([
  369. 'key' => Str::random(),
  370. 'secret' => Str::random(8)
  371. ]);
  372. if($ret){
  373. return Response::json(['status' => 'success', 'message' => '操作成功']);
  374. }
  375. return Response::json(['status' => 'fail', 'message' => '操作失败']);
  376. }
  377. // 域名证书列表
  378. public function certificateList(Request $request) {
  379. $DvList = NodeCertificate::orderBy('id')->paginate(15)->appends($request->except('page'));
  380. foreach($DvList as $Dv){
  381. if($Dv->key && $Dv->pem){
  382. $DvInfo = openssl_x509_parse($Dv->pem);
  383. $Dv->issuer = $DvInfo['issuer']['O'];
  384. $Dv->from = $DvInfo['validFrom_time_t']? date('Y-m-d', $DvInfo['validFrom_time_t']) : null;
  385. $Dv->to = $DvInfo['validTo']? date('Y-m-d', $DvInfo['validTo_time_t']) : null;
  386. }
  387. }
  388. $view['list'] = $DvList;
  389. return view('admin.node.certificateList', $view);
  390. }
  391. // 添加域名证书
  392. public function addCertificate(Request $request) {
  393. if($request->isMethod('POST')){
  394. $obj = new NodeCertificate();
  395. $obj->domain = $request->input('domain');
  396. $obj->key = str_replace(["\r", "\n"], '', $request->input('key'));
  397. $obj->pem = str_replace(["\r", "\n"], '', $request->input('pem'));
  398. $obj->save();
  399. if($obj->id){
  400. return Response::json(['status' => 'success', 'message' => '生成成功']);
  401. }
  402. return Response::json(['status' => 'fail', 'message' => '生成失败']);
  403. }
  404. return view('admin.node.certificateInfo');
  405. }
  406. // 编辑域名证书
  407. public function editCertificate(Request $request) {
  408. $Dv = NodeCertificate::find($request->input('id'));
  409. if($request->isMethod('POST')){
  410. if($Dv){
  411. $ret = NodeCertificate::whereId($Dv->id)->update([
  412. 'domain' => $request->input('domain'),
  413. 'key' => $request->input('key'),
  414. 'pem' => $request->input('pem')
  415. ]);
  416. if($ret){
  417. return Response::json(['status' => 'success', 'message' => '修改成功']);
  418. }
  419. }
  420. return Response::json(['status' => 'fail', 'message' => '修改失败']);
  421. }
  422. $view['Dv'] = $Dv;
  423. return view('admin.node.certificateInfo', $view);
  424. }
  425. // 删除域名证书
  426. public function delCertificate(Request $request): JsonResponse {
  427. try{
  428. NodeCertificate::whereId($request->input('id'))->delete();
  429. }catch(Exception $e){
  430. return Response::json(['status' => 'fail', 'message' => '错误:'.var_export($e, true)]);
  431. }
  432. return Response::json(['status' => 'success', 'message' => '操作成功']);
  433. }
  434. }