Browse Source

模型版本文件查询返回path,修改上传路径

pull/14/head^2
西大锐 1 year ago
parent
commit
d210287cc3
8 changed files with 45 additions and 12 deletions
  1. +1
    -1
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/dataset/DatasetVersionController.java
  2. +1
    -1
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/model/ModelsVersionController.java
  3. +1
    -1
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/DatasetVersionService.java
  4. +1
    -1
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/ModelsVersionService.java
  5. +3
    -2
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/DatasetServiceImpl.java
  6. +17
    -2
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/DatasetVersionServiceImpl.java
  7. +3
    -2
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ModelsServiceImpl.java
  8. +18
    -2
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ModelsVersionServiceImpl.java

+ 1
- 1
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/dataset/DatasetVersionController.java View File

@@ -66,7 +66,7 @@ public class DatasetVersionController extends BaseController {
*/ */
@GetMapping("/versions") @GetMapping("/versions")
@ApiOperation("通过数据集id和version查询版本文件列表") @ApiOperation("通过数据集id和version查询版本文件列表")
public GenericsAjaxResult<List<DatasetVersion>> queryByDatasetIdAndVersion(@RequestParam("dataset_id") Integer datasetId,
public GenericsAjaxResult<Map<String,Object>> queryByDatasetIdAndVersion(@RequestParam("dataset_id") Integer datasetId,
@RequestParam("version") String version) { @RequestParam("version") String version) {
return genericsSuccess(this.datasetVersionService.queryByDatasetIdAndVersion(datasetId, version)); return genericsSuccess(this.datasetVersionService.queryByDatasetIdAndVersion(datasetId, version));
} }


+ 1
- 1
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/model/ModelsVersionController.java View File

@@ -64,7 +64,7 @@ public class ModelsVersionController extends BaseController {
* @return 匹配的模型版本记录列表 * @return 匹配的模型版本记录列表
*/ */
@GetMapping("/versions") @GetMapping("/versions")
public GenericsAjaxResult<List<ModelsVersion>> queryByModelsIdAndVersion(@RequestParam("models_id") Integer modelsId,
public GenericsAjaxResult<Map<String,Object>> queryByModelsIdAndVersion(@RequestParam("models_id") Integer modelsId,
@RequestParam("version") String version) { @RequestParam("version") String version) {
return genericsSuccess(this.modelsVersionService.queryByModelsIdAndVersion(modelsId, version)); return genericsSuccess(this.modelsVersionService.queryByModelsIdAndVersion(modelsId, version));
} }


+ 1
- 1
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/DatasetVersionService.java View File

@@ -66,7 +66,7 @@ public interface DatasetVersionService {


DatasetVersion queryByDatasetVersion(DatasetVersion datasetVersion); DatasetVersion queryByDatasetVersion(DatasetVersion datasetVersion);


List<DatasetVersion> queryByDatasetIdAndVersion(Integer datasetId, String version);
Map<String,Object> queryByDatasetIdAndVersion(Integer datasetId, String version);


Map<Integer,String> deleteDatasetVersion(Integer datasetId, String version); Map<Integer,String> deleteDatasetVersion(Integer datasetId, String version);




+ 1
- 1
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/ModelsVersionService.java View File

@@ -66,7 +66,7 @@ public interface ModelsVersionService {


ModelsVersion queryByModelsVersion(ModelsVersion modelsVersion); ModelsVersion queryByModelsVersion(ModelsVersion modelsVersion);


List<ModelsVersion> queryByModelsIdAndVersion(Integer modelsId, String version);
Map<String,Object> queryByModelsIdAndVersion(Integer modelsId, String version);


Map<Integer, String> deleteModelsVersion(Integer modelsId, String version); Map<Integer, String> deleteModelsVersion(Integer modelsId, String version);




+ 3
- 2
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/DatasetServiceImpl.java View File

@@ -210,6 +210,9 @@ public class DatasetServiceImpl implements DatasetService {
@Override @Override
public List<Map<String, String>> uploadDataset(MultipartFile[] files) throws Exception { public List<Map<String, String>> uploadDataset(MultipartFile[] files) throws Exception {
List<Map<String, String>> results = new ArrayList<>(); List<Map<String, String>> results = new ArrayList<>();
//时间戳统一定在外面,一次上传就定好
Date createTime = new Date();
String timestamp = new SimpleDateFormat("yyyyMMdd-HHmmss").format(createTime);


for (MultipartFile file:files){ for (MultipartFile file:files){
if (file.isEmpty()) { if (file.isEmpty()) {
@@ -222,8 +225,6 @@ public class DatasetServiceImpl implements DatasetService {
// 其余操作基于 modelsVersionToUse // 其余操作基于 modelsVersionToUse
String username = SecurityUtils.getLoginUser().getUsername(); String username = SecurityUtils.getLoginUser().getUsername();
String fileName = file.getOriginalFilename(); String fileName = file.getOriginalFilename();
Date createTime = new Date();
String timestamp = new SimpleDateFormat("yyyyMMdd-HHmmss").format(createTime);
String objectName = "datasets/" + username + "/" + timestamp + "/" + fileName; String objectName = "datasets/" + username + "/" + timestamp + "/" + fileName;


// 上传文件到MinIO并将记录新增到数据库中 // 上传文件到MinIO并将记录新增到数据库中


+ 17
- 2
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/DatasetVersionServiceImpl.java View File

@@ -33,6 +33,9 @@ public class DatasetVersionServiceImpl implements DatasetVersionService {
@Resource @Resource
private DatasetVersionDao datasetVersionDao; private DatasetVersionDao datasetVersionDao;


// 固定存储桶名
private final String bucketName = "platform-data";

/** /**
* 通过ID查询单条数据 * 通过ID查询单条数据
* *
@@ -131,9 +134,21 @@ public class DatasetVersionServiceImpl implements DatasetVersionService {
} }


@Override @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 @Override


+ 3
- 2
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ModelsServiceImpl.java View File

@@ -205,6 +205,9 @@ public class ModelsServiceImpl implements ModelsService {
public List<Map<String, String>> uploadModels(MultipartFile[] files) throws Exception { public List<Map<String, String>> uploadModels(MultipartFile[] files) throws Exception {


List<Map<String, String>> results = new ArrayList<>(); List<Map<String, String>> results = new ArrayList<>();
//时间戳统一定在外面,一次上传就定好
Date createTime = new Date();
String timestamp = new SimpleDateFormat("yyyyMMdd-HHmmss").format(createTime);


for (MultipartFile file:files){ for (MultipartFile file:files){
if (file.isEmpty()) { if (file.isEmpty()) {
@@ -217,8 +220,6 @@ public class ModelsServiceImpl implements ModelsService {
// 其余操作基于 modelsVersionToUse // 其余操作基于 modelsVersionToUse
String username = SecurityUtils.getLoginUser().getUsername(); String username = SecurityUtils.getLoginUser().getUsername();
String fileName = file.getOriginalFilename(); String fileName = file.getOriginalFilename();
Date createTime = new Date();
String timestamp = new SimpleDateFormat("yyyyMMdd-HHmmss").format(createTime);
String objectName = "models/" + username + "/" + timestamp + "/" + fileName; String objectName = "models/" + username + "/" + timestamp + "/" + fileName;


// 上传文件到MinIO并将记录新增到数据库中 // 上传文件到MinIO并将记录新增到数据库中


+ 18
- 2
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ModelsVersionServiceImpl.java View File

@@ -34,6 +34,9 @@ public class ModelsVersionServiceImpl implements ModelsVersionService {
@Resource @Resource
private ModelsDao modelsDao; private ModelsDao modelsDao;


// 固定存储桶名
private final String bucketName = "platform-data";

/** /**
* 通过ID查询单条数据 * 通过ID查询单条数据
* *
@@ -159,8 +162,21 @@ public class ModelsVersionServiceImpl implements ModelsVersionService {
* @return 新的模型版本记录列表 * @return 新的模型版本记录列表
*/ */
@Override @Override
public List<ModelsVersion> queryByModelsIdAndVersion(Integer modelsId, String version) {
return this.modelsVersionDao.queryAllByModelsVersion(modelsId, version) ;
public Map<String,Object> queryByModelsIdAndVersion(Integer modelsId, String version) {
Map<String,Object> response = new HashMap<>();

List<ModelsVersion> modelsVersionList = this.modelsVersionDao.queryAllByModelsVersion(modelsId, version);
modelsVersionList.stream().
findFirst().
ifPresent(modelsVersion -> {
String url = modelsVersion.getUrl();
String path = bucketName + '/' + url.substring(0, url.lastIndexOf('/'));
response.put("path", path);

});

response.put("content", modelsVersionList);
return response;


} }




Loading…
Cancel
Save