| @@ -91,7 +91,7 @@ public class DatasetController { | |||||
| * @return 单条数据 | * @return 单条数据 | ||||
| */ | */ | ||||
| @GetMapping("{id}") | @GetMapping("{id}") | ||||
| @ApiOperation("根据id查询数据集") | |||||
| @ApiOperation("根据数据集id查询数据集") | |||||
| public AjaxResult queryById(@PathVariable("id") Integer id) { | public AjaxResult queryById(@PathVariable("id") Integer id) { | ||||
| return AjaxResult.success(this.datasetService.queryById(id)); | return AjaxResult.success(this.datasetService.queryById(id)); | ||||
| } | } | ||||
| @@ -148,7 +148,7 @@ public class DatasetController { | |||||
| * @return 删除是否成功 | * @return 删除是否成功 | ||||
| */ | */ | ||||
| @DeleteMapping({"{id}"}) | @DeleteMapping({"{id}"}) | ||||
| @ApiOperation("删除数据集") | |||||
| @ApiOperation("根据id删除数据集") | |||||
| public AjaxResult deleteById(@PathVariable("id") Integer id) { | public AjaxResult deleteById(@PathVariable("id") Integer id) { | ||||
| return AjaxResult.success(this.datasetService.removeById(id)); | return AjaxResult.success(this.datasetService.removeById(id)); | ||||
| } | } | ||||
| @@ -175,7 +175,7 @@ public class ExperimentInsController extends BaseController { | |||||
| */ | */ | ||||
| @GetMapping("/nodeResult") | @GetMapping("/nodeResult") | ||||
| @ApiOperation("查询实例节点结果") | @ApiOperation("查询实例节点结果") | ||||
| public GenericsAjaxResult<List> getNodeResult(@RequestParam("id") Integer id, @RequestParam("node_id") String nodeId) throws Exception { | |||||
| public GenericsAjaxResult<List> getNodeResult(@PathVariable("id") Integer id, @PathVariable("node_id") String nodeId) throws Exception { | |||||
| return genericsSuccess(this.experimentInsService.getNodeResult(id,nodeId)); | return genericsSuccess(this.experimentInsService.getNodeResult(id,nodeId)); | ||||
| } | } | ||||
| @@ -0,0 +1,31 @@ | |||||
| package com.ruoyi.platform.controller.labelStudio; | |||||
| import com.ruoyi.common.core.web.controller.BaseController; | |||||
| import com.ruoyi.common.core.web.domain.AjaxResult; | |||||
| import com.ruoyi.common.core.web.domain.GenericsAjaxResult; | |||||
| import com.ruoyi.platform.service.JupyterService; | |||||
| import io.swagger.annotations.Api; | |||||
| import io.swagger.annotations.ApiOperation; | |||||
| import org.springframework.beans.factory.annotation.Value; | |||||
| import org.springframework.web.bind.annotation.GetMapping; | |||||
| import org.springframework.web.bind.annotation.RequestMapping; | |||||
| import org.springframework.web.bind.annotation.RestController; | |||||
| import javax.annotation.Resource; | |||||
| import java.io.File; | |||||
| import java.io.FileInputStream; | |||||
| import java.io.IOException; | |||||
| import java.io.InputStream; | |||||
| @RestController | |||||
| @RequestMapping("/labelStudio") | |||||
| @Api("labelStudio service") | |||||
| public class labelStudioController extends BaseController { | |||||
| @Value("${labelStudio.url}") | |||||
| private String url; | |||||
| @GetMapping(value = "/getURL") | |||||
| @ApiOperation("得到访问地址") | |||||
| public GenericsAjaxResult<String> getURL() throws IOException { | |||||
| return genericsSuccess(url); | |||||
| } | |||||
| } | |||||
| @@ -2,6 +2,7 @@ package com.ruoyi.platform.domain; | |||||
| import com.fasterxml.jackson.databind.PropertyNamingStrategy; | import com.fasterxml.jackson.databind.PropertyNamingStrategy; | ||||
| import com.fasterxml.jackson.databind.annotation.JsonNaming; | import com.fasterxml.jackson.databind.annotation.JsonNaming; | ||||
| import io.swagger.annotations.ApiModelProperty; | |||||
| import java.util.Date; | import java.util.Date; | ||||
| import java.io.Serializable; | import java.io.Serializable; | ||||
| @@ -18,40 +19,34 @@ public class AssetIcon implements Serializable { | |||||
| /** | /** | ||||
| * 主键 | * 主键 | ||||
| */ | */ | ||||
| private Integer id; | |||||
| /** | |||||
| * 资产图标名称 | |||||
| */ | |||||
| @ApiModelProperty(value = "资产ID") | |||||
| private Integer id; | |||||
| @ApiModelProperty(value = "资产图标名称") | |||||
| private String name; | private String name; | ||||
| /** | |||||
| * 分类id | |||||
| */ | |||||
| @ApiModelProperty(value = "分类ID") | |||||
| private Integer categoryId; | private Integer categoryId; | ||||
| /** | |||||
| * 路径 | |||||
| */ | |||||
| @ApiModelProperty(value = "路径") | |||||
| private String path; | private String path; | ||||
| /** | |||||
| * 描述 | |||||
| */ | |||||
| @ApiModelProperty(value = "描述") | |||||
| private String description; | private String description; | ||||
| /** | |||||
| * 创建者 | |||||
| */ | |||||
| @ApiModelProperty(value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| @ApiModelProperty(value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | |||||
| * 更新者 | |||||
| */ | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | |||||
| * 更新时间 | |||||
| */ | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 0失效,1生效 | |||||
| */ | |||||
| @ApiModelProperty(value = "状态,0失效,1生效") | |||||
| private Integer state; | private Integer state; | ||||
| @@ -20,108 +20,108 @@ public class Component implements Serializable { | |||||
| /** | /** | ||||
| * 主键 | * 主键 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "id") | |||||
| @ApiModelProperty(name = "id", value = "主键") | |||||
| private Integer id; | private Integer id; | ||||
| /** | /** | ||||
| * 类别ID,数据字典配置 | * 类别ID,数据字典配置 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "category_id") | |||||
| @ApiModelProperty(name = "category_id" ,value = "类别id") | |||||
| private Integer categoryId; | private Integer categoryId; | ||||
| /** | /** | ||||
| * 组件name | * 组件name | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "category_name") | |||||
| @ApiModelProperty(name = "category_name", value = "组件名称") | |||||
| private String componentName; | private String componentName; | ||||
| /** | /** | ||||
| * 组件面板名 | * 组件面板名 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "component_label") | |||||
| @ApiModelProperty(name = "component_label" , value = "组件面板名" ) | |||||
| private String componentLabel; | private String componentLabel; | ||||
| /** | /** | ||||
| * 镜像 | * 镜像 | ||||
| */ | */ | ||||
| @JsonProperty("image") | @JsonProperty("image") | ||||
| @ApiModelProperty(name = "image") | |||||
| @ApiModelProperty(name = "image" ,value = "镜像") | |||||
| private String images; | private String images; | ||||
| /** | /** | ||||
| * 工作目录 | * 工作目录 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "working_directory") | |||||
| @ApiModelProperty(name = "working_directory" , value = "工作目录") | |||||
| private String workingDirectory; | private String workingDirectory; | ||||
| /** | /** | ||||
| * 启动命令 | * 启动命令 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "command") | |||||
| @ApiModelProperty(name = "command" , value = "启动命令") | |||||
| private String command; | private String command; | ||||
| /** | /** | ||||
| * 环境变量 | * 环境变量 | ||||
| */ | */ | ||||
| @JsonProperty("env_variables") | @JsonProperty("env_variables") | ||||
| @ApiModelProperty(name = "env_variables") | |||||
| @ApiModelProperty(name = "env_variables", value = "环境变量") | |||||
| private String envVirables; | private String envVirables; | ||||
| /** | /** | ||||
| * 资源规格 | * 资源规格 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "resources_standard") | |||||
| @ApiModelProperty(name = "resources_standard" , value = "资源规格") | |||||
| private String resourcesStandard; | private String resourcesStandard; | ||||
| /** | /** | ||||
| * 控制策略 | * 控制策略 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "control_strategy") | |||||
| @ApiModelProperty(name = "control_strategy" ,value = "控制策略") | |||||
| private String controlStrategy; | private String controlStrategy; | ||||
| /** | /** | ||||
| * 挂载路径 | * 挂载路径 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "mount_path") | |||||
| @ApiModelProperty(name = "mount_path" , value = "挂载路径") | |||||
| private String mountPath; | private String mountPath; | ||||
| /** | /** | ||||
| * 输入参数 | * 输入参数 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "in_parameters") | |||||
| @ApiModelProperty(name = "in_parameters" ,value = "输入参数") | |||||
| private String inParameters; | private String inParameters; | ||||
| /** | /** | ||||
| * 输出参数 | * 输出参数 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "out_parameters") | |||||
| @ApiModelProperty(name = "out_parameters" ,value = "输出参数") | |||||
| private String outParameters; | private String outParameters; | ||||
| /** | /** | ||||
| * 描述 | * 描述 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "description") | |||||
| @ApiModelProperty(name = "description" , value = "描述") | |||||
| private String description; | private String description; | ||||
| /** | /** | ||||
| * 图标路径 | * 图标路径 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "icon_path") | |||||
| @ApiModelProperty(name = "icon_path" ,value = "图标路径") | |||||
| private String iconPath; | private String iconPath; | ||||
| /** | /** | ||||
| * 创建者 | * 创建者 | ||||
| */ | */ | ||||
| //@JsonProperty("creater") | //@JsonProperty("creater") | ||||
| @ApiModelProperty(name = "create_by") | |||||
| @ApiModelProperty(name = "create_by" ,value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| /** | /** | ||||
| * 创建时间 | * 创建时间 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "create_time") | |||||
| @ApiModelProperty(name = "create_time" , value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | /** | ||||
| * 更新者 | * 更新者 | ||||
| */ | */ | ||||
| //@JsonProperty("modify_by") | //@JsonProperty("modify_by") | ||||
| @ApiModelProperty(name = "update_by") | |||||
| @ApiModelProperty(name = "update_by" , value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | /** | ||||
| * 更新时间 | * 更新时间 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "update_time") | |||||
| @ApiModelProperty(name = "update_time" , value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | /** | ||||
| * 0,失效 1生效 | * 0,失效 1生效 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "state") | |||||
| @ApiModelProperty(name = "state" , value = "状态") | |||||
| private Integer state; | private Integer state; | ||||
| public Integer getId() { | public Integer getId() { | ||||
| @@ -19,53 +19,35 @@ public class ComputingResource implements Serializable { | |||||
| /** | /** | ||||
| * 主键 | * 主键 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "id") | |||||
| private Integer id; | |||||
| /** | |||||
| * 计算资源 | |||||
| */ | |||||
| @ApiModelProperty(name = "computing_resource") | |||||
| @ApiModelProperty(value = "编号", notes = "唯一标识符") | |||||
| private Integer id; | |||||
| @ApiModelProperty("计算资源的描述") | |||||
| private String computingResource; | private String computingResource; | ||||
| /** | |||||
| * 规格 | |||||
| */ | |||||
| @ApiModelProperty(name = "standard") | |||||
| @ApiModelProperty("计算资源的规格说明") | |||||
| private String standard; | private String standard; | ||||
| /** | |||||
| * 描述 | |||||
| */ | |||||
| @ApiModelProperty(name = "description") | |||||
| @ApiModelProperty("资源的详细描述") | |||||
| private String description; | private String description; | ||||
| /** | |||||
| * 创建者 | |||||
| */ | |||||
| //@JsonProperty("creater") | |||||
| @ApiModelProperty(name = "create_by") | |||||
| @ApiModelProperty(value = "创建者的用户名", example = "admin") | |||||
| private String createBy; | private String createBy; | ||||
| /** | |||||
| * 创建时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_time") | |||||
| @ApiModelProperty(value = "资源的创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | |||||
| * 更新者 | |||||
| */ | |||||
| //@JsonProperty("modify_by") | |||||
| @ApiModelProperty(name = "update_by") | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | |||||
| * 更新时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_time") | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 0,失效 1, 生效 | |||||
| */ | |||||
| @ApiModelProperty(name = "state") | |||||
| @ApiModelProperty(value = "状态标识", notes = "0表示失效,1表示生效") | |||||
| private Integer state; | private Integer state; | ||||
| public Integer getId() { | public Integer getId() { | ||||
| return id; | return id; | ||||
| } | } | ||||
| @@ -22,53 +22,58 @@ public class Dataset implements Serializable { | |||||
| private Integer id; | private Integer id; | ||||
| @CheckDuplicate | @CheckDuplicate | ||||
| @ApiModelProperty(name = "name") | |||||
| @ApiModelProperty(value = "名称") | |||||
| private String name; | private String name; | ||||
| @ApiModelProperty(name = "description") | |||||
| @ApiModelProperty(value = "描述") | |||||
| private String description; | private String description; | ||||
| /** | /** | ||||
| * 是否公开: 1公开,0私有 | * 是否公开: 1公开,0私有 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "available_range") | |||||
| @ApiModelProperty(value = "是否公开:1公开,0私有") | |||||
| private int availableRange; | private int availableRange; | ||||
| /** | /** | ||||
| * 数据集类型 | * 数据集类型 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "data_type") | |||||
| @ApiModelProperty(value = "数据集类型") | |||||
| private String dataType; | private String dataType; | ||||
| /** | /** | ||||
| * 数据集tag | |||||
| * 数据集标签 | |||||
| */ | */ | ||||
| @ApiModelProperty(name = "data_tag") | |||||
| @ApiModelProperty(value = "数据集标签") | |||||
| private String dataTag; | private String dataTag; | ||||
| /** | /** | ||||
| * 创建者 | * 创建者 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "create_by") | |||||
| @ApiModelProperty(value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| /** | /** | ||||
| * 创建时间 | * 创建时间 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "create_time") | |||||
| @ApiModelProperty(value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | /** | ||||
| * 更新者 | * 更新者 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "update_by") | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | /** | ||||
| * 更新时间 | * 更新时间 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "update_time") | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 0,失效 1生效 | |||||
| /** | |||||
| * 状态,0失效,1生效 | |||||
| */ | */ | ||||
| @ApiModelProperty(name = "state") | |||||
| @ApiModelProperty(value = "状态:0失效,1生效") | |||||
| private Integer state; | private Integer state; | ||||
| @@ -22,66 +22,49 @@ public class DatasetVersion implements Serializable { | |||||
| */ | */ | ||||
| @ApiModelProperty(name = "id") | @ApiModelProperty(name = "id") | ||||
| private Integer id; | private Integer id; | ||||
| @ApiModelProperty(name = "dataset_id") | |||||
| @ApiModelProperty(value = "数据集ID") | |||||
| private Integer datasetId; | private Integer datasetId; | ||||
| /** | |||||
| * 版本 | |||||
| */ | |||||
| @ApiModelProperty(name = "version") | |||||
| @ApiModelProperty(value = "版本") | |||||
| private String version; | private String version; | ||||
| /** | |||||
| * 数据集存储地址 | |||||
| */ | |||||
| @ApiModelProperty(name = "url") | |||||
| @ApiModelProperty(value = "数据集存储地址") | |||||
| @CheckDuplicate | @CheckDuplicate | ||||
| private String url; | private String url; | ||||
| /** | |||||
| * 文件名 | |||||
| */ | |||||
| @ApiModelProperty(name = "file_name") | |||||
| @ApiModelProperty(value = "文件名") | |||||
| private String fileName; | private String fileName; | ||||
| /** | |||||
| * 文件大小 | |||||
| */ | |||||
| @ApiModelProperty(name = "file_size") | |||||
| @ApiModelProperty(value = "文件大小") | |||||
| private String fileSize; | private String fileSize; | ||||
| /** | |||||
| * 可用集群 | |||||
| */ | |||||
| @ApiModelProperty(name = "available_cluster") | |||||
| @ApiModelProperty(value = "可用集群") | |||||
| private String availableCluster; | private String availableCluster; | ||||
| /** | |||||
| * 状态 | |||||
| */ | |||||
| @ApiModelProperty(name = "status") | |||||
| @ApiModelProperty(value = "状态") | |||||
| private Integer status; | private Integer status; | ||||
| /** | |||||
| * 创建者 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_by") | |||||
| @ApiModelProperty(value = "描述") | |||||
| private String description; | |||||
| @ApiModelProperty(value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| /** | |||||
| * 创建时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_time") | |||||
| @ApiModelProperty(value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | |||||
| * 更新者 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_by") | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | |||||
| * 更新时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_time") | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 0失效,1生效 | |||||
| */ | |||||
| @ApiModelProperty(name = "state") | |||||
| @ApiModelProperty(value = "状态:0失效,1生效") | |||||
| private Integer state; | private Integer state; | ||||
| public Integer getId() { | public Integer getId() { | ||||
| return id; | return id; | ||||
| } | } | ||||
| @@ -146,6 +129,14 @@ public class DatasetVersion implements Serializable { | |||||
| this.status = status; | this.status = status; | ||||
| } | } | ||||
| public String getDescription() { | |||||
| return description; | |||||
| } | |||||
| public void setDescription(String description) { | |||||
| this.description = description; | |||||
| } | |||||
| public String getCreateBy() { | public String getCreateBy() { | ||||
| return createBy; | return createBy; | ||||
| } | } | ||||
| @@ -25,46 +25,43 @@ import java.util.List; | |||||
| @ApiModel("实验对象") | @ApiModel("实验对象") | ||||
| public class Experiment implements Serializable { | public class Experiment implements Serializable { | ||||
| private static final long serialVersionUID = 409135817108439880L; | private static final long serialVersionUID = 409135817108439880L; | ||||
| // @ApiModelProperty(name = "id") | |||||
| @ApiModelProperty(value = "主键") | |||||
| private Integer id; | private Integer id; | ||||
| // @ApiModelProperty(name = "name") | |||||
| @ApiModelProperty(value = "名称") | |||||
| private String name; | private String name; | ||||
| // @ApiModelProperty(name = "workflow_id") | |||||
| @ApiModelProperty(value = "工作流ID") | |||||
| private Long workflowId; | private Long workflowId; | ||||
| /** | |||||
| * 全局参数 | |||||
| */ | |||||
| @ApiModelProperty(name = "global_param") | |||||
| @ApiModelProperty(value = "全局参数,以JSON字符串格式存储") | |||||
| @JsonRawValue | @JsonRawValue | ||||
| private String globalParam; | private String globalParam; | ||||
| @ApiModelProperty(value = "状态列表") | |||||
| private String statusList; | private String statusList; | ||||
| /** | |||||
| * 简介 | |||||
| */ | |||||
| @ApiModelProperty(name = "description") | |||||
| @ApiModelProperty(value = "简介") | |||||
| private String description; | private String description; | ||||
| /** | |||||
| * 创建者 | |||||
| */ | |||||
| @ApiModelProperty(value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| /** | |||||
| * 创建时间 | |||||
| */ | |||||
| @ApiModelProperty(value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | |||||
| * 更新者 | |||||
| */ | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | |||||
| * 更新时间 | |||||
| */ | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 0,失效 1生效 | |||||
| */ | |||||
| @ApiModelProperty(value = "状态:0失效,1生效") | |||||
| private Integer state; | private Integer state; | ||||
| @ApiModelProperty(value = "对应的实例列表") | |||||
| private List<ExperimentIns> experimentInsList; | private List<ExperimentIns> experimentInsList; | ||||
| @ApiModelProperty(value = "对应的流水线名称") | |||||
| private String workflowName; | private String workflowName; | ||||
| public String getName() { | public String getName() { | ||||
| return name; | return name; | ||||
| @@ -24,79 +24,53 @@ public class ExperimentIns implements Serializable { | |||||
| /** | /** | ||||
| * 实验ID | * 实验ID | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "experiment_id") | |||||
| @ApiModelProperty(value = "实验ID") | |||||
| private Integer experimentId; | private Integer experimentId; | ||||
| /** | |||||
| * argo返回name | |||||
| */ | |||||
| @ApiModelProperty(name = "argo_ins_name") | |||||
| @ApiModelProperty(value = "Argo实例名称") | |||||
| private String argoInsName; | private String argoInsName; | ||||
| /** | |||||
| * argo返回命名空间 | |||||
| */ | |||||
| @ApiModelProperty(name = "argo_ins_ns") | |||||
| @ApiModelProperty(value = "Argo命名空间") | |||||
| private String argoInsNs; | private String argoInsNs; | ||||
| /** | |||||
| * 实例运行状态 | |||||
| */ | |||||
| @ApiModelProperty(name = "status") | |||||
| @ApiModelProperty(value = "实例运行状态") | |||||
| private String status; | private String status; | ||||
| @ApiModelProperty(name = "nodes_status") | |||||
| private String nodesStatus; | |||||
| @ApiModelProperty(name = "nodes_result") | |||||
| private String nodesResult; | |||||
| @ApiModelProperty(name = "nodes_logs") | |||||
| private String nodesLogs; | |||||
| @ApiModelProperty(value = "节点状态") | |||||
| private String nodesStatus; | |||||
| @ApiModelProperty(value = "节点结果") | |||||
| private String nodesResult; | |||||
| /** | |||||
| * 实验实例全局参数 | |||||
| */ | |||||
| // @ApiModelProperty(name = "global_param") | |||||
| @ApiModelProperty(value = "节点日志") | |||||
| private String nodesLogs; | |||||
| @ApiModelProperty(value = "实验实例全局参数", notes = "以JSON字符串格式存储") | |||||
| @JsonRawValue | @JsonRawValue | ||||
| private String globalParam; | private String globalParam; | ||||
| /** | |||||
| * 开始时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "start_time") | |||||
| @ApiModelProperty(value = "开始时间") | |||||
| private Date startTime; | private Date startTime; | ||||
| /** | |||||
| * 结束时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "finish_time") | |||||
| @ApiModelProperty(value = "结束时间") | |||||
| private Date finishTime; | private Date finishTime; | ||||
| /** | |||||
| * 创建者 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_by") | |||||
| @ApiModelProperty(value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| /** | |||||
| * 创建时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_time") | |||||
| @ApiModelProperty(value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | |||||
| * 更新者 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_by") | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | |||||
| * 更新时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_time") | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 0,失效 1生效 | |||||
| */ | |||||
| @ApiModelProperty(name = "state") | |||||
| @ApiModelProperty(value = "状态:0失效,1生效") | |||||
| private Integer state; | private Integer state; | ||||
| public ExperimentIns() { | public ExperimentIns() { | ||||
| } | } | ||||
| @@ -19,51 +19,37 @@ public class Image implements Serializable { | |||||
| /** | /** | ||||
| * 主键 | * 主键 | ||||
| */ | */ | ||||
| @ApiModelProperty(value = "主键") | |||||
| private Integer id; | private Integer id; | ||||
| /** | /** | ||||
| * 镜像名称 | * 镜像名称 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "name") | |||||
| @ApiModelProperty(value = "名称") | |||||
| private String name; | private String name; | ||||
| /** | |||||
| * 镜像描述 | |||||
| */ | |||||
| @ApiModelProperty(name = "description") | |||||
| @ApiModelProperty(value = "镜像描述") | |||||
| private String description; | private String description; | ||||
| /** | |||||
| * 镜像类型 | |||||
| */ | |||||
| @ApiModelProperty(name = "image_type") | |||||
| @ApiModelProperty(value = "镜像类型") | |||||
| private Integer imageType; | private Integer imageType; | ||||
| /** | |||||
| * 创建者 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_by") | |||||
| @ApiModelProperty(value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| /** | |||||
| * 创建时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_time") | |||||
| @ApiModelProperty(value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | |||||
| * 更新者 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_by") | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | |||||
| * 更新时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_time") | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 状态,0失效,1生效 | |||||
| */ | |||||
| @ApiModelProperty(name = "state") | |||||
| @ApiModelProperty(value = "状态,0失效,1生效") | |||||
| private Integer state; | private Integer state; | ||||
| private Integer versionCount; // 版本数量统计 | |||||
| @ApiModelProperty(value = "版本数量统计") | |||||
| private Integer versionCount; | |||||
| @@ -20,63 +20,40 @@ public class ImageVersion implements Serializable { | |||||
| * 主键 | * 主键 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "id") | |||||
| @ApiModelProperty(value = "ID") | |||||
| private Integer id; | private Integer id; | ||||
| /** | |||||
| * 对应的镜像id | |||||
| */ | |||||
| @ApiModelProperty(name = "image_id") | |||||
| @ApiModelProperty(value = "对应的镜像ID") | |||||
| private Integer imageId; | private Integer imageId; | ||||
| /** | |||||
| * 镜像版本 | |||||
| */ | |||||
| @ApiModelProperty(name = "version") | |||||
| @ApiModelProperty(value = "镜像版本") | |||||
| private String version; | private String version; | ||||
| /** | |||||
| * 镜像推送地址 | |||||
| */ | |||||
| @ApiModelProperty(name = "url") | |||||
| @ApiModelProperty(value = "镜像推送地址") | |||||
| private String url; | private String url; | ||||
| /** | |||||
| * 镜像tag名称 | |||||
| */ | |||||
| @ApiModelProperty(name = "tag_name") | |||||
| @ApiModelProperty(value = "镜像tag名称") | |||||
| private String tagName; | private String tagName; | ||||
| /** | |||||
| * 镜像文件大小 | |||||
| */ | |||||
| @ApiModelProperty(name = "file_size") | |||||
| @ApiModelProperty(value = "镜像文件大小") | |||||
| private String fileSize; | private String fileSize; | ||||
| /** | |||||
| * 镜像构建状态 | |||||
| */ | |||||
| @ApiModelProperty(name = "status") | |||||
| @ApiModelProperty(value = "镜像构建状态") | |||||
| private String status; | private String status; | ||||
| /** | |||||
| * 创建者 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_by") | |||||
| @ApiModelProperty(value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| /** | |||||
| * 创建时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_time") | |||||
| @ApiModelProperty(value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | |||||
| * 更新者 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_by") | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | |||||
| * 更新时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_time") | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 状态,0失效,1生效 | |||||
| */ | |||||
| @ApiModelProperty(name = "state") | |||||
| @ApiModelProperty(value = "状态,0失效,1生效") | |||||
| private Integer state; | private Integer state; | ||||
| @@ -18,51 +18,37 @@ import java.io.Serializable; | |||||
| @ApiModel("模型对象") | @ApiModel("模型对象") | ||||
| public class Models implements Serializable { | public class Models implements Serializable { | ||||
| private static final long serialVersionUID = -59896385986032571L; | private static final long serialVersionUID = -59896385986032571L; | ||||
| @ApiModelProperty(name = "id") | |||||
| @ApiModelProperty(value = "ID") | |||||
| private Integer id; | private Integer id; | ||||
| @ApiModelProperty(name = "name") | |||||
| @ApiModelProperty(value = "模型名称") | |||||
| private String name; | private String name; | ||||
| // private String version; | |||||
| @ApiModelProperty(name = "description") | |||||
| @ApiModelProperty(value = "模型描述") | |||||
| private String description; | private String description; | ||||
| /** | |||||
| * 模型可见范围 | |||||
| */ | |||||
| @ApiModelProperty(name = "available_range") | |||||
| @ApiModelProperty(value = "模型可见范围,1表示公开,0表示私有") | |||||
| private int availableRange; | private int availableRange; | ||||
| @ApiModelProperty(name = "model_type") | |||||
| @ApiModelProperty(value = "模型类型") | |||||
| private String modelType; | private String modelType; | ||||
| @ApiModelProperty(name = "model_tag") | |||||
| @ApiModelProperty(value = "模型标签") | |||||
| private String modelTag; | private String modelTag; | ||||
| /** | |||||
| * 创建者 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_by") | |||||
| @ApiModelProperty(value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| /** | |||||
| * 创建时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_time") | |||||
| @ApiModelProperty(value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | |||||
| * 更新者 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_by") | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | |||||
| * 更新时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_time") | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 0,失效 1生效 | |||||
| */ | |||||
| @ApiModelProperty(name = "state") | |||||
| @ApiModelProperty(value = "状态,0失效,1生效") | |||||
| private Integer state; | private Integer state; | ||||
| @@ -21,59 +21,43 @@ public class ModelsVersion implements Serializable { | |||||
| /** | /** | ||||
| * 主键 | * 主键 | ||||
| */ | */ | ||||
| @ApiModelProperty(name = "id") | |||||
| private Integer id; | |||||
| @ApiModelProperty(name = "models_id") | |||||
| @ApiModelProperty(value = "ID") | |||||
| private Integer id; | |||||
| @ApiModelProperty(value = "模型ID") | |||||
| private Integer modelsId; | private Integer modelsId; | ||||
| /** | |||||
| * 版本 | |||||
| */ | |||||
| @ApiModelProperty(name = "version") | |||||
| @ApiModelProperty(value = "版本") | |||||
| private String version; | private String version; | ||||
| /** | |||||
| * 模型存储地址 | |||||
| */ | |||||
| @ApiModelProperty(name = "url") | |||||
| @ApiModelProperty(value = "模型存储地址") | |||||
| private String url; | private String url; | ||||
| /** | |||||
| * 文件名 | |||||
| */ | |||||
| @ApiModelProperty(name = "file_name") | |||||
| @ApiModelProperty(value = "文件名") | |||||
| private String fileName; | private String fileName; | ||||
| /** | |||||
| * 文件大小 | |||||
| */ | |||||
| @ApiModelProperty(name = "file_size") | |||||
| @ApiModelProperty(value = "文件大小") | |||||
| private String fileSize; | private String fileSize; | ||||
| /** | |||||
| * 状态 | |||||
| */ | |||||
| @ApiModelProperty(name = "status") | |||||
| @ApiModelProperty(value = "状态") | |||||
| private Integer status; | private Integer status; | ||||
| /** | |||||
| * 创建者 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_by") | |||||
| @ApiModelProperty(value = "模型版本描述") | |||||
| private String description; | |||||
| @ApiModelProperty(value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| /** | |||||
| * 创建时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_time") | |||||
| @ApiModelProperty(value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | |||||
| * 更新者 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_by") | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | |||||
| * 更新时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_time") | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 0失效,1生效 | |||||
| */ | |||||
| @ApiModelProperty(name = "state") | |||||
| @ApiModelProperty(value = "状态,0失效,1生效") | |||||
| private Integer state; | private Integer state; | ||||
| @@ -133,6 +117,14 @@ public class ModelsVersion implements Serializable { | |||||
| this.status = status; | this.status = status; | ||||
| } | } | ||||
| public String getDescription() { | |||||
| return description; | |||||
| } | |||||
| public void setDescription(String description) { | |||||
| this.description = description; | |||||
| } | |||||
| public String getCreateBy() { | public String getCreateBy() { | ||||
| return createBy; | return createBy; | ||||
| } | } | ||||
| @@ -29,53 +29,35 @@ public class Workflow extends BaseMetaObjectHandler implements Serializable { | |||||
| /** | /** | ||||
| * id | * id | ||||
| */ | */ | ||||
| @TableId | |||||
| @ApiModelProperty(name = "id") | |||||
| @ApiModelProperty(value = "ID") | |||||
| private Long id; | private Long id; | ||||
| /** | |||||
| * 工作流名称 | |||||
| */ | |||||
| @ApiModelProperty(name = "name") | |||||
| @ApiModelProperty(value = "工作流名称") | |||||
| private String name; | private String name; | ||||
| /** | |||||
| * DAG工作流描述 | |||||
| */ | |||||
| @ApiModelProperty(name = "description") | |||||
| @ApiModelProperty(value = "流水线描述") | |||||
| private String description; | private String description; | ||||
| /** | |||||
| * DAG图 | |||||
| */ | |||||
| @ApiModelProperty(name = "dag") | |||||
| @ApiModelProperty(value = "DAG图") | |||||
| private String dag; | private String dag; | ||||
| // @ApiModelProperty(name = "global_param") | |||||
| @JsonRawValue | @JsonRawValue | ||||
| @ApiModelProperty(value = "全局参数") | |||||
| private String globalParam; | private String globalParam; | ||||
| /** | |||||
| * 创建者 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_by") | |||||
| @ApiModelProperty(value = "创建者") | |||||
| private String createBy; | private String createBy; | ||||
| /** | |||||
| * 创建时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "create_time") | |||||
| @ApiModelProperty(value = "创建时间") | |||||
| private Date createTime; | private Date createTime; | ||||
| /** | |||||
| * 更新者 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_by") | |||||
| @ApiModelProperty(value = "更新者") | |||||
| private String updateBy; | private String updateBy; | ||||
| /** | |||||
| * 更新时间 | |||||
| */ | |||||
| @ApiModelProperty(name = "update_time") | |||||
| @ApiModelProperty(value = "更新时间") | |||||
| private Date updateTime; | private Date updateTime; | ||||
| /** | |||||
| * 0,失效 1生效 | |||||
| */ | |||||
| @ApiModelProperty(name = "state") | |||||
| @ApiModelProperty(value = "状态,0失效,1生效") | |||||
| private Integer state; | private Integer state; | ||||
| @@ -90,5 +90,7 @@ public interface ExperimentInsDao { | |||||
| List<ExperimentIns> getByExperimentId(Integer experimentId); | List<ExperimentIns> getByExperimentId(Integer experimentId); | ||||
| List<ExperimentIns> queryByExperiment(@Param("experimentIns") ExperimentIns experimentIns); | List<ExperimentIns> queryByExperiment(@Param("experimentIns") ExperimentIns experimentIns); | ||||
| List<ExperimentIns> queryByExperimentId(Integer id); | |||||
| } | } | ||||
| @@ -60,18 +60,6 @@ public class DatasetServiceImpl implements DatasetService { | |||||
| @Resource | @Resource | ||||
| private DatasetVersionService datasetVersionService; | private DatasetVersionService datasetVersionService; | ||||
| private MinioClient minioClient; | |||||
| @Value("${minio.endpoint}") | |||||
| private String minioEndpoint; | |||||
| @Value("${minio.accessKey}") | |||||
| private String minioAccessKey; | |||||
| @Value("${minio.secretKey}") | |||||
| private String minioSecretKey; | |||||
| // 固定存储桶名 | // 固定存储桶名 | ||||
| private final String bucketName = "platform-data"; | private final String bucketName = "platform-data"; | ||||
| @@ -95,7 +95,7 @@ public class ExperimentInsServiceImpl implements ExperimentInsService { | |||||
| //搞个标记,当状态改变才去改表 | //搞个标记,当状态改变才去改表 | ||||
| boolean flag = false; | boolean flag = false; | ||||
| List<ExperimentIns> result = new ArrayList<ExperimentIns>(); | List<ExperimentIns> result = new ArrayList<ExperimentIns>(); | ||||
| if (experimentInsList!=null&& experimentInsList.size()>0) { | |||||
| if (experimentInsList!=null && experimentInsList.size()>0) { | |||||
| for (ExperimentIns experimentIns : experimentInsList) { | for (ExperimentIns experimentIns : experimentInsList) { | ||||
| //当原本状态为null或非终止态时才调用argo接口 | //当原本状态为null或非终止态时才调用argo接口 | ||||
| if (experimentIns != null && (StringUtils.isEmpty(experimentIns.getStatus())) || !isTerminatedState(experimentIns)) { | if (experimentIns != null && (StringUtils.isEmpty(experimentIns.getStatus())) || !isTerminatedState(experimentIns)) { | ||||
| @@ -111,11 +111,9 @@ public class ExperimentInsServiceImpl implements ExperimentInsService { | |||||
| } | } | ||||
| //新增查询tensorBoard容器状态 | //新增查询tensorBoard容器状态 | ||||
| result.add(experimentIns); | result.add(experimentIns); | ||||
| } | } | ||||
| } | } | ||||
| if (flag) { | if (flag) { | ||||
| List<String> statusList = new ArrayList<String>(); | List<String> statusList = new ArrayList<String>(); | ||||
| // 更新实验状态列表 | // 更新实验状态列表 | ||||
| @@ -231,9 +229,7 @@ public class ExperimentInsServiceImpl implements ExperimentInsService { | |||||
| @Override | @Override | ||||
| public List<ExperimentIns> queryByExperimentId(Integer id) { | public List<ExperimentIns> queryByExperimentId(Integer id) { | ||||
| ExperimentIns experimentIns = new ExperimentIns(); | |||||
| experimentIns.setExperimentId(id); | |||||
| return experimentInsDao.queryByExperiment(experimentIns); | |||||
| return experimentInsDao.queryByExperimentId(id); | |||||
| } | } | ||||
| @Override | @Override | ||||
| @@ -226,9 +226,10 @@ public class ExperimentServiceImpl implements ExperimentService { | |||||
| // 组装运行接口json | // 组装运行接口json | ||||
| Map<String, Object> runReqMap = new HashMap<>(); | Map<String, Object> runReqMap = new HashMap<>(); | ||||
| runReqMap.put("data", converMap.get("data")); | runReqMap.put("data", converMap.get("data")); | ||||
| //这里全局参数是一个json数组,需要转换成一个list<Map> | |||||
| List<Map<String, Object>> params = JacksonUtil.parseJSONStr2MapList(StringUtils.isEmpty(experiment.getGlobalParam()) ? "[]" : experiment.getGlobalParam()); | List<Map<String, Object>> params = JacksonUtil.parseJSONStr2MapList(StringUtils.isEmpty(experiment.getGlobalParam()) ? "[]" : experiment.getGlobalParam()); | ||||
| runReqMap.put("params", params); | runReqMap.put("params", params); | ||||
| //runReqMap.put("params", JsonUtils.jsonToMap(StringUtils.isEmpty(experiment.getGlobalParam())?"{}":experiment.getGlobalParam())); | |||||
| runReqMap.put("experiment", new HashMap<String, Object>().put("name", "experiment-"+experiment.getId())); | runReqMap.put("experiment", new HashMap<String, Object>().put("name", "experiment-"+experiment.getId())); | ||||
| Map<String ,Object> output = (Map<String, Object>) converMap.get("output"); | Map<String ,Object> output = (Map<String, Object>) converMap.get("output"); | ||||
| @@ -254,6 +255,8 @@ public class ExperimentServiceImpl implements ExperimentService { | |||||
| experimentIns.setArgoInsNs((String) metadata.get("namespace")); | experimentIns.setArgoInsNs((String) metadata.get("namespace")); | ||||
| experimentIns.setArgoInsName((String) metadata.get("name")); | experimentIns.setArgoInsName((String) metadata.get("name")); | ||||
| //传入实验全局参数 | //传入实验全局参数 | ||||
| experimentIns.setGlobalParam(experiment.getGlobalParam()); | experimentIns.setGlobalParam(experiment.getGlobalParam()); | ||||
| //替换argoInsName | //替换argoInsName | ||||
| @@ -265,10 +268,9 @@ public class ExperimentServiceImpl implements ExperimentService { | |||||
| }catch (Exception e){ | }catch (Exception e){ | ||||
| throw new RuntimeException(e); | throw new RuntimeException(e); | ||||
| } | } | ||||
| List<ExperimentIns> experimentIns = experimentInsService.queryByExperimentId(id); | |||||
| List<ExperimentIns> updatedExperimentInsList = experimentInsService.getByExperimentId(id); | |||||
| experiment.setExperimentInsList(experimentIns); | |||||
| experiment.setExperimentInsList(updatedExperimentInsList); | |||||
| return experiment; | return experiment; | ||||
| } | } | ||||
| @@ -52,18 +52,9 @@ public class ModelsServiceImpl implements ModelsService { | |||||
| @Resource | @Resource | ||||
| private ModelsVersionDao modelsVersionDao; | private ModelsVersionDao modelsVersionDao; | ||||
| private MinioClient minioClient; | |||||
| @Resource | @Resource | ||||
| private ModelsVersionService modelsVersionService; | private ModelsVersionService modelsVersionService; | ||||
| @Value("${minio.endpoint}") | |||||
| private String minioEndpoint; | |||||
| @Value("${minio.accessKey}") | |||||
| private String minioAccessKey; | |||||
| @Value("${minio.secretKey}") | |||||
| private String minioSecretKey; | |||||
| // 固定存储桶名 | // 固定存储桶名 | ||||
| private final String bucketName = "platform-data"; | private final String bucketName = "platform-data"; | ||||
| @@ -14,9 +14,12 @@ import io.kubernetes.client.util.Watch; | |||||
| import io.kubernetes.client.util.credentials.AccessTokenAuthentication; | import io.kubernetes.client.util.credentials.AccessTokenAuthentication; | ||||
| import lombok.extern.slf4j.Slf4j; | import lombok.extern.slf4j.Slf4j; | ||||
| import org.apache.commons.lang.StringUtils; | import org.apache.commons.lang.StringUtils; | ||||
| import org.apache.poi.ss.formula.functions.T; | |||||
| import org.springframework.beans.factory.annotation.Autowired; | |||||
| import org.springframework.beans.factory.annotation.Value; | import org.springframework.beans.factory.annotation.Value; | ||||
| import org.springframework.stereotype.Component; | import org.springframework.stereotype.Component; | ||||
| import javax.annotation.PostConstruct; | |||||
| import java.io.BufferedReader; | import java.io.BufferedReader; | ||||
| import java.io.InputStreamReader; | import java.io.InputStreamReader; | ||||
| import java.util.HashMap; | import java.util.HashMap; | ||||
| @@ -37,6 +40,7 @@ public class K8sClientUtil { | |||||
| @Value("${k8s.token}") | @Value("${k8s.token}") | ||||
| private String token; | private String token; | ||||
| /** | /** | ||||
| * k8s-api客户端 | * k8s-api客户端 | ||||
| */ | */ | ||||
| @@ -50,17 +54,23 @@ public class K8sClientUtil { | |||||
| * 3. service-account namespace | * 3. service-account namespace | ||||
| * 4. master endpoints(ip, port) from pre-set environment variables | * 4. master endpoints(ip, port) from pre-set environment variables | ||||
| */ | */ | ||||
| public K8sClientUtil() { | |||||
| try { | |||||
| // @Autowired | |||||
| // public K8sClientUtil() { | |||||
| // try { | |||||
| // this.apiClient = new ClientBuilder(). | |||||
| // setBasePath(http).setVerifyingSsl(false). | |||||
| // setAuthentication(new AccessTokenAuthentication(token)).build(); | |||||
| // } catch (Exception e) { | |||||
| // log.error("构建K8s-Client异常", e); | |||||
| // throw new RuntimeException("构建K8s-Client异常"); | |||||
| // } | |||||
| // } | |||||
| @PostConstruct | |||||
| public void init() { | |||||
| this.apiClient = new ClientBuilder(). | this.apiClient = new ClientBuilder(). | ||||
| setBasePath("https://172.20.32.181:6443").setVerifyingSsl(false). | |||||
| setAuthentication(new AccessTokenAuthentication("eyJhbGciOiJSUzI1NiIsImtpZCI6IjRWcFBPWl9YSFFxQ2tVanRuNHdRT1dnUlJNTnB2bG5TQlVSRjNKdExWNDQifQ.eyJpc3MiOiJrdWJlcm5ldGVzL3NlcnZpY2VhY2NvdW50Iiwia3ViZXJuZXRlcy5pby9zZXJ2aWNlYWNjb3VudC9uYW1lc3BhY2UiOiJkZWZhdWx0Iiwia3ViZXJuZXRlcy5pby9zZXJ2aWNlYWNjb3VudC9zZWNyZXQubmFtZSI6ImFkbWluLXNlcnZpY2UtYWNjb3VudC10b2tlbi14ZDk5eiIsImt1YmVybmV0ZXMuaW8vc2VydmljZWFjY291bnQvc2VydmljZS1hY2NvdW50Lm5hbWUiOiJhZG1pbi1zZXJ2aWNlLWFjY291bnQiLCJrdWJlcm5ldGVzLmlvL3NlcnZpY2VhY2NvdW50L3NlcnZpY2UtYWNjb3VudC51aWQiOiJmMGEzNmYyMS01MjQyLTQ4MTAtYWVmZS0xOTEwOTZlZjc5YmUiLCJzdWIiOiJzeXN0ZW06c2VydmljZWFjY291bnQ6ZGVmYXVsdDphZG1pbi1zZXJ2aWNlLWFjY291bnQifQ.fo-Wf0-5-IRC5fhRh65yfqCJqKfE9MrNFIXL2fd1CqVAHD7JBpWO2IsFiSmz9Bm7VfLmFAp2NB7DjW4ZLjC7ODiGhpSseBP8x4ceFuHL6pRGUsEBvHQBBBuQcGhNOcsxIDHnDqUdUzoLprj223lMZNTQowITuqYFU4GVbethyEuS6G5Wh9KHI3KYHFtG4_AeWBgI5Ppz8pDrhHzSFWTFbzxQ3RPGEwF0V-9wEtdrSYnfETi3rdRWif9W4a0RW8HwD9Gf7UCYcyFOs7e5_3-IvmctS85g87PYIfHXMhu_kOw-_Il4bkwPEK5uiBFDw0M1-s9YP-F9r5sXXvOJlsAr1g")).build(); | |||||
| } catch (Exception e) { | |||||
| log.error("构建K8s-Client异常", e); | |||||
| throw new RuntimeException("构建K8s-Client异常"); | |||||
| } | |||||
| } | |||||
| setBasePath(http).setVerifyingSsl(false). | |||||
| setAuthentication(new AccessTokenAuthentication(token)).build(); | |||||
| } | |||||
| /** | /** | ||||
| * 构建集群外通过UA访问的客户端 | * 构建集群外通过UA访问的客户端 | ||||
| @@ -5,9 +5,9 @@ import io.minio.*; | |||||
| import io.minio.errors.MinioException; | import io.minio.errors.MinioException; | ||||
| import io.minio.messages.Item; | import io.minio.messages.Item; | ||||
| import org.springframework.beans.factory.annotation.Value; | import org.springframework.beans.factory.annotation.Value; | ||||
| import org.springframework.core.io.InputStreamResource; | |||||
| import org.springframework.stereotype.Component; | import org.springframework.stereotype.Component; | ||||
| import javax.annotation.PostConstruct; | |||||
| import java.io.*; | import java.io.*; | ||||
| import java.nio.charset.StandardCharsets; | import java.nio.charset.StandardCharsets; | ||||
| import java.nio.file.Path; | import java.nio.file.Path; | ||||
| @@ -21,11 +21,21 @@ import java.util.zip.ZipOutputStream; | |||||
| @Component | @Component | ||||
| public class MinioUtil { | public class MinioUtil { | ||||
| @Value("${minio.endpoint}") | |||||
| private String minioEndpoint; | |||||
| @Value("${minio.accessKey}") | |||||
| private String minioAccessKey; | |||||
| @Value("${minio.secretKey}") | |||||
| private String minioSecretKey; | |||||
| private MinioClient minioClient; | private MinioClient minioClient; | ||||
| public MinioUtil() { | |||||
| @PostConstruct | |||||
| public void init() { | |||||
| this.minioClient = MinioClient.builder() | this.minioClient = MinioClient.builder() | ||||
| .endpoint("http://172.20.32.181:30164") | |||||
| .credentials("admin", "qazxc123456.") | |||||
| .endpoint(minioEndpoint) | |||||
| .credentials(minioAccessKey, minioSecretKey) | |||||
| .build(); | .build(); | ||||
| } | } | ||||
| public void createBucket(String bucketName) throws Exception { | public void createBucket(String bucketName) throws Exception { | ||||
| @@ -53,7 +53,7 @@ | |||||
| and id = #{assetIcon.id} | and id = #{assetIcon.id} | ||||
| </if> | </if> | ||||
| <if test="assetIcon.name != null and assetIcon.name != ''"> | <if test="assetIcon.name != null and assetIcon.name != ''"> | ||||
| and name = #{assetIcon.name} | |||||
| and name like "%"#{assetIcon.name}"%" | |||||
| </if> | </if> | ||||
| <if test="assetIcon.categoryId != null"> | <if test="assetIcon.categoryId != null"> | ||||
| and category_id = #{assetIcon.categoryId} | and category_id = #{assetIcon.categoryId} | ||||
| @@ -94,7 +94,7 @@ | |||||
| and id = #{assetIcon.id} | and id = #{assetIcon.id} | ||||
| </if> | </if> | ||||
| <if test="assetIcon.name != null and assetIcon.name != ''"> | <if test="assetIcon.name != null and assetIcon.name != ''"> | ||||
| and name = #{assetIcon.name} | |||||
| and name like "%"#{assetIcon.name}"%" | |||||
| </if> | </if> | ||||
| <if test="assetIcon.categoryId != null"> | <if test="assetIcon.categoryId != null"> | ||||
| and category_id = #{assetIcon.categoryId} | and category_id = #{assetIcon.categoryId} | ||||
| @@ -11,6 +11,7 @@ | |||||
| <result property="fileSize" column="file_size" jdbcType="VARCHAR"/> | <result property="fileSize" column="file_size" jdbcType="VARCHAR"/> | ||||
| <result property="availableCluster" column="available_cluster" jdbcType="VARCHAR"/> | <result property="availableCluster" column="available_cluster" jdbcType="VARCHAR"/> | ||||
| <result property="status" column="status" jdbcType="INTEGER"/> | <result property="status" column="status" jdbcType="INTEGER"/> | ||||
| <result property="description" column="description" jdbcType="VARCHAR"/> | |||||
| <result property="createBy" column="create_by" jdbcType="VARCHAR"/> | <result property="createBy" column="create_by" jdbcType="VARCHAR"/> | ||||
| <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/> | <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/> | ||||
| <result property="updateBy" column="update_by" jdbcType="VARCHAR"/> | <result property="updateBy" column="update_by" jdbcType="VARCHAR"/> | ||||
| @@ -20,14 +21,14 @@ | |||||
| <select id="queryById" resultMap="DatasetVersionMap"> | <select id="queryById" resultMap="DatasetVersionMap"> | ||||
| select | select | ||||
| id,dataset_id,version,url,file_name,file_size,available_cluster,status,create_by,create_time,update_by,update_time,state | |||||
| id,dataset_id,version,url,file_name,file_size,available_cluster,status, description,create_by,create_time,update_by,update_time,state | |||||
| from dataset_version | from dataset_version | ||||
| where id = #{id} and state = 1 | where id = #{id} and state = 1 | ||||
| </select> | </select> | ||||
| <!--查询单个--> | <!--查询单个--> | ||||
| <select id="queryByDatasetId" resultMap="DatasetVersionMap"> | <select id="queryByDatasetId" resultMap="DatasetVersionMap"> | ||||
| select | select | ||||
| id,dataset_id,version,url,file_name,file_size,available_cluster,status,create_by,create_time,update_by,update_time,state | |||||
| id,dataset_id,version,url,file_name,file_size,available_cluster,status, description,create_by,create_time,update_by,update_time,state | |||||
| from dataset_version | from dataset_version | ||||
| where dataset_id = #{datasetId} and state = 1 | where dataset_id = #{datasetId} and state = 1 | ||||
| order by create_time desc | order by create_time desc | ||||
| @@ -35,7 +36,7 @@ | |||||
| <select id="queryByDatasetVersion" resultMap="DatasetVersionMap"> | <select id="queryByDatasetVersion" resultMap="DatasetVersionMap"> | ||||
| select | select | ||||
| id,dataset_id,version,url,file_name,file_size,available_cluster,status,create_by,create_time,update_by,update_time,state | |||||
| id,dataset_id,version,url,file_name,file_size,available_cluster,status, description,create_by,create_time,update_by,update_time,state | |||||
| from dataset_version | from dataset_version | ||||
| <where> | <where> | ||||
| state = 1 | state = 1 | ||||
| @@ -51,7 +52,7 @@ | |||||
| <select id="queryAllByDatasetVersion" resultMap="DatasetVersionMap"> | <select id="queryAllByDatasetVersion" resultMap="DatasetVersionMap"> | ||||
| select | select | ||||
| id,dataset_id,version,url,file_name,file_size,available_cluster,status,create_by,create_time,update_by,update_time,state | |||||
| id,dataset_id,version,url,file_name,file_size,available_cluster,status, description,create_by,create_time,update_by,update_time,state | |||||
| from dataset_version | from dataset_version | ||||
| <where> | <where> | ||||
| state = 1 | state = 1 | ||||
| @@ -69,7 +70,7 @@ | |||||
| <!--查询指定行数据--> | <!--查询指定行数据--> | ||||
| <select id="queryAllByLimit" resultMap="DatasetVersionMap"> | <select id="queryAllByLimit" resultMap="DatasetVersionMap"> | ||||
| select | select | ||||
| id,dataset_id,version,url,file_name,file_size,available_cluster,status,create_by,create_time,update_by,update_time,state | |||||
| id,dataset_id,version,url,file_name,file_size,available_cluster,status, description,create_by,create_time,update_by,update_time,state | |||||
| from dataset_version | from dataset_version | ||||
| <where> | <where> | ||||
| state = 1 | state = 1 | ||||
| @@ -97,6 +98,9 @@ | |||||
| <if test="datasetVersion.status != null"> | <if test="datasetVersion.status != null"> | ||||
| and status = #{datasetVersion.status} | and status = #{datasetVersion.status} | ||||
| </if> | </if> | ||||
| <if test="datasetVersion.description != null and datasetVersion.description != ''"> | |||||
| and description = #{datasetVersion.description} | |||||
| </if> | |||||
| <if test="datasetVersion.createBy != null and datasetVersion.createBy != ''"> | <if test="datasetVersion.createBy != null and datasetVersion.createBy != ''"> | ||||
| and create_by = #{datasetVersion.createBy} | and create_by = #{datasetVersion.createBy} | ||||
| </if> | </if> | ||||
| @@ -146,6 +150,9 @@ | |||||
| <if test="datasetVersion.status != null"> | <if test="datasetVersion.status != null"> | ||||
| and status = #{datasetVersion.status} | and status = #{datasetVersion.status} | ||||
| </if> | </if> | ||||
| <if test="datasetVersion.description != null and datasetVersion.description != ''"> | |||||
| and description = #{datasetVersion.description} | |||||
| </if> | |||||
| <if test="datasetVersion.createBy != null and datasetVersion.createBy != ''"> | <if test="datasetVersion.createBy != null and datasetVersion.createBy != ''"> | ||||
| and create_by = #{datasetVersion.createBy} | and create_by = #{datasetVersion.createBy} | ||||
| </if> | </if> | ||||
| @@ -167,23 +174,23 @@ | |||||
| <!--新增所有列--> | <!--新增所有列--> | ||||
| <insert id="insert" keyProperty="id" useGeneratedKeys="true"> | <insert id="insert" keyProperty="id" useGeneratedKeys="true"> | ||||
| insert into dataset_version(dataset_id,version,url,file_name,file_size,available_cluster,status,create_by,create_time,update_by,update_time,state) | |||||
| values (#{datasetVersion.datasetId},#{datasetVersion.version},#{datasetVersion.url},#{datasetVersion.fileName},#{datasetVersion.fileSize},#{datasetVersion.availableCluster},#{datasetVersion.status},#{datasetVersion.createBy},#{datasetVersion.createTime},#{datasetVersion.updateBy},#{datasetVersion.updateTime},#{datasetVersion.state}) | |||||
| insert into dataset_version(dataset_id,version,url,file_name,file_size,available_cluster,status, description,create_by,create_time,update_by,update_time,state) | |||||
| values (#{datasetVersion.datasetId},#{datasetVersion.version},#{datasetVersion.url},#{datasetVersion.fileName},#{datasetVersion.fileSize},#{datasetVersion.availableCluster},#{datasetVersion.status},#{datasetVersion.description},#{datasetVersion.createBy},#{datasetVersion.createTime},#{datasetVersion.updateBy},#{datasetVersion.updateTime},#{datasetVersion.state}) | |||||
| </insert> | </insert> | ||||
| <insert id="insertBatch" keyProperty="id" useGeneratedKeys="true"> | <insert id="insertBatch" keyProperty="id" useGeneratedKeys="true"> | ||||
| insert into dataset_version(dataset_id,version,url,file_name,file_size,available_cluster,status,create_by,create_time,update_by,update_time,state) | |||||
| insert into dataset_version(dataset_id,version,url,file_name,file_size,available_cluster,status, description,create_by,create_time,update_by,update_time,state) | |||||
| values | values | ||||
| <foreach collection="entities" item="entity" separator=","> | <foreach collection="entities" item="entity" separator=","> | ||||
| (#{entity.datasetId},#{entity.version},#{entity.url},#{entity.fileName},#{entity.fileSize},#{entity.availableCluster},#{entity.status},#{entity.createBy},#{entity.createTime},#{entity.updateBy},#{entity.updateTime},#{entity.state}) | |||||
| (#{entity.datasetId},#{entity.version},#{entity.url},#{entity.fileName},#{entity.fileSize},#{entity.availableCluster},#{entity.status},#{entity.description},#{entity.createBy},#{entity.createTime},#{entity.updateBy},#{entity.updateTime},#{entity.state}) | |||||
| </foreach> | </foreach> | ||||
| </insert> | </insert> | ||||
| <insert id="insertOrUpdateBatch" keyProperty="id" useGeneratedKeys="true"> | <insert id="insertOrUpdateBatch" keyProperty="id" useGeneratedKeys="true"> | ||||
| insert into dataset_version(dataset_id,version,url,file_name,file_size,available_cluster,status,create_by,create_time,update_by,update_time,state) | |||||
| insert into dataset_version(dataset_id,version,url,file_name,file_size,available_cluster,status, description,create_by,create_time,update_by,update_time,state) | |||||
| values | values | ||||
| <foreach collection="entities" item="entity" separator=","> | <foreach collection="entities" item="entity" separator=","> | ||||
| (#{entity.datasetId},#{entity.version},#{entity.url},#{entity.fileName},#{entity.fileSize},#{entity.availableCluster},#{entity.status},#{entity.createBy},#{entity.createTime},#{entity.updateBy},#{entity.updateTime},#{entity.state}) | |||||
| (#{entity.datasetId},#{entity.version},#{entity.url},#{entity.fileName},#{entity.fileSize},#{entity.availableCluster},#{entity.status},#{entity.description},#{entity.createBy},#{entity.createTime},#{entity.updateBy},#{entity.updateTime},#{entity.state}) | |||||
| </foreach> | </foreach> | ||||
| on duplicate key update | on duplicate key update | ||||
| dataset_id = values(dataset_id)version = values(version)url = values(url)file_name = values(file_name)file_size = values(file_size)available_cluster = values(available_cluster)status = values(status)create_by = values(create_by)create_time = values(create_time)update_by = values(update_by)update_time = values(update_time)state = values(state) | dataset_id = values(dataset_id)version = values(version)url = values(url)file_name = values(file_name)file_size = values(file_size)available_cluster = values(available_cluster)status = values(status)create_by = values(create_by)create_time = values(create_time)update_by = values(update_by)update_time = values(update_time)state = values(state) | ||||
| @@ -217,6 +224,9 @@ dataset_id = values(dataset_id)version = values(version)url = values(url)file_na | |||||
| <if test="datasetVersion.status != null"> | <if test="datasetVersion.status != null"> | ||||
| status = #{datasetVersion.status}, | status = #{datasetVersion.status}, | ||||
| </if> | </if> | ||||
| <if test="datasetVersion.description != null and datasetVersion.description != ''"> | |||||
| description = #{datasetVersion.description}, | |||||
| </if> | |||||
| <if test="datasetVersion.createBy != null and datasetVersion.createBy != ''"> | <if test="datasetVersion.createBy != null and datasetVersion.createBy != ''"> | ||||
| create_by = #{datasetVersion.createBy}, | create_by = #{datasetVersion.createBy}, | ||||
| </if> | </if> | ||||
| @@ -11,6 +11,7 @@ | |||||
| <result property="nodesStatus" column="nodes_status" jdbcType="VARCHAR"/> | <result property="nodesStatus" column="nodes_status" jdbcType="VARCHAR"/> | ||||
| <result property="nodesResult" column="nodes_result" jdbcType="VARCHAR"/> | <result property="nodesResult" column="nodes_result" jdbcType="VARCHAR"/> | ||||
| <result property="nodesLogs" column="nodes_logs" jdbcType="VARCHAR"/> | <result property="nodesLogs" column="nodes_logs" jdbcType="VARCHAR"/> | ||||
| <result property="globalParam" column="global_param" jdbcType="VARCHAR"/> | |||||
| <result property="startTime" column="start_time" jdbcType="TIMESTAMP"/> | <result property="startTime" column="start_time" jdbcType="TIMESTAMP"/> | ||||
| <result property="finishTime" column="finish_time" jdbcType="TIMESTAMP"/> | <result property="finishTime" column="finish_time" jdbcType="TIMESTAMP"/> | ||||
| <result property="createBy" column="create_by" jdbcType="VARCHAR"/> | <result property="createBy" column="create_by" jdbcType="VARCHAR"/> | ||||
| @@ -31,7 +32,7 @@ | |||||
| <!--查询列表--> | <!--查询列表--> | ||||
| <select id="getByExperimentId" resultMap="ExperimentInsMap"> | <select id="getByExperimentId" resultMap="ExperimentInsMap"> | ||||
| select id, experiment_id, argo_ins_name, argo_ins_ns, status, nodes_status,nodes_result, nodes_logs,global_param, start_time, finish_time, create_by, create_time, update_by, update_time, state | |||||
| select id, experiment_id, argo_ins_name, argo_ins_ns, status, nodes_status,nodes_result, nodes_logs, global_param, start_time, finish_time, create_by, create_time, update_by, update_time, state | |||||
| from experiment_ins | from experiment_ins | ||||
| where experiment_id = #{experiment_id} and state = 1 | where experiment_id = #{experiment_id} and state = 1 | ||||
| order by create_time DESC | order by create_time DESC | ||||
| @@ -195,6 +196,12 @@ | |||||
| </where> | </where> | ||||
| </select> | </select> | ||||
| <select id="queryByExperimentId" resultMap="ExperimentInsMap"> | |||||
| select id, experiment_id, argo_ins_name, argo_ins_ns, status, nodes_status,nodes_result, nodes_logs, global_param, start_time, finish_time, create_by, create_time, update_by, update_time, state | |||||
| from experiment_ins | |||||
| where experiment_id = #{id} and state = 1 | |||||
| </select> | |||||
| <!--新增所有列--> | <!--新增所有列--> | ||||
| <insert id="insert" keyProperty="id" useGeneratedKeys="true"> | <insert id="insert" keyProperty="id" useGeneratedKeys="true"> | ||||
| insert into experiment_ins(experiment_id,argo_ins_name,argo_ins_ns,status,nodes_status,nodes_result,nodes_logs,global_param,start_time,finish_time,create_by,create_time,update_by,update_time,state) | insert into experiment_ins(experiment_id,argo_ins_name,argo_ins_ns,status,nodes_status,nodes_result,nodes_logs,global_param,start_time,finish_time,create_by,create_time,update_by,update_time,state) | ||||
| @@ -10,6 +10,7 @@ | |||||
| <result property="fileName" column="file_name" jdbcType="VARCHAR"/> | <result property="fileName" column="file_name" jdbcType="VARCHAR"/> | ||||
| <result property="fileSize" column="file_size" jdbcType="VARCHAR"/> | <result property="fileSize" column="file_size" jdbcType="VARCHAR"/> | ||||
| <result property="status" column="status" jdbcType="INTEGER"/> | <result property="status" column="status" jdbcType="INTEGER"/> | ||||
| <result property="description" column="description" jdbcType="VARCHAR"/> | |||||
| <result property="createBy" column="create_by" jdbcType="VARCHAR"/> | <result property="createBy" column="create_by" jdbcType="VARCHAR"/> | ||||
| <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/> | <result property="createTime" column="create_time" jdbcType="TIMESTAMP"/> | ||||
| <result property="updateBy" column="update_by" jdbcType="VARCHAR"/> | <result property="updateBy" column="update_by" jdbcType="VARCHAR"/> | ||||
| @@ -18,7 +19,7 @@ | |||||
| </resultMap> | </resultMap> | ||||
| <select id="queryByModelsId" resultMap="ModelsVersionMap"> | <select id="queryByModelsId" resultMap="ModelsVersionMap"> | ||||
| select | select | ||||
| id,models_id,version,url,file_name,file_size,status,create_by,create_time,update_by,update_time,state | |||||
| id,models_id,version,url,file_name,file_size,status, description,create_by,create_time,update_by,update_time,state | |||||
| from models_version | from models_version | ||||
| where models_id = #{modelsId} and state = 1 | where models_id = #{modelsId} and state = 1 | ||||
| order by create_time desc | order by create_time desc | ||||
| @@ -27,14 +28,14 @@ | |||||
| <!--查询单个--> | <!--查询单个--> | ||||
| <select id="queryById" resultMap="ModelsVersionMap"> | <select id="queryById" resultMap="ModelsVersionMap"> | ||||
| select | select | ||||
| id,models_id,version,url,file_name,file_size,status,create_by,create_time,update_by,update_time,state | |||||
| id,models_id,version,url,file_name,file_size,status, description,create_by,create_time,update_by,update_time,state | |||||
| from models_version | from models_version | ||||
| where id = #{id} and state = 1 | where id = #{id} and state = 1 | ||||
| </select> | </select> | ||||
| <select id="queryByModelsVersion" resultMap="ModelsVersionMap"> | <select id="queryByModelsVersion" resultMap="ModelsVersionMap"> | ||||
| select | select | ||||
| id,models_id,version,url,file_name,file_size,status,create_by,create_time,update_by,update_time,state | |||||
| id,models_id,version,url,file_name,file_size,status, description,create_by,create_time,update_by,update_time,state | |||||
| from models_version | from models_version | ||||
| <where> | <where> | ||||
| state = 1 | state = 1 | ||||
| @@ -51,7 +52,7 @@ | |||||
| <!-- 查询模型同一个版本下的所有文件 --> | <!-- 查询模型同一个版本下的所有文件 --> | ||||
| <select id="queryAllByModelsVersion" resultMap="ModelsVersionMap"> | <select id="queryAllByModelsVersion" resultMap="ModelsVersionMap"> | ||||
| select | select | ||||
| id,models_id,version,url,file_name,file_size,status,create_by,create_time,update_by,update_time,state | |||||
| id,models_id,version,url,file_name,file_size,status, description,create_by,create_time,update_by,update_time,state | |||||
| from models_version | from models_version | ||||
| <where> | <where> | ||||
| state = 1 | state = 1 | ||||
| @@ -69,7 +70,7 @@ | |||||
| <!--查询指定行数据--> | <!--查询指定行数据--> | ||||
| <select id="queryAllByLimit" resultMap="ModelsVersionMap"> | <select id="queryAllByLimit" resultMap="ModelsVersionMap"> | ||||
| select | select | ||||
| id,models_id,version,url,file_name,file_size,status,create_by,create_time,update_by,update_time,state | |||||
| id,models_id,version,url,file_name,file_size,status, description,create_by,create_time,update_by,update_time,state | |||||
| from models_version | from models_version | ||||
| <where> | <where> | ||||
| state = 1 | state = 1 | ||||
| @@ -94,6 +95,9 @@ | |||||
| <if test="modelsVersion.status != null"> | <if test="modelsVersion.status != null"> | ||||
| and status = #{modelsVersion.status} | and status = #{modelsVersion.status} | ||||
| </if> | </if> | ||||
| <if test="modelsVersion.description != null and modelsVersion.description != ''"> | |||||
| and description = #{modelsVersion.description} | |||||
| </if> | |||||
| <if test="modelsVersion.createBy != null and modelsVersion.createBy != ''"> | <if test="modelsVersion.createBy != null and modelsVersion.createBy != ''"> | ||||
| and create_by = #{modelsVersion.createBy} | and create_by = #{modelsVersion.createBy} | ||||
| </if> | </if> | ||||
| @@ -140,6 +144,10 @@ | |||||
| <if test="modelsVersion.status != null"> | <if test="modelsVersion.status != null"> | ||||
| and status = #{modelsVersion.status} | and status = #{modelsVersion.status} | ||||
| </if> | </if> | ||||
| <if test="modelsVersion.description != null and modelsVersion.description != ''"> | |||||
| and description = #{modelsVersion.description} | |||||
| </if> | |||||
| <if test="modelsVersion.createBy != null and modelsVersion.createBy != ''"> | <if test="modelsVersion.createBy != null and modelsVersion.createBy != ''"> | ||||
| and create_by = #{modelsVersion.createBy} | and create_by = #{modelsVersion.createBy} | ||||
| </if> | </if> | ||||
| @@ -160,14 +168,14 @@ | |||||
| <!--新增所有列--> | <!--新增所有列--> | ||||
| <insert id="insert" keyProperty="id" useGeneratedKeys="true"> | <insert id="insert" keyProperty="id" useGeneratedKeys="true"> | ||||
| insert into models_version(models_id, version, url, file_name, file_size, status, create_by, create_time, update_by, update_time, state) | |||||
| insert into models_version(models_id, version, url, file_name, file_size, status, description, create_by, create_time, update_by, update_time, state) | |||||
| values (#{modelsVersion.modelsId}, #{modelsVersion.version}, #{modelsVersion.url}, #{modelsVersion.fileName}, #{modelsVersion.fileSize}, #{modelsVersion.status}, #{modelsVersion.createBy}, #{modelsVersion.createTime}, #{modelsVersion.updateBy}, #{modelsVersion.updateTime}, #{modelsVersion.state}) | values (#{modelsVersion.modelsId}, #{modelsVersion.version}, #{modelsVersion.url}, #{modelsVersion.fileName}, #{modelsVersion.fileSize}, #{modelsVersion.status}, #{modelsVersion.createBy}, #{modelsVersion.createTime}, #{modelsVersion.updateBy}, #{modelsVersion.updateTime}, #{modelsVersion.state}) | ||||
| </insert> | </insert> | ||||
| <insert id="insertBatch" keyProperty="id" useGeneratedKeys="true"> | <insert id="insertBatch" keyProperty="id" useGeneratedKeys="true"> | ||||
| insert into models_version | insert into models_version | ||||
| (models_id, version, url, file_name, file_size, status, create_by, create_time, update_by, update_time, state) | |||||
| (models_id, version, url, file_name, file_size, status, description, create_by, create_time, update_by, update_time, state) | |||||
| values | values | ||||
| <foreach collection="entities" item="entity" separator=","> | <foreach collection="entities" item="entity" separator=","> | ||||
| (#{entity.modelsId}, #{entity.version}, #{entity.url}, #{entity.fileName}, #{entity.fileSize}, #{entity.status}, #{entity.createBy}, #{entity.createTime}, #{entity.updateBy}, #{entity.updateTime}, #{entity.state}) | (#{entity.modelsId}, #{entity.version}, #{entity.url}, #{entity.fileName}, #{entity.fileSize}, #{entity.status}, #{entity.createBy}, #{entity.createTime}, #{entity.updateBy}, #{entity.updateTime}, #{entity.state}) | ||||
| @@ -177,7 +185,7 @@ | |||||
| <insert id="insertOrUpdateBatch" keyProperty="id" useGeneratedKeys="true"> | <insert id="insertOrUpdateBatch" keyProperty="id" useGeneratedKeys="true"> | ||||
| insert into models_version | insert into models_version | ||||
| (models_id, version, url, file_name, file_size, status, create_by, create_time, update_by, update_time, state) | |||||
| (models_id, version, url, file_name, file_size, status, description, create_by, create_time, update_by, update_time, state) | |||||
| values | values | ||||
| <foreach collection="entities" item="entity" separator=","> | <foreach collection="entities" item="entity" separator=","> | ||||
| (#{entity.modelsId}, #{entity.version}, #{entity.url}, #{entity.fileName}, #{entity.fileSize}, #{entity.status}, #{entity.createBy}, #{entity.createTime}, #{entity.updateBy}, #{entity.updateTime}, #{entity.state}) | (#{entity.modelsId}, #{entity.version}, #{entity.url}, #{entity.fileName}, #{entity.fileSize}, #{entity.status}, #{entity.createBy}, #{entity.createTime}, #{entity.updateBy}, #{entity.updateTime}, #{entity.state}) | ||||
| @@ -222,6 +230,9 @@ | |||||
| <if test="modelsVersion.status != null"> | <if test="modelsVersion.status != null"> | ||||
| status = #{modelsVersion.status}, | status = #{modelsVersion.status}, | ||||
| </if> | </if> | ||||
| <if test="modelsVersion.description != null and modelsVersion.description != ''"> | |||||
| description = #{modelsVersion.description}, | |||||
| </if> | |||||
| <if test="modelsVersion.createBy != null and modelsVersion.createBy != ''"> | <if test="modelsVersion.createBy != null and modelsVersion.createBy != ''"> | ||||
| create_by = #{modelsVersion.createBy}, | create_by = #{modelsVersion.createBy}, | ||||
| </if> | </if> | ||||