function Get-IoTEdgeDeviceStatus {
    [CmdletBinding()]
    param(
        [Parameter(Mandatory=$true)]
        [string]$DeviceIPRange,
        
        [ValidateRange(1,65535)]
        [int]$PollingInterval = 300
    )

    $deviceReport = [PSCustomObject]@{
        Timestamp = Get-Date -Format 'yyyy-MM-dd HH:mm:ss'
        OnlineDevices = @()
        OfflineDevices = @()
        AbnormalMetrics = @()
    }

    # 执行Ping扫描发现设备
    $discoveredDevices = Test-Connection -ComputerName $DeviceIPRange -Count 1 -AsJob |
        Wait-Job | Receive-Job |
        Where-Object { $_.StatusCode -eq 0 } |
        Select-Object Address,ResponseTime

    # 获取设备遥测数据
    $discoveredDevices | ForEach-Object {
        try {
            $metrics = Invoke-RestMethod -Uri "http://$($_.Address)/metrics" -TimeoutSec 5
            
            $deviceReport.OnlineDevices += [PSCustomObject]@{
                IPAddress = $_.Address
                Latency = $_.ResponseTime
                CPUUsage = $metrics.cpu_usage
                MemoryUsage = $metrics.memory_usage
            }

            if($metrics.cpu_usage -gt 90 -or $metrics.memory_usage -gt 85) {
                $deviceReport.AbnormalMetrics += [PSCustomObject]@{
                    IPAddress = $_.Address
                    Metric = ($metrics | ConvertTo-Json)
                    Threshold = "CPU >90% 或 Memory >85%"
                }
            }
        }
        catch {
            $deviceReport.OfflineDevices += $_.Address
        }
    }

    # 生成HTML报告
    $reportPath = "$env:TEMP/IoTEdgeReport_$(Get-Date -Format yyyyMMdd).html"
    $deviceReport | ConvertTo-Html -Title "IoT设备健康报告" | Out-File $reportPath
    return $deviceReport
}

function Start-EdgeDeviceMonitor {
    [CmdletBinding()]
    param(
        [Parameter(Mandatory=$true)]
        [string]$BrokerUrl,
        
        [Parameter(Mandatory=$true)]
        [string[]]$DeviceTopics
    )

    Add-Type -Path "MQTTnet.dll"
    $factory = [MQTTnet.MqttFactory]::new()
    $client = $factory.CreateMqttClient()

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

    $clientOptions = [MQTTnet.Client.MqttClientOptionsBuilder]::new()
        .WithTcpServer($BrokerUrl)
        .Build()

    $client.ConnectAsync($clientOptions).Wait()

    $DeviceTopics | ForEach-Object {
        $client.SubscribeAsync([MQTTnet.MqttTopicFilterBuilder]::new()
            .WithTopic($_)
            .Build()).Wait()

        $client.ApplicationMessageReceivedHandler = [MQTTnet.MqttApplicationMessageReceivedHandler]{
            param($e)
            $payload = [System.Text.Encoding]::UTF8.GetString($e.ApplicationMessage.Payload)
            
            $report.ConnectedDevices += [PSCustomObject]@{
                DeviceID = $e.ApplicationMessage.Topic.Split('/')[-1]
                LastSeen = Get-Date
                Telemetry = $payload | ConvertFrom-Json
            }

            if ($payload -match '"status":"error"') {
                $report.HealthStatus += [PSCustomObject]@{
                    DeviceID = $e.ApplicationMessage.Topic.Split('/')[-1]
                    ErrorCode = ($payload | ConvertFrom-Json).errorCode
                    Recommendation = "检查设备固件版本并重启服务"
                }
            }
        }
    }

    Register-ObjectEvent -InputObject $client -EventName ApplicationMessageReceived -Action {
        $global:report = $eventArgs | ForEach-Object { $_.UserEventArgs }
    }

    $report | Export-Csv -Path "$env:TEMP/EdgeDeviceReport_$(Get-Date -Format yyyyMMdd).csv"
    return $report
}