countLine($file); if ($fileLines < 15000) { return false; } $fp = fopen($file, 'rb+'); assert($n > 0); $pos = $n + 1; $lines = []; while (count($lines) <= $n) { try { fseek($fp, -$pos, SEEK_END); } catch (Exception $e) { 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): int { $fp = fopen($file, 'rb'); $i = 0; while (!feof($fp)) { //每次读取2M if ($data = fread($fp, 1024 * 1024 * 2)) { //计算读取到的行数 $num = substr_count($data, "\n"); $i += $num; } } fclose($fp); return $i; } // 获取邮箱后缀 public function emailFilterList($type): array { return EmailFilter::whereType($type)->pluck('words')->toArray(); } // 将Base64图片转换为本地图片并保存 public function base64ImageSaver($base64_image_content): ?string { // 匹配出图片的格式 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($concurrentDirectory = public_path($path), 0755, true) && !is_dir($concurrentDirectory)) { throw new RuntimeException(sprintf('Directory "%s" was not created', $concurrentDirectory)); } $fileName = Str::random(18).".{$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; } } return ''; } /** * 节点信息 * * @param int $uid 用户ID * @param int $nodeId 节点ID * @param int $infoType 信息类型:0为链接,1为文字 * * @return string */ public function getUserNodeInfo(int $uid, int $nodeId, int $infoType): string { $user = User::find($uid); $node = Node::find($nodeId); $scheme = null; $group = sysConfig('website_name');// 分组名称 $host = $node->is_relay ? $node->relay_server : ($node->server ?: $node->ip); $data = null; switch ($node->type) { case 2: // 生成v2ray scheme if ($infoType !== 1) { // 生成v2ray scheme $data = $this->v2raySubUrl($node->name, $host, $node->v2_port, $user->vmess_id, $node->v2_alter_id, $node->v2_net, $node->v2_type, $node->v2_host, $node->v2_path, $node->v2_tls ? "tls" : ""); } 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; } break; case 3: if ($infoType !== 1) { $data = $this->trojanSubUrl($user->passwd, $host, $node->port, $node->name); } else { $data = "备注:".$node->name.PHP_EOL."服务器:".$host.PHP_EOL."密码:".$user->passwd.PHP_EOL."端口:".$node->port.PHP_EOL; } break; case 1: case 4: $protocol = $node->protocol; $method = $node->method; $obfs = $node->obfs; if ($node->single) { //单端口使用中转的端口 $port = $node->is_relay ? $node->relay_port : $node->port; $passwd = $node->passwd; $protocol_param = $user->port.':'.$user->passwd; } else { $port = $user->port; $passwd = $user->passwd; $protocol_param = $node->protocol_param; if ($node->type === 1) { $protocol = $user->protocol; $method = $user->method; $obfs = $user->obfs; } } if ($infoType !== 1) { // 生成ss/ssr scheme $data = $node->compatible ? $this->ssSubUrl($host, $port, $method, $passwd, $group) : $this->ssrSubUrl($host, $port, $protocol, $method, $obfs, $passwd, $node->obfs_param, $protocol_param, $node->name, $group, $node->is_udp); } else { // 生成文本配置信息 $data = "服务器:".$host.PHP_EOL."IPv6:".$node->ipv6.PHP_EOL."服务器端口:".$port.PHP_EOL."密码:".$passwd.PHP_EOL."加密:".$method.PHP_EOL.($node->compatible ? '' : "协议:".$protocol.PHP_EOL."协议参数:".$protocol_param.PHP_EOL."混淆:".$obfs.PHP_EOL."混淆参数:".$node->obfs_param.PHP_EOL); } break; default: } return $data; } public function v2raySubUrl($name, $host, $port, $uuid, $alter_id, $net, $type, $domain, $path, $tls): string { return 'vmess://'.base64url_encode(json_encode([ "v" => "2", "ps" => $name, "add" => $host, "port" => $port, "id" => $uuid, "aid" => $alter_id, "net" => $net, "type" => $type, "host" => $domain, "path" => $path, "tls" => $tls ? "tls" : "", ], JSON_PRETTY_PRINT)); } public function trojanSubUrl($password, $domain, $port, $remark): string { return 'trojan://'.urlencode($password).'@'.$domain.':'.$port.'#'.urlencode($remark); } public function ssSubUrl($host, $port, $method, $passwd, $group): string { return 'ss://'.base64url_encode($method.':'.$passwd.'@'.$host.':'.$port).'#'.$group; } public function ssrSubUrl($host, $port, $protocol, $method, $obfs, $passwd, $obfs_param, $protocol_param, $name, $group, $is_udp): string { return 'ssr://'.base64url_encode($host.':'.$port.':'.$protocol.':'.$method.':'.$obfs.':'.base64url_encode($passwd).'/?obfsparam='.base64url_encode($obfs_param).'&protoparam='.base64url_encode($protocol_param).'&remarks='.base64url_encode($name).'&group='.base64url_encode($group).'&udpport='.$is_udp.'&uot=0'); } // 流量使用图表 public function dataFlowChart($id, $is_node = 0): array { if ($is_node) { $currentFlow = UserDataFlowLog::whereNodeId($id); $hourlyFlow = NodeHourlyDataFlow::whereNodeId($id); $dailyFlow = NodeDailyDataFlow::whereNodeId($id); } else { $currentFlow = UserDataFlowLog::whereUserId($id); $hourlyFlow = UserHourlyDataFlow::userHourly($id); $dailyFlow = UserDailyDataFlow::userDaily($id); } $currentFlow = $currentFlow->where('log_time', '>=', strtotime(date('Y-m-d H:00')))->sum(DB::raw('u + d')); $hourlyFlow = $hourlyFlow->whereDate('created_at', date('Y-m-d'))->pluck('total', 'created_at')->toArray(); $dailyFlow = $dailyFlow->whereMonth('created_at', date('n'))->pluck('total', 'created_at')->toArray(); // 节点一天内的流量 $hourlyData = array_fill(0, date('G') + 1, 0); foreach ($hourlyFlow as $date => $dataFlow) { $hourlyData[date('G', strtotime($date))] = round($dataFlow / GB, 3); } $hourlyData[date('G') + 1] = round($currentFlow / GB, 3); // 节点一个月内的流量 $dailyData = array_fill(0, date('j'), 0); foreach ($dailyFlow as $date => $dataFlow) { $dailyData[date('j', strtotime($date)) - 1] = round($dataFlow / GB, 3); } $dailyData[date('j', strtotime(now())) - 1] = round((array_sum($hourlyFlow) + $currentFlow) / GB, 3); return [ 'trafficDaily' => json_encode($dailyData), 'trafficHourly' => json_encode($hourlyData), 'monthDays' => json_encode(range(1, date("j"), 1)),// 本月天数 'dayHours' => json_encode(range(0, date("G") + 1, 1))// 本日小时 ]; } }