From ff6f9c0ee137ccbeb7de8e514b814fbd3e5f1393 Mon Sep 17 00:00:00 2001
From: Kris <2893855659@qq.com>
Date: Fri, 26 Sep 2025 09:59:22 +0800
Subject: [PATCH] =?UTF-8?q?=E3=80=90feat=E3=80=91=20=E6=8F=90=E4=BA=A4?=
 =?UTF-8?q?=E5=88=9B=E5=BB=BA=E7=9B=AE=E5=BD=95=E7=9A=84=E6=94=B9=E5=8A=A8?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 .../service/impl/CommonBatchServiceImpl.java  |  2 +-
 .../datadump/util/BulkV2QueryResult.java      | 28 +++++++++++++++++++
 2 files changed, 29 insertions(+), 1 deletion(-)
 create mode 100644 src/main/java/com/celnet/datadump/util/BulkV2QueryResult.java

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