# バッチ設計書 18-Account::SyncStripeCustomerEmailJob

## 概要

本ドキュメントは、StripeカスタマーEメール同期ジョブ（Account::SyncStripeCustomerEmailJob）の設計仕様を記載したものです。

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

Account::SyncStripeCustomerEmailJobは、FizzyアカウントのオーナーのメールアドレスをStripeカスタマー情報と同期する非同期ジョブです。SaaS機能の一部として実装されています。

**業務上の目的・背景**：Stripeを通じた課金処理において、カスタマーのメールアドレスを最新の状態に保つ必要があります。アカウントオーナーのメールアドレスが変更された場合や、オーナーが移譲された場合に、Stripe側のカスタマー情報も更新することで、請求書や通知が正しい宛先に届くようにします。

**バッチの実行タイミング**：サブスクリプションに関連する変更が発生した際にジョブがキューに投入されます。

**主要な処理内容**：
1. サブスクリプションオブジェクトを受け取る
2. sync_customer_email_to_stripeメソッドを呼び出し
3. アカウントオーナーのメールアドレスを取得
4. Stripe::Customer.updateでStripeカスタマー情報を更新

**前後の処理との関連**：Account::Billingモデルの変更やサブスクリプション関連の操作後に実行されます。

**影響範囲**：Stripe上のカスタマーメールアドレス。

## バッチ種別

データ連携

## 実行スケジュール

| 項目 | 内容 |
|-----|------|
| 実行頻度 | 随時（イベント駆動） |
| 実行時刻 | - |
| 実行曜日 | - |
| 実行日 | - |
| トリガー | サブスクリプション関連の変更 |

## 実行条件

### 前提条件

| 条件 | 説明 |
|-----|------|
| Account::Subscriptionレコードが存在 | 有効なサブスクリプション |
| stripe_customer_idが設定済み | Stripeカスタマーが存在 |
| アカウントオーナーが存在 | owner_emailが取得可能 |

### 実行可否判定

サブスクリプションがデシリアライズ可能で、stripe_customer_idが存在する場合に処理を実行。

## 入力仕様

### 入力パラメータ

| パラメータ名 | 型 | 必須 | デフォルト値 | 説明 |
|-------------|-----|-----|-------------|------|
| subscription | Account::Subscription | Yes | - | 同期対象のサブスクリプション |

### 入力データソース

| データソース | 形式 | 説明 |
|-------------|------|------|
| account_subscriptions | DB | サブスクリプション情報 |
| users | DB | アカウントオーナー情報 |
| identities | DB | オーナーのメールアドレス |

## 出力仕様

### 出力データ

| 出力先 | 形式 | 説明 |
|-------|------|------|
| Stripe API | HTTP | カスタマーメールアドレス更新 |

### 出力ファイル仕様

ファイル出力なし

## 処理フロー

### 処理シーケンス

```
1. Subscriptionオブジェクトを受け取り
   └─ Stripe::StripeErrorの場合はポリノミアルリトライ
2. sync_customer_email_to_stripeを呼び出し
   └─ Subscriptionモデルのメソッドを実行
3. stripe_customer_id存在チェック
   └─ 存在しない場合は処理をスキップ
4. owner_email取得
   └─ account.users.owner.first?.identity?.email_address
   └─ 取得できない場合は処理をスキップ
5. Stripe::Customer.updateを呼び出し
   └─ emailパラメータを更新
6. InvalidRequestErrorをハンドル
   └─ カスタマー削除済みの場合は警告ログのみ
```

### フローチャート

```mermaid
flowchart TD
    A[ジョブ開始] --> B[sync_customer_email_to_stripe呼び出し]
    B --> C{stripe_customer_id存在?}
    C -->|なし| D[処理スキップ]
    C -->|あり| E[owner_email取得]
    E --> F{email取得成功?}
    F -->|なし| D
    F -->|あり| G[Stripe::Customer.update呼び出し]
    G --> H{更新成功?}
    H -->|成功| I[ジョブ終了]
    H -->|InvalidRequestError| J{カスタマー削除済み?}
    J -->|はい| K[警告ログ出力]
    K --> I
    J -->|いいえ| L[例外を再raise]
    H -->|StripeError| M[ポリノミアルリトライ]
    D --> I
```

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

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

| 処理 | 対象テーブル | 操作種別 | 概要 |
|-----|-------------|---------|------|
| サブスクリプション取得 | account_subscriptions | SELECT | サブスクリプション情報取得 |
| オーナー取得 | users | SELECT | アカウントオーナー取得 |
| メールアドレス取得 | identities | SELECT | オーナーのメールアドレス取得 |

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

#### account_subscriptions

| 操作 | 項目（カラム名） | 更新値・取得条件 | 備考 |
|-----|-----------------|-----------------|------|
| SELECT | stripe_customer_id | - | Stripe API呼び出しに使用 |

#### users

| 操作 | 項目（カラム名） | 更新値・取得条件 | 備考 |
|-----|-----------------|-----------------|------|
| SELECT | * | account_id = subscription.account_id, role: owner | オーナー取得 |

## エラー処理

### エラーケース一覧

| エラーコード | エラー種別 | 発生条件 | 対処方法 |
|------------|----------|---------|---------|
| - | Stripe::StripeError | Stripe API呼び出し失敗 | ポリノミアルリトライ |
| - | Stripe::InvalidRequestError | カスタマー削除済み等 | 警告ログのみ、成功扱い |

### リトライ仕様

| 項目 | 内容 |
|-----|------|
| リトライ回数 | デフォルト（ActiveJobのリトライ設定） |
| リトライ間隔 | ポリノミアル（wait: :polynomially_longer） |
| リトライ対象エラー | Stripe::StripeError |

### 障害時対応

- Stripe::StripeErrorはポリノミアル間隔でリトライ
- カスタマー削除済み（InvalidRequestError）の場合は警告ログのみで成功扱い
- オーナーが存在しない、またはidentityがない場合はスキップ

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

| 項目 | 内容 |
|-----|------|
| トランザクション範囲 | なし（外部API呼び出しのみ） |
| コミットタイミング | - |
| ロールバック条件 | - |

## パフォーマンス要件

| 項目 | 内容 |
|-----|------|
| 想定処理件数 | 1サブスクリプション/ジョブ |
| 目標処理時間 | 数秒以内（Stripe API応答依存） |
| メモリ使用量上限 | 特に制限なし |

## 排他制御

同一サブスクリプションに対する同時実行の制御は特になし。Stripe側で最終的な整合性を保証。

## ログ出力

| ログ種別 | 出力タイミング | 出力内容 |
|---------|--------------|---------|
| 開始ログ | ジョブ開始時 | Active Jobデフォルト |
| 警告ログ | カスタマー削除済み | stripe_customer_id、エラーメッセージ |
| 終了ログ | ジョブ終了時 | Active Jobデフォルト |
| エラーログ | エラー発生時 | Active Jobデフォルト |

## 監視・アラート

| 監視項目 | 閾値 | アラート先 |
|---------|-----|----------|
| リトライ回数 | 設定依存 | 運用チーム |
| エラー件数 | 設定依存 | 運用チーム |

## 備考

- キューは`default`を使用
- SaaS機能の一部（saas/app/jobs配下に配置）
- Stripe::StripeErrorに対してポリノミアルリトライを設定
- オーナーが存在しない場合（オーナーシップ移譲中、アカウント状態不整合等）はスキップ
- オーナーのidentityがない場合（非アクティブユーザー）もスキップ
- InvalidRequestErrorでカスタマー削除済みの場合は警告ログのみで成功扱い
