# 実行前提:


# - PowerShell 7.0 以降がインストールされていること。


# - C:\Temp\Logs ディレクトリが存在し、中に複数のテキストファイルがあること。


# - ファイルはUTF-8エンコーディングであること（エンコーディング問題の回避）。

param(
    [string]$LogDirectory = "C:\Temp\Logs",
    [string]$SearchPattern = "Error",
    [int]$ThrottleLimit = 5 # 同時実行数
)

# ロギング設定

$LogFile = Join-Path (Get-TempPath) "ParallelFileProcessing_$(Get-Date -Format 'yyyyMMdd_HHmmss').log"
$ErrorActionPreference = "Continue" # デフォルトはContinue。必要に応じてStopに設定。

Function Write-StructuredLog {
    param(
        [string]$Level,
        [string]$Message,
        [object]$Data = $null
    )
    $Timestamp = (Get-Date -Format "yyyy-MM-dd HH:mm:ss.fff")
    $LogEntry = @{
        Timestamp = $Timestamp
        Level = $Level
        Message = $Message
        Data = $Data | Out-String | ConvertFrom-Json -ErrorAction SilentlyContinue # データがJSONの場合
    }

    # 構造化ログをJSON形式でファイルに出力

    $LogEntry | ConvertTo-Json -Depth 5 | Out-File -FilePath $LogFile -Append -Encoding UTF8
    Write-Host "$Timestamp [$Level] $Message"
}

Write-StructuredLog -Level "INFO" -Message "処理を開始します。ログファイル: $LogFile"

try {

    # 処理対象のファイルリストを取得

    $files = Get-ChildItem -Path $LogDirectory -Filter "*.log", "*.txt" -File -Recurse

    if (-not $files) {
        Write-StructuredLog -Level "WARN" -Message "対象ファイルが見つかりませんでした。ディレクトリ: $LogDirectory"
        exit
    }

    Write-StructuredLog -Level "INFO" -Message "並列処理を開始します。対象ファイル数: $($files.Count), スロットル: $ThrottleLimit"

    $results = $files | ForEach-Object -Parallel {
        param($file, $SearchPattern, $LogFile) # スクリプトブロック内で利用する変数を明示的に渡す

        # スクリプトブロック内でWrite-StructuredLog関数が利用できるように再定義（あるいはモジュール化してImport）


        # 簡単化のため、ここでは直接Write-HostとOut-Fileを利用

        Function Write-ThreadLog {
            param(
                [string]$Level,
                [string]$Message,
                [object]$Data = $null
            )
            $Timestamp = (Get-Date -Format "yyyy-MM-dd HH:mm:ss.fff")
            $LogEntry = @{
                Timestamp = $Timestamp
                Level = $Level
                File = $file.FullName
                Message = $Message
                Data = $Data | Out-String | ConvertFrom-Json -ErrorAction SilentlyContinue
            }
            $LogEntry | ConvertTo-Json -Depth 5 | Out-File -FilePath $LogFile -Append -Encoding UTF8
        }

        try {
            Write-ThreadLog -Level "DEBUG" -Message "ファイル処理開始" -Data @{FileName = $file.Name}

            # ファイル内容を読み込み、パターンを検索

            $content = Get-Content -Path $file.FullName -Encoding UTF8 -ErrorAction Stop
            $matches = $content | Select-String -Pattern $SearchPattern -ErrorAction SilentlyContinue

            if ($matches) {
                Write-ThreadLog -Level "INFO" -Message "パターン「$SearchPattern」が見つかりました" -Data @{FileName = $file.Name; MatchCount = $matches.Count}
                [PSCustomObject]@{
                    FileName = $file.Name
                    FullPath = $file.FullName
                    MatchesFound = $true
                    MatchCount = $matches.Count
                }
            } else {
                Write-ThreadLog -Level "INFO" -Message "パターン「$SearchPattern」は見つかりませんでした" -Data @{FileName = $file.Name}
                [PSCustomObject]@{
                    FileName = $file.Name
                    FullPath = $file.FullName
                    MatchesFound = $false
                    MatchCount = 0
                }
            }
        }
        catch {
            Write-ThreadLog -Level "ERROR" -Message "ファイル処理中にエラーが発生しました" -Data @{FileName = $file.Name; ErrorMessage = $_.Exception.Message; ErrorDetails = $_ | ConvertTo-Json -Compress}
            [PSCustomObject]@{
                FileName = $file.Name
                FullPath = $file.FullName
                MatchesFound = $false
                Error = $_.Exception.Message
            }
        }
    } -ThrottleLimit $ThrottleLimit -AsJob # -AsJob を指定するとバックグラウンドジョブとして実行され、Get-Jobなどで進捗確認可能

    # -AsJob を使用しない場合（Foreground実行）


    # $results = $files | ForEach-Object -Parallel { ... } -ThrottleLimit $ThrottleLimit

    # -AsJob を使用した場合、ジョブの完了を待機

    if ($results -is [System.Management.Automation.Job]) {
        Write-StructuredLog -Level "INFO" -Message "バックグラウンドジョブが開始されました。ID: $($results.Id)"
        $results | Wait-Job | Out-Null
        $jobResults = $results | Receive-Job
        Write-StructuredLog -Level "INFO" -Message "バックグラウンドジョブが完了しました。"
        $jobResults
    } else {
        $results
    }
}
catch {
    Write-StructuredLog -Level "FATAL" -Message "スクリプト実行中に致命的なエラーが発生しました" -Data @{ErrorMessage = $_.Exception.Message; ErrorDetails = $_ | ConvertTo-Json -Compress}
}
finally {
    Write-StructuredLog -Level "INFO" -Message "処理を終了します。"
}

# 実行前提:


# - PowerShell 7.0 以降がインストールされていること。


# - ターゲットとなるリモートWindowsホストが複数存在し、WinRMが有効になっていること。


# - 現在のユーザーがリモートホストに対してWMI/CIMアクセス権限を持っていること。


# - `Get-Credential` で取得する認証情報が必要です。実際の運用ではSecretManagementを使用推奨。

param(
    [string[]]$ComputerNames = @("SERVER01", "SERVER02", "SERVER03", "SERVER04", "SERVER05"), # 実際のホスト名に置き換える
    [int]$ThrottleLimit = 3, # 同時接続数を制限
    [int]$RetryCount = 3, # 再試行回数
    [int]$RetryDelaySeconds = 5, # 再試行間隔（秒）
    [int]$CimTimeoutSeconds = 30 # CIMコマンドレットのタイムアウト（秒）
)

# ロギング設定 (コード例1と同様の関数を再利用またはモジュールとしてImport)


# 簡略化のため、ここでは簡単なWrite-HostとOut-Fileを使用

$LogFile = Join-Path (Get-TempPath) "ParallelCIM_$(Get-Date -Format 'yyyyMMdd_HHmmss').log"

Function Write-Log {
    param([string]$Level, [string]$Message)
    $Timestamp = (Get-Date -Format "yyyy-MM-dd HH:mm:ss.fff")
    "$Timestamp [$Level] $Message" | Out-File -FilePath $LogFile -Append -Encoding UTF8
    Write-Host "$Timestamp [$Level] $Message"
}

Write-Log -Level "INFO" -Message "CIM並列処理を開始します。ログファイル: $LogFile"

# 認証情報の取得 (本番環境では SecretManagement を使用することを強く推奨)


# $Credential = Get-Credential -Message "リモートホストへの接続認証情報を入力してください"

$Credential = [System.Management.Automation.PSCredential]::new("YourUser", (ConvertTo-SecureString "YourPassword" -AsPlainText -Force)) # テスト用、本番では非推奨

$results = @()
$measureResult = Measure-Command {
    $jobs = $ComputerNames | ForEach-Object -Parallel {
        param($computerName, $Credential, $LogFile, $RetryCount, $RetryDelaySeconds, $CimTimeoutSeconds)

        # 各Runspaceでログ関数を定義 (またはモジュールをImport)

        Function Write-ThreadLog {
            param([string]$Level, [string]$Message)
            $Timestamp = (Get-Date -Format "yyyy-MM-dd HH:mm:ss.fff")
            "$Timestamp [$Level] [$computerName] $Message" | Out-File -FilePath $LogFile -Append -Encoding UTF8
            Write-Host "$Timestamp [$Level] [$computerName] $Message"
        }

        $attempts = 0
        do {
            $attempts++
            try {
                Write-ThreadLog -Level "INFO" -Message "イベントログ取得を試行中 (試行 $attempts/$RetryCount)..."

                # リモートホストから最新の5件のSystemイベントログを取得

                $events = Get-CimInstance -ClassName Win32_NTLogEvent `
                    -ComputerName $computerName `
                    -Filter "Logfile = 'System'" `
                    -MaxItems 5 `
                    -Credential $Credential `
                    -OperationTimeoutInSeconds $CimTimeoutSeconds `
                    -ErrorAction Stop

                Write-ThreadLog -Level "INFO" -Message "イベントログ取得成功。取得件数: $($events.Count)"
                return [PSCustomObject]@{
                    ComputerName = $computerName
                    Status = "Success"
                    EventCount = $events.Count
                    Events = $events | Select-Object -ExpandProperty Message | Out-String # メッセージのみ抽出
                    Timestamp = (Get-Date)
                }
            }
            catch {
                $errorMessage = $_.Exception.Message
                Write-ThreadLog -Level "ERROR" -Message "CIM操作エラー: $errorMessage (試行 $attempts/$RetryCount)"

                if ($attempts -lt $RetryCount) {
                    Write-ThreadLog -Level "WARN" -Message "再試行します。待機時間: $RetryDelaySeconds秒..."
                    Start-Sleep -Seconds $RetryDelaySeconds
                } else {
                    Write-ThreadLog -Level "ERROR" -Message "最大再試行回数に達しました。処理をスキップします。"
                    return [PSCustomObject]@{
                        ComputerName = $computerName
                        Status = "Failed"
                        Error = $errorMessage
                        Timestamp = (Get-Date)
                    }
                }
            }
        } while ($attempts -lt $RetryCount -and $LASTEXITCODE -ne 0) # CIMエラーの場合、$LASTEXITCODEは必ずしも設定されない
    } -ThrottleLimit $ThrottleLimit -AsJob # ジョブとして実行し、結果をまとめて収集

    # すべてのジョブが完了するまで待機

    $jobs | Wait-Job | Out-Null
    $results = $jobs | Receive-Job -Keep # 結果を収集し、ジョブは削除しない
    $jobs | Remove-Job # ジョブをクリーンアップ
}

Write-Log -Level "INFO" -Message "CIM並列処理が完了しました。"
Write-Log -Level "INFO" -Message "合計実行時間: $($measureResult.TotalSeconds)秒"

$results | Format-Table -AutoSize

# 失敗したホストの集計

$failedHosts = $results | Where-Object { $_.Status -eq "Failed" }
if ($failedHosts.Count -gt 0) {
    Write-Log -Level "WARN" -Message "以下のホストで処理が失敗しました:"
    $failedHosts | ForEach-Object { Write-Log -Level "WARN" -Message "  $($_.ComputerName): $($_.Error)" }
}

Write-Log -Level "INFO" -Message "スクリプトを終了します。"