Java バッチの前処理・本処理・後処理を CsvImportJob で実装する

import java.io.BufferedReader;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileWriter;
import java.io.InputStreamReader;
import java.util.ArrayList;
import java.util.List;
import java.util.logging.Level;
import java.util.logging.Logger;

/**
 * CSV 取込バッチ — ジョブマネージャ連携版
 *
 * 終了コード:
 *   0 ... 正常終了（全件処理成功）
 *   1 ... 警告終了（スキップあり・後続ジョブは続行）
 *   2 ... 異常終了（処理中断・後続ジョブを止める）
 *
 * リラン設計:
 *   - チェックポイントファイル（.done）が存在する場合はスキップ
 *   - 多重起動防止: ロックファイル（.lock）を起動時に作成・終了時に削除
 */
public class CsvImportJob {
    private static final Logger LOGGER = Logger.getLogger(CsvImportJob.class.getName());
    private static final int EXPECTED_COLUMNS = 4;
    private static final int MAX_ERRORS = 100;

    private final File inputFile;
    private final File lockFile;
    private final File doneFile;
    private BufferedReader reader;
    private int totalCount;
    private int successCount;
    private final List<String> errors = new ArrayList<String>();

    public CsvImportJob(File inputFile) {
        this.inputFile = inputFile;
        this.lockFile  = new File(inputFile.getParent(), inputFile.getName() + ".lock");
        this.doneFile  = new File(inputFile.getParent(), inputFile.getName() + ".done");
    }

    /** 前処理: ファイル確認・多重起動防止・リラン判定 */
    public void initialize() throws Exception {
        // リラン判定: 前回正常終了していればスキップ
        if (doneFile.exists()) {
            LOGGER.info("[SKIP] 処理済みファイルを検出: " + doneFile.getName() + " — リラン対象外");
            System.exit(0);
        }
        // 多重起動防止: ロックファイルが存在すれば起動しない
        if (lockFile.exists()) {
            LOGGER.severe("[ERROR] 多重起動を検出: " + lockFile.getName() + " が存在します");
            System.exit(2);
        }
        // ロックファイル作成（PID と起動時刻を記録）
        try (FileWriter fw = new FileWriter(lockFile)) {
            fw.write("pid=" + ProcessHandle.current().pid()
                + " started=" + System.currentTimeMillis());
        }
        if (!inputFile.exists()) {
            LOGGER.severe("[ERROR] 入力ファイルが見つかりません: " + inputFile);
            lockFile.delete();
            System.exit(2);
        }
        reader = new BufferedReader(
            new InputStreamReader(new FileInputStream(inputFile), "UTF-8"));
        String header = reader.readLine();
        if (header == null) {
            LOGGER.severe("[ERROR] 入力ファイルが空: " + inputFile.getName());
            lockFile.delete();
            System.exit(2);
        }
        LOGGER.info("[START] ジョブ開始 file=" + inputFile.getName());
    }

    /** 本処理: 1行ずつ読み込んでバリデーション */
    public int execute() throws Exception {
        String line;
        int lineNum = 1;
        while ((line = reader.readLine()) != null) {
            lineNum++;
            totalCount++;
            if (line.trim().isEmpty()) continue;
            String[] cols = line.split(",", -1);
            if (cols.length != EXPECTED_COLUMNS) {
                errors.add("行" + lineNum + ": カラム数不一致(" + cols.length + ")");
                if (errors.size() >= MAX_ERRORS) {
                    LOGGER.warning("[WARN] エラー上限(" + MAX_ERRORS + "件)到達 — 中断");
                    return 2;
                }
                continue;
            }
            if (cols[0].trim().isEmpty() || cols[1].trim().isEmpty()) {
                errors.add("行" + lineNum + ": 必須項目が空");
                continue;
            }
            successCount++;
        }
        return errors.isEmpty() ? 0 : 1;
    }

    /** 後処理: サマリ出力・ロック解除・完了フラグ書き込み */
    public void terminate(int exitCode) {
        if (reader != null) { try { reader.close(); } catch (Exception e) { /* ignore */ } }

        // 監視システムが拾えるキーワードを含むサマリログ
        // ジョブ名・総件数・成功件数・エラー件数・終了コードを必ず含める
        String status = exitCode == 0 ? "SUCCESS" : exitCode == 1 ? "WARNING" : "ERROR";
        LOGGER.info(String.format("[%s] job=CsvImportJob total=%d success=%d error=%d exitCode=%d",
            status, totalCount, successCount, errors.size(), exitCode));
        for (String err : errors) { LOGGER.warning("[DETAIL] " + err); }

        // 正常/警告終了時は完了フラグを書き込み、次回リランをスキップ
        if (exitCode < 2) {
            try (FileWriter fw = new FileWriter(doneFile)) {
                fw.write("completed=" + System.currentTimeMillis()
                    + " success=" + successCount + " errors=" + errors.size());
            } catch (Exception e) {
                LOGGER.warning("[WARN] 完了フラグの書き込み失敗: " + e.getMessage());
            }
        }
        // ロックファイル削除（異常終了時も必ず削除）
        lockFile.delete();
    }

    /**
     * エントリポイント — ジョブマネージャから呼ばれる想定
     *
     * 起動例（JP1 / cron）:
     *   java -Xmx512m -cp batch.jar CsvImportJob /data/import/sales_20240501.csv
     *
     * HA クラスタ注意:
     *   active-standby 切替後は同じファイルで二重起動が起こりうる。
     *   ロックファイルと .done ファイルを共有ストレージ上に置くこと。
     */
    public static void main(String[] args) {
        if (args.length < 1) {
            System.err.println("使い方: java CsvImportJob <CSVパス>");
            System.exit(2);
            return;
        }
        CsvImportJob job = new CsvImportJob(new File(args[0]));
        int exitCode = 2;
        try {
            job.initialize();
            exitCode = job.execute();
        } catch (Exception e) {
            LOGGER.log(Level.SEVERE, "[ERROR] 予期しない例外 job=CsvImportJob", e);
        } finally {
            job.terminate(exitCode);
        }
        // ジョブマネージャに終了コードを返す — return ではなく必ず System.exit() を使う
        System.exit(exitCode);
    }
}