neiyou_user_web/app/Http/Controllers/Controller.php

<?php

namespace App\Http\Controllers;

use App\Components\Helpers;
use App\Http\Models\ReferralLog;
use App\Http\Models\SensitiveWords;
use App\Http\Models\SsGroup;
use App\Http\Models\SsNode;
use App\Http\Models\User;
use App\Http\Models\UserBalanceLog;
use App\Http\Models\UserSubscribeLog;
use Exception;
use Illuminate\Foundation\Auth\Access\AuthorizesRequests;
use Illuminate\Foundation\Bus\DispatchesJobs;
use Illuminate\Foundation\Validation\ValidatesRequests;
use Illuminate\Routing\Controller as BaseController;

class Controller extends BaseController
{
	use AuthorizesRequests, DispatchesJobs, ValidatesRequests;

	// 生成随机密码
	public function makePasswd()
	{
		return makeRandStr();
	}

	// 生成VmessId
	public function makeVmessId()
	{
		return createGuid();
	}

	// 生成网站安全码
	public function makeSecurityCode()
	{
		return strtolower(makeRandStr(8));
	}

	// 类似Linux中的tail命令
	public function tail($file, $n, $base = 5)
	{
		$fileLines = $this->countLine($file);
		if($fileLines < 15000){
			return FALSE;
		}

		$fp = fopen($file, "r+");
		assert($n > 0);
		$pos = $n+1;
		$lines = [];
		while(count($lines) <= $n){
			try{
				fseek($fp, -$pos, SEEK_END);
			} catch(Exception $e){
				fseek(0);
				break;
			}

			$pos *= $base;
			while(!feof($fp)){
				array_unshift($lines, fgets($fp));
			}
		}

		return array_slice($lines, 0, $n);
	}

	/**
	 * 计算文件行数
	 * @param $file
	 * @return int
	 */
	public function countLine($file)
	{
		$fp = fopen($file, "r");
		$i = 0;
		while(!feof($fp)){
			//每次读取2M
			if($data = fread($fp, 1024*1024*2)){
				//计算读取到的行数
				$num = substr_count($data, "\n");
				$i += $num;
			}
		}

		fclose($fp);

		return $i;
	}

	/**
	 * 记录余额操作日志
	 *
	 * @param int    $userId 用户ID
	 * @param string $oid    订单ID
	 * @param int    $before 记录前余额
	 * @param int    $after  记录后余额
	 * @param int    $amount 发生金额
	 * @param string $desc   描述
	 *
	 * @return int
	 */
	public function addUserBalanceLog($userId, $oid, $before, $after, $amount, $desc = '')
	{
		$log = new UserBalanceLog();
		$log->user_id = $userId;
		$log->order_id = $oid;
		$log->before = $before;
		$log->after = $after;
		$log->amount = $amount;
		$log->desc = $desc;
		$log->created_at = date('Y-m-d H:i:s');

		return $log->save();
	}

	/**
	 * 添加返利日志
	 *
	 * @param int $userId    用户ID
	 * @param int $refUserId 返利用户ID
	 * @param int $oid       订单ID
	 * @param int $amount    发生金额
	 * @param int $refAmount 返利金额
	 *
	 * @return int
	 */
	public function addReferralLog($userId, $refUserId, $oid, $amount, $refAmount)
	{
		$log = new ReferralLog();
		$log->user_id = $userId;
		$log->ref_user_id = $refUserId;
		$log->order_id = $oid;
		$log->amount = $amount;
		$log->ref_amount = $refAmount;
		$log->status = 0;

		return $log->save();
	}

	// 获取敏感词
	public function sensitiveWords($type)
	{
		return SensitiveWords::query()->where('type', $type)->get()->pluck('words')->toArray();
	}

	// 将Base64图片转换为本地图片并保存
	function base64ImageSaver($base64_image_content)
	{
		// 匹配出图片的格式
		if(preg_match('/^(data:\s*image\/(\w+);base64,)/', $base64_image_content, $result)){
			$type = $result[2];

			$directory = date('Ymd');
			$path = '/assets/images/qrcode/'.$directory.'/';
			if(!file_exists(public_path($path))){ // 检查是否有该文件夹，如果没有就创建，并给予最高权限
				mkdir(public_path($path), 0755, TRUE);
			}

			$fileName = makeRandStr(18, TRUE).".{$type}";
			if(file_put_contents(public_path($path.$fileName), base64_decode(str_replace($result[1], '', $base64_image_content)))){
				chmod(public_path($path.$fileName), 0744);

				return $path.$fileName;
			}else{
				return '';
			}
		}else{
			return '';
		}
	}

	/**
	 * 节点信息
	 *
	 * @param int $uid      用户ID
	 * @param int $nodeId   节点ID
	 * @param int $infoType 信息类型：0为链接，1为文字
	 * @return string
	 */
	function getNodeInfo($uid, $nodeId, $infoType)
	{
		$user = User::whereKey($uid)->first();
		$node = SsNode::whereKey($nodeId)->first();
		$scheme = NULL;
		// 获取分组名称
		$group = SsGroup::query()->whereKey($node->group_id)->first();
		$host = $node->server? : $node->ip;

		if($node->type == 1){
			$group = $group? $group->name : Helpers::systemConfig()['website_name'];
			$obfs_param = $user->obfs_param? : $node->obfs_param;
			if($node->single){
				$port = $node->port;
				$protocol = $node->protocol;
				$method = $node->method;
				$obfs = $node->obfs;
				$passwd = $node->passwd;
				$protocol_param = $user->port.':'.$user->passwd;
			}else{
				$port = $user->port;
				$protocol = $user->protocol;
				$method = $user->method;
				$obfs = $user->obfs;
				$passwd = $user->passwd;
				$protocol_param = $user->protocol_param;
			}
			if($infoType != 1){
				// 生成ss/ssr scheme
				if($node->compatible){
					$data = 'ss://'.base64url_encode($method.':'.$passwd.'@'.$host.':'.$port).'#'.$group;
				}else{
					$data = 'ssr://'.base64url_encode($host.':'.$port.':'.$protocol.':'.$method.':'.$obfs.':'.base64url_encode($passwd).'/?obfsparam='.base64url_encode($obfs_param).'&protoparam='.base64url_encode($protocol_param).'&remarks='.base64url_encode($node->name).'&group='.base64url_encode($group).'&udpport=0&uot=0');
				}
			}else{
				// 生成文本配置信息
				$data = "服务器：".$host.PHP_EOL.
					"IPv6：".($node->ipv6? : '').PHP_EOL.
					"远程端口：".$port.PHP_EOL.
					"密码：".$passwd.PHP_EOL.
					"加密方法：".$method.PHP_EOL.
					"路由：绕过局域网及中国大陆地址".PHP_EOL.
					"协议：".$protocol.PHP_EOL.
					"协议参数：".$protocol_param.PHP_EOL.
					"混淆方式：".$obfs.PHP_EOL.
					"混淆参数：".$obfs_param.PHP_EOL.
					"本地端口：1080".PHP_EOL;
			}
		}else{
			// 生成v2ray scheme
			if($infoType != 1){
				// 生成v2ray scheme
				$data = 'vmess://'.base64_encode(json_encode(["v" => "2", "ps" => $node->name, "add" => $host, "port" => $node->v2_port, "id" => $user->vmess_id, "aid" => $node->v2_alter_id, "net" => $node->v2_net, "type" => $node->v2_type, "host" => $node->v2_host, "path" => $node->v2_path, "tls" => $node->v2_tls? "tls" : ""], JSON_PRETTY_PRINT));
			}else{
				$data = "服务器：".$host.PHP_EOL.
					"IPv6：".($node->ipv6? : "").PHP_EOL.
					"端口：".$node->v2_port.PHP_EOL.
					"加密方式：".$node->v2_method.PHP_EOL.
					"用户ID：".$user->vmess_id.PHP_EOL.
					"额外ID：".$node->v2_alter_id.PHP_EOL.
					"传输协议：".$node->v2_net.PHP_EOL.
					"伪装类型：".$node->v2_type.PHP_EOL.
					"伪装域名：".($node->v2_host? : "").PHP_EOL.
					"路径：".($node->v2_path? : "").PHP_EOL.
					"TLS：".($node->v2_tls? "tls" : "").PHP_EOL;
			}
		}

		return $data;
	}

	// 写入订阅访问日志
	public function log($subscribeId, $ip, $headers)
	{
		$log = new UserSubscribeLog();
		$log->sid = $subscribeId;
		$log->request_ip = $ip;
		$log->request_time = date('Y-m-d H:i:s');
		$log->request_header = $headers;
		$log->save();
	}
}