ToolsController.php 6.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Components\Helpers;
  4. use App\Http\Controllers\Controller;
  5. use App\Models\User;
  6. use DB;
  7. use Exception;
  8. use Hash;
  9. use Illuminate\Http\Request;
  10. use Redirect;
  11. use Response;
  12. use Session;
  13. class ToolsController extends Controller {
  14. // SS(R)链接反解析
  15. public function decompile(Request $request) {
  16. if($request->isMethod('POST')){
  17. $content = $request->input('content');
  18. if(empty($content)){
  19. return Response::json(['status' => 'fail', 'message' => '请在左侧填入要反解析的SS(R)链接']);
  20. }
  21. // 反解析处理
  22. $content = str_replace("\n", ",", $content);
  23. $content = explode(',', $content);
  24. $txt = '';
  25. foreach($content as $item){
  26. // 判断是SS还是SSR链接
  27. $str = '';
  28. if(str_contains($item, 'ssr://')){
  29. $str = mb_substr($item, 6);
  30. }elseif(str_contains($item, 'ss://')){
  31. $str = mb_substr($item, 5);
  32. }
  33. $txt .= "\r\n".base64url_decode($str);
  34. }
  35. // 生成转换好的JSON文件
  36. file_put_contents(public_path('downloads/decompile.json'), $txt);
  37. return Response::json(['status' => 'success', 'data' => $txt, 'message' => '反解析成功']);
  38. }
  39. return view('admin.tools.decompile');
  40. }
  41. // 格式转换(SS转SSR)
  42. public function convert(Request $request) {
  43. if($request->isMethod('POST')){
  44. $method = $request->input('method');
  45. $transfer_enable = $request->input('transfer_enable');
  46. $protocol = $request->input('protocol');
  47. $protocol_param = $request->input('protocol_param');
  48. $obfs = $request->input('obfs');
  49. $obfs_param = $request->input('obfs_param');
  50. $content = $request->input('content');
  51. if(empty($content)){
  52. return Response::json(['status' => 'fail', 'message' => '请在左侧填入要转换的内容']);
  53. }
  54. // 校验格式
  55. $content = json_decode($content, true);
  56. if(empty($content->port_password)){
  57. return Response::json(['status' => 'fail', 'message' => '转换失败:配置信息里缺少【port_password】字段,或者该字段为空']);
  58. }
  59. // 转换成SSR格式JSON
  60. $data = [];
  61. foreach($content->port_password as $port => $passwd){
  62. $data[] = [
  63. 'u' => 0,
  64. 'd' => 0,
  65. 'enable' => 1,
  66. 'method' => $method,
  67. 'obfs' => $obfs,
  68. 'obfs_param' => empty($obfs_param)? "" : $obfs_param,
  69. 'passwd' => $passwd,
  70. 'port' => $port,
  71. 'protocol' => $protocol,
  72. 'protocol_param' => empty($protocol_param)? "" : $protocol_param,
  73. 'transfer_enable' => toGB($transfer_enable),
  74. 'user' => date('Ymd').'_IMPORT_'.$port,
  75. ];
  76. }
  77. $json = json_encode($data);
  78. // 生成转换好的JSON文件
  79. file_put_contents(public_path('downloads/convert.json'), $json);
  80. return Response::json(['status' => 'success', 'data' => $json, 'message' => '转换成功']);
  81. }
  82. // 加密方式、协议、混淆
  83. $view['methodList'] = Helpers::methodList();
  84. $view['protocolList'] = Helpers::protocolList();
  85. $view['obfsList'] = Helpers::obfsList();
  86. return view('admin.tools.convert', $view);
  87. }
  88. // 下载转换好的JSON文件
  89. public function download(Request $request) {
  90. $type = $request->input('type');
  91. if(empty($type)){
  92. exit('参数异常');
  93. }
  94. if($type == '1'){
  95. $filePath = public_path('downloads/convert.json');
  96. }else{
  97. $filePath = public_path('downloads/decompile.json');
  98. }
  99. if(!file_exists($filePath)){
  100. exit('文件不存在,请检查目录权限');
  101. }
  102. return Response::download($filePath);
  103. }
  104. // 数据导入
  105. public function import(Request $request) {
  106. if($request->isMethod('POST')){
  107. if(!$request->hasFile('uploadFile')){
  108. Session::flash('errorMsg', '请选择要上传的文件');
  109. return Redirect::back();
  110. }
  111. $file = $request->file('uploadFile');
  112. // 只能上传JSON文件
  113. if($file->getClientMimeType() !== 'application/json' || $file->getClientOriginalExtension() !== 'json'){
  114. Session::flash('errorMsg', '只允许上传JSON文件');
  115. return Redirect::back();
  116. }
  117. if(!$file->isValid()){
  118. Session::flash('errorMsg', '产生未知错误,请重新上传');
  119. return Redirect::back();
  120. }
  121. $save_path = realpath(storage_path('uploads'));
  122. $new_name = md5($file->getClientOriginalExtension()).'.json';
  123. $file->move($save_path, $new_name);
  124. // 读取文件内容
  125. $data = file_get_contents($save_path.'/'.$new_name);
  126. $data = json_decode($data, true);
  127. if(!$data){
  128. Session::flash('errorMsg', '内容格式解析异常,请上传符合SSR(R)配置规范的JSON文件');
  129. return Redirect::back();
  130. }
  131. try{
  132. DB::beginTransaction();
  133. foreach($data as $user){
  134. $obj = new User();
  135. $obj->username = $user->user;
  136. $obj->email = $user->user;
  137. $obj->password = Hash::make('123456');
  138. $obj->port = $user->port;
  139. $obj->passwd = $user->passwd;
  140. $obj->vmess_id = $user->uuid;
  141. $obj->transfer_enable = $user->transfer_enable;
  142. $obj->method = $user->method;
  143. $obj->protocol = $user->protocol;
  144. $obj->obfs = $user->obfs;
  145. $obj->expired_at = '2099-01-01';
  146. $obj->reg_ip = getClientIp();
  147. $obj->created_at = date('Y-m-d H:i:s');
  148. $obj->updated_at = date('Y-m-d H:i:s');
  149. $obj->save();
  150. }
  151. DB::commit();
  152. }catch(Exception $e){
  153. DB::rollBack();
  154. Session::flash('errorMsg', '出错了,可能是导入的配置中有端口已经存在了');
  155. return Redirect::back();
  156. }
  157. Session::flash('successMsg', '导入成功');
  158. return Redirect::back();
  159. }
  160. return view('admin.tools.import');
  161. }
  162. // 日志分析
  163. public function analysis() {
  164. $file = storage_path('app/ssserver.log');
  165. if(!file_exists($file)){
  166. Session::flash('analysisErrorMsg', $file.' 不存在,请先创建文件');
  167. return view('admin.tools.analysis');
  168. }
  169. $logs = $this->tail($file, 10000);
  170. if(false === $logs){
  171. $view['urlList'] = [];
  172. }else{
  173. $url = [];
  174. foreach($logs as $log){
  175. if(str_contains($log, 'TCP connecting')){
  176. continue;
  177. }
  178. preg_match('/TCP request (\w+\.){2}\w+/', $log, $tcp_matches);
  179. if(!empty($tcp_matches)){
  180. $url[] = str_replace('TCP request ', '[TCP] ', $tcp_matches[0]);
  181. }else{
  182. 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)/',
  183. $log, $udp_matches);
  184. if(!empty($udp_matches)){
  185. $url[] = str_replace('UDP data to ', '[UDP] ', $udp_matches[0]);
  186. }
  187. }
  188. }
  189. $view['urlList'] = array_unique($url);
  190. }
  191. return view('admin.tools.analysis', $view);
  192. }
  193. }