# バッチ設計書 23-Sla::ProcessAccountAppliedSlasJob

## 概要

本ドキュメントは、Chatwootシステム（Enterprise版）におけるアカウント単位SLA処理ジョブ（Sla::ProcessAccountAppliedSlasJob）の設計仕様を記載したものである。

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

本バッチは、特定のアカウントに適用されているアクティブなSLA（applied_slas）を抽出し、各SLAに対して個別の評価ジョブをキューイングする処理を行う。

**業務上の目的・背景**：SLA管理では、各会話に対して適用されたSLAポリシーの遵守状況を継続的に監視する必要がある。本バッチは、アカウント単位でアクティブなSLAをフィルタリングし、処理対象を効率的に絞り込む中間層の役割を担う。active（監視中）またはactive_with_misses（一部違反あり）のステータスを持つSLAのみを対象とすることで、既に完了（hit/missed）したSLAの不要な再評価を防ぎ、システムリソースを効率的に活用する。

**バッチの実行タイミング**：Sla::TriggerSlasForAccountsJob（No.22）から呼び出される。親ジョブが5分毎に実行されるため、本ジョブも同様の頻度で実行される。

**主要な処理内容**：
1. 引数として渡されたアカウントオブジェクトを受け取る
2. アカウントに関連付けられたapplied_slasをsla_statusでフィルタリング
3. active/active_with_missesステータスのSLAを抽出
4. 各SLAに対してSla::ProcessAppliedSlaJobをキューイング

**前後の処理との関連**：本バッチはSla::TriggerSlasForAccountsJob（No.22）から呼び出される子ジョブである。処理の後続として、各applied_slaに対してSla::ProcessAppliedSlaJob（No.24）がキューイングされ、実際のSLA評価処理が実行される。

**影響範囲**：対象アカウントのapplied_slasの評価処理のトリガー、Sidekiqキューへのジョブ追加

## バッチ種別

スケジューラー / SLA処理中間層

## 実行スケジュール

| 項目 | 内容 |
|-----|------|
| 実行頻度 | 5分毎（親ジョブ経由） |
| 実行時刻 | TriggerSlasForAccountsJobからのキューイング後 |
| 実行曜日 | 毎日 |
| 実行日 | 毎日 |
| トリガー | Sla::TriggerSlasForAccountsJob.perform_later |

## 実行条件

### 前提条件

| 条件 | 説明 |
|-----|------|
| エディション | Enterprise版であること |
| アカウント | 有効なアカウントオブジェクトが渡されること |
| applied_slas | アカウントにアクティブなSLAが適用されていること |

### 実行可否判定

```ruby
# アクティブなSLAのみ対象
account.applied_slas.where(sla_status: %w[active active_with_misses])
```

## 入力仕様

### 入力パラメータ

| パラメータ名 | 型 | 必須 | デフォルト値 | 説明 |
|-------------|-----|-----|-------------|------|
| account | Account | Yes | - | 処理対象のアカウントオブジェクト |

### 入力データソース

| データソース | 形式 | 説明 |
|-------------|------|------|
| accounts | DB | アカウント情報 |
| applied_slas | DB | 適用済みSLA情報 |

## 出力仕様

### 出力データ

| 出力先 | 形式 | 説明 |
|-------|------|------|
| Sidekiqキュー | Job | ProcessAppliedSlaJobのエンキュー |

### 出力ファイル仕様

ファイル出力なし

## 処理フロー

### 処理シーケンス

```
1. performメソッド実行
   └─ アカウントオブジェクトを引数として受け取り

2. applied_slasの取得
   └─ account.applied_slas.where(sla_status: ['active', 'active_with_misses'])

3. 各applied_slaに対して
   └─ Sla::ProcessAppliedSlaJob.perform_later(applied_sla)
```

### フローチャート

```mermaid
flowchart TD
    A[バッチ開始] --> B[account.applied_slas取得]
    B --> C[sla_statusでフィルタリング]
    C --> D{active/active_with_misses?}
    D -->|Yes| E[each処理開始]
    D -->|No| Z[バッチ終了]
    E --> F[ProcessAppliedSlaJob.perform_later]
    F --> G{次のapplied_sla?}
    G -->|Yes| F
    G -->|No| Z
```

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

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

| 処理 | 対象テーブル | 操作種別 | 概要 |
|-----|-------------|---------|------|
| SLA取得 | applied_slas | SELECT | アクティブなSLAの取得 |

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

#### applied_slas

| 操作 | 項目（カラム名） | 更新値・取得条件 | 備考 |
|-----|-----------------|-----------------|------|
| SELECT | * | account_id = {account.id} AND sla_status IN ('active', 'active_with_misses') | ステータスでフィルタ |

## エラー処理

### エラーケース一覧

| エラーコード | エラー種別 | 発生条件 | 対処方法 |
|------------|----------|---------|---------|
| - | NoMethodError | アカウントがnilの場合 | Sidekiqリトライ |
| - | StandardError | ジョブキューイング失敗 | Sidekiqリトライ |

### リトライ仕様

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

### 障害時対応

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

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

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

## パフォーマンス要件

| 項目 | 内容 |
|-----|------|
| 想定処理件数 | アカウントあたりのアクティブSLA数 |
| 目標処理時間 | SLA数に依存（通常は数秒以内） |
| メモリ使用量上限 | 特に制限なし |

## 排他制御

- 親ジョブからの呼び出しタイミングで制御
- 同一アカウントの同時処理は親ジョブの制御に依存

## ログ出力

| ログ種別 | 出力タイミング | 出力内容 |
|---------|--------------|---------|
| - | - | 本ジョブでは明示的なログ出力なし |

## 監視・アラート

| 監視項目 | 閾値 | アラート先 |
|---------|-----|----------|
| ジョブ実行エラー | 発生時 | Sidekiq監視 |
| キュー滞留 | mediumキュー滞留時 | 運用担当 |

## 備考

- Enterprise版専用機能
- キューはmediumを使用（優先度中）
- sla_statusの値：
  - active（0）：監視中、違反なし
  - hit（1）：SLA達成（会話解決後）
  - missed（2）：SLA未達成（会話解決後）
  - active_with_misses（3）：監視中、一部違反あり
- active/active_with_missesのみを対象とすることで、解決済み会話のSLAは再評価しない
