AdminController.php 46 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Helpers;
  4. use App\Components\IPIP;
  5. use App\Components\PushNotification;
  6. use App\Components\QQWry;
  7. use App\Models\Article;
  8. use App\Models\Config;
  9. use App\Models\Country;
  10. use App\Models\Invite;
  11. use App\Models\Label;
  12. use App\Models\Level;
  13. use App\Models\Node;
  14. use App\Models\NodeDailyDataFlow;
  15. use App\Models\NodeLabel;
  16. use App\Models\NodeOnlineUserIp;
  17. use App\Models\NotificationLog;
  18. use App\Models\Order;
  19. use App\Models\ReferralApply;
  20. use App\Models\ReferralLog;
  21. use App\Models\SsConfig;
  22. use App\Models\User;
  23. use App\Models\UserBanedLog;
  24. use App\Models\UserCreditLog;
  25. use App\Models\UserDataFlowLog;
  26. use App\Models\UserDataModifyLog;
  27. use App\Models\UserGroup;
  28. use App\Models\UserHourlyDataFlow;
  29. use App\Services\UserService;
  30. use Auth;
  31. use DB;
  32. use Exception;
  33. use Hash;
  34. use Illuminate\Http\JsonResponse;
  35. use Illuminate\Http\RedirectResponse;
  36. use Illuminate\Http\Request;
  37. use Log;
  38. use PhpOffice\PhpSpreadsheet\Spreadsheet;
  39. use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
  40. use Redirect;
  41. use Response;
  42. use Session;
  43. use Str;
  44. use Validator;
  45. /**
  46. * 管理员控制器
  47. *
  48. * Class AdminController
  49. *
  50. * @package App\Http\Controllers
  51. */
  52. class AdminController extends Controller {
  53. protected static $sysConfig;
  54. public function __construct() {
  55. self::$sysConfig = Helpers::sysConfig();
  56. }
  57. public function index() {
  58. $past = strtotime("-".self::$sysConfig['expire_days']." days");
  59. $view['expireDays'] = self::$sysConfig['expire_days'];
  60. $view['totalUserCount'] = User::count(); // 总用户数
  61. $view['enableUserCount'] = User::whereEnable(1)->count(); // 有效用户数
  62. $view['activeUserCount'] = User::where('t', '>=', $past)->count(); // 活跃用户数
  63. $view['unActiveUserCount'] = User::whereEnable(1)->whereBetween('t', [1, $past])->count(); // 不活跃用户数
  64. $view['onlineUserCount'] = User::where('t', '>=', strtotime("-10 minutes"))->count(); // 10分钟内在线用户数
  65. $view['expireWarningUserCount'] = User::whereBetween('expired_at', [
  66. date('Y-m-d'),
  67. strtotime("+".self::$sysConfig['expire_days']." days")
  68. ])->count(); // 临近过期用户数
  69. $view['largeTrafficUserCount'] = User::whereRaw('(u + d) >= 107374182400')
  70. ->where('status', '<>', -1)
  71. ->count(); // 流量超过100G的用户
  72. $view['flowAbnormalUserCount'] = count($this->trafficAbnormal());// 1小时内流量异常用户
  73. $view['nodeCount'] = Node::count();
  74. $view['unnormalNodeCount'] = Node::whereStatus(0)->count();
  75. $view['flowCount'] = flowAutoShow(NodeDailyDataFlow::where('created_at', '>=',
  76. date('Y-m-d', strtotime("-30 days")))->sum('total'));
  77. $view['totalFlowCount'] = flowAutoShow(NodeDailyDataFlow::sum('total'));
  78. $view['totalCredit'] = User::where('credit', '<>', 0)->sum('credit') / 100;
  79. $view['totalWaitRefAmount'] = ReferralLog::whereIn('status', [0, 1])->sum('commission') / 100;
  80. $view['totalRefAmount'] = ReferralApply::whereStatus(2)->sum('amount') / 100;
  81. $view['totalOrder'] = Order::count();
  82. $view['totalOnlinePayOrder'] = Order::where('pay_type', '<>', 0)->count();
  83. $view['totalSuccessOrder'] = Order::whereStatus(2)->count();
  84. $view['todaySuccessOrder'] = Order::whereStatus(2)->whereDate('created_at', date('Y-m-d'))->count();
  85. // 今日
  86. $view['todayRegister'] = User::whereDate('created_at', date('Y-m-d'))->count();
  87. return view('admin.index', $view);
  88. }
  89. // 1小时内流量异常用户
  90. private function trafficAbnormal(): array {
  91. $result = [];
  92. $userTotalTrafficList = UserHourlyDataFlow::whereNodeId(0)
  93. ->where('total', '>', MB * 50)
  94. ->where('created_at', '>=', date('Y-m-d H:i:s', time() - 3900))
  95. ->groupBy('user_id')
  96. ->selectRaw("user_id, sum(total) as totalTraffic")
  97. ->get(); // 只统计50M以上的记录,加快速度
  98. foreach($userTotalTrafficList as $user){
  99. if($user->totalTraffic > self::$sysConfig['traffic_ban_value'] * GB){
  100. $result[] = $user->user_id;
  101. }
  102. }
  103. return $result;
  104. }
  105. // 用户列表
  106. public function userList(Request $request) {
  107. $id = $request->input('id');
  108. $email = $request->input('email');
  109. $wechat = $request->input('wechat');
  110. $qq = $request->input('qq');
  111. $port = $request->input('port');
  112. $status = $request->input('status');
  113. $enable = $request->input('enable');
  114. $online = $request->input('online');
  115. $flowAbnormal = $request->input('flowAbnormal');
  116. $expireWarning = $request->input('expireWarning');
  117. $largeTraffic = $request->input('largeTraffic');
  118. $query = User::with('subscribe');
  119. if(isset($id)){
  120. $query->whereId($id);
  121. }
  122. if(isset($email)){
  123. $query->where('email', 'like', '%'.$email.'%');
  124. }
  125. if(isset($wechat)){
  126. $query->where('wechat', 'like', '%'.$wechat.'%');
  127. }
  128. if(isset($qq)){
  129. $query->where('qq', 'like', '%'.$qq.'%');
  130. }
  131. if(isset($port)){
  132. $query->wherePort($port);
  133. }
  134. if(isset($status)){
  135. $query->whereStatus($status);
  136. }
  137. if(isset($enable)){
  138. $query->whereEnable($enable);
  139. }
  140. // 流量超过100G的
  141. if($largeTraffic){
  142. $query->whereIn('status', [0, 1])->whereRaw('(u + d) >= 107374182400');
  143. }
  144. // 临近过期提醒
  145. if($expireWarning){
  146. $query->whereBetween('expired_at',
  147. [date('Y-m-d'), date('Y-m-d', strtotime("+".self::$sysConfig['expire_days']." days"))]);
  148. }
  149. // 当前在线
  150. if($online){
  151. $query->where('t', '>=', strtotime("-10 minutes"));
  152. }
  153. // 不活跃用户
  154. if($request->input('unActive')){
  155. $query->whereBetween('t', [1, strtotime("-".self::$sysConfig['expire_days']." days")])->whereEnable(1);
  156. }
  157. // 1小时内流量异常用户
  158. if($flowAbnormal){
  159. $query->whereIn('id', $this->trafficAbnormal());
  160. }
  161. $userList = $query->latest()->paginate(15)->appends($request->except('page'));
  162. foreach($userList as $user){
  163. $user->transfer_enable = flowAutoShow($user->transfer_enable);
  164. $user->used_flow = flowAutoShow($user->u + $user->d);
  165. if($user->expired_at < date('Y-m-d')){
  166. $user->expireWarning = -1; // 已过期
  167. }elseif($user->expired_at == date('Y-m-d')){
  168. $user->expireWarning = 0; // 今天过期
  169. }elseif($user->expired_at > date('Y-m-d') && $user->expired_at <= date('Y-m-d', strtotime("+30 days"))){
  170. $user->expireWarning = 1; // 最近一个月过期
  171. }else{
  172. $user->expireWarning = 2; // 大于一个月过期
  173. }
  174. // 流量异常警告
  175. $totalTraffic = UserHourlyDataFlow::userRecentUsed($user->id)->sum('total');
  176. $user->trafficWarning = $totalTraffic > (self::$sysConfig['traffic_ban_value'] * GB)? 1 : 0;
  177. // 订阅地址
  178. $user->link = (self::$sysConfig['subscribe_domain']?: self::$sysConfig['website_url']).'/s/'.$user->subscribe->code;
  179. }
  180. $view['userList'] = $userList;
  181. return view('admin.user.userList', $view);
  182. }
  183. // 添加账号
  184. public function addUser(Request $request) {
  185. if($request->isMethod('POST')){
  186. // 校验email是否已存在
  187. $exists = User::whereEmail($request->input('email'))->first();
  188. if($exists){
  189. return Response::json(['status' => 'fail', 'message' => '用户名已存在,请重新输入']);
  190. }
  191. $user = new User();
  192. $user->username = $request->input('username');
  193. $user->email = $request->input('email');
  194. $user->password = Hash::make($request->input('password')?: Str::random());
  195. $user->port = $request->input('port')?: $this->makePort();
  196. $user->passwd = $request->input('passwd')?: Str::random();
  197. $user->vmess_id = $request->input('uuid')?: Str::uuid();
  198. $user->transfer_enable = toGB($request->input('transfer_enable')?: 0);
  199. $user->enable = $request->input('enable')?: 0;
  200. $user->method = $request->input('method');
  201. $user->protocol = $request->input('protocol');
  202. $user->obfs = $request->input('obfs');
  203. $user->speed_limit = $request->input('speed_limit') * Mbps;
  204. $user->wechat = $request->input('wechat');
  205. $user->qq = $request->input('qq');
  206. $user->expired_at = $request->input('expired_at')?: date('Y-m-d', strtotime("+365 days"));
  207. $user->remark = str_replace(["atob", "eval"], "", $request->input('remark'));
  208. $user->level = $request->input('level')?: 0;
  209. $user->group_id = $request->input('group_id')?: 0;
  210. $user->reg_ip = getClientIp();
  211. $user->reset_time = $request->input('reset_time') > date('Y-m-d')? $request->input('reset_time') : null;
  212. $user->invite_num = $request->input('invite_num')?: 0;
  213. $user->status = $request->input('status')?: 0;
  214. $user->save();
  215. if($user->id){
  216. // 写入用户流量变动记录
  217. Helpers::addUserTrafficModifyLog($user->id, 0, 0, toGB($request->input('transfer_enable', 0)),
  218. '后台手动添加用户');
  219. return Response::json(['status' => 'success', 'message' => '添加成功']);
  220. }
  221. return Response::json(['status' => 'fail', 'message' => '添加失败']);
  222. }
  223. // 生成一个可用端口
  224. $view['methodList'] = Helpers::methodList();
  225. $view['protocolList'] = Helpers::protocolList();
  226. $view['obfsList'] = Helpers::obfsList();
  227. $view['levelList'] = Level::orderBy('level')->get();
  228. $view['groupList'] = UserGroup::orderBy('id')->get();
  229. return view('admin.user.userInfo', $view);
  230. }
  231. // 生成端口
  232. public function makePort(): int {
  233. return self::$sysConfig['is_rand_port']? Helpers::getRandPort() : Helpers::getOnlyPort();
  234. }
  235. // 批量生成账号
  236. public function batchAddUsers(Request $request): ?JsonResponse {
  237. $amount = $request->input('amount');
  238. try{
  239. DB::beginTransaction();
  240. for($i = 0; $i < $amount; $i++){
  241. $uid = Helpers::addUser(Str::random(8).'@auto.generate', Hash::make(Str::random()), toGB(1024), 365);
  242. // 生成一个可用端口
  243. if($uid){
  244. // 写入用户流量变动记录
  245. Helpers::addUserTrafficModifyLog($uid, 0, 0, toGB(1024), '后台批量生成用户');
  246. }
  247. }
  248. DB::commit();
  249. return Response::json(['status' => 'success', 'message' => '批量生成账号成功']);
  250. }catch(Exception $e){
  251. DB::rollBack();
  252. return Response::json(['status' => 'fail', 'message' => '批量生成账号失败:'.$e->getMessage()]);
  253. }
  254. }
  255. // 编辑账号
  256. public function editUser(Request $request, $id) {
  257. $user = User::find($id);
  258. if($request->isMethod('POST')){
  259. $email = $request->input('email');
  260. $password = $request->input('password');
  261. $port = $request->input('port');
  262. $transfer_enable = $request->input('transfer_enable');
  263. $is_admin = $request->input('is_admin');
  264. $status = $request->input('status');
  265. // 校验email是否已存在
  266. if(User::where('id', '<>', $id)->whereEmail($email)->exists()){
  267. return Response::json(['status' => 'fail', 'message' => '用户名已存在,请重新输入']);
  268. }
  269. // 校验端口是否已存在
  270. if(User::where('id', '<>', $id)->where('port', '>', 0)->wherePort($port)->exists()){
  271. return Response::json(['status' => 'fail', 'message' => '端口已存在,请重新输入']);
  272. }
  273. // 禁止取消默认管理员
  274. if($id == 1 && $is_admin == 0){
  275. return Response::json(['status' => 'fail', 'message' => '系统默认管理员不可取消']);
  276. }
  277. try{
  278. DB::beginTransaction();
  279. $data = [
  280. 'username' => $request->input('username'),
  281. 'email' => $email,
  282. 'port' => $port,
  283. 'passwd' => $request->input('passwd')?: Str::random(),
  284. 'vmess_id' => $request->input('uuid')?: Str::uuid(),
  285. 'transfer_enable' => toGB($transfer_enable?: 0),
  286. 'enable' => $status < 0? 0 : $request->input('enable'),
  287. 'method' => $request->input('method'),
  288. 'protocol' => $request->input('protocol'),
  289. 'obfs' => $request->input('obfs'),
  290. 'speed_limit' => $request->input('speed_limit') * Mbps,
  291. 'wechat' => $request->input('wechat'),
  292. 'qq' => $request->input('qq'),
  293. 'expired_at' => $request->input('expired_at')?: date('Y-m-d', strtotime("+365 days")),
  294. 'remark' => str_replace("eval", "", str_replace("atob", "", $request->input('remark'))),
  295. 'level' => $request->input('level'),
  296. 'group_id' => $request->input('group_id'),
  297. 'reset_time' => $request->input('reset_time'),
  298. 'invite_num' => $request->input('invite_num'),
  299. 'status' => $status
  300. ];
  301. // 只有admin才有权限操作管理员属性
  302. if(Auth::getUser()->is_admin == 1){
  303. $data['is_admin'] = (int) $is_admin;
  304. }
  305. // 非演示环境才可以修改管理员密码
  306. if(!empty($password) && !(config('app.demo') && $id == 1)){
  307. $data['password'] = Hash::make($password);
  308. }
  309. $user->update($data);
  310. // 写入用户流量变动记录
  311. if($user->transfer_enable != toGB($transfer_enable)){
  312. Helpers::addUserTrafficModifyLog($id, 0, $user->transfer_enable, toGB($transfer_enable),
  313. '后台手动编辑用户');
  314. }
  315. DB::commit();
  316. return Response::json(['status' => 'success', 'message' => '编辑成功']);
  317. }catch(Exception $e){
  318. DB::rollBack();
  319. Log::error('编辑用户信息异常:'.$e->getMessage());
  320. return Response::json(['status' => 'fail', 'message' => '编辑失败']);
  321. }
  322. }else{
  323. if($user){
  324. $user->transfer_enable = flowToGB($user->transfer_enable);
  325. }
  326. $view['user'] = $user->load('inviter:id,email');
  327. $view['methodList'] = Helpers::methodList();
  328. $view['protocolList'] = Helpers::protocolList();
  329. $view['obfsList'] = Helpers::obfsList();
  330. $view['levelList'] = Level::orderBy('level')->get();
  331. $view['groupList'] = UserGroup::orderBy('id')->get();
  332. return view('admin.user.userInfo', $view);
  333. }
  334. }
  335. // 删除用户
  336. public function delUser(Request $request): ?JsonResponse {
  337. $id = $request->input('id');
  338. if($id <= 1){
  339. return Response::json(['status' => 'fail', 'message' => '系统管理员不可删除']);
  340. }
  341. try{
  342. DB::beginTransaction();
  343. User::find($id)->delete();
  344. DB::commit();
  345. return Response::json(['status' => 'success', 'message' => '删除成功']);
  346. }catch(Exception $e){
  347. Log::error('删除用户信息异常:'.$e->getMessage());
  348. DB::rollBack();
  349. return Response::json(['status' => 'fail', 'message' => '删除失败']);
  350. }
  351. }
  352. // 文章列表
  353. public function articleList(Request $request) {
  354. $view['list'] = Article::orderByDesc('sort')->paginate(15)->appends($request->except('page'));
  355. return view('admin.article.articleList', $view);
  356. }
  357. // 添加文章
  358. public function addArticle(Request $request) {
  359. if($request->isMethod('POST')){
  360. $article = new Article();
  361. $article->title = $request->input('title');
  362. $article->type = $request->input('type', 1);
  363. $article->summary = $request->input('summary');
  364. // LOGO
  365. if($article->type == 4){
  366. $article->logo = $request->input('logo');
  367. }else{
  368. $logo = '';
  369. if($request->hasFile('logo')){
  370. $logo = $this->uploadFile($request->file('logo'));
  371. if(!$logo){
  372. Session::flash('errorMsg', 'LOGO不合法');
  373. return Redirect::back()->withInput();
  374. }
  375. }
  376. $article = new Article();
  377. $article->title = $request->input('title');
  378. $article->type = $request->input('type', 1);
  379. $article->summary = $request->input('summary');
  380. $article->logo = $logo;
  381. }
  382. $article->content = $request->input('content');
  383. $article->sort = $request->input('sort', 0);
  384. $article->save();
  385. if($article->id){
  386. Session::flash('successMsg', '添加成功');
  387. }else{
  388. Session::flash('errorMsg', '添加失败');
  389. }
  390. return Redirect::to('admin/articleList');
  391. }
  392. return view('admin.article.addArticle');
  393. }
  394. // 编辑文章
  395. public function editArticle(Request $request) {
  396. $id = $request->input('id');
  397. if($request->isMethod('POST')){
  398. $title = $request->input('title');
  399. $type = $request->input('type');
  400. $summary = $request->input('summary');
  401. $content = $request->input('content');
  402. $sort = $request->input('sort');
  403. // 商品LOGO
  404. if($type == 4){
  405. $logo = $request->input('logo');
  406. }else{
  407. $logo = '';
  408. if($request->hasFile('logo')){
  409. $logo = $this->uploadFile($request->file('logo'));
  410. if(!$logo){
  411. Session::flash('errorMsg', 'LOGO不合法');
  412. return Redirect::back()->withInput();
  413. }
  414. }
  415. }
  416. $data = ['type' => $type, 'title' => $title, 'summary' => $summary, 'content' => $content, 'sort' => $sort];
  417. if($logo){
  418. $data['logo'] = $logo;
  419. }
  420. $ret = Article::whereId($id)->update($data);
  421. if($ret){
  422. Session::flash('successMsg', '编辑成功');
  423. }else{
  424. Session::flash('errorMsg', '编辑失败');
  425. }
  426. return Redirect::to('admin/editArticle?id='.$id);
  427. }
  428. $view['article'] = Article::find($id);
  429. return view('admin.article.editArticle', $view);
  430. }
  431. // 删除文章
  432. public function delArticle(Request $request): ?JsonResponse {
  433. $id = $request->input('id');
  434. $ret = Article::whereId($id)->delete();
  435. if($ret){
  436. return Response::json(['status' => 'success', 'message' => '删除成功']);
  437. }
  438. return Response::json(['status' => 'fail', 'message' => '删除失败']);
  439. }
  440. // 流量日志
  441. public function trafficLog(Request $request) {
  442. $port = $request->input('port');
  443. $user_id = $request->input('user_id');
  444. $email = $request->input('email');
  445. $nodeId = $request->input('nodeId');
  446. $startTime = $request->input('startTime');
  447. $endTime = $request->input('endTime');
  448. $query = UserDataFlowLog::with(['user', 'node']);
  449. if(isset($port)){
  450. $query->whereHas('user', static function($q) use ($port) {
  451. $q->wherePort($port);
  452. });
  453. }
  454. if(isset($user_id)){
  455. $query->whereUserId($user_id);
  456. }
  457. if(isset($email)){
  458. $query->whereHas('user', static function($q) use ($email) {
  459. $q->where('email', 'like', '%'.$email.'%');
  460. });
  461. }
  462. if(isset($nodeId)){
  463. $query->whereNodeId($nodeId);
  464. }
  465. if(isset($startTime)){
  466. $query->where('log_time', '>=', strtotime($startTime));
  467. }
  468. if(isset($endTime)){
  469. $query->where('log_time', '<=', strtotime($endTime));
  470. }
  471. // 已使用流量
  472. $view['totalTraffic'] = flowAutoShow($query->sum('u') + $query->sum('d'));
  473. $list = $query->latest('log_time')->paginate(20)->appends($request->except('page'));
  474. foreach($list as $vo){
  475. $vo->u = flowAutoShow($vo->u);
  476. $vo->d = flowAutoShow($vo->d);
  477. $vo->log_time = date('Y-m-d H:i:s', $vo->log_time);
  478. }
  479. $view['list'] = $list;
  480. $view['nodeList'] = Node::whereStatus(1)->orderByDesc('sort')->latest()->get();
  481. return view('admin.logs.trafficLog', $view);
  482. }
  483. // 导出配置信息
  484. public function export(Request $request, $id) {
  485. if(empty($id)){
  486. return Redirect::to('admin/userList');
  487. }
  488. $user = User::find($id);
  489. if(empty($user)){
  490. return Redirect::to('admin/userList');
  491. }
  492. if($request->isMethod('POST')){
  493. $infoType = $request->input('type');
  494. $node = Node::find($request->input('id'));
  495. if($node->type == 1){
  496. if($node->compatible){
  497. $proxyType = 'SS';
  498. }else{
  499. $proxyType = 'SSR';
  500. }
  501. }else{
  502. $proxyType = 'V2Ray';
  503. }
  504. $data = $this->getUserNodeInfo($id, $node->id, $infoType !== 'text'? 0 : 1);
  505. return Response::json(['status' => 'success', 'data' => $data, 'title' => $proxyType]);
  506. }
  507. $view['nodeList'] = Node::whereStatus(1)
  508. ->orderByDesc('sort')
  509. ->orderBy('id')
  510. ->paginate(15)
  511. ->appends($request->except('page'));
  512. $view['user'] = $user;
  513. return view('admin.user.export', $view);
  514. }
  515. // 导出原版SS用户配置信息
  516. public function exportSSJson() {
  517. $userList = User::where('port', '>', 0)->get();
  518. $json = '';
  519. if(!$userList->isEmpty()){
  520. $userPassword = [];
  521. foreach($userList as $user){
  522. $userPassword[] = $user->port.":".$user->passwd;
  523. }
  524. $json = json_encode([
  525. 'server' => '0.0.0.0',
  526. 'local_address' => '127.0.0.1',
  527. 'local_port' => 1080,
  528. 'port_password' => $userPassword,
  529. 'timeout' => 300,
  530. 'method' => Helpers::getDefaultMethod(),
  531. 'fast_open' => false,
  532. ]);
  533. }
  534. // 生成JSON文件
  535. $fileName = Str::random().'_shadowsocks.json';
  536. $filePath = public_path('downloads/'.$fileName);
  537. file_put_contents($filePath, $json);
  538. if(!is_file($filePath)){
  539. exit('文件生成失败,请检查目录权限');
  540. }
  541. return Response::download($filePath);
  542. }
  543. // 修改个人资料
  544. public function profile(Request $request) {
  545. if($request->isMethod('POST')){
  546. $new_password = $request->input('new_password');
  547. if(!Hash::check($request->input('old_password'), Auth::getUser()->password)){
  548. return Redirect::back()->withErrors('旧密码错误,请重新输入');
  549. }
  550. if(Hash::check($new_password, Auth::getUser()->password)){
  551. return Redirect::back()->withErrors('新密码不可与旧密码一样,请重新输入');
  552. }
  553. $ret = Auth::getUser()->update(['password' => Hash::make($new_password)]);
  554. if(!$ret){
  555. return Redirect::back()->withErrors('修改失败');
  556. }
  557. return Redirect::back()->with('successMsg', '修改成功');
  558. }
  559. return view('admin.config.profile');
  560. }
  561. // 用户流量监控
  562. public function userMonitor(Request $request) {
  563. $id = $request->input('id');
  564. if(empty($id)){
  565. return Redirect::to('admin/userList');
  566. }
  567. $user = User::find($id);
  568. if(empty($user)){
  569. return Redirect::to('admin/userList');
  570. }
  571. $view['email'] = $user->email;
  572. $view = array_merge($view, $this->dataFlowChart($user->id));
  573. return view('admin.logs.userMonitor', $view);
  574. }
  575. // 加密方式、混淆、协议、等级、国家地区
  576. public function config(Request $request) {
  577. if($request->isMethod('POST')){
  578. $name = $request->input('name');
  579. $type = $request->input('type', 1); // 类型:1-加密方式(method)、2-协议(protocol)、3-混淆(obfs)
  580. $is_default = $request->input('is_default', 0);
  581. $sort = $request->input('sort', 0);
  582. if(empty($name)){
  583. return Response::json(['status' => 'fail', 'message' => '配置名称不能为空']);
  584. }
  585. // 校验是否已存在
  586. $config = SsConfig::type($type)->whereName($name)->first();
  587. if($config){
  588. return Response::json(['status' => 'fail', 'message' => '配置已经存在,请勿重复添加']);
  589. }
  590. $ssConfig = new SsConfig();
  591. $ssConfig->name = $name;
  592. $ssConfig->type = $type;
  593. $ssConfig->is_default = $is_default;
  594. $ssConfig->sort = $sort;
  595. $ssConfig->save();
  596. return Response::json(['status' => 'success', 'message' => '添加成功']);
  597. }
  598. $view['methodList'] = SsConfig::type(1)->get();
  599. $view['protocolList'] = SsConfig::type(2)->get();
  600. $view['obfsList'] = SsConfig::type(3)->get();
  601. $view['countryList'] = Country::all();
  602. $view['levelList'] = Level::all();
  603. $view['labelList'] = Label::with('nodes')->get();
  604. return view('admin.config.config', $view);
  605. }
  606. // 删除配置
  607. public function delConfig(Request $request): ?JsonResponse {
  608. $id = $request->input('id');
  609. $ret = SsConfig::whereId($id)->delete();
  610. if($ret){
  611. return Response::json(['status' => 'success', 'message' => '删除成功']);
  612. }
  613. return Response::json(['status' => 'fail', 'message' => '删除失败']);
  614. }
  615. // 设置默认配置
  616. public function setDefaultConfig(Request $request): JsonResponse {
  617. $id = $request->input('id');
  618. if(empty($id)){
  619. return Response::json(['status' => 'fail', 'message' => '非法请求']);
  620. }
  621. $config = SsConfig::find($id);
  622. if(!$config){
  623. return Response::json(['status' => 'fail', 'message' => '配置不存在']);
  624. }
  625. // 去除该配置所属类型的默认值
  626. SsConfig::default()->type($config->type)->update(['is_default' => 0]);
  627. // 将该ID对应记录值置为默认值
  628. SsConfig::whereId($id)->update(['is_default' => 1]);
  629. return Response::json(['status' => 'success', 'message' => '操作成功']);
  630. }
  631. // 设置系统扩展信息,例如客服、统计代码
  632. public function setExtend(Request $request): ?RedirectResponse {
  633. $websiteAnalytics = $request->input('website_analytics');
  634. $websiteCustomerService = $request->input('website_customer_service');
  635. try{
  636. DB::beginTransaction();
  637. // 首页LOGO
  638. if($request->hasFile('website_home_logo')){
  639. $ret = $this->uploadFile($request->file('website_home_logo'));
  640. if(!$ret){
  641. Session::flash('errorMsg', 'LOGO不合法');
  642. return Redirect::back();
  643. }
  644. Config::find('website_home_logo')->update(['value' => $ret]);
  645. }
  646. // 站内LOGO
  647. if($request->hasFile('website_logo')){
  648. $ret = $this->uploadFile($request->file('website_logo'));
  649. if(!$ret){
  650. Session::flash('errorMsg', 'LOGO不合法');
  651. return Redirect::back();
  652. }
  653. Config::find('website_logo')->update(['value' => $ret]);
  654. }
  655. Config::find('website_analytics')->update(['value' => $websiteAnalytics]);
  656. Config::find('website_customer_service')->update(['value' => $websiteCustomerService]);
  657. Session::flash('successMsg', '更新成功');
  658. DB::commit();
  659. return Redirect::back();
  660. }catch(Exception $e){
  661. DB::rollBack();
  662. Session::flash('errorMsg', '更新失败');
  663. return Redirect::back();
  664. }
  665. }
  666. // 添加等级
  667. public function addLevel(Request $request): ?JsonResponse {
  668. $validator = Validator::make($request->all(), [
  669. 'level' => 'required|numeric|unique:level,level',
  670. 'level_name' => 'required',
  671. ]);
  672. if($validator->fails()){
  673. return Response::json(['status' => 'fail', 'message' => $validator->errors()->all()]);
  674. }
  675. $obj = new Level();
  676. $obj->level = $request->input('level');
  677. $obj->name = $request->input('level_name');
  678. $obj->save();
  679. if($obj->id){
  680. return Response::json(['status' => 'success', 'message' => '提交成功']);
  681. }
  682. return Response::json(['status' => 'fail', 'message' => '操作失败']);
  683. }
  684. // 编辑等级
  685. public function updateLevel(Request $request): JsonResponse {
  686. $id = $request->input('id');
  687. $level = $request->input('level');
  688. $validator = Validator::make($request->all(), [
  689. 'id' => 'required|numeric',
  690. 'level' => 'required|numeric',
  691. 'level_name' => 'required',
  692. ]);
  693. if($validator->fails()){
  694. return Response::json(['status' => 'fail', 'message' => $validator->errors()->all()]);
  695. }
  696. // 校验该等级下是否存在关联账号
  697. $levelCheck = Level::where('id', '<>', $id)->whereLevel($level)->exists();
  698. if($levelCheck){
  699. return Response::json(['status' => 'fail', 'message' => '该等级已存在!']);
  700. }
  701. // 校验该等级下是否存在关联账号
  702. $userCount = User::whereLevel($level)->count();
  703. if($userCount){
  704. return Response::json(['status' => 'fail', 'message' => '该等级下存在关联账号,请先取消关联!']);
  705. }
  706. Level::whereId($id)->update(['level' => $level, 'name' => $request->input('level_name')]);
  707. return Response::json(['status' => 'success', 'message' => '操作成功']);
  708. }
  709. // 删除等级
  710. public function delLevel(Request $request): ?JsonResponse {
  711. $id = $request->input('id');
  712. $validator = Validator::make($request->all(), [
  713. 'id' => 'required|numeric|exists:level,id',
  714. ]);
  715. if($validator->fails()){
  716. return Response::json(['status' => 'fail', 'message' => $validator->errors()->all()]);
  717. }
  718. $level = Level::find($id);
  719. // 校验该等级下是否存在关联账号
  720. $userCount = User::whereLevel($level->level)->count();
  721. if($userCount){
  722. return Response::json(['status' => 'fail', 'message' => '该等级下存在关联账号,请先取消关联']);
  723. }
  724. $ret = false;
  725. try{
  726. $ret = Level::whereId($id)->delete();
  727. }catch(Exception $e){
  728. Log::error('删除等级时报错:'.$e->getMessage());
  729. }
  730. if($ret){
  731. return Response::json(['status' => 'success', 'message' => '操作成功']);
  732. }
  733. return Response::json(['status' => 'fail', 'message' => '操作失败']);
  734. }
  735. // 添加国家/地区
  736. public function addCountry(Request $request): JsonResponse {
  737. $code = $request->input('code');
  738. $name = $request->input('name');
  739. if(empty($code)){
  740. return Response::json(['status' => 'fail', 'message' => '国家/地区代码不能为空']);
  741. }
  742. if(empty($name)){
  743. return Response::json(['status' => 'fail', 'message' => '国家/地区名称不能为空']);
  744. }
  745. $exists = Country::find($code);
  746. if($exists){
  747. return Response::json(['status' => 'fail', 'message' => '该国家/地区名称已存在,请勿重复添加']);
  748. }
  749. $obj = new Country();
  750. $obj->code = $code;
  751. $obj->name = $name;
  752. if($obj->save()){
  753. return Response::json(['status' => 'success', 'message' => '提交成功']);
  754. }
  755. return Response::json(['status' => 'fail', 'message' => '操作失败']);
  756. }
  757. // 编辑国家/地区
  758. public function updateCountry(Request $request): JsonResponse {
  759. $code = $request->input('code');
  760. $name = $request->input('name');
  761. if(empty($name)){
  762. return Response::json(['status' => 'fail', 'message' => '国家/地区名称不能为空']);
  763. }
  764. if(empty($code)){
  765. return Response::json(['status' => 'fail', 'message' => '国家/地区代码不能为空']);
  766. }
  767. $country = Country::find($code);
  768. if(!$country){
  769. return Response::json(['status' => 'fail', 'message' => '国家/地区不存在']);
  770. }
  771. // 校验该国家/地区下是否存在关联节点
  772. if(Node::whereCountryCode($country->code)->exists()){
  773. return Response::json(['status' => 'fail', 'message' => '该国家/地区下存在关联节点,请先取消关联']);
  774. }
  775. $ret = $country->update(['name' => $name, 'code' => $code]);
  776. if($ret){
  777. return Response::json(['status' => 'success', 'message' => '操作成功']);
  778. }
  779. return Response::json(['status' => 'fail', 'message' => '操作失败']);
  780. }
  781. // 删除国家/地区
  782. public function delCountry(Request $request): ?JsonResponse {
  783. $code = $request->input('code');
  784. if(empty($id)){
  785. return Response::json(['status' => 'fail', 'message' => 'ID不能为空']);
  786. }
  787. $country = Country::find($code);
  788. if(!$country){
  789. return Response::json(['status' => 'fail', 'message' => '国家/地区不存在']);
  790. }
  791. // 校验该国家/地区下是否存在关联节点
  792. if(Node::whereCountryCode($country->code)->exists()){
  793. return Response::json(['status' => 'fail', 'message' => '该国家/地区下存在关联节点,请先取消关联']);
  794. }
  795. if($country->delete()){
  796. return Response::json(['status' => 'success', 'message' => '操作成功']);
  797. }
  798. return Response::json(['status' => 'fail', 'message' => '操作失败']);
  799. }
  800. // 系统设置
  801. public function system() {
  802. $view = self::$sysConfig;
  803. $view['labelList'] = Label::orderByDesc('sort')->orderBy('id')->get();
  804. return view('admin.config.system', $view);
  805. }
  806. // 设置某个配置项
  807. public function setConfig(Request $request): JsonResponse {
  808. $name = (string) $request->input('name');
  809. $value = $request->input('value');
  810. if(!$name){
  811. return Response::json(['status' => 'fail', 'message' => '设置失败:请求参数异常']);
  812. }
  813. // 屏蔽异常配置
  814. if(!array_key_exists($name, self::$sysConfig)){
  815. return Response::json(['status' => 'fail', 'message' => '设置失败:配置不存在']);
  816. }
  817. // 如果开启用户邮件重置密码,则先设置网站名称和网址
  818. if($value !== '0'
  819. && in_array($name, ['is_reset_password', 'is_activate_account', 'expire_warning', 'traffic_warning'], true)){
  820. $config = Config::find('website_name');
  821. if(!$config->value){
  822. return Response::json(['status' => 'fail', 'message' => '设置失败:启用该配置需要先设置【网站名称】']);
  823. }
  824. $config = Config::find('website_url');
  825. if(!$config->value){
  826. return Response::json(['status' => 'fail', 'message' => '设置失败:启用该配置需要先设置【网站地址】']);
  827. }
  828. }
  829. // 支付设置判断
  830. if($value !== null && in_array($name, ['is_AliPay', 'is_QQPay', 'is_WeChatPay', 'is_otherPay'], true)){
  831. switch($value){
  832. case 'f2fpay':
  833. if(!self::$sysConfig['f2fpay_app_id'] || !self::$sysConfig['f2fpay_private_key']
  834. || !self::$sysConfig['f2fpay_public_key']){
  835. return Response::json(['status' => 'fail', 'message' => '请先设置【支付宝F2F】必要参数']);
  836. }
  837. break;
  838. case 'codepay':
  839. if(!self::$sysConfig['codepay_url'] || !self::$sysConfig['codepay_id']
  840. || !self::$sysConfig['codepay_key']){
  841. return Response::json(['status' => 'fail', 'message' => '请先设置【码支付】必要参数']);
  842. }
  843. break;
  844. case 'epay':
  845. if(!self::$sysConfig['epay_url'] || !self::$sysConfig['epay_mch_id'] || !self::$sysConfig['epay_key']){
  846. return Response::json(['status' => 'fail', 'message' => '请先设置【易支付】必要参数']);
  847. }
  848. break;
  849. case 'payjs':
  850. if(!self::$sysConfig['payjs_mch_id'] || !self::$sysConfig['payjs_key']){
  851. return Response::json(['status' => 'fail', 'message' => '请先设置【PayJs】必要参数']);
  852. }
  853. break;
  854. case 'bitpayx':
  855. if(!self::$sysConfig['bitpay_secret']){
  856. return Response::json(['status' => 'fail', 'message' => '请先设置【麻瓜宝】必要参数']);
  857. }
  858. break;
  859. case 'paypal':
  860. if(!self::$sysConfig['paypal_username'] || !self::$sysConfig['paypal_password']
  861. || !self::$sysConfig['paypal_secret']){
  862. return Response::json(['status' => 'fail', 'message' => '请先设置【PayPal】必要参数']);
  863. }
  864. break;
  865. default:
  866. return Response::json(['status' => 'fail', 'message' => '未知支付渠道']);
  867. }
  868. }
  869. // 演示环境禁止修改特定配置项
  870. if(config('app.demo')){
  871. $denyConfig = [
  872. 'website_url',
  873. 'min_rand_traffic',
  874. 'max_rand_traffic',
  875. 'push_bear_send_key',
  876. 'push_bear_qrcode',
  877. 'is_forbid_china',
  878. 'website_security_code'
  879. ];
  880. if(in_array($name, $denyConfig, true)){
  881. return Response::json(['status' => 'fail', 'message' => '演示环境禁止修改该配置']);
  882. }
  883. }
  884. // 如果是返利比例,则需要除100
  885. if($name === 'referral_percent'){
  886. $value = (int) $value / 100;
  887. }
  888. // 更新配置
  889. Config::find($name)->update(['value' => $value]);
  890. return Response::json(['status' => 'success', 'message' => '操作成功']);
  891. }
  892. // 推送通知测试
  893. public function sendTestNotification(): JsonResponse {
  894. if(self::$sysConfig['is_notification']){
  895. $result = PushNotification::send('这是测试的标题', 'ProxyPanel测试内容');
  896. if($result === false){
  897. return Response::json(['status' => 'fail', 'message' => '发送失败,请重新尝试!']);
  898. }
  899. switch(self::$sysConfig['is_notification']){
  900. case 'serverChan':
  901. if(!$result['errno']){
  902. return Response::json(['status' => 'success', 'message' => '发送成功,请查看手机是否收到推送消息']);
  903. }
  904. return Response::json(['status' => 'fail', 'message' => $result? $result['errmsg'] : '未知']);
  905. case 'bark':
  906. if($result['code'] == 200){
  907. return Response::json(['status' => 'success', 'message' => '发送成功,请查看手机是否收到推送消息']);
  908. }
  909. return Response::json(['status' => 'fail', 'message' => $result['message']]);
  910. default:
  911. }
  912. }
  913. return Response::json(['status' => 'fail', 'message' => '请先选择【日志通知】渠道']);
  914. }
  915. // 邀请码列表
  916. public function inviteList(Request $request) {
  917. $view['inviteList'] = Invite::with(['invitee:id,email', 'inviter:id,email'])
  918. ->orderBy('status')
  919. ->latest()
  920. ->paginate(15)
  921. ->appends($request->except('page'));
  922. return view('admin.inviteList', $view);
  923. }
  924. // 生成邀请码
  925. public function makeInvite(): JsonResponse {
  926. for($i = 0; $i < 10; $i++){
  927. $obj = new Invite();
  928. $obj->inviter_id = 0;
  929. $obj->invitee_id = 0;
  930. $obj->code = strtoupper(substr(md5(microtime().Str::random(6)), 8, 12));
  931. $obj->status = 0;
  932. $obj->dateline = date('Y-m-d H:i:s', strtotime("+".self::$sysConfig['admin_invite_days']." days"));
  933. $obj->save();
  934. }
  935. return Response::json(['status' => 'success', 'message' => '生成成功']);
  936. }
  937. // 导出邀请码
  938. public function exportInvite(): void {
  939. $inviteList = Invite::whereStatus(0)->orderBy('id')->get();
  940. $filename = '邀请码'.date('Ymd').'.xlsx';
  941. $spreadsheet = new Spreadsheet();
  942. $spreadsheet->getProperties()
  943. ->setCreator('ProxyPanel')
  944. ->setLastModifiedBy('ProxyPanel')
  945. ->setTitle('邀请码')
  946. ->setSubject('邀请码')
  947. ->setDescription('')
  948. ->setKeywords('')
  949. ->setCategory('');
  950. try{
  951. $spreadsheet->setActiveSheetIndex(0);
  952. $sheet = $spreadsheet->getActiveSheet();
  953. $sheet->setTitle('邀请码');
  954. $sheet->fromArray(['邀请码', '有效期'], null);
  955. foreach($inviteList as $k => $vo){
  956. $sheet->fromArray([$vo->code, $vo->dateline], null, 'A'.($k + 2));
  957. }
  958. header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'); // 输出07Excel文件
  959. //header('Content-Type:application/vnd.ms-excel'); // 输出Excel03版本文件
  960. header('Content-Disposition: attachment;filename="'.$filename.'"');
  961. header('Cache-Control: max-age=0');
  962. $writer = new Xlsx($spreadsheet);
  963. $writer->save('php://output');
  964. }catch(\PhpOffice\PhpSpreadsheet\Exception $e){
  965. Log::error('导出优惠券时报错'.$e->getMessage());
  966. }
  967. }
  968. // 订单列表
  969. public function orderList(Request $request) {
  970. $email = $request->input('email');
  971. $order_sn = $request->input('order_sn');
  972. $is_coupon = $request->input('is_coupon');
  973. $is_expire = $request->input('is_expire');
  974. $pay_way = $request->input('pay_way');
  975. $status = $request->input('status');
  976. $range_time = $request->input('range_time');
  977. $sort = $request->input('sort'); // 0-按创建时间降序、1-按创建时间升序
  978. $order_id = $request->input('id');
  979. $query = Order::with(['user:id,email', 'goods:id,name', 'coupon:id,name,sn']);
  980. if(isset($email)){
  981. $query->whereHas('user', static function($q) use ($email) {
  982. $q->where('email', 'like', '%'.$email.'%');
  983. });
  984. }
  985. if(isset($order_sn)){
  986. $query->where('order_sn', 'like', '%'.$order_sn.'%');
  987. }
  988. if(isset($is_coupon)){
  989. if($is_coupon){
  990. $query->where('coupon_id', '<>', 0);
  991. }else{
  992. $query->whereCouponId(0);
  993. }
  994. }
  995. if(isset($is_expire)){
  996. $query->whereIsExpire($is_expire);
  997. }
  998. if(isset($pay_way)){
  999. $query->wherePayWay($pay_way);
  1000. }
  1001. if(isset($status)){
  1002. $query->whereStatus($status);
  1003. }
  1004. if(isset($range_time) && $range_time !== ','){
  1005. $range_time = explode(',', $range_time);
  1006. $query->where('created_at', '>=', $range_time[0])->where('created_at', '<=', $range_time[1]);
  1007. }
  1008. if(isset($order_id)){
  1009. $query->whereId($order_id);
  1010. }
  1011. if($sort){
  1012. $query->orderBy('id');
  1013. }else{
  1014. $query->orderByDesc('id');
  1015. }
  1016. $view['orderList'] = $query->paginate(15)->appends($request->except('page'));
  1017. return view('admin.logs.orderList', $view);
  1018. }
  1019. // 重置用户流量
  1020. public function resetUserTraffic(Request $request): JsonResponse {
  1021. User::find($request->input('id'))->update(['u' => 0, 'd' => 0]);
  1022. return Response::json(['status' => 'success', 'message' => '操作成功']);
  1023. }
  1024. // 操作用户余额
  1025. public function handleUserCredit(Request $request) {
  1026. if($request->isMethod('POST')){
  1027. $userId = $request->input('user_id');
  1028. $amount = $request->input('amount');
  1029. if(empty($userId) || empty($amount)){
  1030. return Response::json(['status' => 'fail', 'message' => '充值异常']);
  1031. }
  1032. $user = User::find($userId);
  1033. // 写入余额变动日志
  1034. Helpers::addUserCreditLog($userId, 0, $user->credit, $user->credit + $amount, $amount, '后台手动充值');
  1035. // 加减余额
  1036. if((new UserService($user))->updateCredit($amount)){
  1037. return Response::json(['status' => 'success', 'message' => '充值成功']);
  1038. }
  1039. return Response::json(['status' => 'fail', 'message' => '充值失败']);
  1040. }
  1041. return view('admin.handleUserCredit');
  1042. }
  1043. // 用户余额变动记录
  1044. public function userCreditLogList(Request $request) {
  1045. $email = $request->input('email');
  1046. $query = UserCreditLog::with('user:id,email')->latest();
  1047. if(isset($email)){
  1048. $query->whereHas('user', static function($q) use ($email) {
  1049. $q->where('email', 'like', '%'.$email.'%');
  1050. });
  1051. }
  1052. $view['list'] = $query->paginate(15)->appends($request->except('page'));
  1053. return view('admin.logs.userCreditLogList', $view);
  1054. }
  1055. // 用户封禁记录
  1056. public function userBanLogList(Request $request) {
  1057. $email = $request->input('email');
  1058. $query = UserBanedLog::with('user:id,email,t')->latest();
  1059. if(isset($email)){
  1060. $query->whereHas('user', static function($q) use ($email) {
  1061. $q->where('email', 'like', '%'.$email.'%');
  1062. });
  1063. }
  1064. $view['list'] = $query->paginate(15)->appends($request->except('page'));
  1065. return view('admin.logs.userBanLogList', $view);
  1066. }
  1067. // 用户流量变动记录
  1068. public function userTrafficLogList(Request $request) {
  1069. $email = $request->input('email');
  1070. $query = UserDataModifyLog::with(['user:id,email', 'order.goods:id,name']);
  1071. if(isset($email)){
  1072. $query->whereHas('user', static function($q) use ($email) {
  1073. $q->where('email', 'like', '%'.$email.'%');
  1074. });
  1075. }
  1076. $view['list'] = $query->latest()->paginate(15)->appends($request->except('page'));
  1077. return view('admin.logs.userTrafficLogList', $view);
  1078. }
  1079. // 用户在线IP记录
  1080. public function userOnlineIPList(Request $request) {
  1081. $email = $request->input('email');
  1082. $port = $request->input('port');
  1083. $wechat = $request->input('wechat');
  1084. $qq = $request->input('qq');
  1085. $query = User::activeUser();
  1086. if(isset($email)){
  1087. $query->where('email', 'like', '%'.$email.'%');
  1088. }
  1089. if(isset($wechat)){
  1090. $query->where('wechat', 'like', '%'.$wechat.'%');
  1091. }
  1092. if(isset($qq)){
  1093. $query->where('qq', 'like', '%'.$qq.'%');
  1094. }
  1095. if(isset($port)){
  1096. $query->wherePort($port);
  1097. }
  1098. $userList = $query->paginate(15)->appends($request->except('page'));
  1099. $nodeOnlineIPs = NodeOnlineUserIp::with('node:id,name')
  1100. ->where('created_at', '>=', strtotime("-10 minutes"))
  1101. ->latest()
  1102. ->distinct();
  1103. // Todo 优化查询
  1104. foreach($userList as $user){
  1105. // 最近5条在线IP记录,如果后端设置为60秒上报一次,则为10分钟内的在线IP
  1106. $user->onlineIPList = $nodeOnlineIPs->wherePort($user->port)->limit(5)->get();
  1107. }
  1108. $view['userList'] = $userList;
  1109. return view('admin.logs.userOnlineIPList', $view);
  1110. }
  1111. // 转换成某个用户的身份
  1112. public function switchToUser(Request $request): JsonResponse {
  1113. $id = $request->input('user_id');
  1114. $user = User::find($id);
  1115. if(!$user){
  1116. return Response::json(['status' => 'fail', 'message' => "用户不存在"]);
  1117. }
  1118. // 存储当前管理员ID,并将当前登录信息改成要切换的用户的身份信息
  1119. Session::put('admin', Auth::id());
  1120. Auth::login($user);
  1121. return Response::json(['status' => 'success', 'message' => "身份切换成功"]);
  1122. }
  1123. // 添加标签
  1124. public function addLabel(Request $request) {
  1125. if($request->isMethod('POST')){
  1126. $name = $request->input('name');
  1127. $sort = $request->input('sort');
  1128. $label = new Label();
  1129. $label->name = $name;
  1130. $label->sort = $sort;
  1131. $label->save();
  1132. return Response::json(['status' => 'success', 'message' => '添加成功']);
  1133. }
  1134. return view('admin.label.addLabel');
  1135. }
  1136. // 编辑标签
  1137. public function editLabel(Request $request) {
  1138. $id = $request->input('id');
  1139. if($request->isMethod('POST')){
  1140. $name = $request->input('name');
  1141. $sort = $request->input('sort');
  1142. Label::whereId($id)->update(['name' => $name, 'sort' => $sort]);
  1143. return Response::json(['status' => 'success', 'message' => '添加成功']);
  1144. }
  1145. $view['label'] = Label::find($id);
  1146. return view('admin.label.editLabel', $view);
  1147. }
  1148. // 删除标签
  1149. public function delLabel(Request $request): ?JsonResponse {
  1150. $id = $request->input('id');
  1151. try{
  1152. DB::beginTransaction();
  1153. Label::whereId($id)->delete();
  1154. NodeLabel::whereLabelId($id)->delete(); // 删除节点关联
  1155. DB::commit();
  1156. return Response::json(['status' => 'success', 'message' => '删除成功']);
  1157. }catch(Exception $e){
  1158. DB::rollBack();
  1159. return Response::json(['status' => 'fail', 'message' => '删除失败:'.$e->getMessage()]);
  1160. }
  1161. }
  1162. // 邮件发送日志列表
  1163. public function notificationLog(Request $request) {
  1164. $email = $request->input('email');
  1165. $type = $request->input('type');
  1166. $query = NotificationLog::query();
  1167. if(isset($email)){
  1168. $query->where('address', 'like', '%'.$email.'%');
  1169. }
  1170. if(isset($type)){
  1171. $query->whereType($type);
  1172. }
  1173. $view['list'] = $query->latest()->paginate(15)->appends($request->except('page'));
  1174. return view('admin.logs.notificationLog', $view);
  1175. }
  1176. // 在线IP监控(实时)
  1177. public function onlineIPMonitor(Request $request) {
  1178. $ip = $request->input('ip');
  1179. $email = $request->input('email');
  1180. $port = $request->input('port');
  1181. $nodeId = $request->input('nodeId');
  1182. $userId = $request->input('id');
  1183. $query = NodeOnlineUserIp::with(['node:id,name', 'user:id,email'])
  1184. ->where('created_at', '>=', strtotime("-2 minutes"));
  1185. if(isset($ip)){
  1186. $query->whereIp($ip);
  1187. }
  1188. if(isset($email)){
  1189. $query->whereHas('user', static function($q) use ($email) {
  1190. $q->where('email', 'like', '%'.$email.'%');
  1191. });
  1192. }
  1193. if(isset($port)){
  1194. $query->whereHas('user', static function($q) use ($port) {
  1195. $q->wherePort($port);
  1196. });
  1197. }
  1198. if(isset($nodeId)){
  1199. $query->whereHas('node', static function($q) use ($nodeId) {
  1200. $q->whereId($nodeId);
  1201. });
  1202. }
  1203. if(isset($userId)){
  1204. $query->whereHas('user', static function($q) use ($userId) {
  1205. $q->whereId($userId);
  1206. });
  1207. }
  1208. $onlineIPLogs = $query->groupBy('user_id', 'node_id')
  1209. ->latest()
  1210. ->paginate(20)
  1211. ->appends($request->except('page'));
  1212. foreach($onlineIPLogs as $log){
  1213. // 跳过上报多IP的
  1214. if($log->ip == null || strpos($log->ip, ',') !== false){
  1215. continue;
  1216. }
  1217. $ipInfo = QQWry::ip($log->ip);
  1218. if(isset($ipInfo['error'])){
  1219. // 用IPIP的库再试一下
  1220. $ipip = IPIP::ip($log->ip);
  1221. $ipInfo = [
  1222. 'country' => $ipip['country_name'],
  1223. 'province' => $ipip['region_name'],
  1224. 'city' => $ipip['city_name']
  1225. ];
  1226. }
  1227. $log->ipInfo = $ipInfo['country'].' '.$ipInfo['province'].' '.$ipInfo['city'];
  1228. }
  1229. $view['list'] = $onlineIPLogs;
  1230. $view['nodeList'] = Node::whereStatus(1)->orderByDesc('sort')->latest()->get();
  1231. return view('admin.logs.onlineIPMonitor', $view);
  1232. }
  1233. }