| @@ -2,11 +2,9 @@ package com.ruoyi.platform.controller.model; | |||||
| import com.ruoyi.common.core.web.domain.AjaxResult; | import com.ruoyi.common.core.web.domain.AjaxResult; | ||||
| import com.ruoyi.platform.service.ModelsService; | import com.ruoyi.platform.service.ModelsService; | ||||
| import com.ruoyi.platform.utils.DVCUtils; | |||||
| import com.ruoyi.platform.vo.ModelsVo; | import com.ruoyi.platform.vo.ModelsVo; | ||||
| import io.swagger.annotations.Api; | import io.swagger.annotations.Api; | ||||
| import io.swagger.annotations.ApiOperation; | import io.swagger.annotations.ApiOperation; | ||||
| import org.eclipse.jgit.api.errors.GitAPIException; | |||||
| import org.springframework.core.io.InputStreamResource; | import org.springframework.core.io.InputStreamResource; | ||||
| import org.springframework.data.domain.PageRequest; | import org.springframework.data.domain.PageRequest; | ||||
| import org.springframework.http.ResponseEntity; | import org.springframework.http.ResponseEntity; | ||||
| @@ -14,7 +12,6 @@ import org.springframework.web.bind.annotation.*; | |||||
| import org.springframework.web.multipart.MultipartFile; | import org.springframework.web.multipart.MultipartFile; | ||||
| import javax.annotation.Resource; | import javax.annotation.Resource; | ||||
| import java.io.IOException; | |||||
| import java.util.List; | import java.util.List; | ||||
| import java.util.Map; | import java.util.Map; | ||||
| @@ -77,6 +74,16 @@ public class NewModelFromGitController { | |||||
| } | } | ||||
| } | } | ||||
| @GetMapping("/queryVersions") | |||||
| @ApiOperation("分页查询模型版本") | |||||
| public AjaxResult queryVersions(@RequestParam(value = "page") int page, | |||||
| @RequestParam(value = "size") int size, | |||||
| @RequestParam("identifier") String identifier, | |||||
| @RequestParam("owner") String owner) throws Exception { | |||||
| PageRequest pageRequest = PageRequest.of(page, size); | |||||
| return AjaxResult.success(this.modelsService.queryVersions(pageRequest, identifier, owner)); | |||||
| } | |||||
| @GetMapping("/getVersionList") | @GetMapping("/getVersionList") | ||||
| @ApiOperation(value = "获取模型分支列表") | @ApiOperation(value = "获取模型分支列表") | ||||
| public AjaxResult getVersionList(@RequestParam("identifier") String identifier, @RequestParam("owner") String owner) throws Exception { | public AjaxResult getVersionList(@RequestParam("identifier") String identifier, @RequestParam("owner") String owner) throws Exception { | ||||
| @@ -24,4 +24,6 @@ public interface ModelDependency1Dao { | |||||
| int deleteModel(@Param("repoId") Integer repoId, @Param("identifier") String identifier, @Param("owner") String owner, @Param("version") String version); | int deleteModel(@Param("repoId") Integer repoId, @Param("identifier") String identifier, @Param("owner") String owner, @Param("version") String version); | ||||
| int deleteModelDependency(@Param("parentModel") String parentModel); | int deleteModelDependency(@Param("parentModel") String parentModel); | ||||
| String getMeta(@Param("identifier") String identifier, @Param("owner") String owner, @Param("version") String version); | |||||
| } | } | ||||
| @@ -99,6 +99,8 @@ public interface ModelsService { | |||||
| Page<ModelsVo> newPersonalQueryByPage(ModelsVo modelsVo, PageRequest pageRequest) throws Exception; | Page<ModelsVo> newPersonalQueryByPage(ModelsVo modelsVo, PageRequest pageRequest) throws Exception; | ||||
| Page<Map<String, Object>> queryVersions(PageRequest pageRequest, String identifier, String owner) throws Exception; | |||||
| List<Map<String, Object>> getVersionList(String identifier, String owner) throws Exception; | List<Map<String, Object>> getVersionList(String identifier, String owner) throws Exception; | ||||
| ModelsVo getModelDetail(Integer id, String identifier, String owner, String version) throws Exception; | ModelsVo getModelDetail(Integer id, String identifier, String owner, String version) throws Exception; | ||||
| @@ -973,11 +973,33 @@ public class ModelsServiceImpl implements ModelsService { | |||||
| return new PageImpl<>(result, pageRequest, collect.size()); | return new PageImpl<>(result, pageRequest, collect.size()); | ||||
| } | } | ||||
| @Override | |||||
| public Page<Map<String, Object>> queryVersions(PageRequest pageRequest, String identifier, String owner) throws Exception { | |||||
| String token = gitService.checkoutToken(); | |||||
| List<Map<String, Object>> collect = gitService.getBrancheList(token, owner, identifier); | |||||
| List<Map<String, Object>> result = collect.stream() | |||||
| .filter(branch -> !"master".equals(branch.get("name"))) | |||||
| .skip((pageRequest.getPageNumber()) * pageRequest.getPageSize()).limit(pageRequest.getPageSize()) | |||||
| .collect(Collectors.toList()); | |||||
| for (Map<String, Object> branch : result) { | |||||
| String meta = modelDependency1Dao.getMeta(identifier, owner, (String) branch.get("name")); | |||||
| ModelMetaVo modelMetaVo = JSON.parseObject(meta, ModelMetaVo.class); | |||||
| if (modelMetaVo.getParams() != null) { | |||||
| branch.putAll(modelMetaVo.getParams()); | |||||
| } | |||||
| if (modelMetaVo.getMetrics() != null) { | |||||
| branch.putAll(modelMetaVo.getMetrics()); | |||||
| } | |||||
| } | |||||
| return new PageImpl<>(result, pageRequest, collect.size()); | |||||
| } | |||||
| @Override | @Override | ||||
| public List<Map<String, Object>> getVersionList(String identifier, String owner) throws Exception { | public List<Map<String, Object>> getVersionList(String identifier, String owner) throws Exception { | ||||
| String token = gitService.checkoutToken(); | String token = gitService.checkoutToken(); | ||||
| List<Map<String, Object>> brancheList = gitService.getBrancheList(token, owner, identifier); | |||||
| return brancheList.stream() | |||||
| List<Map<String, Object>> branchList = gitService.getBrancheList(token, owner, identifier); | |||||
| return branchList.stream() | |||||
| .filter(branch -> !"master".equals(branch.get("name"))) | .filter(branch -> !"master".equals(branch.get("name"))) | ||||
| .collect(Collectors.toList()); | .collect(Collectors.toList()); | ||||
| } | } | ||||
| @@ -60,6 +60,15 @@ | |||||
| order by create_time desc limit 1 | order by create_time desc limit 1 | ||||
| </select> | </select> | ||||
| <select id="getMeta" resultType="java.lang.String"> | |||||
| select meta from model_dependency1 | |||||
| where identifier = #{identifier} | |||||
| and owner = #{owner} | |||||
| and version = #{version} | |||||
| and state = 1 | |||||
| order by create_time desc limit 1 | |||||
| </select> | |||||
| <update id="deleteModel"> | <update id="deleteModel"> | ||||
| update model_dependency1 | update model_dependency1 | ||||
| set state = 0 | set state = 0 | ||||