kknongchang_2506/app/Module/ThirdParty/AdminControllers/ThirdPartyServiceController.php

<?php

namespace App\Module\ThirdParty\AdminControllers;

use UCore\DcatAdmin\AdminController;
use App\Module\ThirdParty\Models\ThirdPartyService;
use App\Module\ThirdParty\Repositorys\ThirdPartyServiceRepository;
use App\Module\ThirdParty\Enums\SERVICE_TYPE;
use App\Module\ThirdParty\Enums\AUTH_TYPE;
use App\Module\ThirdParty\Enums\SERVICE_STATUS;
use Dcat\Admin\Form;
use Dcat\Admin\Grid;
use Dcat\Admin\Show;
use Spatie\RouteAttributes\Attributes\Resource;

/**
 * 第三方服务管理控制器
 *
 * 路由: /admin/thirdparty/services
 */
#[Resource('thirdparty/services', names: 'dcat.admin.thirdparty.services')]
class ThirdPartyServiceController extends AdminController
{
    /**
     * 页面标题
     *
     * @var string
     */
    protected $title = '第三方服务管理';

    /**
     * 数据仓库
     *
     * @return string
     */
    protected function repository()
    {
        return ThirdPartyServiceRepository::class;
    }

    /**
     * 列表页面
     *
     * @return Grid
     */
    protected function grid(): Grid
    {
        return Grid::make(new ThirdPartyServiceRepository(), function (Grid $grid) {
            // 基础设置
            $grid->column('id', 'ID')->sortable();
            $grid->column('name', '服务名称')->sortable();
            $grid->column('code', '服务代码')->sortable();

            // 服务类型
            $grid->column('type', '服务类型')->display(function ($type) {
                $serviceType = SERVICE_TYPE::tryFrom($type);
                if ($serviceType) {
                    $label = $serviceType->getLabel();
                    $color = $serviceType->getColor();
                    return "<span class='badge badge-{$color}'>{$label}</span>";
                }
                return $type;
            });

            // 服务提供商
            $grid->column('provider', '服务提供商')->sortable();

            // 认证类型
            $grid->column('auth_type', '认证类型')->display(function ($authType) {
                $auth = AUTH_TYPE::tryFrom($authType);
                if ($auth) {
                    $label = $auth->getLabel();
                    $level = $auth->getSecurityLevel();
                    $color = $auth->getSecurityLevelColor();
                    return "<span class='badge badge-{$color}' title='安全级别: {$level}'>{$label}</span>";
                }
                return $authType;
            });

            // 服务状态
            $grid->column('status', '状态')->display(function ($status) {
                $serviceStatus = SERVICE_STATUS::tryFrom($status);
                if ($serviceStatus) {
                    $label = $serviceStatus->getLabel();
                    $color = $serviceStatus->getColor();
                    $icon = $serviceStatus->getIcon();
                    return "<span class='badge badge-{$color}'><i class='{$icon}'></i> {$label}</span>";
                }
                return $status;
            });

            // 优先级
            $grid->column('priority', '优先级')->sortable();

            // 健康状态
            $grid->column('health_status', '健康状态')->display(function ($healthStatus) {
                $colors = [
                    'HEALTHY' => 'success',
                    'WARNING' => 'warning',
                    'ERROR' => 'danger',
                    'UNKNOWN' => 'secondary',
                ];
                $color = $colors[$healthStatus] ?? 'secondary';
                return "<span class='badge badge-{$color}'>{$healthStatus}</span>";
            });

            // 最后健康检查时间
            $grid->column('last_health_check', '最后检查')->display(function ($time) {
                return $time ? $time : '未检查';
            });

            // 创建时间
            $grid->column('created_at', '创建时间')->sortable();

            // 过滤器
            $grid->filter(function (Grid\Filter $filter) {
                $filter->equal('type', '服务类型')->select(SERVICE_TYPE::getOptions());
                $filter->equal('status', '状态')->select(SERVICE_STATUS::getOptions());
                $filter->equal('auth_type', '认证类型')->select(AUTH_TYPE::getOptions());
                $filter->like('name', '服务名称');
                $filter->like('code', '服务代码');
                $filter->like('provider', '服务提供商');
            });

            // 批量操作
            $grid->batchActions(function (Grid\Tools\BatchActions $batch) {
                // TODO: 创建批量操作类
                // $batch->add('批量激活', new \App\Module\ThirdParty\AdminActions\BatchActivateServiceAction());
                // $batch->add('批量停用', new \App\Module\ThirdParty\AdminActions\BatchDeactivateServiceAction());
            });

            // 工具栏
            $grid->tools(function (Grid\Tools $tools) {
                $tools->append('<a href="/admin/thirdparty/services/health-check" class="btn btn-sm btn-success"><i class="fa fa-heartbeat"></i> 健康检查</a>');
                $tools->append('<a href="/admin/thirdparty/services/stats" class="btn btn-sm btn-info"><i class="fa fa-chart-bar"></i> 统计报告</a>');
            });

            // 行操作
            $grid->actions(function (Grid\Displayers\Actions $actions) {
                $actions->append('<a href="/admin/thirdparty/credentials?service_id=' . $actions->getKey() . '" class="btn btn-xs btn-primary"><i class="fa fa-key"></i> 凭证</a>');
                $actions->append('<a href="/admin/thirdparty/logs?service_id=' . $actions->getKey() . '" class="btn btn-xs btn-info"><i class="fa fa-list"></i> 日志</a>');

                if ($actions->row->status === SERVICE_STATUS::ACTIVE->value) {
                    $actions->append('<a href="/admin/thirdparty/services/' . $actions->getKey() . '/test" class="btn btn-xs btn-warning"><i class="fa fa-flask"></i> 测试</a>');
                }
            });

            // 默认排序
            $grid->model()->orderBy('priority')->orderBy('name');
        });
    }

    /**
     * 详情页面
     *
     * @return Show
     */
    protected function detail($id): Show
    {
        return Show::make($id, new ThirdPartyServiceRepository(), function (Show $show) {
            $show->field('id', 'ID');
            $show->field('name', '服务名称');
            $show->field('code', '服务代码');

            $show->field('type', '服务类型')->as(function ($type) {
                $serviceType = SERVICE_TYPE::tryFrom($type);
                return $serviceType ? $serviceType->getLabel() : $type;
            });

            $show->field('provider', '服务提供商');
            $show->field('description', '服务描述');
            $show->field('base_url', '基础URL');
            $show->field('version', 'API版本');

            $show->field('auth_type', '认证类型')->as(function ($authType) {
                $auth = AUTH_TYPE::tryFrom($authType);
                return $auth ? $auth->getLabel() : $authType;
            });

            $show->field('status', '状态')->as(function ($status) {
                $serviceStatus = SERVICE_STATUS::tryFrom($status);
                return $serviceStatus ? $serviceStatus->getLabel() : $status;
            });

            $show->field('priority', '优先级');
            $show->field('timeout', '超时时间')->as(function ($timeout) {
                return $timeout . ' 秒';
            });

            $show->field('retry_times', '重试次数');
            $show->field('retry_delay', '重试延迟')->as(function ($delay) {
                return $delay . ' 毫秒';
            });

            $show->field('config', '服务配置')->json();
            $show->field('headers', '默认请求头')->json();
            $show->field('params', '默认参数')->json();

            $show->field('webhook_url', 'Webhook URL');
            $show->field('health_check_url', '健康检查URL');
            $show->field('health_check_interval', '健康检查间隔')->as(function ($interval) {
                return $interval . ' 秒';
            });

            $show->field('health_status', '健康状态');
            $show->field('last_health_check', '最后健康检查时间');

            $show->field('created_at', '创建时间');
            $show->field('updated_at', '更新时间');

            // 关联信息
            $show->relation('credentials', '认证凭证', function ($model) {
                $grid = new Grid(new \App\Module\ThirdParty\Models\ThirdPartyCredential());
                $grid->model()->where('service_id', $model->id);
                $grid->column('name', '凭证名称');
                $grid->column('type', '认证类型');
                $grid->column('environment', '环境');
                $grid->column('is_active', '状态')->display(function ($active) {
                    return $active ? '<span class="badge badge-success">激活</span>' : '<span class="badge badge-secondary">未激活</span>';
                });
                $grid->column('expires_at', '过期时间');
                $grid->disableCreateButton();
                $grid->disableActions();
                return $grid;
            });
        });
    }

    /**
     * 表单页面
     *
     * @return Form
     */
    protected function form(): Form
    {
        return Form::make(new ThirdPartyServiceRepository(), function (Form $form) {
            $form->display('id', 'ID');

            $form->text('name', '服务名称')->required()->help('第三方服务的显示名称');
            $form->text('code', '服务代码')->help('唯一标识符，留空自动生成');

            $form->select('type', '服务类型')->options(SERVICE_TYPE::getOptions())->required();
            $form->text('provider', '服务提供商')->required();
            $form->textarea('description', '服务描述');

            $form->url('base_url', '基础URL')->help('第三方服务的API基础地址');
            $form->text('version', 'API版本')->default('v1');

            $form->select('auth_type', '认证类型')->options(AUTH_TYPE::getOptions())->required();
            $form->select('status', '状态')->options(SERVICE_STATUS::getOptions())->default(SERVICE_STATUS::INACTIVE->value);

            $form->number('priority', '优先级')->default(0)->help('数字越小优先级越高');
            $form->number('timeout', '超时时间(秒)')->default(30)->min(1)->max(300);
            $form->number('retry_times', '重试次数')->default(3)->min(0)->max(10);
            $form->number('retry_delay', '重试延迟(毫秒)')->default(1000)->min(100)->max(60000);

            $form->keyValue('config', '服务配置')
                ->help('服务特定配置，键值对形式输入')
                ->default([]);

            $form->keyValue('headers', '默认请求头')
                ->help('默认HTTP请求头，键值对形式输入')
                ->default([]);

            $form->keyValue('params', '默认参数')
                ->help('默认请求参数，键值对形式输入')
                ->default([]);

            $form->url('webhook_url', 'Webhook URL')->help('接收第三方服务回调的地址');
            $form->text('webhook_secret', 'Webhook密钥')->help('用于验证Webhook请求的密钥');

            $form->url('health_check_url', '健康检查URL')->help('用于检查服务健康状态的URL');
            $form->number('health_check_interval', '健康检查间隔(秒)')->default(300)->min(60)->max(86400);

            $form->display('created_at', '创建时间');
            $form->display('updated_at', '更新时间');

            // 保存前处理
            $form->saving(function (Form $form) {


                // 处理keyValue字段，转换为JSON存储
                $keyValueFields = ['config', 'headers', 'params'];
                foreach ($keyValueFields as $field) {
                    if (isset($form->$field)) {
                        if (is_array($form->$field) && !empty($form->$field)) {
                            // 过滤空值
                            $filtered = array_filter($form->$field, function($value, $key) {
                                return !empty($key) && $value !== null && $value !== '';
                            }, ARRAY_FILTER_USE_BOTH);

                            // 转换为JSON存储
                            $form->$field = !empty($filtered) ? json_encode($filtered, JSON_UNESCAPED_UNICODE) : null;
                        } else {
                            $form->$field = null;
                        }
                    }
                }
            });

        });
    }

    /**
     * 综合报告页面
     *
     * @return \Illuminate\Contracts\View\View
     */
    public function overview()
    {
        $title = '第三方服务综合报告';

        // 获取基础统计数据
        $stats = $this->getOverviewStats();

        return view('thirdparty::reports.overview', compact('title', 'stats'));
    }

    /**
     * 测试页面
     *
     * @return \Illuminate\Contracts\View\View
     */
    public function test()
    {
        $title = 'ThirdParty 模块测试页面';

        return view('thirdparty::reports.test', compact('title'));
    }

    /**
     * 健康检查页面
     *
     * @return \Illuminate\Contracts\View\View
     */
    public function healthCheck()
    {
        $title = '服务健康检查';

        // 获取所有服务的健康状态
        $services = ThirdPartyService::with(['credentials', 'quotas'])
            ->orderBy('priority')
            ->get();

        return view('thirdparty::services.health-check', compact('title', 'services'));
    }

    /**
     * 统计报告页面
     *
     * @return \Illuminate\Contracts\View\View
     */
    public function stats()
    {
        $title = '服务统计报告';

        // 获取统计数据
        $stats = $this->getServiceStats();

        return view('thirdparty::services.stats', compact('title', 'stats'));
    }

    /**
     * 健康报告
     *
     * @return \Illuminate\Contracts\View\View
     */
    public function healthReport()
    {
        $title = '服务健康报告';

        // 获取健康状态统计
        $healthStats = $this->getHealthStats();

        return view('thirdparty::reports.health', compact('title', 'healthStats'));
    }

    /**
     * 使用统计报告
     *
     * @return \Illuminate\Contracts\View\View
     */
    public function usageReport()
    {
        $title = '服务使用统计报告';

        // 获取使用统计数据
        $usageStats = $this->getUsageStats();

        return view('thirdparty::reports.usage', compact('title', 'usageStats'));
    }

    /**
     * 获取综合报告统计数据
     *
     * @return array
     */
    protected function getOverviewStats(): array
    {
        $totalServices = ThirdPartyService::count();
        $activeServices = ThirdPartyService::where('status', SERVICE_STATUS::ACTIVE->value)->count();
        $healthyServices = ThirdPartyService::where('health_status', 'HEALTHY')->count();
        $totalCredentials = \App\Module\ThirdParty\Models\ThirdPartyCredential::count();
        $activeCredentials = \App\Module\ThirdParty\Models\ThirdPartyCredential::where('is_active', true)->count();
        $totalLogs = \App\Module\ThirdParty\Models\ThirdPartyLog::count();
        $todayLogs = \App\Module\ThirdParty\Models\ThirdPartyLog::whereDate('created_at', today())->count();
        $errorLogs = \App\Module\ThirdParty\Models\ThirdPartyLog::where('level', 'ERROR')->count();

        return [
            'services' => [
                'total' => $totalServices,
                'active' => $activeServices,
                'healthy' => $healthyServices,
                'inactive' => $totalServices - $activeServices,
                'unhealthy' => $totalServices - $healthyServices,
            ],
            'credentials' => [
                'total' => $totalCredentials,
                'active' => $activeCredentials,
                'inactive' => $totalCredentials - $activeCredentials,
            ],
            'logs' => [
                'total' => $totalLogs,
                'today' => $todayLogs,
                'errors' => $errorLogs,
            ],
        ];
    }

    /**
     * 获取服务统计数据
     *
     * @return array
     */
    protected function getServiceStats(): array
    {
        // 按服务类型统计
        $typeStats = ThirdPartyService::selectRaw('type, count(*) as count')
            ->groupBy('type')
            ->get()
            ->mapWithKeys(function ($item) {
                $serviceType = SERVICE_TYPE::tryFrom($item->type);
                $label = $serviceType ? $serviceType->getLabel() : $item->type;
                return [$label => $item->count];
            });

        // 按服务提供商统计
        $providerStats = ThirdPartyService::selectRaw('provider, count(*) as count')
            ->groupBy('provider')
            ->orderByDesc('count')
            ->limit(10)
            ->get()
            ->pluck('count', 'provider');

        // 按状态统计
        $statusStats = ThirdPartyService::selectRaw('status, count(*) as count')
            ->groupBy('status')
            ->get()
            ->mapWithKeys(function ($item) {
                $status = SERVICE_STATUS::tryFrom($item->status);
                $label = $status ? $status->getLabel() : $item->status;
                return [$label => $item->count];
            });

        return [
            'by_type' => $typeStats,
            'by_provider' => $providerStats,
            'by_status' => $statusStats,
        ];
    }

    /**
     * 获取健康状态统计
     *
     * @return array
     */
    protected function getHealthStats(): array
    {
        $healthStats = ThirdPartyService::selectRaw('health_status, count(*) as count')
            ->groupBy('health_status')
            ->get()
            ->pluck('count', 'health_status');

        $recentChecks = ThirdPartyService::whereNotNull('last_health_check')
            ->where('last_health_check', '>=', now()->subHours(24))
            ->count();

        return [
            'status_distribution' => $healthStats,
            'recent_checks' => $recentChecks,
            'total_services' => ThirdPartyService::count(),
        ];
    }

    /**
     * 获取使用统计数据
     *
     * @return array
     */
    protected function getUsageStats(): array
    {
        // 最近7天的API调用统计
        $dailyStats = \App\Module\ThirdParty\Models\ThirdPartyLog::selectRaw('DATE(created_at) as date, count(*) as count')
            ->where('created_at', '>=', now()->subDays(7))
            ->groupBy('date')
            ->orderBy('date')
            ->get()
            ->pluck('count', 'date');

        // 按服务统计调用次数
        $serviceStats = \App\Module\ThirdParty\Models\ThirdPartyLog::join('kku_thirdparty_services', 'kku_thirdparty_logs.service_id', '=', 'kku_thirdparty_services.id')
            ->selectRaw('kku_thirdparty_services.name, count(*) as count')
            ->groupBy('kku_thirdparty_services.id', 'kku_thirdparty_services.name')
            ->orderByDesc('count')
            ->limit(10)
            ->get()
            ->pluck('count', 'name');

        return [
            'daily_calls' => $dailyStats,
            'service_calls' => $serviceStats,
        ];
    }
}