|
|
|
@@ -33,6 +33,9 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { |
|
|
|
@Resource |
|
|
|
private DatasetVersionDao datasetVersionDao; |
|
|
|
|
|
|
|
// 固定存储桶名 |
|
|
|
private final String bucketName = "platform-data"; |
|
|
|
|
|
|
|
/** |
|
|
|
* 通过ID查询单条数据 |
|
|
|
* |
|
|
|
@@ -131,9 +134,21 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public Map<String,Object> queryByDatasetIdAndVersion(Integer datasetId, String version) { |
|
|
|
Map<String, Object> response = new HashMap<>(); |
|
|
|
|
|
|
|
List<DatasetVersion> datasetVersionList = this.datasetVersionDao.queryAllByDatasetVersion(datasetId, version); |
|
|
|
datasetVersionList.stream(). |
|
|
|
findFirst(). |
|
|
|
ifPresent(datasetVersion -> { |
|
|
|
String url = datasetVersion.getUrl(); |
|
|
|
String path = bucketName + '/' + url.substring(0, url.lastIndexOf('/')); |
|
|
|
response.put("path", path); |
|
|
|
|
|
|
|
}); |
|
|
|
|
|
|
|
public List<DatasetVersion> queryByDatasetIdAndVersion(Integer datasetId, String version) { |
|
|
|
return this.datasetVersionDao.queryAllByDatasetVersion(datasetId, version); |
|
|
|
response.put("content", datasetVersionList); |
|
|
|
return response; |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
|