|
|
|
@@ -1,6 +1,8 @@ |
|
|
|
package com.ruoyi.platform.service.impl; |
|
|
|
|
|
|
|
import com.ruoyi.common.security.utils.SecurityUtils; |
|
|
|
import com.ruoyi.platform.annotations.CheckDuplicate; |
|
|
|
import com.ruoyi.platform.domain.Dataset; |
|
|
|
import com.ruoyi.platform.domain.DatasetVersion; |
|
|
|
import com.ruoyi.platform.domain.ModelsVersion; |
|
|
|
import com.ruoyi.platform.domain.Workflow; |
|
|
|
@@ -14,6 +16,7 @@ import org.springframework.data.domain.PageRequest; |
|
|
|
import org.springframework.stereotype.Service; |
|
|
|
|
|
|
|
import javax.annotation.Resource; |
|
|
|
import java.lang.reflect.Field; |
|
|
|
import java.util.Date; |
|
|
|
import java.util.HashMap; |
|
|
|
import java.util.List; |
|
|
|
@@ -61,8 +64,8 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { |
|
|
|
* @return 实例对象 |
|
|
|
*/ |
|
|
|
@Override |
|
|
|
public DatasetVersion insert(DatasetVersion datasetVersion) { |
|
|
|
|
|
|
|
public DatasetVersion insert(DatasetVersion datasetVersion) throws Exception { |
|
|
|
checkDeclaredVersion(datasetVersion); |
|
|
|
LoginUser loginUser = SecurityUtils.getLoginUser(); |
|
|
|
datasetVersion.setCreateBy(loginUser.getUsername()); |
|
|
|
datasetVersion.setUpdateBy(loginUser.getUsername()); |
|
|
|
@@ -127,22 +130,6 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { |
|
|
|
return datasetVersionDao.queryByDatasetId(datasetId); |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
/** |
|
|
|
* 复制数据集版本 |
|
|
|
* |
|
|
|
* @param oldDatasetVersion 待更新的数据集版本 |
|
|
|
* @return 新的数据集版本记录 |
|
|
|
*/ |
|
|
|
public DatasetVersion duplicateDatasetVersion(DatasetVersion oldDatasetVersion) { |
|
|
|
DatasetVersion newDatasetVersion = new DatasetVersion(); |
|
|
|
newDatasetVersion.setDatasetId(oldDatasetVersion.getDatasetId()); |
|
|
|
newDatasetVersion.setVersion(oldDatasetVersion.getVersion()); |
|
|
|
newDatasetVersion.setAvailableCluster(oldDatasetVersion.getAvailableCluster()); |
|
|
|
newDatasetVersion.setStatus(oldDatasetVersion.getStatus()); |
|
|
|
return this.insert(newDatasetVersion); |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public DatasetVersion queryByDatasetVersion(DatasetVersion datasetVersion) { |
|
|
|
return datasetVersionDao.queryByDatasetVersion(datasetVersion); |
|
|
|
@@ -167,4 +154,17 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { |
|
|
|
return results; |
|
|
|
} |
|
|
|
|
|
|
|
@Override |
|
|
|
public void checkDeclaredVersion(DatasetVersion insert) throws Exception { |
|
|
|
DatasetVersion datasetVersion = datasetVersionDao.findByDatasetAndVersion(insert.getDatasetId(),insert.getVersion()); |
|
|
|
if (datasetVersion != null) { |
|
|
|
Field[] fields = Dataset.class.getDeclaredFields(); |
|
|
|
for (Field field : fields) { |
|
|
|
if (field.isAnnotationPresent(CheckDuplicate.class)) { |
|
|
|
CheckDuplicate annotation = field.getAnnotation(CheckDuplicate.class); |
|
|
|
throw new Exception(annotation.value() + "不能重复"); |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |