neiyou_user_web/app/Http/Controllers/AdminController.php

<?php

namespace App\Http\Controllers;

use App\Components\Helpers;
use App\Components\IPIP;
use App\Components\NetworkDetection;
use App\Components\PushNotification;
use App\Components\QQWry;
use App\Http\Models\Article;
use App\Http\Models\Config;
use App\Http\Models\Country;
use App\Http\Models\Invite;
use App\Http\Models\Label;
use App\Http\Models\Level;
use App\Http\Models\NotificationLog;
use App\Http\Models\Order;
use App\Http\Models\ReferralApply;
use App\Http\Models\ReferralLog;
use App\Http\Models\SsConfig;
use App\Http\Models\SsGroup;
use App\Http\Models\SsGroupNode;
use App\Http\Models\SsNode;
use App\Http\Models\SsNodeInfo;
use App\Http\Models\SsNodeIp;
use App\Http\Models\SsNodeLabel;
use App\Http\Models\SsNodeOnlineLog;
use App\Http\Models\SsNodePing;
use App\Http\Models\SsNodeTrafficDaily;
use App\Http\Models\SsNodeTrafficHourly;
use App\Http\Models\User;
use App\Http\Models\UserBalanceLog;
use App\Http\Models\UserBanLog;
use App\Http\Models\UserLabel;
use App\Http\Models\UserLoginLog;
use App\Http\Models\UserSubscribe;
use App\Http\Models\UserTrafficDaily;
use App\Http\Models\UserTrafficHourly;
use App\Http\Models\UserTrafficLog;
use App\Http\Models\UserTrafficModifyLog;
use Auth;
use DB;
use Exception;
use Hash;
use Illuminate\Http\Request;
use Log;
use PhpOffice\PhpSpreadsheet\Spreadsheet;
use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
use Redirect;
use Response;
use Session;

/**
 * 管理员控制器
 *
 * Class AdminController
 *
 * @package App\Http\Controllers
 */
class AdminController extends Controller {
	protected static $systemConfig;

	function __construct() {
		self::$systemConfig = Helpers::systemConfig();
	}

	public function index() {
		$past = strtotime(date('Y-m-d', strtotime("-".self::$systemConfig['expire_days']." days")));

		$view['expireDays'] = self::$systemConfig['expire_days'];
		$view['totalUserCount'] = User::query()->count(); // 总用户数
		$view['enableUserCount'] = User::query()->whereEnable(1)->count(); // 有效用户数
		$view['activeUserCount'] = User::query()->where('t', '>=', $past)->count(); // 活跃用户数
		$view['unActiveUserCount'] = User::query()
		                                 ->where('t', '<=', $past)
		                                 ->whereEnable(1)
		                                 ->where('t', '>', 0)
		                                 ->count(); // 不活跃用户数
		$view['onlineUserCount'] = User::query()->where('t', '>=', time() - 600)->count(); // 10分钟内在线用户数
		$view['expireWarningUserCount'] = User::query()
		                                      ->where('expire_time', '>=', date('Y-m-d', strtotime("now")))
		                                      ->where('expire_time', '<=', date('Y-m-d',
		                                                                        strtotime("+".self::$systemConfig['expire_days']." days")))
		                                      ->count(); // 临近过期用户数
		$view['largeTrafficUserCount'] = User::query()
		                                     ->whereRaw('(u + d) >= 107374182400')
		                                     ->whereIn('status', [0, 1])
		                                     ->count(); // 流量超过100G的用户

		// 1小时内流量异常用户
		$tempUsers = [];
		$userTotalTrafficList = UserTrafficHourly::query()
		                                         ->whereNodeId(0)
		                                         ->where('total', '>', 104857600)
		                                         ->where('created_at', '>=', date('Y-m-d H:i:s', time() - 3900))
		                                         ->groupBy('user_id')
		                                         ->selectRaw("user_id, sum(total) as totalTraffic")
		                                         ->get(); // 只统计100M以上的记录，加快速度
		if(!$userTotalTrafficList->isEmpty()){
			foreach($userTotalTrafficList as $vo){
				if($vo->totalTraffic > (self::$systemConfig['traffic_ban_value'] * 1073741824)){
					$tempUsers[] = $vo->user_id;
				}
			}
		}
		$view['flowAbnormalUserCount'] = User::query()->whereIn('id', $tempUsers)->count();
		$view['nodeCount'] = SsNode::query()->count();
		$view['unnormalNodeCount'] = SsNode::query()->whereStatus(0)->count();
		$flowCount = SsNodeTrafficDaily::query()
		                               ->where('created_at', '>=', date('Y-m-d 00:00:00', strtotime("-30 days")))
		                               ->sum('total');
		$view['flowCount'] = flowAutoShow($flowCount);
		$totalFlowCount = SsNodeTrafficDaily::query()->sum('total');
		$view['totalFlowCount'] = flowAutoShow($totalFlowCount);
		$view['totalBalance'] = User::query()->sum('balance') / 100;
		$view['totalWaitRefAmount'] = ReferralLog::query()->whereIn('status', [0, 1])->sum('ref_amount') / 100;
		$view['totalRefAmount'] = ReferralApply::query()->whereStatus(2)->sum('amount') / 100;
		$view['totalOrder'] = Order::query()->count();
		$view['totalOnlinePayOrder'] = Order::query()->wherePayWay(2)->count();
		$view['totalSuccessOrder'] = Order::query()->whereStatus(2)->count();
		$view['todaySuccessOrder'] = Order::query()
		                                  ->whereStatus(2)
		                                  ->where('created_at', '>=', date('Y-m-d 00:00:00'))
		                                  ->where('created_at', '<=', date('Y-m-d 23:59:59'))
		                                  ->count();

		return Response::view('admin.index', $view);
	}

	// 用户列表
	public function userList(Request $request) {
		$id = $request->input('id');
		$email = $request->input('email');
		$wechat = $request->input('wechat');
		$qq = $request->input('qq');
		$port = $request->input('port');
		$pay_way = $request->input('pay_way');
		$status = $request->input('status');
		$enable = $request->input('enable');
		$online = $request->input('online');
		$unActive = $request->input('unActive');
		$flowAbnormal = $request->input('flowAbnormal');
		$expireWarning = $request->input('expireWarning');
		$largeTraffic = $request->input('largeTraffic');

		$query = User::query()->with(['subscribe']);
		if(isset($id)){
			$query->whereId($id);
		}

		if(isset($email)){
			$query->where('email', 'like', '%'.$email.'%');
		}

		if(isset($wechat)){
			$query->where('wechat', 'like', '%'.$wechat.'%');
		}

		if(isset($qq)){
			$query->where('qq', 'like', '%'.$qq.'%');
		}

		if(isset($port)){
			$query->wherePort($port);
		}

		if(isset($pay_way)){
			$query->wherePayWay($pay_way);
		}

		if(isset($status)){
			$query->whereStatus($status);
		}

		if(isset($enable)){
			$query->whereEnable($enable);
		}

		// 流量超过100G的
		if($largeTraffic){
			$query->whereIn('status', [0, 1])->whereRaw('(u + d) >= 107374182400');
		}

		// 临近过期提醒
		if($expireWarning){
			$query->where('expire_time', '>=', date('Y-m-d'))
			      ->where('expire_time', '<=',
			              date('Y-m-d', strtotime("+".self::$systemConfig['expire_days']." days")));
		}

		// 当前在线
		if($online){
			$query->where('t', '>=', time() - 600);
		}

		// 不活跃用户
		if($unActive){
			$query->where('t', '>', 0)
			      ->where('t', '<=',
			              strtotime(date('Y-m-d', strtotime("-".self::$systemConfig['expire_days']." days"))))
			      ->whereEnable(1);
		}

		// 1小时内流量异常用户
		if($flowAbnormal){
			$tempUsers = [];
			$userTotalTrafficList = UserTrafficHourly::query()
			                                         ->whereNodeId(0)
			                                         ->where('total', '>', 104857600)
			                                         ->where('created_at', '>=', date('Y-m-d H:i:s', time() - 3900))
			                                         ->groupBy('user_id')
			                                         ->selectRaw("user_id, sum(total) as totalTraffic")
			                                         ->get(); // 只统计100M以上的记录，加快速度
			if(!$userTotalTrafficList->isEmpty()){
				foreach($userTotalTrafficList as $vo){
					if($vo->totalTraffic > (self::$systemConfig['traffic_ban_value'] * 1024 * 1024 * 1024)){
						$tempUsers[] = $vo->user_id;
					}
				}
			}
			$query->whereIn('id', $tempUsers);
		}

		$userList = $query->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));
		foreach($userList as $user){
			$user->transfer_enable = flowAutoShow($user->transfer_enable);
			$user->used_flow = flowAutoShow($user->u + $user->d);
			if($user->expire_time < date('Y-m-d')){
				$user->expireWarning = -1; // 已过期
			}elseif($user->expire_time == date('Y-m-d')){
				$user->expireWarning = 0; // 今天过期
			}elseif($user->expire_time > date('Y-m-d') && $user->expire_time <= date('Y-m-d', strtotime("+30 days"))){
				$user->expireWarning = 1; // 最近一个月过期
			}else{
				$user->expireWarning = 2; // 大于一个月过期
			}

			// 流量异常警告
			$time = date('Y-m-d H:i:s', time() - 3900);
			$totalTraffic = UserTrafficHourly::query()
			                                 ->whereUserId($user->id)
			                                 ->whereNodeId(0)
			                                 ->where('created_at', '>=', $time)
			                                 ->sum('total');
			$user->trafficWarning = $totalTraffic > (self::$systemConfig['traffic_ban_value'] * 1024 * 1024 * 1024)? 1 : 0;

			// 订阅地址
			$user->link = (self::$systemConfig['subscribe_domain']? self::$systemConfig['subscribe_domain'] : self::$systemConfig['website_url']).'/s/'.$user->subscribe->code;
		}

		$view['userList'] = $userList;

		return Response::view('admin.user.userList', $view);
	}

	// 添加账号
	public function addUser(Request $request) {
		if($request->isMethod('POST')){
			// 校验email是否已存在
			$exists = User::query()->whereEmail($request->input('email'))->first();
			if($exists){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '用户名已存在，请重新输入']);
			}

			if(!$request->input('usage')){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '请至少选择一种用途']);
			}

			$user = new User();
			$user->email = trim($request->input('email'));
			$user->password = Hash::make(trim($request->input('password'))?: makeRandStr());
			$user->port = $request->input('port');
			$user->passwd = empty($request->input('passwd'))? makeRandStr() : $request->input('passwd');
			$user->vmess_id = $request->input('vmess_id')?: createGuid();
			$user->transfer_enable = toGB($request->input('transfer_enable', 0));
			$user->enable = $request->input('enable', 0);
			$user->method = $request->input('method');
			$user->protocol = $request->input('protocol');
			$user->protocol_param = $request->input('protocol_param')?: '';
			$user->obfs = $request->input('obfs');
			$user->obfs_param = $request->input('obfs_param')?: '';
			$user->speed_limit_per_con = $request->input('speed_limit_per_con');
			$user->speed_limit_per_user = $request->input('speed_limit_per_user');
			$user->wechat = $request->input('wechat')?: '';
			$user->qq = $request->input('qq')?: '';
			$user->usage = $request->input('usage');
			$user->pay_way = $request->input('pay_way');
			$user->balance = 0;
			$user->enable_time = empty($request->input('enable_time'))? date('Y-m-d') : $request->input('enable_time');
			$user->expire_time = empty($request->input('expire_time'))? date('Y-m-d',
			                                                                 strtotime("+365 days")) : $request->input('expire_time');
			$user->remark = str_replace("eval", "", str_replace("atob", "", $request->input('remark')));
			$user->level = $request->input('level')?: 1;
			$user->is_admin = 0;
			$user->reg_ip = getClientIp();
			$user->referral_uid = 0;
			$user->reset_time = $request->input('reset_time') > date('Y-m-d')? $request->input('reset_time') : null;
			$user->status = $request->input('status')?: 1;
			$user->save();

			if($user->id){
				// 生成订阅码
				$subscribe = new UserSubscribe();
				$subscribe->user_id = $user->id;
				$subscribe->code = Helpers::makeSubscribeCode();
				$subscribe->times = 0;
				$subscribe->save();

				// 生成用户标签
				$this->makeUserLabels($user->id, $request->input('labels'));

				// 写入用户流量变动记录
				Helpers::addUserTrafficModifyLog($user->id, 0, 0, toGB($request->input('transfer_enable', 0)),
				                                 '后台手动添加用户');

				return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
			}else{
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败']);
			}
		}else{
			// 生成一个可用端口
			$view['last_port'] = self::$systemConfig['is_rand_port']? Helpers::getRandPort() : Helpers::getOnlyPort();
			$view['method_list'] = Helpers::methodList();
			$view['protocol_list'] = Helpers::protocolList();
			$view['obfs_list'] = Helpers::obfsList();
			$view['level_list'] = Helpers::levelList();
			$view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
			$view['initial_labels'] = explode(",", self::$systemConfig['initial_labels_for_user']);

			return Response::view('admin.user.addUser', $view);
		}
	}

	// 生成用户标签
	private function makeUserLabels($userId, $labels) {
		// 先删除该用户所有的标签
		UserLabel::query()->whereUserId($userId)->delete();

		if(!empty($labels) && is_array($labels)){
			foreach($labels as $label){
				$userLabel = new UserLabel();
				$userLabel->user_id = $userId;
				$userLabel->label_id = $label;
				$userLabel->save();
			}
		}
	}

	// 批量生成账号
	public function batchAddUsers(Request $request) {
		$amount = $request->input('amount');
		DB::beginTransaction();
		try{
			for($i = 0; $i < $amount; $i++){
				$uid = Helpers::addUser('批量生成-'.makeRandStr(), Hash::make(makeRandStr()), toGB(1024), 365);
				// 生成一个可用端口

				if($uid){
					// 生成订阅码
					$subscribe = new UserSubscribe();
					$subscribe->user_id = $uid;
					$subscribe->code = Helpers::makeSubscribeCode();
					$subscribe->times = 0;
					$subscribe->save();

					// 初始化默认标签
					if(!empty(self::$systemConfig['initial_labels_for_user'])){
						$labels = explode(',', self::$systemConfig['initial_labels_for_user']);
						$this->makeUserLabels($uid, $labels);
					}

					// 写入用户流量变动记录
					Helpers::addUserTrafficModifyLog($uid, 0, 0, toGB(1024), '后台批量生成用户');
				}
			}

			DB::commit();

			return Response::json(['status' => 'success', 'data' => '', 'message' => '批量生成账号成功']);
		}catch(Exception $e){
			DB::rollBack();

			return Response::json(['status' => 'fail', 'data' => '', 'message' => '批量生成账号失败：'.$e->getMessage()]);
		}
	}

	// 编辑账号
	public function editUser(Request $request, $id) {
		if($request->isMethod('POST')){
			$username = trim($request->input('username'));
			$email = trim($request->input('email'));
			$password = $request->input('password');
			$port = $request->input('port');
			$passwd = $request->input('passwd');
			$vmess_id = $request->input('vmess_id')? trim($request->input('vmess_id')) : createGuid();
			$transfer_enable = $request->input('transfer_enable');
			$enable = $request->input('enable');
			$method = $request->input('method');
			$protocol = $request->input('protocol');
			$protocol_param = $request->input('protocol_param');
			$obfs = $request->input('obfs');
			$obfs_param = $request->input('obfs_param');
			$speed_limit_per_con = $request->input('speed_limit_per_con');
			$speed_limit_per_user = $request->input('speed_limit_per_user');
			$wechat = $request->input('wechat');
			$qq = $request->input('qq');
			$usage = $request->input('usage');
			$pay_way = $request->input('pay_way');
			$status = $request->input('status');
			$labels = $request->input('labels');
			$enable_time = $request->input('enable_time');
			$expire_time = $request->input('expire_time');
			$remark = str_replace("eval", "", str_replace("atob", "", $request->input('remark')));
			$level = $request->input('level');
			$is_admin = $request->input('is_admin');
			$reset_time = $request->input('reset_time');

			// 校验email是否已存在
			$exists = User::query()->where('id', '<>', $id)->whereEmail($email)->first();
			if($exists){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '用户名已存在，请重新输入']);
			}

			// 校验端口是否已存在
			$exists = User::query()->where('id', '<>', $id)->where('port', '>', 0)->wherePort($port)->first();
			if($exists){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '端口已存在，请重新输入']);
			}

			// 禁止取消默认管理员
			if($id == 1 && $is_admin == 0){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '系统默认管理员不可取消']);
			}

			if(!$usage){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '请至少选择一种用途']);
			}

			// 用户编辑前的信息
			$user = User::query()->whereId($id)->first();

			DB::beginTransaction();
			try{
				$data = [
					'username'             => $username,
					'email'                => $email,
					'port'                 => $port,
					'passwd'               => $passwd,
					'vmess_id'             => $vmess_id,
					'transfer_enable'      => toGB($transfer_enable),
					'enable'               => $status < 0? 0 : $enable,
					'method'               => $method,
					'protocol'             => $protocol,
					'protocol_param'       => $protocol_param,
					'obfs'                 => $obfs,
					'obfs_param'           => $obfs_param,
					'speed_limit_per_con'  => $speed_limit_per_con,
					'speed_limit_per_user' => $speed_limit_per_user,
					'wechat'               => $wechat,
					'qq'                   => $qq,
					'usage'                => $usage,
					'pay_way'              => $pay_way,
					'status'               => $status,
					'reset_time'           => empty($reset_time)? null : $reset_time,
					'enable_time'          => empty($enable_time)? date('Y-m-d') : $enable_time,
					'expire_time'          => empty($expire_time)? date('Y-m-d', strtotime("+365 days")) : $expire_time,
					'remark'               => $remark,
					'level'                => $level
				];

				// 只有admin才有权限操作管理员属性
				if(Auth::user()->id == 1){
					$data['is_admin'] = $is_admin;
				}

				if(!empty($password)){
					if(!(env('APP_DEMO') && $id == 1)){ // 演示环境禁止修改管理员密码
						$data['password'] = Hash::make($password);
					}
				}

				User::query()->whereId($id)->update($data);

				// 重新生成用户标签
				$this->makeUserLabels($id, $labels);

				// 写入用户流量变动记录
				if($user->transfer_enable != toGB($transfer_enable)){
					Helpers::addUserTrafficModifyLog($id, 0, $user->transfer_enable, toGB($transfer_enable),
					                                 '后台手动编辑用户');
				}

				DB::commit();

				return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
			}catch(Exception $e){
				DB::rollBack();
				Log::error('编辑用户信息异常：'.$e->getMessage());

				return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败']);
			}
		}else{
			$user = User::query()->with(['label', 'referral'])->whereId($id)->first();
			if($user){
				$user->transfer_enable = flowToGB($user->transfer_enable);

				// 处理标签
				$label = [];
				foreach($user->label as $vo){
					$label[] = $vo->label_id;
				}
				$user->labels = $label;

				// 处理用途
				$user->usage = explode(',', $user->usage);
			}

			$view['user'] = $user;
			$view['method_list'] = Helpers::methodList();
			$view['protocol_list'] = Helpers::protocolList();
			$view['obfs_list'] = Helpers::obfsList();
			$view['level_list'] = Helpers::levelList();
			$view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();

			return Response::view('admin.user.editUser', $view);
		}
	}

	// 删除用户
	public function delUser(Request $request) {
		$id = $request->input('id');

		if($id <= 1){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '系统管理员不可删除']);
		}

		DB::beginTransaction();
		try{
			User::query()->whereId($id)->delete();
			UserSubscribe::query()->whereUserId($id)->delete();
			UserBanLog::query()->whereUserId($id)->delete();
			UserLabel::query()->whereUserId($id)->delete();
			UserBalanceLog::query()->whereUserId($id)->delete();
			UserTrafficModifyLog::query()->whereUserId($id)->delete();
			UserLoginLog::query()->whereUserId($id)->delete();

			DB::commit();

			return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
		}catch(Exception $e){
			Log::error($e);
			DB::rollBack();

			return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
		}
	}

	// 节点列表
	public function nodeList(Request $request) {
		if($request->isMethod('POST')){
			$id = $request->input('id');
			$node = SsNode::query()->whereId($id)->first();
			// 使用DDNS的node先通过gethostbyname获取ipv4地址
			if($node->is_ddns){
				$ip = gethostbyname($node->server);
				if(strcmp($ip, $node->server) != 0){
					$node->ip = $ip;
				}else{
					return Response::json(['status' => 'fail', 'title' => 'IP获取错误', 'message' => $node->name.'IP获取失败']);
				}
			}
			$data[0] = NetworkDetection::networkCheck($node->ip, true); //ICMP
			$data[1] = NetworkDetection::networkCheck($node->ip, false, $node->single? $node->port : null); //TCP

			return Response::json(['status' => 'success', 'title' => '['.$node->name.']阻断信息', 'message' => $data]);
		}else{
			$status = $request->input('status');

			$query = SsNode::query();

			if(isset($status)){
				$query->whereStatus($status);
			}

			$nodeList = $query->orderBy('status', 'desc')
			                  ->orderBy('id', 'asc')
			                  ->paginate(15)
			                  ->appends($request->except('page'));
			foreach($nodeList as $node){
				// 在线人数
				$online_log = SsNodeOnlineLog::query()
				                             ->whereNodeId($node->id)
				                             ->where('log_time', '>=', strtotime("-5 minutes"))
				                             ->orderBy('id', 'desc')
				                             ->first();
				$node->online_users = empty($online_log)? 0 : $online_log->online_user;

				// 已产生流量
				$totalTraffic = SsNodeTrafficDaily::query()->whereNodeId($node->id)->sum('total');
				$node->transfer = flowAutoShow($totalTraffic);

				// 负载（10分钟以内）
				$node_info = SsNodeInfo::query()
				                       ->whereNodeId($node->id)
				                       ->where('log_time', '>=', strtotime("-10 minutes"))
				                       ->orderBy('id', 'desc')
				                       ->first();
				$node->isOnline = empty($node_info) || empty($node_info->load)? 0 : 1;
				$node->load = $node->isOnline? $node_info->load : '离线';
				$node->uptime = empty($node_info)? 0 : seconds2time($node_info->uptime);
			}

			$view['nodeList'] = $nodeList;
		}

		return Response::view('admin.node.nodeList', $view);
	}

	// 添加节点
	public function addNode(Request $request) {
		if($request->isMethod('POST')){
			if($request->input('ssh_port') <= 0 || $request->input('ssh_port') >= 65535){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败：SSH端口不合法']);
			}

			if(false === filter_var($request->input('ip'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV4)){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败：IPv4地址不合法']);
			}

			if($request->input('ipv6')
			   && false === filter_var($request->input('ipv6'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV6)){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败：IPv6地址不合法']);
			}

			if($request->input('server')){
				$domain = $request->input('server');
				$domain = explode('.', $domain);
				$domainSuffix = end($domain); // 取得域名后缀

				if(!in_array($domainSuffix, \config('domains'))){
					return Response::json(['status' => 'fail', 'data' => '', 'message' => '绑定域名不合法']);
				}
			}

			// TODO：判断是否已存在绑定了相同域名的节点，提示是否要强制替换，或者不提示之前强制将其他节点的绑定域名置为空，然后发起域名绑定请求，或者请求进入队列

			DB::beginTransaction();
			try{
				$ssNode = new SsNode();
				$ssNode->type = $request->input('type');
				$ssNode->name = $request->input('name');
				$ssNode->group_id = $request->input('group_id')?: 0;
				$ssNode->country_code = $request->input('country_code')?: 'un';
				$ssNode->server = $request->input('server')?: '';
				$ssNode->ip = $request->input('ip');
				$ssNode->ipv6 = $request->input('ipv6');
				$ssNode->desc = $request->input('desc')?: '';
				$ssNode->method = $request->input('method');
				$ssNode->protocol = $request->input('protocol');
				$ssNode->protocol_param = $request->input('protocol_param')?: '';
				$ssNode->obfs = $request->input('obfs')?: '';
				$ssNode->obfs_param = $request->input('obfs_param')?: '';
				$ssNode->traffic_rate = $request->input('traffic_rate')?: 1;
				$ssNode->bandwidth = $request->input('bandwidth')?: 1000;
				$ssNode->traffic = $request->input('traffic')?: 1000;
				$ssNode->monitor_url = $request->input('monitor_url')?: '';
				$ssNode->is_subscribe = $request->input('is_subscribe');
				$ssNode->is_ddns = $request->input('is_ddns');
				$ssNode->is_transit = $request->input('is_transit');
				$ssNode->ssh_port = $request->input('ssh_port')?: 22;
				$ssNode->detectionType = $request->input('detectionType');
				$ssNode->compatible = $request->input('type') == 2? 0 : ($request->input('is_ddns')? 0 : $request->input('compatible'));
				$ssNode->single = $request->input('single');
				$ssNode->port = $request->input('single')? ($request->input('port')?: 443) : '';
				$ssNode->passwd = $request->input('single')? ($request->input('passwd')?: 'password') : '';
				$ssNode->sort = $request->input('sort')?: 0;
				$ssNode->status = $request->input('status')?: 1;
				$ssNode->v2_alter_id = $request->input('v2_alter_id')?: 16;
				$ssNode->v2_port = $request->input('v2_port')?: 10087;
				$ssNode->v2_method = $request->input('v2_method')?: 'aes-128-gcm';
				$ssNode->v2_net = $request->input('v2_net')?: 'tcp';
				$ssNode->v2_type = $request->input('v2_type')?: 'none';
				$ssNode->v2_host = $request->input('v2_host')?: '';
				$ssNode->v2_path = $request->input('v2_path')?: '';
				$ssNode->v2_tls = $request->input('v2_tls')?: 0;
				$ssNode->v2_insider_port = $request->input('v2_insider_port')?: 10550;
				$ssNode->v2_outsider_port = $request->input('v2_outsider_port')?: 443;
				$ssNode->save();

				// 建立分组关联
				if($ssNode->id && $request->input('group_id', 0)){
					$ssGroupNode = new SsGroupNode();
					$ssGroupNode->group_id = $request->input('group_id', 0);
					$ssGroupNode->node_id = $ssNode->id;
					$ssGroupNode->save();
				}

				// 生成节点标签
				$labels = $request->input('labels');
				if($ssNode->id && !empty($labels)){
					foreach($labels as $label){
						$ssNodeLabel = new SsNodeLabel();
						$ssNodeLabel->node_id = $ssNode->id;
						$ssNodeLabel->label_id = $label;
						$ssNodeLabel->save();
					}
				}

				DB::commit();

				return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
			}catch(Exception $e){
				DB::rollBack();
				Log::error('添加节点信息异常：'.$e->getMessage());

				return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败：'.$e->getMessage()]);
			}
		}else{
			$view['method_list'] = Helpers::methodList();
			$view['protocol_list'] = Helpers::protocolList();
			$view['obfs_list'] = Helpers::obfsList();
			$view['level_list'] = Helpers::levelList();
			$view['group_list'] = SsGroup::query()->get();
			$view['country_list'] = Country::query()->orderBy('code', 'asc')->get();
			$view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();

			return Response::view('admin.node.addNode', $view);
		}
	}

	// 编辑节点
	public function editNode(Request $request) {
		$id = $request->input('id');

		if($request->isMethod('POST')){
			if($request->input('ssh_port') <= 0 || $request->input('ssh_port') >= 65535){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败：SSH端口不合法']);
			}

			if(false === filter_var($request->input('ip'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV4)){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败：IPv4地址不合法']);
			}

			if($request->input('ipv6')
			   && false === filter_var($request->input('ipv6'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV6)){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败：IPv6地址不合法']);
			}

			if($request->input('server')){
				$domain = $request->input('server');
				$domain = explode('.', $domain);
				$domainSuffix = end($domain); // 取得域名后缀

				if(!in_array($domainSuffix, \config('domains'))){
					return Response::json(['status' => 'fail', 'data' => '', 'message' => '绑定域名不合法']);
				}
			}

			if($request->input('v2_alter_id') <= 0 || $request->input('v2_alter_id') >= 65535){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败：AlterId不合法']);
			}

			DB::beginTransaction();
			try{
				$data = [
					'type'             => $request->input('type'),
					'name'             => $request->input('name'),
					'group_id'         => $request->input('group_id')? $request->input('group_id') : 0,
					'country_code'     => $request->input('country_code'),
					'server'           => $request->input('server'),
					'ip'               => $request->input('ip'),
					'ipv6'             => $request->input('ipv6'),
					'desc'             => $request->input('desc'),
					'method'           => $request->input('method'),
					'protocol'         => $request->input('protocol'),
					'protocol_param'   => $request->input('protocol_param'),
					'obfs'             => $request->input('obfs'),
					'obfs_param'       => $request->input('obfs_param'),
					'traffic_rate'     => $request->input('traffic_rate'),
					'bandwidth'        => $request->input('bandwidth')? $request->input('bandwidth') : 1000,
					'traffic'          => $request->input('traffic')? $request->input('traffic') : 1000,
					'monitor_url'      => $request->input('monitor_url')? $request->input('monitor_url') : '',
					'is_subscribe'     => $request->input('is_subscribe'),
					'is_ddns'          => $request->input('is_ddns'),
					'is_transit'       => $request->input('is_transit'),
					'ssh_port'         => $request->input('ssh_port'),
					'detectionType'    => $request->input('detectionType'),
					'compatible'       => $request->input('type') == 2? 0 : ($request->input('is_ddns')? 0 : $request->input('compatible')),
					'single'           => $request->input('single'),
					'port'             => $request->input('single')? ($request->input('port')? $request->input('port') : 443) : '',
					'passwd'           => $request->input('single')? ($request->input('passwd')? $request->input('passwd') : 'password') : '',
					'sort'             => $request->input('sort'),
					'status'           => $request->input('status'),
					'v2_alter_id'      => $request->input('v2_alter_id')? $request->input('v2_alter_id') : 16,
					'v2_port'          => $request->input('v2_port')? $request->input('v2_port') : 10087,
					'v2_method'        => $request->input('v2_method')? $request->input('v2_method') : 'aes-128-gcm',
					'v2_net'           => $request->input('v2_net'),
					'v2_type'          => $request->input('v2_type'),
					'v2_host'          => $request->input('v2_host'),
					'v2_path'          => $request->input('v2_path'),
					'v2_tls'           => $request->input('v2_tls'),
					'v2_insider_port'  => $request->input('v2_insider_port', 10550),
					'v2_outsider_port' => $request->input('v2_outsider_port', 443)
				];

				SsNode::query()->whereid($id)->update($data);

				// 建立分组关联
				if($request->input('group_id')){
					// 先删除该节点所有关联
					SsGroupNode::query()->whereNodeId($id)->delete();

					// 建立关联
					$ssGroupNode = new SsGroupNode();
					$ssGroupNode->group_id = $request->input('group_id');
					$ssGroupNode->node_id = $id;
					$ssGroupNode->save();
				}

				// 生成节点标签
				$this->makeNodeLabels($id, $request->input('labels'));

				// TODO:更新节点绑定的域名DNS（将节点IP更新到域名DNS 的A记录）

				DB::commit();

				return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
			}catch(Exception $e){
				DB::rollBack();
				Log::error('编辑节点信息异常：'.$e->getMessage());

				return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败：'.$e->getMessage()]);
			}
		}else{
			$node = SsNode::query()->with(['label'])->whereId($id)->first();
			if($node){
				$labels = [];
				foreach($node->label as $vo){
					$labels[] = $vo->label_id;
				}
				$node->labels = $labels;
			}

			$view['node'] = $node;
			$view['method_list'] = Helpers::methodList();
			$view['protocol_list'] = Helpers::protocolList();
			$view['obfs_list'] = Helpers::obfsList();
			$view['level_list'] = Helpers::levelList();
			$view['group_list'] = SsGroup::query()->get();
			$view['country_list'] = Country::query()->orderBy('code', 'asc')->get();
			$view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();

			return Response::view('admin.node.editNode', $view);
		}
	}

	// 生成节点标签
	private function makeNodeLabels($nodeId, $labels) {
		// 先删除所有该节点的标签
		SsNodeLabel::query()->whereNodeId($nodeId)->delete();

		if(!empty($labels) && is_array($labels)){
			foreach($labels as $label){
				$ssNodeLabel = new SsNodeLabel();
				$ssNodeLabel->node_id = $nodeId;
				$ssNodeLabel->label_id = $label;
				$ssNodeLabel->save();
			}
		}
	}

	// 删除节点
	public function delNode(Request $request) {
		$id = $request->input('id');

		$node = SsNode::query()->whereId($id)->first();
		if(!$node){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '节点不存在，请重试']);
		}

		DB::beginTransaction();
		try{
			// 删除分组关联、节点标签、节点相关日志
			SsNode::query()->whereId($id)->delete();
			SsGroupNode::query()->whereNodeId($id)->delete();
			SsNodeLabel::query()->whereNodeId($id)->delete();
			SsNodeInfo::query()->whereNodeId($id)->delete();
			SsNodeOnlineLog::query()->whereNodeId($id)->delete();
			SsNodeTrafficDaily::query()->whereNodeId($id)->delete();
			SsNodeTrafficHourly::query()->whereNodeId($id)->delete();
			SsNodePing::query()->whereNodeId($id)->delete();
			UserTrafficDaily::query()->whereNodeId($id)->delete();
			UserTrafficHourly::query()->whereNodeId($id)->delete();
			UserTrafficLog::query()->whereNodeId($id)->delete();

			DB::commit();

			return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
		}catch(Exception $e){
			DB::rollBack();
			Log::error('删除节点信息异常：'.$e->getMessage());

			return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败：'.$e->getMessage()]);
		}
	}

	// 节点流量监控
	public function nodeMonitor($node_id) {
		$node = SsNode::query()->whereId($node_id)->orderBy('sort', 'desc')->first();
		if(!$node){
			Session::flash('errorMsg', '节点不存在，请重试');

			return Redirect::back();
		}

		// 查看流量
		$dailyData = [];
		$hourlyData = [];

		// 节点一个月内的流量
		$nodeTrafficDaily = SsNodeTrafficDaily::query()
		                                      ->with(['info'])
		                                      ->whereNodeId($node->id)
		                                      ->where('created_at', '>=', date('Y-m', time()))
		                                      ->orderBy('created_at', 'asc')
		                                      ->pluck('total')
		                                      ->toArray();
		$dailyTotal = date('d', time()) - 1;//今天不算，减一
		$dailyCount = count($nodeTrafficDaily);
		for($x = 0; $x < ($dailyTotal - $dailyCount); $x++){
			$dailyData[$x] = 0;
		}
		for($x = ($dailyTotal - $dailyCount); $x < $dailyTotal; $x++){
			$dailyData[$x] = round($nodeTrafficDaily[$x - ($dailyTotal - $dailyCount)] / (1024 * 1024 * 1024), 3);
		}

		// 节点一天内的流量
		$nodeTrafficHourly = SsNodeTrafficHourly::query()
		                                        ->with(['info'])
		                                        ->whereNodeId($node->id)
		                                        ->where('created_at', '>=', date('Y-m-d', time()))
		                                        ->orderBy('created_at', 'asc')
		                                        ->pluck('total')
		                                        ->toArray();
		$hourlyTotal = date('H', time());
		$hourlyCount = count($nodeTrafficHourly);
		for($x = 0; $x < ($hourlyTotal - $hourlyCount); $x++){
			$hourlyData[$x] = 0;
		}
		for($x = ($hourlyTotal - $hourlyCount); $x < $hourlyTotal; $x++){
			$hourlyData[$x] = round($nodeTrafficHourly[$x - ($hourlyTotal - $hourlyCount)] / (1024 * 1024 * 1024), 3);
		}

		$view['trafficDaily'] = ['nodeName' => $node->name, 'dailyData' => "'".implode("','", $dailyData)."'"];

		$view['trafficHourly'] = ['nodeName' => $node->name, 'hourlyData' => "'".implode("','", $hourlyData)."'"];


		// 本月天数数据
		$monthDays = [];
		for($i = 1; $i <= date("d"); $i++){
			$monthDays[] = $i;
		}
		// 本日小时数据
		$dayHours = [];
		for($i = 1; $i <= date("H"); $i++){
			$dayHours[] = $i;
		}

		$view['nodeName'] = $node->name;
		$view['nodeServer'] = $node->server;
		$view['monthDays'] = "'".implode("','", $monthDays)."'";
		$view['dayHours'] = "'".implode("','", $dayHours)."'";

		return Response::view('admin.node.nodeMonitor', $view);
	}

	// Ping节点延迟
	public function pingNode(Request $request) {
		$node = SsNode::query()->whereId($request->input('id'))->first();
		if(!$node){
			return Response::json(['status' => 'fail', 'message' => '节点不存在，请重试']);
		}

		$result = NetworkDetection::ping($node->is_ddns? $node->server : $node->ip);

		if($result){
			$data[0] = $result['China Telecom']['time']?: '无';
			$data[1] = $result['China Unicom']['time']?: '无';
			$data[2] = $result['China Mobile']['time']?: '无';
			$data[3] = $result['Hong Kong']['time']?: '无';

			return Response::json(['status' => 'success', 'message' => $data]);
		}else{
			return Response::json(['status' => 'fail', 'message' => 'Ping访问失败']);
		}
	}

	public function nodePingLog(Request $request) {

		$node_id = $request->input('nodeId');
		$query = SsNodePing::query();
		if(isset($node_id)){
			$query->whereNodeId($node_id);
		}

		$view['nodeList'] = SsNode::query()->orderBy('id', 'asc')->get();
		$view['pingLogs'] = $query->orderBy('id', 'asc')->paginate(15)->appends($request->except('page'));

		return Response::view('admin.logs.nodePingLog', $view);
	}


	// 文章列表
	public function articleList(Request $request) {
		$view['list'] = Article::query()->orderBy('sort', 'desc')->paginate(15)->appends($request->except('page'));

		return Response::view('admin.article.articleList', $view);
	}

	// 添加文章
	public function addArticle(Request $request) {
		if($request->isMethod('POST')){
			$article = new Article();
			$article->title = $request->input('title');
			$article->type = $request->input('type', 1);
			$article->author = '管理员';
			$article->summary = $request->input('summary');
			// LOGO
			if($article->type == 4){
				$article->logo = $request->input('logo');
			}else{
				$logo = '';
				if($request->hasFile('logo')){
					$file = $request->file('logo');
					$fileType = $file->getClientOriginalExtension();

					// 验证文件合法性
					if(!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])){
						Session::flash('errorMsg', 'LOGO不合法');

						return Redirect::back()->withInput();
					}

					$logoName = date('YmdHis').mt_rand(1000, 2000).'.'.$fileType;
					$move = $file->move(base_path().'/public/upload/image/', $logoName);
					$logo = $move? '/upload/image/'.$logoName : '';
				}
				$article = new Article();
				$article->title = $request->input('title');
				$article->type = $request->input('type', 1);
				$article->author = '管理员';
				$article->summary = $request->input('summary');
				$article->logo = $logo;
			}
			$article->content = $request->input('content');
			$article->sort = $request->input('sort', 0);
			$article->save();

			if($article->id){
				Session::flash('successMsg', '添加成功');
			}else{
				Session::flash('errorMsg', '添加失败');
			}

			return Redirect::to('admin/articleList');
		}else{
			return Response::view('admin.article.addArticle');
		}
	}

	// 编辑文章
	public function editArticle(Request $request) {
		$id = $request->input('id');

		if($request->isMethod('POST')){
			$title = $request->input('title');
			$type = $request->input('type');
			$summary = $request->input('summary');
			$content = $request->input('content');
			$sort = $request->input('sort');

			// 商品LOGO
			if($type == 4){
				$logo = $request->input('logo');
			}else{
				$logo = '';
				if($request->hasFile('logo')){
					$file = $request->file('logo');
					$fileType = $file->getClientOriginalExtension();

					// 验证文件合法性
					if(!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])){
						Session::flash('errorMsg', 'LOGO不合法');

						return Redirect::back()->withInput();
					}

					$logoName = date('YmdHis').mt_rand(1000, 2000).'.'.$fileType;
					$move = $file->move(base_path().'/public/upload/image/', $logoName);
					$logo = $move? '/upload/image/'.$logoName : '';
				}
			}

			$data = ['type' => $type, 'title' => $title, 'summary' => $summary, 'content' => $content, 'sort' => $sort];

			if($logo){
				$data['logo'] = $logo;
			}

			$ret = Article::query()->whereId('id', $id)->update($data);
			if($ret){
				Session::flash('successMsg', '编辑成功');
			}else{
				Session::flash('errorMsg', '编辑失败');
			}

			return Redirect::to('admin/editArticle?id='.$id);
		}else{
			$view['article'] = Article::query()->whereId($id)->first();

			return Response::view('admin.article.editArticle', $view);
		}
	}

	// 删除文章
	public function delArticle(Request $request) {
		$id = $request->input('id');

		$ret = Article::query()->whereId($id)->delete();
		if($ret){
			return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
		}else{
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
		}
	}

	// 节点分组列表
	public function groupList(Request $request) {
		$view['groupList'] = SsGroup::query()->paginate(15)->appends($request->except('page'));

		$levelList = Helpers::levelList();
		$levelMap = [];
		foreach($levelList as $vo){
			$levelMap[$vo['level']] = $vo['level_name'];
		}
		$view['levelMap'] = $levelMap;

		return Response::view('admin.group.groupList', $view);
	}

	// 添加节点分组
	public function addGroup(Request $request) {
		if($request->isMethod('POST')){
			$ssGroup = new SsGroup();
			$ssGroup->name = $request->input('name');
			$ssGroup->level = $request->input('level');
			$ssGroup->save();

			return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
		}else{
			$view['levelList'] = Helpers::levelList();

			return Response::view('admin.group.addGroup', $view);
		}
	}

	// 编辑节点分组
	public function editGroup(Request $request, $id) {
		if($request->isMethod('POST')){
			$name = $request->input('name');
			$level = $request->input('level');

			$data = ['name' => $name, 'level' => $level];

			$ret = SsGroup::query()->whereId($id)->update($data);
			if($ret){
				return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
			}else{
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败']);
			}
		}else{
			$view['group'] = SsGroup::query()->whereId($id)->first();
			$view['levelList'] = Helpers::levelList();

			return Response::view('admin.group.editGroup', $view);
		}
	}

	// 删除节点分组
	public function delGroup(Request $request) {
		$id = $request->input('id');

		// 检查是否该分组下是否有节点
		$ssGroupNodeCount = SsGroupNode::query()->whereGroupId($id)->count();
		if($ssGroupNodeCount){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败：该分组下有节点关联，请先解除关联']);
		}

		$ret = SsGroup::query()->whereId($id)->delete();
		if($ret){
			return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
		}else{
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
		}
	}

	// 流量日志
	public function trafficLog(Request $request) {
		$port = $request->input('port');
		$user_id = $request->input('user_id');
		$email = $request->input('email');
		$nodeId = $request->input('nodeId');
		$startTime = $request->input('startTime');
		$endTime = $request->input('endTime');

		$query = UserTrafficLog::query()->with(['user', 'node']);

		if(isset($port)){
			$query->whereHas('user', function($q) use ($port) {
				$q->wherePort($port);
			});
		}

		if(isset($user_id)){
			$query->whereUserId($user_id);
		}

		if(isset($email)){
			$query->whereHas('user', function($q) use ($email) {
				$q->where('email', 'like', '%'.$email.'%');
			});
		}

		if(isset($nodeId)){
			$query->whereNodeId($nodeId);
		}

		if(isset($startTime)){
			$query->where('log_time', '>=', strtotime($startTime));
		}

		if(isset($endTime)){
			$query->where('log_time', '<=', strtotime($endTime));
		}

		// 已使用流量
		$view['totalTraffic'] = flowAutoShow($query->sum('u') + $query->sum('d'));

		$list = $query->orderBy('id', 'desc')->paginate(20)->appends($request->except('page'));
		foreach($list as $vo){
			$vo->u = flowAutoShow($vo->u);
			$vo->d = flowAutoShow($vo->d);
			$vo->log_time = date('Y-m-d H:i:s', $vo->log_time);
		}

		$view['list'] = $list;
		$view['nodeList'] = SsNode::query()->whereStatus(1)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get();

		return Response::view('admin.logs.trafficLog', $view);
	}

	// SS(R)链接反解析
	public function decompile(Request $request) {
		if($request->isMethod('POST')){
			$content = $request->input('content');

			if(empty($content)){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '请在左侧填入要反解析的SS(R)链接']);
			}

			// 反解析处理
			$content = str_replace("\n", ",", $content);
			$content = explode(',', $content);
			$txt = '';
			foreach($content as $item){
				// 判断是SS还是SSR链接
				$str = '';
				if(false !== strpos($item, 'ssr://')){
					$str = mb_substr($item, 6);
				}elseif(false !== strpos($item, 'ss://')){
					$str = mb_substr($item, 5);
				}

				$txt .= "\r\n".base64url_decode($str);
			}

			// 生成转换好的JSON文件
			file_put_contents(public_path('downloads/decompile.json'), $txt);

			return Response::json(['status' => 'success', 'data' => $txt, 'message' => '反解析成功']);
		}else{
			return Response::view('admin.decompile');
		}
	}

	// 格式转换(SS转SSR)
	public function convert(Request $request) {
		if($request->isMethod('POST')){
			$method = $request->input('method');
			$transfer_enable = $request->input('transfer_enable');
			$protocol = $request->input('protocol');
			$protocol_param = $request->input('protocol_param');
			$obfs = $request->input('obfs');
			$obfs_param = $request->input('obfs_param');
			$content = $request->input('content');

			if(empty($content)){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '请在左侧填入要转换的内容']);
			}

			// 校验格式
			$content = json_decode($content);
			if(empty($content->port_password)){
				return Response::json([
					                      'status'  => 'fail',
					                      'data'    => '',
					                      'message' => '转换失败：配置信息里缺少【port_password】字段，或者该字段为空'
				                      ]);
			}

			// 转换成SSR格式JSON
			$data = [];
			foreach($content->port_password as $port => $passwd){
				$data[] = [
					'd'               => 0,
					'enable'          => 1,
					'method'          => $method,
					'obfs'            => $obfs,
					'obfs_param'      => empty($obfs_param)? "" : $obfs_param,
					'passwd'          => $passwd,
					'port'            => $port,
					'protocol'        => $protocol,
					'protocol_param'  => empty($protocol_param)? "" : $protocol_param,
					'transfer_enable' => toGB($transfer_enable),
					'u'               => 0,
					'user'            => date('Ymd').'_IMPORT_'.$port,
				];
			}

			$json = json_encode($data);

			// 生成转换好的JSON文件
			file_put_contents(public_path('downloads/convert.json'), $json);

			return Response::json(['status' => 'success', 'data' => $json, 'message' => '转换成功']);
		}else{
			// 加密方式、协议、混淆
			$view['method_list'] = Helpers::methodList();
			$view['protocol_list'] = Helpers::protocolList();
			$view['obfs_list'] = Helpers::obfsList();

			return Response::view('admin.convert', $view);
		}
	}

	// 下载转换好的JSON文件
	public function download(Request $request) {
		$type = $request->input('type');
		if(empty($type)){
			exit('参数异常');
		}

		if($type == '1'){
			$filePath = public_path('downloads/convert.json');
		}else{
			$filePath = public_path('downloads/decompile.json');
		}

		if(!file_exists($filePath)){
			exit('文件不存在，请检查目录权限');
		}

		return Response::download($filePath);
	}

	// 数据导入
	public function import(Request $request) {
		if($request->isMethod('POST')){
			if(!$request->hasFile('uploadFile')){
				Session::flash('errorMsg', '请选择要上传的文件');

				return Redirect::back();
			}

			$file = $request->file('uploadFile');

			// 只能上传JSON文件
			if($file->getClientMimeType() != 'application/json' || $file->getClientOriginalExtension() != 'json'){
				Session::flash('errorMsg', '只允许上传JSON文件');

				return Redirect::back();
			}

			if(!$file->isValid()){
				Session::flash('errorMsg', '产生未知错误，请重新上传');

				return Redirect::back();
			}

			$save_path = realpath(storage_path('uploads'));
			$new_name = md5($file->getClientOriginalExtension()).'.json';
			$file->move($save_path, $new_name);

			// 读取文件内容
			$data = file_get_contents($save_path.'/'.$new_name);
			$data = json_decode($data);
			if(!$data){
				Session::flash('errorMsg', '内容格式解析异常，请上传符合SSR(R)配置规范的JSON文件');

				return Redirect::back();
			}

			try{
				DB::beginTransaction();
				foreach($data as $user){
					$obj = new User();
					$obj->email = $user->user;
					$obj->password = Hash::make('123456');
					$obj->port = $user->port;
					$obj->passwd = $user->passwd;
					$obj->vmess_id = $user->vmess_id;
					$obj->transfer_enable = $user->transfer_enable;
					$obj->u = 0;
					$obj->d = 0;
					$obj->t = 0;
					$obj->enable = 1;
					$obj->method = $user->method;
					$obj->protocol = $user->protocol;
					$obj->protocol_param = $user->protocol_param;
					$obj->obfs = $user->obfs;
					$obj->obfs_param = $user->obfs_param;
					$obj->speed_limit_per_con = 204800;
					$obj->speed_limit_per_user = 204800;
					$obj->wechat = '';
					$obj->qq = '';
					$obj->usage = 1;
					$obj->pay_way = 3;
					$obj->balance = 0;
					$obj->enable_time = date('Y-m-d');
					$obj->expire_time = '2099-01-01';
					$obj->remark = '';
					$obj->is_admin = 0;
					$obj->reg_ip = getClientIp();
					$obj->created_at = date('Y-m-d H:i:s');
					$obj->updated_at = date('Y-m-d H:i:s');
					$obj->save();
				}

				DB::commit();
			}catch(Exception $e){
				DB::rollBack();

				Session::flash('errorMsg', '出错了，可能是导入的配置中有端口已经存在了');

				return Redirect::back();
			}

			Session::flash('successMsg', '导入成功');

			return Redirect::back();
		}else{
			return Response::view('admin.import');
		}
	}

	// 导出配置信息
	public function export(Request $request, $id) {
		if(empty($id)){
			return Redirect::to('admin/userList');
		}

		$user = User::query()->whereId($id)->first();
		if(empty($user)){
			return Redirect::to('admin/userList');
		}

		if($request->isMethod('POST')){
			$node_id = $request->input('id');
			$infoType = $request->input('type');

			$node = SsNode::query()->whereId($node_id)->first();
			$proxyType = $node->type == 1? ($node->compatible? 'SS' : 'SSR') : 'V2Ray';
			$data = $this->getNodeInfo($id, $node->id, $infoType != 'text'? 0 : 1);

			return Response::json(['status' => 'success', 'data' => $data, 'title' => $proxyType]);

		}else{
			$view['nodeList'] = SsNode::query()
			                          ->whereStatus(1)
			                          ->orderBy('sort', 'desc')
			                          ->orderBy('id', 'asc')
			                          ->paginate(15)
			                          ->appends($request->except('page'));
			$view['user'] = $user;
		}

		return Response::view('admin.export', $view);
	}

	// 导出原版SS用户配置信息
	public function exportSSJson() {
		$userList = User::query()->where('port', '>', 0)->get();
		$defaultMethod = Helpers::getDefaultMethod();

		$json = '';
		if(!$userList->isEmpty()){
			$tmp = [];
			foreach($userList as $key => $user){
				$tmp[] = '"'.$user->port.'":"'.$user->passwd.'"';
			}

			$userPassword = implode(",\n\t\t", $tmp);
			$json = <<<EOF
{
	"server":"0.0.0.0",
    "local_address":"127.0.0.1",
    "local_port":1080,
    "port_password":{
        {$userPassword}
    },
    "timeout":300,
    "method":"{$defaultMethod}",
    "fast_open":false
}
EOF;
		}

		// 生成JSON文件
		$fileName = makeRandStr('16').'_shadowsocks.json';
		$filePath = public_path('downloads/'.$fileName);
		file_put_contents($filePath, $json);

		if(!file_exists($filePath)){
			exit('文件生成失败，请检查目录权限');
		}

		return Response::download($filePath);
	}

	// 修改个人资料
	public function profile(Request $request) {
		if($request->isMethod('POST')){
			$old_password = trim($request->input('old_password'));
			$new_password = trim($request->input('new_password'));

			if(!Hash::check($old_password, Auth::user()->password)){
				return Redirect::back()->withErrors('旧密码错误，请重新输入');
			}elseif(Hash::check($new_password, Auth::user()->password)){
				return Redirect::back()->withErrors('新密码不可与旧密码一样，请重新输入');
			}

			$ret = User::uid()->update(['password' => Hash::make($new_password)]);
			if(!$ret){
				return Redirect::back()->withErrors('修改失败');
			}else{
				return Redirect::back()->with('successMsg', '修改成功');
			}
		}else{
			return Response::view('admin.profile');
		}
	}

	// 用户流量监控
	public function userMonitor($id) {
		if(empty($id)){
			return Redirect::to('admin/userList');
		}

		$user = User::query()->whereId($id)->first();
		if(empty($user)){
			return Redirect::to('admin/userList');
		}

		// 30天内的流量
		$dailyData = [];
		$hourlyData = [];
		// 节点一个月内的流量
		$userTrafficDaily = UserTrafficDaily::query()
		                                    ->whereUserId($user->id)
		                                    ->whereNodeId(0)
		                                    ->where('created_at', '>=', date('Y-m', time()))
		                                    ->orderBy('created_at', 'asc')
		                                    ->pluck('total')
		                                    ->toArray();

		$dailyTotal = date('d') - 1; // 今天不算，减一
		$dailyCount = count($userTrafficDaily);
		for($x = 0; $x < $dailyTotal - $dailyCount; $x++){
			$dailyData[$x] = 0;
		}
		for($x = $dailyTotal - $dailyCount; $x < $dailyTotal; $x++){
			$dailyData[$x] = round($userTrafficDaily[$x - ($dailyTotal - $dailyCount)] / (1024 * 1024 * 1024), 3);
		}

		// 节点一天内的流量
		$userTrafficHourly = UserTrafficHourly::query()
		                                      ->whereUserId($user->id)
		                                      ->whereNodeId(0)
		                                      ->where('created_at', '>=', date('Y-m-d', time()))
		                                      ->orderBy('created_at', 'asc')
		                                      ->pluck('total')
		                                      ->toArray();
		$hourlyTotal = date('H');
		$hourlyCount = count($userTrafficHourly);
		for($x = 0; $x < $hourlyTotal - $hourlyCount; $x++){
			$hourlyData[$x] = 0;
		}
		for($x = ($hourlyTotal - $hourlyCount); $x < $hourlyTotal; $x++){
			$hourlyData[$x] = round($userTrafficHourly[$x - ($hourlyTotal - $hourlyCount)] / (1024 * 1024 * 1024), 3);
		}

		// 本月天数数据
		$monthDays = [];
		for($i = 1; $i <= date("d"); $i++){
			$monthDays[] = $i;
		}
		// 本日小时数据
		$dayHours = [];
		for($i = 1; $i <= date("H"); $i++){
			$dayHours[] = $i;
		}

		$view['trafficDaily'] = "'".implode("','", $dailyData)."'";
		$view['trafficHourly'] = "'".implode("','", $hourlyData)."'";
		$view['monthDays'] = "'".implode("','", $monthDays)."'";
		$view['dayHours'] = "'".implode("','", $dayHours)."'";
		$view['email'] = $user->email;

		return Response::view('admin.logs.userMonitor', $view);
	}

	// 生成端口
	public function makePort() {
		return self::$systemConfig['is_rand_port']? Helpers::getRandPort() : Helpers::getOnlyPort();
	}

	// 加密方式、混淆、协议、等级、国家地区
	public function config(Request $request) {
		if($request->isMethod('POST')){
			$name = $request->input('name');
			$type = $request->input('type', 1); // 类型：1-加密方式（method）、2-协议（protocol）、3-混淆（obfs）
			$is_default = $request->input('is_default', 0);
			$sort = $request->input('sort', 0);

			if(empty($name)){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置名称不能为空']);
			}

			// 校验是否已存在
			$config = SsConfig::type($type)->whereName($name)->first();
			if($config){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置已经存在，请勿重复添加']);
			}

			$ssConfig = new SsConfig();
			$ssConfig->name = $name;
			$ssConfig->type = $type;
			$ssConfig->is_default = $is_default;
			$ssConfig->sort = $sort;
			$ssConfig->save();

			return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
		}else{
			$view['method_list'] = SsConfig::type(1)->get();
			$view['protocol_list'] = SsConfig::type(2)->get();
			$view['obfs_list'] = SsConfig::type(3)->get();
			$view['level_list'] = Helpers::levelList();
			$view['country_list'] = Country::query()->get();

			return Response::view('admin.config', $view);
		}
	}

	// 删除配置
	public function delConfig(Request $request) {
		$id = $request->input('id');

		$ret = SsConfig::query()->whereId($id)->delete();
		if($ret){
			return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
		}else{
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
		}
	}

	// 设置默认配置
	public function setDefaultConfig(Request $request) {
		$id = $request->input('id');

		if(empty($id)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '非法请求']);
		}

		$config = SsConfig::query()->whereId($id)->first();
		if(!$config){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置不存在']);
		}

		// 去除该配置所属类型的默认值
		SsConfig::default()->type($config->type)->update(['is_default' => 0]);

		// 将该ID对应记录值置为默认值
		SsConfig::query()->whereId($id)->update(['is_default' => 1]);

		return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
	}

	// 设置系统扩展信息，例如客服、统计代码
	public function setExtend(Request $request) {
		$websiteAnalytics = $request->input('website_analytics');
		$websiteCustomerService = $request->input('website_customer_service');

		DB::beginTransaction();
		try{
			// 首页LOGO
			if($request->hasFile('website_home_logo')){
				$file = $request->file('website_home_logo');
				$fileType = $file->getClientOriginalExtension();

				// 验证文件合法性
				if(!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])){
					Session::flash('errorMsg', 'LOGO不合法');

					return Redirect::back();
				}

				$logoName = date('YmdHis').mt_rand(1000, 2000).'.'.$fileType;
				$move = $file->move(base_path().'/public/upload/image/', $logoName);
				$websiteHomeLogo = $move? '/upload/image/'.$logoName : '';

				Config::query()->whereName('website_home_logo')->update(['value' => $websiteHomeLogo]);
			}

			// 站内LOGO
			if($request->hasFile('website_logo')){
				$file = $request->file('website_logo');
				$fileType = $file->getClientOriginalExtension();

				// 验证文件合法性
				if(!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])){
					Session::flash('errorMsg', 'LOGO不合法');

					return Redirect::back();
				}

				$logoName = date('YmdHis').mt_rand(1000, 2000).'.'.$fileType;
				$move = $file->move(base_path().'/public/upload/image/', $logoName);
				$websiteLogo = $move? '/upload/image/'.$logoName : '';

				Config::query()->whereName('website_logo')->update(['value' => $websiteLogo]);
			}

			Config::query()->whereName('website_analytics')->update(['value' => $websiteAnalytics]);
			Config::query()->whereName('website_customer_service')->update(['value' => $websiteCustomerService]);

			Session::flash('successMsg', '更新成功');

			DB::commit();

			return Redirect::back();
		}catch(Exception $e){
			DB::rollBack();

			Session::flash('errorMsg', '更新失败');

			return Redirect::back();
		}
	}

	// 日志分析
	public function analysis() {
		$file = storage_path('app/ssserver.log');
		if(!file_exists($file)){
			Session::flash('analysisErrorMsg', $file.' 不存在，请先创建文件');

			return Response::view('admin.analysis');
		}

		$logs = $this->tail($file, 10000);
		if(false === $logs){
			$view['urlList'] = [];
		}else{
			$url = [];
			foreach($logs as $log){
				if(strpos($log, 'TCP connecting')){
					continue;
				}

				preg_match('/TCP request (\w+\.){2}\w+/', $log, $tcp_matches);
				if(!empty($tcp_matches)){
					$url[] = str_replace('TCP request ', '[TCP] ', $tcp_matches[0]);
				}else{
					preg_match('/UDP data to (25[0-5]|2[0-4]\d|[0-1]\d{2}|[1-9]?\d)\.(25[0-5]|2[0-4]\d|[0-1]\d{2}|[1-9]?\d)\.(25[0-5]|2[0-4]\d|[0-1]\d{2}|[1-9]?\d)\.(25[0-5]|2[0-4]\d|[0-1]\d{2}|[1-9]?\d)/',
					           $log, $udp_matches);
					if(!empty($udp_matches)){
						$url[] = str_replace('UDP data to ', '[UDP] ', $udp_matches[0]);
					}
				}
			}

			$view['urlList'] = array_unique($url);
		}

		return Response::view('admin.analysis', $view);
	}

	// 添加等级
	public function addLevel(Request $request) {
		$level = $request->input('level');
		$level_name = trim($request->input('level_name'));

		if(empty($level)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不能为空']);
		}

		if(empty($level_name)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级名称不能为空']);
		}

		$exists = Level::query()->whereLevel($level)->first();
		if($exists){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级已存在，请勿重复添加']);
		}

		$obj = new Level();
		$obj->level = $level;
		$obj->level_name = $level_name;
		$obj->save();

		if($obj->id){
			return Response::json(['status' => 'success', 'data' => '', 'message' => '提交成功']);
		}else{
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
		}
	}

	// 编辑等级
	public function updateLevel(Request $request) {
		$id = $request->input('id');
		$level = $request->input('level');
		$level_name = $request->input('level_name');

		if(!$id){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
		}

		if(!$level){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不能为空']);
		}

		if(!$level_name){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级名称不能为空']);
		}

		$le = Level::query()->whereId($id)->first();
		if(!$le){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不存在']);
		}

		// 校验该等级下是否存在关联分组
		$ssGroupCount = SsGroup::query()->whereLevel($le->level)->count();
		if($ssGroupCount){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联分组，请先取消关联']);
		}

		// 校验该等级下是否存在关联账号
		$userCount = User::query()->whereLevel($le->level)->count();
		if($userCount){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联账号，请先取消关联']);
		}

		Level::query()->whereId($id)->update(['level' => $level, 'level_name' => $level_name]);

		return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
	}

	// 删除等级
	public function delLevel(Request $request) {
		$id = $request->input('id');

		if(empty($id)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
		}

		$level = Level::query()->whereId($id)->first();
		if(empty($level)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不存在']);
		}

		// 校验该等级下是否存在关联分组
		$existGroups = SsGroup::query()->whereLevel($level->level)->get();
		if(!$existGroups->isEmpty()){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联分组，请先取消关联']);
		}

		// 校验该等级下是否存在关联账号
		$existUsers = User::query()->whereLevel($level->level)->get();
		if(!$existUsers->isEmpty()){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联账号，请先取消关联']);
		}
		$ret = false;
		try{
			$ret = Level::query()->whereId($id)->delete();
		}catch(Exception $e){
			Log::error('删除等级时报错：'.$e);
		}
		if($ret){
			return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
		}else{
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
		}
	}

	// 添加国家/地区
	public function addCountry(Request $request) {
		$name = $request->input('country_name');
		$code = $request->input('country_code');

		if(empty($name)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区名称不能为空']);
		}

		if(empty($code)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区代码不能为空']);
		}

		$exists = Country::query()->whereName($name)->first();
		if($exists){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '该国家/地区名称已存在，请勿重复添加']);
		}

		$obj = new Country();
		$obj->name = $name;
		$obj->code = $code;
		$obj->save();

		if($obj->id){
			return Response::json(['status' => 'success', 'data' => '', 'message' => '提交成功']);
		}else{
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
		}
	}

	// 编辑国家/地区
	public function updateCountry(Request $request) {
		$id = $request->input('id');
		$name = $request->input('country_name');
		$code = $request->input('country_code');

		if(empty($id)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
		}

		if(empty($name)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区名称不能为空']);
		}

		if(empty($code)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区代码不能为空']);
		}

		$country = Country::query()->whereId($id)->first();
		if(empty($country)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区不存在']);
		}

		// 校验该国家/地区下是否存在关联节点
		$existNode = SsNode::query()->whereCountryCode($country->code)->get();
		if(!$existNode->isEmpty()){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '该国家/地区下存在关联节点，请先取消关联']);
		}

		$ret = Country::query()->whereId($id)->update(['name' => $name, 'code' => $code]);
		if($ret){
			return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
		}else{
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
		}
	}

	// 删除国家/地区
	public function delCountry(Request $request) {
		$id = $request->input('id');

		if(empty($id)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
		}

		$country = Country::query()->whereId($id)->first();
		if(empty($country)){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区不存在']);
		}

		// 校验该国家/地区下是否存在关联节点
		$existNode = SsNode::query()->whereCountryCode($country->code)->get();
		if(!$existNode->isEmpty()){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '该国家/地区下存在关联节点，请先取消关联']);
		}
		$ret = false;
		try{
			$ret = Country::query()->whereId($id)->delete();
		}catch(Exception $e){
			Log::error('删除国家/地区时报错：'.$e);
		}
		if($ret){
			return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
		}else{
			return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
		}
	}

	// 系统设置
	public function system() {
		$view = self::$systemConfig;
		$view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();

		return Response::view('admin.system', $view);
	}

	// 设置某个配置项
	public function setConfig(Request $request) {
		$name = $request->input('name');
		$value = trim($request->input('value'));

		if(!$name){
			return Response::json(['status' => 'fail', 'message' => '设置失败：请求参数异常']);
		}

		// 屏蔽异常配置
		if(!array_key_exists($name, self::$systemConfig)){
			return Response::json(['status' => 'fail', 'message' => '设置失败：配置不存在']);
		}

		// 如果开启用户邮件重置密码，则先设置网站名称和网址
		if(in_array($name, ['is_reset_password', 'is_activate_account', 'expire_warning', 'traffic_warning'])
		   && $value != '0'){
			$config = Config::query()->whereName('website_name')->first();
			if($config->value == ''){
				return Response::json(['status' => 'fail', 'message' => '设置失败：启用该配置需要先设置【网站名称】']);
			}

			$config = Config::query()->whereName('website_url')->first();
			if($config->value == ''){
				return Response::json(['status' => 'fail', 'message' => '设置失败：启用该配置需要先设置【网站地址】']);
			}
		}

		// 支付设置判断
		if(in_array($name, ['is_AliPay', 'is_QQPay', 'is_WeChatPay', 'is_otherPay']) && $value != ''){
			switch($value){
				case 'f2fpay':
					if(!self::$systemConfig['f2fpay_app_id'] || !self::$systemConfig['f2fpay_private_key']
					   || !self::$systemConfig['f2fpay_public_key']){
						return Response::json(['status' => 'fail', 'message' => '请先设置【支付宝F2F】必要参数']);
					}
					break;
				case 'codepay':
					if(!self::$systemConfig['codepay_url'] || !self::$systemConfig['codepay_id']
					   || !self::$systemConfig['codepay_key']){
						return Response::json(['status' => 'fail', 'message' => '请先设置【码支付】必要参数']);
					}
					break;
				case 'payjs':
					if(!self::$systemConfig['payjs_mch_id'] || !self::$systemConfig['payjs_key']){
						return Response::json(['status' => 'fail', 'message' => '请先设置【PayJs】必要参数']);
					}
					break;
				case 'bitpayx':
					if(!self::$systemConfig['bitpay_secret']){
						return Response::json(['status' => 'fail', 'message' => '请先设置【麻瓜宝】必要参数']);
					}
					break;
				case 'paypal':
					if(!self::$systemConfig['paypal_username'] || !self::$systemConfig['paypal_password']
					   || !self::$systemConfig['paypal_secret']){
						return Response::json(['status' => 'fail', 'message' => '请先设置【PayPal】必要参数']);
					}
					break;
				default:
					return Response::json(['status' => 'fail', 'message' => '未知支付渠道']);
					break;
			}
		}

		// 演示环境禁止修改特定配置项
		if(env('APP_DEMO')){
			$denyConfig = [
				'website_url',
				'min_rand_traffic',
				'max_rand_traffic',
				'push_bear_send_key',
				'push_bear_qrcode',
				'is_forbid_china',
				'website_security_code'
			];

			if(in_array($name, $denyConfig)){
				return Response::json(['status' => 'fail', 'message' => '演示环境禁止修改该配置']);
			}
		}

		// 如果是返利比例，则需要除100
		if(in_array($name, ['referral_percent'])){
			$value = intval($value) / 100;
		}

		// 更新配置
		Config::query()->whereName($name)->update(['value' => $value]);

		return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
	}

	//推送通知测试
	public function sendTestNotification() {
		if(self::$systemConfig['is_notification']){
			$result = PushNotification::send('这是测试的标题', 'SSRPanel_OM测试内容');
			if($result == false){
				return Response::json(['status' => 'fail', 'message' => '发送失败，请重新尝试！']);
			}
			switch(self::$systemConfig['is_notification']){
				case 'serverChan':
					if(!$result->errno){
						return Response::json(['status' => 'success', 'message' => '发送成功，请查看手机是否收到推送消息']);
					}else{
						return Response::json(['status' => 'fail', 'message' => $result? $result->errmsg : '未知']);
					}
					break;
				case 'bark':
					if($result->code == 200){
						return Response::json(['status' => 'success', 'message' => '发送成功，请查看手机是否收到推送消息']);
					}else{
						return Response::json(['status' => 'fail', 'message' => $result->message]);
					}
					break;
				default:
			}
		}

		return Response::json(['status' => 'fail', 'message' => '请先选择【日志通知】渠道']);
	}

	// 邀请码列表
	public function inviteList(Request $request) {
		$view['inviteList'] = Invite::query()
		                            ->with(['generator', 'user'])
		                            ->orderBy('status', 'asc')
		                            ->orderBy('id', 'desc')
		                            ->paginate(15)
		                            ->appends($request->except('page'));

		return Response::view('admin.inviteList', $view);
	}

	// 生成邀请码
	public function makeInvite() {
		for($i = 0; $i < 10; $i++){
			$obj = new Invite();
			$obj->uid = 0;
			$obj->fuid = 0;
			$obj->code = strtoupper(substr(md5(microtime().makeRandStr()), 8, 12));
			$obj->status = 0;
			$obj->dateline = date('Y-m-d H:i:s', strtotime("+".self::$systemConfig['admin_invite_days']." days"));
			$obj->save();
		}

		return Response::json(['status' => 'success', 'data' => '', 'message' => '生成成功']);
	}

	// 导出邀请码
	public function exportInvite() {
		$inviteList = Invite::query()->whereStatus(0)->orderBy('id', 'asc')->get();

		$filename = '邀请码'.date('Ymd').'.xlsx';

		$spreadsheet = new Spreadsheet();
		$spreadsheet->getProperties()
		            ->setCreator('SSRPanel')
		            ->setLastModifiedBy('SSRPanel')
		            ->setTitle('邀请码')
		            ->setSubject('邀请码')
		            ->setDescription('')
		            ->setKeywords('')
		            ->setCategory('');

		try{
			$spreadsheet->setActiveSheetIndex(0);
			$sheet = $spreadsheet->getActiveSheet();
			$sheet->setTitle('邀请码');
			$sheet->fromArray(['邀请码', '有效期'], null);

			foreach($inviteList as $k => $vo){
				$sheet->fromArray([$vo->code, $vo->dateline], null, 'A'.($k + 2));
			}

			header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'); // 输出07Excel文件
			//header('Content-Type:application/vnd.ms-excel'); // 输出Excel03版本文件
			header('Content-Disposition: attachment;filename="'.$filename.'"');
			header('Cache-Control: max-age=0');
			$writer = new Xlsx($spreadsheet);
			$writer->save('php://output');
		}catch(\PhpOffice\PhpSpreadsheet\Exception $e){
			Log::error('导出优惠券时报错'.$e);
		}
	}

	// 订单列表
	public function orderList(Request $request) {
		$email = $request->input('email');
		$order_sn = $request->input('order_sn');
		$is_coupon = $request->input('is_coupon');
		$is_expire = $request->input('is_expire');
		$pay_way = $request->input('pay_way');
		$status = $request->input('status');
		$range_time = $request->input('range_time');
		$sort = $request->input('sort'); // 0-按创建时间降序、1-按创建时间升序
		$order_id = $request->input('oid');

		$query = Order::query()->with(['user', 'goods', 'coupon']);

		if(isset($email)){
			$query->whereHas('user', function($q) use ($email) {
				$q->where('email', 'like', '%'.$email.'%');
			});
		}
		if(isset($order_sn)){
			$query->where('order_sn', 'like', '%'.$order_sn.'%');
		}

		if(isset($is_coupon)){
			if($is_coupon){
				$query->where('coupon_id', '<>', 0);
			}else{
				$query->whereCouponId(0);
			}
		}

		if(isset($is_expire)){
			$query->whereIsExpire($is_expire);
		}

		if(isset($pay_way)){
			$query->wherePayWay($pay_way);
		}

		if(isset($status)){
			$query->whereStatus($status);
		}

		if(isset($range_time) && $range_time != ','){
			$range_time = explode(',', $range_time);
			$query->where('created_at', '>=', $range_time[0])->where('created_at', '<=', $range_time[1]);
		}

		if(isset($order_id)){
			$query->whereOid($order_id);
		}

		if($sort){
			$query->orderBy('oid', 'asc');
		}else{
			$query->orderBy('oid', 'desc');
		}

		$view['orderList'] = $query->paginate(15)->appends($request->except('page'));

		return Response::view('admin.logs.orderList', $view);
	}

	// 重置用户流量
	public function resetUserTraffic(Request $request) {
		$id = $request->input('id');

		User::query()->whereId($id)->update(['u' => 0, 'd' => 0]);

		return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
	}

	// 操作用户余额
	public function handleUserBalance(Request $request) {
		if($request->isMethod('POST')){
			$userId = $request->input('user_id');
			$amount = $request->input('amount');

			if(empty($userId) || empty($amount)){
				return Response::json(['status' => 'fail', 'data' => '', 'message' => '充值异常']);
			}

			DB::beginTransaction();
			try{
				$user = User::query()->whereId($userId)->first();

				// 写入余额变动日志
				Helpers::addUserBalanceLog($userId, 0, $user->balance, $user->balance + $amount, $amount, '后台手动充值');

				// 加减余额
				if($amount < 0){
					$user->decrement('balance', abs($amount) * 100);
				}else{
					$user->increment('balance', abs($amount) * 100);
				}

				DB::commit();

				return Response::json(['status' => 'success', 'data' => '', 'message' => '充值成功']);
			}catch(Exception $e){
				DB::rollBack();

				return Response::json(['status' => 'fail', 'data' => '', 'message' => '充值失败：'.$e->getMessage()]);
			}
		}else{
			return Response::view('admin.handleUserBalance');
		}
	}

	// 用户余额变动记录
	public function userBalanceLogList(Request $request) {
		$email = $request->input('email');

		$query = UserBalanceLog::query()->with(['user'])->orderBy('id', 'desc');

		if(isset($email)){
			$query->whereHas('user', function($q) use ($email) {
				$q->where('email', 'like', '%'.$email.'%');
			});
		}

		$view['list'] = $query->paginate(15)->appends($request->except('page'));

		return Response::view('admin.logs.userBalanceLogList', $view);
	}

	// 用户封禁记录
	public function userBanLogList(Request $request) {
		$email = $request->input('email');

		$query = UserBanLog::query()->with(['user'])->orderBy('id', 'desc');

		if(isset($email)){
			$query->whereHas('user', function($q) use ($email) {
				$q->where('email', 'like', '%'.$email.'%');
			});
		}

		$view['list'] = $query->paginate(15)->appends($request->except('page'));

		return Response::view('admin.logs.userBanLogList', $view);
	}

	// 用户流量变动记录
	public function userTrafficLogList(Request $request) {
		$email = $request->input('email');

		$query = UserTrafficModifyLog::query()->with(['user', 'order', 'order.goods']);

		if(isset($email)){
			$query->whereHas('user', function($q) use ($email) {
				$q->where('email', 'like', '%'.$email.'%');
			});
		}

		$view['list'] = $query->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));

		return Response::view('admin.logs.userTrafficLogList', $view);
	}

	// 用户在线IP记录
	public function userOnlineIPList(Request $request) {
		$email = $request->input('email');
		$port = $request->input('port');
		$wechat = $request->input('wechat');
		$qq = $request->input('qq');

		$query = User::query()->where('status', '>=', 0)->whereEnable(1);

		if(isset($email)){
			$query->where('email', 'like', '%'.$email.'%');
		}

		if(isset($wechat)){
			$query->where('wechat', 'like', '%'.$wechat.'%');
		}

		if(isset($qq)){
			$query->where('qq', 'like', '%'.$qq.'%');
		}

		if(isset($port)){
			$query->wherePort($port);
		}

		$userList = $query->paginate(15)->appends($request->except('page'));
		if(!$userList->isEmpty()){
			foreach($userList as $user){
				// 最近5条在线IP记录，如果后端设置为60秒上报一次，则为10分钟内的在线IP
				$user->onlineIPList = SsNodeIp::query()
				                              ->with(['node'])
				                              ->whereType('tcp')
				                              ->wherePort($user->port)
				                              ->where('created_at', '>=', strtotime("-10 minutes"))
				                              ->orderBy('id', 'desc')
				                              ->limit(5)
				                              ->get();
			}
		}

		$view['userList'] = $userList;

		return Response::view('admin.logs.userOnlineIPList', $view);
	}

	// 转换成某个用户的身份
	public function switchToUser(Request $request) {
		$id = $request->input('user_id');

		$user = User::query()->find($id);
		if(!$user){
			return Response::json(['status' => 'fail', 'data' => '', 'message' => "用户不存在"]);
		}

		// 存储当前管理员ID，并将当前登录信息改成要切换的用户的身份信息
		Session::put('admin', Auth::user()->id);
		Auth::login($user);

		return Response::json(['status' => 'success', 'data' => '', 'message' => "身份切换成功"]);
	}

	// 标签列表
	public function labelList(Request $request) {
		$labelList = Label::query()->paginate(15)->appends($request->except('page'));
		foreach($labelList as $label){
			$label->userCount = UserLabel::query()->whereLabelId($label->id)->groupBy('label_id')->count();
			$label->nodeCount = SsNodeLabel::query()->whereLabelId($label->id)->groupBy('label_id')->count();
		}

		$view['labelList'] = $labelList;

		return Response::view('admin.label.labelList', $view);
	}

	// 添加标签
	public function addLabel(Request $request) {
		if($request->isMethod('POST')){
			$name = $request->input('name');
			$sort = $request->input('sort');

			$label = new Label();
			$label->name = $name;
			$label->sort = $sort;
			$label->save();

			return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
		}else{
			return Response::view('admin.label.addLabel');
		}
	}

	// 编辑标签
	public function editLabel(Request $request) {
		if($request->isMethod('POST')){
			$id = $request->input('id');
			$name = $request->input('name');
			$sort = $request->input('sort');

			Label::query()->whereId($id)->update(['name' => $name, 'sort' => $sort]);

			return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
		}else{
			$id = $request->input('id');
			$view['label'] = Label::query()->whereId($id)->first();

			return Response::view('admin.label.editLabel', $view);
		}
	}

	// 删除标签
	public function delLabel(Request $request) {
		$id = $request->input('id');

		DB::beginTransaction();
		try{
			Label::query()->whereId($id)->delete();
			UserLabel::query()->whereLabelId($id)->delete(); // 删除用户关联
			SsNodeLabel::query()->whereLabelId($id)->delete(); // 删除节点关联

			DB::commit();

			return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
		}catch(Exception $e){
			DB::rollBack();

			return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败：'.$e->getMessage()]);
		}
	}

	// 邮件发送日志列表
	public function notificationLog(Request $request) {
		$email = $request->input('email');
		$type = $request->input('type');

		$query = NotificationLog::query();

		if(isset($email)){
			$query->where('address', 'like', '%'.$email.'%');
		}

		if(isset($type)){
			$query->whereType($type);
		}

		$view['list'] = $query->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));

		return Response::view('admin.logs.notificationLog', $view);
	}

	// 在线IP监控（实时）
	public function onlineIPMonitor(Request $request) {
		$ip = $request->input('ip');
		$email = $request->input('email');
		$port = $request->input('port');
		$nodeId = $request->input('nodeId');
		$userId = $request->input('id');

		$query = SsNodeIp::query()
		                 ->with(['node', 'user'])
		                 ->whereType('tcp')
		                 ->where('created_at', '>=', strtotime("-120 seconds"));

		if(isset($ip)){
			$query->whereIp($ip);
		}

		if(isset($email)){
			$query->whereHas('user', function($q) use ($email) {
				$q->where('email', 'like', '%'.$email.'%');
			});
		}

		if(isset($port)){
			$query->whereHas('user', function($q) use ($port) {
				$q->wherePort($port);
			});
		}

		if(isset($nodeId)){
			$query->whereHas('node', function($q) use ($nodeId) {
				$q->whereId($nodeId);
			});
		}

		if(isset($userId)){
			$query->whereHas('user', function($q) use ($userId) {
				$q->whereId($userId);
			});
		}

		$list = $query->groupBy('port')->orderBy('id', 'desc');

		foreach($list as $vo){
			// 跳过上报多IP的
			if(strpos($vo->ip, ',') == true){
				continue;
			}

			$ipInfo = QQWry::ip($vo->ip);
			if(isset($ipInfo['error'])){
				// 用IPIP的库再试一下
				$ipip = IPIP::ip($vo->ip);
				$ipInfo = [
					'country'  => $ipip['country_name'],
					'province' => $ipip['region_name'],
					'city'     => $ipip['city_name']
				];
			}

			$vo->ipInfo = $ipInfo['country'].' '.$ipInfo['province'].' '.$ipInfo['city'];
		}

		$view['list'] = $list->paginate(20)->appends($request->except('page'));
		$view['nodeList'] = SsNode::query()->whereStatus(1)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get();

		return Response::view('admin.logs.onlineIPMonitor', $view);
	}
}