ShadowsocksController.php 3.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135
  1. <?php
  2. namespace App\Http\Controllers\Admin\Server;
  3. use App\Http\Requests\Admin\ServerShadowsocksSave;
  4. use App\Http\Requests\Admin\ServerShadowsocksSort;
  5. use App\Http\Requests\Admin\ServerShadowsocksUpdate;
  6. use App\Models\ServerShadowsocks;
  7. use App\Utils\CacheKey;
  8. use Illuminate\Http\Request;
  9. use App\Http\Controllers\Controller;
  10. use App\Models\Server;
  11. use Illuminate\Support\Facades\Cache;
  12. use Illuminate\Support\Facades\DB;
  13. class ShadowsocksController extends Controller
  14. {
  15. public function fetch(Request $request)
  16. {
  17. $server = ServerShadowsocks::orderBy('sort', 'ASC')->get();
  18. for ($i = 0; $i < count($server); $i++) {
  19. if (!empty($server[$i]['tags'])) {
  20. $server[$i]['tags'] = json_decode($server[$i]['tags']);
  21. }
  22. $server[$i]['group_id'] = json_decode($server[$i]['group_id']);
  23. $server[$i]['online'] = Cache::get(CacheKey::get('SERVER_SHADOWSOCKS_ONLINE_USER', $server[$i]['parent_id'] ? $server[$i]['parent_id'] : $server[$i]['id']));
  24. if ($server[$i]['parent_id']) {
  25. $server[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_SHADOWSOCKS_LAST_CHECK_AT', $server[$i]['parent_id']));
  26. } else {
  27. $server[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_SHADOWSOCKS_LAST_CHECK_AT', $server[$i]['id']));
  28. }
  29. }
  30. return response([
  31. 'data' => $server
  32. ]);
  33. }
  34. public function save(ServerShadowsocksSave $request)
  35. {
  36. $params = $request->validated();
  37. $params['group_id'] = json_encode($params['group_id']);
  38. if (isset($params['tags'])) {
  39. $params['tags'] = json_encode($params['tags']);
  40. }
  41. if ($request->input('id')) {
  42. $server = ServerShadowsocks::find($request->input('id'));
  43. if (!$server) {
  44. abort(500, '服务器不存在');
  45. }
  46. try {
  47. $server->update($params);
  48. } catch (\Exception $e) {
  49. abort(500, '保存失败');
  50. }
  51. return response([
  52. 'data' => true
  53. ]);
  54. }
  55. if (!ServerShadowsocks::create($params)) {
  56. abort(500, '创建失败');
  57. }
  58. return response([
  59. 'data' => true
  60. ]);
  61. }
  62. public function drop(Request $request)
  63. {
  64. if ($request->input('id')) {
  65. $server = ServerShadowsocks::find($request->input('id'));
  66. if (!$server) {
  67. abort(500, '节点ID不存在');
  68. }
  69. }
  70. return response([
  71. 'data' => $server->delete()
  72. ]);
  73. }
  74. public function update(ServerShadowsocksUpdate $request)
  75. {
  76. $params = $request->only([
  77. 'show',
  78. ]);
  79. $server = ServerShadowsocks::find($request->input('id'));
  80. if (!$server) {
  81. abort(500, '该服务器不存在');
  82. }
  83. try {
  84. $server->update($params);
  85. } catch (\Exception $e) {
  86. abort(500, '保存失败');
  87. }
  88. return response([
  89. 'data' => true
  90. ]);
  91. }
  92. public function copy(Request $request)
  93. {
  94. $server = ServerShadowsocks::find($request->input('id'));
  95. $server->show = 0;
  96. if (!$server) {
  97. abort(500, '服务器不存在');
  98. }
  99. if (!ServerShadowsocks::create($server->toArray())) {
  100. abort(500, '复制失败');
  101. }
  102. return response([
  103. 'data' => true
  104. ]);
  105. }
  106. public function sort(ServerShadowsocksSort $request)
  107. {
  108. DB::beginTransaction();
  109. foreach ($request->input('server_ids') as $k => $v) {
  110. if (!ServerShadowsocks::find($v)->update(['sort' => $k + 1])) {
  111. DB::rollBack();
  112. abort(500, '保存失败');
  113. }
  114. }
  115. DB::commit();
  116. return response([
  117. 'data' => true
  118. ]);
  119. }
  120. }