function Invoke-K8sNodeOrchestration {
    [CmdletBinding()]
    param(
        [ValidateSet('ScaleUp','ScaleDown','Maintenance')]
        [string]$Operation,
        [int]$NodeCount = 1
    )

    $nodePool = Get-AzAksNodePool -ClusterName 'prod-cluster'
    $metrics = Invoke-RestMethod -Uri 'http://k8s-metrics:8080/api/v1/nodes'

    switch ($Operation) {
        'ScaleUp' {
            $newCount = $nodePool.Count + $NodeCount
            Update-AzAksNodePool -Name $nodePool.Name -Count $newCount
            Write-Host "节点池已扩容至$newCount个节点"
        }
        'ScaleDown' {
            $nodesToRemove = $metrics.Nodes | 
                Where-Object { $_.CpuUsage -lt 20 } | 
                Select-Object -First $NodeCount
            $nodesToRemove | ForEach-Object {
                Set-AzAksNode -Name $_.Name -State Draining
            }
        }
        'Maintenance' {
            $metrics.Nodes | Where-Object { $_.HealthStatus -ne 'Healthy' } |
                ForEach-Object {
                    Add-K8sNodeLabel -Node $_.Name -Label @{
                        'maintenance' = (Get-Date).ToString('yyyyMMdd')
                    }
                }
        }
    }
}

function Invoke-ContainerPipeline {
    [CmdletBinding()]
    param(
        [Parameter(Mandatory=$true)]
        [string]$ImageName,
        [string]$DockerfilePath = './Dockerfile'
    )

    $report = [PSCustomObject]@{
        Timestamp = Get-Date -Format 'yyyy-MM-dd HH:mm:ss'
        BuildLog = @()
        DeploymentStatus = @()
    }

    # 构建Docker镜像
    $buildOutput = docker build -t $ImageName -f $DockerfilePath . 2>&1
    $report.BuildLog += $buildOutput

    # 推送镜像到仓库
    if ($LASTEXITCODE -eq 0) {
        $pushOutput = docker push $ImageName 2>&1
        $report.BuildLog += $pushOutput
    }

    # 部署到Kubernetes
    if ($LASTEXITCODE -eq 0) {
        $k8sOutput = kubectl apply -f deployment.yaml 2>&1
        $report.DeploymentStatus += [PSCustomObject]@{
            Cluster = (kubectl config current-context)
            Status = if($LASTEXITCODE -eq 0){'Success'}else{'Failed'}
            Output = $k8sOutput
        }
    }

    # 生成HTML报告
    $htmlReport = $report | ConvertTo-Html -Fragment
    $htmlReport | Out-File "$env:TEMP/ContainerReport_$(Get-Date -Format yyyyMMdd).html"
    return $report
}

# 创建Kubernetes部署模块
function New-KubeCluster {
    param(
        [ValidateSet('minikube','k3s','microk8s')]
        [string]$ClusterType = 'minikube',
        [int]$WorkerNodes = 2
    )

    try {
        # 环境预检
        if (-not (Get-Command docker -ErrorAction SilentlyContinue)) {
            throw "Docker引擎未安装"
        }

        # 根据不同集群类型执行部署
        switch ($ClusterType) {
            'minikube' {
                minikube start --nodes=$WorkerNodes --driver=docker
                minikube addons enable ingress
            }
            'k3s' {
                Invoke-WebRequest -Uri https://get.k3s.io | bash -s -- --worker $WorkerNodes
            }
            'microk8s' {
                snap install microk8s --classic
                microk8s enable dns dashboard ingress
            }
        }

        # 验证集群状态
        $status = kubectl cluster-info
        Write-Host "集群部署完成：$status"
    }
    catch {
        Write-Error "部署失败：$_"
    }
}

function Manage-DockerContainer {
    param(
        [ValidateSet('Create','Start','Stop','Remove')]
        [string]$Action,
        [string]$ImageName,
        [string]$ContainerName
    )

    try {
        switch ($Action) {
            'Create' {
                docker run -d --name $ContainerName $ImageName
            }
            'Start' {
                docker start $ContainerName
            }
            'Stop' {
                docker stop $ContainerName
            }
            'Remove' {
                docker rm -f $ContainerName
            }
        }

        # 获取容器状态
        $status = docker inspect -f '{{.State.Status}}' $ContainerName
        Write-Host "$($Action)操作完成，当前状态：$status"
    }
    catch {
        Write-Error "$Action操作失败：$_"
    }
}