v2board/app/Services/ServerService.php

217 lines
7.7 KiB
PHP
Raw Normal View History

2020-02-28 01:03:05 +08:00
<?php
namespace App\Services;
2020-04-25 19:44:47 +08:00
use App\Models\ServerLog;
2020-10-04 14:21:09 +08:00
use App\Models\ServerShadowsocks;
2020-02-28 01:03:05 +08:00
use App\Models\User;
2021-09-21 18:07:53 +08:00
use App\Models\ServerV2ray;
2020-06-12 00:18:35 +08:00
use App\Models\ServerTrojan;
use App\Utils\CacheKey;
2022-02-17 02:44:49 +08:00
use App\Utils\Helper;
2020-06-12 00:18:35 +08:00
use Illuminate\Support\Facades\Cache;
2020-02-28 01:03:05 +08:00
class ServerService
{
2020-03-10 13:11:31 +08:00
2020-11-14 17:26:17 +08:00
public function getV2ray(User $user, $all = false):array
2020-06-12 00:18:35 +08:00
{
2020-11-16 11:58:34 +08:00
$servers = [];
2021-09-21 18:07:53 +08:00
$model = ServerV2ray::orderBy('sort', 'ASC');
2020-06-12 00:18:35 +08:00
if (!$all) {
$model->where('show', 1);
}
2020-11-16 11:58:34 +08:00
$v2ray = $model->get();
for ($i = 0; $i < count($v2ray); $i++) {
$v2ray[$i]['type'] = 'v2ray';
2021-08-06 00:43:01 +08:00
$groupId = $v2ray[$i]['group_id'];
2022-02-19 13:45:57 +08:00
if (!in_array($user->group_id, $groupId)) continue;
2022-02-17 03:17:05 +08:00
if (strpos($v2ray[$i]['port'], '-') !== false) {
$v2ray[$i]['port'] = Helper::randomPort($v2ray[$i]['port']);
}
2022-02-19 13:45:57 +08:00
if ($v2ray[$i]['parent_id']) {
$v2ray[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_V2RAY_LAST_CHECK_AT', $v2ray[$i]['parent_id']));
} else {
$v2ray[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_V2RAY_LAST_CHECK_AT', $v2ray[$i]['id']));
2022-02-17 02:44:49 +08:00
}
2022-02-19 13:45:57 +08:00
array_push($servers, $v2ray[$i]->toArray());
2020-06-12 00:18:35 +08:00
}
2020-11-16 11:58:34 +08:00
return $servers;
2020-06-12 00:18:35 +08:00
}
2020-11-15 15:25:32 +08:00
public function getTrojan(User $user, $all = false):array
2020-06-12 00:18:35 +08:00
{
2020-11-16 11:58:34 +08:00
$servers = [];
2020-06-12 00:18:35 +08:00
$model = ServerTrojan::orderBy('sort', 'ASC');
if (!$all) {
$model->where('show', 1);
}
2020-11-15 15:25:32 +08:00
$trojan = $model->get();
for ($i = 0; $i < count($trojan); $i++) {
$trojan[$i]['type'] = 'trojan';
2021-08-06 00:43:01 +08:00
$groupId = $trojan[$i]['group_id'];
2022-02-19 13:45:57 +08:00
if (!in_array($user->group_id, $groupId)) continue;
2022-02-17 03:17:05 +08:00
if (strpos($trojan[$i]['port'], '-') !== false) {
$trojan[$i]['port'] = Helper::randomPort($trojan[$i]['port']);
}
2022-02-19 13:45:57 +08:00
if ($trojan[$i]['parent_id']) {
$trojan[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_TROJAN_LAST_CHECK_AT', $trojan[$i]['parent_id']));
} else {
$trojan[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_TROJAN_LAST_CHECK_AT', $trojan[$i]['id']));
2022-02-17 02:44:49 +08:00
}
2022-02-19 13:45:57 +08:00
array_push($servers, $trojan[$i]->toArray());
2020-06-12 00:18:35 +08:00
}
2020-11-16 11:58:34 +08:00
return $servers;
2020-06-12 00:18:35 +08:00
}
2020-10-04 14:21:09 +08:00
public function getShadowsocks(User $user, $all = false)
{
2020-11-16 11:58:34 +08:00
$servers = [];
2020-10-04 14:21:09 +08:00
$model = ServerShadowsocks::orderBy('sort', 'ASC');
if (!$all) {
$model->where('show', 1);
}
2020-11-15 15:25:32 +08:00
$shadowsocks = $model->get();
for ($i = 0; $i < count($shadowsocks); $i++) {
$shadowsocks[$i]['type'] = 'shadowsocks';
2021-08-06 00:43:01 +08:00
$groupId = $shadowsocks[$i]['group_id'];
2022-02-19 13:45:57 +08:00
if (!in_array($user->group_id, $groupId)) continue;
2022-02-17 03:17:05 +08:00
if (strpos($shadowsocks[$i]['port'], '-') !== false) {
$shadowsocks[$i]['port'] = Helper::randomPort($shadowsocks[$i]['port']);
}
2022-02-19 13:45:57 +08:00
if ($shadowsocks[$i]['parent_id']) {
$shadowsocks[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_SHADOWSOCKS_LAST_CHECK_AT', $shadowsocks[$i]['parent_id']));
} else {
$shadowsocks[$i]['last_check_at'] = Cache::get(CacheKey::get('SERVER_SHADOWSOCKS_LAST_CHECK_AT', $shadowsocks[$i]['id']));
2022-02-17 02:44:49 +08:00
}
2022-02-19 13:45:57 +08:00
array_push($servers, $shadowsocks[$i]->toArray());
2020-10-04 14:21:09 +08:00
}
2020-11-16 11:58:34 +08:00
return $servers;
2020-10-04 14:21:09 +08:00
}
2020-11-14 17:26:17 +08:00
public function getAvailableServers(User $user, $all = false)
2020-06-12 00:18:35 +08:00
{
2020-11-14 17:26:17 +08:00
$servers = array_merge(
$this->getShadowsocks($user, $all),
$this->getV2ray($user, $all),
$this->getTrojan($user, $all)
);
$tmp = array_column($servers, 'sort');
array_multisort($tmp, SORT_ASC, $servers);
return $servers;
2020-06-12 00:18:35 +08:00
}
2020-02-28 01:03:05 +08:00
public function getAvailableUsers($groupId)
{
return User::whereIn('group_id', $groupId)
->whereRaw('u + d < transfer_enable')
->where(function ($query) {
$query->where('expired_at', '>=', time())
2020-03-01 23:29:49 +08:00
->orWhere('expired_at', NULL);
2020-02-28 01:03:05 +08:00
})
2020-03-02 20:47:52 +08:00
->where('banned', 0)
2020-02-28 01:03:05 +08:00
->select([
'id',
2020-11-17 21:23:16 +08:00
'uuid'
2020-02-28 01:03:05 +08:00
])
->get();
}
2020-03-10 13:11:31 +08:00
2020-06-11 20:47:02 +08:00
public function log(int $userId, int $serverId, int $u, int $d, float $rate, string $method)
2020-04-25 19:44:47 +08:00
{
2021-09-01 02:32:15 +08:00
if (($u + $d) < 10240) return true;
2021-09-02 20:09:04 +08:00
$timestamp = strtotime(date('Y-m-d'));
2020-05-11 17:19:58 +08:00
$serverLog = ServerLog::where('log_at', '>=', $timestamp)
->where('log_at', '<', $timestamp + 3600)
->where('server_id', $serverId)
->where('user_id', $userId)
->where('rate', $rate)
2020-06-11 20:47:02 +08:00
->where('method', $method)
2020-05-11 17:19:58 +08:00
->first();
if ($serverLog) {
2021-09-02 23:31:12 +08:00
try {
$serverLog->increment('u', $u);
$serverLog->increment('d', $d);
return true;
} catch (\Exception $e) {
return false;
}
2020-05-11 17:19:58 +08:00
} else {
$serverLog = new ServerLog();
$serverLog->user_id = $userId;
$serverLog->server_id = $serverId;
$serverLog->u = $u;
$serverLog->d = $d;
$serverLog->rate = $rate;
$serverLog->log_at = $timestamp;
2020-06-11 20:47:02 +08:00
$serverLog->method = $method;
2021-08-31 23:55:07 +08:00
return $serverLog->save();
2020-05-11 17:19:58 +08:00
}
2020-04-25 19:44:47 +08:00
}
2020-11-14 17:26:17 +08:00
public function getShadowsocksServers()
{
$server = ServerShadowsocks::orderBy('sort', 'ASC')->get();
for ($i = 0; $i < count($server); $i++) {
$server[$i]['type'] = 'shadowsocks';
}
return $server->toArray();
}
public function getV2rayServers()
{
2021-09-21 18:07:53 +08:00
$server = ServerV2ray::orderBy('sort', 'ASC')->get();
2020-11-14 17:26:17 +08:00
for ($i = 0; $i < count($server); $i++) {
$server[$i]['type'] = 'v2ray';
}
return $server->toArray();
}
public function getTrojanServers()
{
$server = ServerTrojan::orderBy('sort', 'ASC')->get();
for ($i = 0; $i < count($server); $i++) {
$server[$i]['type'] = 'trojan';
2021-03-24 15:04:09 +08:00
}
return $server->toArray();
}
public function mergeData(&$servers)
{
foreach ($servers as $k => $v) {
$serverType = strtoupper($servers[$k]['type']);
$servers[$k]['online'] = Cache::get(CacheKey::get("SERVER_{$serverType}_ONLINE_USER", $servers[$k]['parent_id'] ? $servers[$k]['parent_id'] : $servers[$k]['id']));
if ($servers[$k]['parent_id']) {
$servers[$k]['last_check_at'] = Cache::get(CacheKey::get("SERVER_{$serverType}_LAST_CHECK_AT", $servers[$k]['parent_id']));
$servers[$k]['last_push_at'] = Cache::get(CacheKey::get("SERVER_{$serverType}_LAST_PUSH_AT", $servers[$k]['parent_id']));
2020-11-14 17:26:17 +08:00
} else {
2021-03-24 15:04:09 +08:00
$servers[$k]['last_check_at'] = Cache::get(CacheKey::get("SERVER_{$serverType}_LAST_CHECK_AT", $servers[$k]['id']));
$servers[$k]['last_push_at'] = Cache::get(CacheKey::get("SERVER_{$serverType}_LAST_PUSH_AT", $servers[$k]['id']));
}
if ((time() - 300) >= $servers[$k]['last_check_at']) {
$servers[$k]['available_status'] = 0;
} else if ((time() - 300) >= $servers[$k]['last_push_at']) {
$servers[$k]['available_status'] = 1;
} else {
$servers[$k]['available_status'] = 2;
2020-11-14 17:26:17 +08:00
}
}
}
2021-06-08 19:07:10 +08:00
public function getAllServers()
{
$servers = array_merge(
$this->getShadowsocksServers(),
$this->getV2rayServers(),
$this->getTrojanServers()
);
$this->mergeData($servers);
$tmp = array_column($servers, 'sort');
array_multisort($tmp, SORT_ASC, $servers);
return $servers;
}
2020-02-28 01:03:05 +08:00
}