费用报销场景（无工作空间）

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", "Acgpt")
            .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);