DeepbworkController.php 4.0 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105
  1. <?php
  2. namespace App\Http\Controllers\Server;
  3. use Illuminate\Http\Request;
  4. use App\Http\Controllers\Server\Controller;
  5. use App\Models\User;
  6. use App\Models\Plan;
  7. use App\Models\Server;
  8. use App\Models\ServerLog;
  9. use Illuminate\Support\Facades\Log;
  10. class DeepbworkController extends Controller
  11. {
  12. CONST SERVER_CONFIG = '{"api":{"services":["HandlerService","StatsService"],"tag":"api"},"stats":{},"inbound":{"port":443,"protocol":"vmess","settings":{"clients":[]},"streamSettings":{"network":"tcp"},"tag":"proxy"},"inboundDetour":[{"listen":"0.0.0.0","port":23333,"protocol":"dokodemo-door","settings":{"address":"0.0.0.0"},"tag":"api"}],"log":{"loglevel":"debug","access":"access.log","error":"error.log"},"outbound":{"protocol":"freedom","settings":{}},"routing":{"settings":{"rules":[{"inboundTag":["api"],"outboundTag":"api","type":"field"}]},"strategy":"rules"},"policy":{"levels":{"0":{"handshake":4,"connIdle":300,"uplinkOnly":5,"downlinkOnly":30,"statsUserUplink":true,"statsUserDownlink":true}}}}';
  13. // 后端获取用户
  14. public function user (Request $request) {
  15. $nodeId = $request->input('node_id');
  16. $server = Server::find($nodeId);
  17. $users = User::whereIn('group_id', json_decode($server->group_id))
  18. ->select([
  19. 'id',
  20. 'email',
  21. 't',
  22. 'u',
  23. 'd',
  24. 'transfer_enable',
  25. 'enable',
  26. 'v2ray_uuid',
  27. 'v2ray_alter_id',
  28. 'v2ray_level'
  29. ])
  30. ->get();
  31. $result = [];
  32. foreach ($users as $user) {
  33. $user->v2ray_user = [
  34. "uuid" => $user->v2ray_uuid,
  35. "email" => sprintf("%s@v2panel.user", $user->v2ray_uuid),
  36. "alter_id" => $user->v2ray_alter_id,
  37. "level" => $user->v2ray_level,
  38. ];
  39. unset($user['v2ray_uuid']);
  40. unset($user['v2ray_alter_id']);
  41. unset($user['v2ray_level']);
  42. array_push($result, $user);
  43. }
  44. return response([
  45. 'msg' => 'ok',
  46. 'data' => $result,
  47. ]);
  48. }
  49. // 后端提交数据
  50. public function submit (Request $request) {
  51. Log::info('serverSubmitData:' . $request->input('node_id') . ':' . file_get_contents('php://input'));
  52. $server = Server::find($request->input('node_id'));
  53. if (!$server) {
  54. return response([
  55. 'ret' => 1,
  56. 'msg' => 'ok'
  57. ]);
  58. }
  59. $data = file_get_contents('php://input');
  60. $data = json_decode($data, true);
  61. foreach ($data as $item) {
  62. $u = $item['u'] * $server->rate;
  63. $d = $item['d'] * $server->rate;
  64. $user = User::find($item['user_id']);
  65. $user->t = time();
  66. $user->u = $user->u + $u;
  67. $user->d = $user->d + $d;
  68. $user->save();
  69. $serverLog = new ServerLog();
  70. $serverLog->user_id = $item['user_id'];
  71. $serverLog->node_id = $request->input('node_id');
  72. $serverLog->u = $item['u'];
  73. $serverLog->d = $item['d'];
  74. $serverLog->rate = $server->rate;
  75. $serverLog->save();
  76. }
  77. return response([
  78. 'ret' => 1,
  79. 'msg' => 'ok'
  80. ]);
  81. }
  82. // 后端获取配置
  83. public function config (Request $request) {
  84. $nodeId = $request->input('node_id');
  85. $localPort = $request->input('local_port');
  86. $server = Server::find($nodeId);
  87. $jsonData = json_decode(self::SERVER_CONFIG);
  88. $jsonData->inboundDetour[0]->port = (int)$localPort;
  89. $jsonData->inbound->port = (int)$server->server_port;
  90. if ((int)$server->tls) {
  91. $jsonData->inbound->streamSettings->security = "tls";
  92. $tls = (object) array("certificateFile" => "/home/v2ray.crt", "keyFile" => "/home/v2ray.key");
  93. $jsonData->inbound->streamSettings->tlsSettings->certificates[0] = $tls;
  94. }
  95. die(json_encode($jsonData, JSON_UNESCAPED_UNICODE));
  96. }
  97. }