| @@ -139,6 +139,9 @@ public class ModelsController extends BaseController { | |||||
| public GenericsAjaxResult<String> addModelAndVersion(@RequestBody ModelsVo modelsVo) throws Exception { | public GenericsAjaxResult<String> addModelAndVersion(@RequestBody ModelsVo modelsVo) throws Exception { | ||||
| return genericsSuccess(this.modelsService.insertModelAndVersion(modelsVo)); | return genericsSuccess(this.modelsService.insertModelAndVersion(modelsVo)); | ||||
| } | } | ||||
| /** | /** | ||||
| @@ -32,7 +32,7 @@ public class Models implements Serializable { | |||||
| @ApiModelProperty(value = "模型可见范围,1表示公开,0表示私有") | @ApiModelProperty(value = "模型可见范围,1表示公开,0表示私有") | ||||
| private int availableRange; | private int availableRange; | ||||
| @ApiModelProperty(value = "模型类型") | |||||
| @ApiModelProperty(value = "模型类型(模型框架)") | |||||
| private String modelType; | private String modelType; | ||||
| @ApiModelProperty(value = "模型标签") | @ApiModelProperty(value = "模型标签") | ||||
| @@ -22,8 +22,8 @@ public class ModelsVersion implements Serializable { | |||||
| /** | /** | ||||
| * 主键 | * 主键 | ||||
| */ | */ | ||||
| @ApiModelProperty(value = "ID") | |||||
| private Integer id; | |||||
| @ApiModelProperty(value = "ID") | |||||
| private Integer id; | |||||
| @ApiModelProperty(value = "模型ID") | @ApiModelProperty(value = "模型ID") | ||||
| private Integer modelsId; | private Integer modelsId; | ||||
| @@ -105,6 +105,8 @@ public class DatasetServiceImpl implements DatasetService { | |||||
| } | } | ||||
| } | } | ||||
| return dataset; | return dataset; | ||||
| } | } | ||||
| /** | /** | ||||
| @@ -326,7 +328,7 @@ public class DatasetServiceImpl implements DatasetService { | |||||
| throw new Exception("新增数据集失败"); | throw new Exception("新增数据集失败"); | ||||
| } | } | ||||
| for (VersionVo datasetVersionVo :datasetVersionVos){ | |||||
| for (VersionVo datasetVersionVo : datasetVersionVos){ | |||||
| DatasetVersion datasetVersion = new DatasetVersion(); | DatasetVersion datasetVersion = new DatasetVersion(); | ||||
| datasetVersion.setDatasetId(datasetInsert.getId()); | datasetVersion.setDatasetId(datasetInsert.getId()); | ||||
| datasetVersion.setVersion(datasetVo.getVersion()); | datasetVersion.setVersion(datasetVo.getVersion()); | ||||
| @@ -45,6 +45,9 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { | |||||
| private String bucketName; | private String bucketName; | ||||
| @Resource | @Resource | ||||
| private MinioService minioService; | private MinioService minioService; | ||||
| // 固定存储桶名 | |||||
| @Value("${labelStudio.loaclUrl}") | |||||
| private String labelloaclUrl; | |||||
| /** | /** | ||||
| * 通过ID查询单条数据 | * 通过ID查询单条数据 | ||||
| * | * | ||||
| @@ -78,7 +81,12 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { | |||||
| @Override | @Override | ||||
| public DatasetVersion insert(DatasetVersion datasetVersion) throws Exception { | public DatasetVersion insert(DatasetVersion datasetVersion) throws Exception { | ||||
| //插入预备 | //插入预备 | ||||
| insertPrepare(datasetVersion); | |||||
| LoginUser loginUser = SecurityUtils.getLoginUser(); | |||||
| datasetVersion.setCreateBy(loginUser.getUsername()); | |||||
| datasetVersion.setUpdateBy(loginUser.getUsername()); | |||||
| datasetVersion.setUpdateTime(new Date()); | |||||
| datasetVersion.setCreateTime(new Date()); | |||||
| datasetVersion.setState(1); | |||||
| this.datasetVersionDao.insert(datasetVersion); | this.datasetVersionDao.insert(datasetVersion); | ||||
| return datasetVersion; | return datasetVersion; | ||||
| } | } | ||||
| @@ -99,6 +107,11 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { | |||||
| datasetVersion.setUpdateBy(loginUser.getUsername()); | datasetVersion.setUpdateBy(loginUser.getUsername()); | ||||
| datasetVersion.setUpdateTime(new Date()); | datasetVersion.setUpdateTime(new Date()); | ||||
| this.datasetVersionDao.update(datasetVersion); | this.datasetVersionDao.update(datasetVersion); | ||||
| //插入时需要更新对应的数据集更新时间 | |||||
| Integer datasetId = datasetVersion.getDatasetId(); | |||||
| Dataset dataset = this.datasetDao.queryById(datasetId); | |||||
| dataset.setUpdateTime(new Date()); | |||||
| this.datasetDao.update(dataset); | |||||
| return this.queryById(datasetVersion.getId()); | return this.queryById(datasetVersion.getId()); | ||||
| } | } | ||||
| @@ -213,7 +226,7 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { | |||||
| // 获取label-studio数据流 | // 获取label-studio数据流 | ||||
| Map<String, String> headers = new HashMap<String, String>(); | Map<String, String> headers = new HashMap<String, String>(); | ||||
| headers.put("Authorization","Token "+labelDatasetVersionVo.getToken()); | headers.put("Authorization","Token "+labelDatasetVersionVo.getToken()); | ||||
| InputStream inputStream = HttpUtils.getIntputStream("http://127.0.0.1:8080/api/projects/"+labelDatasetVersionVo.getProject_id()+"/export?exportType="+labelDatasetVersionVo.getExportType(), headers); | |||||
| InputStream inputStream = HttpUtils.getIntputStream(labelloaclUrl+"/api/projects/"+labelDatasetVersionVo.getProject_id()+"/export?exportType="+labelDatasetVersionVo.getExportType(), headers); | |||||
| // 构建objectName | // 构建objectName | ||||
| String username = SecurityUtils.getLoginUser().getUsername(); | String username = SecurityUtils.getLoginUser().getUsername(); | ||||
| String url = username + "/" + DateUtils.dateTimeNow() + "/" + dataset.getName()+"_"+labelDatasetVersionVo.getVersion()+"."+labelDatasetVersionVo.getExportType(); | String url = username + "/" + DateUtils.dateTimeNow() + "/" + dataset.getName()+"_"+labelDatasetVersionVo.getVersion()+"."+labelDatasetVersionVo.getExportType(); | ||||
| @@ -240,5 +253,10 @@ public class DatasetVersionServiceImpl implements DatasetVersionService { | |||||
| datasetVersion.setUpdateTime(new Date()); | datasetVersion.setUpdateTime(new Date()); | ||||
| datasetVersion.setCreateTime(new Date()); | datasetVersion.setCreateTime(new Date()); | ||||
| datasetVersion.setState(1); | datasetVersion.setState(1); | ||||
| //插入时需要更新对应的数据集更新时间 | |||||
| Integer datasetId = datasetVersion.getDatasetId(); | |||||
| Dataset dataset = this.datasetDao.queryById(datasetId); | |||||
| dataset.setUpdateTime(new Date()); | |||||
| this.datasetDao.update(dataset); | |||||
| } | } | ||||
| } | } | ||||
| @@ -2,6 +2,8 @@ package com.ruoyi.platform.service.impl; | |||||
| import com.ruoyi.common.security.utils.SecurityUtils; | import com.ruoyi.common.security.utils.SecurityUtils; | ||||
| import com.ruoyi.platform.annotations.CheckDuplicate; | import com.ruoyi.platform.annotations.CheckDuplicate; | ||||
| import com.ruoyi.platform.domain.Dataset; | |||||
| import com.ruoyi.platform.domain.Models; | |||||
| import com.ruoyi.platform.domain.ModelsVersion; | import com.ruoyi.platform.domain.ModelsVersion; | ||||
| import com.ruoyi.platform.mapper.ModelsDao; | import com.ruoyi.platform.mapper.ModelsDao; | ||||
| import com.ruoyi.platform.mapper.ModelsVersionDao; | import com.ruoyi.platform.mapper.ModelsVersionDao; | ||||
| @@ -71,8 +73,13 @@ public class ModelsVersionServiceImpl implements ModelsVersionService { | |||||
| */ | */ | ||||
| @Override | @Override | ||||
| public ModelsVersion insert(ModelsVersion modelsVersion) throws Exception { | public ModelsVersion insert(ModelsVersion modelsVersion) throws Exception { | ||||
| //插入预备 | |||||
| insertPrepare(modelsVersion); | |||||
| //插入预备,此时不需要判断版本重复 | |||||
| LoginUser loginUser = SecurityUtils.getLoginUser(); | |||||
| modelsVersion.setCreateBy(loginUser.getUsername()); | |||||
| modelsVersion.setUpdateBy(loginUser.getUsername()); | |||||
| modelsVersion.setUpdateTime(new Date()); | |||||
| modelsVersion.setCreateTime(new Date()); | |||||
| modelsVersion.setState(1); | |||||
| this.modelsVersionDao.insert(modelsVersion); | this.modelsVersionDao.insert(modelsVersion); | ||||
| return modelsVersion; | return modelsVersion; | ||||
| } | } | ||||
| @@ -157,7 +164,7 @@ public class ModelsVersionServiceImpl implements ModelsVersionService { | |||||
| /** | /** | ||||
| * 复制模型版本 | |||||
| * 根据版本id和version查询 | |||||
| * | * | ||||
| * @param modelsId 模型的id | * @param modelsId 模型的id | ||||
| * @param version 模型版本号 | * @param version 模型版本号 | ||||
| @@ -199,7 +206,7 @@ public class ModelsVersionServiceImpl implements ModelsVersionService { | |||||
| @Override | @Override | ||||
| public String addModelVersions(List<ModelsVersion> modelsVersions) throws Exception { | public String addModelVersions(List<ModelsVersion> modelsVersions) throws Exception { | ||||
| try { | try { | ||||
| // 遍历传入的 datasetVersions 列表 | |||||
| // 遍历传入的 modelsVersions 列表 | |||||
| for(ModelsVersion modelsVersion : modelsVersions) { | for(ModelsVersion modelsVersion : modelsVersions) { | ||||
| insertPrepare(modelsVersion); | insertPrepare(modelsVersion); | ||||
| } | } | ||||
| @@ -233,6 +240,11 @@ public class ModelsVersionServiceImpl implements ModelsVersionService { | |||||
| modelsVersion.setUpdateTime(new Date()); | modelsVersion.setUpdateTime(new Date()); | ||||
| modelsVersion.setCreateTime(new Date()); | modelsVersion.setCreateTime(new Date()); | ||||
| modelsVersion.setState(1); | modelsVersion.setState(1); | ||||
| //插入时需要更新对应的模型更新时间 | |||||
| Integer modelsId = modelsVersion.getModelsId(); | |||||
| Models models = this.modelsDao.queryById(modelsId); | |||||
| models.setUpdateTime(new Date()); | |||||
| this.modelsDao.update(models); | |||||
| } | } | ||||
| @@ -30,6 +30,7 @@ | |||||
| id, name, description,available_range, model_type,model_tag, create_by, create_time, update_by, update_time, state | id, name, description,available_range, model_type,model_tag, create_by, create_time, update_by, update_time, state | ||||
| from models | from models | ||||
| where name = #{name} and state = 1 limit 1 | where name = #{name} and state = 1 limit 1 | ||||
| </select> | </select> | ||||
| <!--查询指定行数据--> | <!--查询指定行数据--> | ||||
| @@ -11,7 +11,7 @@ import com.ruoyi.file.utils.FileUploadUtils; | |||||
| * | * | ||||
| * @author ruoyi | * @author ruoyi | ||||
| */ | */ | ||||
| @Primary | |||||
| @Service | @Service | ||||
| public class LocalSysFileServiceImpl implements ISysFileService | public class LocalSysFileServiceImpl implements ISysFileService | ||||
| { | { | ||||
| @@ -2,6 +2,7 @@ package com.ruoyi.file.service; | |||||
| import java.io.InputStream; | import java.io.InputStream; | ||||
| import org.springframework.beans.factory.annotation.Autowired; | import org.springframework.beans.factory.annotation.Autowired; | ||||
| import org.springframework.context.annotation.Primary; | |||||
| import org.springframework.stereotype.Service; | import org.springframework.stereotype.Service; | ||||
| import org.springframework.web.multipart.MultipartFile; | import org.springframework.web.multipart.MultipartFile; | ||||
| import com.alibaba.nacos.common.utils.IoUtils; | import com.alibaba.nacos.common.utils.IoUtils; | ||||
| @@ -15,6 +16,7 @@ import io.minio.PutObjectArgs; | |||||
| * | * | ||||
| * @author ruoyi | * @author ruoyi | ||||
| */ | */ | ||||
| @Primary | |||||
| @Service | @Service | ||||
| public class MinioSysFileServiceImpl implements ISysFileService | public class MinioSysFileServiceImpl implements ISysFileService | ||||
| { | { | ||||
| @@ -31,6 +33,8 @@ public class MinioSysFileServiceImpl implements ISysFileService | |||||
| * @return 访问地址 | * @return 访问地址 | ||||
| * @throws Exception | * @throws Exception | ||||
| */ | */ | ||||
| @Override | @Override | ||||
| public String uploadFile(MultipartFile file) throws Exception | public String uploadFile(MultipartFile file) throws Exception | ||||
| { | { | ||||