# バッチ設計書 18-Conversations::ResolutionJob

## 概要

本ドキュメントは、Chatwootシステムにおける非アクティブ会話の自動解決処理を実行するバッチ処理の設計を記述するものです。

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

本バッチは、指定されたアカウントにおいて、設定された期間アクティビティのない会話を自動的に解決済み（resolved）状態に変更する処理を実行します。

**業務上の目的・背景**：カスタマーサポート業務において、顧客からの反応がない会話が長期間オープン状態のまま残ると、会話一覧が煩雑になり、エージェントの作業効率が低下します。本バッチは、設定された期間（auto_resolve_after分）が経過した非アクティブな会話を自動的に解決済みにすることで、会話一覧の整理と運用効率の向上を実現します。オプションで自動解決メッセージの送信やラベルの付与も可能です。

**バッチの実行タイミング**：ConversationsResolutionSchedulerJobから5分毎にトリガーされます。

**主要な処理内容**：
1. アカウントのauto_resolve設定を確認
2. 解決対象の会話をスコープで取得（resolvable_not_waiting or resolvable_all）
3. 処理件数をBULK_ACTIONS_LIMIT（100件）に制限
4. 各会話に対して：
   - 自動解決メッセージを送信（設定時）
   - 自動解決ラベルを付与（設定時）
   - ステータスを解決済みに変更

**前後の処理との関連**：本バッチはConversationsResolutionSchedulerJob（親ジョブ）からキューイングされる子ジョブです。親ジョブから渡されたアカウント単位で処理を実行します。

**影響範囲**：指定アカウント内の非アクティブ会話のstatusが更新されます。また、設定によりメッセージの作成やラベルの付与が行われます。

## バッチ種別

ステータス更新 / 会話管理

## 実行スケジュール

| 項目 | 内容 |
|-----|------|
| 実行頻度 | 随時（親ジョブからトリガー） |
| 実行時刻 | 不定 |
| 実行曜日 | 毎日 |
| 実行日 | 毎日 |
| トリガー | ConversationsResolutionSchedulerJob経由 |

## 実行条件

### 前提条件

| 条件 | 説明 |
|-----|------|
| アカウントにauto_resolve_after設定があること | 自動解決期間が設定されている必要がある |
| 対象会話が存在すること | 解決対象となる非アクティブ会話が存在する必要がある |

### 実行可否判定

- アカウントのauto_resolve_after設定が0または未設定の場合、resolvableスコープが空を返す
- contact_idがnilの会話は除外される（孤立会話対策）

## 入力仕様

### 入力パラメータ

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

### 入力データソース

| データソース | 形式 | 説明 |
|-------------|------|------|
| accounts | DB | アカウント設定（auto_resolve_after, auto_resolve_message, auto_resolve_label, auto_resolve_ignore_waiting） |
| conversations | DB | 解決対象の会話レコード |

## 出力仕様

### 出力データ

| 出力先 | 形式 | 説明 |
|-------|------|------|
| conversations | DB | statusがresolvedに更新される |
| messages | DB | 自動解決メッセージが作成される（設定時） |
| labels | DB | 自動解決ラベルが付与される（設定時） |

### 出力ファイル仕様

ファイル出力はありません。

## 処理フロー

### 処理シーケンス

```
1. バッチ開始
   └─ lowキューから起動
2. 解決対象会話のスコープを構築
   └─ auto_resolve_ignore_waitingに応じてスコープを選択
3. 孤立会話を除外
   └─ where.not(contact_id: nil)
4. 処理件数を制限
   └─ limit(BULK_ACTIONS_LIMIT) = 100件
5. 各会話に対して処理
   └─ 5-1. 自動解決メッセージを送信（auto_resolve_message設定時）
   └─ 5-2. 自動解決ラベルを付与（auto_resolve_label設定時）
   └─ 5-3. toggle_statusでステータスを変更
6. バッチ終了
```

### フローチャート

```mermaid
flowchart TD
    A[バッチ開始] --> B{auto_resolve_ignore_waiting?}
    B -->|Yes| C[resolvable_not_waiting取得]
    B -->|No| D[resolvable_all取得]
    C --> E[contact_id非NULLでフィルタ]
    D --> E
    E --> F[limit BULK_ACTIONS_LIMIT]
    F --> G{会話あり?}
    G -->|No| K[バッチ終了]
    G -->|Yes| H{auto_resolve_message設定?}
    H -->|Yes| I[AutoResolveテンプレートでメッセージ送信]
    H -->|No| J{auto_resolve_label設定?}
    I --> J
    J -->|Yes| L[ラベルを付与]
    J -->|No| M[toggle_status呼び出し]
    L --> M
    M --> G
```

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

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

| 処理 | 対象テーブル | 操作種別 | 概要 |
|-----|-------------|---------|------|
| 解決対象会話取得 | conversations | SELECT | resolvableスコープで検索 |
| メッセージ作成 | messages | INSERT | 自動解決メッセージを作成 |
| ラベル付与 | labels, conversation_labels | INSERT/UPDATE | ラベルを付与 |
| ステータス更新 | conversations | UPDATE | statusをresolvedに変更 |

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

#### conversations

| 操作 | 項目（カラム名） | 更新値・取得条件 | 備考 |
|-----|-----------------|-----------------|------|
| SELECT | id, status, last_activity_at, waiting_since, contact_id | status=open, last_activity_at < auto_resolve_after分前 | スコープに応じて条件変更 |
| UPDATE | status | resolved (toggle_statusによる) | 各会話個別に更新 |

## エラー処理

### エラーケース一覧

| エラーコード | エラー種別 | 発生条件 | 対処方法 |
|------------|----------|---------|---------|
| - | StandardError | DB操作失敗時 | Sidekiqの標準リトライ機構により再実行 |

### リトライ仕様

| 項目 | 内容 |
|-----|------|
| リトライ回数 | Sidekiqのデフォルト設定 |
| リトライ間隔 | 指数バックオフ |
| リトライ対象エラー | StandardError全般 |

### 障害時対応

バッチ失敗時は次回の定期実行（5分後）で自動的にリカバリされます。緊急時はRailsコンソールから手動実行可能です：
```ruby
Conversations::ResolutionJob.perform_now(account: Account.find(1))
```

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

| 項目 | 内容 |
|-----|------|
| トランザクション範囲 | 各会話の処理は個別トランザクション |
| コミットタイミング | 各会話の処理完了時 |
| ロールバック条件 | 個別会話の処理失敗時 |

## パフォーマンス要件

| 項目 | 内容 |
|-----|------|
| 想定処理件数 | 最大100件（BULK_ACTIONS_LIMIT） |
| 目標処理時間 | 数秒〜数十秒 |
| メモリ使用量上限 | limit指定により一定に制御 |

## 排他制御

- 同一アカウントでの重複実行が発生する可能性あり
- 各会話の処理は個別トランザクションで行われるため、競合時は後勝ち
- 5分間隔で実行されるため、重複実行のリスクは低い

## ログ出力

| ログ種別 | 出力タイミング | 出力内容 |
|---------|--------------|---------|
| 開始ログ | バッチ開始時 | Sidekiq標準ログ |
| 進捗ログ | - | 明示的なログ出力なし |
| 終了ログ | バッチ終了時 | Sidekiq標準ログ |
| エラーログ | エラー発生時 | Sidekiq標準エラーログ |

## 監視・アラート

| 監視項目 | 閾値 | アラート先 |
|---------|-----|----------|
| 処理時間 | 5分以上 | Sidekiq監視システム |
| エラー件数 | 1件以上 | Sidekiq監視システム |

## 備考

- BULK_ACTIONS_LIMIT = 100（lib/limits.rb）
- resolvable_not_waiting: waiting_since IS NULLの会話のみ対象（顧客待ち状態の会話は除外）
- resolvable_all: 全てのオープン会話が対象
- auto_resolve_after: 分単位で指定（例: 1440 = 24時間）
- toggle_statusメソッド: オープン会話を解決済みに、解決済み会話をオープンに切り替え
- MessageTemplates::Template::AutoResolve: 自動解決メッセージのテンプレート処理
- 孤立会話（contact_id=nil）は処理対象から除外される
