AdminController.php 107 KB

1234567891011121314151617181920212223242526272829303132333435363738394041424344454647484950515253545556575859606162636465666768697071727374757677787980818283848586878889909192939495969798991001011021031041051061071081091101111121131141151161171181191201211221231241251261271281291301311321331341351361371381391401411421431441451461471481491501511521531541551561571581591601611621631641651661671681691701711721731741751761771781791801811821831841851861871881891901911921931941951961971981992002012022032042052062072082092102112122132142152162172182192202212222232242252262272282292302312322332342352362372382392402412422432442452462472482492502512522532542552562572582592602612622632642652662672682692702712722732742752762772782792802812822832842852862872882892902912922932942952962972982993003013023033043053063073083093103113123133143153163173183193203213223233243253263273283293303313323333343353363373383393403413423433443453463473483493503513523533543553563573583593603613623633643653663673683693703713723733743753763773783793803813823833843853863873883893903913923933943953963973983994004014024034044054064074084094104114124134144154164174184194204214224234244254264274284294304314324334344354364374384394404414424434444454464474484494504514524534544554564574584594604614624634644654664674684694704714724734744754764774784794804814824834844854864874884894904914924934944954964974984995005015025035045055065075085095105115125135145155165175185195205215225235245255265275285295305315325335345355365375385395405415425435445455465475485495505515525535545555565575585595605615625635645655665675685695705715725735745755765775785795805815825835845855865875885895905915925935945955965975985996006016026036046056066076086096106116126136146156166176186196206216226236246256266276286296306316326336346356366376386396406416426436446456466476486496506516526536546556566576586596606616626636646656666676686696706716726736746756766776786796806816826836846856866876886896906916926936946956966976986997007017027037047057067077087097107117127137147157167177187197207217227237247257267277287297307317327337347357367377387397407417427437447457467477487497507517527537547557567577587597607617627637647657667677687697707717727737747757767777787797807817827837847857867877887897907917927937947957967977987998008018028038048058068078088098108118128138148158168178188198208218228238248258268278288298308318328338348358368378388398408418428438448458468478488498508518528538548558568578588598608618628638648658668678688698708718728738748758768778788798808818828838848858868878888898908918928938948958968978988999009019029039049059069079089099109119129139149159169179189199209219229239249259269279289299309319329339349359369379389399409419429439449459469479489499509519529539549559569579589599609619629639649659669679689699709719729739749759769779789799809819829839849859869879889899909919929939949959969979989991000100110021003100410051006100710081009101010111012101310141015101610171018101910201021102210231024102510261027102810291030103110321033103410351036103710381039104010411042104310441045104610471048104910501051105210531054105510561057105810591060106110621063106410651066106710681069107010711072107310741075107610771078107910801081108210831084108510861087108810891090109110921093109410951096109710981099110011011102110311041105110611071108110911101111111211131114111511161117111811191120112111221123112411251126112711281129113011311132113311341135113611371138113911401141114211431144114511461147114811491150115111521153115411551156115711581159116011611162116311641165116611671168116911701171117211731174117511761177117811791180118111821183118411851186118711881189119011911192119311941195119611971198119912001201120212031204120512061207120812091210121112121213121412151216121712181219122012211222122312241225122612271228122912301231123212331234123512361237123812391240124112421243124412451246124712481249125012511252125312541255125612571258125912601261126212631264126512661267126812691270127112721273127412751276127712781279128012811282128312841285128612871288128912901291129212931294129512961297129812991300130113021303130413051306130713081309131013111312131313141315131613171318131913201321132213231324132513261327132813291330133113321333133413351336133713381339134013411342134313441345134613471348134913501351135213531354135513561357135813591360136113621363136413651366136713681369137013711372137313741375137613771378137913801381138213831384138513861387138813891390139113921393139413951396139713981399140014011402140314041405140614071408140914101411141214131414141514161417141814191420142114221423142414251426142714281429143014311432143314341435143614371438143914401441144214431444144514461447144814491450145114521453145414551456145714581459146014611462146314641465146614671468146914701471147214731474147514761477147814791480148114821483148414851486148714881489149014911492149314941495149614971498149915001501150215031504150515061507150815091510151115121513151415151516151715181519152015211522152315241525152615271528152915301531153215331534153515361537153815391540154115421543154415451546154715481549155015511552155315541555155615571558155915601561156215631564156515661567156815691570157115721573157415751576157715781579158015811582158315841585158615871588158915901591159215931594159515961597159815991600160116021603160416051606160716081609161016111612161316141615161616171618161916201621162216231624162516261627162816291630163116321633163416351636163716381639164016411642164316441645164616471648164916501651165216531654165516561657165816591660166116621663166416651666166716681669167016711672167316741675167616771678167916801681168216831684168516861687168816891690169116921693169416951696169716981699170017011702170317041705170617071708170917101711171217131714171517161717171817191720172117221723172417251726172717281729173017311732173317341735173617371738173917401741174217431744174517461747174817491750175117521753175417551756175717581759176017611762176317641765176617671768176917701771177217731774177517761777177817791780178117821783178417851786178717881789179017911792179317941795179617971798179918001801180218031804180518061807180818091810181118121813181418151816181718181819182018211822182318241825182618271828182918301831183218331834183518361837183818391840184118421843184418451846184718481849185018511852185318541855185618571858185918601861186218631864186518661867186818691870187118721873187418751876187718781879188018811882188318841885188618871888188918901891189218931894189518961897189818991900190119021903190419051906190719081909191019111912191319141915191619171918191919201921192219231924192519261927192819291930193119321933193419351936193719381939194019411942194319441945194619471948194919501951195219531954195519561957195819591960196119621963196419651966196719681969197019711972197319741975197619771978197919801981198219831984198519861987198819891990199119921993199419951996199719981999200020012002200320042005200620072008200920102011201220132014201520162017201820192020202120222023202420252026202720282029203020312032203320342035203620372038203920402041204220432044204520462047204820492050205120522053205420552056205720582059206020612062206320642065206620672068206920702071207220732074207520762077207820792080208120822083208420852086208720882089209020912092209320942095209620972098209921002101210221032104210521062107210821092110211121122113211421152116211721182119212021212122212321242125212621272128212921302131213221332134213521362137213821392140214121422143214421452146214721482149215021512152215321542155215621572158215921602161216221632164216521662167216821692170217121722173217421752176217721782179218021812182218321842185218621872188218921902191219221932194219521962197219821992200220122022203220422052206220722082209221022112212221322142215221622172218221922202221222222232224222522262227222822292230223122322233223422352236223722382239224022412242224322442245224622472248224922502251225222532254225522562257225822592260226122622263226422652266226722682269227022712272227322742275227622772278227922802281228222832284228522862287228822892290229122922293229422952296229722982299230023012302230323042305230623072308230923102311231223132314231523162317231823192320232123222323232423252326232723282329233023312332233323342335233623372338233923402341234223432344234523462347234823492350235123522353235423552356235723582359236023612362236323642365236623672368236923702371237223732374237523762377237823792380238123822383238423852386238723882389239023912392239323942395239623972398239924002401240224032404240524062407240824092410241124122413241424152416241724182419242024212422242324242425242624272428242924302431243224332434243524362437243824392440244124422443244424452446244724482449245024512452245324542455245624572458245924602461246224632464246524662467246824692470247124722473247424752476247724782479248024812482248324842485248624872488248924902491249224932494249524962497249824992500250125022503250425052506250725082509251025112512251325142515251625172518251925202521252225232524252525262527252825292530253125322533253425352536253725382539254025412542254325442545254625472548254925502551255225532554255525562557255825592560256125622563256425652566256725682569257025712572257325742575257625772578257925802581258225832584258525862587258825892590259125922593259425952596259725982599260026012602260326042605260626072608260926102611261226132614261526162617261826192620262126222623262426252626262726282629263026312632263326342635263626372638263926402641
  1. <?php
  2. namespace App\Http\Controllers;
  3. use App\Components\Helpers;
  4. use App\Components\IPIP;
  5. use App\Components\QQWry;
  6. use App\Http\Models\Article;
  7. use App\Http\Models\Config;
  8. use App\Http\Models\Country;
  9. use App\Http\Models\EmailLog;
  10. use App\Http\Models\Invite;
  11. use App\Http\Models\Label;
  12. use App\Http\Models\Level;
  13. use App\Http\Models\Order;
  14. use App\Http\Models\ReferralApply;
  15. use App\Http\Models\ReferralLog;
  16. use App\Http\Models\SsConfig;
  17. use App\Http\Models\SsGroup;
  18. use App\Http\Models\SsGroupNode;
  19. use App\Http\Models\SsNode;
  20. use App\Http\Models\SsNodeInfo;
  21. use App\Http\Models\SsNodeIp;
  22. use App\Http\Models\SsNodeLabel;
  23. use App\Http\Models\SsNodeOnlineLog;
  24. use App\Http\Models\SsNodeTrafficDaily;
  25. use App\Http\Models\SsNodeTrafficHourly;
  26. use App\Http\Models\User;
  27. use App\Http\Models\UserBalanceLog;
  28. use App\Http\Models\UserBanLog;
  29. use App\Http\Models\UserLabel;
  30. use App\Http\Models\UserLoginLog;
  31. use App\Http\Models\UserSubscribe;
  32. use App\Http\Models\UserTrafficDaily;
  33. use App\Http\Models\UserTrafficHourly;
  34. use App\Http\Models\UserTrafficLog;
  35. use App\Http\Models\UserTrafficModifyLog;
  36. use PhpOffice\PhpSpreadsheet\Spreadsheet;
  37. use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
  38. use Illuminate\Http\Request;
  39. use Redirect;
  40. use Response;
  41. use Session;
  42. use Log;
  43. use DB;
  44. use Auth;
  45. use Hash;
  46. /**
  47. * 管理员控制器
  48. *
  49. * Class AdminController
  50. *
  51. * @package App\Http\Controllers
  52. */
  53. class AdminController extends Controller
  54. {
  55. protected static $systemConfig;
  56. function __construct()
  57. {
  58. self::$systemConfig = Helpers::systemConfig();
  59. }
  60. public function index(Request $request)
  61. {
  62. $past = strtotime(date('Y-m-d', strtotime("-" . self::$systemConfig['expire_days'] . " days")));
  63. $view['expireDays'] = self::$systemConfig['expire_days'];
  64. $view['totalUserCount'] = User::query()->count(); // 总用户数
  65. $view['enableUserCount'] = User::query()->where('enable', 1)->count(); // 有效用户数
  66. $view['activeUserCount'] = User::query()->where('t', '>=', $past)->count(); // 活跃用户数
  67. $view['unActiveUserCount'] = User::query()->where('t', '<=', $past)->where('enable', 1)->where('t', '>', 0)->count(); // 不活跃用户数
  68. $view['onlineUserCount'] = User::query()->where('t', '>=', time() - 600)->count(); // 10分钟内在线用户数
  69. $view['expireWarningUserCount'] = User::query()->where('expire_time', '>=', date('Y-m-d', strtotime("now")))->where('expire_time', '<=', date('Y-m-d', strtotime("+" . self::$systemConfig['expire_days'] . " days")))->count(); // 临近过期用户数
  70. $view['largeTrafficUserCount'] = User::query()->whereRaw('(u + d) >= 107374182400')->whereIn('status', [0, 1])->count(); // 流量超过100G的用户
  71. // 1小时内流量异常用户
  72. $tempUsers = [];
  73. $userTotalTrafficList = UserTrafficHourly::query()->where('node_id', 0)->where('total', '>', 104857600)->where('created_at', '>=', date('Y-m-d H:i:s', time() - 3900))->groupBy('user_id')->selectRaw("user_id, sum(total) as totalTraffic")->get(); // 只统计100M以上的记录,加快速度
  74. if (!$userTotalTrafficList->isEmpty()) {
  75. foreach ($userTotalTrafficList as $vo) {
  76. if ($vo->totalTraffic > (self::$systemConfig['traffic_ban_value'] * 1073741824)) {
  77. $tempUsers[] = $vo->user_id;
  78. }
  79. }
  80. }
  81. $view['flowAbnormalUserCount'] = User::query()->whereIn('id', $tempUsers)->count();
  82. $view['nodeCount'] = SsNode::query()->count();
  83. $view['unnormalNodeCount'] = SsNode::query()->where('status', 0)->count();
  84. $flowCount = SsNodeTrafficDaily::query()->where('created_at', '>=', date('Y-m-d 00:00:00', strtotime("-30 days")))->sum('total');
  85. $view['flowCount'] = flowAutoShow($flowCount);
  86. $totalFlowCount = SsNodeTrafficDaily::query()->sum('total');
  87. $view['totalFlowCount'] = flowAutoShow($totalFlowCount);
  88. $view['totalBalance'] = User::query()->sum('balance') / 100;
  89. $view['totalWaitRefAmount'] = ReferralLog::query()->whereIn('status', [0, 1])->sum('ref_amount') / 100;
  90. $view['totalRefAmount'] = ReferralApply::query()->where('status', 2)->sum('amount') / 100;
  91. $view['totalOrder'] = Order::query()->count();
  92. $view['totalOnlinePayOrder'] = Order::query()->where('pay_way', 2)->count();
  93. $view['totalSuccessOrder'] = Order::query()->where('status', 2)->count();
  94. $view['todaySuccessOrder'] = Order::query()->where('status', 2)->where('created_at', '>=', date('Y-m-d 00:00:00'))->where('created_at', '<=', date('Y-m-d 23:59:59'))->count();
  95. return Response::view('admin.index', $view);
  96. }
  97. // 用户列表
  98. public function userList(Request $request)
  99. {
  100. $id = intval($request->get('id'));
  101. $username = trim($request->get('username'));
  102. $wechat = trim($request->get('wechat'));
  103. $qq = trim($request->get('qq'));
  104. $port = intval($request->get('port'));
  105. $pay_way = intval($request->get('pay_way'));
  106. $status = $request->get('status');
  107. $enable = $request->get('enable');
  108. $online = $request->get('online');
  109. $unActive = $request->get('unActive');
  110. $flowAbnormal = $request->get('flowAbnormal');
  111. $expireWarning = $request->get('expireWarning');
  112. $largeTraffic = $request->get('largeTraffic');
  113. $query = User::query()->with(['subscribe']);
  114. if (!empty($id)) {
  115. $query->where('id', $id);
  116. }
  117. if (!empty($username)) {
  118. $query->where('username', 'like', '%' . $username . '%');
  119. }
  120. if (!empty($wechat)) {
  121. $query->where('wechat', 'like', '%' . $wechat . '%');
  122. }
  123. if (!empty($qq)) {
  124. $query->where('qq', 'like', '%' . $qq . '%');
  125. }
  126. if ($port != '') {
  127. $query->where('port', $port);
  128. }
  129. if ($pay_way != '') {
  130. $query->where('pay_way', $pay_way);
  131. }
  132. if ($status != '') {
  133. $query->where('status', intval($status));
  134. }
  135. if ($enable != '') {
  136. $query->where('enable', intval($enable));
  137. }
  138. // 流量超过100G的
  139. if ($largeTraffic) {
  140. $query->whereIn('status', [0, 1])->whereRaw('(u + d) >= 107374182400');
  141. }
  142. // 临近过期提醒
  143. if ($expireWarning) {
  144. $query->where('expire_time', '>=', date('Y-m-d', strtotime("now")))->where('expire_time', '<=', date('Y-m-d', strtotime("+" . self::$systemConfig['expire_days'] . " days")));
  145. }
  146. // 当前在线
  147. if ($online) {
  148. $query->where('t', '>=', time() - 600);
  149. }
  150. // 不活跃用户
  151. if ($unActive) {
  152. $query->where('t', '>', 0)->where('t', '<=', strtotime(date('Y-m-d', strtotime("-" . self::$systemConfig['expire_days'] . " days"))))->where('enable', 1);
  153. }
  154. // 1小时内流量异常用户
  155. if ($flowAbnormal) {
  156. $tempUsers = [];
  157. $userTotalTrafficList = UserTrafficHourly::query()->where('node_id', 0)->where('total', '>', 104857600)->where('created_at', '>=', date('Y-m-d H:i:s', time() - 3900))->groupBy('user_id')->selectRaw("user_id, sum(total) as totalTraffic")->get(); // 只统计100M以上的记录,加快速度
  158. if (!$userTotalTrafficList->isEmpty()) {
  159. foreach ($userTotalTrafficList as $vo) {
  160. if ($vo->totalTraffic > (self::$systemConfig['traffic_ban_value'] * 1024 * 1024 * 1024)) {
  161. $tempUsers[] = $vo->user_id;
  162. }
  163. }
  164. }
  165. $query->whereIn('id', $tempUsers);
  166. }
  167. $userList = $query->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));
  168. foreach ($userList as &$user) {
  169. $user->transfer_enable = flowAutoShow($user->transfer_enable);
  170. $user->used_flow = flowAutoShow($user->u + $user->d);
  171. if ($user->expire_time < date('Y-m-d', strtotime("now"))) {
  172. $user->expireWarning = -1; // 已过期
  173. } elseif ($user->expire_time == date('Y-m-d', strtotime("now"))) {
  174. $user->expireWarning = 0; // 今天过期
  175. } elseif ($user->expire_time > date('Y-m-d', strtotime("now")) && $user->expire_time <= date('Y-m-d', strtotime("+30 days"))) {
  176. $user->expireWarning = 1; // 最近一个月过期
  177. } else {
  178. $user->expireWarning = 2; // 大于一个月过期
  179. }
  180. // 流量异常警告
  181. $time = date('Y-m-d H:i:s', time() - 3900);
  182. $totalTraffic = UserTrafficHourly::query()->where('user_id', $user->id)->where('node_id', 0)->where('created_at', '>=', $time)->sum('total');
  183. $user->trafficWarning = $totalTraffic > (self::$systemConfig['traffic_ban_value'] * 1024 * 1024 * 1024) ? 1 : 0;
  184. // 订阅地址
  185. $user->link = (self::$systemConfig['subscribe_domain'] ? self::$systemConfig['subscribe_domain'] : self::$systemConfig['website_url']) . '/s/' . $user->subscribe->code;
  186. }
  187. $view['userList'] = $userList;
  188. return Response::view('admin.userList', $view);
  189. }
  190. // 添加账号
  191. public function addUser(Request $request)
  192. {
  193. if ($request->isMethod('POST')) {
  194. // 校验username是否已存在
  195. $exists = User::query()->where('username', $request->get('username'))->first();
  196. if ($exists) {
  197. return Response::json(['status' => 'fail', 'data' => '', 'message' => '用户名已存在,请重新输入']);
  198. }
  199. if (!$request->get('usage')) {
  200. return Response::json(['status' => 'fail', 'data' => '', 'message' => '请至少选择一种用途']);
  201. }
  202. $user = new User();
  203. $user->username = trim($request->get('username'));
  204. $user->password = trim($request->get('password')) ? Hash::make(trim($request->get('password'))) : Hash::make(makeRandStr());
  205. $user->port = $request->get('port');
  206. $user->passwd = empty($request->get('passwd')) ? makeRandStr() : $request->get('passwd');
  207. $user->vmess_id = $request->get('vmess_id') ? trim($request->get('vmess_id')) : createGuid();
  208. $user->transfer_enable = toGB($request->get('transfer_enable', 0));
  209. $user->enable = intval($request->get('enable', 0));
  210. $user->method = $request->get('method');
  211. $user->protocol = $request->get('protocol');
  212. $user->protocol_param = $request->get('protocol_param') ? $request->get('protocol_param') : '';
  213. $user->obfs = $request->get('obfs');
  214. $user->obfs_param = $request->get('obfs_param') ? $request->get('obfs_param') : '';
  215. $user->speed_limit_per_con = intval($request->get('speed_limit_per_con'));
  216. $user->speed_limit_per_user = intval($request->get('speed_limit_per_user'));
  217. $user->gender = intval($request->get('gender'));
  218. $user->wechat = $request->get('wechat') ? $request->get('wechat') : '';
  219. $user->qq = $request->get('qq') ? $request->get('qq') : '';
  220. $user->usage = $request->get('usage');
  221. $user->pay_way = $request->get('pay_way');
  222. $user->balance = 0;
  223. $user->enable_time = empty($request->get('enable_time')) ? date('Y-m-d') : $request->get('enable_time');
  224. $user->expire_time = empty($request->get('expire_time')) ? date('Y-m-d', strtotime("+365 days")) : $request->get('expire_time');
  225. $user->remark = str_replace("eval", "", str_replace("atob", "", $request->get('remark')));
  226. $user->level = $request->get('level') ? $request->get('level') : 1;
  227. $user->is_admin = 0;
  228. $user->reg_ip = getClientIp();
  229. $user->referral_uid = 0;
  230. $user->traffic_reset_day = 0;
  231. $user->status = $request->get('status') ? $request->get('status') : 1;
  232. $user->save();
  233. if ($user->id) {
  234. // 生成订阅码
  235. $subscribe = new UserSubscribe();
  236. $subscribe->user_id = $user->id;
  237. $subscribe->code = Helpers::makeSubscribeCode();
  238. $subscribe->times = 0;
  239. $subscribe->save();
  240. // 生成用户标签
  241. $this->makeUserLabels($user->id, $request->get('labels'));
  242. // 写入用户流量变动记录
  243. Helpers::addUserTrafficModifyLog($user->id, 0, 0, toGB($request->get('transfer_enable', 0)), '后台手动添加用户');
  244. return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
  245. } else {
  246. return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败']);
  247. }
  248. } else {
  249. // 生成一个可用端口
  250. $view['last_port'] = self::$systemConfig['is_rand_port'] ? Helpers::getRandPort() : Helpers::getOnlyPort();
  251. $view['method_list'] = Helpers::methodList();
  252. $view['protocol_list'] = Helpers::protocolList();
  253. $view['obfs_list'] = Helpers::obfsList();
  254. $view['level_list'] = Helpers::levelList();
  255. $view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
  256. $view['initial_labels'] = explode(",", Helpers::systemConfig()['initial_labels_for_user']);
  257. return Response::view('admin.addUser', $view);
  258. }
  259. }
  260. // 批量生成账号
  261. public function batchAddUsers(Request $request)
  262. {
  263. DB::beginTransaction();
  264. try {
  265. for ($i = 0; $i < 5; $i++) {
  266. // 生成一个可用端口
  267. $port = self::$systemConfig['is_rand_port'] ? Helpers::getRandPort() : Helpers::getOnlyPort();
  268. $user = new User();
  269. $user->username = '批量生成-' . makeRandStr();
  270. $user->password = Hash::make(makeRandStr());
  271. $user->port = $port;
  272. $user->passwd = makeRandStr();
  273. $user->vmess_id = createGuid();
  274. $user->enable = 1;
  275. $user->method = Helpers::getDefaultMethod();
  276. $user->protocol = Helpers::getDefaultProtocol();
  277. $user->protocol_param = '';
  278. $user->obfs = Helpers::getDefaultObfs();
  279. $user->obfs_param = '';
  280. $user->usage = 1;
  281. $user->transfer_enable = toGB(1024);
  282. $user->enable_time = date('Y-m-d');
  283. $user->expire_time = date('Y-m-d', strtotime("+365 days"));
  284. $user->remark = '';
  285. $user->reg_ip = getClientIp();
  286. $user->referral_uid = 0;
  287. $user->traffic_reset_day = 0;
  288. $user->status = 1;
  289. $user->save();
  290. if ($user->id) {
  291. // 生成订阅码
  292. $subscribe = new UserSubscribe();
  293. $subscribe->user_id = $user->id;
  294. $subscribe->code = Helpers::makeSubscribeCode();
  295. $subscribe->times = 0;
  296. $subscribe->save();
  297. // 初始化默认标签
  298. if (!empty(self::$systemConfig['initial_labels_for_user'])) {
  299. $labels = explode(',', self::$systemConfig['initial_labels_for_user']);
  300. $this->makeUserLabels($user->id, $labels);
  301. }
  302. // 写入用户流量变动记录
  303. Helpers::addUserTrafficModifyLog($user->id, 0, 0, toGB(1024), '后台批量生成用户');
  304. }
  305. }
  306. DB::commit();
  307. return Response::json(['status' => 'success', 'data' => '', 'message' => '批量生成账号成功']);
  308. } catch (\Exception $e) {
  309. DB::rollBack();
  310. return Response::json(['status' => 'fail', 'data' => '', 'message' => '批量生成账号失败:' . $e->getMessage()]);
  311. }
  312. }
  313. // 编辑账号
  314. public function editUser(Request $request)
  315. {
  316. $id = intval($request->get('id'));
  317. if ($request->isMethod('POST')) {
  318. $username = trim($request->get('username'));
  319. $password = $request->get('password');
  320. $port = intval($request->get('port'));
  321. $passwd = $request->get('passwd');
  322. $vmess_id = $request->get('vmess_id') ? trim($request->get('vmess_id')) : createGuid();
  323. $transfer_enable = $request->get('transfer_enable');
  324. $enable = intval($request->get('enable'));
  325. $method = $request->get('method');
  326. $protocol = $request->get('protocol');
  327. $protocol_param = $request->get('protocol_param');
  328. $obfs = $request->get('obfs');
  329. $obfs_param = $request->get('obfs_param');
  330. $speed_limit_per_con = intval($request->get('speed_limit_per_con'));
  331. $speed_limit_per_user = intval($request->get('speed_limit_per_user'));
  332. $gender = intval($request->get('gender'));
  333. $wechat = $request->get('wechat');
  334. $qq = $request->get('qq');
  335. $usage = $request->get('usage');
  336. $pay_way = $request->get('pay_way');
  337. $status = $request->get('status');
  338. $labels = $request->get('labels');
  339. $enable_time = $request->get('enable_time');
  340. $expire_time = $request->get('expire_time');
  341. $remark = str_replace("eval", "", str_replace("atob", "", $request->get('remark')));
  342. $level = $request->get('level');
  343. $is_admin = $request->get('is_admin');
  344. // 校验username是否已存在
  345. $exists = User::query()->where('id', '<>', $id)->where('username', $username)->first();
  346. if ($exists) {
  347. return Response::json(['status' => 'fail', 'data' => '', 'message' => '用户名已存在,请重新输入']);
  348. }
  349. // 校验端口是否已存在
  350. $exists = User::query()->where('id', '<>', $id)->where('port', '>', 0)->where('port', $port)->first();
  351. if ($exists) {
  352. return Response::json(['status' => 'fail', 'data' => '', 'message' => '端口已存在,请重新输入']);
  353. }
  354. // 禁止取消默认管理员
  355. if ($id == 1 && $is_admin == 0) {
  356. return Response::json(['status' => 'fail', 'data' => '', 'message' => '系统默认管理员不可取消']);
  357. }
  358. if (!$request->get('usage')) {
  359. return Response::json(['status' => 'fail', 'data' => '', 'message' => '请至少选择一种用途']);
  360. }
  361. // 用户编辑前的信息
  362. $user = User::query()->where('id', $id)->first();
  363. DB::beginTransaction();
  364. try {
  365. $data = [
  366. 'username' => $username,
  367. 'port' => $port,
  368. 'passwd' => $passwd,
  369. 'vmess_id' => $vmess_id,
  370. 'transfer_enable' => toGB($transfer_enable),
  371. 'enable' => $status < 0 ? 0 : $enable, // 如果禁止登陆则同时禁用代理
  372. 'method' => $method,
  373. 'protocol' => $protocol,
  374. 'protocol_param' => $protocol_param,
  375. 'obfs' => $obfs,
  376. 'obfs_param' => $obfs_param,
  377. 'speed_limit_per_con' => $speed_limit_per_con,
  378. 'speed_limit_per_user' => $speed_limit_per_user,
  379. 'gender' => $gender,
  380. 'wechat' => $wechat,
  381. 'qq' => $qq,
  382. 'usage' => $usage,
  383. 'pay_way' => $pay_way,
  384. 'status' => $status,
  385. 'enable_time' => empty($enable_time) ? date('Y-m-d') : $enable_time,
  386. 'expire_time' => empty($expire_time) ? date('Y-m-d', strtotime("+365 days")) : $expire_time,
  387. 'remark' => $remark,
  388. 'level' => $level,
  389. ];
  390. // 只有admin才有权限操作管理员属性
  391. if (Auth::user()->id == 1) {
  392. $data['is_admin'] = $is_admin;
  393. }
  394. if (!empty($password)) {
  395. if (!(env('APP_DEMO') && $id == 1)) { // 演示环境禁止修改管理员密码
  396. $data['password'] = Hash::make($password);
  397. }
  398. }
  399. User::query()->where('id', $id)->update($data);
  400. // 重新生成用户标签
  401. $this->makeUserLabels($id, $labels);
  402. // 写入用户流量变动记录
  403. if ($user->transfer_enable != toGB($transfer_enable)) {
  404. Helpers::addUserTrafficModifyLog($id, 0, $user->transfer_enable, toGB($transfer_enable), '后台手动编辑用户');
  405. }
  406. DB::commit();
  407. return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
  408. } catch (\Exception $e) {
  409. DB::rollBack();
  410. Log::error('编辑用户信息异常:' . $e->getMessage());
  411. return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败']);
  412. }
  413. } else {
  414. $user = User::query()->with(['label', 'referral'])->where('id', $id)->first();
  415. if ($user) {
  416. $user->transfer_enable = flowToGB($user->transfer_enable);
  417. // 处理标签
  418. $label = [];
  419. foreach ($user->label as $vo) {
  420. $label[] = $vo->label_id;
  421. }
  422. $user->labels = $label;
  423. // 处理用途
  424. $user->usage = explode(',', $user->usage);
  425. }
  426. $view['user'] = $user;
  427. $view['method_list'] = Helpers::methodList();
  428. $view['protocol_list'] = Helpers::protocolList();
  429. $view['obfs_list'] = Helpers::obfsList();
  430. $view['level_list'] = Helpers::levelList();
  431. $view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
  432. return Response::view('admin.editUser', $view);
  433. }
  434. }
  435. // 删除用户
  436. public function delUser(Request $request)
  437. {
  438. $id = $request->get('id');
  439. if ($id <= 1) {
  440. return Response::json(['status' => 'fail', 'data' => '', 'message' => '系统管理员不可删除']);
  441. }
  442. DB::beginTransaction();
  443. try {
  444. User::query()->where('id', $id)->delete();
  445. UserSubscribe::query()->where('user_id', $id)->delete();
  446. UserBanLog::query()->where('user_id', $id)->delete();
  447. UserLabel::query()->where('user_id', $id)->delete();
  448. UserBalanceLog::query()->where('user_id', $id)->delete();
  449. UserTrafficModifyLog::query()->where('user_id', $id)->delete();
  450. UserLoginLog::query()->where('user_id', $id)->delete();
  451. DB::commit();
  452. return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
  453. } catch (\Exception $e) {
  454. Log::error($e);
  455. DB::rollBack();
  456. return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
  457. }
  458. }
  459. // 节点列表
  460. public function nodeList(Request $request)
  461. {
  462. $status = $request->input('status');
  463. $query = SsNode::query();
  464. if ($status != '') {
  465. $query->where('status', intval($status));
  466. }
  467. $nodeList = $query->orderBy('status', 'desc')->orderBy('id', 'asc')->paginate(15)->appends($request->except('page'));
  468. foreach ($nodeList as &$node) {
  469. // 在线人数
  470. $online_log = SsNodeOnlineLog::query()->where('node_id', $node->id)->where('log_time', '>=', strtotime("-5 minutes"))->orderBy('id', 'desc')->first();
  471. $node->online_users = empty($online_log) ? 0 : $online_log->online_user;
  472. // 已产生流量
  473. $totalTraffic = SsNodeTrafficDaily::query()->where('node_id', $node->id)->sum('total');
  474. $node->transfer = flowAutoShow($totalTraffic);
  475. // 负载(10分钟以内)
  476. $node_info = SsNodeInfo::query()->where('node_id', $node->id)->where('log_time', '>=', strtotime("-10 minutes"))->orderBy('id', 'desc')->first();
  477. $node->load = $node->is_transit ? '' : (empty($node_info) || empty($node_info->load) ? '离线' : $node_info->load);
  478. $node->uptime = empty($node_info) ? 0 : seconds2time($node_info->uptime);
  479. }
  480. $view['nodeList'] = $nodeList;
  481. return Response::view('admin.nodeList', $view);
  482. }
  483. // 添加节点
  484. public function addNode(Request $request)
  485. {
  486. if ($request->isMethod('POST')) {
  487. if ($request->get('ssh_port') <= 0 || $request->get('ssh_port') >= 65535) {
  488. return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败:SSH端口不合法']);
  489. }
  490. if (false === filter_var($request->get('ip'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV4)) {
  491. return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败:IPv4地址不合法']);
  492. }
  493. if ($request->get('ipv6') && false === filter_var($request->get('ipv6'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV6)) {
  494. return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败:IPv6地址不合法']);
  495. }
  496. if ($request->get('server')) {
  497. $domain = $request->get('server');
  498. $domain = explode('.', $domain);
  499. $domainSuffix = end($domain); // 取得域名后缀
  500. if (!in_array($domainSuffix, \config('domains'))) {
  501. return Response::json(['status' => 'fail', 'data' => '', 'message' => '绑定域名不合法']);
  502. }
  503. }
  504. // TODO:判断是否已存在绑定了相同域名的节点,提示是否要强制替换,或者不提示之前强制将其他节点的绑定域名置为空,然后发起域名绑定请求,或者请求进入队列
  505. DB::beginTransaction();
  506. try {
  507. $ssNode = new SsNode();
  508. $ssNode->type = intval($request->get('type'));
  509. $ssNode->name = $request->get('name');
  510. $ssNode->group_id = $request->get('group_id') ? intval($request->get('group_id')) : 0;
  511. $ssNode->country_code = $request->get('country_code') ? $request->get('country_code') : 'un';
  512. $ssNode->server = $request->get('server') ? $request->get('server') : '';
  513. $ssNode->ip = $request->get('ip');
  514. $ssNode->ipv6 = $request->get('ipv6');
  515. $ssNode->desc = $request->get('desc') ? $request->get('desc') : '';
  516. $ssNode->method = $request->get('method');
  517. $ssNode->protocol = $request->get('protocol');
  518. $ssNode->protocol_param = $request->get('protocol_param') ? $request->get('protocol_param') : '';
  519. $ssNode->obfs = $request->get('obfs') ? $request->get('obfs') : '';
  520. $ssNode->obfs_param = $request->get('obfs_param') ? $request->get('obfs_param') : '';
  521. $ssNode->traffic_rate = $request->get('traffic_rate') ? $request->get('traffic_rate') : 1;
  522. $ssNode->bandwidth = $request->get('bandwidth') ? $request->get('bandwidth') : 1000;
  523. $ssNode->traffic = $request->get('traffic') ? $request->get('traffic') : 1000;
  524. $ssNode->monitor_url = $request->get('monitor_url') ? $request->get('monitor_url') : '';
  525. $ssNode->is_subscribe = intval($request->get('is_subscribe'));
  526. $ssNode->is_nat = intval($request->get('is_nat'));
  527. $ssNode->is_transit = intval($request->get('is_transit'));
  528. $ssNode->ssh_port = $request->get('ssh_port') ? intval($request->get('ssh_port')) : 22;
  529. $ssNode->is_tcp_check = intval($request->get('is_tcp_check'));
  530. $ssNode->compatible = intval($request->get('type')) == 2 ? 0 : (intval($request->get('is_nat')) ? 0 : intval($request->get('compatible')));
  531. $ssNode->single = intval($request->get('single'));
  532. $ssNode->single_force = intval($request->get('single')) ? intval($request->get('single_force')) : 0;
  533. $ssNode->single_port = intval($request->get('single')) ? ($request->get('single_port') ? $request->get('single_port') : 443) : '';
  534. $ssNode->single_passwd = intval($request->get('single')) ? ($request->get('single_passwd') ? $request->get('single_passwd') : 'password') : '';
  535. $ssNode->single_method = intval($request->get('single')) ? $request->get('single_method') : '';
  536. $ssNode->single_protocol = intval($request->get('single')) ? $request->get('single_protocol') : '';
  537. $ssNode->single_obfs = intval($request->get('single')) ? $request->get('single_obfs') : '';
  538. $ssNode->sort = $request->get('sort') ? intval($request->get('sort')) : 0;
  539. $ssNode->status = $request->get('status') ? intval($request->get('status')) : 1;
  540. $ssNode->v2_alter_id = $request->get('v2_alter_id') ? intval($request->get('v2_alter_id')) : 16;
  541. $ssNode->v2_port = $request->get('v2_port') ? intval($request->get('v2_port')) : 10087;
  542. $ssNode->v2_method = $request->get('v2_method') ? $request->get('v2_method') : 'aes-128-gcm';
  543. $ssNode->v2_net = $request->get('v2_net') ? $request->get('v2_net') : 'tcp';
  544. $ssNode->v2_type = $request->get('v2_type') ? $request->get('v2_type') : 'none';
  545. $ssNode->v2_host = $request->get('v2_host') ? $request->get('v2_host') : '';
  546. $ssNode->v2_path = $request->get('v2_path') ? $request->get('v2_path') : '';
  547. $ssNode->v2_tls = $request->get('v2_tls') ? intval($request->get('v2_tls')) : 0;
  548. $ssNode->v2_insider_port = $request->get('v2_insider_port') ? intval($request->get('v2_insider_port')) : 10550;
  549. $ssNode->v2_outsider_port = $request->get('v2_outsider_port') ? intval($request->get('v2_outsider_port')) : 443;
  550. $ssNode->save();
  551. // 建立分组关联
  552. if ($ssNode->id && $request->get('group_id', 0)) {
  553. $ssGroupNode = new SsGroupNode();
  554. $ssGroupNode->group_id = $request->get('group_id', 0);
  555. $ssGroupNode->node_id = $ssNode->id;
  556. $ssGroupNode->save();
  557. }
  558. // 生成节点标签
  559. $labels = $request->get('labels');
  560. if ($ssNode->id && !empty($labels)) {
  561. foreach ($labels as $label) {
  562. $ssNodeLabel = new SsNodeLabel();
  563. $ssNodeLabel->node_id = $ssNode->id;
  564. $ssNodeLabel->label_id = $label;
  565. $ssNodeLabel->save();
  566. }
  567. }
  568. DB::commit();
  569. return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
  570. } catch (\Exception $e) {
  571. DB::rollBack();
  572. Log::error('添加节点信息异常:' . $e->getMessage());
  573. return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败:' . $e->getMessage()]);
  574. }
  575. } else {
  576. $view['method_list'] = Helpers::methodList();
  577. $view['protocol_list'] = Helpers::protocolList();
  578. $view['obfs_list'] = Helpers::obfsList();
  579. $view['level_list'] = Helpers::levelList();
  580. $view['group_list'] = SsGroup::query()->get();
  581. $view['country_list'] = Country::query()->orderBy('country_code', 'asc')->get();
  582. $view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
  583. return Response::view('admin.addNode', $view);
  584. }
  585. }
  586. // 编辑节点
  587. public function editNode(Request $request)
  588. {
  589. $id = $request->get('id');
  590. if ($request->isMethod('POST')) {
  591. if ($request->get('ssh_port') <= 0 || $request->get('ssh_port') >= 65535) {
  592. return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败:SSH端口不合法']);
  593. }
  594. if (false === filter_var($request->get('ip'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV4)) {
  595. return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败:IPv4地址不合法']);
  596. }
  597. if ($request->get('ipv6') && false === filter_var($request->get('ipv6'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV6)) {
  598. return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败:IPv6地址不合法']);
  599. }
  600. if ($request->get('server')) {
  601. $domain = $request->get('server');
  602. $domain = explode('.', $domain);
  603. $domainSuffix = end($domain); // 取得域名后缀
  604. if (!in_array($domainSuffix, \config('domains'))) {
  605. return Response::json(['status' => 'fail', 'data' => '', 'message' => '绑定域名不合法']);
  606. }
  607. }
  608. if ($request->get('v2_alter_id') <= 0 || $request->get('v2_alter_id') >= 65535) {
  609. return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败:AlterId不合法']);
  610. }
  611. DB::beginTransaction();
  612. try {
  613. $data = [
  614. 'type' => intval($request->get('type')),
  615. 'name' => $request->get('name'),
  616. 'group_id' => $request->get('group_id') ? $request->get('group_id') : 0,
  617. 'country_code' => $request->get('country_code'),
  618. 'server' => $request->get('server'),
  619. 'ip' => $request->get('ip'),
  620. 'ipv6' => $request->get('ipv6'),
  621. 'desc' => $request->get('desc'),
  622. 'method' => $request->get('method'),
  623. 'protocol' => $request->get('protocol'),
  624. 'protocol_param' => $request->get('protocol_param'),
  625. 'obfs' => $request->get('obfs'),
  626. 'obfs_param' => $request->get('obfs_param'),
  627. 'traffic_rate' => $request->get('traffic_rate'),
  628. 'bandwidth' => $request->get('bandwidth') ? $request->get('bandwidth') : 1000,
  629. 'traffic' => $request->get('traffic') ? $request->get('traffic') : 1000,
  630. 'monitor_url' => $request->get('monitor_url') ? $request->get('monitor_url') : '',
  631. 'is_subscribe' => intval($request->get('is_subscribe')),
  632. 'is_nat' => intval($request->get('is_nat')),
  633. 'is_transit' => intval($request->get('is_transit')),
  634. 'ssh_port' => intval($request->get('ssh_port')),
  635. 'is_tcp_check' => intval($request->get('is_tcp_check')),
  636. 'compatible' => intval($request->get('type')) == 2 ? 0 : (intval($request->get('is_nat')) ? 0 : intval($request->get('compatible'))),
  637. 'single' => intval($request->get('single')),
  638. 'single_force' => intval($request->get('single')) ? intval($request->get('single_force')) : 0,
  639. 'single_port' => intval($request->get('single')) ? ($request->get('single_port') ? $request->get('single_port') : 443) : '',
  640. 'single_passwd' => intval($request->get('single')) ? ($request->get('single_passwd') ? $request->get('single_passwd') : 'password') : '',
  641. 'single_method' => intval($request->get('single')) ? $request->get('single_method') : '',
  642. 'single_protocol' => intval($request->get('single')) ? $request->get('single_protocol') : '',
  643. 'single_obfs' => intval($request->get('single')) ? $request->get('single_obfs') : '',
  644. 'sort' => intval($request->get('sort')),
  645. 'status' => intval($request->get('status')),
  646. 'v2_alter_id' => $request->get('v2_alter_id') ? intval($request->get('v2_alter_id')) : 16,
  647. 'v2_port' => $request->get('v2_port') ? intval($request->get('v2_port')) : 10087,
  648. 'v2_method' => $request->get('v2_method') ? $request->get('v2_method') : 'aes-128-gcm',
  649. 'v2_net' => $request->get('v2_net'),
  650. 'v2_type' => $request->get('v2_type'),
  651. 'v2_host' => $request->get('v2_host'),
  652. 'v2_path' => $request->get('v2_path'),
  653. 'v2_tls' => intval($request->get('v2_tls')),
  654. 'v2_insider_port' => intval($request->get('v2_insider_port', 10550)),
  655. 'v2_outsider_port' => intval($request->get('v2_outsider_port', 443))
  656. ];
  657. SsNode::query()->where('id', $id)->update($data);
  658. // 建立分组关联
  659. if ($request->get('group_id')) {
  660. // 先删除该节点所有关联
  661. SsGroupNode::query()->where('node_id', $id)->delete();
  662. // 建立关联
  663. $ssGroupNode = new SsGroupNode();
  664. $ssGroupNode->group_id = $request->get('group_id');
  665. $ssGroupNode->node_id = $id;
  666. $ssGroupNode->save();
  667. }
  668. // 生成节点标签
  669. $this->makeNodeLabels($id, $request->get('labels'));
  670. // TODO:更新节点绑定的域名DNS(将节点IP更新到域名DNS 的A记录)
  671. DB::commit();
  672. return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
  673. } catch (\Exception $e) {
  674. DB::rollBack();
  675. Log::error('编辑节点信息异常:' . $e->getMessage());
  676. return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败:' . $e->getMessage()]);
  677. }
  678. } else {
  679. $node = SsNode::query()->with(['label'])->where('id', $id)->first();
  680. if ($node) {
  681. $labels = [];
  682. foreach ($node->label as $vo) {
  683. $labels[] = $vo->label_id;
  684. }
  685. $node->labels = $labels;
  686. }
  687. $view['node'] = $node;
  688. $view['method_list'] = Helpers::methodList();
  689. $view['protocol_list'] = Helpers::protocolList();
  690. $view['obfs_list'] = Helpers::obfsList();
  691. $view['level_list'] = Helpers::levelList();
  692. $view['group_list'] = SsGroup::query()->get();
  693. $view['country_list'] = Country::query()->orderBy('country_code', 'asc')->get();
  694. $view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
  695. return Response::view('admin.editNode', $view);
  696. }
  697. }
  698. // 删除节点
  699. public function delNode(Request $request)
  700. {
  701. $id = $request->get('id');
  702. $node = SsNode::query()->where('id', $id)->first();
  703. if (!$node) {
  704. return Response::json(['status' => 'fail', 'data' => '', 'message' => '节点不存在,请重试']);
  705. }
  706. DB::beginTransaction();
  707. try {
  708. // 删除分组关联、节点标签、节点相关日志
  709. SsNode::query()->where('id', $id)->delete();
  710. SsGroupNode::query()->where('node_id', $id)->delete();
  711. SsNodeLabel::query()->where('node_id', $id)->delete();
  712. SsNodeInfo::query()->where('node_id', $id)->delete();
  713. SsNodeOnlineLog::query()->where('node_id', $id)->delete();
  714. SsNodeTrafficDaily::query()->where('node_id', $id)->delete();
  715. SsNodeTrafficHourly::query()->where('node_id', $id)->delete();
  716. UserTrafficDaily::query()->where('node_id', $id)->delete();
  717. UserTrafficHourly::query()->where('node_id', $id)->delete();
  718. UserTrafficLog::query()->where('node_id', $id)->delete();
  719. DB::commit();
  720. return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
  721. } catch (\Exception $e) {
  722. DB::rollBack();
  723. Log::error('删除节点信息异常:' . $e->getMessage());
  724. return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败:' . $e->getMessage()]);
  725. }
  726. }
  727. // 节点流量监控
  728. public function nodeMonitor(Request $request)
  729. {
  730. $node_id = $request->get('id');
  731. $node = SsNode::query()->where('id', $node_id)->orderBy('sort', 'desc')->first();
  732. if (!$node) {
  733. Session::flash('errorMsg', '节点不存在,请重试');
  734. return Redirect::back();
  735. }
  736. // 查看流量
  737. $dailyData = [];
  738. $hourlyData = [];
  739. // 节点一个月内的流量
  740. $nodeTrafficDaily = SsNodeTrafficDaily::query()->with(['info'])->where('node_id', $node->id)->where('created_at', '>=', date('Y-m', time()))->orderBy('created_at', 'asc')->pluck('total')->toArray();
  741. $dailyTotal = date('d', time()) - 1;//今天不算,减一
  742. $dailyCount = count($nodeTrafficDaily);
  743. for ($x = 0; $x < ($dailyTotal - $dailyCount); $x++) {
  744. $dailyData[$x] = 0;
  745. }
  746. for ($x = ($dailyTotal - $dailyCount); $x < $dailyTotal; $x++) {
  747. $dailyData[$x] = round($nodeTrafficDaily[$x - ($dailyTotal - $dailyCount)] / (1024 * 1024 * 1024), 3);
  748. }
  749. // 节点一天内的流量
  750. $nodeTrafficHourly = SsNodeTrafficHourly::query()->with(['info'])->where('node_id', $node->id)->where('created_at', '>=', date('Y-m-d', time()))->orderBy('created_at', 'asc')->pluck('total')->toArray();
  751. $hourlyTotal = date('H', time());
  752. $hourlyCount = count($nodeTrafficHourly);
  753. for ($x = 0; $x < ($hourlyTotal - $hourlyCount); $x++) {
  754. $hourlyData[$x] = 0;
  755. }
  756. for ($x = ($hourlyTotal - $hourlyCount); $x < $hourlyTotal; $x++) {
  757. $hourlyData[$x] = round($nodeTrafficHourly[$x - ($hourlyTotal - $hourlyCount)] / (1024 * 1024 * 1024), 3);
  758. }
  759. $view['trafficDaily'] = [
  760. 'nodeName' => $node->name,
  761. 'dailyData' => "'" . implode("','", $dailyData) . "'"
  762. ];
  763. $view['trafficHourly'] = [
  764. 'nodeName' => $node->name,
  765. 'hourlyData' => "'" . implode("','", $hourlyData) . "'"
  766. ];
  767. // 本月天数数据
  768. $monthDays = [];
  769. for ($i = 1; $i <= date("d"); $i++) {
  770. $monthDays[] = $i;
  771. }
  772. // 本日小时数据
  773. $dayHours = [];
  774. for ($i = 1; $i <= date("H"); $i++) {
  775. $dayHours[] = $i;
  776. }
  777. $view['nodeName'] = $node->name;
  778. $view['nodeServer'] = $node->server;
  779. $view['monthDays'] = "'" . implode("','", $monthDays) . "'";
  780. $view['dayHours'] = "'" . implode("','", $dayHours) . "'";
  781. return Response::view('admin.nodeMonitor', $view);
  782. }
  783. // 文章列表
  784. public function articleList(Request $request)
  785. {
  786. $view['list'] = Article::query()->orderBy('sort', 'desc')->paginate(15)->appends($request->except('page'));
  787. return Response::view('admin.articleList', $view);
  788. }
  789. // 添加文章
  790. public function addArticle(Request $request)
  791. {
  792. if ($request->isMethod('POST')) {
  793. $article = new Article();
  794. $article->title = $request->get('title');
  795. $article->type = $request->get('type', 1);
  796. $article->author = '管理员';
  797. $article->summary = $request->get('summary');
  798. // LOGO
  799. if ($article->type == 4) {
  800. $article->logo = $request->get('logo');
  801. } else {
  802. $logo = '';
  803. if ($request->hasFile('logo')) {
  804. $file = $request->file('logo');
  805. $fileType = $file->getClientOriginalExtension();
  806. // 验证文件合法性
  807. if (!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])) {
  808. Session::flash('errorMsg', 'LOGO不合法');
  809. return Redirect::back()->withInput();
  810. }
  811. $logoName = date('YmdHis') . mt_rand(1000, 2000) . '.' . $fileType;
  812. $move = $file->move(base_path() . '/public/upload/image/', $logoName);
  813. $logo = $move ? '/upload/image/' . $logoName : '';
  814. }
  815. $article = new Article();
  816. $article->title = $request->get('title');
  817. $article->type = $request->get('type', 1);
  818. $article->author = '管理员';
  819. $article->summary = $request->get('summary');
  820. $article->logo = $logo;
  821. }
  822. $article->content = $request->get('content');
  823. $article->sort = $request->get('sort', 0);
  824. $article->save();
  825. if ($article->id) {
  826. Session::flash('successMsg', '添加成功');
  827. } else {
  828. Session::flash('errorMsg', '添加失败');
  829. }
  830. return Redirect::to('admin/articleList');
  831. } else {
  832. return Response::view('admin.addArticle');
  833. }
  834. }
  835. // 编辑文章
  836. public function editArticle(Request $request)
  837. {
  838. $id = $request->get('id');
  839. if ($request->isMethod('POST')) {
  840. $title = $request->get('title');
  841. $type = $request->get('type');
  842. $summary = $request->get('summary');
  843. $content = $request->get('content');
  844. $sort = $request->get('sort');
  845. // 商品LOGO
  846. if ($type == 4) {
  847. $logo = $request->get('logo');
  848. } else {
  849. $logo = '';
  850. if ($request->hasFile('logo')) {
  851. $file = $request->file('logo');
  852. $fileType = $file->getClientOriginalExtension();
  853. // 验证文件合法性
  854. if (!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])) {
  855. Session::flash('errorMsg', 'LOGO不合法');
  856. return Redirect::back()->withInput();
  857. }
  858. $logoName = date('YmdHis') . mt_rand(1000, 2000) . '.' . $fileType;
  859. $move = $file->move(base_path() . '/public/upload/image/', $logoName);
  860. $logo = $move ? '/upload/image/' . $logoName : '';
  861. }
  862. }
  863. $data = [
  864. 'type' => $type,
  865. 'title' => $title,
  866. 'summary' => $summary,
  867. 'content' => $content,
  868. 'sort' => $sort
  869. ];
  870. if ($logo) {
  871. $data['logo'] = $logo;
  872. }
  873. $ret = Article::query()->where('id', $id)->update($data);
  874. if ($ret) {
  875. Session::flash('successMsg', '编辑成功');
  876. } else {
  877. Session::flash('errorMsg', '编辑失败');
  878. }
  879. return Redirect::to('admin/editArticle?id=' . $id);
  880. } else {
  881. $view['article'] = Article::query()->where('id', $id)->first();
  882. return Response::view('admin.editArticle', $view);
  883. }
  884. }
  885. // 删除文章
  886. public function delArticle(Request $request)
  887. {
  888. $id = $request->get('id');
  889. $ret = Article::query()->where('id', $id)->delete();
  890. if ($ret) {
  891. return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
  892. } else {
  893. return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
  894. }
  895. }
  896. // 节点分组列表
  897. public function groupList(Request $request)
  898. {
  899. $view['groupList'] = SsGroup::query()->paginate(15)->appends($request->except('page'));
  900. $levelList = Helpers::levelList();
  901. $levelMap = [];
  902. foreach ($levelList as $vo) {
  903. $levelMap[$vo['level']] = $vo['level_name'];
  904. }
  905. $view['levelMap'] = $levelMap;
  906. return Response::view('admin.groupList', $view);
  907. }
  908. // 添加节点分组
  909. public function addGroup(Request $request)
  910. {
  911. if ($request->isMethod('POST')) {
  912. $ssGroup = new SsGroup();
  913. $ssGroup->name = $request->get('name');
  914. $ssGroup->level = $request->get('level');
  915. $ssGroup->save();
  916. return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
  917. } else {
  918. $view['levelList'] = Helpers::levelList();
  919. return Response::view('admin.addGroup', $view);
  920. }
  921. }
  922. // 编辑节点分组
  923. public function editGroup(Request $request)
  924. {
  925. $id = $request->get('id');
  926. if ($request->isMethod('POST')) {
  927. $name = $request->get('name');
  928. $level = $request->get('level');
  929. $data = [
  930. 'name' => $name,
  931. 'level' => $level
  932. ];
  933. $ret = SsGroup::query()->where('id', $id)->update($data);
  934. if ($ret) {
  935. return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
  936. } else {
  937. return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败']);
  938. }
  939. } else {
  940. $view['group'] = SsGroup::query()->where('id', $id)->first();
  941. $view['levelList'] = Helpers::levelList();
  942. return Response::view('admin.editGroup', $view);
  943. }
  944. }
  945. // 删除节点分组
  946. public function delGroup(Request $request)
  947. {
  948. $id = $request->get('id');
  949. // 检查是否该分组下是否有节点
  950. $ssGroupNodeCount = SsGroupNode::query()->where('group_id', $id)->count();
  951. if ($ssGroupNodeCount) {
  952. return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败:该分组下有节点关联,请先解除关联']);
  953. }
  954. $ret = SsGroup::query()->where('id', $id)->delete();
  955. if ($ret) {
  956. return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
  957. } else {
  958. return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
  959. }
  960. }
  961. // 流量日志
  962. public function trafficLog(Request $request)
  963. {
  964. $port = $request->get('port');
  965. $user_id = $request->get('user_id');
  966. $username = trim($request->get('username'));
  967. $nodeId = intval($request->get('nodeId'));
  968. $query = UserTrafficLog::query()->with(['user', 'node']);
  969. if ($port) {
  970. $query->whereHas('user', function ($q) use ($port) {
  971. $q->where('port', $port);
  972. });
  973. }
  974. if ($user_id) {
  975. $query->where('user_id', intval($user_id));
  976. }
  977. if ($username) {
  978. $query->whereHas('user', function ($q) use ($username) {
  979. $q->where('username', 'like', '%' . $username . '%');
  980. });
  981. }
  982. if ($nodeId) {
  983. $query->where('node_id', $nodeId);
  984. }
  985. // 已使用流量
  986. $view['totalTraffic'] = flowAutoShow($query->sum('u') + $query->sum('d'));
  987. $list = $query->orderBy('id', 'desc')->paginate(20)->appends($request->except('page'));
  988. foreach ($list as &$vo) {
  989. $vo->u = flowAutoShow($vo->u);
  990. $vo->d = flowAutoShow($vo->d);
  991. $vo->log_time = date('Y-m-d H:i:s', $vo->log_time);
  992. }
  993. $view['list'] = $list;
  994. $view['nodeList'] = SsNode::query()->where('status', 1)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get();
  995. return Response::view('admin.trafficLog', $view);
  996. }
  997. // SS(R)链接反解析
  998. public function decompile(Request $request)
  999. {
  1000. if ($request->isMethod('POST')) {
  1001. $content = $request->get('content');
  1002. if (empty($content)) {
  1003. return Response::json(['status' => 'fail', 'data' => '', 'message' => '请在左侧填入要反解析的SS(R)链接']);
  1004. }
  1005. // 反解析处理
  1006. $content = str_replace("\n", ",", $content);
  1007. $content = explode(',', $content);
  1008. $txt = '';
  1009. foreach ($content as $item) {
  1010. // 判断是SS还是SSR链接
  1011. $str = '';
  1012. if (false !== strpos($item, 'ssr://')) {
  1013. $str = mb_substr($item, 6);
  1014. } elseif (false !== strpos($item, 'ss://')) {
  1015. $str = mb_substr($item, 5);
  1016. }
  1017. $txt .= "\r\n" . base64url_decode($str);
  1018. }
  1019. // 生成转换好的JSON文件
  1020. file_put_contents(public_path('downloads/decompile.json'), $txt);
  1021. return Response::json(['status' => 'success', 'data' => $txt, 'message' => '反解析成功']);
  1022. } else {
  1023. return Response::view('admin.decompile');
  1024. }
  1025. }
  1026. // 格式转换(SS转SSR)
  1027. public function convert(Request $request)
  1028. {
  1029. if ($request->isMethod('POST')) {
  1030. $method = $request->get('method');
  1031. $transfer_enable = $request->get('transfer_enable');
  1032. $protocol = $request->get('protocol');
  1033. $protocol_param = $request->get('protocol_param');
  1034. $obfs = $request->get('obfs');
  1035. $obfs_param = $request->get('obfs_param');
  1036. $content = $request->get('content');
  1037. if (empty($content)) {
  1038. return Response::json(['status' => 'fail', 'data' => '', 'message' => '请在左侧填入要转换的内容']);
  1039. }
  1040. // 校验格式
  1041. $content = json_decode($content);
  1042. if (empty($content->port_password)) {
  1043. return Response::json(['status' => 'fail', 'data' => '', 'message' => '转换失败:配置信息里缺少【port_password】字段,或者该字段为空']);
  1044. }
  1045. // 转换成SSR格式JSON
  1046. $data = [];
  1047. foreach ($content->port_password as $port => $passwd) {
  1048. $data[] = [
  1049. 'd' => 0,
  1050. 'enable' => 1,
  1051. 'method' => $method,
  1052. 'obfs' => $obfs,
  1053. 'obfs_param' => empty($obfs_param) ? "" : $obfs_param,
  1054. 'passwd' => $passwd,
  1055. 'port' => $port,
  1056. 'protocol' => $protocol,
  1057. 'protocol_param' => empty($protocol_param) ? "" : $protocol_param,
  1058. 'transfer_enable' => toGB($transfer_enable),
  1059. 'u' => 0,
  1060. 'user' => date('Ymd') . '_IMPORT_' . $port,
  1061. ];
  1062. }
  1063. $json = json_encode($data);
  1064. // 生成转换好的JSON文件
  1065. file_put_contents(public_path('downloads/convert.json'), $json);
  1066. return Response::json(['status' => 'success', 'data' => $json, 'message' => '转换成功']);
  1067. } else {
  1068. // 加密方式、协议、混淆
  1069. $view['method_list'] = Helpers::methodList();
  1070. $view['protocol_list'] = Helpers::protocolList();
  1071. $view['obfs_list'] = Helpers::obfsList();
  1072. return Response::view('admin.convert', $view);
  1073. }
  1074. }
  1075. // 下载转换好的JSON文件
  1076. public function download(Request $request)
  1077. {
  1078. $type = $request->get('type');
  1079. if (empty($type)) {
  1080. exit('参数异常');
  1081. }
  1082. if ($type == '1') {
  1083. $filePath = public_path('downloads/convert.json');
  1084. } else {
  1085. $filePath = public_path('downloads/decompile.json');
  1086. }
  1087. if (!file_exists($filePath)) {
  1088. exit('文件不存在,请检查目录权限');
  1089. }
  1090. return Response::download($filePath);
  1091. }
  1092. // 数据导入
  1093. public function import(Request $request)
  1094. {
  1095. if ($request->isMethod('POST')) {
  1096. if (!$request->hasFile('uploadFile')) {
  1097. Session::flash('errorMsg', '请选择要上传的文件');
  1098. return Redirect::back();
  1099. }
  1100. $file = $request->file('uploadFile');
  1101. // 只能上传JSON文件
  1102. if ($file->getClientMimeType() != 'application/json' || $file->getClientOriginalExtension() != 'json') {
  1103. Session::flash('errorMsg', '只允许上传JSON文件');
  1104. return Redirect::back();
  1105. }
  1106. if (!$file->isValid()) {
  1107. Session::flash('errorMsg', '产生未知错误,请重新上传');
  1108. return Redirect::back();
  1109. }
  1110. $save_path = realpath(storage_path('uploads'));
  1111. $new_name = md5($file->getClientOriginalExtension()) . '.json';
  1112. $file->move($save_path, $new_name);
  1113. // 读取文件内容
  1114. $data = file_get_contents($save_path . '/' . $new_name);
  1115. $data = json_decode($data);
  1116. if (!$data) {
  1117. Session::flash('errorMsg', '内容格式解析异常,请上传符合SSR(R)配置规范的JSON文件');
  1118. return Redirect::back();
  1119. }
  1120. DB::beginTransaction();
  1121. try {
  1122. foreach ($data as $user) {
  1123. $obj = new User();
  1124. $obj->username = $user->user;
  1125. $obj->password = Hash::make('123456');
  1126. $obj->port = $user->port;
  1127. $obj->passwd = $user->passwd;
  1128. $obj->vmess_id = $user->vmess_id;
  1129. $obj->transfer_enable = $user->transfer_enable;
  1130. $obj->u = 0;
  1131. $obj->d = 0;
  1132. $obj->t = 0;
  1133. $obj->enable = 1;
  1134. $obj->method = $user->method;
  1135. $obj->protocol = $user->protocol;
  1136. $obj->protocol_param = $user->protocol_param;
  1137. $obj->obfs = $user->obfs;
  1138. $obj->obfs_param = $user->obfs_param;
  1139. $obj->speed_limit_per_con = 204800;
  1140. $obj->speed_limit_per_user = 204800;
  1141. $obj->wechat = '';
  1142. $obj->qq = '';
  1143. $obj->usage = 1;
  1144. $obj->pay_way = 3;
  1145. $obj->balance = 0;
  1146. $obj->enable_time = date('Y-m-d');
  1147. $obj->expire_time = '2099-01-01';
  1148. $obj->remark = '';
  1149. $obj->is_admin = 0;
  1150. $obj->reg_ip = getClientIp();
  1151. $obj->created_at = date('Y-m-d H:i:s');
  1152. $obj->updated_at = date('Y-m-d H:i:s');
  1153. $obj->save();
  1154. }
  1155. DB::commit();
  1156. } catch (\Exception $e) {
  1157. DB::rollBack();
  1158. Session::flash('errorMsg', '出错了,可能是导入的配置中有端口已经存在了');
  1159. return Redirect::back();
  1160. }
  1161. Session::flash('successMsg', '导入成功');
  1162. return Redirect::back();
  1163. } else {
  1164. return Response::view('admin.import');
  1165. }
  1166. }
  1167. // 导出配置信息
  1168. public function export(Request $request)
  1169. {
  1170. $id = $request->get('id');
  1171. if (empty($id)) {
  1172. return Redirect::to('admin/userList');
  1173. }
  1174. $user = User::query()->where('id', $id)->first();
  1175. if (empty($user)) {
  1176. return Redirect::to('admin/userList');
  1177. }
  1178. $nodeList = SsNode::query()->where('status', 1)->orderBy('sort', 'desc')->orderBy('id', 'asc')->paginate(15)->appends($request->except('page'));
  1179. foreach ($nodeList as &$node) {
  1180. // 获取分组名称
  1181. $group = SsGroup::query()->where('id', $node->group_id)->first();
  1182. if ($node->type == 1) {
  1183. // 生成ssr scheme
  1184. $obfs_param = $user->obfs_param ? $user->obfs_param : $node->obfs_param;
  1185. $protocol_param = $node->single ? $user->port . ':' . $user->passwd : $user->protocol_param;
  1186. $ssr_str = ($node->server ? $node->server : $node->ip) . ':' . ($node->single ? $node->single_port : $user->port);
  1187. $ssr_str .= ':' . ($node->single ? $node->single_protocol : $user->protocol) . ':' . ($node->single ? $node->single_method : $user->method);
  1188. $ssr_str .= ':' . ($node->single ? $node->single_obfs : $user->obfs) . ':' . ($node->single ? base64url_encode($node->single_passwd) : base64url_encode($user->passwd));
  1189. $ssr_str .= '/?obfsparam=' . base64url_encode($obfs_param);
  1190. $ssr_str .= '&protoparam=' . ($node->single ? base64url_encode($user->port . ':' . $user->passwd) : base64url_encode($protocol_param));
  1191. $ssr_str .= '&remarks=' . base64url_encode($node->name);
  1192. $ssr_str .= '&group=' . base64url_encode(empty($group) ? '' : $group->name);
  1193. $ssr_str .= '&udpport=0';
  1194. $ssr_str .= '&uot=0';
  1195. $ssr_str = base64url_encode($ssr_str);
  1196. $ssr_scheme = 'ssr://' . $ssr_str;
  1197. // 生成ss scheme
  1198. $ss_str = $user->method . ':' . $user->passwd . '@';
  1199. $ss_str .= ($node->server ? $node->server : $node->ip) . ':' . $user->port;
  1200. $ss_str = base64url_encode($ss_str) . '#' . 'VPN';
  1201. $ss_scheme = 'ss://' . $ss_str;
  1202. // 生成配置信息
  1203. $txt = "服务器:" . ($node->server ? $node->server : $node->ip) . "\r\n";
  1204. if ($node->ipv6) {
  1205. $txt .= "IPv6:" . $node->ipv6 . "\r\n";
  1206. }
  1207. $txt .= "远程端口:" . ($node->single ? $node->single_port : $user->port) . "\r\n";
  1208. $txt .= "密码:" . ($node->single ? $node->single_passwd : $user->passwd) . "\r\n";
  1209. $txt .= "加密方法:" . ($node->single ? $node->single_method : $user->method) . "\r\n";
  1210. $txt .= "路由:绕过局域网及中国大陆地址\r\n\r\n";
  1211. $txt .= "协议:" . ($node->single ? $node->single_protocol : $user->protocol) . "\r\n";
  1212. $txt .= "协议参数:" . ($node->single ? $user->port . ':' . $user->passwd : $user->protocol_param) . "\r\n";
  1213. $txt .= "混淆方式:" . ($node->single ? $node->single_obfs : $user->obfs) . "\r\n";
  1214. $txt .= "混淆参数:" . ($user->obfs_param ? $user->obfs_param : $node->obfs_param) . "\r\n";
  1215. $txt .= "本地端口:1080\r\n";
  1216. $node->txt = $txt;
  1217. $node->ssr_scheme = $ssr_scheme;
  1218. $node->ss_scheme = $node->compatible ? $ss_scheme : ''; // 节点兼容原版才显示
  1219. } else {
  1220. // 生成v2ray scheme
  1221. $v2_json = [
  1222. "v" => "2",
  1223. "ps" => $node->name,
  1224. "add" => $node->server ? $node->server : $node->ip,
  1225. "port" => $node->v2_port,
  1226. "id" => $user->vmess_id,
  1227. "aid" => $node->v2_alter_id,
  1228. "net" => $node->v2_net,
  1229. "type" => $node->v2_type,
  1230. "host" => $node->v2_host,
  1231. "path" => $node->v2_path,
  1232. "tls" => $node->v2_tls ? "tls" : ""
  1233. ];
  1234. $v2_scheme = 'vmess://' . base64url_encode(json_encode($v2_json, JSON_PRETTY_PRINT));
  1235. // 生成文本配置信息
  1236. $txt = "服务器:" . ($node->server ? $node->server : $node->ip) . "\r\n";
  1237. if ($node->ipv6) {
  1238. $txt .= "IPv6:" . $node->ipv6 . "\r\n";
  1239. }
  1240. $txt .= "端口:" . $node->v2_port . "\r\n";
  1241. $txt .= "加密方式:" . $node->v2_method . "\r\n";
  1242. $txt .= "用户ID:" . $user->vmess_id . "\r\n";
  1243. $txt .= "额外ID:" . $node->v2_alter_id . "\r\n";
  1244. $txt .= "传输协议:" . $node->v2_net . "\r\n";
  1245. $txt .= "伪装类型:" . $node->v2_type . "\r\n";
  1246. $txt .= $node->v2_host ? "伪装域名:" . $node->v2_host . "\r\n" : "";
  1247. $txt .= $node->v2_path ? "路径:" . $node->v2_path . "\r\n" : "";
  1248. $txt .= $node->v2_tls == 1 ? "TLS:tls\r\n" : "";
  1249. $node->txt = $txt;
  1250. $node->v2_scheme = $v2_scheme;
  1251. }
  1252. }
  1253. $view['nodeList'] = $nodeList;
  1254. $view['user'] = $user;
  1255. return Response::view('admin.export', $view);
  1256. }
  1257. // 导出原版SS用户配置信息
  1258. public function exportSSJson(Request $request)
  1259. {
  1260. $userList = User::query()->where('port', '>', 0)->get();
  1261. $defaultMethod = Helpers::getDefaultMethod();
  1262. $json = '';
  1263. if (!$userList->isEmpty()) {
  1264. $tmp = [];
  1265. foreach ($userList as $key => $user) {
  1266. $tmp[] = '"' . $user->port . '":"' . $user->passwd . '"';
  1267. }
  1268. $userPassword = implode(",\n\t\t", $tmp);
  1269. $json = <<<EOF
  1270. {
  1271. "server":"0.0.0.0",
  1272. "local_address":"127.0.0.1",
  1273. "local_port":1080,
  1274. "port_password":{
  1275. {$userPassword}
  1276. },
  1277. "timeout":300,
  1278. "method":"{$defaultMethod}",
  1279. "fast_open":false
  1280. }
  1281. EOF;
  1282. }
  1283. // 生成JSON文件
  1284. $fileName = makeRandStr('16') . '_shadowsocks.json';
  1285. $filePath = public_path('downloads/' . $fileName);
  1286. file_put_contents($filePath, $json);
  1287. if (!file_exists($filePath)) {
  1288. exit('文件生成失败,请检查目录权限');
  1289. }
  1290. return Response::download($filePath);
  1291. }
  1292. // 修改个人资料
  1293. public function profile(Request $request)
  1294. {
  1295. if ($request->isMethod('POST')) {
  1296. $old_password = trim($request->get('old_password'));
  1297. $new_password = trim($request->get('new_password'));
  1298. if (!Hash::check($old_password, Auth::user()->password)) {
  1299. return Redirect::back()->withErrors('旧密码错误,请重新输入');
  1300. } elseif (Hash::check($new_password, Auth::user()->password)) {
  1301. return Redirect::back()->withErrors('新密码不可与旧密码一样,请重新输入');
  1302. }
  1303. $ret = User::uid()->update(['password' => Hash::make($new_password)]);
  1304. if (!$ret) {
  1305. return Redirect::back()->withErrors('修改失败');
  1306. } else {
  1307. return Redirect::back()->with('successMsg', '修改成功');
  1308. }
  1309. } else {
  1310. return Response::view('admin.profile');
  1311. }
  1312. }
  1313. // 用户流量监控
  1314. public function userMonitor(Request $request)
  1315. {
  1316. $id = $request->get('id');
  1317. if (empty($id)) {
  1318. return Redirect::to('admin/userList');
  1319. }
  1320. $user = User::query()->where('id', $id)->first();
  1321. if (empty($user)) {
  1322. return Redirect::to('admin/userList');
  1323. }
  1324. // 30天内的流量
  1325. $dailyData = [];
  1326. $hourlyData = [];
  1327. // 节点一个月内的流量
  1328. $userTrafficDaily = UserTrafficDaily::query()->where('user_id', $user->id)->where('node_id', 0)->where('created_at', '>=', date('Y-m', time()))->orderBy('created_at', 'asc')->pluck('total')->toArray();
  1329. $dailyTotal = date('d') - 1; // 今天不算,减一
  1330. $dailyCount = count($userTrafficDaily);
  1331. for ($x = 0; $x < $dailyTotal - $dailyCount; $x++) {
  1332. $dailyData[$x] = 0;
  1333. }
  1334. for ($x = $dailyTotal - $dailyCount; $x < $dailyTotal; $x++) {
  1335. $dailyData[$x] = round($userTrafficDaily[$x - ($dailyTotal - $dailyCount)] / (1024 * 1024 * 1024), 3);
  1336. }
  1337. // 节点一天内的流量
  1338. $userTrafficHourly = UserTrafficHourly::query()->where('user_id', $user->id)->where('node_id', 0)->where('created_at', '>=', date('Y-m-d', time()))->orderBy('created_at', 'asc')->pluck('total')->toArray();
  1339. $hourlyTotal = date('H');
  1340. $hourlyCount = count($userTrafficHourly);
  1341. for ($x = 0; $x < $hourlyTotal - $hourlyCount; $x++) {
  1342. $hourlyData[$x] = 0;
  1343. }
  1344. for ($x = ($hourlyTotal - $hourlyCount); $x < $hourlyTotal; $x++) {
  1345. $hourlyData[$x] = round($userTrafficHourly[$x - ($hourlyTotal - $hourlyCount)] / (1024 * 1024 * 1024), 3);
  1346. }
  1347. // 本月天数数据
  1348. $monthDays = [];
  1349. for ($i = 1; $i <= date("d"); $i++) {
  1350. $monthDays[] = $i;
  1351. }
  1352. // 本日小时数据
  1353. $dayHours = [];
  1354. for ($i = 1; $i <= date("H"); $i++) {
  1355. $dayHours[] = $i;
  1356. }
  1357. $view['trafficDaily'] = "'" . implode("','", $dailyData) . "'";
  1358. $view['trafficHourly'] = "'" . implode("','", $hourlyData) . "'";
  1359. $view['monthDays'] = "'" . implode("','", $monthDays) . "'";
  1360. $view['dayHours'] = "'" . implode("','", $dayHours) . "'";
  1361. $view['username'] = $user->username;
  1362. return Response::view('admin.userMonitor', $view);
  1363. }
  1364. // 生成端口
  1365. public function makePort(Request $request)
  1366. {
  1367. $new_port = self::$systemConfig['is_rand_port'] ? Helpers::getRandPort() : Helpers::getOnlyPort();
  1368. echo $new_port;
  1369. exit;
  1370. }
  1371. // 加密方式、混淆、协议、等级、国家地区
  1372. public function config(Request $request)
  1373. {
  1374. if ($request->isMethod('POST')) {
  1375. $name = $request->get('name');
  1376. $type = $request->get('type', 1); // 类型:1-加密方式(method)、2-协议(protocol)、3-混淆(obfs)
  1377. $is_default = $request->get('is_default', 0);
  1378. $sort = $request->get('sort', 0);
  1379. if (empty($name)) {
  1380. return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置名称不能为空']);
  1381. }
  1382. // 校验是否已存在
  1383. $config = SsConfig::type($type)->where('name', $name)->first();
  1384. if ($config) {
  1385. return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置已经存在,请勿重复添加']);
  1386. }
  1387. $ssConfig = new SsConfig();
  1388. $ssConfig->name = $name;
  1389. $ssConfig->type = $type;
  1390. $ssConfig->is_default = $is_default;
  1391. $ssConfig->sort = $sort;
  1392. $ssConfig->save();
  1393. return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
  1394. } else {
  1395. $view['method_list'] = SsConfig::type(1)->get();
  1396. $view['protocol_list'] = SsConfig::type(2)->get();
  1397. $view['obfs_list'] = SsConfig::type(3)->get();
  1398. $view['level_list'] = Helpers::levelList();
  1399. $view['country_list'] = Country::query()->get();
  1400. return Response::view('admin.config', $view);
  1401. }
  1402. }
  1403. // 删除配置
  1404. public function delConfig(Request $request)
  1405. {
  1406. $id = $request->get('id');
  1407. $ret = SsConfig::query()->where('id', $id)->delete();
  1408. if ($ret) {
  1409. return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
  1410. } else {
  1411. return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
  1412. }
  1413. }
  1414. // 设置默认配置
  1415. public function setDefaultConfig(Request $request)
  1416. {
  1417. $id = $request->get('id');
  1418. if (empty($id)) {
  1419. return Response::json(['status' => 'fail', 'data' => '', 'message' => '非法请求']);
  1420. }
  1421. $config = SsConfig::query()->where('id', $id)->first();
  1422. if (!$config) {
  1423. return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置不存在']);
  1424. }
  1425. // 去除该配置所属类型的默认值
  1426. SsConfig::default()->type($config->type)->update(['is_default' => 0]);
  1427. // 将该ID对应记录值置为默认值
  1428. SsConfig::query()->where('id', $id)->update(['is_default' => 1]);
  1429. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  1430. }
  1431. // 设置系统扩展信息,例如客服、统计代码
  1432. public function setExtend(Request $request)
  1433. {
  1434. $websiteAnalytics = $request->get('website_analytics');
  1435. $websiteCustomerService = $request->get('website_customer_service');
  1436. DB::beginTransaction();
  1437. try {
  1438. // 首页LOGO
  1439. if ($request->hasFile('website_home_logo')) {
  1440. $file = $request->file('website_home_logo');
  1441. $fileType = $file->getClientOriginalExtension();
  1442. // 验证文件合法性
  1443. if (!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])) {
  1444. Session::flash('errorMsg', 'LOGO不合法');
  1445. return Redirect::back();
  1446. }
  1447. $logoName = date('YmdHis') . mt_rand(1000, 2000) . '.' . $fileType;
  1448. $move = $file->move(base_path() . '/public/upload/image/', $logoName);
  1449. $websiteHomeLogo = $move ? '/upload/image/' . $logoName : '';
  1450. Config::query()->where('name', 'website_home_logo')->update(['value' => $websiteHomeLogo]);
  1451. }
  1452. // 站内LOGO
  1453. if ($request->hasFile('website_logo')) {
  1454. $file = $request->file('website_logo');
  1455. $fileType = $file->getClientOriginalExtension();
  1456. // 验证文件合法性
  1457. if (!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])) {
  1458. Session::flash('errorMsg', 'LOGO不合法');
  1459. return Redirect::back();
  1460. }
  1461. $logoName = date('YmdHis') . mt_rand(1000, 2000) . '.' . $fileType;
  1462. $move = $file->move(base_path() . '/public/upload/image/', $logoName);
  1463. $websiteLogo = $move ? '/upload/image/' . $logoName : '';
  1464. Config::query()->where('name', 'website_logo')->update(['value' => $websiteLogo]);
  1465. }
  1466. Config::query()->where('name', 'website_analytics')->update(['value' => $websiteAnalytics]);
  1467. Config::query()->where('name', 'website_customer_service')->update(['value' => $websiteCustomerService]);
  1468. Session::flash('successMsg', '更新成功');
  1469. DB::commit();
  1470. return Redirect::back();
  1471. } catch (\Exception $e) {
  1472. DB::rollBack();
  1473. Session::flash('errorMsg', '更新失败');
  1474. return Redirect::back();
  1475. }
  1476. }
  1477. // 日志分析
  1478. public function analysis(Request $request)
  1479. {
  1480. $file = storage_path('app/ssserver.log');
  1481. if (!file_exists($file)) {
  1482. Session::flash('analysisErrorMsg', $file . ' 不存在,请先创建文件');
  1483. return Response::view('admin.analysis');
  1484. }
  1485. $logs = $this->tail($file, 10000);
  1486. if (false === $logs) {
  1487. $view['urlList'] = [];
  1488. } else {
  1489. $url = [];
  1490. foreach ($logs as $log) {
  1491. if (strpos($log, 'TCP connecting')) {
  1492. continue;
  1493. }
  1494. preg_match('/TCP request (\w+\.){2}\w+/', $log, $tcp_matches);
  1495. if (!empty($tcp_matches)) {
  1496. $url[] = str_replace('TCP request ', '[TCP] ', $tcp_matches[0]);
  1497. } else {
  1498. 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);
  1499. if (!empty($udp_matches)) {
  1500. $url[] = str_replace('UDP data to ', '[UDP] ', $udp_matches[0]);
  1501. }
  1502. }
  1503. }
  1504. $view['urlList'] = array_unique($url);
  1505. }
  1506. return Response::view('admin.analysis', $view);
  1507. }
  1508. // 添加等级
  1509. public function addLevel(Request $request)
  1510. {
  1511. $level = intval($request->get('level'));
  1512. $level_name = trim($request->get('level_name'));
  1513. if (empty($level)) {
  1514. return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不能为空']);
  1515. }
  1516. if (empty($level_name)) {
  1517. return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级名称不能为空']);
  1518. }
  1519. $exists = Level::query()->where('level', $level)->first();
  1520. if ($exists) {
  1521. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级已存在,请勿重复添加']);
  1522. }
  1523. $obj = new Level();
  1524. $obj->level = $level;
  1525. $obj->level_name = $level_name;
  1526. $obj->save();
  1527. if ($obj->id) {
  1528. return Response::json(['status' => 'success', 'data' => '', 'message' => '提交成功']);
  1529. } else {
  1530. return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
  1531. }
  1532. }
  1533. // 编辑等级
  1534. public function updateLevel(Request $request)
  1535. {
  1536. $id = $request->get('id');
  1537. $level = $request->get('level');
  1538. $level_name = $request->get('level_name');
  1539. if (!$id) {
  1540. return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
  1541. }
  1542. if (!$level) {
  1543. return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不能为空']);
  1544. }
  1545. if (!$level_name) {
  1546. return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级名称不能为空']);
  1547. }
  1548. $le = Level::query()->where('id', $id)->first();
  1549. if (!$le) {
  1550. return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不存在']);
  1551. }
  1552. // 校验该等级下是否存在关联分组
  1553. $ssGroupCount = SsGroup::query()->where('level', $le->level)->count();
  1554. if ($ssGroupCount) {
  1555. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联分组,请先取消关联']);
  1556. }
  1557. // 校验该等级下是否存在关联账号
  1558. $userCount = User::query()->where('level', $le->level)->count();
  1559. if ($userCount) {
  1560. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联账号,请先取消关联']);
  1561. }
  1562. Level::query()->where('id', $id)->update(['level' => $level, 'level_name' => $level_name]);
  1563. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  1564. }
  1565. // 删除等级
  1566. public function delLevel(Request $request)
  1567. {
  1568. $id = $request->get('id');
  1569. if (empty($id)) {
  1570. return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
  1571. }
  1572. $level = Level::query()->where('id', $id)->first();
  1573. if (empty($level)) {
  1574. return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不存在']);
  1575. }
  1576. // 校验该等级下是否存在关联分组
  1577. $existGroups = SsGroup::query()->where('level', $level->level)->get();
  1578. if (!$existGroups->isEmpty()) {
  1579. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联分组,请先取消关联']);
  1580. }
  1581. // 校验该等级下是否存在关联账号
  1582. $existUsers = User::query()->where('level', $level->level)->get();
  1583. if (!$existUsers->isEmpty()) {
  1584. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联账号,请先取消关联']);
  1585. }
  1586. $ret = Level::query()->where('id', $id)->delete();
  1587. if ($ret) {
  1588. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  1589. } else {
  1590. return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
  1591. }
  1592. }
  1593. // 添加国家/地区
  1594. public function addCountry(Request $request)
  1595. {
  1596. $country_name = $request->get('country_name');
  1597. $country_code = $request->get('country_code');
  1598. if (empty($country_name)) {
  1599. return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区名称不能为空']);
  1600. }
  1601. if (empty($country_code)) {
  1602. return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区代码不能为空']);
  1603. }
  1604. $exists = Country::query()->where('country_name', $country_name)->first();
  1605. if ($exists) {
  1606. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该国家/地区名称已存在,请勿重复添加']);
  1607. }
  1608. $obj = new Country();
  1609. $obj->country_name = $country_name;
  1610. $obj->country_code = $country_code;
  1611. $obj->save();
  1612. if ($obj->id) {
  1613. return Response::json(['status' => 'success', 'data' => '', 'message' => '提交成功']);
  1614. } else {
  1615. return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
  1616. }
  1617. }
  1618. // 编辑国家/地区
  1619. public function updateCountry(Request $request)
  1620. {
  1621. $id = $request->get('id');
  1622. $country_name = $request->get('country_name');
  1623. $country_code = $request->get('country_code');
  1624. if (empty($id)) {
  1625. return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
  1626. }
  1627. if (empty($country_name)) {
  1628. return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区名称不能为空']);
  1629. }
  1630. if (empty($country_code)) {
  1631. return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区代码不能为空']);
  1632. }
  1633. $country = Country::query()->where('id', $id)->first();
  1634. if (empty($country)) {
  1635. return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区不存在']);
  1636. }
  1637. // 校验该国家/地区下是否存在关联节点
  1638. $existNode = SsNode::query()->where('country_code', $country->country_code)->get();
  1639. if (!$existNode->isEmpty()) {
  1640. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该国家/地区下存在关联节点,请先取消关联']);
  1641. }
  1642. $ret = Country::query()->where('id', $id)->update(['country_name' => $country_name, 'country_code' => $country_code]);
  1643. if ($ret) {
  1644. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  1645. } else {
  1646. return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
  1647. }
  1648. }
  1649. // 删除国家/地区
  1650. public function delCountry(Request $request)
  1651. {
  1652. $id = $request->get('id');
  1653. if (empty($id)) {
  1654. return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
  1655. }
  1656. $country = Country::query()->where('id', $id)->first();
  1657. if (empty($country)) {
  1658. return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区不存在']);
  1659. }
  1660. // 校验该国家/地区下是否存在关联节点
  1661. $existNode = SsNode::query()->where('country_code', $country->country_code)->get();
  1662. if (!$existNode->isEmpty()) {
  1663. return Response::json(['status' => 'fail', 'data' => '', 'message' => '该国家/地区下存在关联节点,请先取消关联']);
  1664. }
  1665. $ret = Country::query()->where('id', $id)->delete();
  1666. if ($ret) {
  1667. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  1668. } else {
  1669. return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
  1670. }
  1671. }
  1672. // 系统设置
  1673. public function system(Request $request)
  1674. {
  1675. $view = Helpers::systemConfig();
  1676. $view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
  1677. return Response::view('admin.system', $view);
  1678. }
  1679. // 设置某个配置项
  1680. public function setConfig(Request $request)
  1681. {
  1682. $name = trim($request->get('name'));
  1683. $value = trim($request->get('value'));
  1684. if (!$name) {
  1685. return Response::json(['status' => 'fail', 'data' => '', 'message' => '设置失败:请求参数异常']);
  1686. }
  1687. // 屏蔽异常配置
  1688. if (!array_key_exists($name, self::$systemConfig)) {
  1689. return Response::json(['status' => 'fail', 'data' => '', 'message' => '设置失败:配置不存在']);
  1690. }
  1691. // 如果开启用户邮件重置密码,则先设置网站名称和网址
  1692. if (in_array($name, ['is_reset_password', 'is_active_register']) && $value == '1') {
  1693. $config = Config::query()->where('name', 'website_name')->first();
  1694. if ($config->value == '') {
  1695. return Response::json(['status' => 'fail', 'data' => '', 'message' => '设置失败:启用该配置需要先设置【网站名称】']);
  1696. }
  1697. $config = Config::query()->where('name', 'website_url')->first();
  1698. if ($config->value == '') {
  1699. return Response::json(['status' => 'fail', 'data' => '', 'message' => '设置失败:启用该配置需要先设置【网站地址】']);
  1700. }
  1701. }
  1702. // 演示环境禁止修改特定配置项
  1703. if (env('APP_DEMO')) {
  1704. $denyConfig = [
  1705. 'website_url',
  1706. 'min_rand_traffic',
  1707. 'max_rand_traffic',
  1708. 'push_bear_send_key',
  1709. 'push_bear_qrcode',
  1710. 'youzan_client_id',
  1711. 'youzan_client_secret',
  1712. 'kdt_id',
  1713. 'is_forbid_china',
  1714. 'alipay_partner',
  1715. 'alipay_key',
  1716. 'alipay_transport',
  1717. 'alipay_sign_type',
  1718. 'alipay_private_key',
  1719. 'alipay_public_key',
  1720. 'website_security_code'
  1721. ];
  1722. if (in_array($name, $denyConfig)) {
  1723. return Response::json(['status' => 'fail', 'data' => '', 'message' => '演示环境禁止修改该配置']);
  1724. }
  1725. }
  1726. // 如果更改了有赞云任何一个配置,则删除有赞云的授权缓存,防止出现client_id错误
  1727. if (in_array($name, ['youzan_client_id', 'youzan_client_secret', 'kdt_id'])) {
  1728. \Cache::forget('YZY_TOKEN');
  1729. }
  1730. // 如果是返利比例,则需要除100
  1731. if (in_array($name, ['referral_percent'])) {
  1732. $value = intval($value) / 100;
  1733. }
  1734. // 用有赞云支付则不可用支付宝国际和支付宝当面付
  1735. if (in_array($name, ['is_youzan'])) {
  1736. $is_alipay = Config::query()->where('name', 'is_alipay')->first();
  1737. if ($is_alipay->value) {
  1738. return Response::json(['status' => 'fail', 'data' => '', 'message' => '已经在使用【支付宝国际支付】']);
  1739. }
  1740. $is_f2fpay = Config::query()->where('name', 'is_f2fpay')->first();
  1741. if ($is_f2fpay->value) {
  1742. return Response::json(['status' => 'fail', 'data' => '', 'message' => '已经在使用【支付宝当面付】']);
  1743. }
  1744. }
  1745. // 用支付国际则不可用有赞云支付和支付宝当面付
  1746. if (in_array($name, ['is_alipay'])) {
  1747. $is_youzan = Config::query()->where('name', 'is_youzan')->first();
  1748. if ($is_youzan->value) {
  1749. return Response::json(['status' => 'fail', 'data' => '', 'message' => '已经在使用【有赞云支付】']);
  1750. }
  1751. $is_f2fpay = Config::query()->where('name', 'is_f2fpay')->first();
  1752. if ($is_f2fpay->value) {
  1753. return Response::json(['status' => 'fail', 'data' => '', 'message' => '已经在使用【支付宝当面付】']);
  1754. }
  1755. }
  1756. // 用支付宝当面则不可用有赞云支付和支付宝国际
  1757. if (in_array($name, ['is_f2fpay'])) {
  1758. $is_youzan = Config::query()->where('name', 'is_youzan')->first();
  1759. if ($is_youzan->value) {
  1760. return Response::json(['status' => 'fail', 'data' => '', 'message' => '已经在使用【有赞云支付】']);
  1761. }
  1762. $is_alipay = Config::query()->where('name', 'is_alipay')->first();
  1763. if ($is_alipay->value) {
  1764. return Response::json(['status' => 'fail', 'data' => '', 'message' => '已经在使用【支付宝国际支付】']);
  1765. }
  1766. }
  1767. // 更新配置
  1768. Config::query()->where('name', $name)->update(['value' => $value]);
  1769. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  1770. }
  1771. // 邀请码列表
  1772. public function inviteList(Request $request)
  1773. {
  1774. $view['inviteList'] = Invite::query()->with(['generator', 'user'])->orderBy('status', 'asc')->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));
  1775. return Response::view('admin.inviteList', $view);
  1776. }
  1777. // 生成邀请码
  1778. public function makeInvite(Request $request)
  1779. {
  1780. for ($i = 0; $i < 10; $i++) {
  1781. $obj = new Invite();
  1782. $obj->uid = 0;
  1783. $obj->fuid = 0;
  1784. $obj->code = strtoupper(substr(md5(microtime() . makeRandStr()), 8, 12));
  1785. $obj->status = 0;
  1786. $obj->dateline = date('Y-m-d H:i:s', strtotime("+" . self::$systemConfig['admin_invite_days'] . " days"));
  1787. $obj->save();
  1788. }
  1789. return Response::json(['status' => 'success', 'data' => '', 'message' => '生成成功']);
  1790. }
  1791. // 导出邀请码
  1792. public function exportInvite(Request $request)
  1793. {
  1794. $inviteList = Invite::query()->where('status', 0)->orderBy('id', 'asc')->get();
  1795. $filename = '邀请码' . date('Ymd') . '.xlsx';
  1796. $spreadsheet = new Spreadsheet();
  1797. $spreadsheet->getProperties()->setCreator('SSRPanel')->setLastModifiedBy('SSRPanel')->setTitle('邀请码')->setSubject('邀请码')->setDescription('')->setKeywords('')->setCategory('');
  1798. $spreadsheet->setActiveSheetIndex(0);
  1799. $sheet = $spreadsheet->getActiveSheet();
  1800. $sheet->setTitle('邀请码');
  1801. $sheet->fromArray(['邀请码', '有效期'], null);
  1802. foreach ($inviteList as $k => $vo) {
  1803. $sheet->fromArray([$vo->code, $vo->dateline], null, 'A' . ($k + 2));
  1804. }
  1805. header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'); // 输出07Excel文件
  1806. //header('Content-Type:application/vnd.ms-excel'); // 输出Excel03版本文件
  1807. header('Content-Disposition: attachment;filename="' . $filename . '"');
  1808. header('Cache-Control: max-age=0');
  1809. $writer = new Xlsx($spreadsheet);
  1810. $writer->save('php://output');
  1811. }
  1812. // 提现申请列表
  1813. public function applyList(Request $request)
  1814. {
  1815. $username = $request->get('username');
  1816. $status = $request->get('status');
  1817. $query = ReferralApply::with('user');
  1818. if ($username) {
  1819. $query->whereHas('user', function ($q) use ($username) {
  1820. $q->where('username', 'like', '%' . $username . '%');
  1821. });
  1822. }
  1823. if ($status) {
  1824. $query->where('status', $status);
  1825. }
  1826. $view['applyList'] = $query->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));
  1827. return Response::view('admin.applyList', $view);
  1828. }
  1829. // 提现申请详情
  1830. public function applyDetail(Request $request)
  1831. {
  1832. $id = $request->get('id');
  1833. $list = new \stdClass();
  1834. $apply = ReferralApply::query()->with(['user'])->where('id', $id)->first();
  1835. if ($apply && $apply->link_logs) {
  1836. $link_logs = explode(',', $apply->link_logs);
  1837. $list = ReferralLog::query()->with(['user', 'order.goods'])->whereIn('id', $link_logs)->paginate(15)->appends($request->except('page'));
  1838. }
  1839. $view['info'] = $apply;
  1840. $view['list'] = $list;
  1841. return Response::view('admin.applyDetail', $view);
  1842. }
  1843. // 订单列表
  1844. public function orderList(Request $request)
  1845. {
  1846. $username = trim($request->get('username'));
  1847. $is_coupon = $request->get('is_coupon');
  1848. $is_expire = $request->get('is_expire');
  1849. $pay_way = $request->get('pay_way');
  1850. $status = intval($request->get('status'));
  1851. $range_time = $request->get('range_time');
  1852. $sort = intval($request->get('sort')); // 0-按创建时间降序、1-按创建时间升序
  1853. $query = Order::query()->with(['user', 'goods', 'coupon']);
  1854. if ($username) {
  1855. $query->whereHas('user', function ($q) use ($username) {
  1856. $q->where('username', 'like', '%' . $username . '%');
  1857. });
  1858. }
  1859. if ($is_coupon != '') {
  1860. if ($is_coupon) {
  1861. $query->where('coupon_id', '<>', 0);
  1862. } else {
  1863. $query->where('coupon_id', 0);
  1864. }
  1865. }
  1866. if ($is_expire != '') {
  1867. $query->where('is_expire', $is_expire);
  1868. }
  1869. if ($pay_way != '') {
  1870. $query->where('pay_way', $pay_way);
  1871. }
  1872. if ($status != '') {
  1873. $query->where('status', $status);
  1874. }
  1875. if ($range_time) {
  1876. $range_time = explode('至', $range_time);
  1877. $query->where('created_at', '>=', trim($range_time['0']))->where('created_at', '<=', trim($range_time[1]));
  1878. }
  1879. if ($sort) {
  1880. $query->orderBy('oid', 'asc');
  1881. } else {
  1882. $query->orderBy('oid', 'desc');
  1883. }
  1884. $view['orderList'] = $query->paginate(15)->appends($request->except('page'));
  1885. return Response::view('admin.orderList', $view);
  1886. }
  1887. // 设置提现申请状态
  1888. public function setApplyStatus(Request $request)
  1889. {
  1890. $id = $request->get('id');
  1891. $status = $request->get('status');
  1892. $ret = ReferralApply::query()->where('id', $id)->update(['status' => $status]);
  1893. if ($ret) {
  1894. // 审核申请的时候将关联的
  1895. $referralApply = ReferralApply::query()->where('id', $id)->first();
  1896. $log_ids = explode(',', $referralApply->link_logs);
  1897. if ($referralApply && $status == 1) {
  1898. ReferralLog::query()->whereIn('id', $log_ids)->update(['status' => 1]);
  1899. } elseif ($referralApply && $status == 2) {
  1900. ReferralLog::query()->whereIn('id', $log_ids)->update(['status' => 2]);
  1901. }
  1902. }
  1903. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  1904. }
  1905. // 重置用户流量
  1906. public function resetUserTraffic(Request $request)
  1907. {
  1908. $id = $request->get('id');
  1909. User::query()->where('id', $id)->update(['u' => 0, 'd' => 0]);
  1910. return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
  1911. }
  1912. // 操作用户余额
  1913. public function handleUserBalance(Request $request)
  1914. {
  1915. if ($request->isMethod('POST')) {
  1916. $userId = $request->get('user_id');
  1917. $amount = $request->get('amount');
  1918. if (empty($userId) || empty($amount)) {
  1919. return Response::json(['status' => 'fail', 'data' => '', 'message' => '充值异常']);
  1920. }
  1921. DB::beginTransaction();
  1922. try {
  1923. $user = User::query()->where('id', $userId)->first();
  1924. // 写入余额变动日志
  1925. $this->addUserBalanceLog($userId, 0, $user->balance, $user->balance + $amount, $amount, '后台手动充值');
  1926. // 加减余额
  1927. if ($amount < 0) {
  1928. $user->decrement('balance', abs($amount) * 100);
  1929. } else {
  1930. $user->increment('balance', abs($amount) * 100);
  1931. }
  1932. DB::commit();
  1933. return Response::json(['status' => 'success', 'data' => '', 'message' => '充值成功']);
  1934. } catch (\Exception $e) {
  1935. DB::rollBack();
  1936. return Response::json(['status' => 'fail', 'data' => '', 'message' => '充值失败:' . $e->getMessage()]);
  1937. }
  1938. } else {
  1939. return Response::view('admin.handleUserBalance');
  1940. }
  1941. }
  1942. // 用户余额变动记录
  1943. public function userBalanceLogList(Request $request)
  1944. {
  1945. $username = trim($request->get('username'));
  1946. $query = UserBalanceLog::query()->with(['user'])->orderBy('id', 'desc');
  1947. if ($username) {
  1948. $query->whereHas('user', function ($q) use ($username) {
  1949. $q->where('username', 'like', '%' . $username . '%');
  1950. });
  1951. }
  1952. $view['list'] = $query->paginate(15)->appends($request->except('page'));
  1953. return Response::view('admin.userBalanceLogList', $view);
  1954. }
  1955. // 用户封禁记录
  1956. public function userBanLogList(Request $request)
  1957. {
  1958. $username = trim($request->get('username'));
  1959. $query = UserBanLog::query()->with(['user'])->orderBy('id', 'desc');
  1960. if ($username) {
  1961. $query->whereHas('user', function ($q) use ($username) {
  1962. $q->where('username', 'like', '%' . $username . '%');
  1963. });
  1964. }
  1965. $view['list'] = $query->paginate(15)->appends($request->except('page'));
  1966. return Response::view('admin.userBanLogList', $view);
  1967. }
  1968. // 用户流量变动记录
  1969. public function userTrafficLogList(Request $request)
  1970. {
  1971. $username = trim($request->get('username'));
  1972. $query = UserTrafficModifyLog::query()->with(['user', 'order', 'order.goods'])->orderBy('id', 'desc');
  1973. if ($username) {
  1974. $query->whereHas('user', function ($q) use ($username) {
  1975. $q->where('username', 'like', '%' . $username . '%');
  1976. });
  1977. }
  1978. $view['list'] = $query->paginate(15)->appends($request->except('page'));
  1979. return Response::view('admin.userTrafficLogList', $view);
  1980. }
  1981. // 用户返利流水记录
  1982. public function userRebateList(Request $request)
  1983. {
  1984. $username = trim($request->get('username'));
  1985. $ref_username = trim($request->get('ref_username'));
  1986. $status = $request->get('status');
  1987. $query = ReferralLog::query()->with(['user', 'order'])->orderBy('status', 'asc')->orderBy('id', 'desc');
  1988. if ($username) {
  1989. $query->whereHas('user', function ($q) use ($username) {
  1990. $q->where('username', 'like', '%' . $username . '%');
  1991. });
  1992. }
  1993. if ($ref_username) {
  1994. $query->whereHas('ref_user', function ($q) use ($ref_username) {
  1995. $q->where('username', 'like', '%' . $ref_username . '%');
  1996. });
  1997. }
  1998. if ($status != '') {
  1999. $query->where('status', intval($status));
  2000. }
  2001. $view['list'] = $query->paginate(15)->appends($request->except('page'));
  2002. return Response::view('admin.userRebateList', $view);
  2003. }
  2004. // 用户在线IP记录
  2005. public function userOnlineIPList(Request $request)
  2006. {
  2007. $username = trim($request->get('username'));
  2008. $port = intval($request->get('port'));
  2009. $wechat = trim($request->get('wechat'));
  2010. $qq = trim($request->get('qq'));
  2011. $query = User::query()->where('status', '>=', 0)->where('enable', 1);
  2012. if ($username) {
  2013. $query->where('username', 'like', '%' . $username . '%');
  2014. }
  2015. if (!empty($wechat)) {
  2016. $query->where('wechat', 'like', '%' . $wechat . '%');
  2017. }
  2018. if (!empty($qq)) {
  2019. $query->where('qq', 'like', '%' . $qq . '%');
  2020. }
  2021. if ($port) {
  2022. $query->where('port', $port);
  2023. }
  2024. $userList = $query->paginate(15)->appends($request->except('page'));
  2025. if (!$userList->isEmpty()) {
  2026. foreach ($userList as &$user) {
  2027. // 最近5条在线IP记录,如果后端设置为60秒上报一次,则为10分钟内的在线IP
  2028. $user->onlineIPList = SsNodeIp::query()->with(['node'])->where('type', 'tcp')->where('port', $user->port)->where('created_at', '>=', strtotime("-10 minutes"))->orderBy('id', 'desc')->limit(5)->get();
  2029. }
  2030. }
  2031. $view['userList'] = $userList;
  2032. return Response::view('admin.userOnlineIPList', $view);
  2033. }
  2034. // 转换成某个用户的身份
  2035. public function switchToUser(Request $request)
  2036. {
  2037. $id = $request->get('user_id');
  2038. $user = User::query()->find($id);
  2039. if (!$user) {
  2040. return Response::json(['status' => 'fail', 'data' => '', 'message' => "用户不存在"]);
  2041. }
  2042. // 存储当前管理员ID,并将当前登录信息改成要切换的用户的身份信息
  2043. Session::put('admin', Auth::user()->id);
  2044. Auth::login($user);
  2045. return Response::json(['status' => 'success', 'data' => '', 'message' => "身份切换成功"]);
  2046. }
  2047. // 标签列表
  2048. public function labelList(Request $request)
  2049. {
  2050. $labelList = Label::query()->paginate(15)->appends($request->except('page'));
  2051. foreach ($labelList as $label) {
  2052. $label->userCount = UserLabel::query()->where('label_id', $label->id)->groupBy('label_id')->count();
  2053. $label->nodeCount = SsNodeLabel::query()->where('label_id', $label->id)->groupBy('label_id')->count();
  2054. }
  2055. $view['labelList'] = $labelList;
  2056. return Response::view('admin.labelList', $view);
  2057. }
  2058. // 添加标签
  2059. public function addLabel(Request $request)
  2060. {
  2061. if ($request->isMethod('POST')) {
  2062. $name = $request->get('name');
  2063. $sort = $request->get('sort');
  2064. $label = new Label();
  2065. $label->name = $name;
  2066. $label->sort = $sort;
  2067. $label->save();
  2068. return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
  2069. } else {
  2070. return Response::view('admin.addLabel');
  2071. }
  2072. }
  2073. // 编辑标签
  2074. public function editLabel(Request $request)
  2075. {
  2076. if ($request->isMethod('POST')) {
  2077. $id = $request->get('id');
  2078. $name = $request->get('name');
  2079. $sort = $request->get('sort');
  2080. Label::query()->where('id', $id)->update(['name' => $name, 'sort' => $sort]);
  2081. return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
  2082. } else {
  2083. $id = $request->get('id');
  2084. $view['label'] = Label::query()->where('id', $id)->first();
  2085. return Response::view('admin.editLabel', $view);
  2086. }
  2087. }
  2088. // 删除标签
  2089. public function delLabel(Request $request)
  2090. {
  2091. $id = $request->get('id');
  2092. DB::beginTransaction();
  2093. try {
  2094. Label::query()->where('id', $id)->delete();
  2095. UserLabel::query()->where('label_id', $id)->delete(); // 删除用户关联
  2096. SsNodeLabel::query()->where('label_id', $id)->delete(); // 删除节点关联
  2097. DB::commit();
  2098. return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
  2099. } catch (\Exception $e) {
  2100. DB::rollBack();
  2101. return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败:' . $e->getMessage()]);
  2102. }
  2103. }
  2104. // 邮件发送日志列表
  2105. public function emailLog(Request $request)
  2106. {
  2107. $view['list'] = EmailLog::query()->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));
  2108. return Response::view('admin.emailLog', $view);
  2109. }
  2110. // 在线IP监控(实时)
  2111. public function onlineIPMonitor(Request $request)
  2112. {
  2113. $ip = trim($request->get('ip'));
  2114. $username = trim($request->get('username'));
  2115. $port = intval($request->get('port'));
  2116. $nodeId = intval($request->get('nodeId'));
  2117. $userId = intval($request->get('id'));
  2118. $query = SsNodeIp::query()->with(['node', 'user'])->where('type', 'tcp')->where('created_at', '>=', strtotime("-120 seconds"));
  2119. if ($ip) {
  2120. $query->where('ip', $ip);
  2121. }
  2122. if ($username) {
  2123. $query->whereHas('user', function ($q) use ($username) {
  2124. $q->where('username', 'like', '%' . $username . '%');
  2125. });
  2126. }
  2127. if ($port) {
  2128. $query->whereHas('user', function ($q) use ($port) {
  2129. $q->where('port', $port);
  2130. });
  2131. }
  2132. if ($nodeId) {
  2133. $query->whereHas('node', function ($q) use ($nodeId) {
  2134. $q->where('id', $nodeId);
  2135. });
  2136. }
  2137. if ($userId) {
  2138. $query->whereHas('user', function ($q) use ($userId) {
  2139. $q->where('id', $userId);
  2140. });
  2141. }
  2142. $list = $query->groupBy('port')->orderBy('id', 'desc')->paginate(20)->appends($request->except('page'));
  2143. foreach ($list as $vo) {
  2144. // 跳过上报多IP的
  2145. if (strpos($vo->ip, ',') !== false) {
  2146. continue;
  2147. }
  2148. $ipInfo = QQWry::ip($vo->ip);
  2149. if (isset($ipInfo['error'])) {
  2150. // 用IPIP的库再试一下
  2151. $ipip = IPIP::ip($vo->ip);
  2152. $ipInfo = [
  2153. 'country' => $ipip['country_name'],
  2154. 'province' => $ipip['region_name'],
  2155. 'city' => $ipip['city_name']
  2156. ];
  2157. }
  2158. $vo->ipInfo = $ipInfo['country'] . ' ' . $ipInfo['province'] . ' ' . $ipInfo['city'];
  2159. }
  2160. $view['list'] = $list;
  2161. $view['nodeList'] = SsNode::query()->where('status', 1)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get();
  2162. return Response::view('admin.onlineIPMonitor', $view);
  2163. }
  2164. // 生成用户标签
  2165. private function makeUserLabels($userId, $labels)
  2166. {
  2167. // 先删除该用户所有的标签
  2168. UserLabel::query()->where('user_id', $userId)->delete();
  2169. if (!empty($labels) && is_array($labels)) {
  2170. foreach ($labels as $label) {
  2171. $userLabel = new UserLabel();
  2172. $userLabel->user_id = $userId;
  2173. $userLabel->label_id = $label;
  2174. $userLabel->save();
  2175. }
  2176. }
  2177. }
  2178. // 生成节点标签
  2179. private function makeNodeLabels($nodeId, $labels)
  2180. {
  2181. // 先删除所有该节点的标签
  2182. SsNodeLabel::query()->where('node_id', $nodeId)->delete();
  2183. if (!empty($labels) && is_array($labels)) {
  2184. foreach ($labels as $label) {
  2185. $ssNodeLabel = new SsNodeLabel();
  2186. $ssNodeLabel->node_id = $nodeId;
  2187. $ssNodeLabel->label_id = $label;
  2188. $ssNodeLabel->save();
  2189. }
  2190. }
  2191. }
  2192. }