Promise.allで独立したバッチ処理ステップを並列化しつつ個別のエラーを管理する

// ❌ 逐次実行: 合計時間が長い
public async main() {
  await this.step1_売上データ同期();     // 30秒
  await this.step2_在庫データ更新();     // 30秒
  await this.step3_配送ステータス更新(); // 30秒
  await this.step4_請求データ更新();     // 30秒
  // 合計: 約120秒
}

// ❌ Promise.all: 1つのエラーで全部キャンセル
public async main() {
  await Promise.all([
    this.step1(),  // step1 が throw すると...
    this.step2(),  // step2, 3, 4 の結果が無視される
    this.step3(),
    this.step4(),
  ]);
}

class SyncDailyReports {
  // 各ステップの状態を個別に管理
  private 売上データ同期 = { error: null as string | null, fileId: "" };
  private 在庫データ更新 = { error: null as string | null, fileId: "" };
  private 配送ステータス更新 = { error: null as string | null, fileId: "" };
  private 請求データ更新 = { error: null as string | null, fileId: "" };

  public async main() {
    Logger.task("【処理開始】日次データ同期");

    try {
      // 4ステップを並列実行 — 1つが失敗しても他は続く
      await Promise.all([
        this.step1_売上データ同期(),
        this.step2_在庫データ更新(),
        this.step3_配送ステータス更新(),
        this.step4_請求データ更新(),
      ]);

      await this.broadcastOutput(); // 全ステップ完了後に結果をまとめて通知
    } finally {
      this.キャッシュクリア();
    }
  }

  private async step1_売上データ同期() {
    try {
      await this.get売上データ更新対象();
      await this.create売上データCSV();
      Logger.success("【ステップ1完了】売上データ同期");
    } catch (error) {
      // エラーをプロパティに記録するだけ — throw しない
      this.売上データ同期.error = "売上データ処理中にエラーが発生しました。";
      Logger.error("【ステップ1失敗】売上データ同期");
    }
    // ↑ catch を抜けても Promise は resolved — Promise.all はキャンセルされない
  }

  private async step2_在庫データ更新() {
    try {
      await this.get在庫データ更新対象();
      await this.create在庫データCSV();
      Logger.success("【ステップ2完了】在庫データ更新");
    } catch {
      this.在庫データ更新.error = "在庫データ処理中にエラーが発生しました。";
      Logger.error("【ステップ2失敗】在庫データ更新");
    }
  }

  // step3, step4 も同様...
}

private async broadcastOutput() {
  const steps = [
    { name: "売上データ同期", state: this.売上データ同期 },
    { name: "在庫データ更新", state: this.在庫データ更新 },
    { name: "配送ステータス更新", state: this.配送ステータス更新 },
    { name: "請求データ更新", state: this.請求データ更新 },
  ];

  const errors = steps
    .filter((s) => s.state.error)
    .map((s) => `❌ ${s.name}: ${s.state.error}`);

  const successes = steps
    .filter((s) => !s.state.error)
    .map((s) => `✅ ${s.name}`);

  const msg = [
    "【日次データ同期完了】",
    ...successes,
    ...(errors.length > 0 ? ["", "--- エラー ---", ...errors] : []),
  ].join("\n");

  await Notification.send(msg);
}

逐次実行: 30 + 30 + 30 + 30 = 約120秒

並列実行: max(30, 30, 30, 30) = 約30秒

// Promise.allSettled を使うアプローチ
const results = await Promise.allSettled([
  this.step1(),
  this.step2(),
  this.step3(),
  this.step4(),
]);

results.forEach((result, i) => {
  if (result.status === "rejected") {
    console.error(`Step ${i + 1} failed:`, result.reason);
  }
});

// 各ステップの状態を型で明確に定義する
private step1 = { error: null as string | null, fileId: "" };

// ステップメソッドはエラーをキャッチしてプロパティに記録
private async step1_処理() {
  try {
    // 処理...
  } catch {
    this.step1.error = "処理中にエラーが発生しました。";
  }
  // throw しない → Promise は常に resolved
}

// Promise.all で並列実行 → 全ステップ完了を待つ
await Promise.all([
  this.step1_処理(),
  this.step2_処理(),
]);

// 完了後に状態を確認して通知
await this.結果通知();

// 必ずクリア
this.キャッシュクリア();