PART 03 — バッチ処理設計書
スケジュール・ジョブ依存関係・エラーリカバリの定義

┌─────────────── 分
│  ┌──────────── 時
│  │  ┌───────── 日
│  │  │  ┌────── 月
│  │  │  │  ┌─── 曜日（0=日曜）
│  │  │  │  │
0  2  *  *  * /opt/app/batch/daily_summary.sh
  → 意味: 毎日 02:00 に実行（深夜バッチ。オンライン停止後に実行）

0  3  1  *  * /opt/app/batch/monthly_invoice.sh
  → 意味: 毎月1日 03:00 に実行（月次請求バッチ）

*/30 8-18 * * 1-5 /opt/app/batch/stock_sync.sh
  → 意味: 平日 8〜18時の間 30分ごとに実行（在庫同期）

【注意事項】
- 実行時間の最大見積: 30分（通常 5分）
  → 03:30 開始の後続バッチまでに必ず完了させること
- タイムゾーン: Asia/Tokyo（サーバー設定確認必須）
- 同一時刻の重複起動防止: flock を使用（flock -n /var/lock/batch.lock）

【前処理】
1. 処理開始ログを batch_logs テーブルに INSERT（status=RUNNING）
2. 前回実行時刻を batch_control テーブルから取得
   2a. 前回実行日 = 今日の場合 → 二重起動エラー → E01
3. ロックファイル（/var/lock/daily_summary.lock）を確認
   3a. 存在する場合 → 前回バッチが継続中 → E02

【主処理】
4. 処理対象日付を確定（前日: TODAY-1）
5. orders テーブルから対象日付の注文を取得
   WHERE order_date = :target_date
   AND status IN (20, 30, 40)   ← 確定済み・出荷済み・完了
6. 1000件ずつ FETCH してループ処理
7. 各 1000件ごとに daily_summaries テーブルへ UPSERT
   ON CONFLICT (summary_date, category_id) DO UPDATE
8. コミット（1000件ごと）

【後処理】
9. batch_control.last_run_date を TODAY に更新
10. 処理完了ログ（status=SUCCESS, processed_count=N）を batch_logs に UPDATE
11. ロックファイルを削除

【異常終了時】
- ロールバック（STEP 7〜8 のコミット分は保持、途中処理のみロールバック）
- status=FAILED で batch_logs を更新
- Slack #alert チャンネルに通知（エラーコード・処理済み件数・スタックトレース）
- ロックファイルを削除（次回実行を妨げないこと）

■ 処理件数想定
  通常時: 50,000件/日
  ピーク時: 200,000件/日（年末シーズン）
  最大タイムアウト: 60分（60分超でアラート）

■ コミット戦略
  バルクサイズ: 1,000件ごとにコミット
  理由: メモリ使用量を抑えつつ、障害時の再実行範囲を限定

■ インデックス利用確認
  orders テーブル: idx_orders_date（order_date, status）
  実行計画で INDEX SCAN であることを確認すること

■ テーブルロック回避
  SKIP LOCKED を使用して他セッションにロックされた行をスキップ
  SELECT ... FOR UPDATE SKIP LOCKED

■ 並列実行設計
  カテゴリID を分割キーとして 4並列で実行
  各プロセスに担当カテゴリ範囲を引数で渡す
  結果を集約プロセスが最後にマージ

"""
crontab ファイルを解析し、スケジュール情報を一覧化する
pip install croniter
"""
from croniter import croniter
from datetime import datetime

CRONTAB_SAMPLE = """
# 受注取込
0 1 * * * /opt/app/batch/import_orders.sh

# 在庫引当（受注取込後に実行想定）
0 1 * * * /opt/app/batch/allocate_stock.sh

# 日次集計
0 2 * * * /opt/app/batch/daily_summary.sh

# 月次請求
0 3 1 * * /opt/app/batch/monthly_invoice.sh
"""

def parse_crontab(content: str) -> list[dict]:
    jobs = []
    for line in content.strip().splitlines():
        line = line.strip()
        if not line or line.startswith("#"):
            continue
        parts = line.split(None, 5)
        if len(parts) < 6:
            continue
        cron_expr = " ".join(parts[:5])
        command = parts[5]

        base = datetime(2026, 1, 1)
        try:
            it = croniter(cron_expr, base)
            next_runs = [it.get_next(datetime) for _ in range(3)]
            jobs.append({
                "cron": cron_expr,
                "command": command,
                "next_3_runs": [str(r) for r in next_runs],
            })
        except Exception as e:
            jobs.append({"cron": cron_expr, "command": command, "error": str(e)})
    return jobs

def check_conflicts(jobs: list[dict]) -> list[str]:
    """同一分に複数ジョブが起動する衝突を検出"""
    from collections import defaultdict
    schedule_map = defaultdict(list)
    base = datetime(2026, 1, 1)
    for job in jobs:
        if "error" in job:
            continue
        it = croniter(job["cron"], base)
        for _ in range(24 * 7):   # 1週間分チェック
            t = it.get_next(datetime)
            schedule_map[t].append(job["command"])

    conflicts = []
    for t, cmds in schedule_map.items():
        if len(cmds) > 1:
            conflicts.append(f"{t}: {cmds}")
    return conflicts[:5]   # 最初の5件を返す

jobs = parse_crontab(CRONTAB_SAMPLE)
for j in jobs:
    print(f"[{j['cron']}] {j['command']}")
    if "next_3_runs" in j:
        for r in j["next_3_runs"]:
            print(f"  次回実行: {r}")

conflicts = check_conflicts(jobs)
if conflicts:
    print("\n⚠️ 同時刻起動の検出:")
    for c in conflicts:
        print(f"  {c}")