123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343344345346347348349350351352353354355356357358359360361362363364365366367368369370371372373374375376377378379380381382383384385386387388389390391392393394395396397398399400401402403404405406407408409410411412413414415416417418419420421422423424425426427428429430431432433434435436437438439440441442443444445446447448449450451452453454455456457458459460461462463464465466467468469470471472473474475476477478479480481482483484485486487488489490491492493494495496497498499500501502503504505506507508509510511512513514515516517518519520521522523524525526527528529530531532533534535536537538539540541542543544545546547548549550551552553554555556557558559560561562563564565566567568569570571572573574575576577578579580581582583584585586587588589590591592593594595596597598599600601602603604605606607608609610611612613614615616617618619620621622623624625626627628629630631632633634635636637638639640641642643644645646647648649650651652653654655656657658659660661662663664665666667668669670671672673674675676677678679680681682683684685686687688689690691692693694695696697698699700701702703704705706707708709710711712713714715716717718719720721722723724725726727728729730731732733734735736737738739740741742743744745746747748749750751752753754755756757758759760761762763764765766767768769770771772773774775776777778779780781782783784785786787788789790791792793794795796797798799800801802803804805806807808809810811812813814815816817818819820821822823824825826827828829830831832833834835836837838839840841842843844845846847848849850851852853854855856857858859860861862863864865866867868869870871872873874875876877878879880881882883884885886887888889890891892893894895896897898899900901902903904905906907908909910911912913914915916917918919920921922923924925926927928929930931932933934935936937938939940941942943944945946947948949950951952953954955956957958959960961962963964965966967968969970971972973974975976977978979980981982983984985986987988989990991992993994995996997998999100010011002100310041005100610071008100910101011101210131014101510161017101810191020102110221023102410251026102710281029103010311032103310341035103610371038103910401041104210431044104510461047104810491050105110521053105410551056105710581059106010611062106310641065106610671068106910701071107210731074107510761077107810791080108110821083108410851086108710881089109010911092109310941095109610971098109911001101110211031104110511061107110811091110111111121113111411151116111711181119112011211122112311241125112611271128112911301131113211331134113511361137113811391140114111421143114411451146114711481149115011511152115311541155115611571158115911601161116211631164116511661167116811691170117111721173117411751176117711781179118011811182118311841185118611871188118911901191119211931194119511961197119811991200120112021203120412051206120712081209121012111212121312141215121612171218121912201221122212231224122512261227122812291230123112321233123412351236123712381239124012411242124312441245124612471248124912501251125212531254125512561257125812591260126112621263126412651266126712681269127012711272127312741275127612771278127912801281128212831284128512861287128812891290129112921293129412951296129712981299130013011302130313041305130613071308130913101311131213131314131513161317131813191320132113221323132413251326132713281329133013311332133313341335133613371338133913401341134213431344134513461347134813491350135113521353135413551356135713581359136013611362136313641365136613671368136913701371137213731374137513761377137813791380138113821383138413851386138713881389139013911392139313941395139613971398139914001401140214031404140514061407140814091410141114121413141414151416141714181419142014211422142314241425142614271428142914301431143214331434143514361437143814391440144114421443144414451446144714481449145014511452145314541455145614571458145914601461146214631464146514661467146814691470147114721473147414751476147714781479148014811482148314841485148614871488148914901491149214931494149514961497149814991500150115021503150415051506150715081509151015111512151315141515151615171518151915201521152215231524152515261527152815291530153115321533153415351536153715381539154015411542154315441545154615471548154915501551155215531554155515561557155815591560156115621563156415651566156715681569157015711572157315741575157615771578157915801581158215831584158515861587158815891590159115921593159415951596159715981599160016011602160316041605160616071608160916101611161216131614161516161617161816191620162116221623162416251626162716281629163016311632163316341635163616371638163916401641164216431644164516461647164816491650165116521653165416551656165716581659166016611662166316641665166616671668166916701671167216731674167516761677167816791680168116821683168416851686168716881689169016911692169316941695169616971698169917001701170217031704170517061707170817091710171117121713171417151716171717181719172017211722172317241725172617271728172917301731173217331734173517361737173817391740174117421743174417451746174717481749175017511752175317541755175617571758175917601761176217631764176517661767176817691770177117721773177417751776177717781779178017811782178317841785178617871788178917901791179217931794179517961797179817991800180118021803180418051806180718081809181018111812181318141815181618171818181918201821182218231824182518261827182818291830183118321833183418351836183718381839184018411842184318441845184618471848184918501851185218531854185518561857185818591860186118621863186418651866186718681869187018711872187318741875187618771878187918801881188218831884188518861887188818891890189118921893189418951896189718981899190019011902190319041905190619071908190919101911191219131914191519161917191819191920192119221923192419251926192719281929193019311932193319341935193619371938193919401941194219431944194519461947194819491950195119521953195419551956195719581959196019611962196319641965196619671968196919701971197219731974197519761977197819791980198119821983198419851986198719881989199019911992199319941995199619971998199920002001200220032004200520062007200820092010201120122013201420152016201720182019202020212022202320242025202620272028202920302031203220332034203520362037203820392040204120422043204420452046204720482049205020512052205320542055205620572058205920602061206220632064206520662067206820692070207120722073207420752076207720782079208020812082208320842085208620872088208920902091209220932094209520962097209820992100210121022103210421052106210721082109211021112112211321142115211621172118211921202121212221232124212521262127212821292130213121322133213421352136213721382139214021412142214321442145214621472148214921502151215221532154215521562157215821592160216121622163216421652166216721682169217021712172217321742175217621772178217921802181218221832184218521862187218821892190219121922193219421952196219721982199220022012202220322042205220622072208220922102211221222132214221522162217221822192220222122222223222422252226222722282229223022312232223322342235223622372238223922402241224222432244224522462247224822492250225122522253225422552256225722582259226022612262226322642265226622672268226922702271227222732274227522762277227822792280228122822283228422852286228722882289229022912292229322942295229622972298229923002301230223032304230523062307230823092310231123122313231423152316231723182319232023212322232323242325232623272328232923302331233223332334233523362337233823392340234123422343234423452346234723482349235023512352235323542355235623572358235923602361236223632364236523662367236823692370237123722373237423752376237723782379238023812382238323842385238623872388238923902391239223932394239523962397239823992400240124022403240424052406240724082409241024112412241324142415241624172418241924202421242224232424242524262427242824292430243124322433243424352436243724382439244024412442244324442445244624472448244924502451245224532454245524562457245824592460246124622463246424652466246724682469247024712472247324742475247624772478247924802481248224832484248524862487248824892490249124922493249424952496249724982499250025012502250325042505250625072508250925102511251225132514251525162517251825192520252125222523252425252526252725282529253025312532 |
- <?php
- namespace App\Http\Controllers;
- use App\Components\Helpers;
- use App\Components\IPIP;
- use App\Components\QQWry;
- use App\Http\Models\Article;
- use App\Http\Models\Config;
- use App\Http\Models\Country;
- use App\Http\Models\EmailLog;
- use App\Http\Models\Invite;
- use App\Http\Models\Label;
- use App\Http\Models\Level;
- use App\Http\Models\Order;
- use App\Http\Models\ReferralApply;
- use App\Http\Models\ReferralLog;
- use App\Http\Models\SsConfig;
- use App\Http\Models\SsGroup;
- use App\Http\Models\SsGroupNode;
- use App\Http\Models\SsNode;
- use App\Http\Models\SsNodeInfo;
- use App\Http\Models\SsNodeIp;
- use App\Http\Models\SsNodeLabel;
- use App\Http\Models\SsNodeOnlineLog;
- use App\Http\Models\SsNodeTrafficDaily;
- use App\Http\Models\SsNodeTrafficHourly;
- use App\Http\Models\User;
- use App\Http\Models\UserBalanceLog;
- use App\Http\Models\UserBanLog;
- use App\Http\Models\UserLabel;
- use App\Http\Models\UserLoginLog;
- use App\Http\Models\UserSubscribe;
- use App\Http\Models\UserTrafficDaily;
- use App\Http\Models\UserTrafficHourly;
- use App\Http\Models\UserTrafficLog;
- use App\Http\Models\UserTrafficModifyLog;
- use Auth;
- use DB;
- use Exception;
- use Hash;
- use Illuminate\Http\Request;
- use Log;
- use PhpOffice\PhpSpreadsheet\Spreadsheet;
- use PhpOffice\PhpSpreadsheet\Writer\Xlsx;
- use Redirect;
- use Response;
- use Session;
- use stdClass;
- /**
- * 管理员控制器
- *
- * Class AdminController
- *
- * @package App\Http\Controllers
- */
- class AdminController extends Controller
- {
- protected static $systemConfig;
- function __construct()
- {
- self::$systemConfig = Helpers::systemConfig();
- }
- public function index(Request $request)
- {
- $past = strtotime(date('Y-m-d', strtotime("-".self::$systemConfig['expire_days']." days")));
- $view['expireDays'] = self::$systemConfig['expire_days'];
- $view['totalUserCount'] = User::query()->count(); // 总用户数
- $view['enableUserCount'] = User::query()->where('enable', 1)->count(); // 有效用户数
- $view['activeUserCount'] = User::query()->where('t', '>=', $past)->count(); // 活跃用户数
- $view['unActiveUserCount'] = User::query()->where('t', '<=', $past)->where('enable', 1)->where('t', '>', 0)->count(); // 不活跃用户数
- $view['onlineUserCount'] = User::query()->where('t', '>=', time()-600)->count(); // 10分钟内在线用户数
- $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(); // 临近过期用户数
- $view['largeTrafficUserCount'] = User::query()->whereRaw('(u + d) >= 107374182400')->whereIn('status', [0, 1])->count(); // 流量超过100G的用户
- // 1小时内流量异常用户
- $tempUsers = [];
- $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以上的记录,加快速度
- if(!$userTotalTrafficList->isEmpty()){
- foreach($userTotalTrafficList as $vo){
- if($vo->totalTraffic > (self::$systemConfig['traffic_ban_value']*1073741824)){
- $tempUsers[] = $vo->user_id;
- }
- }
- }
- $view['flowAbnormalUserCount'] = User::query()->whereIn('id', $tempUsers)->count();
- $view['nodeCount'] = SsNode::query()->count();
- $view['unnormalNodeCount'] = SsNode::query()->where('status', 0)->count();
- $flowCount = SsNodeTrafficDaily::query()->where('created_at', '>=', date('Y-m-d 00:00:00', strtotime("-30 days")))->sum('total');
- $view['flowCount'] = flowAutoShow($flowCount);
- $totalFlowCount = SsNodeTrafficDaily::query()->sum('total');
- $view['totalFlowCount'] = flowAutoShow($totalFlowCount);
- $view['totalBalance'] = User::query()->sum('balance')/100;
- $view['totalWaitRefAmount'] = ReferralLog::query()->whereIn('status', [0, 1])->sum('ref_amount')/100;
- $view['totalRefAmount'] = ReferralApply::query()->where('status', 2)->sum('amount')/100;
- $view['totalOrder'] = Order::query()->count();
- $view['totalOnlinePayOrder'] = Order::query()->where('pay_way', 2)->count();
- $view['totalSuccessOrder'] = Order::query()->where('status', 2)->count();
- $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();
- return Response::view('admin.index', $view);
- }
- // 用户列表
- public function userList(Request $request)
- {
- $id = $request->input('id');
- $username = $request->input('username');
- $wechat = $request->input('wechat');
- $qq = $request->input('qq');
- $port = $request->input('port');
- $pay_way = $request->input('pay_way');
- $status = $request->input('status');
- $enable = $request->input('enable');
- $online = $request->input('online');
- $unActive = $request->input('unActive');
- $flowAbnormal = $request->input('flowAbnormal');
- $expireWarning = $request->input('expireWarning');
- $largeTraffic = $request->input('largeTraffic');
- $query = User::query()->with(['subscribe']);
- if(isset($id)){
- $query->where('id', $id);
- }
- if(isset($username)){
- $query->where('username', 'like', '%'.$username.'%');
- }
- if(isset($wechat)){
- $query->where('wechat', 'like', '%'.$wechat.'%');
- }
- if(isset($qq)){
- $query->where('qq', 'like', '%'.$qq.'%');
- }
- if(isset($port)){
- $query->where('port', $port);
- }
- if(isset($pay_way)){
- $query->where('pay_way', $pay_way);
- }
- if(isset($status)){
- $query->where('status', $status);
- }
- if(isset($enable)){
- $query->where('enable', $enable);
- }
- // 流量超过100G的
- if($largeTraffic){
- $query->whereIn('status', [0, 1])->whereRaw('(u + d) >= 107374182400');
- }
- // 临近过期提醒
- if($expireWarning){
- $query->where('expire_time', '>=', date('Y-m-d'))->where('expire_time', '<=', date('Y-m-d', strtotime("+".self::$systemConfig['expire_days']." days")));
- }
- // 当前在线
- if($online){
- $query->where('t', '>=', time()-600);
- }
- // 不活跃用户
- if($unActive){
- $query->where('t', '>', 0)->where('t', '<=', strtotime(date('Y-m-d', strtotime("-".self::$systemConfig['expire_days']." days"))))->where('enable', 1);
- }
- // 1小时内流量异常用户
- if($flowAbnormal){
- $tempUsers = [];
- $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以上的记录,加快速度
- if(!$userTotalTrafficList->isEmpty()){
- foreach($userTotalTrafficList as $vo){
- if($vo->totalTraffic > (self::$systemConfig['traffic_ban_value']*1024*1024*1024)){
- $tempUsers[] = $vo->user_id;
- }
- }
- }
- $query->whereIn('id', $tempUsers);
- }
- $userList = $query->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));
- foreach($userList as $user){
- $user->transfer_enable = flowAutoShow($user->transfer_enable);
- $user->used_flow = flowAutoShow($user->u+$user->d);
- if($user->expire_time < date('Y-m-d')){
- $user->expireWarning = -1; // 已过期
- }elseif($user->expire_time == date('Y-m-d')){
- $user->expireWarning = 0; // 今天过期
- }elseif($user->expire_time > date('Y-m-d') && $user->expire_time <= date('Y-m-d', strtotime("+30 days"))){
- $user->expireWarning = 1; // 最近一个月过期
- }else{
- $user->expireWarning = 2; // 大于一个月过期
- }
- // 流量异常警告
- $time = date('Y-m-d H:i:s', time()-3900);
- $totalTraffic = UserTrafficHourly::query()->where('user_id', $user->id)->where('node_id', 0)->where('created_at', '>=', $time)->sum('total');
- $user->trafficWarning = $totalTraffic > (self::$systemConfig['traffic_ban_value']*1024*1024*1024)? 1 : 0;
- // 订阅地址
- $user->link = (self::$systemConfig['subscribe_domain']? self::$systemConfig['subscribe_domain'] : self::$systemConfig['website_url']).'/s/'.$user->subscribe->code;
- }
- $view['userList'] = $userList;
- return Response::view('admin.userList', $view);
- }
- // 添加账号
- public function addUser(Request $request)
- {
- if($request->isMethod('POST')){
- // 校验username是否已存在
- $exists = User::query()->where('username', $request->input('username'))->first();
- if($exists){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '用户名已存在,请重新输入']);
- }
- if(!$request->input('usage')){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '请至少选择一种用途']);
- }
- $user = new User();
- $user->username = trim($request->input('username'));
- $user->password = Hash::make(trim($request->input('password'))? : makeRandStr());
- $user->port = $request->input('port');
- $user->passwd = empty($request->input('passwd'))? makeRandStr() : $request->input('passwd');
- $user->vmess_id = $request->input('vmess_id')? : createGuid();
- $user->transfer_enable = toGB($request->input('transfer_enable', 0));
- $user->enable = $request->input('enable', 0);
- $user->method = $request->input('method');
- $user->protocol = $request->input('protocol');
- $user->protocol_param = $request->input('protocol_param')? : '';
- $user->obfs = $request->input('obfs');
- $user->obfs_param = $request->input('obfs_param')? : '';
- $user->speed_limit_per_con = $request->input('speed_limit_per_con');
- $user->speed_limit_per_user = $request->input('speed_limit_per_user');
- $user->wechat = $request->input('wechat')? : '';
- $user->qq = $request->input('qq')? : '';
- $user->usage = $request->input('usage');
- $user->pay_way = $request->input('pay_way');
- $user->balance = 0;
- $user->enable_time = empty($request->input('enable_time'))? date('Y-m-d') : $request->input('enable_time');
- $user->expire_time = empty($request->input('expire_time'))? date('Y-m-d', strtotime("+365 days")) : $request->input('expire_time');
- $user->remark = str_replace("eval", "", str_replace("atob", "", $request->input('remark')));
- $user->level = $request->input('level')? : 1;
- $user->is_admin = 0;
- $user->reg_ip = getClientIp();
- $user->referral_uid = 0;
- $user->reset_time = $request->input('reset_time') > date('Y-m-d')? $request->input('reset_time') : NULL;
- $user->status = $request->input('status')? : 1;
- $user->save();
- if($user->id){
- // 生成订阅码
- $subscribe = new UserSubscribe();
- $subscribe->user_id = $user->id;
- $subscribe->code = Helpers::makeSubscribeCode();
- $subscribe->times = 0;
- $subscribe->save();
- // 生成用户标签
- $this->makeUserLabels($user->id, $request->input('labels'));
- // 写入用户流量变动记录
- Helpers::addUserTrafficModifyLog($user->id, 0, 0, toGB($request->input('transfer_enable', 0)), '后台手动添加用户');
- return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
- }else{
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败']);
- }
- }else{
- // 生成一个可用端口
- $view['last_port'] = self::$systemConfig['is_rand_port']? Helpers::getRandPort() : Helpers::getOnlyPort();
- $view['method_list'] = Helpers::methodList();
- $view['protocol_list'] = Helpers::protocolList();
- $view['obfs_list'] = Helpers::obfsList();
- $view['level_list'] = Helpers::levelList();
- $view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
- $view['initial_labels'] = explode(",", Helpers::systemConfig()['initial_labels_for_user']);
- return Response::view('admin.addUser', $view);
- }
- }
- // 批量生成账号
- public function batchAddUsers(Request $request)
- {
- $amount = $request->input('amount');
- DB::beginTransaction();
- try{
- for($i = 0; $i < $amount; $i++){
- $uid = Helpers::addUser('批量生成-'.makeRandStr(), Hash::make(makeRandStr()), toGB(1024), 365);
- // 生成一个可用端口
- if($uid){
- // 生成订阅码
- $subscribe = new UserSubscribe();
- $subscribe->user_id = $uid;
- $subscribe->code = Helpers::makeSubscribeCode();
- $subscribe->times = 0;
- $subscribe->save();
- // 初始化默认标签
- if(!empty(self::$systemConfig['initial_labels_for_user'])){
- $labels = explode(',', self::$systemConfig['initial_labels_for_user']);
- $this->makeUserLabels($uid, $labels);
- }
- // 写入用户流量变动记录
- Helpers::addUserTrafficModifyLog($uid, 0, 0, toGB(1024), '后台批量生成用户');
- }
- }
- DB::commit();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '批量生成账号成功']);
- } catch(Exception $e){
- DB::rollBack();
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '批量生成账号失败:'.$e->getMessage()]);
- }
- }
- // 编辑账号
- public function editUser(Request $request, $id)
- {
- if($request->isMethod('POST')){
- $username = trim($request->input('username'));
- $password = $request->input('password');
- $port = $request->input('port');
- $passwd = $request->input('passwd');
- $vmess_id = $request->input('vmess_id')? trim($request->input('vmess_id')) : createGuid();
- $transfer_enable = $request->input('transfer_enable');
- $enable = $request->input('enable');
- $method = $request->input('method');
- $protocol = $request->input('protocol');
- $protocol_param = $request->input('protocol_param');
- $obfs = $request->input('obfs');
- $obfs_param = $request->input('obfs_param');
- $speed_limit_per_con = $request->input('speed_limit_per_con');
- $speed_limit_per_user = $request->input('speed_limit_per_user');
- $wechat = $request->input('wechat');
- $qq = $request->input('qq');
- $usage = $request->input('usage');
- $pay_way = $request->input('pay_way');
- $status = $request->input('status');
- $labels = $request->input('labels');
- $enable_time = $request->input('enable_time');
- $expire_time = $request->input('expire_time');
- $remark = str_replace("eval", "", str_replace("atob", "", $request->input('remark')));
- $level = $request->input('level');
- $is_admin = $request->input('is_admin');
- $reset_time = $request->input('reset_time');
- // 校验username是否已存在
- $exists = User::query()->where('id', '<>', $id)->where('username', $username)->first();
- if($exists){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '用户名已存在,请重新输入']);
- }
- // 校验端口是否已存在
- $exists = User::query()->where('id', '<>', $id)->where('port', '>', 0)->where('port', $port)->first();
- if($exists){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '端口已存在,请重新输入']);
- }
- // 禁止取消默认管理员
- if($id == 1 && $is_admin == 0){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '系统默认管理员不可取消']);
- }
- if(!$usage){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '请至少选择一种用途']);
- }
- // 用户编辑前的信息
- $user = User::query()->where('id', $id)->first();
- DB::beginTransaction();
- try{
- $data = [
- 'username' => $username,
- 'port' => $port,
- 'passwd' => $passwd,
- 'vmess_id' => $vmess_id,
- 'transfer_enable' => toGB($transfer_enable),
- 'enable' => $status < 0? 0 : $enable,
- 'method' => $method,
- 'protocol' => $protocol,
- 'protocol_param' => $protocol_param,
- 'obfs' => $obfs,
- 'obfs_param' => $obfs_param,
- 'speed_limit_per_con' => $speed_limit_per_con,
- 'speed_limit_per_user' => $speed_limit_per_user,
- 'wechat' => $wechat,
- 'qq' => $qq,
- 'usage' => $usage,
- 'pay_way' => $pay_way,
- 'status' => $status,
- 'reset_time' => empty($reset_time)? NULL : $reset_time,
- 'enable_time' => empty($enable_time)? date('Y-m-d') : $enable_time,
- 'expire_time' => empty($expire_time)? date('Y-m-d', strtotime("+365 days")) : $expire_time,
- 'remark' => $remark,
- 'level' => $level
- ];
- // 只有admin才有权限操作管理员属性
- if(Auth::user()->id == 1){
- $data['is_admin'] = $is_admin;
- }
- if(!empty($password)){
- if(!(env('APP_DEMO') && $id == 1)){ // 演示环境禁止修改管理员密码
- $data['password'] = Hash::make($password);
- }
- }
- User::query()->where('id', $id)->update($data);
- // 重新生成用户标签
- $this->makeUserLabels($id, $labels);
- // 写入用户流量变动记录
- if($user->transfer_enable != toGB($transfer_enable)){
- Helpers::addUserTrafficModifyLog($id, 0, $user->transfer_enable, toGB($transfer_enable), '后台手动编辑用户');
- }
- DB::commit();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
- } catch(Exception $e){
- DB::rollBack();
- Log::error('编辑用户信息异常:'.$e->getMessage());
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败']);
- }
- }else{
- $user = User::query()->with(['label', 'referral'])->where('id', $id)->first();
- if($user){
- $user->transfer_enable = flowToGB($user->transfer_enable);
- // 处理标签
- $label = [];
- foreach($user->label as $vo){
- $label[] = $vo->label_id;
- }
- $user->labels = $label;
- // 处理用途
- $user->usage = explode(',', $user->usage);
- }
- $view['user'] = $user;
- $view['method_list'] = Helpers::methodList();
- $view['protocol_list'] = Helpers::protocolList();
- $view['obfs_list'] = Helpers::obfsList();
- $view['level_list'] = Helpers::levelList();
- $view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
- return Response::view('admin.editUser', $view);
- }
- }
- // 删除用户
- public function delUser(Request $request)
- {
- $id = $request->input('id');
- if($id <= 1){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '系统管理员不可删除']);
- }
- DB::beginTransaction();
- try{
- User::query()->where('id', $id)->delete();
- UserSubscribe::query()->where('user_id', $id)->delete();
- UserBanLog::query()->where('user_id', $id)->delete();
- UserLabel::query()->where('user_id', $id)->delete();
- UserBalanceLog::query()->where('user_id', $id)->delete();
- UserTrafficModifyLog::query()->where('user_id', $id)->delete();
- UserLoginLog::query()->where('user_id', $id)->delete();
- DB::commit();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
- } catch(Exception $e){
- Log::error($e);
- DB::rollBack();
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
- }
- }
- // 节点列表
- public function nodeList(Request $request)
- {
- $status = $request->input('status');
- $query = SsNode::query();
- if(isset($status)){
- $query->where('status', $status);
- }
- $nodeList = $query->orderBy('status', 'desc')->orderBy('id', 'asc')->paginate(15)->appends($request->except('page'));
- foreach($nodeList as $node){
- // 在线人数
- $online_log = SsNodeOnlineLog::query()->where('node_id', $node->id)->where('log_time', '>=', strtotime("-5 minutes"))->orderBy('id', 'desc')->first();
- $node->online_users = empty($online_log)? 0 : $online_log->online_user;
- // 已产生流量
- $totalTraffic = SsNodeTrafficDaily::query()->where('node_id', $node->id)->sum('total');
- $node->transfer = flowAutoShow($totalTraffic);
- // 负载(10分钟以内)
- $node_info = SsNodeInfo::query()->where('node_id', $node->id)->where('log_time', '>=', strtotime("-10 minutes"))->orderBy('id', 'desc')->first();
- $node->isOnline = empty($node_info) || empty($node_info->load)? 0 : 1;
- $node->load = $node->isOnline? $node_info->load : '离线';
- $node->uptime = empty($node_info)? 0 : seconds2time($node_info->uptime);
- }
- $view['nodeList'] = $nodeList;
- return Response::view('admin.nodeList', $view);
- }
- // 添加节点
- public function addNode(Request $request)
- {
- if($request->isMethod('POST')){
- if($request->input('ssh_port') <= 0 || $request->input('ssh_port') >= 65535){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败:SSH端口不合法']);
- }
- if(FALSE === filter_var($request->input('ip'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV4)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败:IPv4地址不合法']);
- }
- if($request->input('ipv6') && FALSE === filter_var($request->input('ipv6'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV6)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败:IPv6地址不合法']);
- }
- if($request->input('server')){
- $domain = $request->input('server');
- $domain = explode('.', $domain);
- $domainSuffix = end($domain); // 取得域名后缀
- if(!in_array($domainSuffix, \config('domains'))){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '绑定域名不合法']);
- }
- }
- // TODO:判断是否已存在绑定了相同域名的节点,提示是否要强制替换,或者不提示之前强制将其他节点的绑定域名置为空,然后发起域名绑定请求,或者请求进入队列
- DB::beginTransaction();
- try{
- $ssNode = new SsNode();
- $ssNode->type = $request->input('type');
- $ssNode->name = $request->input('name');
- $ssNode->group_id = $request->input('group_id')? : 0;
- $ssNode->country_code = $request->input('country_code')? : 'un';
- $ssNode->server = $request->input('server')? : '';
- $ssNode->ip = $request->input('ip');
- $ssNode->ipv6 = $request->input('ipv6');
- $ssNode->desc = $request->input('desc')? : '';
- $ssNode->method = $request->input('method');
- $ssNode->protocol = $request->input('protocol');
- $ssNode->protocol_param = $request->input('protocol_param')? : '';
- $ssNode->obfs = $request->input('obfs')? : '';
- $ssNode->obfs_param = $request->input('obfs_param')? : '';
- $ssNode->traffic_rate = $request->input('traffic_rate')? : 1;
- $ssNode->bandwidth = $request->input('bandwidth')? : 1000;
- $ssNode->traffic = $request->input('traffic')? : 1000;
- $ssNode->monitor_url = $request->input('monitor_url')? : '';
- $ssNode->is_subscribe = $request->input('is_subscribe');
- $ssNode->is_ddns = $request->input('is_ddns');
- $ssNode->is_transit = $request->input('is_transit');
- $ssNode->ssh_port = $request->input('ssh_port')? : 22;
- $ssNode->detectionType = $request->input('detectionType');
- $ssNode->compatible = $request->input('type') == 2? 0 : ($request->input('is_ddns')? 0 : $request->input('compatible'));
- $ssNode->single = $request->input('single');
- $ssNode->port = $request->input('single')? ($request->input('port')? : 443) : '';
- $ssNode->passwd = $request->input('single')? ($request->input('passwd')? : 'password') : '';
- $ssNode->sort = $request->input('sort')? : 0;
- $ssNode->status = $request->input('status')? : 1;
- $ssNode->v2_alter_id = $request->input('v2_alter_id')? : 16;
- $ssNode->v2_port = $request->input('v2_port')? : 10087;
- $ssNode->v2_method = $request->input('v2_method')? : 'aes-128-gcm';
- $ssNode->v2_net = $request->input('v2_net')? : 'tcp';
- $ssNode->v2_type = $request->input('v2_type')? : 'none';
- $ssNode->v2_host = $request->input('v2_host')? : '';
- $ssNode->v2_path = $request->input('v2_path')? : '';
- $ssNode->v2_tls = $request->input('v2_tls')? : 0;
- $ssNode->v2_insider_port = $request->input('v2_insider_port')? : 10550;
- $ssNode->v2_outsider_port = $request->input('v2_outsider_port')? : 443;
- $ssNode->save();
- // 建立分组关联
- if($ssNode->id && $request->input('group_id', 0)){
- $ssGroupNode = new SsGroupNode();
- $ssGroupNode->group_id = $request->input('group_id', 0);
- $ssGroupNode->node_id = $ssNode->id;
- $ssGroupNode->save();
- }
- // 生成节点标签
- $labels = $request->input('labels');
- if($ssNode->id && !empty($labels)){
- foreach($labels as $label){
- $ssNodeLabel = new SsNodeLabel();
- $ssNodeLabel->node_id = $ssNode->id;
- $ssNodeLabel->label_id = $label;
- $ssNodeLabel->save();
- }
- }
- DB::commit();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
- } catch(Exception $e){
- DB::rollBack();
- Log::error('添加节点信息异常:'.$e->getMessage());
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '添加失败:'.$e->getMessage()]);
- }
- }else{
- $view['method_list'] = Helpers::methodList();
- $view['protocol_list'] = Helpers::protocolList();
- $view['obfs_list'] = Helpers::obfsList();
- $view['level_list'] = Helpers::levelList();
- $view['group_list'] = SsGroup::query()->get();
- $view['country_list'] = Country::query()->orderBy('code', 'asc')->get();
- $view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
- return Response::view('admin.addNode', $view);
- }
- }
- // 编辑节点
- public function editNode(Request $request)
- {
- $id = $request->input('id');
- if($request->isMethod('POST')){
- if($request->input('ssh_port') <= 0 || $request->input('ssh_port') >= 65535){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败:SSH端口不合法']);
- }
- if(FALSE === filter_var($request->input('ip'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV4)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败:IPv4地址不合法']);
- }
- if($request->input('ipv6') && FALSE === filter_var($request->input('ipv6'), FILTER_VALIDATE_IP, FILTER_FLAG_IPV6)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败:IPv6地址不合法']);
- }
- if($request->input('server')){
- $domain = $request->input('server');
- $domain = explode('.', $domain);
- $domainSuffix = end($domain); // 取得域名后缀
- if(!in_array($domainSuffix, \config('domains'))){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '绑定域名不合法']);
- }
- }
- if($request->input('v2_alter_id') <= 0 || $request->input('v2_alter_id') >= 65535){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败:AlterId不合法']);
- }
- DB::beginTransaction();
- try{
- $data = [
- 'type' => $request->input('type'),
- 'name' => $request->input('name'),
- 'group_id' => $request->input('group_id')? $request->input('group_id') : 0,
- 'country_code' => $request->input('country_code'),
- 'server' => $request->input('server'),
- 'ip' => $request->input('ip'),
- 'ipv6' => $request->input('ipv6'),
- 'desc' => $request->input('desc'),
- 'method' => $request->input('method'),
- 'protocol' => $request->input('protocol'),
- 'protocol_param' => $request->input('protocol_param'),
- 'obfs' => $request->input('obfs'),
- 'obfs_param' => $request->input('obfs_param'),
- 'traffic_rate' => $request->input('traffic_rate'),
- 'bandwidth' => $request->input('bandwidth')? $request->input('bandwidth') : 1000,
- 'traffic' => $request->input('traffic')? $request->input('traffic') : 1000,
- 'monitor_url' => $request->input('monitor_url')? $request->input('monitor_url') : '',
- 'is_subscribe' => $request->input('is_subscribe'),
- 'is_ddns' => $request->input('is_ddns'),
- 'is_transit' => $request->input('is_transit'),
- 'ssh_port' => $request->input('ssh_port'),
- 'detectionType' => $request->input('detectionType'),
- 'compatible' => $request->input('type') == 2? 0 : ($request->input('is_ddns')? 0 : $request->input('compatible')),
- 'single' => $request->input('single'),
- 'port' => $request->input('single')? ($request->input('port')? $request->input('port') : 443) : '',
- 'passwd' => $request->input('single')? ($request->input('passwd')? $request->input('passwd') : 'password') : '',
- 'sort' => $request->input('sort'), 'status' => $request->input('status'),
- 'v2_alter_id' => $request->input('v2_alter_id')? $request->input('v2_alter_id') : 16,
- 'v2_port' => $request->input('v2_port')? $request->input('v2_port') : 10087,
- 'v2_method' => $request->input('v2_method')? $request->input('v2_method') : 'aes-128-gcm',
- 'v2_net' => $request->input('v2_net'), 'v2_type' => $request->input('v2_type'),
- 'v2_host' => $request->input('v2_host'), 'v2_path' => $request->input('v2_path'),
- 'v2_tls' => $request->input('v2_tls'),
- 'v2_insider_port' => $request->input('v2_insider_port', 10550),
- 'v2_outsider_port' => $request->input('v2_outsider_port', 443)
- ];
- SsNode::query()->where('id', $id)->update($data);
- // 建立分组关联
- if($request->input('group_id')){
- // 先删除该节点所有关联
- SsGroupNode::query()->where('node_id', $id)->delete();
- // 建立关联
- $ssGroupNode = new SsGroupNode();
- $ssGroupNode->group_id = $request->input('group_id');
- $ssGroupNode->node_id = $id;
- $ssGroupNode->save();
- }
- // 生成节点标签
- $this->makeNodeLabels($id, $request->input('labels'));
- // TODO:更新节点绑定的域名DNS(将节点IP更新到域名DNS 的A记录)
- DB::commit();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
- } catch(Exception $e){
- DB::rollBack();
- Log::error('编辑节点信息异常:'.$e->getMessage());
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败:'.$e->getMessage()]);
- }
- }else{
- $node = SsNode::query()->with(['label'])->where('id', $id)->first();
- if($node){
- $labels = [];
- foreach($node->label as $vo){
- $labels[] = $vo->label_id;
- }
- $node->labels = $labels;
- }
- $view['node'] = $node;
- $view['method_list'] = Helpers::methodList();
- $view['protocol_list'] = Helpers::protocolList();
- $view['obfs_list'] = Helpers::obfsList();
- $view['level_list'] = Helpers::levelList();
- $view['group_list'] = SsGroup::query()->get();
- $view['country_list'] = Country::query()->orderBy('code', 'asc')->get();
- $view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
- return Response::view('admin.editNode', $view);
- }
- }
- // 删除节点
- public function delNode(Request $request)
- {
- $id = $request->input('id');
- $node = SsNode::query()->where('id', $id)->first();
- if(!$node){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '节点不存在,请重试']);
- }
- DB::beginTransaction();
- try{
- // 删除分组关联、节点标签、节点相关日志
- SsNode::query()->where('id', $id)->delete();
- SsGroupNode::query()->where('node_id', $id)->delete();
- SsNodeLabel::query()->where('node_id', $id)->delete();
- SsNodeInfo::query()->where('node_id', $id)->delete();
- SsNodeOnlineLog::query()->where('node_id', $id)->delete();
- SsNodeTrafficDaily::query()->where('node_id', $id)->delete();
- SsNodeTrafficHourly::query()->where('node_id', $id)->delete();
- UserTrafficDaily::query()->where('node_id', $id)->delete();
- UserTrafficHourly::query()->where('node_id', $id)->delete();
- UserTrafficLog::query()->where('node_id', $id)->delete();
- DB::commit();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
- } catch(Exception $e){
- DB::rollBack();
- Log::error('删除节点信息异常:'.$e->getMessage());
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败:'.$e->getMessage()]);
- }
- }
- // 节点流量监控
- public function nodeMonitor(Request $request, $node_id)
- {
- $node = SsNode::query()->where('id', $node_id)->orderBy('sort', 'desc')->first();
- if(!$node){
- Session::flash('errorMsg', '节点不存在,请重试');
- return Redirect::back();
- }
- // 查看流量
- $dailyData = [];
- $hourlyData = [];
- // 节点一个月内的流量
- $nodeTrafficDaily = SsNodeTrafficDaily::query()->with(['info'])->where('node_id', $node->id)->where('created_at', '>=', date('Y-m', time()))->orderBy('created_at', 'asc')->pluck('total')->toArray();
- $dailyTotal = date('d', time())-1;//今天不算,减一
- $dailyCount = count($nodeTrafficDaily);
- for($x = 0; $x < ($dailyTotal-$dailyCount); $x++){
- $dailyData[$x] = 0;
- }
- for($x = ($dailyTotal-$dailyCount); $x < $dailyTotal; $x++){
- $dailyData[$x] = round($nodeTrafficDaily[$x-($dailyTotal-$dailyCount)]/(1024*1024*1024), 3);
- }
- // 节点一天内的流量
- $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();
- $hourlyTotal = date('H', time());
- $hourlyCount = count($nodeTrafficHourly);
- for($x = 0; $x < ($hourlyTotal-$hourlyCount); $x++){
- $hourlyData[$x] = 0;
- }
- for($x = ($hourlyTotal-$hourlyCount); $x < $hourlyTotal; $x++){
- $hourlyData[$x] = round($nodeTrafficHourly[$x-($hourlyTotal-$hourlyCount)]/(1024*1024*1024), 3);
- }
- $view['trafficDaily'] = ['nodeName' => $node->name, 'dailyData' => "'".implode("','", $dailyData)."'"];
- $view['trafficHourly'] = ['nodeName' => $node->name, 'hourlyData' => "'".implode("','", $hourlyData)."'"];
- // 本月天数数据
- $monthDays = [];
- for($i = 1; $i <= date("d"); $i++){
- $monthDays[] = $i;
- }
- // 本日小时数据
- $dayHours = [];
- for($i = 1; $i <= date("H"); $i++){
- $dayHours[] = $i;
- }
- $view['nodeName'] = $node->name;
- $view['nodeServer'] = $node->server;
- $view['monthDays'] = "'".implode("','", $monthDays)."'";
- $view['dayHours'] = "'".implode("','", $dayHours)."'";
- return Response::view('admin.nodeMonitor', $view);
- }
- // 文章列表
- public function articleList(Request $request)
- {
- $view['list'] = Article::query()->orderBy('sort', 'desc')->paginate(15)->appends($request->except('page'));
- return Response::view('admin.articleList', $view);
- }
- // 添加文章
- public function addArticle(Request $request)
- {
- if($request->isMethod('POST')){
- $article = new Article();
- $article->title = $request->input('title');
- $article->type = $request->input('type', 1);
- $article->author = '管理员';
- $article->summary = $request->input('summary');
- // LOGO
- if($article->type == 4){
- $article->logo = $request->input('logo');
- }else{
- $logo = '';
- if($request->hasFile('logo')){
- $file = $request->file('logo');
- $fileType = $file->getClientOriginalExtension();
- // 验证文件合法性
- if(!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])){
- Session::flash('errorMsg', 'LOGO不合法');
- return Redirect::back()->withInput();
- }
- $logoName = date('YmdHis').mt_rand(1000, 2000).'.'.$fileType;
- $move = $file->move(base_path().'/public/upload/image/', $logoName);
- $logo = $move? '/upload/image/'.$logoName : '';
- }
- $article = new Article();
- $article->title = $request->input('title');
- $article->type = $request->input('type', 1);
- $article->author = '管理员';
- $article->summary = $request->input('summary');
- $article->logo = $logo;
- }
- $article->content = $request->input('content');
- $article->sort = $request->input('sort', 0);
- $article->save();
- if($article->id){
- Session::flash('successMsg', '添加成功');
- }else{
- Session::flash('errorMsg', '添加失败');
- }
- return Redirect::to('admin/articleList');
- }else{
- return Response::view('admin.addArticle');
- }
- }
- // 编辑文章
- public function editArticle(Request $request)
- {
- $id = $request->input('id');
- if($request->isMethod('POST')){
- $title = $request->input('title');
- $type = $request->input('type');
- $summary = $request->input('summary');
- $content = $request->input('content');
- $sort = $request->input('sort');
- // 商品LOGO
- if($type == 4){
- $logo = $request->input('logo');
- }else{
- $logo = '';
- if($request->hasFile('logo')){
- $file = $request->file('logo');
- $fileType = $file->getClientOriginalExtension();
- // 验证文件合法性
- if(!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])){
- Session::flash('errorMsg', 'LOGO不合法');
- return Redirect::back()->withInput();
- }
- $logoName = date('YmdHis').mt_rand(1000, 2000).'.'.$fileType;
- $move = $file->move(base_path().'/public/upload/image/', $logoName);
- $logo = $move? '/upload/image/'.$logoName : '';
- }
- }
- $data = ['type' => $type, 'title' => $title, 'summary' => $summary, 'content' => $content, 'sort' => $sort];
- if($logo){
- $data['logo'] = $logo;
- }
- $ret = Article::query()->where('id', $id)->update($data);
- if($ret){
- Session::flash('successMsg', '编辑成功');
- }else{
- Session::flash('errorMsg', '编辑失败');
- }
- return Redirect::to('admin/editArticle?id='.$id);
- }else{
- $view['article'] = Article::query()->where('id', $id)->first();
- return Response::view('admin.editArticle', $view);
- }
- }
- // 删除文章
- public function delArticle(Request $request)
- {
- $id = $request->input('id');
- $ret = Article::query()->where('id', $id)->delete();
- if($ret){
- return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
- }else{
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
- }
- }
- // 节点分组列表
- public function groupList(Request $request)
- {
- $view['groupList'] = SsGroup::query()->paginate(15)->appends($request->except('page'));
- $levelList = Helpers::levelList();
- $levelMap = [];
- foreach($levelList as $vo){
- $levelMap[$vo['level']] = $vo['level_name'];
- }
- $view['levelMap'] = $levelMap;
- return Response::view('admin.groupList', $view);
- }
- // 添加节点分组
- public function addGroup(Request $request)
- {
- if($request->isMethod('POST')){
- $ssGroup = new SsGroup();
- $ssGroup->name = $request->input('name');
- $ssGroup->level = $request->input('level');
- $ssGroup->save();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
- }else{
- $view['levelList'] = Helpers::levelList();
- return Response::view('admin.addGroup', $view);
- }
- }
- // 编辑节点分组
- public function editGroup(Request $request, $id)
- {
- if($request->isMethod('POST')){
- $name = $request->input('name');
- $level = $request->input('level');
- $data = ['name' => $name, 'level' => $level];
- $ret = SsGroup::query()->where('id', $id)->update($data);
- if($ret){
- return Response::json(['status' => 'success', 'data' => '', 'message' => '编辑成功']);
- }else{
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '编辑失败']);
- }
- }else{
- $view['group'] = SsGroup::query()->where('id', $id)->first();
- $view['levelList'] = Helpers::levelList();
- return Response::view('admin.editGroup', $view);
- }
- }
- // 删除节点分组
- public function delGroup(Request $request)
- {
- $id = $request->input('id');
- // 检查是否该分组下是否有节点
- $ssGroupNodeCount = SsGroupNode::query()->where('group_id', $id)->count();
- if($ssGroupNodeCount){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败:该分组下有节点关联,请先解除关联']);
- }
- $ret = SsGroup::query()->where('id', $id)->delete();
- if($ret){
- return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
- }else{
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
- }
- }
- // 流量日志
- public function trafficLog(Request $request)
- {
- $port = $request->input('port');
- $user_id = $request->input('user_id');
- $username = $request->input('username');
- $nodeId = $request->input('nodeId');
- $query = UserTrafficLog::query()->with(['user', 'node']);
- if(isset($port)){
- $query->whereHas('user', function($q) use ($port){
- $q->where('port', $port);
- });
- }
- if(isset($user_id)){
- $query->where('user_id', $user_id);
- }
- if(isset($username)){
- $query->whereHas('user', function($q) use ($username){
- $q->where('username', 'like', '%'.$username.'%');
- });
- }
- if(isset($nodeId)){
- $query->where('node_id', $nodeId);
- }
- // 已使用流量
- $view['totalTraffic'] = flowAutoShow($query->sum('u')+$query->sum('d'));
- $list = $query->orderBy('id', 'desc')->paginate(20)->appends($request->except('page'));
- foreach($list as $vo){
- $vo->u = flowAutoShow($vo->u);
- $vo->d = flowAutoShow($vo->d);
- $vo->log_time = date('Y-m-d H:i:s', $vo->log_time);
- }
- $view['list'] = $list;
- $view['nodeList'] = SsNode::query()->where('status', 1)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get();
- return Response::view('admin.trafficLog', $view);
- }
- // SS(R)链接反解析
- public function decompile(Request $request)
- {
- if($request->isMethod('POST')){
- $content = $request->input('content');
- if(empty($content)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '请在左侧填入要反解析的SS(R)链接']);
- }
- // 反解析处理
- $content = str_replace("\n", ",", $content);
- $content = explode(',', $content);
- $txt = '';
- foreach($content as $item){
- // 判断是SS还是SSR链接
- $str = '';
- if(FALSE !== strpos($item, 'ssr://')){
- $str = mb_substr($item, 6);
- }elseif(FALSE !== strpos($item, 'ss://')){
- $str = mb_substr($item, 5);
- }
- $txt .= "\r\n".base64url_decode($str);
- }
- // 生成转换好的JSON文件
- file_put_contents(public_path('downloads/decompile.json'), $txt);
- return Response::json(['status' => 'success', 'data' => $txt, 'message' => '反解析成功']);
- }else{
- return Response::view('admin.decompile');
- }
- }
- // 格式转换(SS转SSR)
- public function convert(Request $request)
- {
- if($request->isMethod('POST')){
- $method = $request->input('method');
- $transfer_enable = $request->input('transfer_enable');
- $protocol = $request->input('protocol');
- $protocol_param = $request->input('protocol_param');
- $obfs = $request->input('obfs');
- $obfs_param = $request->input('obfs_param');
- $content = $request->input('content');
- if(empty($content)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '请在左侧填入要转换的内容']);
- }
- // 校验格式
- $content = json_decode($content);
- if(empty($content->port_password)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '转换失败:配置信息里缺少【port_password】字段,或者该字段为空']);
- }
- // 转换成SSR格式JSON
- $data = [];
- foreach($content->port_password as $port => $passwd){
- $data[] = ['d' => 0, 'enable' => 1, 'method' => $method, 'obfs' => $obfs, 'obfs_param' => empty($obfs_param)? "" : $obfs_param, 'passwd' => $passwd, 'port' => $port, 'protocol' => $protocol, 'protocol_param' => empty($protocol_param)? "" : $protocol_param, 'transfer_enable' => toGB($transfer_enable), 'u' => 0, 'user' => date('Ymd').'_IMPORT_'.$port,];
- }
- $json = json_encode($data);
- // 生成转换好的JSON文件
- file_put_contents(public_path('downloads/convert.json'), $json);
- return Response::json(['status' => 'success', 'data' => $json, 'message' => '转换成功']);
- }else{
- // 加密方式、协议、混淆
- $view['method_list'] = Helpers::methodList();
- $view['protocol_list'] = Helpers::protocolList();
- $view['obfs_list'] = Helpers::obfsList();
- return Response::view('admin.convert', $view);
- }
- }
- // 下载转换好的JSON文件
- public function download(Request $request)
- {
- $type = $request->input('type');
- if(empty($type)){
- exit('参数异常');
- }
- if($type == '1'){
- $filePath = public_path('downloads/convert.json');
- }else{
- $filePath = public_path('downloads/decompile.json');
- }
- if(!file_exists($filePath)){
- exit('文件不存在,请检查目录权限');
- }
- return Response::download($filePath);
- }
- // 数据导入
- public function import(Request $request)
- {
- if($request->isMethod('POST')){
- if(!$request->hasFile('uploadFile')){
- Session::flash('errorMsg', '请选择要上传的文件');
- return Redirect::back();
- }
- $file = $request->file('uploadFile');
- // 只能上传JSON文件
- if($file->getClientMimeType() != 'application/json' || $file->getClientOriginalExtension() != 'json'){
- Session::flash('errorMsg', '只允许上传JSON文件');
- return Redirect::back();
- }
- if(!$file->isValid()){
- Session::flash('errorMsg', '产生未知错误,请重新上传');
- return Redirect::back();
- }
- $save_path = realpath(storage_path('uploads'));
- $new_name = md5($file->getClientOriginalExtension()).'.json';
- $file->move($save_path, $new_name);
- // 读取文件内容
- $data = file_get_contents($save_path.'/'.$new_name);
- $data = json_decode($data);
- if(!$data){
- Session::flash('errorMsg', '内容格式解析异常,请上传符合SSR(R)配置规范的JSON文件');
- return Redirect::back();
- }
- DB::beginTransaction();
- try{
- foreach($data as $user){
- $obj = new User();
- $obj->username = $user->user;
- $obj->password = Hash::make('123456');
- $obj->port = $user->port;
- $obj->passwd = $user->passwd;
- $obj->vmess_id = $user->vmess_id;
- $obj->transfer_enable = $user->transfer_enable;
- $obj->u = 0;
- $obj->d = 0;
- $obj->t = 0;
- $obj->enable = 1;
- $obj->method = $user->method;
- $obj->protocol = $user->protocol;
- $obj->protocol_param = $user->protocol_param;
- $obj->obfs = $user->obfs;
- $obj->obfs_param = $user->obfs_param;
- $obj->speed_limit_per_con = 204800;
- $obj->speed_limit_per_user = 204800;
- $obj->wechat = '';
- $obj->qq = '';
- $obj->usage = 1;
- $obj->pay_way = 3;
- $obj->balance = 0;
- $obj->enable_time = date('Y-m-d');
- $obj->expire_time = '2099-01-01';
- $obj->remark = '';
- $obj->is_admin = 0;
- $obj->reg_ip = getClientIp();
- $obj->created_at = date('Y-m-d H:i:s');
- $obj->updated_at = date('Y-m-d H:i:s');
- $obj->save();
- }
- DB::commit();
- } catch(Exception $e){
- DB::rollBack();
- Session::flash('errorMsg', '出错了,可能是导入的配置中有端口已经存在了');
- return Redirect::back();
- }
- Session::flash('successMsg', '导入成功');
- return Redirect::back();
- }else{
- return Response::view('admin.import');
- }
- }
- // 导出配置信息
- public function export(Request $request, $id)
- {
- if(empty($id)){
- return Redirect::to('admin/userList');
- }
- $user = User::query()->where('id', $id)->first();
- if(empty($user)){
- return Redirect::to('admin/userList');
- }
- $nodeList = SsNode::query()->where('status', 1)->orderBy('sort', 'desc')->orderBy('id', 'asc')->paginate(15)->appends($request->except('page'));
- foreach($nodeList as $node){
- // 获取分组名称
- $group = SsGroup::query()->where('id', $node->group_id)->first();
- $host = $node->server? : $node->ip;
- if($node->type == 1){
- $obfs_param = $user->obfs_param? : $node->obfs_param;
- $group = empty($group)? Helpers::systemConfig()['website_name'] : $group->name;
- if($node->single){
- $port = $node->port;
- $protocol = $node->protocol;
- $method = $node->method;
- $obfs = $node->obfs;
- $passwd = $node->passwd;
- $protocol_param = $user->port.':'.$user->passwd;
- }else{
- $port = $user->port;
- $protocol = $user->protocol;
- $method = $user->method;
- $obfs = $user->obfs;
- $passwd = $user->passwd;
- $protocol_param = $user->protocol_param;
- }
- // 生成ssr scheme
- $node->ssr_scheme = 'ssr://'.base64url_encode($host.':'.$port.':'.$protocol.':'.$method.':'.$obfs.':'.base64url_encode($passwd).'/?obfsparam='.base64url_encode($obfs_param).'&protoparam='.base64url_encode($protocol_param).'&remarks='.base64url_encode($node->name).'&group='.base64url_encode($group).'&udpport=0&uot=0');
- // 生成ss scheme
- $node->ss_scheme = $node->compatible? 'ss://'.base64url_encode($user->method.':'.$user->passwd.'@'.$host.':'.$user->port).'#'.$group : '';
- // 生成文本配置信息
- $node->txt = "服务器:".$host."\r\n".
- $node->ipv6? "IPv6:".$node->ipv6."\r\n" : ''.
- "远程端口:".$port."\r\n".
- "密码:".$passwd."\r\n".
- "加密方法:".$method."\r\n".
- "路由:绕过局域网及中国大陆地址"."\r\n".
- "协议:".$protocol."\r\n".
- "协议参数:".$protocol_param."\r\n".
- "混淆方式:".$obfs."\r\n".
- "混淆参数:".$obfs_param."\r\n".
- "本地端口:1080"."\r\n";
- }else{
- // 生成v2ray scheme
- $node->v2_scheme = 'vmess://'.base64url_encode(json_encode([
- "v" => "2",
- "ps" => $node->name,
- "add" => $node->server? : $node->ip,
- "port" => $node->v2_port,
- "id" => $user->vmess_id,
- "aid" => $node->v2_alter_id,
- "net" => $node->v2_net,
- "type" => $node->v2_type,
- "host" => $node->v2_host,
- "path" => $node->v2_path,
- "tls" => $node->v2_tls? "tls" : ""
- ], JSON_PRETTY_PRINT));
- // 生成文本配置信息
- $node->txt =
- "服务器:".$node->server? : $node->ip."\r\n".
- $node->ipv6? "IPv6:".$node->ipv6."\r\n" : ''.
- "端口:".$node->v2_port."\r\n".
- "加密方式:".$node->v2_method."\r\n".
- "用户ID:".$user->vmess_id."\r\n".
- "额外ID:".$node->v2_alter_id."\r\n".
- "传输协议:".$node->v2_net."\r\n".
- "伪装类型:".$node->v2_type."\r\n".
- ($node->v2_host? "伪装域名:".$node->v2_host."\r\n" : "").
- ($node->v2_path? "路径:".$node->v2_path."\r\n" : "").
- ($node->v2_tls == 1? "TLS:tls\r\n" : "");
- }
- }
- $view['nodeList'] = $nodeList;
- $view['user'] = $user;
- return Response::view('admin.export', $view);
- }
- // 导出原版SS用户配置信息
- public function exportSSJson(Request $request)
- {
- $userList = User::query()->where('port', '>', 0)->get();
- $defaultMethod = Helpers::getDefaultMethod();
- $json = '';
- if(!$userList->isEmpty()){
- $tmp = [];
- foreach($userList as $key => $user){
- $tmp[] = '"'.$user->port.'":"'.$user->passwd.'"';
- }
- $userPassword = implode(",\n\t\t", $tmp);
- $json = <<<EOF
- {
- "server":"0.0.0.0",
- "local_address":"127.0.0.1",
- "local_port":1080,
- "port_password":{
- {$userPassword}
- },
- "timeout":300,
- "method":"{$defaultMethod}",
- "fast_open":false
- }
- EOF;
- }
- // 生成JSON文件
- $fileName = makeRandStr('16').'_shadowsocks.json';
- $filePath = public_path('downloads/'.$fileName);
- file_put_contents($filePath, $json);
- if(!file_exists($filePath)){
- exit('文件生成失败,请检查目录权限');
- }
- return Response::download($filePath);
- }
- // 修改个人资料
- public function profile(Request $request)
- {
- if($request->isMethod('POST')){
- $old_password = trim($request->input('old_password'));
- $new_password = trim($request->input('new_password'));
- if(!Hash::check($old_password, Auth::user()->password)){
- return Redirect::back()->withErrors('旧密码错误,请重新输入');
- }elseif(Hash::check($new_password, Auth::user()->password)){
- return Redirect::back()->withErrors('新密码不可与旧密码一样,请重新输入');
- }
- $ret = User::uid()->update(['password' => Hash::make($new_password)]);
- if(!$ret){
- return Redirect::back()->withErrors('修改失败');
- }else{
- return Redirect::back()->with('successMsg', '修改成功');
- }
- }else{
- return Response::view('admin.profile');
- }
- }
- // 用户流量监控
- public function userMonitor(Request $request, $id)
- {
- if(empty($id)){
- return Redirect::to('admin/userList');
- }
- $user = User::query()->where('id', $id)->first();
- if(empty($user)){
- return Redirect::to('admin/userList');
- }
- // 30天内的流量
- $dailyData = [];
- $hourlyData = [];
- // 节点一个月内的流量
- $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();
- $dailyTotal = date('d')-1; // 今天不算,减一
- $dailyCount = count($userTrafficDaily);
- for($x = 0; $x < $dailyTotal-$dailyCount; $x++){
- $dailyData[$x] = 0;
- }
- for($x = $dailyTotal-$dailyCount; $x < $dailyTotal; $x++){
- $dailyData[$x] = round($userTrafficDaily[$x-($dailyTotal-$dailyCount)]/(1024*1024*1024), 3);
- }
- // 节点一天内的流量
- $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();
- $hourlyTotal = date('H');
- $hourlyCount = count($userTrafficHourly);
- for($x = 0; $x < $hourlyTotal-$hourlyCount; $x++){
- $hourlyData[$x] = 0;
- }
- for($x = ($hourlyTotal-$hourlyCount); $x < $hourlyTotal; $x++){
- $hourlyData[$x] = round($userTrafficHourly[$x-($hourlyTotal-$hourlyCount)]/(1024*1024*1024), 3);
- }
- // 本月天数数据
- $monthDays = [];
- for($i = 1; $i <= date("d"); $i++){
- $monthDays[] = $i;
- }
- // 本日小时数据
- $dayHours = [];
- for($i = 1; $i <= date("H"); $i++){
- $dayHours[] = $i;
- }
- $view['trafficDaily'] = "'".implode("','", $dailyData)."'";
- $view['trafficHourly'] = "'".implode("','", $hourlyData)."'";
- $view['monthDays'] = "'".implode("','", $monthDays)."'";
- $view['dayHours'] = "'".implode("','", $dayHours)."'";
- $view['username'] = $user->username;
- return Response::view('admin.userMonitor', $view);
- }
- // 生成端口
- public function makePort(Request $request)
- {
- $new_port = self::$systemConfig['is_rand_port']? Helpers::getRandPort() : Helpers::getOnlyPort();
- echo $new_port;
- exit;
- }
- // 加密方式、混淆、协议、等级、国家地区
- public function config(Request $request)
- {
- if($request->isMethod('POST')){
- $name = $request->input('name');
- $type = $request->input('type', 1); // 类型:1-加密方式(method)、2-协议(protocol)、3-混淆(obfs)
- $is_default = $request->input('is_default', 0);
- $sort = $request->input('sort', 0);
- if(empty($name)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置名称不能为空']);
- }
- // 校验是否已存在
- $config = SsConfig::type($type)->where('name', $name)->first();
- if($config){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置已经存在,请勿重复添加']);
- }
- $ssConfig = new SsConfig();
- $ssConfig->name = $name;
- $ssConfig->type = $type;
- $ssConfig->is_default = $is_default;
- $ssConfig->sort = $sort;
- $ssConfig->save();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
- }else{
- $view['method_list'] = SsConfig::type(1)->get();
- $view['protocol_list'] = SsConfig::type(2)->get();
- $view['obfs_list'] = SsConfig::type(3)->get();
- $view['level_list'] = Helpers::levelList();
- $view['country_list'] = Country::query()->get();
- return Response::view('admin.config', $view);
- }
- }
- // 删除配置
- public function delConfig(Request $request)
- {
- $id = $request->input('id');
- $ret = SsConfig::query()->where('id', $id)->delete();
- if($ret){
- return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
- }else{
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败']);
- }
- }
- // 设置默认配置
- public function setDefaultConfig(Request $request)
- {
- $id = $request->input('id');
- if(empty($id)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '非法请求']);
- }
- $config = SsConfig::query()->where('id', $id)->first();
- if(!$config){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '配置不存在']);
- }
- // 去除该配置所属类型的默认值
- SsConfig::default()->type($config->type)->update(['is_default' => 0]);
- // 将该ID对应记录值置为默认值
- SsConfig::query()->where('id', $id)->update(['is_default' => 1]);
- return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
- }
- // 设置系统扩展信息,例如客服、统计代码
- public function setExtend(Request $request)
- {
- $websiteAnalytics = $request->input('website_analytics');
- $websiteCustomerService = $request->input('website_customer_service');
- DB::beginTransaction();
- try{
- // 首页LOGO
- if($request->hasFile('website_home_logo')){
- $file = $request->file('website_home_logo');
- $fileType = $file->getClientOriginalExtension();
- // 验证文件合法性
- if(!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])){
- Session::flash('errorMsg', 'LOGO不合法');
- return Redirect::back();
- }
- $logoName = date('YmdHis').mt_rand(1000, 2000).'.'.$fileType;
- $move = $file->move(base_path().'/public/upload/image/', $logoName);
- $websiteHomeLogo = $move? '/upload/image/'.$logoName : '';
- Config::query()->where('name', 'website_home_logo')->update(['value' => $websiteHomeLogo]);
- }
- // 站内LOGO
- if($request->hasFile('website_logo')){
- $file = $request->file('website_logo');
- $fileType = $file->getClientOriginalExtension();
- // 验证文件合法性
- if(!in_array($fileType, ['jpg', 'png', 'jpeg', 'bmp'])){
- Session::flash('errorMsg', 'LOGO不合法');
- return Redirect::back();
- }
- $logoName = date('YmdHis').mt_rand(1000, 2000).'.'.$fileType;
- $move = $file->move(base_path().'/public/upload/image/', $logoName);
- $websiteLogo = $move? '/upload/image/'.$logoName : '';
- Config::query()->where('name', 'website_logo')->update(['value' => $websiteLogo]);
- }
- Config::query()->where('name', 'website_analytics')->update(['value' => $websiteAnalytics]);
- Config::query()->where('name', 'website_customer_service')->update(['value' => $websiteCustomerService]);
- Session::flash('successMsg', '更新成功');
- DB::commit();
- return Redirect::back();
- } catch(Exception $e){
- DB::rollBack();
- Session::flash('errorMsg', '更新失败');
- return Redirect::back();
- }
- }
- // 日志分析
- public function analysis(Request $request)
- {
- $file = storage_path('app/ssserver.log');
- if(!file_exists($file)){
- Session::flash('analysisErrorMsg', $file.' 不存在,请先创建文件');
- return Response::view('admin.analysis');
- }
- $logs = $this->tail($file, 10000);
- if(FALSE === $logs){
- $view['urlList'] = [];
- }else{
- $url = [];
- foreach($logs as $log){
- if(strpos($log, 'TCP connecting')){
- continue;
- }
- preg_match('/TCP request (\w+\.){2}\w+/', $log, $tcp_matches);
- if(!empty($tcp_matches)){
- $url[] = str_replace('TCP request ', '[TCP] ', $tcp_matches[0]);
- }else{
- 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);
- if(!empty($udp_matches)){
- $url[] = str_replace('UDP data to ', '[UDP] ', $udp_matches[0]);
- }
- }
- }
- $view['urlList'] = array_unique($url);
- }
- return Response::view('admin.analysis', $view);
- }
- // 添加等级
- public function addLevel(Request $request)
- {
- $level = $request->input('level');
- $level_name = trim($request->input('level_name'));
- if(empty($level)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不能为空']);
- }
- if(empty($level_name)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级名称不能为空']);
- }
- $exists = Level::query()->where('level', $level)->first();
- if($exists){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级已存在,请勿重复添加']);
- }
- $obj = new Level();
- $obj->level = $level;
- $obj->level_name = $level_name;
- $obj->save();
- if($obj->id){
- return Response::json(['status' => 'success', 'data' => '', 'message' => '提交成功']);
- }else{
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
- }
- }
- // 编辑等级
- public function updateLevel(Request $request)
- {
- $id = $request->input('id');
- $level = $request->input('level');
- $level_name = $request->input('level_name');
- if(!$id){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
- }
- if(!$level){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不能为空']);
- }
- if(!$level_name){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级名称不能为空']);
- }
- $le = Level::query()->where('id', $id)->first();
- if(!$le){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不存在']);
- }
- // 校验该等级下是否存在关联分组
- $ssGroupCount = SsGroup::query()->where('level', $le->level)->count();
- if($ssGroupCount){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联分组,请先取消关联']);
- }
- // 校验该等级下是否存在关联账号
- $userCount = User::query()->where('level', $le->level)->count();
- if($userCount){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联账号,请先取消关联']);
- }
- Level::query()->where('id', $id)->update(['level' => $level, 'level_name' => $level_name]);
- return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
- }
- // 删除等级
- public function delLevel(Request $request)
- {
- $id = $request->input('id');
- if(empty($id)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
- }
- $level = Level::query()->where('id', $id)->first();
- if(empty($level)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '等级不存在']);
- }
- // 校验该等级下是否存在关联分组
- $existGroups = SsGroup::query()->where('level', $level->level)->get();
- if(!$existGroups->isEmpty()){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联分组,请先取消关联']);
- }
- // 校验该等级下是否存在关联账号
- $existUsers = User::query()->where('level', $level->level)->get();
- if(!$existUsers->isEmpty()){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '该等级下存在关联账号,请先取消关联']);
- }
- $ret = Level::query()->where('id', $id)->delete();
- if($ret){
- return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
- }else{
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
- }
- }
- // 添加国家/地区
- public function addCountry(Request $request)
- {
- $name = $request->input('country_name');
- $code = $request->input('country_code');
- if(empty($name)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区名称不能为空']);
- }
- if(empty($code)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区代码不能为空']);
- }
- $exists = Country::query()->where('name', $name)->first();
- if($exists){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '该国家/地区名称已存在,请勿重复添加']);
- }
- $obj = new Country();
- $obj->name = $name;
- $obj->code = $code;
- $obj->save();
- if($obj->id){
- return Response::json(['status' => 'success', 'data' => '', 'message' => '提交成功']);
- }else{
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
- }
- }
- // 编辑国家/地区
- public function updateCountry(Request $request)
- {
- $id = $request->input('id');
- $name = $request->input('country_name');
- $code = $request->input('country_code');
- if(empty($id)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
- }
- if(empty($name)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区名称不能为空']);
- }
- if(empty($code)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区代码不能为空']);
- }
- $country = Country::query()->where('id', $id)->first();
- if(empty($country)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区不存在']);
- }
- // 校验该国家/地区下是否存在关联节点
- $existNode = SsNode::query()->where('country_code', $country->code)->get();
- if(!$existNode->isEmpty()){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '该国家/地区下存在关联节点,请先取消关联']);
- }
- $ret = Country::query()->where('id', $id)->update(['name' => $name, 'code' => $code]);
- if($ret){
- return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
- }else{
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
- }
- }
- // 删除国家/地区
- public function delCountry(Request $request)
- {
- $id = $request->input('id');
- if(empty($id)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => 'ID不能为空']);
- }
- $country = Country::query()->where('id', $id)->first();
- if(empty($country)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '国家/地区不存在']);
- }
- // 校验该国家/地区下是否存在关联节点
- $existNode = SsNode::query()->where('country_code', $country->code)->get();
- if(!$existNode->isEmpty()){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '该国家/地区下存在关联节点,请先取消关联']);
- }
- $ret = Country::query()->where('id', $id)->delete();
- if($ret){
- return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
- }else{
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '操作失败']);
- }
- }
- // 系统设置
- public function system(Request $request)
- {
- $view = Helpers::systemConfig();
- $view['label_list'] = Label::query()->orderBy('sort', 'desc')->orderBy('id', 'asc')->get();
- return Response::view('admin.system', $view);
- }
- // 设置某个配置项
- public function setConfig(Request $request)
- {
- $name = trim($request->input('name'));
- $value = trim($request->input('value'));
- if(!$name){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '设置失败:请求参数异常']);
- }
- // 屏蔽异常配置
- if(!array_key_exists($name, self::$systemConfig)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '设置失败:配置不存在']);
- }
- // 如果开启用户邮件重置密码,则先设置网站名称和网址
- if(in_array($name, ['is_reset_password', 'is_active_register']) && $value == '1'){
- $config = Config::query()->where('name', 'website_name')->first();
- if($config->value == ''){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '设置失败:启用该配置需要先设置【网站名称】']);
- }
- $config = Config::query()->where('name', 'website_url')->first();
- if($config->value == ''){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '设置失败:启用该配置需要先设置【网站地址】']);
- }
- }
- // 演示环境禁止修改特定配置项
- if(env('APP_DEMO')){
- $denyConfig = ['website_url', 'min_rand_traffic', 'max_rand_traffic', 'push_bear_send_key', 'push_bear_qrcode', 'is_forbid_china', 'alipay_partner', 'alipay_key', 'alipay_transport', 'alipay_sign_type', 'alipay_private_key', 'alipay_public_key', 'website_security_code'];
- if(in_array($name, $denyConfig)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '演示环境禁止修改该配置']);
- }
- }
- // 如果是返利比例,则需要除100
- if(in_array($name, ['referral_percent'])){
- $value = intval($value)/100;
- }
- // 用支付国际则不可用支付宝当面付
- if(in_array($name, ['is_alipay'])){
- $is_f2fpay = Config::query()->where('name', 'is_f2fpay')->first();
- if($is_f2fpay->value){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '已经在使用【支付宝当面付】']);
- }
- }
- // 用支付宝当面则不可用支付宝国际
- if(in_array($name, ['is_f2fpay'])){
- $is_alipay = Config::query()->where('name', 'is_alipay')->first();
- if($is_alipay->value){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '已经在使用【支付宝国际支付】']);
- }
- }
- // 更新配置
- Config::query()->where('name', $name)->update(['value' => $value]);
- return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
- }
- // 邀请码列表
- public function inviteList(Request $request)
- {
- $view['inviteList'] = Invite::query()->with(['generator', 'user'])->orderBy('status', 'asc')->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));
- return Response::view('admin.inviteList', $view);
- }
- // 生成邀请码
- public function makeInvite(Request $request)
- {
- for($i = 0; $i < 10; $i++){
- $obj = new Invite();
- $obj->uid = 0;
- $obj->fuid = 0;
- $obj->code = strtoupper(substr(md5(microtime().makeRandStr()), 8, 12));
- $obj->status = 0;
- $obj->dateline = date('Y-m-d H:i:s', strtotime("+".self::$systemConfig['admin_invite_days']." days"));
- $obj->save();
- }
- return Response::json(['status' => 'success', 'data' => '', 'message' => '生成成功']);
- }
- // 导出邀请码
- public function exportInvite(Request $request)
- {
- $inviteList = Invite::query()->where('status', 0)->orderBy('id', 'asc')->get();
- $filename = '邀请码'.date('Ymd').'.xlsx';
- $spreadsheet = new Spreadsheet();
- $spreadsheet->getProperties()->setCreator('SSRPanel')->setLastModifiedBy('SSRPanel')->setTitle('邀请码')->setSubject('邀请码')->setDescription('')->setKeywords('')->setCategory('');
- $spreadsheet->setActiveSheetIndex(0);
- $sheet = $spreadsheet->getActiveSheet();
- $sheet->setTitle('邀请码');
- $sheet->fromArray(['邀请码', '有效期'], NULL);
- foreach($inviteList as $k => $vo){
- $sheet->fromArray([$vo->code, $vo->dateline], NULL, 'A'.($k+2));
- }
- header('Content-Type: application/vnd.openxmlformats-officedocument.spreadsheetml.sheet'); // 输出07Excel文件
- //header('Content-Type:application/vnd.ms-excel'); // 输出Excel03版本文件
- header('Content-Disposition: attachment;filename="'.$filename.'"');
- header('Cache-Control: max-age=0');
- $writer = new Xlsx($spreadsheet);
- $writer->save('php://output');
- }
- // 提现申请列表
- public function applyList(Request $request)
- {
- $username = $request->input('username');
- $status = $request->input('status');
- $query = ReferralApply::with('user');
- if(isset($username)){
- $query->whereHas('user', function($q) use ($username){
- $q->where('username', 'like', '%'.$username.'%');
- });
- }
- if($status){
- $query->where('status', $status);
- }
- $view['applyList'] = $query->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));
- return Response::view('admin.applyList', $view);
- }
- // 提现申请详情
- public function applyDetail(Request $request)
- {
- $id = $request->input('id');
- $list = new stdClass();
- $apply = ReferralApply::query()->with(['user'])->where('id', $id)->first();
- if($apply && $apply->link_logs){
- $link_logs = explode(',', $apply->link_logs);
- $list = ReferralLog::query()->with(['user', 'order.goods'])->whereIn('id', $link_logs)->paginate(15)->appends($request->except('page'));
- }
- $view['info'] = $apply;
- $view['list'] = $list;
- return Response::view('admin.applyDetail', $view);
- }
- // 订单列表
- public function orderList(Request $request)
- {
- $username = $request->input('username');
- $order_sn = $request->input('order_sn');
- $is_coupon = $request->input('is_coupon');
- $is_expire = $request->input('is_expire');
- $pay_way = $request->input('pay_way');
- $status = $request->input('status');
- $range_time = $request->input('range_time');
- $sort = $request->input('sort'); // 0-按创建时间降序、1-按创建时间升序
- $order_id = $request->input('oid');
- $query = Order::query()->with(['user', 'goods', 'coupon']);
- if(isset($username)){
- $query->whereHas('user', function($q) use ($username){
- $q->where('username', 'like', '%'.$username.'%');
- });
- }
- if(isset($order_sn)){
- $query->where('order_sn', 'like', '%'.$order_sn.'%');
- }
- if(isset($is_coupon)){
- if($is_coupon){
- $query->where('coupon_id', '<>', 0);
- }else{
- $query->where('coupon_id', 0);
- }
- }
- if(isset($is_expire)){
- $query->where('is_expire', $is_expire);
- }
- if(isset($pay_way)){
- $query->where('pay_way', $pay_way);
- }
- if(isset($status)){
- $query->where('status', $status);
- }
- if(isset($range_time) && $range_time != ','){
- $range_time = explode(',', $range_time);
- $query->where('created_at', '>=', $range_time[0])->where('created_at', '<=', $range_time[1]);
- }
- if(isset($order_id)){
- $query->where('oid', $order_id);
- }
- if($sort){
- $query->orderBy('oid', 'asc');
- }else{
- $query->orderBy('oid', 'desc');
- }
- $view['orderList'] = $query->paginate(15)->appends($request->except('page'));
- return Response::view('admin.orderList', $view);
- }
- // 设置提现申请状态
- public function setApplyStatus(Request $request)
- {
- $id = $request->input('id');
- $status = $request->input('status');
- $ret = ReferralApply::query()->where('id', $id)->update(['status' => $status]);
- if($ret){
- // 审核申请的时候将关联的
- $referralApply = ReferralApply::query()->where('id', $id)->first();
- $log_ids = explode(',', $referralApply->link_logs);
- if($referralApply && $status == 1){
- ReferralLog::query()->whereIn('id', $log_ids)->update(['status' => 1]);
- }elseif($referralApply && $status == 2){
- ReferralLog::query()->whereIn('id', $log_ids)->update(['status' => 2]);
- }
- }
- return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
- }
- // 重置用户流量
- public function resetUserTraffic(Request $request)
- {
- $id = $request->input('id');
- User::query()->where('id', $id)->update(['u' => 0, 'd' => 0]);
- return Response::json(['status' => 'success', 'data' => '', 'message' => '操作成功']);
- }
- // 操作用户余额
- public function handleUserBalance(Request $request)
- {
- if($request->isMethod('POST')){
- $userId = $request->input('user_id');
- $amount = $request->input('amount');
- if(empty($userId) || empty($amount)){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '充值异常']);
- }
- DB::beginTransaction();
- try{
- $user = User::query()->where('id', $userId)->first();
- // 写入余额变动日志
- $this->addUserBalanceLog($userId, 0, $user->balance, $user->balance+$amount, $amount, '后台手动充值');
- // 加减余额
- if($amount < 0){
- $user->decrement('balance', abs($amount)*100);
- }else{
- $user->increment('balance', abs($amount)*100);
- }
- DB::commit();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '充值成功']);
- } catch(Exception $e){
- DB::rollBack();
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '充值失败:'.$e->getMessage()]);
- }
- }else{
- return Response::view('admin.handleUserBalance');
- }
- }
- // 用户余额变动记录
- public function userBalanceLogList(Request $request)
- {
- $username = $request->input('username');
- $query = UserBalanceLog::query()->with(['user'])->orderBy('id', 'desc');
- if(isset($username)){
- $query->whereHas('user', function($q) use ($username){
- $q->where('username', 'like', '%'.$username.'%');
- });
- }
- $view['list'] = $query->paginate(15)->appends($request->except('page'));
- return Response::view('admin.userBalanceLogList', $view);
- }
- // 用户封禁记录
- public function userBanLogList(Request $request)
- {
- $username = $request->input('username');
- $query = UserBanLog::query()->with(['user'])->orderBy('id', 'desc');
- if(isset($username)){
- $query->whereHas('user', function($q) use ($username){
- $q->where('username', 'like', '%'.$username.'%');
- });
- }
- $view['list'] = $query->paginate(15)->appends($request->except('page'));
- return Response::view('admin.userBanLogList', $view);
- }
- // 用户流量变动记录
- public function userTrafficLogList(Request $request)
- {
- $username = $request->input('username');
- $query = UserTrafficModifyLog::query()->with(['user', 'order', 'order.goods']);
- if(isset($username)){
- $query->whereHas('user', function($q) use ($username){
- $q->where('username', 'like', '%'.$username.'%');
- });
- }
- $view['list'] = $query->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));
- return Response::view('admin.userTrafficLogList', $view);
- }
- // 用户返利流水记录
- public function userRebateList(Request $request)
- {
- $username = $request->input('username');
- $ref_username = $request->input('ref_username');
- $status = $request->input('status');
- $query = ReferralLog::query()->with(['user', 'order'])->orderBy('status', 'asc')->orderBy('id', 'desc');
- if(isset($username)){
- $query->whereHas('user', function($q) use ($username){
- $q->where('username', 'like', '%'.$username.'%');
- });
- }
- if(isset($ref_username)){
- $query->whereHas('ref_user', function($q) use ($ref_username){
- $q->where('username', 'like', '%'.$ref_username.'%');
- });
- }
- if(isset($status)){
- $query->where('status', $status);
- }
- $view['list'] = $query->paginate(15)->appends($request->except('page'));
- return Response::view('admin.userRebateList', $view);
- }
- // 用户在线IP记录
- public function userOnlineIPList(Request $request)
- {
- $username = $request->input('username');
- $port = $request->input('port');
- $wechat = $request->input('wechat');
- $qq = $request->input('qq');
- $query = User::query()->where('status', '>=', 0)->where('enable', 1);
- if(isset($username)){
- $query->where('username', 'like', '%'.$username.'%');
- }
- if(isset($wechat)){
- $query->where('wechat', 'like', '%'.$wechat.'%');
- }
- if(isset($qq)){
- $query->where('qq', 'like', '%'.$qq.'%');
- }
- if(isset($port)){
- $query->where('port', $port);
- }
- $userList = $query->paginate(15)->appends($request->except('page'));
- if(!$userList->isEmpty()){
- foreach($userList as $user){
- // 最近5条在线IP记录,如果后端设置为60秒上报一次,则为10分钟内的在线IP
- $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();
- }
- }
- $view['userList'] = $userList;
- return Response::view('admin.userOnlineIPList', $view);
- }
- // 转换成某个用户的身份
- public function switchToUser(Request $request)
- {
- $id = $request->input('user_id');
- $user = User::query()->find($id);
- if(!$user){
- return Response::json(['status' => 'fail', 'data' => '', 'message' => "用户不存在"]);
- }
- // 存储当前管理员ID,并将当前登录信息改成要切换的用户的身份信息
- Session::put('admin', Auth::user()->id);
- Auth::login($user);
- return Response::json(['status' => 'success', 'data' => '', 'message' => "身份切换成功"]);
- }
- // 标签列表
- public function labelList(Request $request)
- {
- $labelList = Label::query()->paginate(15)->appends($request->except('page'));
- foreach($labelList as $label){
- $label->userCount = UserLabel::query()->where('label_id', $label->id)->groupBy('label_id')->count();
- $label->nodeCount = SsNodeLabel::query()->where('label_id', $label->id)->groupBy('label_id')->count();
- }
- $view['labelList'] = $labelList;
- return Response::view('admin.labelList', $view);
- }
- // 添加标签
- public function addLabel(Request $request)
- {
- if($request->isMethod('POST')){
- $name = $request->input('name');
- $sort = $request->input('sort');
- $label = new Label();
- $label->name = $name;
- $label->sort = $sort;
- $label->save();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
- }else{
- return Response::view('admin.addLabel');
- }
- }
- // 编辑标签
- public function editLabel(Request $request)
- {
- if($request->isMethod('POST')){
- $id = $request->input('id');
- $name = $request->input('name');
- $sort = $request->input('sort');
- Label::query()->where('id', $id)->update(['name' => $name, 'sort' => $sort]);
- return Response::json(['status' => 'success', 'data' => '', 'message' => '添加成功']);
- }else{
- $id = $request->input('id');
- $view['label'] = Label::query()->where('id', $id)->first();
- return Response::view('admin.editLabel', $view);
- }
- }
- // 删除标签
- public function delLabel(Request $request)
- {
- $id = $request->input('id');
- DB::beginTransaction();
- try{
- Label::query()->where('id', $id)->delete();
- UserLabel::query()->where('label_id', $id)->delete(); // 删除用户关联
- SsNodeLabel::query()->where('label_id', $id)->delete(); // 删除节点关联
- DB::commit();
- return Response::json(['status' => 'success', 'data' => '', 'message' => '删除成功']);
- } catch(Exception $e){
- DB::rollBack();
- return Response::json(['status' => 'fail', 'data' => '', 'message' => '删除失败:'.$e->getMessage()]);
- }
- }
- // 邮件发送日志列表
- public function emailLog(Request $request)
- {
- $username = $request->input('username');
- $type = $request->input('type');
- $query = EmailLog::query();
- if(isset($username)){
- $query->where('address', 'like', '%'.$username.'%');
- }
- if(isset($type)){
- $query->where('type', $type);
- }
- $view['list'] = $query->orderBy('id', 'desc')->paginate(15)->appends($request->except('page'));
- return Response::view('admin.emailLog', $view);
- }
- // 在线IP监控(实时)
- public function onlineIPMonitor(Request $request)
- {
- $ip = $request->input('ip');
- $username = $request->input('username');
- $port = $request->input('port');
- $nodeId = $request->input('nodeId');
- $userId = $request->input('id');
- $query = SsNodeIp::query()->with(['node', 'user'])->where('type', 'tcp')->where('created_at', '>=', strtotime("-120 seconds"));
- if(isset($ip)){
- $query->where('ip', $ip);
- }
- if(isset($username)){
- $query->whereHas('user', function($q) use ($username){
- $q->where('username', 'like', '%'.$username.'%');
- });
- }
- if(isset($port)){
- $query->whereHas('user', function($q) use ($port){
- $q->where('port', $port);
- });
- }
- if(isset($nodeId)){
- $query->whereHas('node', function($q) use ($nodeId){
- $q->where('id', $nodeId);
- });
- }
- if(isset($userId)){
- $query->whereHas('user', function($q) use ($userId){
- $q->where('id', $userId);
- });
- }
- $list = $query->groupBy('port')->orderBy('id', 'desc');
- foreach($list as $vo){
- // 跳过上报多IP的
- if(strpos($vo->ip, ',') == TRUE){
- continue;
- }
- $ipInfo = QQWry::ip($vo->ip);
- if(isset($ipInfo['error'])){
- // 用IPIP的库再试一下
- $ipip = IPIP::ip($vo->ip);
- $ipInfo = ['country' => $ipip['country_name'], 'province' => $ipip['region_name'], 'city' => $ipip['city_name']];
- }
- $vo->ipInfo = $ipInfo['country'].' '.$ipInfo['province'].' '.$ipInfo['city'];
- }
- $view['list'] = $list->paginate(20)->appends($request->except('page'));
- $view['nodeList'] = SsNode::query()->where('status', 1)->orderBy('sort', 'desc')->orderBy('id', 'desc')->get();
- return Response::view('admin.onlineIPMonitor', $view);
- }
- // 生成用户标签
- private function makeUserLabels($userId, $labels)
- {
- // 先删除该用户所有的标签
- UserLabel::query()->where('user_id', $userId)->delete();
- if(!empty($labels) && is_array($labels)){
- foreach($labels as $label){
- $userLabel = new UserLabel();
- $userLabel->user_id = $userId;
- $userLabel->label_id = $label;
- $userLabel->save();
- }
- }
- }
- // 生成节点标签
- private function makeNodeLabels($nodeId, $labels)
- {
- // 先删除所有该节点的标签
- SsNodeLabel::query()->where('node_id', $nodeId)->delete();
- if(!empty($labels) && is_array($labels)){
- foreach($labels as $label){
- $ssNodeLabel = new SsNodeLabel();
- $ssNodeLabel->node_id = $nodeId;
- $ssNodeLabel->label_id = $label;
- $ssNodeLabel->save();
- }
- }
- }
- }
|