# バッチ設計書 22-Sla::TriggerSlasForAccountsJob

## 概要

本ドキュメントは、Chatwootシステム（Enterprise版）におけるSLAトリガージョブ（Sla::TriggerSlasForAccountsJob）の設計仕様を記載したものである。

### 本バッチの処理概要

本バッチは、SLAポリシーが設定されているアカウントに対して、SLA処理ジョブをスケジュールするスケジューラーバッチである。

**業務上の目的・背景**：SLA（Service Level Agreement）は、顧客サポートにおける応答時間や解決時間の目標を定義するもので、企業が顧客に約束するサービス品質の基準となる。本バッチは、SLAポリシーを持つ全アカウントに対してSLA評価処理を定期的に実行し、初回応答時間（FRT）、次回応答時間（NRT）、解決時間（RT）の各閾値を監視することで、SLA違反の検出と通知を可能にする。これにより、サポートチームはSLA遵守状況をリアルタイムで把握し、違反が発生する前に対処することができる。

**バッチの実行タイミング**：Enterprise版のTriggerScheduledItemsJobから5分毎にトリガーされる。

**主要な処理内容**：
1. sla_policiesテーブルとjoinsしてSLAポリシーを持つアカウントを抽出
2. find_eachで各アカウントを効率的にイテレーション
3. 各アカウントに対してSla::ProcessAccountAppliedSlasJobをキューイング
4. ログ出力による進捗追跡

**前後の処理との関連**：本バッチはEnterprise版TriggerScheduledItemsJobから呼び出される親ジョブである。処理の後続として、各アカウントに対してSla::ProcessAccountAppliedSlasJob（No.23）がキューイングされ、さらにその先でSla::ProcessAppliedSlaJob（No.24）が実行される階層構造となっている。

**影響範囲**：SLAポリシーを持つ全アカウントのSLA評価処理、applied_slasテーブル、sla_eventsテーブル、SLA違反通知

## バッチ種別

スケジューラー / SLA評価トリガー

## 実行スケジュール

| 項目 | 内容 |
|-----|------|
| 実行頻度 | 5分毎（親ジョブ経由） |
| 実行時刻 | 毎時 0, 5, 10, 15, 20, 25, 30, 35, 40, 45, 50, 55分 |
| 実行曜日 | 毎日 |
| 実行日 | 毎日 |
| トリガー | Enterprise::TriggerScheduledItemsJob（cron: */5 * * * *） |

## 実行条件

### 前提条件

| 条件 | 説明 |
|-----|------|
| エディション | Enterprise版であること |
| SLAポリシー | アカウントにSLAポリシーが設定されていること |

### 実行可否判定

```ruby
# SLAポリシーを持つアカウントのみ対象
Account.joins(:sla_policies).distinct
```

## 入力仕様

### 入力パラメータ

| パラメータ名 | 型 | 必須 | デフォルト値 | 説明 |
|-------------|-----|-----|-------------|------|
| - | - | - | - | パラメータなし |

### 入力データソース

| データソース | 形式 | 説明 |
|-------------|------|------|
| accounts | DB | アカウント情報 |
| sla_policies | DB | SLAポリシー情報（JOIN用） |

## 出力仕様

### 出力データ

| 出力先 | 形式 | 説明 |
|-------|------|------|
| Sidekiqキュー | Job | ProcessAccountAppliedSlasJobのエンキュー |
| Rails.logger | Log | 進捗ログ |

### 出力ファイル仕様

ファイル出力なし

## 処理フロー

### 処理シーケンス

```
1. performメソッド実行
   └─ SLAポリシーを持つアカウントの検索開始

2. Account.joins(:sla_policies).distinct
   └─ sla_policiesテーブルとJOINしてユニークなアカウントを取得

3. find_eachでバッチ処理
   └─ デフォルトバッチサイズ（1000件）でイテレーション

4. 各アカウントに対して
   ├─ ログ出力（アカウントID）
   └─ Sla::ProcessAccountAppliedSlasJob.perform_later(account)
```

### フローチャート

```mermaid
flowchart TD
    A[バッチ開始] --> B[Account.joins sla_policies .distinct]
    B --> C{アカウント存在?}
    C -->|No| Z[バッチ終了]
    C -->|Yes| D[find_each開始]
    D --> E[ログ出力]
    E --> F[ProcessAccountAppliedSlasJob.perform_later]
    F --> G{次のアカウント?}
    G -->|Yes| D
    G -->|No| Z
```

## データベース操作仕様

### 操作別データベース影響一覧

| 処理 | 対象テーブル | 操作種別 | 概要 |
|-----|-------------|---------|------|
| アカウント取得 | accounts | SELECT | SLAポリシーを持つアカウントの取得 |
| JOIN | sla_policies | SELECT | アカウントとのJOIN条件 |

### テーブル別操作詳細

#### accounts / sla_policies

| 操作 | 項目（カラム名） | 更新値・取得条件 | 備考 |
|-----|-----------------|-----------------|------|
| SELECT | accounts.* | sla_policies.account_id = accounts.id | DISTINCT適用 |

## エラー処理

### エラーケース一覧

| エラーコード | エラー種別 | 発生条件 | 対処方法 |
|------------|----------|---------|---------|
| - | ActiveRecord::RecordNotFound | アカウント取得失敗 | Sidekiqリトライ |
| - | StandardError | ジョブキューイング失敗 | Sidekiqリトライ |

### リトライ仕様

| 項目 | 内容 |
|-----|------|
| リトライ回数 | Sidekiqデフォルト設定に依存 |
| リトライ間隔 | Sidekiqデフォルト設定に依存 |
| リトライ対象エラー | 一時的なエラー全般 |

### 障害時対応

- 5分毎に再実行されるため、一時的な障害は次回実行で回復
- 永続的なエラーの場合はSidekiqダッシュボードで確認・対処

## トランザクション仕様

| 項目 | 内容 |
|-----|------|
| トランザクション範囲 | なし（読み取りのみ） |
| コミットタイミング | 該当なし |
| ロールバック条件 | 該当なし |

## パフォーマンス要件

| 項目 | 内容 |
|-----|------|
| 想定処理件数 | SLAポリシーを持つアカウント数 |
| 目標処理時間 | アカウント数に依存 |
| メモリ使用量上限 | find_eachによるバッチ処理で制御 |

## 排他制御

- 5分間隔の実行により同時実行を抑制
- 子ジョブは非同期キューイングのため、本ジョブの処理時間は短い

## ログ出力

| ログ種別 | 出力タイミング | 出力内容 |
|---------|--------------|---------|
| 進捗ログ | アカウント処理時 | Enqueuing ProcessAccountAppliedSlasJob for account {id} |

## 監視・アラート

| 監視項目 | 閾値 | アラート先 |
|---------|-----|----------|
| ジョブ実行エラー | 発生時 | Sidekiq監視 |
| 処理時間 | 5分超過時 | 運用担当 |

## 備考

- Enterprise版専用機能
- prepend_mod_withによりTriggerScheduledItemsJobを拡張
- find_eachを使用することで大量アカウントでもメモリ効率的に処理
- 子ジョブへの処理委譲により、各アカウントの処理は並列化される
