経費精算シナリオ（ワークスペース未作成）

public static String createWorkspace(String name, String description) throws IOException {
    String url = BASE_URL + "/api/app-api/sip/platform/v2/workspace/create";
    JsonObject payload = new JsonObject();
    payload.addProperty("name", name);
    payload.addProperty("description", description);
    payload.addProperty("auth_scope", 0);

    Request req = new Request.Builder().url(url).headers(authHeaders())
            .post(RequestBody.create(GSON.toJson(payload), JSON_TYPE)).build();
    try (Response resp = HTTP.newCall(req).execute()) {
        JsonObject data = checkResponse(resp.body().string(), "ワークスペースを作成");
        return data.getAsJsonObject("result").get("workspace_id").getAsString();
    }
}

// 呼び出し例
String workspaceName = "経費精算_"
        + new SimpleDateFormat("yyyyMMdd_HHmmss").format(new Date());
String workspaceId = createWorkspace(workspaceName, "経費精算書類自動化処理スペース");

public static String createCategory(String workspaceId, String name,
        String sampleFilePath, List<Map<String, String>> fields,
        String categoryPrompt) throws IOException {
    File sampleFile = new File(sampleFilePath);
    MultipartBody body = new MultipartBody.Builder().setType(MultipartBody.FORM)
            .addFormDataPart("workspace_id",  workspaceId)
            .addFormDataPart("name",          name)
            .addFormDataPart("extract_model", "llm")
            .addFormDataPart("category_prompt", categoryPrompt)
            .addFormDataPart("fields", GSON.toJson(fields))
            .addFormDataPart("sample_files", sampleFile.getName(),
                    RequestBody.create(sampleFile, MediaType.get(mimeType(sampleFile.getName()))))
            .build();
    Request req = new Request.Builder().url(BASE_URL + "/api/app-api/sip/platform/v2/category/create")
            .headers(authHeaders()).post(body).build();
    try (Response resp = HTTP.newCall(req).execute()) {
        return checkResponse(resp.body().string(), "作成ファイルカテゴリ")
                .getAsJsonObject("result").get("category_id").getAsString();
    }
}

// 呼び出し例:ホテル明細（含テーブルフィールド）
String hotelId = createCategory(workspaceId, "ホテル明細",
        SAMPLE_DIR + "/sample_hotel_receipt.png",
        Arrays.asList(field("チェックイン日付"), field("チェックアウト日付"), field("合計金額")), "");
batchAddCategoryFields(workspaceId, hotelId, "-1",
        List.of("日付", "費用タイプ", "金額", "備考"));

public static String uploadFile(String workspaceId, String filePath) throws IOException {
    File file = new File(filePath);
    HttpUrl url = HttpUrl.parse(BASE_URL + "/api/app-api/sip/platform/v2/file/upload")
            .newBuilder().addQueryParameter("workspace_id", workspaceId).build();
    MultipartBody body = new MultipartBody.Builder().setType(MultipartBody.FORM)
            .addFormDataPart("file", file.getName(),
                    RequestBody.create(file, MediaType.get(mimeType(file.getName()))))
            .build();
    Request req = new Request.Builder().url(url).headers(authHeaders()).post(body).build();
    try (Response resp = HTTP.newCall(req).execute()) {
        return checkResponse(resp.body().string(), "ファイルをアップロード")
                .getAsJsonObject("result").get("batch_number").getAsString();
    }
}

// 呼び出し例
String[] files = {
    SAMPLE_DIR + "/sample_expense_form.xls",
    SAMPLE_DIR + "/sample_hotel_receipt.png",
    SAMPLE_DIR + "/sample_payment_record.pdf"
};
List<String> batchNumbers = new ArrayList<>();
for (String path : files) batchNumbers.add(uploadFile(workspaceId, path));

public static JsonObject uploadFileSync(String workspaceId, String filePath) throws IOException {
    File file = new File(filePath);
    HttpUrl url = HttpUrl.parse(BASE_URL + "/api/app-api/sip/platform/v2/file/upload/sync")
            .newBuilder().addQueryParameter("workspace_id", workspaceId).build();
    MultipartBody body = new MultipartBody.Builder().setType(MultipartBody.FORM)
            .addFormDataPart("file", file.getName(),
                    RequestBody.create(file, MediaType.get(mimeType(file.getName()))))
            .build();
    Request req = new Request.Builder().url(url).headers(authHeaders()).post(body).build();
    try (Response resp = HTTP.newCall(req).execute()) {
        return checkResponse(resp.body().string(), "ファイルを同期アップロード")
                .getAsJsonObject("result").getAsJsonArray("files")
                .get(0).getAsJsonObject();   // 戻り値構造は file/fetch と同じ
    }
}

// 呼び出し例
List<JsonObject> rawResults = new ArrayList<>();
for (String path : new String[]{
        SAMPLE_DIR + "/sample_expense_form.xls",
        SAMPLE_DIR + "/sample_hotel_receipt.png",
        SAMPLE_DIR + "/sample_payment_record.pdf"}) {
    rawResults.add(uploadFileSync(workspaceId, path));
}

public static JsonObject waitForResult(String workspaceId, String batchNumber,
        int timeoutSec, int intervalSec) throws IOException, InterruptedException {
    HttpUrl url = HttpUrl.parse(BASE_URL + "/api/app-api/sip/platform/v2/file/fetch")
            .newBuilder().addQueryParameter("workspace_id", workspaceId)
            .addQueryParameter("batch_number", batchNumber).build();
    long deadline = System.currentTimeMillis() + (long) timeoutSec * 1000;
    while (System.currentTimeMillis() < deadline) {
        Request req = new Request.Builder().url(url).headers(authHeaders()).get().build();
        try (Response resp = HTTP.newCall(req).execute()) {
            JsonObject data = checkResponse(resp.body().string(), "処理結果を取得");
            JsonArray files = data.getAsJsonObject("result").getAsJsonArray("files");
            if (files != null && files.size() > 0) {
                JsonObject file = files.get(0).getAsJsonObject();
                int status = file.get("recognition_status").getAsInt();
                if (status == 1) return file;   // 含 task_id
                if (status == 2) throw new RuntimeException("ファイル処理失敗");
            }
        }
        Thread.sleep((long) intervalSec * 1000);
    }
    throw new RuntimeException("待機タイムアウト");
}

// 呼び出し例
List<JsonObject> rawResults = new ArrayList<>();
for (String bn : batchNumbers) {
    rawResults.add(waitForResult(workspaceId, bn, 120, 3));
}

// 作成規則リポジトリ
String repoId = createRuleRepo(workspaceId, "経費精算レビュー規則リポジトリ");

// 規則グループ1:経費申請書コンプライアンス性チェック
String group1Id = createRuleGroup(workspaceId, repoId, "経費申請書コンプライアンス性チェック");
createRule(workspaceId, repoId, group1Id,
        "必須フィールド完全性チェック",
        "\"申請者\"、\"費用発生日\"、\"費用項目\"、\"支払申請額\"均不空、" +
        "任一フィールド空则レビュー不合格",
        Arrays.asList(baoxiaoId), 10);   // category_ids 传入ステップ2获得的 category_id

// 規則グループ3:複数文書クロスレビュー（関連複数の分類）
String group3Id = createRuleGroup(workspaceId, repoId, "複数文書クロスレビュー");
createRule(workspaceId, repoId, group3Id,
        "複数文書金額照合",
        "経費申請書出張費金額 = ホテル明細合計金額 = 支払記録取引金額、許容±0.1元誤差",
        Arrays.asList(baoxiaoId, hotelId, paymentId), 10);   // 関連三个分類

public static String submitReviewTask(String workspaceId, String name,
        String repoId, List<String> extractTaskIds) throws IOException {
    JsonObject payload = new JsonObject();
    payload.addProperty("workspace_id", workspaceId);
    payload.addProperty("name", name);
    payload.addProperty("repo_id", repoId);
    JsonArray ids = new JsonArray();
    extractTaskIds.forEach(ids::add);
    payload.add("extract_task_ids", ids);
    Request req = new Request.Builder()
            .url(BASE_URL + "/api/app-api/sip/platform/v2/review/task/submit")
            .headers(authHeaders()).post(RequestBody.create(GSON.toJson(payload), JSON_TYPE)).build();
    try (Response resp = HTTP.newCall(req).execute()) {
        return checkResponse(resp.body().string(), "送信レビュータスク")
                .getAsJsonObject("result").get("task_id").getAsString();
    }
}

// 呼び出し例
List<String> extractTaskIds = new ArrayList<>();
for (JsonObject r : rawResults) {
    if (r.has("task_id")) extractTaskIds.add(r.get("task_id").getAsString());
}
String reviewTaskId = submitReviewTask(workspaceId, "経費精算レビュー", repoId, extractTaskIds);

public static JsonObject waitForReview(String workspaceId, String taskId,
        int timeoutSec, int intervalSec) throws IOException, InterruptedException {
    JsonObject payload = new JsonObject();
    payload.addProperty("workspace_id", workspaceId);
    payload.addProperty("task_id", taskId);
    long deadline = System.currentTimeMillis() + (long) timeoutSec * 1000;
    while (System.currentTimeMillis() < deadline) {
        Request req = new Request.Builder()
                .url(BASE_URL + "/api/app-api/sip/platform/v2/review/task/result")
                .headers(authHeaders()).post(RequestBody.create(GSON.toJson(payload), JSON_TYPE)).build();
        try (Response resp = HTTP.newCall(req).execute()) {
            JsonObject result = checkResponse(resp.body().string(), "取得レビュー結果")
                    .getAsJsonObject("result");
            int status = result.get("status").getAsInt();
            if (status == 1 || status == 2 || status == 4 || status == 7) return result;
        }
        Thread.sleep((long) intervalSec * 1000);
    }
    throw new RuntimeException("待機レビュー結果タイムアウト");
}

// 呼び出し例
JsonObject reviewResult = waitForReview(workspaceId, reviewTaskId, 300, 5);