Browse Source

优化终止实验bug

dev-complex-computation
chenzhihang 1 year ago
parent
commit
36d5c0a7fe
4 changed files with 12 additions and 79 deletions
  1. +5
    -74
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/domain/DatasetTempStorage.java
  2. +3
    -2
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ExperimentInsServiceImpl.java
  3. +2
    -1
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ExperimentServiceImpl.java
  4. +2
    -2
      ruoyi-modules/management-platform/src/main/resources/mapper/managementPlatform/DatasetTempStorageDao.xml

+ 5
- 74
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/domain/DatasetTempStorage.java View File

@@ -1,5 +1,7 @@
package com.ruoyi.platform.domain; package com.ruoyi.platform.domain;


import lombok.Data;

import java.util.Date; import java.util.Date;
import java.io.Serializable; import java.io.Serializable;


@@ -9,11 +11,14 @@ import java.io.Serializable;
* @author makejava * @author makejava
* @since 2024-09-12 09:42:09 * @since 2024-09-12 09:42:09
*/ */
@Data
public class DatasetTempStorage implements Serializable { public class DatasetTempStorage implements Serializable {
private static final long serialVersionUID = -44025176874790480L; private static final long serialVersionUID = -44025176874790480L;


private Integer id; private Integer id;


private Integer repoId;

private String name; private String name;


private String version; private String version;
@@ -31,79 +36,5 @@ public class DatasetTempStorage implements Serializable {
private String updateBy; private String updateBy;


private Date updateTime; private Date updateTime;


public Integer getId() {
return id;
}

public void setId(Integer id) {
this.id = id;
}

public String getName() {
return name;
}

public void setName(String name) {
this.name = name;
}

public String getVersion() {
return version;
}

public void setVersion(String version) {
this.version = version;
}

public String getSource() {
return source;
}

public void setSource(String source) {
this.source = source;
}

public Integer getState() {
return state;
}

public void setState(Integer state) {
this.state = state;
}

public String getCreateBy() {
return createBy;
}

public void setCreateBy(String createBy) {
this.createBy = createBy;
}

public Date getCreateTime() {
return createTime;
}

public void setCreateTime(Date createTime) {
this.createTime = createTime;
}

public String getUpdateBy() {
return updateBy;
}

public void setUpdateBy(String updateBy) {
this.updateBy = updateBy;
}

public Date getUpdateTime() {
return updateTime;
}

public void setUpdateTime(Date updateTime) {
this.updateTime = updateTime;
}

} }



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

@@ -451,8 +451,9 @@ public class ExperimentInsServiceImpl implements ExperimentInsService {
queryMap.put("ins_id", experimentIns.getId()); queryMap.put("ins_id", experimentIns.getId());
DatasetTempStorage datasetTempStorage = datasetTempStorageDao.queryByInsId(JSON.toJSONString(queryMap)); DatasetTempStorage datasetTempStorage = datasetTempStorageDao.queryByInsId(JSON.toJSONString(queryMap));
Map<String, Object> source = JSONUtil.toBean(datasetTempStorage.getSource(), Map.class); Map<String, Object> source = JSONUtil.toBean(datasetTempStorage.getSource(), Map.class);
String relativePath = ci4sUsername + "/datasets/" + source.get("repo_id") + "/" + source.get("identifier") + "/" + source.get("version") + "/dataset";
newDatasetService.deleteDatasetVersionNew(Integer.valueOf((String) source.get("repo_id")), (String) source.get("identifier"), (String) source.get("owner"), (String) source.get("version"), relativePath);
String relativePath = ci4sUsername + "/datasets/" + datasetTempStorage.getRepoId() + "/" + datasetTempStorage.getName() + "/" + datasetTempStorage.getVersion() + "/dataset";
// todo owner替换为datasetTempStorage的
newDatasetService.deleteDatasetVersionNew(datasetTempStorage.getRepoId(), datasetTempStorage.getName(), (String) source.get("owner"), datasetTempStorage.getVersion(), relativePath);
} }
} }
} }


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

@@ -501,10 +501,11 @@ public class ExperimentServiceImpl implements ExperimentService {
if (datasets != null) { if (datasets != null) {
for (Map<String, Object> dataset : datasets) { for (Map<String, Object> dataset : datasets) {
DatasetTempStorage datasetTempStorage = new DatasetTempStorage(); DatasetTempStorage datasetTempStorage = new DatasetTempStorage();
datasetTempStorage.setRepoId(Integer.valueOf((String) dataset.get("dataset_id")));
datasetTempStorage.setName((String) dataset.get("dataset_identifier")); datasetTempStorage.setName((String) dataset.get("dataset_identifier"));
datasetTempStorage.setVersion((String) dataset.get("dataset_version")); datasetTempStorage.setVersion((String) dataset.get("dataset_version"));
datasetTempStorage.setSource(JacksonUtil.toJSONString(sourceParams)); datasetTempStorage.setSource(JacksonUtil.toJSONString(sourceParams));
datasetTempStorage.setState(1);
datasetTempStorage.setState(Constant.State_valid);
datasetTempStorageService.insert(datasetTempStorage); datasetTempStorageService.insert(datasetTempStorage);
} }
} }


+ 2
- 2
ruoyi-modules/management-platform/src/main/resources/mapper/managementPlatform/DatasetTempStorageDao.xml View File

@@ -140,8 +140,8 @@


<!--新增所有列--> <!--新增所有列-->
<insert id="insert" keyProperty="id" useGeneratedKeys="true"> <insert id="insert" keyProperty="id" useGeneratedKeys="true">
insert into dataset_temp_storage(name, version, source, state, create_by, create_time, update_by, update_time)
values (#{name}, #{version}, #{source}, #{state}, #{createBy}, #{createTime}, #{updateBy}, #{updateTime})
insert into dataset_temp_storage(repo_id, name, version, source, state, create_by, create_time, update_by, update_time)
values (#{repoId}, #{name}, #{version}, #{source}, #{state}, #{createBy}, #{createTime}, #{updateBy}, #{updateTime})
</insert> </insert>


<insert id="insertBatch" keyProperty="id" useGeneratedKeys="true"> <insert id="insertBatch" keyProperty="id" useGeneratedKeys="true">


Loading…
Cancel
Save