AdminController.php 33 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Http\Models\Config;
  4. use App\Http\Models\SsConfig;
  5. use App\Http\Models\SsNode;
  6. use App\Http\Models\SsNodeInfo;
  7. use App\Http\Models\SsNodeOnlineLog;
  8. use App\Http\Models\User;
  9. use App\Http\Models\UserTrafficLog;
  10. use Illuminate\Http\Request;
  11. use Redirect;
  12. use Response;
  13. class AdminController extends BaseController
  14. {
  15. public function index(Request $request)
  16. {
  17. if (!$request->session()->has('user')) {
  18. return Redirect::to('login');
  19. }
  20. $past = strtotime(date('Y-m-d', strtotime("-7 days")));
  21. $online = time() - 3600;
  22. $view['userCount'] = User::count();
  23. $view['activeUserCount'] = User::where('t', '>=', $past)->count();
  24. $view['onlineUserCount'] = User::where('t', '>=', $online)->count();
  25. $view['nodeCount'] = SsNode::count();
  26. $flowCount = UserTrafficLog::sum('u') + UserTrafficLog::sum('d');
  27. $flowCount = $this->flowAutoShow($flowCount);
  28. $view['flowCount'] = $flowCount;
  29. $view['totalBalance'] = User::sum('balance');
  30. $view['expireWarningUserCount'] = User::where('expire_time', '<=', date('Y-m-d', strtotime("+15 days")))->count();
  31. // 到期账号禁用
  32. User::where('enable', 1)->where('expire_time', '<=', date('Y-m-d'))->update(['enable' => 0]);
  33. return Response::view('admin/index', $view);
  34. }
  35. // 用户列表
  36. public function userList(Request $request)
  37. {
  38. if (!$request->session()->has('user')) {
  39. return Redirect::to('login');
  40. }
  41. $username = $request->get('username');
  42. $wechat = $request->get('wechat');
  43. $qq = $request->get('qq');
  44. $port = $request->get('port');
  45. $pay_way = $request->get('pay_way');
  46. $enable = $request->get('enable');
  47. $expireWarning = $request->get('expireWarning');
  48. $query = User::query();
  49. if (!empty($username)) {
  50. $query->where('username', 'like', '%' . $username . '%');
  51. }
  52. if (!empty($wechat)) {
  53. $query->where('wechat', 'like', '%' . $wechat . '%');
  54. }
  55. if (!empty($qq)) {
  56. $query->where('qq', 'like', '%' . $qq . '%');
  57. }
  58. if (!empty($port)) {
  59. $query->where('port', intval($port));
  60. }
  61. if (!empty($pay_way)) {
  62. $query->where('pay_way', intval($pay_way));
  63. }
  64. if ($enable != '') {
  65. $query->where('enable', intval($enable));
  66. }
  67. // 临近过期提醒
  68. if ($expireWarning) {
  69. $query->where('expire_time', '<=', date('Y-m-d', strtotime("+15 days")));
  70. }
  71. $userList = $query->orderBy('id', 'desc')->paginate(10);
  72. foreach ($userList as &$user) {
  73. $user->transfer_enable = $this->flowAutoShow($user->transfer_enable);
  74. $user->used_flow = $this->flowAutoShow($user->u + $user->d);
  75. $user->expireWarning = $user->expire_time <= date('Y-m-d', strtotime("+ 30 days")) ? 1 : 0;
  76. }
  77. $view['userList'] = $userList;
  78. return Response::view('admin/userList', $view);
  79. }
  80. // 添加账号
  81. public function addUser(Request $request)
  82. {
  83. if (!$request->session()->has('user')) {
  84. return Redirect::to('login');
  85. }
  86. if ($request->method() == 'POST') {
  87. $username = $request->get('username');
  88. $password = $request->get('password');
  89. $port = $request->get('port');
  90. $passwd = $request->get('passwd');
  91. $transfer_enable = $request->get('transfer_enable');
  92. $enable = $request->get('enable');
  93. $method = $request->get('method');
  94. $custom_method = $request->get('custom_method');
  95. $protocol = $request->get('protocol');
  96. $protocol_param = $request->get('protocol_param');
  97. $obfs = $request->get('obfs');
  98. $obfs_param = $request->get('obfs_param');
  99. $wechat = $request->get('wechat');
  100. $qq = $request->get('qq');
  101. $usage = $request->get('usage');
  102. $pay_way = $request->get('pay_way');
  103. $balance = $request->get('balance');
  104. $enable_time = $request->get('enable_time');
  105. $expire_time = $request->get('expire_time');
  106. $remark = $request->get('remark');
  107. $is_admin = $request->get('is_admin');
  108. // 密码为空时生成默认密码
  109. if (empty($password)) {
  110. $str = $this->makeRandStr();
  111. $password = md5($str);
  112. } else {
  113. $password = md5($password);
  114. }
  115. $ret = User::create([
  116. 'username' => $username,
  117. 'password' => $password,
  118. 'port' => $port,
  119. 'passwd' => empty($passwd) ? $this->makeRandStr() : $passwd, // SS密码为空时生成默认密码
  120. 'transfer_enable' => $transfer_enable,
  121. 'enable' => $enable,
  122. 'method' => $method,
  123. 'custom_method' => $custom_method,
  124. 'protocol' => $protocol,
  125. 'protocol_param' => $protocol_param,
  126. 'obfs' => $obfs,
  127. 'obfs_param' => $obfs_param,
  128. 'wechat' => $wechat,
  129. 'qq' => $qq,
  130. 'usage' => $usage,
  131. 'pay_way' => $pay_way,
  132. 'balance' => $balance,
  133. 'enable_time' => empty($enable_time) ? date('Y-m-d') : $enable_time,
  134. 'expire_time' => empty($expire_time) ? '2099-1-1' : $expire_time,
  135. 'remark' => $remark,
  136. 'is_admin' => $is_admin,
  137. 'reg_ip' => $request->getClientIp()
  138. ]);
  139. if ($ret) {
  140. return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
  141. } else {
  142. return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败']);
  143. }
  144. } else {
  145. $config = $this->systemConfig();
  146. // 最后一个可用端口
  147. $last_user = User::orderBy('id', 'desc')->first();
  148. $view['last_port'] = $config['is_rand_port'] ? $this->getRandPort() : $last_user->port + 1;
  149. // 加密方式、协议、混淆
  150. $view['method_list'] = $this->methodList();
  151. $view['protocol_list'] = $this->protocolList();
  152. $view['obfs_list'] = $this->obfsList();
  153. return Response::view('admin/addUser', $view);
  154. }
  155. }
  156. // 编辑账号
  157. public function editUser(Request $request)
  158. {
  159. if (!$request->session()->has('user')) {
  160. return Redirect::to('login');
  161. }
  162. $id = $request->get('id');
  163. if ($request->method() == 'POST') {
  164. $username = $request->get('username');
  165. $password = $request->get('password');
  166. $port = $request->get('port');
  167. $passwd = $request->get('passwd');
  168. $transfer_enable = $request->get('transfer_enable');
  169. $enable = $request->get('enable');
  170. $method = $request->get('method');
  171. $custom_method = $request->get('custom_method');
  172. $protocol = $request->get('protocol');
  173. $protocol_param = $request->get('protocol_param');
  174. $obfs = $request->get('obfs');
  175. $obfs_param = $request->get('obfs_param');
  176. $speed_limit_per_con = $request->get('speed_limit_per_con');
  177. $speed_limit_per_user = $request->get('speed_limit_per_user');
  178. $wechat = $request->get('wechat');
  179. $qq = $request->get('qq');
  180. $usage = $request->get('usage');
  181. $pay_way = $request->get('pay_way');
  182. $balance = $request->get('balance');
  183. $enable_time = $request->get('enable_time');
  184. $expire_time = $request->get('expire_time');
  185. $remark = $request->get('remark');
  186. $is_admin = $request->get('is_admin');
  187. $data = [
  188. 'username' => $username,
  189. 'port' => $port,
  190. 'passwd' => $passwd,
  191. 'transfer_enable' => $this->toGB($transfer_enable),
  192. 'enable' => $enable,
  193. 'method' => $method,
  194. 'custom_method' => $custom_method,
  195. 'protocol' => $protocol,
  196. 'protocol_param' => $protocol_param,
  197. 'obfs' => $obfs,
  198. 'obfs_param' => $obfs_param,
  199. 'speed_limit_per_con' => $speed_limit_per_con,
  200. 'speed_limit_per_user' => $speed_limit_per_user,
  201. 'wechat' => $wechat,
  202. 'qq' => $qq,
  203. 'usage' => $usage,
  204. 'pay_way' => $pay_way,
  205. 'balance' => $balance,
  206. 'enable_time' => empty($enable_time) ? date('Y-m-d') : $enable_time,
  207. 'expire_time' => empty($expire_time) ? '2099-1-1' : $expire_time,
  208. 'remark' => $remark,
  209. 'is_admin' => $is_admin
  210. ];
  211. if (!empty($password)) {
  212. $data['password'] = md5($password);
  213. }
  214. $ret = User::where('id', $id)->update($data);
  215. if ($ret) {
  216. return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
  217. } else {
  218. return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败']);
  219. }
  220. } else {
  221. $user = User::where('id', $id)->first();
  222. if (!empty($user)) {
  223. $user->transfer_enable = $this->flowToGB($user->transfer_enable);
  224. }
  225. $view['user'] = $user;
  226. // 加密方式、协议、混淆
  227. $view['method_list'] = $this->methodList();
  228. $view['protocol_list'] = $this->protocolList();
  229. $view['obfs_list'] = $this->obfsList();
  230. return Response::view('admin/editUser', $view);
  231. }
  232. }
  233. // 删除用户
  234. public function delUser(Request $request)
  235. {
  236. if (!$request->session()->has('user')) {
  237. return Redirect::to('login');
  238. }
  239. $id = $request->get('id');
  240. if ($id == 1) {
  241. return Response::json(['status' => 'fail', 'data' => '', 'message' => '系统管理员不可删除']);
  242. }
  243. $user = User::where('id', $id)->delete();
  244. if ($user) {
  245. return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
  246. } else {
  247. return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
  248. }
  249. }
  250. // 节点列表
  251. public function nodeList(Request $request)
  252. {
  253. if (!$request->session()->has('user')) {
  254. return Redirect::to('login');
  255. }
  256. $nodeList = SsNode::paginate(10);
  257. foreach ($nodeList as &$node) {
  258. // 在线人数
  259. $online_log = SsNodeOnlineLog::where('node_id', $node->id)->orderBy('id', 'desc')->first();
  260. $node->online_users = empty($online_log) ? 0 : $online_log->online_user;
  261. // 已产生流量
  262. $u = UserTrafficLog::where('node_id', $node->id)->sum('u');
  263. $d = UserTrafficLog::where('node_id', $node->id)->sum('d');
  264. $node->transfer = $this->flowAutoShow($u + $d);
  265. // 负载
  266. $node_info = SsNodeInfo::where('node_id', $node->id)->orderBy('id', 'desc')->first();
  267. $node->load = empty($node_info->load) ? 0 : $node_info->load;
  268. }
  269. $view['nodeList'] = $nodeList;
  270. return Response::view('admin/nodeList', $view);
  271. }
  272. // 添加节点
  273. public function addNode(Request $request)
  274. {
  275. if (!$request->session()->has('user')) {
  276. return Redirect::to('login');
  277. }
  278. if ($request->method() == 'POST') {
  279. $name = $request->get('name');
  280. $server = $request->get('server');
  281. $method = $request->get('method');
  282. $custom_method = $request->get('custom_method');
  283. $protocol = $request->get('protocol');
  284. $protocol_param = $request->get('protocol_param');
  285. $obfs = $request->get('obfs');
  286. $obfs_param = $request->get('obfs_param');
  287. $traffic_rate = $request->get('traffic_rate');
  288. $bandwidth = $request->get('bandwidth');
  289. $traffic = $request->get('traffic');
  290. $monitor_url = $request->get('monitor_url');
  291. $compatible = $request->get('compatible');
  292. $sort = $request->get('sort');
  293. $status = $request->get('status');
  294. SsNode::create([
  295. 'name' => $name,
  296. 'server' => $server,
  297. 'method' => $method,
  298. 'custom_method' => $custom_method,
  299. 'protocol' => $protocol,
  300. 'protocol_param' => $protocol_param,
  301. 'obfs' => $obfs,
  302. 'obfs_param' => $obfs_param,
  303. 'traffic_rate' => $traffic_rate,
  304. 'bandwidth' => $bandwidth,
  305. 'traffic' => $traffic,
  306. 'monitor_url' => $monitor_url,
  307. 'compatible' => $compatible,
  308. 'sort' => $sort,
  309. 'status' => $status,
  310. ]);
  311. return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
  312. } else {
  313. // 加密方式、协议、混淆
  314. $view['method_list'] = $this->methodList();
  315. $view['protocol_list'] = $this->protocolList();
  316. $view['obfs_list'] = $this->obfsList();
  317. return Response::view('admin/addNode', $view);
  318. }
  319. }
  320. // 编辑节点
  321. public function editNode(Request $request)
  322. {
  323. if (!$request->session()->has('user')) {
  324. return Redirect::to('login');
  325. }
  326. $id = $request->get('id');
  327. if ($request->method() == 'POST') {
  328. $name = $request->get('name');
  329. $server = $request->get('server');
  330. $method = $request->get('method');
  331. $custom_method = $request->get('custom_method');
  332. $protocol = $request->get('protocol');
  333. $protocol_param = $request->get('protocol_param');
  334. $obfs = $request->get('obfs');
  335. $obfs_param = $request->get('obfs_param');
  336. $traffic_rate = $request->get('traffic_rate');
  337. $bandwidth = $request->get('bandwidth');
  338. $traffic = $request->get('traffic');
  339. $monitor_url = $request->get('monitor_url');
  340. $compatible = $request->get('compatible');
  341. $sort = $request->get('sort');
  342. $status = $request->get('status');
  343. $data = [
  344. 'name' => $name,
  345. 'server' => $server,
  346. 'method' => $method,
  347. 'custom_method' => $custom_method,
  348. 'protocol' => $protocol,
  349. 'protocol_param' => $protocol_param,
  350. 'obfs' => $obfs,
  351. 'obfs_param' => $obfs_param,
  352. 'traffic_rate' => $traffic_rate,
  353. 'bandwidth' => $bandwidth,
  354. 'traffic' => $traffic,
  355. 'monitor_url' => $monitor_url,
  356. 'compatible' => $compatible,
  357. 'sort' => $sort,
  358. 'status' => $status
  359. ];
  360. $ret = SsNode::where('id', $id)->update($data);
  361. if ($ret) {
  362. return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
  363. } else {
  364. return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败']);
  365. }
  366. } else {
  367. $view['node'] = SsNode::where('id', $id)->first();
  368. // 加密方式、协议、混淆
  369. $view['method_list'] = $this->methodList();
  370. $view['protocol_list'] = $this->protocolList();
  371. $view['obfs_list'] = $this->obfsList();
  372. return Response::view('admin/editNode', $view);
  373. }
  374. }
  375. // 删除节点
  376. public function delNode(Request $request)
  377. {
  378. if (!$request->session()->has('user')) {
  379. return Redirect::to('login');
  380. }
  381. $id = $request->get('id');
  382. $user = SsNode::where('id', $id)->delete();
  383. if ($user) {
  384. return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
  385. } else {
  386. return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
  387. }
  388. }
  389. // 流量日志
  390. public function trafficLog(Request $request)
  391. {
  392. if (!$request->session()->has('user')) {
  393. return Redirect::to('login');
  394. }
  395. $trafficLogList = UserTrafficLog::with(['User', 'SsNode'])->orderBy('id', 'desc')->paginate(20);
  396. foreach ($trafficLogList as &$trafficLog) {
  397. $trafficLog->u = $this->flowAutoShow($trafficLog->u);
  398. $trafficLog->d = $this->flowAutoShow($trafficLog->d);
  399. $trafficLog->log_time = date('Y-m-d H:i:s', $trafficLog->log_time);
  400. }
  401. $view['trafficLogList'] = $trafficLogList;
  402. return Response::view('admin/trafficLog', $view);
  403. }
  404. // 格式转换(SS转SSR)
  405. public function convert(Request $request)
  406. {
  407. if (!$request->session()->has('user')) {
  408. return Redirect::to('login');
  409. }
  410. if ($request->method() == 'POST') {
  411. $method = $request->get('method');
  412. $transfer_enable = $request->get('transfer_enable');
  413. $protocol = $request->get('protocol');
  414. $protocol_param = $request->get('protocol_param');
  415. $obfs = $request->get('obfs');
  416. $obfs_param = $request->get('obfs_param');
  417. $content = $request->get('content');
  418. if (empty($content)) {
  419. return Response::json(['status' => 'fail', 'data' => '', 'message' => '请在左侧填入要转换的内容']);
  420. }
  421. // 校验格式
  422. $content = json_decode($content);
  423. if (empty($content->port_password)) {
  424. return Response::json(['status' => 'fail', 'data' => '', 'message' => '转换失败:配置信息里缺少【port_password】字段,或者该字段为空']);
  425. }
  426. // 转换成SSR格式JSON
  427. $data = [];
  428. foreach ($content->port_password as $port => $passwd) {
  429. $data[] = [
  430. 'd' => 0,
  431. 'enable' => 1,
  432. 'method' => $method,
  433. 'obfs' => $obfs,
  434. 'obfs_param' => empty($obfs_param) ? "" : $obfs_param,
  435. 'passwd' => $passwd,
  436. 'port' => $port,
  437. 'protocol' => $protocol,
  438. 'protocol_param' => empty($protocol_param) ? "" : $protocol_param,
  439. 'transfer_enable' => $this->toGB($transfer_enable),
  440. 'u' => 0,
  441. 'user' => date('Ymd') . '_IMPORT_' . $port,
  442. ];
  443. }
  444. $json = json_encode($data);
  445. // 生成转换好的JSON文件
  446. file_put_contents(public_path('downloads/convert.json'), $json);
  447. return Response::json(['status' => 'success', 'data' => $json, 'message' => '转换成功']);
  448. } else {
  449. // 加密方式、协议、混淆
  450. $view['method_list'] = $this->methodList();
  451. $view['protocol_list'] = $this->protocolList();
  452. $view['obfs_list'] = $this->obfsList();
  453. return Response::view('admin/convert', $view);
  454. }
  455. }
  456. // 下载转换好的JSON文件
  457. public function download(Request $request)
  458. {
  459. if (!$request->session()->has('user')) {
  460. return Redirect::to('login');
  461. }
  462. if (!file_exists(public_path('downloads/convert.json'))) {
  463. exit('文件不存在');
  464. }
  465. return Response::download(public_path('downloads/convert.json'));
  466. }
  467. // 数据导入
  468. public function import(Request $request)
  469. {
  470. if (!$request->session()->has('user')) {
  471. return Redirect::to('login');
  472. }
  473. if ($request->method() == 'POST') {
  474. if (!$request->hasFile('uploadFile')) {
  475. $request->session()->flash('errorMsg', '请选择要上传的文件');
  476. return Redirect::back();
  477. }
  478. $file = $request->file('uploadFile');
  479. // 只能上传JSON文件
  480. if ($file->getClientMimeType() != 'application/json' || $file->getClientOriginalExtension() != 'json') {
  481. $request->session()->flash('errorMsg', '只允许上传JSON文件');
  482. return Redirect::back();
  483. }
  484. if (!$file->isValid()) {
  485. $request->session()->flash('errorMsg', '产生未知错误,请重新上传');
  486. return Redirect::back();
  487. }
  488. $save_path = realpath(storage_path('uploads'));
  489. $new_name = md5($file->getClientOriginalExtension()).'json';
  490. $file->move($save_path, $new_name);
  491. // 读取文件内容
  492. $data = file_get_contents($save_path.'/'.$new_name);
  493. $data = json_decode($data);
  494. if (!$data) {
  495. $request->session()->flash('errorMsg', '内容格式解析异常,请上传符合SSR配置规范的JSON文件');
  496. return Redirect::back();
  497. }
  498. \DB::beginTransaction();
  499. try {
  500. foreach ($data as $user) {
  501. $obj = new User();
  502. $obj->username = $user->user;
  503. $obj->password = md5('123456');
  504. $obj->port = $user->port;
  505. $obj->passwd = $user->passwd;
  506. $obj->transfer_enable = $user->transfer_enable;
  507. $obj->u = 0;
  508. $obj->d = 0;
  509. $obj->t = 0;
  510. $obj->enable = 1;
  511. $obj->method = $user->method;
  512. $obj->custom_method = $user->method;
  513. $obj->protocol = $user->protocol;
  514. $obj->protocol_param = $user->protocol_param;
  515. $obj->obfs = $user->obfs;
  516. $obj->obfs_param = $user->obfs_param;
  517. $obj->speed_limit_per_con = 204800;
  518. $obj->speed_limit_per_user = 204800;
  519. $obj->wechat = '';
  520. $obj->qq = '';
  521. $obj->usage = 1;
  522. $obj->pay_way = 3;
  523. $obj->balance = 0;
  524. $obj->enable_time = date('Y-m-d');
  525. $obj->expire_time = '2099-01-01';
  526. $obj->remark = '';
  527. $obj->is_admin = 0;
  528. $obj->reg_ip = $request->getClientIp();
  529. $obj->created_at = date('Y-m-d H:i:s');
  530. $obj->updated_at = date('Y-m-d H:i:s');
  531. $obj->save();
  532. }
  533. \DB::commit();
  534. } catch (\Exception $e) {
  535. \DB::rollBack();
  536. $request->session()->flash('errorMsg', '出错了,可能是导入的配置中有端口已经存在了');
  537. return Redirect::back();
  538. }
  539. $request->session()->flash('successMsg', '导入成功');
  540. return Redirect::back();
  541. } else {
  542. return Response::view('admin/import');
  543. }
  544. }
  545. // 导出配置信息
  546. public function export(Request $request)
  547. {
  548. if (!$request->session()->has('user')) {
  549. return Redirect::to('login');
  550. }
  551. $id = $request->get('id');
  552. if (empty($id)) {
  553. return Redirect::to('admin/userList');
  554. }
  555. $user = User::where('id', $id)->first();
  556. if (empty($user)) {
  557. return Redirect::to('admin/userList');
  558. }
  559. $nodeList = SsNode::paginate(10);
  560. foreach ($nodeList as &$node) {
  561. // 生成ssr scheme
  562. $ssr_str = '';
  563. $ssr_str .= $node->server . ':' . $user->port;
  564. $ssr_str .= ':' . $user->protocol . ':' . $user->method;
  565. $ssr_str .= ':' . $user->obfs . ':' . base64_encode($user->passwd);
  566. $ssr_str .= '/?obfsparam=' . $user->obfs_param;
  567. $ssr_str .= '&=protoparam' . $user->protocol_param;
  568. $ssr_str .= '&remarks=' . base64_encode('VPN');
  569. $ssr_str = $this->base64url_encode($ssr_str);
  570. $ssr_scheme = 'ssr://' . $ssr_str;
  571. // 生成ss scheme
  572. $ss_str = '';
  573. $ss_str .= $user->method . ':' . $user->passwd . '@';
  574. $ss_str .= $node->server . ':' . $user->port;
  575. $ss_str .= $this->base64url_encode($ss_str);
  576. $ss_scheme = 'ss://' . $ss_str;
  577. // 生成json配置信息
  578. $config = <<<CONFIG
  579. {
  580. "remarks" : "{$node->name}",
  581. "server" : "{$node->server}",
  582. "server_port" : {$user->port},
  583. "server_udp_port" : 0,
  584. "password" : "{$user->passwd}",
  585. "method" : "{$user->method}",
  586. "protocol" : "{$user->protocol}",
  587. "protocolparam" : "{$user->protocol_param}",
  588. "obfs" : "{$user->obfs}",
  589. "obfsparam" : "{$user->obfs_param}",
  590. "remarks_base64" : "",
  591. "group" : "VPN",
  592. "enable" : true,
  593. "udp_over_tcp" : false
  594. }
  595. CONFIG;
  596. // 生成文本配置信息
  597. $txt = <<<TXT
  598. 服务器:{$node->server}
  599. 端口:{$user->port}
  600. 密码:{$user->passwd}
  601. 加密方式:{$user->method}
  602. 协议:{$user->protocol}
  603. 协议参数:{$user->protocol_param}
  604. 混淆:{$user->obfs}
  605. 混淆参数:{$user->obfs_param}
  606. TXT;
  607. $node->txt = $txt;
  608. $node->json = $config;
  609. $node->ssr_scheme = $ssr_scheme;
  610. $node->ss_scheme = $ss_scheme;
  611. }
  612. $view['nodeList'] = $nodeList;
  613. return Response::view('admin/export', $view);
  614. }
  615. // 修改个人资料
  616. public function profile(Request $request)
  617. {
  618. if (!$request->session()->has('user')) {
  619. return Redirect::to('login');
  620. }
  621. $user = $request->session()->get('user');
  622. if ($request->method() == 'POST') {
  623. $old_password = $request->get('old_password');
  624. $new_password = $request->get('new_password');
  625. $old_password = md5(trim($old_password));
  626. $new_password = md5(trim($new_password));
  627. $user = User::where('id', $user['id'])->first();
  628. if ($user->password != $old_password) {
  629. $request->session()->flash('errorMsg', '旧密码错误,请重新输入');
  630. return Redirect::back();
  631. } else if ($user->password == $new_password) {
  632. $request->session()->flash('errorMsg', '新密码不可与旧密码一样,请重新输入');
  633. return Redirect::back();
  634. }
  635. $ret = User::where('id', $user['id'])->update(['password' => $new_password]);
  636. if (!$ret) {
  637. $request->session()->flash('errorMsg', '修改失败');
  638. return Redirect::back();
  639. } else {
  640. $request->session()->flash('successMsg', '修改成功');
  641. return Redirect::back();
  642. }
  643. } else {
  644. return Response::view('admin/profile');
  645. }
  646. }
  647. // 流量监控
  648. public function monitor(Request $request)
  649. {
  650. if (!$request->session()->has('user')) {
  651. return Redirect::to('login');
  652. }
  653. $id = $request->get('id');
  654. if (empty($id)) {
  655. return Redirect::to('admin/userList');
  656. }
  657. $user = User::where('id', $id)->first();
  658. if (empty($user)) {
  659. return Redirect::to('admin/userList');
  660. }
  661. // 30天内的流量
  662. $traffic = [];
  663. $node_list = SsNode::get();
  664. foreach ($node_list as $node) {
  665. $trafficList = \DB::select("SELECT date(from_unixtime(log_time)) AS dd, SUM(u) AS u, SUM(d) AS d FROM `user_traffic_log` WHERE `user_id` = {$id} AND `node_id` = {$node->id} GROUP BY `dd`");
  666. foreach ($trafficList as $key => &$val) {
  667. $val->total = ($val->u + $val->d) / (1024 * 1024); // 以M为单位
  668. }
  669. $traffic[$node->id] = $trafficList;
  670. }
  671. $view['traffic'] = $traffic;
  672. return Response::view('admin/monitor', $view);
  673. }
  674. // 生成SS密码
  675. public function makePasswd(Request $request)
  676. {
  677. exit($this->makeRandStr());
  678. }
  679. // 加密方式、混淆、协议列表
  680. public function config(Request $request)
  681. {
  682. if (!$request->session()->has('user')) {
  683. return Redirect::to('login');
  684. }
  685. if ($request->method() == 'POST') {
  686. $name = $request->get('name');
  687. $type = $request->get('type', 1); // 类型:1-加密方式(method)、2-协议(protocol)、3-混淆(obfs)
  688. $is_default = $request->get('is_default', 0);
  689. $sort = $request->get('sort', 0);
  690. if (empty($name)) {
  691. return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置名称不能为空']);
  692. }
  693. // 校验是否已存在
  694. $config = SsConfig::where('name', $name)->where('type', $type)->first();
  695. if ($config) {
  696. return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置已经存在,请勿重复添加']);
  697. }
  698. SsConfig::create([
  699. 'name' => $name,
  700. 'type' => $type,
  701. 'is_default' => $is_default,
  702. 'sort' => $sort
  703. ]);
  704. return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
  705. } else {
  706. $view['method_list'] = SsConfig::where('type', 1)->get();
  707. $view['protocol_list'] = SsConfig::where('type', 2)->get();
  708. $view['obfs_list'] = SsConfig::where('type', 3)->get();
  709. return Response::view('admin/config', $view);
  710. }
  711. }
  712. // 删除配置
  713. public function delConfig(Request $request)
  714. {
  715. if (!$request->session()->has('user')) {
  716. return Redirect::to('login');
  717. }
  718. $id = $request->get('id');
  719. $config = SsConfig::where('id', $id)->delete();
  720. if ($config) {
  721. return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
  722. } else {
  723. return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
  724. }
  725. }
  726. // 设置默认配置
  727. public function setDefaultConfig(Request $request)
  728. {
  729. if (!$request->session()->has('user')) {
  730. return Redirect::to('login');
  731. }
  732. $id = $request->get('id');
  733. if (empty($id)) {
  734. return Response::json(['status' => 'fail', 'data' => '', 'message' => '非法请求']);
  735. }
  736. $config = SsConfig::where('id', $id)->first();
  737. if (empty($config)) {
  738. return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置不存在']);
  739. }
  740. // 去除该配置所属类型的默认值
  741. SsConfig::where('type', $config->type)->update(['is_default' => 0]);
  742. // 将该ID对应记录值置为默认值
  743. SsConfig::where('id', $id)->update(['is_default' => 1]);
  744. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  745. }
  746. // 日志分析
  747. public function analysis(Request $request)
  748. {
  749. if (!$request->session()->has('user')) {
  750. return Redirect::to('login');
  751. }
  752. $file = storage_path('app/public/ssserver.log');
  753. $logs = $this->tail($file, 10000);
  754. $url = [];
  755. foreach ($logs as $log) {
  756. if (strpos($log, 'TCP connecting')) {
  757. continue;
  758. }
  759. preg_match('/TCP request (\w+\.){2}\w+/', $log, $tcp_matches);
  760. if (!empty($tcp_matches)) {
  761. $url[] = str_replace('TCP request ', '[TCP] ', $tcp_matches[0]);
  762. } else {
  763. 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);
  764. if (!empty($udp_matches)) {
  765. $url[] = str_replace('UDP data to ', '[UDP] ', $udp_matches[0]);
  766. }
  767. }
  768. }
  769. $view['urlList'] = array_unique($url);
  770. return Response::view('admin/analysis', $view);
  771. }
  772. // 系统设置
  773. public function system(Request $request)
  774. {
  775. if (!$request->session()->has('user')) {
  776. return Redirect::to('login');
  777. }
  778. $view = $this->systemConfig();
  779. return Response::view('admin/system', $view);
  780. }
  781. // 启用、禁用随机端口
  782. public function enableRandPort(Request $request)
  783. {
  784. $value = intval($request->get('value'));
  785. Config::where('id', 1)->update(['value' => $value]);
  786. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  787. }
  788. }