ProxyPanel/app/Http/Controllers/Mu/v2ray/NodeController.php

<?php

namespace App\Http\Controllers\Muv2;

use App\Http\Controllers\Controller;
use App\Http\Models\SsNode;
use App\Http\Models\SsNodeInfo;
use App\Http\Models\SsNodeLabel;
use App\Http\Models\SsNodeOnlineLog;
use App\Http\Models\User;
use App\Http\Models\UserLabel;
use App\Http\Models\UserTrafficLog;
use App\Http\V2ray\V2rayGenerator;
use Illuminate\Http\Request;
use Response;

class NodeController extends Controller
{
    protected static $config;
    protected static $userLevel;

    function __construct()
    {
        self::$config = $this->systemConfig();
    }

    //V2ray 用户
    public function users(Request $request)
    {
        $node_id = $request->route('id');
        $ssr_node = SsNode::query()->where('id', $node_id)->first(); // 节点是否存在
        if ($ssr_node == null) {
            $res = [
                "ret" => 0
            ];

            return Response::json($res, 400);
        }

        // 找出该节点的标签id
        $ssr_node_label = SsNodeLabel::query()->where('node_id', $node_id)->pluck('label_id');

        //找出有这个标签的用户
        $user_with_label = UserLabel::query()->whereIn('label_id', $ssr_node_label)->pluck('user_id');

        //提取用户信息
        $userids = User::query()->whereIn('id', $user_with_label)->where('enable', 1)->where('id', '<>', self::$config['free_node_users_id'])->pluck('id')->toArray();
        $users = User::query()->where('id', '<>', self::$config['free_node_users_id'])->select(
                "id", "username", "passwd", "t", "u", "d", "transfer_enable",
                "port", "protocol", "obfs", "enable", "expire_time as expire_time_d", "method",
                "v2ray_uuid", "v2ray_level", "v2ray_alter_id")->get();

        $data = [];
        foreach ($users as $user) {
            //datetime 转timestamp
            $user['switch'] = 1;
            $user['email'] = $user['username'];
            $user['expire_time'] = strval((new \DateTime($user['expire_time_d']))->getTimestamp());
            if (in_array($user->id, $userids)) {
                $user->enable = 1;
            } else {
                $user->enable = 0;
            }

            //v2ray用户信息
            $user->v2ray_user = [
                "uuid"     => $user->v2ray_uuid,
                "email"    => sprintf("%[email protected]", $user->v2ray_uuid),
                "alter_id" => $user->v2ray_alter_id,
                "level"    => $user->v2ray_level,
            ];

            array_push($data, $user);
        }

        if (self::$config['is_free_node']) {
            if (self::$config['free_node_id'] == $node_id) {
                $user = User::query()->whereIn('id', $user_with_label)->where('id', self::$config['free_node_users_id'])->select(
                        "id", "enable", "username", "passwd", "t", "u", "d", "transfer_enable",
                        "port", "protocol", "obfs", "enable", "expire_time as expire_time_d", "method",
                        "v2ray_uuid", "v2ray_level", "v2ray_alter_id")->first();

                //datetime 转timestamp
                $user['switch'] = 1;
                $user['email'] = $user['username'];
                $user['expire_time'] = strval((new \DateTime($user['expire_time_d']))->getTimestamp());

                //v2ray用户信息
                $user->v2ray_user = [
                    "uuid"     => $user->v2ray_uuid,
                    "email"    => sprintf("%[email protected]", $user->v2ray_uuid),
                    "alter_id" => $user->v2ray_alter_id,
                    "level"    => $user->v2ray_level,
                ];

                array_push($data, $user);
            }
        }

        $load = '1';
        $uptime = time();

        $log = new SsNodeInfo();
        $log->node_id = $node_id;
        $log->load = $load;
        $log->uptime = $uptime;
        $log->log_time = time();
        $log->save();

        $res = [
            'msg'  => 'ok',
            'data' => $data,
        ];

        return Response::json($res);
    }

    //写在线用户日志
    public function onlineUserLog(Request $request)
    {
        $node_id = $request->route('id');
        $count = $request->get('count');
        $log = new SsNodeOnlineLog();
        $log->node_id = $node_id;
        $log->online_user = $count;
        $log->log_time = time();

        if (!$log->save()) {
            $res = [
                "ret" => 0,
                "msg" => "update failed",
            ];

            return response()->json($res);
        }

        $res = [
            "ret" => 1,
            "msg" => "ok",
        ];

        return response()->json($res);
    }

    //节点信息
    public function info(Request $request)
    {
        $node_id = $request->route('id');
        $load = $request->get('load');
        $uptime = $request->get('uptime');

        $log = new SsNodeInfo();
        $log->node_id = $node_id;
        $log->load = $load;
        $log->uptime = $uptime;
        $log->log_time = time();

        if (!$log->save()) {
            $res = [
                "ret" => 0,
                "msg" => "update failed",
            ];

            return response()->json($res);
        }

        $res = [
            "ret" => 1,
            "msg" => "ok",
        ];

        return response()->json($res);
    }

    //PostTraffic
    public function postTraffic(Request $request)
    {
        $nodeId = $request->route('id');
        $node = SsNode::query()->where('id', $nodeId)->first();
        $rate = $node->traffic_rate;
        $input = $request->getContent();
        $datas = json_decode($input, true);

        foreach ($datas as $data) {
            $user = User::query()->where('id', $data['user_id'])->first();
            if (!$user) {
                continue;
            }

            $user->t = time();
            $user->u = $user->u + ($data['u'] * $rate);
            $user->d = $user->d + ($data['d'] * $rate);
            $user->save();

            // 写usertrafficlog
            $totalTraffic = flowAutoShow(($data['u'] + $data['d']) * $rate);
            $traffic = new UserTrafficLog();
            $traffic->user_id = $data['user_id'];
            $traffic->u = $data['u'];
            $traffic->d = $data['d'];
            $traffic->node_id = $nodeId;
            $traffic->rate = $rate;
            $traffic->traffic = $totalTraffic;
            $traffic->log_time = time();
            $traffic->save();
        }

        $res = [
            'ret' => 1,
            "msg" => "ok",
        ];

        return response()->json($res);
    }

    //V2ray Users
    public function v2rayUsers(Request $request)
    {
        $node = SsNode::query()->where('id', $request->route('id'))->first();
        $users = User::query()->where('enable', 1)->where('id', '<>', self::$config['free_node_users_id'])->get();

        $v = new V2rayGenerator();
        $v->setPort($node->v2ray_port);

        foreach ($users as $user) {
            $email = sprintf("%[email protected]", $user->v2ray_uuid);
            $v->addUser($user->v2ray_uuid, $user->v2ray_level, $user->v2ray_alter_id, $email);
        }

        if (self::$config['is_free_node']) {
            if ($request->route('id') == self::$config['free_node_id']) {
                $freeuser = User::query()->where('enable', 1)->where('id', self::$config['free_node_users_id'])->first();
                $email = sprintf("%[email protected]", $freeuser->v2ray_uuid);
                $v->addUser($freeuser->v2ray_uuid, $freeuser->v2ray_level, $freeuser->v2ray_alter_id, $email);
            }
        }

        return Response::json($v->getArr());
    }
}