mianbin/ops-pro
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

0602 ljc

Browse Source
This commit is contained in:
Hope Li 2025-06-02 10:15:03 +08:00
parent c7c64cc666
commit ef858413b9
3 changed files with 10 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/dal/req/resource/ResourceReq.java
View File

@ -3,7 +3,7 @@ package cd.casic.ci.process.dal.req.resource;
import cd.casic.ci.process.process.dataObject.resource.PipResourceCloud; import cd.casic.ci.process.process.dataObject.resource.PipResourceCloud;
import cd.casic.ci.process.process.dataObject.resource.PipResourceK8S; import cd.casic.ci.process.process.dataObject.resource.PipResourceK8S;
import cd.casic.ci.process.process.dataObject.resource.PipResourceMachine; import cd.casic.ci.process.process.dataObject.resource.PipResourceMachine;
import cd.casic.ci.process.process.dataObject.resource.PipelineDockerEndpoint; import cd.casic.module.execute.docker.dataobject.dto.DockerEndpointDo;
import lombok.Data; import lombok.Data;
@Data @Data
@ -36,7 +36,7 @@ public class ResourceReq {
private PipResourceMachine resourceMachine; private PipResourceMachine resourceMachine;
private PipelineDockerEndpoint dockerEndpoint; private DockerEndpointDo dockerEndpoint;
private PipResourceK8S pipResourceK8S; private PipResourceK8S pipResourceK8S;

4
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/dal/resp/resource/ResourceFindResp.java
View File

@ -3,7 +3,7 @@ package cd.casic.ci.process.dal.resp.resource;
import cd.casic.ci.process.process.dataObject.resource.PipResourceCloud; import cd.casic.ci.process.process.dataObject.resource.PipResourceCloud;
import cd.casic.ci.process.process.dataObject.resource.PipResourceK8S; import cd.casic.ci.process.process.dataObject.resource.PipResourceK8S;
import cd.casic.ci.process.process.dataObject.resource.PipResourceMachine; import cd.casic.ci.process.process.dataObject.resource.PipResourceMachine;
import cd.casic.ci.process.process.dataObject.resource.PipelineDockerEndpoint; import cd.casic.module.execute.docker.dataobject.dto.DockerEndpointDo;
import lombok.Data; import lombok.Data;
@Data @Data
@ -54,7 +54,7 @@ public class ResourceFindResp {
private PipResourceMachine resourceMachine; private PipResourceMachine resourceMachine;
private PipelineDockerEndpoint dockerEndpoint; private DockerEndpointDo dockerEndpoint;
private PipResourceK8S pipResourceK8S; private PipResourceK8S pipResourceK8S;

12
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/process/service/resource/impl/ResourceManagerServiceImpl.java
View File

@ -5,7 +5,6 @@ import cd.casic.ci.process.dal.req.resource.ResourceReq;
import cd.casic.ci.process.dal.resp.resource.ResourceFindResp; import cd.casic.ci.process.dal.resp.resource.ResourceFindResp;
import cd.casic.ci.process.process.converter.ResourceConverter; import cd.casic.ci.process.process.converter.ResourceConverter;
import cd.casic.ci.process.process.dal.pipeline.PipResourceCloudDao; import cd.casic.ci.process.process.dal.pipeline.PipResourceCloudDao;
import cd.casic.ci.process.process.dal.pipeline.PipResourceDockerEndpointDao;
import cd.casic.ci.process.process.dal.pipeline.PipResourceK8SDao; import cd.casic.ci.process.process.dal.pipeline.PipResourceK8SDao;
import cd.casic.ci.process.process.dal.pipeline.PipResourceMachineDao; import cd.casic.ci.process.process.dal.pipeline.PipResourceMachineDao;
import cd.casic.ci.process.process.dal.pipeline.PipResourceManagerDao; import cd.casic.ci.process.process.dal.pipeline.PipResourceManagerDao;
@ -13,13 +12,14 @@ import cd.casic.ci.process.process.dataObject.resource.PipResourceCloud;
import cd.casic.ci.process.process.dataObject.resource.PipResourceK8S; import cd.casic.ci.process.process.dataObject.resource.PipResourceK8S;
import cd.casic.ci.process.process.dataObject.resource.PipResourceMachine; import cd.casic.ci.process.process.dataObject.resource.PipResourceMachine;
import cd.casic.ci.process.process.dataObject.resource.PipResourceManager; import cd.casic.ci.process.process.dataObject.resource.PipResourceManager;
import cd.casic.ci.process.process.dataObject.resource.PipelineDockerEndpoint;
import cd.casic.ci.process.process.service.resource.ResourceManagerService; import cd.casic.ci.process.process.service.resource.ResourceManagerService;
import cd.casic.framework.commons.exception.ServiceException; import cd.casic.framework.commons.exception.ServiceException;
import cd.casic.framework.commons.exception.enums.GlobalErrorCodeConstants; import cd.casic.framework.commons.exception.enums.GlobalErrorCodeConstants;
import cd.casic.framework.commons.pojo.PageResult; import cd.casic.framework.commons.pojo.PageResult;
import cd.casic.framework.security.dal.user.AdminUserDO; import cd.casic.framework.security.dal.user.AdminUserDO;
import cd.casic.framework.tenant.core.service.AdminUserServiceImpl; import cd.casic.framework.tenant.core.service.AdminUserServiceImpl;
import cd.casic.module.execute.docker.dao.DockerEndpointDao;
import cd.casic.module.execute.docker.dataobject.dto.DockerEndpointDo;
import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper; import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;
import com.baomidou.mybatisplus.extension.plugins.pagination.Page; import com.baomidou.mybatisplus.extension.plugins.pagination.Page;
import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl; import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
@ -50,7 +50,7 @@ public class ResourceManagerServiceImpl extends ServiceImpl<PipResourceManagerDa
private PipResourceMachineDao machineDao; private PipResourceMachineDao machineDao;
@Resource @Resource
private PipResourceDockerEndpointDao dockerEndpointDao; private DockerEndpointDao dockerEndpointDao;
@Resource @Resource
private PipResourceK8SDao k8SDao; private PipResourceK8SDao k8SDao;
@ -82,7 +82,7 @@ public class ResourceManagerServiceImpl extends ServiceImpl<PipResourceManagerDa
pipResourceManager.setK8sId(pipResourceK8S.getId()); pipResourceManager.setK8sId(pipResourceK8S.getId());
} }
if (!ObjectUtils.isEmpty(resourceReq.getDockerEndpoint())) { if (!ObjectUtils.isEmpty(resourceReq.getDockerEndpoint())) {
PipelineDockerEndpoint dockerEndpoint = resourceReq.getDockerEndpoint(); DockerEndpointDo dockerEndpoint = resourceReq.getDockerEndpoint();
dockerEndpointDao.insert(dockerEndpoint); dockerEndpointDao.insert(dockerEndpoint);
pipResourceManager.setDockerId(dockerEndpoint.getId()); pipResourceManager.setDockerId(dockerEndpoint.getId());
@ -158,7 +158,7 @@ public class ResourceManagerServiceImpl extends ServiceImpl<PipResourceManagerDa
temp.setK8sId(pipResourceK8S.getId()); temp.setK8sId(pipResourceK8S.getId());
} }
if (!ObjectUtils.isEmpty(resourceReq.getDockerEndpoint())) { if (!ObjectUtils.isEmpty(resourceReq.getDockerEndpoint())) {
PipelineDockerEndpoint dockerEndpoint = resourceReq.getDockerEndpoint(); DockerEndpointDo dockerEndpoint = resourceReq.getDockerEndpoint();
dockerEndpointDao.insert(dockerEndpoint); dockerEndpointDao.insert(dockerEndpoint);
temp.setDockerId(dockerEndpoint.getId()); temp.setDockerId(dockerEndpoint.getId());
@ -289,7 +289,7 @@ public class ResourceManagerServiceImpl extends ServiceImpl<PipResourceManagerDa
resourceFindResp.setPipResourceK8S(pipResourceK8S); resourceFindResp.setPipResourceK8S(pipResourceK8S);
} }
if (!StringUtils.isEmpty(resourceFindResp.getDockerId())) { if (!StringUtils.isEmpty(resourceFindResp.getDockerId())) {
PipelineDockerEndpoint dockerEndpoint = dockerEndpointDao.selectById(resourceFindResp.getDockerId()); DockerEndpointDo dockerEndpoint = dockerEndpointDao.selectById(resourceFindResp.getDockerId());
resourceFindResp.setDockerEndpoint(dockerEndpoint); resourceFindResp.setDockerEndpoint(dockerEndpoint);
} }
if (!StringUtils.isEmpty(resourceFindResp.getCloudId())) { if (!StringUtils.isEmpty(resourceFindResp.getCloudId())) {