合并device_limit分支：增加面板设备数限制功能

2025-09-19 12:43:05 +08:00 · 2023-10-19 03:00:06 +09:00
parent 82640f047f 0c9aab2236
commit 6417dda334
19 changed files with 143 additions and 8 deletions
--- a/app/Http/Controllers/V1/Admin/PlanController.php
+++ b/app/Http/Controllers/V1/Admin/PlanController.php
@ -45,6 +45,7 @@ class PlanController extends Controller
                    User::where('plan_id', $plan->id)->update([
                        'group_id' => $params['group_id'],
                        'transfer_enable' => $params['transfer_enable'] * 1073741824,
+                        'device_limit' => $params['device_limit'],
                        'speed_limit' => $params['speed_limit']
                    ]);
                }
--- a/app/Http/Controllers/V1/Admin/UserController.php
+++ b/app/Http/Controllers/V1/Admin/UserController.php
@ -157,16 +157,17 @@ class UserController extends Controller
            }
        }

-        $data = "邮箱,余额,推广佣金,总流量,剩余流量,套餐到期时间,订阅计划,订阅地址\r\n";
+        $data = "邮箱,余额,推广佣金,总流量,设备数限制,剩余流量,套餐到期时间,订阅计划,订阅地址\r\n";
        foreach($res as $user) {
            $expireDate = $user['expired_at'] === NULL ? '长期有效' : date('Y-m-d H:i:s', $user['expired_at']);
            $balance = $user['balance'] / 100;
            $commissionBalance = $user['commission_balance'] / 100;
            $transferEnable = $user['transfer_enable'] ? $user['transfer_enable'] / 1073741824 : 0;
+            $deviceLimit = $user['devce_limit'] ? $user['devce_limit'] : NULL;
            $notUseFlow = (($user['transfer_enable'] - ($user['u'] + $user['d'])) / 1073741824) ?? 0;
            $planName = $user['plan_name'] ?? '无订阅';
            $subscribeUrl = Helper::getSubscribeUrl('/api/v1/client/subscribe?token=' . $user['token']);
-            $data .= "{$user['email']},{$balance},{$commissionBalance},{$transferEnable},{$notUseFlow},{$expireDate},{$planName},{$subscribeUrl}\r\n";
+            $data .= "{$user['email']},{$balance},{$commissionBalance},{$transferEnable}, {$deviceLimit}, {$notUseFlow},{$expireDate},{$planName},{$subscribeUrl}\r\n";
        }
        echo "\xEF\xBB\xBF" . $data;
    }
@ -185,6 +186,7 @@ class UserController extends Controller
                'plan_id' => isset($plan->id) ? $plan->id : NULL,
                'group_id' => isset($plan->group_id) ? $plan->group_id : NULL,
                'transfer_enable' => isset($plan->transfer_enable) ? $plan->transfer_enable * 1073741824 : 0,
+                'device_limit' => isset($plan->device_limit) ? $plan->device_limit : NULL,
                'expired_at' => $request->input('expired_at') ?? NULL,
                'uuid' => Helper::guid(true),
                'token' => Helper::guid()
@ -220,6 +222,7 @@ class UserController extends Controller
                'plan_id' => isset($plan->id) ? $plan->id : NULL,
                'group_id' => isset($plan->group_id) ? $plan->group_id : NULL,
                'transfer_enable' => isset($plan->transfer_enable) ? $plan->transfer_enable * 1073741824 : 0,
+                'device_limit' => isset($plan->device_limit) ? $plan->device_limit : NULL,
                'expired_at' => $request->input('expired_at') ?? NULL,
                'uuid' => Helper::guid(true),
                'token' => Helper::guid(),
--- a/app/Http/Controllers/V1/Passport/AuthController.php
+++ b/app/Http/Controllers/V1/Passport/AuthController.php
@ -153,6 +153,7 @@ class AuthController extends Controller
            $plan = Plan::find(config('v2board.try_out_plan_id'));
            if ($plan) {
                $user->transfer_enable = $plan->transfer_enable * 1073741824;
+                $user->device_limit = $plan->device_limit;
                $user->plan_id = $plan->id;
                $user->group_id = $plan->group_id;
                $user->expired_at = time() + (config('v2board.try_out_hour', 1) * 3600);
--- a/app/Http/Controllers/V1/Server/UniProxyController.php
+++ b/app/Http/Controllers/V1/Server/UniProxyController.php
@ -43,6 +43,20 @@ class UniProxyController extends Controller
        $users = $this->serverService->getAvailableUsers($this->nodeInfo->group_id);
        $users = $users->toArray();

+        $users = array_map(function ($user) {
+            $count =0;
+            $ips_array = Cache::get('ALIVE_IP_USER_'. $user['id']);
+            if ($ips_array) {
+                foreach ($ips_array as $nodetypeid => $ip_array) {
+                    foreach ($ip_array['aliveips'] as $ip) {
+                        $count++;
+                    }
+                }
+            }
+            $user['alive_ip'] = $count;
+            return $user;
+        }, $users);
+
        $response['users'] = $users;

        $eTag = sha1(json_encode($response));
@ -68,6 +82,41 @@ class UniProxyController extends Controller
        ]);
    }

+    // 后端提交在线数据
+    public function alive(Request $request)
+    {
+        $data = file_get_contents('php://input');
+        $data = json_decode($data, true);
+        if ($data === null && json_last_error() !== JSON_ERROR_NONE) {
+            // JSON decoding error
+            return response([
+                'error' => 'Invalid online data'
+            ], 400);
+        }
+
+        foreach ($data as $k => $v) {
+            $updateAt = time();
+            $oldips_array = Cache::get('ALIVE_IP_USER_'. $k) ?? [];
+
+            // 更新节点数据
+            $oldips_array[$this->nodeType . $this->nodeId] = ['aliveips' => $v, 'lastupdateAt' => $updateAt];
+            //删除过期节点在线数据
+            $expired_array = [];
+            foreach($oldips_array as $nodetypeid => $oldips) {
+                if ($updateAt - $oldips['lastupdateAt'] > 300){
+                    $expired_array[$nodetypeid] = '';
+                }
+            }
+            // 清理过期数据并存回缓存
+            $new_array = array_diff_key($oldips_array, $expired_array);
+            Cache::put('ALIVE_IP_USER_'. $k, $new_array, 120);
+        }
+
+        return response([
+            'data' => true
+        ]);
+    }
+
    // 后端获取配置
    public function config(Request $request)
    {
--- a/app/Http/Controllers/V1/User/UserController.php
+++ b/app/Http/Controllers/V1/User/UserController.php
@ -87,6 +87,7 @@ class UserController extends Controller
            ->select([
                'email',
                'transfer_enable',
+                'device_limit',
                'last_login_at',
                'created_at',
                'banned',
@ -138,6 +139,7 @@ class UserController extends Controller
                'u',
                'd',
                'transfer_enable',
+                'device_limit',
                'email',
                'uuid'
            ])
@ -151,6 +153,19 @@ class UserController extends Controller
                abort(500, __('Subscription plan does not exist'));
            }
        }
+
+        //统计在线设备
+        $countalive = 0;
+        $ips_array = Cache::get('ALIVE_IP_USER_'. $request->user['id']);
+        if ($ips_array) {
+            foreach ($ips_array as $nodetypeid => $ip_array) {
+                foreach ($ip_array['aliveips'] as $ip) {
+                    $countalive++;
+                }
+            }
+        }
+        $user['alive_ip'] = $countalive;
+
        $user['subscribe_url'] = Helper::getSubscribeUrl("/api/v1/client/subscribe?token={$user['token']}");
        $userService = new UserService();
        $user['reset_day'] = $userService->getResetDay($user);
--- a/app/Http/Requests/Admin/PlanSave.php
+++ b/app/Http/Requests/Admin/PlanSave.php
@ -18,6 +18,7 @@ class PlanSave extends FormRequest
            'content' => '',
            'group_id' => 'required',
            'transfer_enable' => 'required',
+            'device_limit' => 'nullable|integer',
            'month_price' => 'nullable|integer',
            'quarter_price' => 'nullable|integer',
            'half_year_price' => 'nullable|integer',
@ -40,6 +41,7 @@ class PlanSave extends FormRequest
            'type.in' => '套餐类型格式有误',
            'group_id.required' => '权限组不能为空',
            'transfer_enable.required' => '流量不能为空',
+            'device_limit.integer' => '设备数限制格式有误',
            'month_price.integer' => '月付金额格式有误',
            'quarter_price.integer' => '季付金额格式有误',
            'half_year_price.integer' => '半年付金额格式有误',
--- a/app/Http/Requests/Admin/UserFetch.php
+++ b/app/Http/Requests/Admin/UserFetch.php
@ -14,7 +14,7 @@ class UserFetch extends FormRequest
    public function rules()
    {
        return [
-            'filter.*.key' => 'required|in:id,email,transfer_enable,d,expired_at,uuid,token,invite_by_email,invite_user_id,plan_id,banned,remarks,is_admin',
+            'filter.*.key' => 'required|in:id,email,transfer_enable,device_limit,d,expired_at,uuid,token,invite_by_email,invite_user_id,plan_id,banned,remarks,is_admin',
            'filter.*.condition' => 'required|in:>,<,=,>=,<=,模糊,!=',
            'filter.*.value' => 'required'
        ];
--- a/app/Http/Requests/Admin/UserUpdate.php
+++ b/app/Http/Requests/Admin/UserUpdate.php
@ -17,6 +17,7 @@ class UserUpdate extends FormRequest
            'email' => 'required|email:strict',
            'password' => 'nullable|min:8',
            'transfer_enable' => 'numeric',
+            'device_limit' => 'nullable|integer',
            'expired_at' => 'nullable|integer',
            'banned' => 'required|in:0,1',
            'plan_id' => 'nullable|integer',
@ -40,6 +41,7 @@ class UserUpdate extends FormRequest
            'email.required' => '邮箱不能为空',
            'email.email' => '邮箱格式不正确',
            'transfer_enable.numeric' => '流量格式不正确',
+            'device_limit.integer' => '设备数限制格式不正确',
            'expired_at.integer' => '到期时间格式不正确',
            'banned.required' => '是否封禁不能为空',
            'banned.in' => '是否封禁格式不正确',
--- a/app/Http/Requests/Staff/UserUpdate.php
+++ b/app/Http/Requests/Staff/UserUpdate.php
@ -17,6 +17,7 @@ class UserUpdate extends FormRequest
            'email' => 'required|email:strict',
            'password' => 'nullable',
            'transfer_enable' => 'numeric',
+            'device_limit' => 'nullable|integer',
            'expired_at' => 'nullable|integer',
            'banned' => 'required|in:0,1',
            'plan_id' => 'nullable|integer',
@ -35,6 +36,7 @@ class UserUpdate extends FormRequest
            'email.required' => '邮箱不能为空',
            'email.email' => '邮箱格式不正确',
            'transfer_enable.numeric' => '流量格式不正确',
+            'device_limit.integer' => '设备数限制格式不正确',
            'expired_at.integer' => '到期时间格式不正确',
            'banned.required' => '是否封禁不能为空',
            'banned.in' => '是否封禁格式不正确',
--- a/app/Services/OrderService.php
+++ b/app/Services/OrderService.php
@ -269,6 +269,7 @@ class OrderService
            $this->user->expired_at = time();
        }
        $this->user->transfer_enable = $plan->transfer_enable * 1073741824;
+        $this->user->device_limit = $plan->device_limit;
        // 从一次性转换到循环
        if ($this->user->expired_at === NULL) $this->buyByResetTraffic();
        // 新购
@ -282,6 +283,7 @@ class OrderService
    {
        $this->buyByResetTraffic();
        $this->user->transfer_enable = $plan->transfer_enable * 1073741824;
+        $this->user->device_limit = $plan->device_limit;
        $this->user->plan_id = $plan->id;
        $this->user->group_id = $plan->group_id;
        $this->user->expired_at = NULL;
--- a/app/Services/ServerService.php
+++ b/app/Services/ServerService.php
@ -167,7 +167,8 @@ class ServerService
            ->select([
                'id',
                'uuid',
-                'speed_limit'
+                'speed_limit',
+                'device_limit'
            ])
            ->get();
    }