mirror of
https://github.com/lkddi/Xboard.git
synced 2026-04-09 23:50:51 +08:00
301 lines
10 KiB
PHP
301 lines
10 KiB
PHP
<?php
|
||
|
||
namespace App\Http\Controllers\V2\Admin;
|
||
|
||
use App\Http\Controllers\Controller;
|
||
use App\Models\Log as LogModel;
|
||
use App\Utils\CacheKey;
|
||
use Illuminate\Http\Request;
|
||
use Illuminate\Support\Facades\Cache;
|
||
use Laravel\Horizon\Contracts\JobRepository;
|
||
use Laravel\Horizon\Contracts\MasterSupervisorRepository;
|
||
use Laravel\Horizon\Contracts\MetricsRepository;
|
||
use Laravel\Horizon\Contracts\SupervisorRepository;
|
||
use Laravel\Horizon\Contracts\WorkloadRepository;
|
||
use Laravel\Horizon\WaitTimeCalculator;
|
||
use App\Helpers\ResponseEnum;
|
||
|
||
class SystemController extends Controller
|
||
{
|
||
public function getSystemStatus()
|
||
{
|
||
$data = [
|
||
'schedule' => $this->getScheduleStatus(),
|
||
'horizon' => $this->getHorizonStatus(),
|
||
'schedule_last_runtime' => Cache::get(CacheKey::get('SCHEDULE_LAST_CHECK_AT', null)),
|
||
'logs' => $this->getLogStatistics()
|
||
];
|
||
return $this->success($data);
|
||
}
|
||
|
||
/**
|
||
* 获取日志统计信息
|
||
*
|
||
* @return array 各级别日志的数量统计
|
||
*/
|
||
protected function getLogStatistics(): array
|
||
{
|
||
// 初始化日志统计数组
|
||
$statistics = [
|
||
'info' => 0,
|
||
'warning' => 0,
|
||
'error' => 0,
|
||
'total' => 0
|
||
];
|
||
|
||
if (class_exists(LogModel::class) && LogModel::count() > 0) {
|
||
$statistics['info'] = LogModel::where('level', 'INFO')->count();
|
||
$statistics['warning'] = LogModel::where('level', 'WARNING')->count();
|
||
$statistics['error'] = LogModel::where('level', 'ERROR')->count();
|
||
$statistics['total'] = LogModel::count();
|
||
|
||
return $statistics;
|
||
}
|
||
return $statistics;
|
||
}
|
||
|
||
public function getQueueWorkload(WorkloadRepository $workload)
|
||
{
|
||
return $this->success(collect($workload->get())->sortBy('name')->values()->toArray());
|
||
}
|
||
|
||
protected function getScheduleStatus(): bool
|
||
{
|
||
return (time() - 120) < Cache::get(CacheKey::get('SCHEDULE_LAST_CHECK_AT', null));
|
||
}
|
||
|
||
protected function getHorizonStatus(): bool
|
||
{
|
||
if (!$masters = app(MasterSupervisorRepository::class)->all()) {
|
||
return false;
|
||
}
|
||
|
||
return collect($masters)->contains(function ($master) {
|
||
return $master->status === 'paused';
|
||
}) ? false : true;
|
||
}
|
||
|
||
public function getQueueStats()
|
||
{
|
||
$data = [
|
||
'failedJobs' => app(JobRepository::class)->countRecentlyFailed(),
|
||
'jobsPerMinute' => app(MetricsRepository::class)->jobsProcessedPerMinute(),
|
||
'pausedMasters' => $this->totalPausedMasters(),
|
||
'periods' => [
|
||
'failedJobs' => config('horizon.trim.recent_failed', config('horizon.trim.failed')),
|
||
'recentJobs' => config('horizon.trim.recent'),
|
||
],
|
||
'processes' => $this->totalProcessCount(),
|
||
'queueWithMaxRuntime' => app(MetricsRepository::class)->queueWithMaximumRuntime(),
|
||
'queueWithMaxThroughput' => app(MetricsRepository::class)->queueWithMaximumThroughput(),
|
||
'recentJobs' => app(JobRepository::class)->countRecent(),
|
||
'status' => $this->getHorizonStatus(),
|
||
'wait' => collect(app(WaitTimeCalculator::class)->calculate())->take(1),
|
||
];
|
||
return $this->success($data);
|
||
}
|
||
|
||
/**
|
||
* Get the total process count across all supervisors.
|
||
*
|
||
* @return int
|
||
*/
|
||
protected function totalProcessCount()
|
||
{
|
||
$supervisors = app(SupervisorRepository::class)->all();
|
||
|
||
return collect($supervisors)->reduce(function ($carry, $supervisor) {
|
||
return $carry + collect($supervisor->processes)->sum();
|
||
}, 0);
|
||
}
|
||
|
||
/**
|
||
* Get the number of master supervisors that are currently paused.
|
||
*
|
||
* @return int
|
||
*/
|
||
protected function totalPausedMasters()
|
||
{
|
||
if (!$masters = app(MasterSupervisorRepository::class)->all()) {
|
||
return 0;
|
||
}
|
||
|
||
return collect($masters)->filter(function ($master) {
|
||
return $master->status === 'paused';
|
||
})->count();
|
||
}
|
||
|
||
public function getSystemLog(Request $request)
|
||
{
|
||
$current = $request->input('current') ? $request->input('current') : 1;
|
||
$pageSize = $request->input('page_size') >= 10 ? $request->input('page_size') : 10;
|
||
$level = $request->input('level');
|
||
$keyword = $request->input('keyword');
|
||
|
||
$builder = LogModel::orderBy('created_at', 'DESC')
|
||
->when($level, function ($query) use ($level) {
|
||
return $query->where('level', strtoupper($level));
|
||
})
|
||
->when($keyword, function ($query) use ($keyword) {
|
||
return $query->where(function ($q) use ($keyword) {
|
||
$q->where('data', 'like', '%' . $keyword . '%')
|
||
->orWhere('context', 'like', '%' . $keyword . '%')
|
||
->orWhere('title', 'like', '%' . $keyword . '%')
|
||
->orWhere('uri', 'like', '%' . $keyword . '%');
|
||
});
|
||
});
|
||
|
||
$total = $builder->count();
|
||
$res = $builder->forPage($current, $pageSize)
|
||
->get();
|
||
|
||
return response([
|
||
'data' => $res,
|
||
'total' => $total
|
||
]);
|
||
}
|
||
|
||
public function getHorizonFailedJobs(Request $request, JobRepository $jobRepository)
|
||
{
|
||
$current = max(1, (int) $request->input('current', 1));
|
||
$pageSize = max(10, (int) $request->input('page_size', 20));
|
||
$offset = ($current - 1) * $pageSize;
|
||
|
||
$failedJobs = collect($jobRepository->getFailed())
|
||
->sortByDesc('failed_at')
|
||
->slice($offset, $pageSize)
|
||
->values();
|
||
|
||
$total = $jobRepository->countFailed();
|
||
|
||
return response()->json([
|
||
'data' => $failedJobs,
|
||
'total' => $total,
|
||
'current' => $current,
|
||
'page_size' => $pageSize,
|
||
]);
|
||
}
|
||
|
||
/**
|
||
* 清除系统日志
|
||
*
|
||
* @param Request $request
|
||
* @return \Illuminate\Http\JsonResponse
|
||
*/
|
||
public function clearSystemLog(Request $request)
|
||
{
|
||
$request->validate([
|
||
'days' => 'integer|min:0|max:365',
|
||
'level' => 'string|in:info,warning,error,all',
|
||
'limit' => 'integer|min:100|max:10000'
|
||
], [
|
||
'days.required' => '请指定要清除多少天前的日志',
|
||
'days.integer' => '天数必须为整数',
|
||
'days.min' => '天数不能少于1天',
|
||
'days.max' => '天数不能超过365天',
|
||
'level.in' => '日志级别只能是：info、warning、error、all',
|
||
'limit.min' => '单次清除数量不能少于100条',
|
||
'limit.max' => '单次清除数量不能超过10000条'
|
||
]);
|
||
|
||
$days = $request->input('days', 30); // 默认清除30天前的日志
|
||
$level = $request->input('level', 'all'); // 默认清除所有级别
|
||
$limit = $request->input('limit', 1000); // 默认单次清除1000条
|
||
|
||
try {
|
||
$cutoffDate = now()->subDays($days);
|
||
|
||
// 构建查询条件
|
||
$query = LogModel::where('created_at', '<', $cutoffDate->timestamp);
|
||
|
||
if ($level !== 'all') {
|
||
$query->where('level', strtoupper($level));
|
||
}
|
||
|
||
// 获取要删除的记录数量
|
||
$totalCount = $query->count();
|
||
|
||
if ($totalCount === 0) {
|
||
return $this->success([
|
||
'message' => '没有找到符合条件的日志记录',
|
||
'deleted_count' => 0,
|
||
'total_count' => $totalCount
|
||
]);
|
||
}
|
||
|
||
// 分批删除，避免单次删除过多数据
|
||
$deletedCount = 0;
|
||
$batchSize = min($limit, 1000); // 每批最多1000条
|
||
|
||
while ($deletedCount < $limit && $deletedCount < $totalCount) {
|
||
$remainingLimit = min($batchSize, $limit - $deletedCount);
|
||
|
||
$batchQuery = LogModel::where('created_at', '<', $cutoffDate->timestamp);
|
||
if ($level !== 'all') {
|
||
$batchQuery->where('level', strtoupper($level));
|
||
}
|
||
|
||
$idsToDelete = $batchQuery->limit($remainingLimit)->pluck('id');
|
||
|
||
if ($idsToDelete->isEmpty()) {
|
||
break;
|
||
}
|
||
|
||
$batchDeleted = LogModel::whereIn('id', $idsToDelete)->delete();
|
||
$deletedCount += $batchDeleted;
|
||
|
||
// 避免长时间占用数据库连接
|
||
if ($deletedCount < $limit && $deletedCount < $totalCount) {
|
||
usleep(100000); // 暂停0.1秒
|
||
}
|
||
}
|
||
|
||
return $this->success([
|
||
'message' => '日志清除完成',
|
||
'deleted_count' => $deletedCount,
|
||
'total_count' => $totalCount,
|
||
'remaining_count' => max(0, $totalCount - $deletedCount)
|
||
]);
|
||
|
||
} catch (\Exception $e) {
|
||
return $this->fail(ResponseEnum::HTTP_ERROR, null, '清除日志失败：' . $e->getMessage());
|
||
}
|
||
}
|
||
|
||
/**
|
||
* 获取日志清除统计信息
|
||
*
|
||
* @param Request $request
|
||
* @return \Illuminate\Http\JsonResponse
|
||
*/
|
||
public function getLogClearStats(Request $request)
|
||
{
|
||
$days = $request->input('days', 30);
|
||
$level = $request->input('level', 'all');
|
||
|
||
try {
|
||
$cutoffDate = now()->subDays($days);
|
||
|
||
$query = LogModel::where('created_at', '<', $cutoffDate->timestamp);
|
||
if ($level !== 'all') {
|
||
$query->where('level', strtoupper($level));
|
||
}
|
||
|
||
$stats = [
|
||
'days' => $days,
|
||
'level' => $level,
|
||
'cutoff_date' => $cutoffDate->format(format: 'Y-m-d H:i:s'),
|
||
'total_logs' => LogModel::count(),
|
||
'logs_to_clear' => $query->count(),
|
||
'oldest_log' => LogModel::orderBy('created_at', 'asc')->first(),
|
||
'newest_log' => LogModel::orderBy('created_at', 'desc')->first(),
|
||
];
|
||
|
||
return $this->success($stats);
|
||
|
||
} catch (\Exception $e) {
|
||
return $this->fail(ResponseEnum::HTTP_ERROR, null, '获取统计信息失败：' . $e->getMessage());
|
||
}
|
||
}
|
||
}
|