Controller.php 6.4 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Helpers;
  4. use App\Http\Models\SensitiveWords;
  5. use App\Http\Models\SsGroup;
  6. use App\Http\Models\SsNode;
  7. use App\Http\Models\User;
  8. use App\Http\Models\UserBalanceLog;
  9. use App\Http\Models\UserSubscribeLog;
  10. use Exception;
  11. use Illuminate\Foundation\Auth\Access\AuthorizesRequests;
  12. use Illuminate\Foundation\Bus\DispatchesJobs;
  13. use Illuminate\Foundation\Validation\ValidatesRequests;
  14. use Illuminate\Routing\Controller as BaseController;
  15. class Controller extends BaseController
  16. {
  17. use AuthorizesRequests, DispatchesJobs, ValidatesRequests;
  18. // 生成随机密码
  19. public function makePasswd()
  20. {
  21. return makeRandStr();
  22. }
  23. // 生成VmessId
  24. public function makeVmessId()
  25. {
  26. return createGuid();
  27. }
  28. // 生成网站安全码
  29. public function makeSecurityCode()
  30. {
  31. return strtolower(makeRandStr(8));
  32. }
  33. // 类似Linux中的tail命令
  34. public function tail($file, $n, $base = 5)
  35. {
  36. $fileLines = $this->countLine($file);
  37. if($fileLines < 15000){
  38. return FALSE;
  39. }
  40. $fp = fopen($file, "r+");
  41. assert($n > 0);
  42. $pos = $n+1;
  43. $lines = [];
  44. while(count($lines) <= $n){
  45. try{
  46. fseek($fp, -$pos, SEEK_END);
  47. } catch(Exception $e){
  48. fseek(0);
  49. break;
  50. }
  51. $pos *= $base;
  52. while(!feof($fp)){
  53. array_unshift($lines, fgets($fp));
  54. }
  55. }
  56. return array_slice($lines, 0, $n);
  57. }
  58. /**
  59. * 计算文件行数
  60. * @param $file
  61. * @return int
  62. */
  63. public function countLine($file)
  64. {
  65. $fp = fopen($file, "r");
  66. $i = 0;
  67. while(!feof($fp)){
  68. //每次读取2M
  69. if($data = fread($fp, 1024*1024*2)){
  70. //计算读取到的行数
  71. $num = substr_count($data, "\n");
  72. $i += $num;
  73. }
  74. }
  75. fclose($fp);
  76. return $i;
  77. }
  78. /**
  79. * 记录余额操作日志
  80. *
  81. * @param int $userId 用户ID
  82. * @param string $oid 订单ID
  83. * @param int $before 记录前余额
  84. * @param int $after 记录后余额
  85. * @param int $amount 发生金额
  86. * @param string $desc 描述
  87. *
  88. * @return int
  89. */
  90. public function addUserBalanceLog($userId, $oid, $before, $after, $amount, $desc = '')
  91. {
  92. $log = new UserBalanceLog();
  93. $log->user_id = $userId;
  94. $log->order_id = $oid;
  95. $log->before = $before;
  96. $log->after = $after;
  97. $log->amount = $amount;
  98. $log->desc = $desc;
  99. $log->created_at = date('Y-m-d H:i:s');
  100. return $log->save();
  101. }
  102. // 获取敏感词
  103. public function sensitiveWords($type)
  104. {
  105. return SensitiveWords::query()->where('type', $type)->get()->pluck('words')->toArray();
  106. }
  107. // 将Base64图片转换为本地图片并保存
  108. function base64ImageSaver($base64_image_content)
  109. {
  110. // 匹配出图片的格式
  111. if(preg_match('/^(data:\s*image\/(\w+);base64,)/', $base64_image_content, $result)){
  112. $type = $result[2];
  113. $directory = date('Ymd');
  114. $path = '/assets/images/qrcode/'.$directory.'/';
  115. if(!file_exists(public_path($path))){ // 检查是否有该文件夹,如果没有就创建,并给予最高权限
  116. mkdir(public_path($path), 0755, TRUE);
  117. }
  118. $fileName = makeRandStr(18, TRUE).".{$type}";
  119. if(file_put_contents(public_path($path.$fileName), base64_decode(str_replace($result[1], '', $base64_image_content)))){
  120. chmod(public_path($path.$fileName), 0744);
  121. return $path.$fileName;
  122. }else{
  123. return '';
  124. }
  125. }else{
  126. return '';
  127. }
  128. }
  129. /**
  130. * 节点信息
  131. *
  132. * @param int $uid 用户ID
  133. * @param int $nodeId 节点ID
  134. * @param int $infoType 信息类型:0为链接,1为文字
  135. * @return string
  136. */
  137. function getNodeInfo($uid, $nodeId, $infoType)
  138. {
  139. $user = User::whereKey($uid)->first();
  140. $node = SsNode::whereKey($nodeId)->first();
  141. $scheme = NULL;
  142. // 获取分组名称
  143. $group = SsGroup::query()->whereKey($node->group_id)->first();
  144. $host = $node->server? : $node->ip;
  145. if($node->type == 1){
  146. $group = $group? $group->name : Helpers::systemConfig()['website_name'];
  147. $obfs_param = $user->obfs_param? : $node->obfs_param;
  148. if($node->single){
  149. $port = $node->port;
  150. $protocol = $node->protocol;
  151. $method = $node->method;
  152. $obfs = $node->obfs;
  153. $passwd = $node->passwd;
  154. $protocol_param = $user->port.':'.$user->passwd;
  155. }else{
  156. $port = $user->port;
  157. $protocol = $user->protocol;
  158. $method = $user->method;
  159. $obfs = $user->obfs;
  160. $passwd = $user->passwd;
  161. $protocol_param = $user->protocol_param;
  162. }
  163. if($infoType != 1){
  164. // 生成ss/ssr scheme
  165. if($node->compatible){
  166. $data = 'ss://'.base64url_encode($method.':'.$passwd.'@'.$host.':'.$port).'#'.$group;
  167. }else{
  168. $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');
  169. }
  170. }else{
  171. // 生成文本配置信息
  172. $data = "服务器:".$host.PHP_EOL.
  173. "IPv6:".($node->ipv6? : '').PHP_EOL.
  174. "远程端口:".$port.PHP_EOL.
  175. "密码:".$passwd.PHP_EOL.
  176. "加密方法:".$method.PHP_EOL.
  177. "路由:绕过局域网及中国大陆地址".PHP_EOL.
  178. "协议:".$protocol.PHP_EOL.
  179. "协议参数:".$protocol_param.PHP_EOL.
  180. "混淆方式:".$obfs.PHP_EOL.
  181. "混淆参数:".$obfs_param.PHP_EOL.
  182. "本地端口:1080".PHP_EOL;
  183. }
  184. }else{
  185. // 生成v2ray scheme
  186. if($infoType != 1){
  187. // 生成v2ray scheme
  188. $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));
  189. }else{
  190. $data = "服务器:".$host.PHP_EOL.
  191. "IPv6:".($node->ipv6? : "").PHP_EOL.
  192. "端口:".$node->v2_port.PHP_EOL.
  193. "加密方式:".$node->v2_method.PHP_EOL.
  194. "用户ID:".$user->vmess_id.PHP_EOL.
  195. "额外ID:".$node->v2_alter_id.PHP_EOL.
  196. "传输协议:".$node->v2_net.PHP_EOL.
  197. "伪装类型:".$node->v2_type.PHP_EOL.
  198. "伪装域名:".($node->v2_host? : "").PHP_EOL.
  199. "路径:".($node->v2_path? : "").PHP_EOL.
  200. "TLS:".($node->v2_tls? "tls" : "").PHP_EOL;
  201. }
  202. }
  203. return $data;
  204. }
  205. // 写入订阅访问日志
  206. public function log($subscribeId, $ip, $headers)
  207. {
  208. $log = new UserSubscribeLog();
  209. $log->sid = $subscribeId;
  210. $log->request_ip = $ip;
  211. $log->request_time = date('Y-m-d H:i:s');
  212. $log->request_header = $headers;
  213. $log->save();
  214. }
  215. }