ServerService.php 15 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360
  1. <?php
  2. namespace App\Services;
  3. use App\Models\ServerLog;
  4. use App\Models\ServerShadowsocks;
  5. use App\Models\User;
  6. use App\Models\Server;
  7. use App\Models\ServerTrojan;
  8. use App\Utils\CacheKey;
  9. use App\Utils\Helper;
  10. use App\Utils\URLSchemes;
  11. use Illuminate\Support\Facades\Cache;
  12. class ServerService
  13. {
  14. CONST V2RAY_CONFIG = '{"api":{"services":["HandlerService","StatsService"],"tag":"api"},"dns":{},"stats":{},"inbound":{"port":443,"protocol":"vmess","settings":{"clients":[]},"sniffing":{"enabled":true,"destOverride":["http","tls"]},"streamSettings":{"network":"tcp"},"tag":"proxy"},"inboundDetour":[{"listen":"127.0.0.1","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":{}},"outboundDetour":[{"protocol":"blackhole","settings":{},"tag":"block"}],"routing":{"rules":[{"inboundTag":"api","outboundTag":"api","type":"field"}]},"policy":{"levels":{"0":{"handshake":4,"connIdle":300,"uplinkOnly":5,"downlinkOnly":30,"statsUserUplink":true,"statsUserDownlink":true}}}}';
  15. CONST TROJAN_CONFIG = '{"run_type":"server","local_addr":"0.0.0.0","local_port":443,"remote_addr":"www.taobao.com","remote_port":80,"password":[],"ssl":{"cert":"server.crt","key":"server.key","sni":"domain.com"},"api":{"enabled":true,"api_addr":"127.0.0.1","api_port":10000}}';
  16. public function getV2ray(User $user, $all = false):array
  17. {
  18. $servers = [];
  19. $model = Server::orderBy('sort', 'ASC');
  20. if (!$all) {
  21. $model->where('show', 1);
  22. }
  23. $v2ray = $model->get();
  24. for ($i = 0; $i < count($v2ray); $i++) {
  25. $v2ray[$i]['type'] = 'v2ray';
  26. $groupId = json_decode($v2ray[$i]['group_id']);
  27. if (in_array($user->group_id, $groupId)) {
  28. $v2ray[$i]['link'] = URLSchemes::buildVmess($v2ray[$i], $user);
  29. if ($v2ray[$i]['parent_id']) {
  30. $v2ray[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_V2RAY_LAST_CHECK_AT', $v2ray[$i]['parent_id']));
  31. } else {
  32. $v2ray[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_V2RAY_LAST_CHECK_AT', $v2ray[$i]['id']));
  33. }
  34. array_push($servers, $v2ray[$i]->toArray());
  35. }
  36. }
  37. return $servers;
  38. }
  39. public function getTrojan(User $user, $all = false):array
  40. {
  41. $servers = [];
  42. $model = ServerTrojan::orderBy('sort', 'ASC');
  43. if (!$all) {
  44. $model->where('show', 1);
  45. }
  46. $trojan = $model->get();
  47. for ($i = 0; $i < count($trojan); $i++) {
  48. $trojan[$i]['type'] = 'trojan';
  49. $groupId = json_decode($trojan[$i]['group_id']);
  50. $trojan[$i]['link'] = URLSchemes::buildTrojan($trojan[$i], $user);
  51. if (in_array($user->group_id, $groupId)) {
  52. if ($trojan[$i]['parent_id']) {
  53. $trojan[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_TROJAN_LAST_CHECK_AT', $trojan[$i]['parent_id']));
  54. } else {
  55. $trojan[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_TROJAN_LAST_CHECK_AT', $trojan[$i]['id']));
  56. }
  57. array_push($servers, $trojan[$i]->toArray());
  58. }
  59. }
  60. return $servers;
  61. }
  62. public function getShadowsocks(User $user, $all = false)
  63. {
  64. $servers = [];
  65. $model = ServerShadowsocks::orderBy('sort', 'ASC');
  66. if (!$all) {
  67. $model->where('show', 1);
  68. }
  69. $shadowsocks = $model->get();
  70. for ($i = 0; $i < count($shadowsocks); $i++) {
  71. $shadowsocks[$i]['type'] = 'shadowsocks';
  72. $groupId = json_decode($shadowsocks[$i]['group_id']);
  73. $shadowsocks[$i]['link'] = URLSchemes::buildShadowsocks($shadowsocks[$i], $user);
  74. if (in_array($user->group_id, $groupId)) {
  75. if ($shadowsocks[$i]['parent_id']) {
  76. $shadowsocks[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_SHADOWSOCKS_LAST_CHECK_AT', $shadowsocks[$i]['parent_id']));
  77. } else {
  78. $shadowsocks[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_SHADOWSOCKS_LAST_CHECK_AT', $shadowsocks[$i]['id']));
  79. }
  80. array_push($servers, $shadowsocks[$i]->toArray());
  81. }
  82. }
  83. return $servers;
  84. }
  85. public function getAvailableServers(User $user, $all = false)
  86. {
  87. $servers = array_merge(
  88. $this->getShadowsocks($user, $all),
  89. $this->getV2ray($user, $all),
  90. $this->getTrojan($user, $all)
  91. );
  92. $tmp = array_column($servers, 'sort');
  93. array_multisort($tmp, SORT_ASC, $servers);
  94. return $servers;
  95. }
  96. public function getAvailableUsers($groupId)
  97. {
  98. return User::whereIn('group_id', $groupId)
  99. ->whereRaw('u + d < transfer_enable')
  100. ->where(function ($query) {
  101. $query->where('expired_at', '>=', time())
  102. ->orWhere('expired_at', NULL);
  103. })
  104. ->where('banned', 0)
  105. ->select([
  106. 'id',
  107. 'email',
  108. 't',
  109. 'u',
  110. 'd',
  111. 'transfer_enable',
  112. 'uuid'
  113. ])
  114. ->get();
  115. }
  116. public function getVmessConfig(int $nodeId, int $localPort)
  117. {
  118. $server = Server::find($nodeId);
  119. if (!$server) {
  120. abort(500, '节点不存在');
  121. }
  122. $json = json_decode(self::V2RAY_CONFIG);
  123. $json->log->loglevel = (int)config('v2board.server_log_enable') ? 'debug' : 'none';
  124. $json->inboundDetour[0]->port = (int)$localPort;
  125. $json->inbound->port = (int)$server->server_port;
  126. $json->inbound->streamSettings->network = $server->network;
  127. $this->setDns($server, $json);
  128. $this->setNetwork($server, $json);
  129. $this->setRule($server, $json);
  130. $this->setTls($server, $json);
  131. return $json;
  132. }
  133. public function getTrojanConfig(int $nodeId, int $localPort)
  134. {
  135. $server = ServerTrojan::find($nodeId);
  136. if (!$server) {
  137. abort(500, '节点不存在');
  138. }
  139. $json = json_decode(self::TROJAN_CONFIG);
  140. $json->local_port = $server->server_port;
  141. $json->ssl->sni = $server->server_name ? $server->server_name : $server->host;
  142. $json->ssl->cert = "/root/.cert/server.crt";
  143. $json->ssl->key = "/root/.cert/server.key";
  144. $json->api->api_port = $localPort;
  145. return $json;
  146. }
  147. private function setDns(Server $server, object $json)
  148. {
  149. if ($server->dnsSettings) {
  150. $dns = json_decode($server->dnsSettings);
  151. if (isset($dns->servers)) {
  152. array_push($dns->servers, '1.1.1.1');
  153. array_push($dns->servers, 'localhost');
  154. }
  155. $json->dns = $dns;
  156. $json->outbound->settings->domainStrategy = 'UseIP';
  157. }
  158. }
  159. private function setNetwork(Server $server, object $json)
  160. {
  161. if ($server->networkSettings) {
  162. switch ($server->network) {
  163. case 'tcp':
  164. $json->inbound->streamSettings->tcpSettings = json_decode($server->networkSettings);
  165. break;
  166. case 'kcp':
  167. $json->inbound->streamSettings->kcpSettings = json_decode($server->networkSettings);
  168. break;
  169. case 'ws':
  170. $json->inbound->streamSettings->wsSettings = json_decode($server->networkSettings);
  171. break;
  172. case 'http':
  173. $json->inbound->streamSettings->httpSettings = json_decode($server->networkSettings);
  174. break;
  175. case 'domainsocket':
  176. $json->inbound->streamSettings->dsSettings = json_decode($server->networkSettings);
  177. break;
  178. case 'quic':
  179. $json->inbound->streamSettings->quicSettings = json_decode($server->networkSettings);
  180. break;
  181. }
  182. }
  183. }
  184. private function setRule(Server $server, object $json)
  185. {
  186. $domainRules = array_filter(explode(PHP_EOL, config('v2board.server_v2ray_domain')));
  187. $protocolRules = array_filter(explode(PHP_EOL, config('v2board.server_v2ray_protocol')));
  188. if ($server->ruleSettings) {
  189. $ruleSettings = json_decode($server->ruleSettings);
  190. // domain
  191. if (isset($ruleSettings->domain)) {
  192. $ruleSettings->domain = array_filter($ruleSettings->domain);
  193. if (!empty($ruleSettings->domain)) {
  194. $domainRules = array_merge($domainRules, $ruleSettings->domain);
  195. }
  196. }
  197. // protocol
  198. if (isset($ruleSettings->protocol)) {
  199. $ruleSettings->protocol = array_filter($ruleSettings->protocol);
  200. if (!empty($ruleSettings->protocol)) {
  201. $protocolRules = array_merge($protocolRules, $ruleSettings->protocol);
  202. }
  203. }
  204. }
  205. if (!empty($domainRules)) {
  206. $domainObj = new \StdClass();
  207. $domainObj->type = 'field';
  208. $domainObj->domain = $domainRules;
  209. $domainObj->outboundTag = 'block';
  210. array_push($json->routing->rules, $domainObj);
  211. }
  212. if (!empty($protocolRules)) {
  213. $protocolObj = new \StdClass();
  214. $protocolObj->type = 'field';
  215. $protocolObj->protocol = $protocolRules;
  216. $protocolObj->outboundTag = 'block';
  217. array_push($json->routing->rules, $protocolObj);
  218. }
  219. if (empty($domainRules) && empty($protocolRules)) {
  220. $json->inbound->sniffing->enabled = false;
  221. }
  222. }
  223. private function setTls(Server $server, object $json)
  224. {
  225. if ((int)$server->tls) {
  226. $tlsSettings = json_decode($server->tlsSettings);
  227. $json->inbound->streamSettings->security = 'tls';
  228. $tls = (object)[
  229. 'certificateFile' => '/root/.cert/server.crt',
  230. 'keyFile' => '/root/.cert/server.key'
  231. ];
  232. $json->inbound->streamSettings->tlsSettings = new \StdClass();
  233. if (isset($tlsSettings->serverName)) {
  234. $json->inbound->streamSettings->tlsSettings->serverName = (string)$tlsSettings->serverName;
  235. }
  236. if (isset($tlsSettings->allowInsecure)) {
  237. $json->inbound->streamSettings->tlsSettings->allowInsecure = (int)$tlsSettings->allowInsecure ? true : false;
  238. }
  239. $json->inbound->streamSettings->tlsSettings->certificates[0] = $tls;
  240. }
  241. }
  242. public function log(int $userId, int $serverId, int $u, int $d, float $rate, string $method)
  243. {
  244. if (($u + $d) <= 10240) return;
  245. $timestamp = strtotime(date('Y-m-d H:0'));
  246. $serverLog = ServerLog::where('log_at', '>=', $timestamp)
  247. ->where('log_at', '<', $timestamp + 3600)
  248. ->where('server_id', $serverId)
  249. ->where('user_id', $userId)
  250. ->where('rate', $rate)
  251. ->where('method', $method)
  252. ->lockForUpdate()
  253. ->first();
  254. if ($serverLog) {
  255. $serverLog->u = $serverLog->u + $u;
  256. $serverLog->d = $serverLog->d + $d;
  257. $serverLog->save();
  258. } else {
  259. $serverLog = new ServerLog();
  260. $serverLog->user_id = $userId;
  261. $serverLog->server_id = $serverId;
  262. $serverLog->u = $u;
  263. $serverLog->d = $d;
  264. $serverLog->rate = $rate;
  265. $serverLog->log_at = $timestamp;
  266. $serverLog->method = $method;
  267. $serverLog->save();
  268. }
  269. }
  270. public function getShadowsocksServers()
  271. {
  272. $server = ServerShadowsocks::orderBy('sort', 'ASC')->get();
  273. for ($i = 0; $i < count($server); $i++) {
  274. $server[$i]['type'] = 'shadowsocks';
  275. if (!empty($server[$i]['tags'])) {
  276. $server[$i]['tags'] = json_decode($server[$i]['tags']);
  277. }
  278. $server[$i]['group_id'] = json_decode($server[$i]['group_id']);
  279. $server[$i]['online'] = Cache::get(CacheKey::get('SERVER_SHADOWSOCKS_ONLINE_USER', $server[$i]['parent_id'] ? $server[$i]['parent_id'] : $server[$i]['id']));
  280. if ($server[$i]['parent_id']) {
  281. $server[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_SHADOWSOCKS_LAST_CHECK_AT', $server[$i]['parent_id']));
  282. } else {
  283. $server[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_SHADOWSOCKS_LAST_CHECK_AT', $server[$i]['id']));
  284. }
  285. $server[$i]['available'] = (time() - 300) < $server[$i]['last_check_at'];
  286. }
  287. return $server->toArray();
  288. }
  289. public function getV2rayServers()
  290. {
  291. $server = Server::orderBy('sort', 'ASC')->get();
  292. for ($i = 0; $i < count($server); $i++) {
  293. $server[$i]['type'] = 'v2ray';
  294. if (!empty($server[$i]['tags'])) {
  295. $server[$i]['tags'] = json_decode($server[$i]['tags']);
  296. }
  297. if (!empty($server[$i]['dnsSettings'])) {
  298. $server[$i]['dnsSettings'] = json_decode($server[$i]['dnsSettings']);
  299. }
  300. if (!empty($server[$i]['tlsSettings'])) {
  301. $server[$i]['tlsSettings'] = json_decode($server[$i]['tlsSettings']);
  302. }
  303. if (!empty($server[$i]['ruleSettings'])) {
  304. $server[$i]['ruleSettings'] = json_decode($server[$i]['ruleSettings']);
  305. }
  306. $server[$i]['group_id'] = json_decode($server[$i]['group_id']);
  307. $server[$i]['online'] = Cache::get(CacheKey::get('SERVER_V2RAY_ONLINE_USER', $server[$i]['parent_id'] ? $server[$i]['parent_id'] : $server[$i]['id']));
  308. if ($server[$i]['parent_id']) {
  309. $server[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_V2RAY_LAST_CHECK_AT', $server[$i]['parent_id']));
  310. } else {
  311. $server[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_V2RAY_LAST_CHECK_AT', $server[$i]['id']));
  312. }
  313. $server[$i]['available'] = (time() - 300) < $server[$i]['last_check_at'];
  314. }
  315. return $server->toArray();
  316. }
  317. public function getTrojanServers()
  318. {
  319. $server = ServerTrojan::orderBy('sort', 'ASC')->get();
  320. for ($i = 0; $i < count($server); $i++) {
  321. $server[$i]['type'] = 'trojan';
  322. if (!empty($server[$i]['tags'])) {
  323. $server[$i]['tags'] = json_decode($server[$i]['tags']);
  324. }
  325. $server[$i]['group_id'] = json_decode($server[$i]['group_id']);
  326. $server[$i]['online'] = Cache::get(CacheKey::get('SERVER_TROJAN_ONLINE_USER', $server[$i]['parent_id'] ? $server[$i]['parent_id'] : $server[$i]['id']));
  327. if ($server[$i]['parent_id']) {
  328. $server[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_TROJAN_LAST_CHECK_AT', $server[$i]['parent_id']));
  329. } else {
  330. $server[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_TROJAN_LAST_CHECK_AT', $server[$i]['id']));
  331. }
  332. $server[$i]['available'] = (time() - 300) < $server[$i]['last_check_at'];
  333. }
  334. return $server->toArray();
  335. }
  336. }