LogsController.php 11 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225226227228229230231232233234235236237238239240241242243244245246247248249250251252253254255256257258259260261262263264265266267268269270271272273274275276277278279280281282283284285286287288289290291292293294295296297298299300301302303304305306307308309310311312313314315316317318319320321322323324325326327328329330331332333334335336337338339340341342343
  1. <?php
  2. namespace App\Http\Controllers\Admin;
  3. use App\Components\IP;
  4. use App\Http\Controllers\Controller;
  5. use App\Models\Node;
  6. use App\Models\NodeOnlineIp;
  7. use App\Models\NotificationLog;
  8. use App\Models\Order;
  9. use App\Models\PaymentCallback;
  10. use App\Models\User;
  11. use App\Models\UserBanedLog;
  12. use App\Models\UserCreditLog;
  13. use App\Models\UserDataFlowLog;
  14. use App\Models\UserDataModifyLog;
  15. use Illuminate\Http\Request;
  16. use phpseclib3\Crypt\EC\Curves\brainpoolP160r1;
  17. use function Matrix\diagonal;
  18. class LogsController extends Controller
  19. {
  20. // 订单列表
  21. public function orderList(Request $request)
  22. {
  23. $email = $request->input('email');
  24. $sn = $request->input('sn');
  25. $is_coupon = $request->input('is_coupon');
  26. $is_expire = $request->input('is_expire');
  27. $pay_way = $request->input('pay_way');
  28. $status = $request->input('status');
  29. $range_time = $request->input('range_time');
  30. $sort = $request->input('sort'); // 0-按创建时间降序、1-按创建时间升序
  31. $order_id = $request->input('id');
  32. $trade_no = $request->input('trade_no');
  33. $query = Order::with(['user:id,email', 'goods:id,name', 'coupon:id,name,sn']);
  34. if (isset($email)) {
  35. $query->whereHas('user', static function ($q) use ($email) {
  36. $q->where('email', 'like', '%'.$email.'%');
  37. });
  38. }
  39. if (isset($sn)) {
  40. $query->where('sn', 'like', '%'.$sn.'%');
  41. }
  42. if (isset($is_coupon)) {
  43. if ($is_coupon) {
  44. $query->where('coupon_id', '<>', null);
  45. } else {
  46. $query->whereCouponId(null);
  47. }
  48. }
  49. if (isset($is_expire)) {
  50. $query->whereIsExpire($is_expire);
  51. }
  52. if (isset($pay_way)) {
  53. $query->wherePayWay($pay_way);
  54. }
  55. if (isset($status)) {
  56. $query->whereStatus($status);
  57. }
  58. if (isset($range_time) && $range_time !== ',') {
  59. $range_time = explode(',', $range_time);
  60. $query->where('created_at', '>=', $range_time[0])->where('created_at', '<=', $range_time[1]);
  61. }
  62. if (isset($order_id)) {
  63. $query->whereId($order_id);
  64. }
  65. if ($sort) {
  66. $query->orderBy('id');
  67. } else {
  68. $query->orderByDesc('id');
  69. }
  70. if (isset($trade_no)){
  71. $query->whereHas('payment' , function ($q) use ($trade_no) {
  72. $q->where('trade_no', 'like', '%'.$trade_no.'%');
  73. });
  74. }else {
  75. // $query->payment();
  76. }
  77. // //dump( ['orders' => $query->latest()->paginate(15)->appends($request->except('page'))]); die();
  78. // $data = $query->latest()->paginate(15)->appends($request->except('page'));
  79. // foreach ($data as $key => $v){
  80. // echo $v;
  81. // }
  82. // die();
  83. // var_dump($query->latest()->paginate(15)->appends($request->except('page'))); die();
  84. return view('admin.logs.order', ['orders' => $query->latest()->paginate(15)->appends($request->except('page'))]);
  85. }
  86. // 流量日志
  87. public function trafficLog(Request $request)
  88. {
  89. $port = $request->input('port');
  90. $user_id = $request->input('user_id');
  91. $email = $request->input('email');
  92. $nodeId = $request->input('nodeId');
  93. $startTime = $request->input('startTime');
  94. $endTime = $request->input('endTime');
  95. $query = UserDataFlowLog::with(['user', 'node']);
  96. if (isset($port)) {
  97. $query->whereHas('user', static function ($q) use ($port) {
  98. $q->wherePort($port);
  99. });
  100. }
  101. if (isset($user_id)) {
  102. $query->whereUserId($user_id);
  103. }
  104. if (isset($email)) {
  105. $query->whereHas('user', static function ($q) use ($email) {
  106. $q->where('email', 'like', '%'.$email.'%');
  107. });
  108. }
  109. if (isset($nodeId)) {
  110. $query->whereNodeId($nodeId);
  111. }
  112. if (isset($startTime)) {
  113. $query->where('log_time', '>=', strtotime($startTime));
  114. }
  115. if (isset($endTime)) {
  116. $query->where('log_time', '<=', strtotime($endTime));
  117. }
  118. $dataFlowLogs = $query->latest('log_time')->paginate(20)->appends($request->except('page'));
  119. foreach ($dataFlowLogs as $log) {
  120. $log->u = flowAutoShow($log->u);
  121. $log->d = flowAutoShow($log->d);
  122. $log->log_time = date('Y-m-d H:i:s', $log->log_time);
  123. }
  124. return view('admin.logs.traffic', [
  125. 'totalTraffic' => flowAutoShow($query->sum('u') + $query->sum('d')), // 已使用流量
  126. 'dataFlowLogs' => $dataFlowLogs,
  127. 'nodes' => Node::whereStatus(1)->orderByDesc('sort')->latest()->get(),
  128. ]);
  129. }
  130. // 邮件发送日志列表
  131. public function notificationLog(Request $request)
  132. {
  133. $email = $request->input('email');
  134. $type = $request->input('type');
  135. $query = NotificationLog::query();
  136. if (isset($email)) {
  137. $query->where('address', 'like', '%'.$email.'%');
  138. }
  139. if (isset($type)) {
  140. $query->whereType($type);
  141. }
  142. return view('admin.logs.notification', ['notificationLogs' => $query->latest()->paginate(15)->appends($request->except('page'))]);
  143. }
  144. // 在线IP监控(实时)
  145. public function onlineIPMonitor(Request $request, $id = null)
  146. {
  147. $ip = $request->input('ip');
  148. $email = $request->input('email');
  149. $port = $request->input('port');
  150. $nodeId = $request->input('nodeId');
  151. $query = NodeOnlineIp::with(['node:id,name', 'user:id,email'])->where('created_at', '>=', strtotime('-2 minutes'));
  152. if (isset($ip)) {
  153. $query->whereIp($ip);
  154. }
  155. if (isset($email)) {
  156. $query->whereHas('user', static function ($q) use ($email) {
  157. $q->where('email', 'like', '%'.$email.'%');
  158. });
  159. }
  160. if (isset($port)) {
  161. $query->whereHas('user', static function ($q) use ($port) {
  162. $q->wherePort($port);
  163. });
  164. }
  165. if (isset($nodeId)) {
  166. $query->whereHas('node', static function ($q) use ($nodeId) {
  167. $q->whereId($nodeId);
  168. });
  169. }
  170. if (isset($id)) {
  171. $query->whereHas('user', static function ($q) use ($id) {
  172. $q->whereId($id);
  173. });
  174. }
  175. $onlineIPLogs = $query->groupBy('user_id', 'node_id')->latest()->paginate(20)->appends($request->except('page'));
  176. // foreach ($onlineIPLogs as $log) {
  177. // // 跳过上报多IP的
  178. // if ($log->ip === null || strpos($log->ip, ',') !== false) {
  179. // continue;
  180. // }
  181. // //$ipInfo = IP::getIPInfo($log->ip);
  182. //
  183. // //$log->ipInfo = implode(' ', $ipInfo);
  184. // }
  185. return view('admin.logs.onlineIPMonitor', [
  186. 'onlineIPLogs' => $onlineIPLogs,
  187. 'nodes' => Node::whereStatus(1)->orderByDesc('sort')->latest()->get(),
  188. ]);
  189. }
  190. // 用户余额变动记录
  191. public function userCreditLogList(Request $request)
  192. {
  193. $email = $request->input('email');
  194. $query = UserCreditLog::with('user:id,email')->latest();
  195. if (isset($email)) {
  196. $query->whereHas('user', static function ($q) use ($email) {
  197. $q->where('email', 'like', '%'.$email.'%');
  198. });
  199. }
  200. return view('admin.logs.userCreditHistory', ['userCreditLogs' => $query->paginate(15)->appends($request->except('page'))]);
  201. }
  202. // 用户封禁记录
  203. public function userBanLogList(Request $request)
  204. {
  205. $email = $request->input('email');
  206. $query = UserBanedLog::with('user:id,email,t')->latest();
  207. if (isset($email)) {
  208. $query->whereHas('user', static function ($q) use ($email) {
  209. $q->where('email', 'like', '%'.$email.'%');
  210. });
  211. }
  212. return view('admin.logs.userBanHistory', ['userBanLogs' => $query->paginate(15)->appends($request->except('page'))]);
  213. }
  214. // 用户流量变动记录
  215. public function userTrafficLogList(Request $request)
  216. {
  217. $email = $request->input('email');
  218. $query = UserDataModifyLog::with(['user:id,email', 'order.goods:id,name']);
  219. if (isset($email)) {
  220. $query->whereHas('user', static function ($q) use ($email) {
  221. $q->where('email', 'like', '%'.$email.'%');
  222. });
  223. }
  224. return view('admin.logs.userTraffic', ['userTrafficLogs' => $query->latest()->paginate(15)->appends($request->except('page'))]);
  225. }
  226. // 用户在线IP记录
  227. public function userOnlineIPList(Request $request)
  228. {
  229. $email = $request->input('email');
  230. $port = $request->input('port');
  231. $wechat = $request->input('wechat');
  232. $qq = $request->input('qq');
  233. $query = User::activeUser();
  234. if (isset($email)) {
  235. $query->where('email', 'like', '%'.$email.'%');
  236. }
  237. if (isset($wechat)) {
  238. $query->where('wechat', 'like', '%'.$wechat.'%');
  239. }
  240. if (isset($qq)) {
  241. $query->where('qq', 'like', '%'.$qq.'%');
  242. }
  243. if (isset($port)) {
  244. $query->wherePort($port);
  245. }
  246. $userList = $query->paginate(15)->appends($request->except('page'));
  247. $nodeOnlineIPs = NodeOnlineIp::with('node:id,name')->where('created_at', '>=', strtotime('-10 minutes'))->latest()->distinct()->get();
  248. foreach ($userList as $user) {
  249. //Todo node_online_ip表 api可以用user_id
  250. // 最近5条在线IP记录,如果后端设置为60秒上报一次,则为10分钟内的在线IP
  251. $user->onlineIPList = $nodeOnlineIPs->where('port', $user->port)->take(5);
  252. }
  253. return view('admin.logs.userOnlineIP', ['userList' => $userList]);
  254. }
  255. // 用户流量监控
  256. public function userTrafficMonitor(User $user)
  257. {
  258. return view('admin.logs.userMonitor', array_merge(['email' => $user->email], $this->dataFlowChart($user->id)));
  259. }
  260. // 回调日志
  261. public function callbackList(Request $request)
  262. {
  263. $status = $request->input('status', 0);
  264. $out_trade_no = $request->input('out_trade_no', 0);
  265. $query = PaymentCallback::query();
  266. if (isset($status)) {
  267. $query->whereStatus($status);
  268. }
  269. if (isset($out_trade_no)){
  270. $query->where('out_trade_no',"=",$out_trade_no);
  271. }
  272. $data = $query->latest()->paginate(10)->appends($request->except('page'));
  273. // die();
  274. return view('admin.logs.callback', ['callbackLogs' => $data]);
  275. }
  276. }