AdminController.php 84 KB

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