Browse Source

修改顺序

dev-DXTZYK
fanshuai 1 year ago
parent
commit
38ced879f4
4 changed files with 40 additions and 42 deletions
  1. +6
    -6
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/GitService.java
  2. +6
    -12
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/GitServiceImpl.java
  3. +12
    -8
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ModelsServiceImpl.java
  4. +16
    -16
      ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/NewDatasetServiceImpl.java

+ 6
- 6
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/GitService.java View File

@@ -12,17 +12,17 @@ public interface GitService {
String checkoutToken(); String checkoutToken();


//输入token,项目名,tag,创建新项目,返回项目地址 //输入token,项目名,tag,创建新项目,返回项目地址
Map createProject(GitProjectVo gitProjectVo) throws Exception;
Map createProject(String token,GitProjectVo gitProjectVo) throws Exception;


void createBranch(String owner, String projectName, String branchName, String oldBranchName) throws Exception;
void createBranch(String token,String owner, String projectName, String branchName, String oldBranchName) throws Exception;


void createTopic(Integer id, String topicName) throws Exception;
void createTopic(String token,Integer id, String topicName) throws Exception;


List<Map<String, Object>> getBrancheList(String owner, String projectName) throws Exception;
List<Map<String, Object>> getBrancheList(String token,String owner, String projectName) throws Exception;


void deleteProject(String owner, String projectName) throws Exception;
void deleteProject(String token,String owner, String projectName) throws Exception;


void deleteBranch(String owner, String projectName, String branchName, String localPath) throws Exception;
void deleteBranch(String token,String owner, String projectName, String branchName, String localPath) throws Exception;


Map getUserInfo(String token) throws Exception; Map getUserInfo(String token) throws Exception;
} }

+ 6
- 12
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/GitServiceImpl.java View File

@@ -98,20 +98,18 @@ public class GitServiceImpl implements GitService {
} }


@Override @Override
public Map createProject(GitProjectVo gitProjectVo) throws Exception {
String token = this.checkoutToken();
public Map createProject(String token,GitProjectVo gitProjectVo) throws Exception {
String userReq = HttpUtils.sendPostWithToken("https://www.gitlink.org.cn/api/projects.json", JsonUtils.objectToJson(gitProjectVo), token); String userReq = HttpUtils.sendPostWithToken("https://www.gitlink.org.cn/api/projects.json", JsonUtils.objectToJson(gitProjectVo), token);
return JsonUtils.jsonToMap(userReq); return JsonUtils.jsonToMap(userReq);
} }


@Override @Override
public void createBranch(String owner, String projectName, String branchName, String oldBranchName) throws Exception {
public void createBranch(String token,String owner, String projectName, String branchName, String oldBranchName) throws Exception {
//https://www.gitlink.org.cn/api/v1/fanshuai/testdssa8755/branches.json //https://www.gitlink.org.cn/api/v1/fanshuai/testdssa8755/branches.json
// { // {
// "new_branch_name": "SsS", // "new_branch_name": "SsS",
// "old_branch_name": "master" // "old_branch_name": "master"
// } // }
String token = this.checkoutToken();
String createBranchUrl = "https://www.gitlink.org.cn/api/v1/" + owner + "/" + projectName + "/branches.json"; String createBranchUrl = "https://www.gitlink.org.cn/api/v1/" + owner + "/" + projectName + "/branches.json";
Map<String, Object> resMap = new HashMap<>(); Map<String, Object> resMap = new HashMap<>();
resMap.put("new_branch_name", branchName); resMap.put("new_branch_name", branchName);
@@ -121,9 +119,8 @@ public class GitServiceImpl implements GitService {
} }


@Override @Override
public void createTopic(Integer id, String topicName) throws Exception {
public void createTopic(String token,Integer id, String topicName) throws Exception {
// https://www.gitlink.org.cn/api/v1/project_topics.json // https://www.gitlink.org.cn/api/v1/project_topics.json
String token = this.checkoutToken();
Map<String, Object> resMap = new HashMap<>(); Map<String, Object> resMap = new HashMap<>();
resMap.put("project_id", id); resMap.put("project_id", id);
resMap.put("name", topicName); resMap.put("name", topicName);
@@ -131,8 +128,7 @@ public class GitServiceImpl implements GitService {
} }


@Override @Override
public List<Map<String, Object>> getBrancheList(String owner, String projectName) throws Exception {
String token = checkoutToken();
public List<Map<String, Object>> getBrancheList(String token,String owner, String projectName) throws Exception {
String req = HttpUtils.sendGetWithToken("https://www.gitlink.org.cn/api/v1/" + owner + "/" + projectName + "/branches/all.json", null, token); String req = HttpUtils.sendGetWithToken("https://www.gitlink.org.cn/api/v1/" + owner + "/" + projectName + "/branches/all.json", null, token);
// 解析响应JSON // 解析响应JSON
if (StringUtils.isEmpty(req)) { if (StringUtils.isEmpty(req)) {
@@ -144,20 +140,18 @@ public class GitServiceImpl implements GitService {
} }


@Override @Override
public void deleteProject(String owner, String projectName) throws Exception {
String token = this.checkoutToken();
public void deleteProject(String token,String owner, String projectName) throws Exception {
HttpUtils.sendDeleteRequest("https://www.gitlink.org.cn/api/" + owner + "/" + projectName + ".json", token); HttpUtils.sendDeleteRequest("https://www.gitlink.org.cn/api/" + owner + "/" + projectName + ".json", token);
} }


@Override @Override
public void deleteBranch(String owner, String projectName, String branchName, String localPath) throws Exception {
public void deleteBranch(String token,String owner, String projectName, String branchName, String localPath) throws Exception {
try (Git git = Git.open(new File(localPath))) { try (Git git = Git.open(new File(localPath))) {
git.checkout().setName("master").call(); git.checkout().setName("master").call();
git.branchDelete().setBranchNames(branchName).setForce(true).call(); git.branchDelete().setBranchNames(branchName).setForce(true).call();
} catch (IOException | GitAPIException e) { } catch (IOException | GitAPIException e) {
log.error("Exception occurred while creating local branch based on master",e); log.error("Exception occurred while creating local branch based on master",e);
} }
String token = this.checkoutToken();
HttpUtils.sendDeleteRequest("https://www.gitlink.org.cn/api/v1/" + owner + "/" + projectName + "/branches/" + branchName + ".json", token); HttpUtils.sendDeleteRequest("https://www.gitlink.org.cn/api/v1/" + owner + "/" + projectName + "/branches/" + branchName + ".json", token);
} }




+ 12
- 8
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/ModelsServiceImpl.java View File

@@ -540,6 +540,7 @@ public class ModelsServiceImpl implements ModelsService {
@Override @Override
public String newCreateModel(ModelsVo modelsVo) { public String newCreateModel(ModelsVo modelsVo) {
try { try {
String token = gitService.checkoutToken();
LoginUser loginUser = SecurityUtils.getLoginUser(); LoginUser loginUser = SecurityUtils.getLoginUser();
String ci4sUsername = loginUser.getUsername(); String ci4sUsername = loginUser.getUsername();
String gitLinkUsername = loginUser.getSysUser().getGitLinkUsername(); String gitLinkUsername = loginUser.getSysUser().getGitLinkUsername();
@@ -571,17 +572,17 @@ public class ModelsServiceImpl implements ModelsService {
gitProjectVo.setUserId(userId); gitProjectVo.setUserId(userId);


// 创建项目 // 创建项目
Map project = gitService.createProject(gitProjectVo);
Map project = gitService.createProject(token,gitProjectVo);
Integer gitlinIid = (Integer) project.get("id"); Integer gitlinIid = (Integer) project.get("id");
if (gitlinIid == null) { if (gitlinIid == null) {
throw new Exception("创建模型失败:" + project.get("message")); throw new Exception("创建模型失败:" + project.get("message"));
} }
// 创建分支 // 创建分支
gitService.createBranch((String) userInfo.get("login"), repositoryName, modelsVo.getVersion(), "master");
gitService.createBranch(token,(String) userInfo.get("login"), repositoryName, modelsVo.getVersion(), "master");
// 定义标签 标签1:ci4s_model 标签2:ModelTag 标签3:ModelType // 定义标签 标签1:ci4s_model 标签2:ModelTag 标签3:ModelType
gitService.createTopic(gitlinIid, "ci4s_model");
gitService.createTopic(gitlinIid, "modeltag_" + modelsVo.getModelTag());
gitService.createTopic(gitlinIid, "modeltype_" + modelsVo.getModelType());
gitService.createTopic(token,gitlinIid, "ci4s_model");
gitService.createTopic(token,gitlinIid, "modeltag_" + modelsVo.getModelTag());
gitService.createTopic(token,gitlinIid, "modeltype_" + modelsVo.getModelType());


String branchName = modelsVo.getVersion(); String branchName = modelsVo.getVersion();
String owner = (String) userInfo.get("login"); String owner = (String) userInfo.get("login");
@@ -874,7 +875,8 @@ public class ModelsServiceImpl implements ModelsService {


@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 {
List<Map<String, Object>> brancheList = gitService.getBrancheList(owner, identifier);
String token = gitService.checkoutToken();
List<Map<String, Object>> brancheList = gitService.getBrancheList(token,owner, identifier);
return brancheList.stream() return brancheList.stream()
.filter(branch -> !"master".equals(branch.get("name"))) .filter(branch -> !"master".equals(branch.get("name")))
.collect(Collectors.toList()); .collect(Collectors.toList());
@@ -940,7 +942,8 @@ public class ModelsServiceImpl implements ModelsService {


@Override @Override
public void deleteModel(Integer repoId, String identifier, String owner) throws Exception { public void deleteModel(Integer repoId, String identifier, String owner) throws Exception {
gitService.deleteProject(owner, identifier);
String token = gitService.checkoutToken();
gitService.deleteProject(token,owner, identifier);
//删除模型依赖 //删除模型依赖
modelDependency1Dao.deleteModel(repoId, identifier, owner, null); modelDependency1Dao.deleteModel(repoId, identifier, owner, null);


@@ -953,7 +956,8 @@ public class ModelsServiceImpl implements ModelsService {


@Override @Override
public void deleteVersion(Integer repoId, String identifier, String owner, String version, String relativePath) throws Exception { public void deleteVersion(Integer repoId, String identifier, String owner, String version, String relativePath) throws Exception {
gitService.deleteBranch(owner, identifier, version, localPath + relativePath);
String token = gitService.checkoutToken();
gitService.deleteBranch(token,owner, identifier, version, localPath + relativePath);
//删除模型依赖 //删除模型依赖
modelDependency1Dao.deleteModel(repoId, identifier, owner, version); modelDependency1Dao.deleteModel(repoId, identifier, owner, version);
HashMap<String, Object> map = new HashMap<>(); HashMap<String, Object> map = new HashMap<>();


+ 16
- 16
ruoyi-modules/management-platform/src/main/java/com/ruoyi/platform/service/impl/NewDatasetServiceImpl.java View File

@@ -64,6 +64,7 @@ public class NewDatasetServiceImpl implements NewDatasetService {
private DatasetTempStorageService datasetTempStorageService; private DatasetTempStorageService datasetTempStorageService;
@Override @Override
public String newCreateDataset(NewDatasetVo datasetVo) throws Exception { public String newCreateDataset(NewDatasetVo datasetVo) throws Exception {
String token = gitService.checkoutToken();
Jedis jedis = new Jedis(redisHost); Jedis jedis = new Jedis(redisHost);
LoginUser loginUser = SecurityUtils.getLoginUser(); LoginUser loginUser = SecurityUtils.getLoginUser();
String ci4sUsername = loginUser.getUsername(); String ci4sUsername = loginUser.getUsername();
@@ -82,18 +83,18 @@ public class NewDatasetServiceImpl implements NewDatasetService {
gitProjectVo.setPrivate(!datasetVo.getIsPublic()); gitProjectVo.setPrivate(!datasetVo.getIsPublic());
gitProjectVo.setUserId(userId); gitProjectVo.setUserId(userId);
// 创建项目 // 创建项目
Map project = gitService.createProject(gitProjectVo);
Map project = gitService.createProject(token,gitProjectVo);
Integer gitlinIid = (Integer) project.get("id"); Integer gitlinIid = (Integer) project.get("id");
if (gitlinIid == null){ if (gitlinIid == null){
throw new Exception("创建数据集失败:"+project.get("message")); throw new Exception("创建数据集失败:"+project.get("message"));
} }
// 创建分支 // 创建分支
String branchName = datasetVo.getVersion(); String branchName = datasetVo.getVersion();
gitService.createBranch((String) userInfo.get("login"), repositoryName, branchName, "master");
gitService.createBranch(token,(String) userInfo.get("login"), repositoryName, branchName, "master");
// 定义标签 标签1:ci4s_dataset 标签2:DataTag 标签3:DataType // 定义标签 标签1:ci4s_dataset 标签2:DataTag 标签3:DataType
gitService.createTopic(gitlinIid, "ci4s_dataset");
gitService.createTopic(gitlinIid, "DataTag_" + datasetVo.getDataTag());
gitService.createTopic( gitlinIid, "DataType_" + datasetVo.getDataType());
gitService.createTopic(token,gitlinIid, "ci4s_dataset");
gitService.createTopic(token,gitlinIid, "DataTag_" + datasetVo.getDataTag());
gitService.createTopic(token, gitlinIid, "DataType_" + datasetVo.getDataType());
// 得到项目地址 // 得到项目地址
String projectUrl = gitendpoint + "/" + (String) userInfo.get("login") + "/"+ repositoryName + ".git"; String projectUrl = gitendpoint + "/" + (String) userInfo.get("login") + "/"+ repositoryName + ".git";


@@ -145,6 +146,7 @@ public class NewDatasetServiceImpl implements NewDatasetService {
} }


public String newCreateVersion(NewDatasetVo datasetVo) throws Exception { public String newCreateVersion(NewDatasetVo datasetVo) throws Exception {
gitService.checkoutToken();
Jedis jedis = new Jedis(redisHost); Jedis jedis = new Jedis(redisHost);
LoginUser loginUser = SecurityUtils.getLoginUser(); LoginUser loginUser = SecurityUtils.getLoginUser();
String ci4sUsername = loginUser.getUsername(); String ci4sUsername = loginUser.getUsername();
@@ -215,6 +217,7 @@ public class NewDatasetServiceImpl implements NewDatasetService {


@Override @Override
public Page<NewDatasetVo> newPersonalQueryByPage(Dataset dataset, PageRequest pageRequest) throws Exception { public Page<NewDatasetVo> newPersonalQueryByPage(Dataset dataset, PageRequest pageRequest) throws Exception {
gitService.checkoutToken();
Jedis jedis = new Jedis(redisHost); Jedis jedis = new Jedis(redisHost);
LoginUser loginUser = SecurityUtils.getLoginUser(); LoginUser loginUser = SecurityUtils.getLoginUser();
String ci4sUsername = loginUser.getUsername(); String ci4sUsername = loginUser.getUsername();
@@ -242,6 +245,7 @@ public class NewDatasetServiceImpl implements NewDatasetService {


@Override @Override
public Page<NewDatasetVo> newPubilcQueryByPage(Dataset dataset, PageRequest pageRequest) throws Exception { public Page<NewDatasetVo> newPubilcQueryByPage(Dataset dataset, PageRequest pageRequest) throws Exception {
gitService.checkoutToken();
Jedis jedis = new Jedis(redisHost); Jedis jedis = new Jedis(redisHost);
LoginUser loginUser = SecurityUtils.getLoginUser(); LoginUser loginUser = SecurityUtils.getLoginUser();
String ci4sUsername = loginUser.getUsername(); String ci4sUsername = loginUser.getUsername();
@@ -305,7 +309,8 @@ public class NewDatasetServiceImpl implements NewDatasetService {


@Override @Override
public List<Map<String, Object>> getVersionList(String repo, String owner) throws Exception { public List<Map<String, Object>> getVersionList(String repo, String owner) throws Exception {
List<Map<String, Object>> brancheList = gitService.getBrancheList(owner, repo);
String token = gitService.checkoutToken();
List<Map<String, Object>> brancheList = gitService.getBrancheList(token,owner, repo);
return brancheList.stream() return brancheList.stream()
.filter(branch -> !"master".equals(branch.get("name"))) .filter(branch -> !"master".equals(branch.get("name")))
.collect(Collectors.toList()); .collect(Collectors.toList());
@@ -313,20 +318,14 @@ public class NewDatasetServiceImpl implements NewDatasetService {


@Override @Override
public void deleteDatasetNew(String repo, String owner) throws Exception { public void deleteDatasetNew(String repo, String owner) throws Exception {
Jedis jedis = new Jedis(redisHost);
LoginUser loginUser = SecurityUtils.getLoginUser();
String ci4sUsername = loginUser.getUsername();
String token = jedis.get(ci4sUsername+"_gitToken");
gitService.deleteProject(owner, repo);
String token = gitService.checkoutToken();
gitService.deleteProject(token,owner, repo);
} }


@Override @Override
public void deleteDatasetVersionNew(String repo, String owner, String version, String relativePath) throws Exception { public void deleteDatasetVersionNew(String repo, String owner, String version, String relativePath) throws Exception {
Jedis jedis = new Jedis(redisHost);
LoginUser loginUser = SecurityUtils.getLoginUser();
String ci4sUsername = loginUser.getUsername();
String token = jedis.get(ci4sUsername+"_gitToken");
gitService.deleteBranch(owner, repo, version, localPathlocal + relativePath);
String token = gitService.checkoutToken();
gitService.deleteBranch(token,owner, repo, version, localPathlocal + relativePath);
} }


@Override @Override
@@ -341,6 +340,7 @@ public class NewDatasetServiceImpl implements NewDatasetService {
long sizeInBytes = file.getSize(); long sizeInBytes = file.getSize();
String formattedSize = FileUtil.formatFileSize(sizeInBytes); String formattedSize = FileUtil.formatFileSize(sizeInBytes);
File targetFile = new File(path, file.getOriginalFilename()); File targetFile = new File(path, file.getOriginalFilename());

// 确保目录存在 // 确保目录存在
targetFile.getParentFile().mkdirs(); targetFile.getParentFile().mkdirs();
// 保存文件到目标路径 // 保存文件到目标路径


Loading…
Cancel
Save