mirror of
https://github.com/cedar2025/Xboard.git
synced 2025-01-23 11:08:13 -05:00
297 lines
11 KiB
PHP
297 lines
11 KiB
PHP
<?php
|
|
|
|
namespace App\Http\Controllers\V2\Admin;
|
|
|
|
use App\Http\Controllers\Controller;
|
|
use App\Models\CommissionLog;
|
|
use App\Models\Order;
|
|
use App\Models\Server;
|
|
use App\Models\Stat;
|
|
use App\Models\StatServer;
|
|
use App\Models\StatUser;
|
|
use App\Models\Ticket;
|
|
use App\Models\User;
|
|
use App\Services\StatisticalService;
|
|
use Illuminate\Http\Request;
|
|
|
|
class StatController extends Controller
|
|
{
|
|
private $service;
|
|
public function __construct(StatisticalService $service)
|
|
{
|
|
$this->service = $service;
|
|
}
|
|
public function getOverride(Request $request)
|
|
{
|
|
return [
|
|
'data' => [
|
|
'month_income' => Order::where('created_at', '>=', strtotime(date('Y-m-1')))
|
|
->where('created_at', '<', time())
|
|
->whereNotIn('status', [0, 2])
|
|
->sum('total_amount'),
|
|
'month_register_total' => User::where('created_at', '>=', strtotime(date('Y-m-1')))
|
|
->where('created_at', '<', time())
|
|
->count(),
|
|
'ticket_pending_total' => Ticket::where('status', 0)
|
|
->count(),
|
|
'commission_pending_total' => Order::where('commission_status', 0)
|
|
->where('invite_user_id', '!=', NULL)
|
|
->whereNotIn('status', [0, 2])
|
|
->where('commission_balance', '>', 0)
|
|
->count(),
|
|
'day_income' => Order::where('created_at', '>=', strtotime(date('Y-m-d')))
|
|
->where('created_at', '<', time())
|
|
->whereNotIn('status', [0, 2])
|
|
->sum('total_amount'),
|
|
'last_month_income' => Order::where('created_at', '>=', strtotime('-1 month', strtotime(date('Y-m-1'))))
|
|
->where('created_at', '<', strtotime(date('Y-m-1')))
|
|
->whereNotIn('status', [0, 2])
|
|
->sum('total_amount'),
|
|
'commission_month_payout' => CommissionLog::where('created_at', '>=', strtotime(date('Y-m-1')))
|
|
->where('created_at', '<', time())
|
|
->sum('get_amount'),
|
|
'commission_last_month_payout' => CommissionLog::where('created_at', '>=', strtotime('-1 month', strtotime(date('Y-m-1'))))
|
|
->where('created_at', '<', strtotime(date('Y-m-1')))
|
|
->sum('get_amount'),
|
|
]
|
|
];
|
|
}
|
|
|
|
public function getOrder(Request $request)
|
|
{
|
|
$statistics = Stat::where('record_type', 'd')
|
|
->limit(31)
|
|
->orderBy('record_at', 'DESC')
|
|
->get()
|
|
->toArray();
|
|
$result = [];
|
|
foreach ($statistics as $statistic) {
|
|
$date = date('m-d', $statistic['record_at']);
|
|
$result[] = [
|
|
'type' => '收款金额',
|
|
'date' => $date,
|
|
'value' => $statistic['paid_total'] / 100
|
|
];
|
|
$result[] = [
|
|
'type' => '收款笔数',
|
|
'date' => $date,
|
|
'value' => $statistic['paid_count']
|
|
];
|
|
$result[] = [
|
|
'type' => '佣金金额(已发放)',
|
|
'date' => $date,
|
|
'value' => $statistic['commission_total'] / 100
|
|
];
|
|
$result[] = [
|
|
'type' => '佣金笔数(已发放)',
|
|
'date' => $date,
|
|
'value' => $statistic['commission_count']
|
|
];
|
|
}
|
|
$result = array_reverse($result);
|
|
return [
|
|
'data' => $result
|
|
];
|
|
}
|
|
|
|
// 获取当日实时流量排行
|
|
public function getServerLastRank()
|
|
{
|
|
$data = $this->service->getServerRank();
|
|
return $this->success(data: $data);
|
|
}
|
|
// 获取昨日节点流量排行
|
|
public function getServerYesterdayRank()
|
|
{
|
|
$data = $this->service->getServerRank('yesterday');
|
|
return $this->success($data);
|
|
}
|
|
|
|
public function getStatUser(Request $request)
|
|
{
|
|
$request->validate([
|
|
'user_id' => 'required|integer'
|
|
]);
|
|
|
|
$pageSize = $request->input('pageSize', 10);
|
|
$records = StatUser::orderBy('record_at', 'DESC')
|
|
->where('user_id', $request->input('user_id'))
|
|
->paginate($pageSize);
|
|
|
|
$data = $records->items();
|
|
return [
|
|
'data' => $data,
|
|
'total' => $records->total(),
|
|
];
|
|
}
|
|
|
|
public function getStatRecord(Request $request)
|
|
{
|
|
return [
|
|
'data' => $this->service->getStatRecord($request->input('type'))
|
|
];
|
|
}
|
|
|
|
/**
|
|
* Get comprehensive statistics data including income, users, and growth rates
|
|
*/
|
|
public function getStats()
|
|
{
|
|
$currentMonthStart = strtotime(date('Y-m-01'));
|
|
$lastMonthStart = strtotime('-1 month', $currentMonthStart);
|
|
$twoMonthsAgoStart = strtotime('-2 month', $currentMonthStart);
|
|
|
|
// Current month income
|
|
$currentMonthIncome = Order::where('created_at', '>=', $currentMonthStart)
|
|
->where('created_at', '<', time())
|
|
->whereNotIn('status', [0, 2])
|
|
->sum('total_amount');
|
|
|
|
// Last month income
|
|
$lastMonthIncome = Order::where('created_at', '>=', $lastMonthStart)
|
|
->where('created_at', '<', $currentMonthStart)
|
|
->whereNotIn('status', [0, 2])
|
|
->sum('total_amount');
|
|
|
|
// Last month commission payout
|
|
$lastMonthCommissionPayout = CommissionLog::where('created_at', '>=', $lastMonthStart)
|
|
->where('created_at', '<', $currentMonthStart)
|
|
->sum('get_amount');
|
|
|
|
// Current month new users
|
|
$currentMonthNewUsers = User::where('created_at', '>=', $currentMonthStart)
|
|
->where('created_at', '<', time())
|
|
->count();
|
|
|
|
// Total users
|
|
$totalUsers = User::count();
|
|
|
|
// Active users (users with valid subscription)
|
|
$activeUsers = User::where(function ($query) {
|
|
$query->where('expired_at', '>=', time())
|
|
->orWhere('expired_at', NULL);
|
|
})->count();
|
|
|
|
// Previous month income for growth calculation
|
|
$twoMonthsAgoIncome = Order::where('created_at', '>=', $twoMonthsAgoStart)
|
|
->where('created_at', '<', $lastMonthStart)
|
|
->whereNotIn('status', [0, 2])
|
|
->sum('total_amount');
|
|
|
|
// Previous month commission for growth calculation
|
|
$twoMonthsAgoCommission = CommissionLog::where('created_at', '>=', $twoMonthsAgoStart)
|
|
->where('created_at', '<', $lastMonthStart)
|
|
->sum('get_amount');
|
|
|
|
// Previous month users for growth calculation
|
|
$lastMonthNewUsers = User::where('created_at', '>=', $lastMonthStart)
|
|
->where('created_at', '<', $currentMonthStart)
|
|
->count();
|
|
|
|
// Calculate growth rates
|
|
$monthIncomeGrowth = $lastMonthIncome > 0 ? round(($currentMonthIncome - $lastMonthIncome) / $lastMonthIncome * 100, 1) : 0;
|
|
$lastMonthIncomeGrowth = $twoMonthsAgoIncome > 0 ? round(($lastMonthIncome - $twoMonthsAgoIncome) / $twoMonthsAgoIncome * 100, 1) : 0;
|
|
$commissionGrowth = $twoMonthsAgoCommission > 0 ? round(($lastMonthCommissionPayout - $twoMonthsAgoCommission) / $twoMonthsAgoCommission * 100, 1) : 0;
|
|
$userGrowth = $lastMonthNewUsers > 0 ? round(($currentMonthNewUsers - $lastMonthNewUsers) / $lastMonthNewUsers * 100, 1) : 0;
|
|
|
|
return [
|
|
'data' => [
|
|
'currentMonthIncome' => $currentMonthIncome,
|
|
'lastMonthIncome' => $lastMonthIncome,
|
|
'lastMonthCommissionPayout' => $lastMonthCommissionPayout,
|
|
'currentMonthNewUsers' => $currentMonthNewUsers,
|
|
'totalUsers' => $totalUsers,
|
|
'activeUsers' => $activeUsers,
|
|
'monthIncomeGrowth' => $monthIncomeGrowth,
|
|
'lastMonthIncomeGrowth' => $lastMonthIncomeGrowth,
|
|
'commissionGrowth' => $commissionGrowth,
|
|
'userGrowth' => $userGrowth
|
|
]
|
|
];
|
|
}
|
|
|
|
/**
|
|
* Get traffic ranking data for nodes or users
|
|
*
|
|
* @param Request $request
|
|
* @return array
|
|
*/
|
|
public function getTrafficRank(Request $request)
|
|
{
|
|
$request->validate([
|
|
'type' => 'required|in:node,user',
|
|
'start_time' => 'nullable|integer|min:1000000000|max:9999999999',
|
|
'end_time' => 'nullable|integer|min:1000000000|max:9999999999'
|
|
]);
|
|
|
|
$type = $request->input('type');
|
|
$startDate = $request->input('start_time', strtotime('-7 days'));
|
|
$endDate = $request->input('end_time', time());
|
|
$previousStartDate = $startDate - ($endDate - $startDate);
|
|
$previousEndDate = $startDate;
|
|
|
|
if ($type === 'node') {
|
|
// Get node traffic data
|
|
$currentData = StatServer::selectRaw('server_id as id, SUM(u + d) as value')
|
|
->where('record_at', '>=', $startDate)
|
|
->where('record_at', '<=', $endDate)
|
|
->groupBy('server_id')
|
|
->orderBy('value', 'DESC')
|
|
->limit(10)
|
|
->get();
|
|
|
|
// Get previous period data for comparison
|
|
$previousData = StatServer::selectRaw('server_id as id, SUM(u + d) as value')
|
|
->where('record_at', '>=', $previousStartDate)
|
|
->where('record_at', '<', $previousEndDate)
|
|
->whereIn('server_id', $currentData->pluck('id'))
|
|
->groupBy('server_id')
|
|
->get()
|
|
->keyBy('id');
|
|
|
|
} else {
|
|
// Get user traffic data
|
|
$currentData = StatUser::selectRaw('user_id as id, SUM(u + d) as value')
|
|
->where('record_at', '>=', $startDate)
|
|
->where('record_at', '<=', $endDate)
|
|
->groupBy('user_id')
|
|
->orderBy('value', 'DESC')
|
|
->limit(10)
|
|
->get();
|
|
|
|
// Get previous period data for comparison
|
|
$previousData = StatUser::selectRaw('user_id as id, SUM(u + d) as value')
|
|
->where('record_at', '>=', $previousStartDate)
|
|
->where('record_at', '<', $previousEndDate)
|
|
->whereIn('user_id', $currentData->pluck('id'))
|
|
->groupBy('user_id')
|
|
->get()
|
|
->keyBy('id');
|
|
}
|
|
|
|
$result = [];
|
|
foreach ($currentData as $data) {
|
|
$previousValue = isset($previousData[$data->id]) ? $previousData[$data->id]->value : 0;
|
|
$change = $previousValue > 0 ? round(($data->value - $previousValue) / $previousValue * 100, 1) : 0;
|
|
|
|
$name = $type === 'node'
|
|
? optional(Server::find($data->id))->name ?? "Node {$data->id}"
|
|
: optional(User::find($data->id))->email ?? "User {$data->id}";
|
|
|
|
$result[] = [
|
|
'id' => (string) $data->id,
|
|
'name' => $name,
|
|
'value' => round($data->value / (1024 * 1024 * 1024), 2), // Convert to GB
|
|
'previousValue' => round($previousValue / (1024 * 1024 * 1024), 2), // Convert to GB
|
|
'change' => $change,
|
|
'timestamp' => date('c', $endDate)
|
|
];
|
|
}
|
|
|
|
return [
|
|
'timestamp' => date('c'),
|
|
'data' => $result
|
|
];
|
|
}
|
|
}
|