diff --git a/src/main/java/com/celnet/datadump/service/impl/CommonBatchServiceImpl.java b/src/main/java/com/celnet/datadump/service/impl/CommonBatchServiceImpl.java index ecbd997..92ce0c2 100644 --- a/src/main/java/com/celnet/datadump/service/impl/CommonBatchServiceImpl.java +++ b/src/main/java/com/celnet/datadump/service/impl/CommonBatchServiceImpl.java @@ -218,8 +218,8 @@ public class CommonBatchServiceImpl implements CommonBatchService { // 检测路径是否存在 不存在则创建 Path apiPath = Paths.get(param.getApi()); if (!Files.exists(apiPath)) { - log.info("创建目录: {}", apiPath); Files.createDirectories(apiPath); + log.info("创建目录: {}", apiPath.toAbsolutePath()); } // 使用确定性命名策略,避免使用随机时间戳 diff --git a/src/main/java/com/celnet/datadump/util/BulkV2QueryResult.java b/src/main/java/com/celnet/datadump/util/BulkV2QueryResult.java new file mode 100644 index 0000000..202a3e3 --- /dev/null +++ b/src/main/java/com/celnet/datadump/util/BulkV2QueryResult.java @@ -0,0 +1,28 @@ +package com.celnet.datadump.util; + +/** + * Bulk API v2 查询结果封装类 + */ +public class BulkV2QueryResult { + private String csvContent; + private String locator; + private int recordCount; + + public BulkV2QueryResult(String csvContent, String locator, int recordCount) { + this.csvContent = csvContent; + this.locator = locator; + this.recordCount = recordCount; + } + + public String getCsvContent() { + return csvContent; + } + + public String getLocator() { + return locator; + } + + public int getRecordCount() { + return recordCount; + } +} \ No newline at end of file