|
|
|
@@ -45,6 +45,9 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { |
|
|
|
private String bucketName; |
|
|
|
@Resource |
|
|
|
private MinioService minioService; |
|
|
|
// 固定存储桶名 |
|
|
|
@Value("${labelStudio.loaclUrl}") |
|
|
|
private String labelloaclUrl; |
|
|
|
/** |
|
|
|
* 通过ID查询单条数据 |
|
|
|
* |
|
|
|
@@ -78,7 +81,12 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { |
|
|
|
@Override |
|
|
|
public DatasetVersion insert(DatasetVersion datasetVersion) throws Exception { |
|
|
|
//插入预备 |
|
|
|
insertPrepare(datasetVersion); |
|
|
|
LoginUser loginUser = SecurityUtils.getLoginUser(); |
|
|
|
datasetVersion.setCreateBy(loginUser.getUsername()); |
|
|
|
datasetVersion.setUpdateBy(loginUser.getUsername()); |
|
|
|
datasetVersion.setUpdateTime(new Date()); |
|
|
|
datasetVersion.setCreateTime(new Date()); |
|
|
|
datasetVersion.setState(1); |
|
|
|
this.datasetVersionDao.insert(datasetVersion); |
|
|
|
return datasetVersion; |
|
|
|
} |
|
|
|
@@ -99,6 +107,11 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { |
|
|
|
datasetVersion.setUpdateBy(loginUser.getUsername()); |
|
|
|
datasetVersion.setUpdateTime(new Date()); |
|
|
|
this.datasetVersionDao.update(datasetVersion); |
|
|
|
//插入时需要更新对应的数据集更新时间 |
|
|
|
Integer datasetId = datasetVersion.getDatasetId(); |
|
|
|
Dataset dataset = this.datasetDao.queryById(datasetId); |
|
|
|
dataset.setUpdateTime(new Date()); |
|
|
|
this.datasetDao.update(dataset); |
|
|
|
return this.queryById(datasetVersion.getId()); |
|
|
|
} |
|
|
|
|
|
|
|
@@ -213,7 +226,7 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { |
|
|
|
// 获取label-studio数据流 |
|
|
|
Map<String, String> headers = new HashMap<String, String>(); |
|
|
|
headers.put("Authorization","Token "+labelDatasetVersionVo.getToken()); |
|
|
|
InputStream inputStream = HttpUtils.getIntputStream("http://127.0.0.1:8080/api/projects/"+labelDatasetVersionVo.getProject_id()+"/export?exportType="+labelDatasetVersionVo.getExportType(), headers); |
|
|
|
InputStream inputStream = HttpUtils.getIntputStream(labelloaclUrl+"/api/projects/"+labelDatasetVersionVo.getProject_id()+"/export?exportType="+labelDatasetVersionVo.getExportType(), headers); |
|
|
|
// 构建objectName |
|
|
|
String username = SecurityUtils.getLoginUser().getUsername(); |
|
|
|
String url = username + "/" + DateUtils.dateTimeNow() + "/" + dataset.getName()+"_"+labelDatasetVersionVo.getVersion()+"."+labelDatasetVersionVo.getExportType(); |
|
|
|
@@ -240,5 +253,10 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { |
|
|
|
datasetVersion.setUpdateTime(new Date()); |
|
|
|
datasetVersion.setCreateTime(new Date()); |
|
|
|
datasetVersion.setState(1); |
|
|
|
//插入时需要更新对应的数据集更新时间 |
|
|
|
Integer datasetId = datasetVersion.getDatasetId(); |
|
|
|
Dataset dataset = this.datasetDao.queryById(datasetId); |
|
|
|
dataset.setUpdateTime(new Date()); |
|
|
|
this.datasetDao.update(dataset); |
|
|
|
} |
|
|
|
} |