【feat】 提交创建目录的改动
This commit is contained in:
parent
afb7abd999
commit
ff6f9c0ee1
@ -218,8 +218,8 @@ public class CommonBatchServiceImpl implements CommonBatchService {
|
|||||||
// 检测路径是否存在 不存在则创建
|
// 检测路径是否存在 不存在则创建
|
||||||
Path apiPath = Paths.get(param.getApi());
|
Path apiPath = Paths.get(param.getApi());
|
||||||
if (!Files.exists(apiPath)) {
|
if (!Files.exists(apiPath)) {
|
||||||
log.info("创建目录: {}", apiPath);
|
|
||||||
Files.createDirectories(apiPath);
|
Files.createDirectories(apiPath);
|
||||||
|
log.info("创建目录: {}", apiPath.toAbsolutePath());
|
||||||
}
|
}
|
||||||
|
|
||||||
// 使用确定性命名策略,避免使用随机时间戳
|
// 使用确定性命名策略,避免使用随机时间戳
|
||||||
|
|||||||
@ -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;
|
||||||
|
}
|
||||||
|
}
|
||||||
Loading…
Reference in New Issue
Block a user