Browse Source

Merge remote-tracking branch 'origin/dev' into dev

# Conflicts:
#	ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/experiment/ExperimentController.java
#	ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/experiment/ExperimentInsController.java
tags/v20240126
西大锐 2 years ago
parent
commit
2c9245dc30
10 changed files with 154 additions and 167 deletions
  1. +15
    -18
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/component/ComponentController.java
  2. +21
    -22
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/dataset/DatasetController.java
  3. +13
    -14
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/dataset/DatasetVersionController.java
  4. +21
    -24
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/experiment/ExperimentController.java
  5. +15
    -17
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/experiment/ExperimentInsController.java
  6. +20
    -24
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/model/ModelsController.java
  7. +11
    -10
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/model/ModelsVersionController.java
  8. +13
    -14
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/resources/ComputingResourceController.java
  9. +16
    -17
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/workflow/WorkflowController.java
  10. +9
    -7
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ExperimentInsServiceImpl.java

+ 15
- 18
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/component/ComponentController.java View File

@@ -1,18 +1,15 @@
package com.ruoyi.platform.controller.component;

import com.ruoyi.platform.domain.*;
import com.ruoyi.platform.service.*;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.platform.domain.Component;
import com.ruoyi.platform.service.ComponentService;
import com.ruoyi.platform.vo.ComponentVo;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
import java.util.List;
import java.util.Map;

/**
* (Component)表控制层
@@ -38,9 +35,9 @@ public class ComponentController {
*/
@GetMapping
@ApiOperation("分页查询")
public ResponseEntity<Page<Component>> queryByPage( Component component, int page, int size) {
public AjaxResult queryByPage( Component component, int page, int size) {
PageRequest pageRequest = PageRequest.of(page,size);
return ResponseEntity.ok(this.componentService.queryByPage(component, pageRequest));
return AjaxResult.success(this.componentService.queryByPage(component, pageRequest));
}


@@ -53,8 +50,8 @@ public class ComponentController {
*/
@GetMapping("/components/all")
@ApiOperation("查询全部")
public ResponseEntity<List> queryAll() throws Exception {
return ResponseEntity.ok(this.componentService.queryAllGroupedByCategory());
public AjaxResult queryAll() throws Exception {
return AjaxResult.success(this.componentService.queryAllGroupedByCategory());
}


@@ -67,8 +64,8 @@ public class ComponentController {
*/
@GetMapping("{id}")
@ApiOperation("根据id查询")
public ResponseEntity<Component> queryById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.componentService.queryById(id));
public AjaxResult queryById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.componentService.queryById(id));
}

/**
@@ -79,8 +76,8 @@ public class ComponentController {
*/
@PostMapping
@ApiOperation("添加组件")
public ResponseEntity<Component> add(@RequestBody ComponentVo component) {
return ResponseEntity.ok(this.componentService.insert(component));
public AjaxResult add(@RequestBody ComponentVo component) {
return AjaxResult.success(this.componentService.insert(component));
}

/**
@@ -91,8 +88,8 @@ public class ComponentController {
*/
@PutMapping
@ApiOperation("编辑组件")
public ResponseEntity<Component> edit(@RequestBody ComponentVo component) {
return ResponseEntity.ok(this.componentService.update(component));
public AjaxResult edit(@RequestBody ComponentVo component) {
return AjaxResult.success(this.componentService.update(component));
}

/**
@@ -103,8 +100,8 @@ public class ComponentController {
*/
@DeleteMapping("{id}")
@ApiOperation("根据id删除组件")
public ResponseEntity<String> deleteById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.componentService.removeById(id));
public AjaxResult deleteById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.componentService.removeById(id));
}

}


+ 21
- 22
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/dataset/DatasetController.java View File

@@ -1,20 +1,19 @@
package com.ruoyi.platform.controller.dataset;

import com.ruoyi.platform.domain.*;
import com.ruoyi.platform.service.*;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.platform.domain.Dataset;
import com.ruoyi.platform.domain.DatasetVersion;
import com.ruoyi.platform.service.DatasetService;
import com.ruoyi.platform.service.DatasetVersionService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiImplicitParam;
import io.swagger.annotations.ApiImplicitParams;
import io.swagger.annotations.ApiOperation;
import org.springframework.core.io.InputStreamResource;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import java.util.Map;

/**
* (Dataset)表控制层
@@ -45,9 +44,9 @@ public class DatasetController {
*/
@GetMapping
@ApiOperation("分页查询")
public ResponseEntity<Page<Dataset>> queryByPage(Dataset dataset, int page,int size) {
public AjaxResult queryByPage(Dataset dataset, int page,int size) {
PageRequest pageRequest = PageRequest.of(page,size);
return ResponseEntity.ok(this.datasetService.queryByPage(dataset, pageRequest));
return AjaxResult.success(this.datasetService.queryByPage(dataset, pageRequest));
}

/**
@@ -58,8 +57,8 @@ public class DatasetController {
*/
@GetMapping("{id}")
@ApiOperation("根据id查询数据集")
public ResponseEntity<Dataset> queryById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.datasetService.queryById(id));
public AjaxResult queryById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.datasetService.queryById(id));
}

/**
@@ -70,8 +69,8 @@ public class DatasetController {
*/
@PostMapping
@ApiOperation("添加数据集")
public ResponseEntity<Dataset> add(@RequestBody Dataset dataset) {
return ResponseEntity.ok(this.datasetService.insert(dataset));
public AjaxResult add(@RequestBody Dataset dataset) {
return AjaxResult.success(this.datasetService.insert(dataset));

}

@@ -83,8 +82,8 @@ public class DatasetController {
*/
@PutMapping
@ApiOperation("编辑数据集")
public ResponseEntity<Dataset> edit(@RequestBody Dataset dataset) {
return ResponseEntity.ok(this.datasetService.update(dataset));
public AjaxResult edit(@RequestBody Dataset dataset) {
return AjaxResult.success(this.datasetService.update(dataset));
}

/**
@@ -95,8 +94,8 @@ public class DatasetController {
*/
@DeleteMapping({"{id}"})
@ApiOperation("删除数据集")
public ResponseEntity<String> deleteById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.datasetService.removeById(id));
public AjaxResult deleteById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.datasetService.removeById(id));
}

/**
@@ -107,8 +106,8 @@ public class DatasetController {
*/
@GetMapping("/download/{dataset_version_id}")
@ApiOperation(value = "下载数据集", notes = "根据数据集版本表id下载数据集文件")
public ResponseEntity<InputStreamResource> downloadDataset(@PathVariable("dataset_version_id") Integer dataset_version_id) {
return datasetService.downloadDataset(dataset_version_id);
public AjaxResult downloadDataset(@PathVariable("dataset_version_id") Integer dataset_version_id) {
return AjaxResult.success(datasetService.downloadDataset(dataset_version_id));
}

/**
@@ -124,9 +123,9 @@ public class DatasetController {
@ApiImplicitParam(name = "file", value = "要上传的数据集文件", required = true, dataType = "file", paramType = "form"),
@ApiImplicitParam(name = "dataset_version_id", value = "数据集版本表id", required = true, dataType = "integer", paramType = "path")
})
public ResponseEntity<Map> uploadDataset(@RequestParam("file") MultipartFile file,
public AjaxResult uploadDataset(@RequestParam("file") MultipartFile file,
@PathVariable("dataset_version_id") Integer dataset_version_id) throws Exception {
return ResponseEntity.ok(this.datasetService.uploadDataset(file, dataset_version_id));
return AjaxResult.success(this.datasetService.uploadDataset(file, dataset_version_id));
}

/**
@@ -135,8 +134,8 @@ public class DatasetController {
*/
@PostMapping("/upload_pipeline")
@ApiOperation(value = "从流水线上传数据集", notes = "并将信息存入数据库。")
public ResponseEntity<Map> uploadDatasetPipeline(@RequestBody(required =false) DatasetVersion datasetVersion) throws Exception {
return ResponseEntity.ok(this.datasetService.uploadDatasetPipeline(datasetVersion));
public AjaxResult uploadDatasetPipeline(@RequestBody(required =false) DatasetVersion datasetVersion) throws Exception {
return AjaxResult.success(this.datasetService.uploadDatasetPipeline(datasetVersion));
}
}


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

@@ -1,11 +1,10 @@
package com.ruoyi.platform.controller.dataset;

import com.ruoyi.platform.domain.*;
import com.ruoyi.platform.service.*;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.platform.domain.DatasetVersion;
import com.ruoyi.platform.service.DatasetVersionService;
import io.swagger.annotations.ApiOperation;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
@@ -36,9 +35,9 @@ public class DatasetVersionController {
*/
@GetMapping
@ApiOperation("分页查询")
public ResponseEntity<Page<DatasetVersion>> queryByPage(DatasetVersion datasetVersion, int page,int size) {
public AjaxResult queryByPage(DatasetVersion datasetVersion, int page,int size) {
PageRequest pageRequest = PageRequest.of(page,size);
return ResponseEntity.ok(this.datasetVersionService.queryByPage(datasetVersion, pageRequest));
return AjaxResult.success(this.datasetVersionService.queryByPage(datasetVersion, pageRequest));
}


@@ -50,8 +49,8 @@ public class DatasetVersionController {
*/
@GetMapping("{id}")
@ApiOperation("根据id查询数据集版本")
public ResponseEntity<DatasetVersion> queryById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.datasetVersionService.queryById(id));
public AjaxResult queryById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.datasetVersionService.queryById(id));
}

/**
@@ -62,8 +61,8 @@ public class DatasetVersionController {
*/
@PostMapping
@ApiOperation("添加数据集版本")
public ResponseEntity<DatasetVersion> add(@RequestBody DatasetVersion datasetVersion) {
return ResponseEntity.ok(this.datasetVersionService.insert(datasetVersion));
public AjaxResult add(@RequestBody DatasetVersion datasetVersion) {
return AjaxResult.success(this.datasetVersionService.insert(datasetVersion));
}

/**
@@ -74,8 +73,8 @@ public class DatasetVersionController {
*/
@PutMapping
@ApiOperation("编辑数据集版本")
public ResponseEntity<DatasetVersion> edit(@RequestBody DatasetVersion datasetVersion) {
return ResponseEntity.ok(this.datasetVersionService.update(datasetVersion));
public AjaxResult edit(@RequestBody DatasetVersion datasetVersion) {
return AjaxResult.success(this.datasetVersionService.update(datasetVersion));
}

/**
@@ -86,8 +85,8 @@ public class DatasetVersionController {
*/
@DeleteMapping({"{id}"})
@ApiOperation("删除数据集版本")
public ResponseEntity<String> deleteById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.datasetVersionService.removeById(id));
public AjaxResult deleteById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.datasetVersionService.removeById(id));
}

}


+ 21
- 24
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/experiment/ExperimentController.java View File

@@ -1,14 +1,12 @@
package com.ruoyi.platform.controller.experiment;


import com.ruoyi.platform.domain.*;
import com.ruoyi.platform.service.*;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.platform.domain.Experiment;
import com.ruoyi.platform.service.ExperimentService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import io.swagger.models.auth.In;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
@@ -37,23 +35,22 @@ public class ExperimentController {
*/
@GetMapping
@ApiOperation("分页查询")
public ResponseEntity<Page<Experiment>> queryByPage(Experiment experiment, int page,int size) {
public AjaxResult queryByPage(Experiment experiment, int page,int size) {
PageRequest pageRequest = PageRequest.of(page,size);
return ResponseEntity.ok(this.experimentService.queryByPage(experiment, pageRequest));
return AjaxResult.success(this.experimentService.queryByPage(experiment, pageRequest));
}

@GetMapping(("/status"))
@ApiOperation("查询实验状态")
public Page<Experiment> selectStatus(Experiment experiment, int page,int size){
PageRequest pageRequest = PageRequest.of(page,size);
return this.experimentService.selectStatus(experiment, pageRequest);
public AjaxResult selectStatus(@RequestBody Experiment experiment, PageRequest pageRequest){
return AjaxResult.success(this.experimentService.selectStatus(experiment, pageRequest));
}



@GetMapping(("/configuration"))
public ResponseEntity<Experiment> showExperimentConfig(@RequestBody Experiment experiment){
return this.experimentService.showExperimentConfig(experiment);
public AjaxResult showExperimentConfig(@RequestBody Experiment experiment){
return AjaxResult.success(this.experimentService.showExperimentConfig(experiment));
}

/**
@@ -64,8 +61,8 @@ public class ExperimentController {
*/
@GetMapping("{id}")
@ApiOperation("通过id查询实验")
public ResponseEntity<Experiment> queryById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.experimentService.queryById(id));
public AjaxResult queryById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.experimentService.queryById(id));
}

/**
@@ -76,8 +73,8 @@ public class ExperimentController {
*/
@PostMapping
@ApiOperation("新增实验")
public ResponseEntity<Experiment> add(@RequestBody Experiment experiment) {
return ResponseEntity.ok(this.experimentService.insert(experiment));
public AjaxResult add(@RequestBody Experiment experiment) {
return AjaxResult.success(this.experimentService.insert(experiment));
}

/**
@@ -88,8 +85,8 @@ public class ExperimentController {
*/
@PutMapping
@ApiOperation("编辑实验")
public ResponseEntity<Experiment> edit(@RequestBody Experiment experiment) {
return ResponseEntity.ok(this.experimentService.update(experiment));
public AjaxResult edit(@RequestBody Experiment experiment) {
return AjaxResult.success(this.experimentService.update(experiment));
}

/**
@@ -100,8 +97,8 @@ public class ExperimentController {
*/
@DeleteMapping("{id}")
@ApiOperation("删除流水线")
public ResponseEntity<String> deleteById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.experimentService.removeById(id));
public AjaxResult deleteById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.experimentService.removeById(id));
}


@@ -116,8 +113,8 @@ public class ExperimentController {
*/
@PutMapping("/experiments/{id}")
@ApiOperation("运行实验")
public ResponseEntity<Experiment> runExperiment(@PathVariable("id") Integer id) throws Exception {
return ResponseEntity.ok(this.experimentService.runExperiment(id));
public AjaxResult runExperiment(@PathVariable("id") Integer id) {
return AjaxResult.success(this.experimentService.runExperiment(id));
}

/**
@@ -128,8 +125,8 @@ public class ExperimentController {
*/
@PostMapping("/addAndRunExperiment")
@ApiOperation("实验创建页面确定并运行")
public ResponseEntity<Experiment> addAndRunExperiment(@RequestBody Experiment experiment) {
return ResponseEntity.ok(this.experimentService.addAndRunExperiment(experiment));
public AjaxResult addAndRunExperiment(@RequestBody Experiment experiment) {
return AjaxResult.success(this.experimentService.addAndRunExperiment(experiment));
}
}


+ 15
- 17
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/experiment/ExperimentInsController.java View File

@@ -1,12 +1,11 @@
package com.ruoyi.platform.controller.experiment;

import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.platform.domain.ExperimentIns;
import com.ruoyi.platform.service.ExperimentInsService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
@@ -35,9 +34,9 @@ public class ExperimentInsController {
*/
@GetMapping
@ApiOperation("分页查询")
public ResponseEntity<Page<ExperimentIns>> queryByPage(ExperimentIns experimentIns, int page, int size) {
public AjaxResult queryByPage(ExperimentIns experimentIns, int page, int size) {
PageRequest pageRequest = PageRequest.of(page,size);
return ResponseEntity.ok(this.experimentInsService.queryByPage(experimentIns, pageRequest));
return AjaxResult.success(this.experimentInsService.queryByPage(experimentIns, pageRequest));
}

/**
@@ -48,8 +47,8 @@ public class ExperimentInsController {
*/
@GetMapping("{id}")
@ApiOperation("通过id查询实验实例")
public ResponseEntity<ExperimentIns> queryById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.experimentInsService.queryById(id));
public AjaxResult queryById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.experimentInsService.queryById(id));
}


@@ -62,8 +61,8 @@ public class ExperimentInsController {
*/
@PostMapping
@ApiOperation("新增实验实例")
public ResponseEntity<ExperimentIns> add(@RequestBody ExperimentIns experimentIns) {
return ResponseEntity.ok(this.experimentInsService.insert(experimentIns));
public AjaxResult add(@RequestBody ExperimentIns experimentIns) {
return AjaxResult.success(this.experimentInsService.insert(experimentIns));
}

/**
@@ -74,8 +73,8 @@ public class ExperimentInsController {
*/
@PutMapping
@ApiOperation("编辑实验实例")
public ResponseEntity<ExperimentIns> edit(@RequestBody ExperimentIns experimentIns) {
return ResponseEntity.ok(this.experimentInsService.update(experimentIns));
public AjaxResult edit(@RequestBody ExperimentIns experimentIns) {
return AjaxResult.success(this.experimentInsService.update(experimentIns));
}

/**
@@ -86,8 +85,8 @@ public class ExperimentInsController {
*/
@DeleteMapping("{id}")
@ApiOperation("删除实验实例")
public ResponseEntity<String> deleteById( @PathVariable("id") Integer id) {
return ResponseEntity.ok(this.experimentInsService.removeById(id));
public AjaxResult deleteById( @PathVariable("id") Integer id) {
return AjaxResult.success(this.experimentInsService.removeById(id));
}

/**
@@ -98,9 +97,8 @@ public class ExperimentInsController {
*/
@PutMapping("{id}")
@ApiOperation("终止实验实例")
public boolean terminateExperimentIns(@PathVariable("id") Integer id) {
return this.experimentInsService.terminateExperimentIns(id);

public AjaxResult terminateExperimentIns(@PathVariable("id") Integer id) {
return AjaxResult.success(this.experimentInsService.terminateExperimentIns(id));
}

/**
@@ -111,8 +109,8 @@ public class ExperimentInsController {
*/

@GetMapping(("/log/{id}"))
public String showExperimentInsLog(@PathVariable("id") Integer id){
return this.experimentInsService.showExperimentInsLog(id);
public AjaxResult showExperimentInsLog(@PathVariable("id") Integer id){
return AjaxResult.success(this.experimentInsService.showExperimentInsLog(id));
}




+ 20
- 24
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/model/ModelsController.java View File

@@ -1,21 +1,17 @@
package com.ruoyi.platform.controller.model;



import com.ruoyi.platform.domain.*;
import com.ruoyi.platform.service.*;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.platform.domain.Models;
import com.ruoyi.platform.domain.ModelsVersion;
import com.ruoyi.platform.service.ModelsService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.core.io.InputStreamResource;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.http.MediaType;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;
import org.springframework.web.multipart.MultipartFile;

import javax.annotation.Resource;
import java.util.Map;

/**
* (Models)表控制层
@@ -43,9 +39,9 @@ public class ModelsController {
*/
@GetMapping
@ApiOperation("分页查询")
public ResponseEntity<Page<Models>> queryByPage(Models models, int page, int size) {
public AjaxResult queryByPage(Models models, int page, int size) {
PageRequest pageRequest = PageRequest.of(page,size);
return ResponseEntity.ok(this.modelsService.queryByPage(models, pageRequest));
return AjaxResult.success(this.modelsService.queryByPage(models, pageRequest));
}

/**
@@ -56,8 +52,8 @@ public class ModelsController {
*/
@GetMapping("{id}")
@ApiOperation("根据id查询")
public ResponseEntity<Models> queryById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.modelsService.queryById(id));
public AjaxResult queryById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.modelsService.queryById(id));
}

/**
@@ -68,8 +64,8 @@ public class ModelsController {
*/
@PostMapping
@ApiOperation("添加模型")
public ResponseEntity<Models> add(@RequestBody Models models) {
return ResponseEntity.ok(this.modelsService.insert(models));
public AjaxResult add(@RequestBody Models models) {
return AjaxResult.success(this.modelsService.insert(models));
}

/**
@@ -80,8 +76,8 @@ public class ModelsController {
*/
@PutMapping
@ApiOperation("编辑模型")
public ResponseEntity<Models> edit(@RequestBody Models models) {
return ResponseEntity.ok(this.modelsService.update(models));
public AjaxResult edit(@RequestBody Models models) {
return AjaxResult.success(this.modelsService.update(models));
}

/**
@@ -92,8 +88,8 @@ public class ModelsController {
*/
@DeleteMapping("{id}")
@ApiOperation("删除模型")
public ResponseEntity<String> deleteById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.modelsService.removeById(id));
public AjaxResult deleteById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.modelsService.removeById(id));
}

/**
@@ -108,8 +104,8 @@ public class ModelsController {

@PostMapping("/upload/{models_version_id}")
@ApiOperation(value = "上传模型", notes = "根据模型版本表id上传模型文件,并将信息存入数据库。")
public ResponseEntity<Map> uploadModels(@RequestParam("file") MultipartFile file, @PathVariable("models_version_id") Integer models_version_id) throws Exception {
return ResponseEntity.ok(this.modelsService.uploadModels(file,models_version_id));
public AjaxResult uploadModels(@RequestParam("file") MultipartFile file, @PathVariable("models_version_id") Integer models_version_id) throws Exception {
return AjaxResult.success(this.modelsService.uploadModels(file,models_version_id));

}

@@ -119,8 +115,8 @@ public class ModelsController {
*/
@PostMapping("/upload_pipeline")
@ApiOperation("从流水线上传模型,并将信息存入数据库")
public ResponseEntity<Map> uploadModelsPipeline(@RequestBody(required =false) ModelsVersion modelsVersion) throws Exception {
return ResponseEntity.ok(this.modelsService.uploadModelsPipeline(modelsVersion));
public AjaxResult uploadModelsPipeline(@RequestBody(required =false) ModelsVersion modelsVersion) throws Exception {
return AjaxResult.success(this.modelsService.uploadModelsPipeline(modelsVersion));
}

/**
@@ -131,8 +127,8 @@ public class ModelsController {
*/
@GetMapping("/download/{models_version_id}")
@ApiOperation(value = "下载模型", notes = "根据模型版本表id下载模型文件。")
public ResponseEntity<InputStreamResource> downloadModels(@PathVariable("models_version_id") Integer models_version_id) {
return modelsService.downloadModels(models_version_id);
public AjaxResult downloadModels(@PathVariable("models_version_id") Integer models_version_id) {
return AjaxResult.success(modelsService.downloadModels(models_version_id));
}

}


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

@@ -1,5 +1,6 @@
package com.ruoyi.platform.controller.model;

import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.platform.domain.*;
import com.ruoyi.platform.service.*;
import io.swagger.annotations.ApiOperation;
@@ -35,9 +36,9 @@ public class ModelsVersionController {
*/
@GetMapping
@ApiOperation("分页查询")
public ResponseEntity<Page<ModelsVersion>> queryByPage(ModelsVersion modelsVersion, int page, int size) {
public AjaxResult queryByPage(ModelsVersion modelsVersion, int page, int size) {
PageRequest pageRequest = PageRequest.of(page,size);
return ResponseEntity.ok(this.modelsVersionService.queryByPage(modelsVersion, pageRequest));
return AjaxResult.success(this.modelsVersionService.queryByPage(modelsVersion, pageRequest));
}

/**
@@ -47,8 +48,8 @@ public class ModelsVersionController {
* @return 单条数据
*/
@GetMapping("{id}")
public ResponseEntity<ModelsVersion> queryById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.modelsVersionService.queryById(id));
public AjaxResult queryById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.modelsVersionService.queryById(id));
}

/**
@@ -58,8 +59,8 @@ public class ModelsVersionController {
* @return 新增结果
*/
@PostMapping
public ResponseEntity<ModelsVersion> add(@RequestBody ModelsVersion modelsVersion) {
return ResponseEntity.ok(this.modelsVersionService.insert(modelsVersion));
public AjaxResult add(@RequestBody ModelsVersion modelsVersion) {
return AjaxResult.success(this.modelsVersionService.insert(modelsVersion));
}

/**
@@ -69,8 +70,8 @@ public class ModelsVersionController {
* @return 编辑结果
*/
@PutMapping
public ResponseEntity<ModelsVersion> edit(@RequestBody ModelsVersion modelsVersion) {
return ResponseEntity.ok(this.modelsVersionService.update(modelsVersion));
public AjaxResult edit(@RequestBody ModelsVersion modelsVersion) {
return AjaxResult.success(this.modelsVersionService.update(modelsVersion));
}

/**
@@ -80,8 +81,8 @@ public class ModelsVersionController {
* @return 删除是否成功
*/
@DeleteMapping("{id}")
public ResponseEntity<String> deleteById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.modelsVersionService.removeById(id));
public AjaxResult deleteById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.modelsVersionService.removeById(id));
}

}


+ 13
- 14
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/resources/ComputingResourceController.java View File

@@ -1,12 +1,11 @@
package com.ruoyi.platform.controller.resources;

import com.ruoyi.platform.domain.*;
import com.ruoyi.platform.service.*;
import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.platform.domain.ComputingResource;
import com.ruoyi.platform.service.ComputingResourceService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
@@ -35,9 +34,9 @@ public class ComputingResourceController {
*/
@GetMapping
@ApiOperation("分页查询")
public ResponseEntity<Page<ComputingResource>> queryByPage(ComputingResource computingResource, int page, int size) {
public AjaxResult queryByPage(ComputingResource computingResource, int page, int size) {
PageRequest pageRequest = PageRequest.of(page,size);
return ResponseEntity.ok(this.computingResourceService.queryByPage(computingResource, pageRequest));
return AjaxResult.success(this.computingResourceService.queryByPage(computingResource, pageRequest));
}

/**
@@ -48,8 +47,8 @@ public class ComputingResourceController {
*/
@GetMapping("{id}")
@ApiOperation("根据id查询")
public ResponseEntity<ComputingResource> queryById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.computingResourceService.queryById(id));
public AjaxResult queryById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.computingResourceService.queryById(id));
}

/**
@@ -60,8 +59,8 @@ public class ComputingResourceController {
*/
@PostMapping
@ApiOperation("新增计算资源")
public ResponseEntity<ComputingResource> add(@RequestBody ComputingResource computingResource) {
return ResponseEntity.ok(this.computingResourceService.insert(computingResource));
public AjaxResult add(@RequestBody ComputingResource computingResource) {
return AjaxResult.success(this.computingResourceService.insert(computingResource));
}

/**
@@ -72,8 +71,8 @@ public class ComputingResourceController {
*/
@PutMapping
@ApiOperation("编辑计算资源")
public ResponseEntity<ComputingResource> edit(@RequestBody ComputingResource computingResource) {
return ResponseEntity.ok(this.computingResourceService.update(computingResource));
public AjaxResult edit(@RequestBody ComputingResource computingResource) {
return AjaxResult.success(this.computingResourceService.update(computingResource));
}

/**
@@ -84,8 +83,8 @@ public class ComputingResourceController {
*/
@DeleteMapping("{id}")
@ApiOperation("删除计算资源")
public ResponseEntity<String> deleteById(@PathVariable("id") Integer id) {
return ResponseEntity.ok(this.computingResourceService.removeById(id));
public AjaxResult deleteById(@PathVariable("id") Integer id) {
return AjaxResult.success(this.computingResourceService.removeById(id));
}

}


+ 16
- 17
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/controller/workflow/WorkflowController.java View File

@@ -1,12 +1,11 @@
package com.ruoyi.platform.controller.workflow;

import com.ruoyi.common.core.web.domain.AjaxResult;
import com.ruoyi.platform.domain.Workflow;
import com.ruoyi.platform.service.WorkflowService;
import io.swagger.annotations.Api;
import io.swagger.annotations.ApiOperation;
import org.springframework.data.domain.Page;
import org.springframework.data.domain.PageRequest;
import org.springframework.http.ResponseEntity;
import org.springframework.web.bind.annotation.*;

import javax.annotation.Resource;
@@ -40,9 +39,9 @@ public class WorkflowController {
*/
@GetMapping
@ApiOperation("分页查询")
public ResponseEntity<Page<Workflow>> queryByPage(Workflow workflow, int page,int size) {
public AjaxResult queryByPage(Workflow workflow, int page,int size) {
PageRequest pageRequest = PageRequest.of(page,size);
return ResponseEntity.ok(this.workflowService.queryByPage(workflow, pageRequest));
return AjaxResult.success(this.workflowService.queryByPage(workflow, pageRequest));
}


@@ -54,8 +53,8 @@ public class WorkflowController {
*/
@GetMapping("name/{name}")
@ApiOperation("按流水线名字模糊查询流水线")
public ResponseEntity<Page<Workflow>> queryByName(@PathVariable("name") String name) {
return ResponseEntity.ok(this.workflowService.queryByName(name));
public AjaxResult queryByName(@PathVariable("name") String name) {
return AjaxResult.success(this.workflowService.queryByName(name));
}

/**
@@ -66,8 +65,8 @@ public class WorkflowController {
*/
@GetMapping("{id}")
@ApiOperation("根据id查询单条数据")
public ResponseEntity<Workflow> queryById(@PathVariable("id") Long id) {
return ResponseEntity.ok(this.workflowService.queryById(id));
public AjaxResult queryById(@PathVariable("id") Long id) {
return AjaxResult.success(this.workflowService.queryById(id));
}

/**
@@ -78,8 +77,8 @@ public class WorkflowController {
*/
@PostMapping
@ApiOperation("新增")
public ResponseEntity<Workflow> add(@RequestBody Workflow workflow) {
return ResponseEntity.ok(this.workflowService.insert(workflow));
public AjaxResult add(@RequestBody Workflow workflow) {
return AjaxResult.success(this.workflowService.insert(workflow));
}


@@ -91,8 +90,8 @@ public class WorkflowController {
*/
@ApiOperation("复制流水线记录")
@PostMapping("duplicate/{id}")
public ResponseEntity<Workflow> duplicateWorkflow(@PathVariable("id") Long id) {
return ResponseEntity.ok(this.workflowService.duplicateWorkflow(id));
public AjaxResult duplicateWorkflow(@PathVariable("id") Long id) {
return AjaxResult.success(this.workflowService.duplicateWorkflow(id));
}

/**
@@ -103,7 +102,7 @@ public class WorkflowController {
// @ApiOperation("流水线保存")
// @PutMapping("/saveWorkflow/{id}")
// public ResponseEntity<Workflow> saveWorkflow(@PathVariable("id") Long id) {
// return ResponseEntity.ok(this.workflowService.saveWorkflow(id));
// return AjaxResult.success(this.workflowService.saveWorkflow(id));
// }


@@ -115,8 +114,8 @@ public class WorkflowController {
*/
@PutMapping
@ApiOperation("编辑流水线")
public ResponseEntity<Workflow> edit(@RequestBody Workflow workflow) {
return ResponseEntity.ok(this.workflowService.update(workflow));
public AjaxResult edit(@RequestBody Workflow workflow) {
return AjaxResult.success(this.workflowService.update(workflow));
}

/**
@@ -130,8 +129,8 @@ public class WorkflowController {
*/
@DeleteMapping("{id}")
@ApiOperation("删除流水线")
public ResponseEntity<String> deleteById(@PathVariable("id") Long id) {
return ResponseEntity.ok(this.workflowService.removeById(id));
public AjaxResult deleteById(@PathVariable("id") Long id) {
return AjaxResult.success(this.workflowService.removeById(id));
}

}


+ 9
- 7
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ExperimentInsServiceImpl.java View File

@@ -114,13 +114,15 @@ public class ExperimentInsServiceImpl implements ExperimentInsService {
public Page<ExperimentIns> queryByPage(ExperimentIns experimentIns, PageRequest pageRequest) {
long total = this.experimentInsDao.count(experimentIns);
List<ExperimentIns> experimentInsList = this.experimentInsDao.queryAllByLimit(experimentIns, pageRequest);
for (ExperimentIns ins: experimentInsList) {
//如果实验实例不为空或者
if (experimentIns!=null && StringUtils.isEmpty(experimentIns.getStatus())) {
Integer experimentInsId = experimentIns.getId();
String status = this.queryStatusFromArgo(ins.getArgoInsNs(), ins.getArgoInsName(), experimentInsId );
ins.setStatus(status);
this.update(experimentIns);
if (experimentInsList!=null && experimentInsList.size()>0) {
for (ExperimentIns ins : experimentInsList) {
//如果实验实例不为空或者
if (ins != null && StringUtils.isEmpty(ins.getStatus())) {
Integer experimentInsId = ins.getId();
String status = this.queryStatusFromArgo(ins.getArgoInsNs(), ins.getArgoInsName(), experimentInsId);
ins.setStatus(status);
this.update(ins);
}
}
}
return new PageImpl<>(experimentInsList, pageRequest, total);


Loading…
Cancel
Save