ServerController.php 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Http\Requests\Admin\ServerSave;
  4. use Illuminate\Http\Request;
  5. use App\Http\Controllers\Controller;
  6. use App\Models\ServerGroup;
  7. use App\Models\Server;
  8. use App\Models\Plan;
  9. use App\Models\User;
  10. class ServerController extends Controller
  11. {
  12. public function index (Request $request) {
  13. $server = Server::get();
  14. for ($i = 0; $i < count($server); $i++) {
  15. if (!empty($server[$i]['tags'])) {
  16. $server[$i]['tags'] = json_decode($server[$i]['tags']);
  17. }
  18. $server[$i]['group_id'] = json_decode($server[$i]['group_id']);
  19. }
  20. return response([
  21. 'data' => $server
  22. ]);
  23. }
  24. public function save (ServerSave $request) {
  25. if ($request->input('id')) {
  26. $server = Server::find($request->input('id'));
  27. if (!$server) {
  28. abort(500, '服务器不存在');
  29. }
  30. } else {
  31. $server = new Server();
  32. }
  33. $server->group_id = json_encode($request->input('group_id'));
  34. $server->name = $request->input('name');
  35. $server->host = $request->input('host');
  36. $server->port = $request->input('port');
  37. $server->server_port = $request->input('server_port');
  38. $server->tls = $request->input('tls');
  39. $server->tags = $request->input('tags') ? json_encode($request->input('tags')) : NULL;
  40. $server->rate = $request->input('rate');
  41. $server->network = $request->input('network');
  42. if ($request->input('settings')) {
  43. if (!is_object(json_decode($request->input('settings')))) {
  44. abort(500, '传输协议配置格式不正确');
  45. }
  46. $server->settings = $request->input('settings');
  47. }
  48. return response([
  49. 'data' => $server->save()
  50. ]);
  51. }
  52. public function group (Request $request) {
  53. if ($request->input('group_id')) {
  54. return response([
  55. 'data' => [ServerGroup::find($request->input('group_id'))]
  56. ]);
  57. }
  58. return response([
  59. 'data' => ServerGroup::get()
  60. ]);
  61. }
  62. public function groupSave (Request $request) {
  63. if (empty($request->input('name'))) {
  64. abort(500, '组名不能为空');
  65. }
  66. if ($request->input('id')) {
  67. $serverGroup = ServerGroup::find($request->input('id'));
  68. } else {
  69. $serverGroup = new ServerGroup();
  70. }
  71. $serverGroup->name = $request->input('name');
  72. return response([
  73. 'data' => $serverGroup->save()
  74. ]);
  75. }
  76. public function groupDrop (Request $request) {
  77. if ($request->input('id')) {
  78. $serverGroup = ServerGroup::find($request->input('id'));
  79. if (!$serverGroup) {
  80. abort(500, '组不存在');
  81. }
  82. }
  83. $servers = Server::all();
  84. foreach ($servers as $server) {
  85. $groupId = json_decode($server->group_id);
  86. if (in_array($request->input('id'), $groupId)) {
  87. abort(500, '该组已被节点所使用,无法删除');
  88. }
  89. }
  90. if (Plan::where('group_id', $request->input('id'))->first()) {
  91. abort(500, '该组已被订阅所使用,无法删除');
  92. }
  93. if (User::where('group_id', $request->input('id'))->first()) {
  94. abort(500, '该组已被用户所使用,无法删除');
  95. }
  96. return response([
  97. 'data' => $serverGroup->delete()
  98. ]);
  99. }
  100. public function drop (Request $request) {
  101. if ($request->input('id')) {
  102. $server = Server::find($request->input('id'));
  103. if (!$server) {
  104. abort(500, '节点ID不存在');
  105. }
  106. }
  107. return response([
  108. 'data' => $server->delete()
  109. ]);
  110. }
  111. }