toolbox/app/Console/Commands/LogAnalysisCommand.php

<?php

namespace App\Console\Commands;

use App\Enums\AnalysisMode;
use App\Services\LogAnalysisService;
use App\Services\SlsService;
use App\Services\AiService;
use Carbon\Carbon;
use Illuminate\Console\Command;
use Illuminate\Support\Facades\Log;

class LogAnalysisCommand extends Command
{
    protected $signature = 'log-analysis:run
                            {--from= : 开始时间 (Y-m-d H:i:s 或相对时间如 -1h, -30m, -1d)}
                            {--to= : 结束时间 (Y-m-d H:i:s 或相对时间，默认 now)}
                            {--query= : SLS 查询语句}
                            {--mode=logs : 分析模式 (logs|logs+code)}
                            {--output= : 输出 JSON 报告的文件路径}
                            {--push : 推送结果到钉钉}
                            {--no-save : 不保存报告到数据库}';

    protected $description = '分析 SLS 日志，支持 AI 智能分析和钉钉推送';

    public function handle(
        LogAnalysisService $analysisService,
        SlsService $slsService,
        AiService $aiService
    ): int {
        // 检查配置
        if (!$slsService->isConfigured()) {
            Log::channel('log-analysis')->error('SLS 服务未配置，请检查 .env 中的 SLS_* 配置项');
            return self::FAILURE;
        }

        if (!$aiService->isConfigured()) {
            Log::channel('log-analysis')->error('AI 服务未配置，请在页面上配置 AI 提供商或设置 .env 中的 AI_* 配置项');
            return self::FAILURE;
        }

        // 解析时间参数
        $from = $this->parseTime($this->option('from') ?? '-1h');
        $to = $this->parseTime($this->option('to') ?? 'now');

        if ($from >= $to) {
            Log::channel('log-analysis')->error('开始时间必须早于结束时间');
            return self::FAILURE;
        }

        // 解析分析模式
        $modeOption = $this->option('mode');
        $mode = $modeOption === 'logs+code'
            ? AnalysisMode::LogsWithCode
            : AnalysisMode::Logs;

        $query = $this->option('query');

        Log::channel('log-analysis')->info("开始分析日志...");
        Log::channel('log-analysis')->info("  时间范围: {$from->format('Y-m-d H:i:s')} ~ {$to->format('Y-m-d H:i:s')}");
        Log::channel('log-analysis')->info("  查询语句: " . ($query ?: '*'));
        Log::channel('log-analysis')->info("  分析模式: {$mode->label()}");

        try {
            $result = $analysisService->analyze(
                $from,
                $to,
                $query,
                $mode,
                !$this->option('no-save')
            );

            // 输出到文件
            if ($outputPath = $this->option('output')) {
                $json = json_encode($result, JSON_PRETTY_PRINT | JSON_UNESCAPED_UNICODE);
                file_put_contents($outputPath, $json);
                Log::channel('log-analysis')->info("报告已保存到: {$outputPath}");
            }

            // 推送到钉钉
            if ($this->option('push')) {
                Log::channel('log-analysis')->info("正在推送到钉钉...");
                $pushed = $analysisService->pushToNotification($result);
                if ($pushed) {
                    Log::channel('log-analysis')->info("已推送到钉钉");
                } else {
                    Log::channel('log-analysis')->warning("钉钉推送失败");
                }
            }

            // 显示摘要
            $this->displaySummary($result);

            return self::SUCCESS;
        } catch (\Exception $e) {
            Log::channel('log-analysis')->error("分析失败: {$e->getMessage()}");
            return self::FAILURE;
        }
    }

    /**
     * 解析时间参数
     */
    private function parseTime(string $input): Carbon
    {
        // 相对时间格式: -1h, -30m, -1d, -2w
        if (preg_match('/^-(\d+)([hmsdw])$/', $input, $matches)) {
            $value = (int) $matches[1];
            $unit = $matches[2];

            return match ($unit) {
                'h' => Carbon::now()->subHours($value),
                'm' => Carbon::now()->subMinutes($value),
                's' => Carbon::now()->subSeconds($value),
                'd' => Carbon::now()->subDays($value),
                'w' => Carbon::now()->subWeeks($value),
                default => Carbon::now(),
            };
        }

        // 特殊值
        if ($input === 'now') {
            return Carbon::now();
        }

        // 尝试解析为日期时间
        return Carbon::parse($input);
    }

    /**
     * 显示分析摘要
     */
    private function displaySummary(array $result): void
    {
        Log::channel('log-analysis')->info('=== 分析摘要 ===');
        Log::channel('log-analysis')->info("总日志数: {$result['metadata']['total_logs']}");
        Log::channel('log-analysis')->info("分析应用数: {$result['metadata']['apps_analyzed']}");
        Log::channel('log-analysis')->info("执行时间: {$result['metadata']['execution_time_ms']}ms");

        if (empty($result['results'])) {
            Log::channel('log-analysis')->warning('未找到匹配的日志');
            return;
        }

        foreach ($result['results'] as $appName => $appResult) {
            Log::channel('log-analysis')->info("【{$appName}】");

            if (isset($appResult['error'])) {
                Log::channel('log-analysis')->error("  分析失败: {$appResult['error']}");
                continue;
            }

            $impact = $appResult['impact'] ?? 'unknown';

            Log::channel('log-analysis')->info("  日志数: {$appResult['log_count']}");
            Log::channel('log-analysis')->info("  影响级别: {$impact}");
            Log::channel('log-analysis')->info("  摘要: " . ($appResult['summary'] ?? 'N/A'));

            $anomalies = $appResult['core_anomalies'] ?? [];
            if (!empty($anomalies)) {
                Log::channel('log-analysis')->info("  异常数: " . count($anomalies));

                foreach (array_slice($anomalies, 0, 5) as $anomaly) {
                    Log::channel('log-analysis')->info(sprintf(
                        "    - [%s] %s (数量: %d) - %s",
                        $anomaly['type'] ?? 'N/A',
                        $anomaly['classification'] ?? 'N/A',
                        $anomaly['count'] ?? 1,
                        mb_substr($anomaly['possible_cause'] ?? 'N/A', 0, 40)
                    ));
                }
            }
        }
    }
}