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

参数名称修改

Browse Source
This commit is contained in:
even 2025-05-22 09:26:50 +08:00
parent c09ebec3c7
commit 1ee523dc21
3 changed files with 255 additions and 255 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/runContext/SecondStageRunContext.java
View File

@ -12,7 +12,7 @@ import java.util.concurrent.ConcurrentHashMap;
public class SecondStageRunContext extends BaseRunContext{
public SecondStageRunContext(PipStage contextDef,Integer childCount, PipelineRunContext parentContext, Map<String, Object> localVariables) {
super(contextDef,childCount, parentContext, LocalDateTime.now(), parentContext.getResourceId(), parentContext.getTargetId(), parentContext.getTargetType(), parentContext.getGlobalVariables(), localVariables, new ConcurrentHashMap<>());
super(contextDef,childCount, parentContext, LocalDateTime.now(), parentContext.getResourceId(), parentContext.getTargetVersionId(), parentContext.getTargetType(), parentContext.getGlobalVariables(), localVariables, new ConcurrentHashMap<>());
}
@Override

2
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/runContext/TaskRunContext.java
View File

@ -12,7 +12,7 @@ import java.util.Map;
public class TaskRunContext extends BaseRunContext{
public TaskRunContext(PipTask contextDef, SecondStageRunContext parentContext,Map<String,Object> localVariable) {
super(contextDef,0, parentContext, LocalDateTime.now(), parentContext.getResourceId(), parentContext.getTargetId(), parentContext.getTargetType(), parentContext.getGlobalVariables(),localVariable, new HashMap<>());
super(contextDef,0, parentContext, LocalDateTime.now(), parentContext.getResourceId(), parentContext.getTargetVersionId(), parentContext.getTargetType(), parentContext.getGlobalVariables(),localVariable, new HashMap<>());
}
private TaskRunContext(PipBaseElement contextDef, BaseRunContext parentContext, LocalDateTime startTime, String resourceId, String targetId, String targetType, Map<String, Object> globalVariables, Map<String, Object> localVariables, Map<String, BaseRunContext> childContext) {
super(contextDef,0, parentContext, startTime, resourceId, targetId, targetType, globalVariables, localVariables, childContext);

506
modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/ScaSbomWorker.java
View File

@ -1,253 +1,253 @@
package cd.casic.ci.process.engine.worker;
import cd.casic.ci.common.pipeline.annotation.Plugin;
import cd.casic.ci.process.engine.configinfo.ScaSbomConfigInfo;
import cd.casic.ci.process.engine.runContext.BaseRunContext;
import cd.casic.ci.process.engine.runContext.TaskRunContext;
import cd.casic.ci.process.process.dataObject.base.PipBaseElement;
import cd.casic.ci.process.process.dataObject.pipeline.PipPipeline;
import cd.casic.ci.process.process.dataObject.target.TargetVersion;
import cd.casic.ci.process.process.dataObject.task.PipTask;
import cd.casic.ci.process.process.service.pipeline.PipelineService;
import cd.casic.ci.process.process.service.target.impl.TargetVersionServiceImpl;
import cd.casic.ci.process.process.service.task.impl.TaskServiceImpl;
import cd.casic.framework.commons.exception.ServiceException;
import cd.casic.framework.commons.exception.enums.GlobalErrorCodeConstants;
import cn.hutool.core.util.ObjectUtil;
import com.alibaba.fastjson.JSON;
import com.alibaba.fastjson.JSONObject;
import jakarta.annotation.Resource;
import lombok.extern.slf4j.Slf4j;
import org.apache.commons.lang3.StringUtils;
import org.springframework.beans.BeanUtils;
import org.springframework.core.io.FileSystemResource;
import org.springframework.http.*;
import org.springframework.util.LinkedMultiValueMap;
import org.springframework.util.MultiValueMap;
import org.springframework.web.client.RestTemplate;
import java.io.File;
import java.security.KeyManagementException;
import java.security.KeyStoreException;
import java.security.NoSuchAlgorithmException;
import java.util.*;
/**
* @author HopeLi
* @version v1.0
* @ClassName ScaSbomWorker
* @Date: 2025/5/21 9:30
* @Description:
*/
@Slf4j
@Plugin(taskType = "ScaSbom")
public class ScaSbomWorker extends HttpWorker{
private static final int POLLING_INTERVAL = 5000; // 轮询间隔，单位：毫秒
private static final int MAX_POLLING_TIMES = 100; // 最大退出次数
@Resource
private PipelineService pipelineService;
@Resource
private TargetVersionServiceImpl targetVersionService;
@Resource
private TaskServiceImpl pipelineNodeInfoService;
public String work(BaseRunContext workerParam) {
int statusCode = 0;
PipBaseElement contextDef = workerParam.getContextDef();
log.info("================SCA-SBOM节点执行===================");
if (ObjectUtil.isEmpty(contextDef)) {
log.error("未查询到节点[{}]配置,taskType = ScaSbom");
return "-1";
}
if (ObjectUtil.isEmpty(contextDef)) {
log.error("未查询到节点[{}]配置,taskType = ScaSbom");
return "-1";
}
String filePath = "";
if (contextDef instanceof PipTask pipTask){
// 查询并下载目标文件
String pipelineId = pipTask.getPipelineId();
//根据流水线id查询流水线信息
PipPipeline pipeline = pipelineService.getById(pipelineId);
//根据目标id查询目标信息
if (StringUtils.isEmpty(pipeline.getTargetVersionId())){
throw new ServiceException(GlobalErrorCodeConstants.INTERNAL_SERVER_ERROR.getCode(),"目标文件不存在");
}
TargetVersion targetVersion = targetVersionService.getById(pipeline.getTargetVersionId());
filePath = targetVersion.getFilePath();
try {
File file = new File(filePath);
if (!file.exists() || !file.canRead()) {
log.error("目标文件不存在或不可读");
// nodeLogger.appendErrorNow("目标文件不存在或不可读");
return "-1";
}
handleUpload(workerParam, contextDef, pipTask.getTaskProperties(), file);
}catch (Exception e){
throw new ServiceException(GlobalErrorCodeConstants.INTERNAL_SERVER_ERROR.getCode(),"SCA-SBOM节点执行失败");
}
}
return statusCode + "";
}
private void handleUpload(BaseRunContext workerParam, PipBaseElement pipelineNodeConfigInfo,
Map<String,Object> scaSbomConfigInfo, File file) throws NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
RestTemplate restTemplate = getRestTemplateWithoutSANCheck();
String scaUploadUrl = ConstantContextHolder.getScaIp() + "/openapi/v1/sbom/detect-file";
MultiValueMap<String, Object> body = buildRequestBody(scaSbomConfigInfo, file);
HttpHeaders headers = createHeaders();
headers.setContentType(MediaType.MULTIPART_FORM_DATA);
headers.add("OpenApiUserToken", ConstantContextHolder.getScaToken());
HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(body, headers);
log.info("SCA上传接口:" + scaUploadUrl);
JSONObject response = restTemplate.postForObject(scaUploadUrl, requestEntity, JSONObject.class);
String message = response.getString("message");
if (message.equals("success")) {
nodeLogger.appendNow("==================SCA上传成功=================");
JSONObject data = response.getJSONObject("data");
Integer scaTaskId = data.getInteger("scaTaskId");
Integer applicationId = data.getInteger("applicationId");
scaSbomConfigInfo.setScaTaskId(scaTaskId);
scaSbomConfigInfo.setApplicationId(applicationId);
//更新到节点json数据
String nodeJson = JSON.toJSONString(scaSbomConfigInfo);
pipelineNodeConfigInfo.setInfo(nodeJson);
PipelineNodeInfoParam pipelineNodeInfoParam = new PipelineNodeInfoParam();
BeanUtils.copyProperties(pipelineNodeConfigInfo, pipelineNodeInfoParam);
pipelineNodeInfoService.update(pipelineNodeInfoParam);
workerParam.getPipelineNodeConfigInfo().setInfo(nodeJson);
pollTaskStatus(restTemplate, scaTaskId);
} else if (message.equals("应用已经存在")) {
Integer oldScaTaskId = scaSbomConfigInfo.getScaTaskId();
Integer oldApplicationId = scaSbomConfigInfo.getApplicationId();
int restartResult = reStartTask(restTemplate, oldApplicationId);
if (restartResult != 0) {
return;
}
pollTaskStatus(restTemplate, oldScaTaskId);
} else {
nodeLogger.appendNow("==================SCA接口异常，调用失败=================");
}
}
private MultiValueMap<String, Object> buildRequestBody(ScaSbomConfigInfo scaSbomConfigInfo, File file) {
MultiValueMap<String, Object> body = new LinkedMultiValueMap<>();
body.add("file", new FileSystemResource(file));
body.add("projectName", scaSbomConfigInfo.getProjectName());
body.add("applicationName", scaSbomConfigInfo.getApplicationName());
body.add("applicationVersion", scaSbomConfigInfo.getApplicationVersion());
body.add("applicationDescription", scaSbomConfigInfo.getApplicationDescription());
return body;
}
/**
* 创建请求头
*
* @return HttpHeaders
*/
private HttpHeaders createHeaders() {
HttpHeaders headers = new HttpHeaders();
headers.add("OpenApiUserToken", ConstantContextHolder.getScaToken());
return headers;
}
/**
* 轮询请求任务状态
*
* @param restTemplate
* @param scaTaskId
*/
public void pollTaskStatus(RestTemplate restTemplate, Integer scaTaskId) {
int currentPollingTimes = 0;
while (currentPollingTimes < MAX_POLLING_TIMES) {
try {
HttpHeaders headers = new HttpHeaders();
headers.add("OpenApiUserToken", ConstantContextHolder.getScaToken());
HttpEntity<String> requestEntity = new HttpEntity<>(null, headers);
String scaStatusUrl = ConstantContextHolder.getScaIp() + "/openapi/v1/task/" + scaTaskId;
ResponseEntity<JSONObject> response = restTemplate.exchange(scaStatusUrl, HttpMethod.GET, requestEntity, JSONObject.class);
if (Objects.requireNonNull(response.getBody()).getString("message").equals("success")) {
//"status": 5, //状态 0-未审计 1-未检测 2-排队中 3-检测中 4-检测暂停 5-检测完成 6-检测超时 7-手动停止 8-检测异常 9-已删除 10-拉取中 11-停止中 12-下载中
int status = response.getBody().getJSONObject("data").getInteger("status");
log.info("当前任务状态: " + status);
if (status == 5) {
System.out.println("任务已完成，停止轮询。");
log.info("任务已完成，停止轮询。");
break;
}
} else {
log.error("获取任务状态失败: " + response.getBody().getString("message"));
break;
}
} catch (Exception e) {
log.error("获取任务状态时发生错误: " + e.getMessage());
}
try {
// 轮询间隔 5 秒
Thread.sleep(POLLING_INTERVAL);
} catch (InterruptedException e) {
Thread.currentThread().interrupt();
log.error("轮询被中断: " + e.getMessage());
}
currentPollingTimes++;
}
System.out.println("停止轮询");
}
/**
* 重新检测接口
*
* @param restTemplate
* @param applicationId
*/
public int reStartTask(RestTemplate restTemplate, Integer applicationId) {
try {
String url = ConstantContextHolder.getScaIp() + "/openapi/v1/task/batch/detect";
HttpHeaders headers = new HttpHeaders();
headers.add("OpenApiUserToken", ConstantContextHolder.getScaToken());
headers.setContentType(MediaType.APPLICATION_JSON);
headers.add("Accept", MediaType.APPLICATION_JSON.toString());
Map<String, List<Integer>> param = new HashMap<>();
param.put("applicationIds", Arrays.asList(applicationId));
String s = JSON.toJSONString(param);
HttpEntity<String> formEntry = new HttpEntity<>(s, headers);
JSONObject res = restTemplate.postForObject(url, formEntry, JSONObject.class);
if (res.getString("message").equals("success")) {
log.info("重新检测成功");
return 0;
} else {
log.error("重新检测失败");
log.error(res.getString("message"));
return -1;
}
} catch (Exception e) {
log.error("重新检测失败");
log.error(e.getMessage());
}
return 0;
}
@Override
public void execute(TaskRunContext context) {
}
}
//package cd.casic.ci.process.engine.worker;
//
//import cd.casic.ci.common.pipeline.annotation.Plugin;
//import cd.casic.ci.process.engine.configinfo.ScaSbomConfigInfo;
//import cd.casic.ci.process.engine.runContext.BaseRunContext;
//import cd.casic.ci.process.engine.runContext.TaskRunContext;
//import cd.casic.ci.process.process.dataObject.base.PipBaseElement;
//import cd.casic.ci.process.process.dataObject.pipeline.PipPipeline;
//import cd.casic.ci.process.process.dataObject.target.TargetVersion;
//import cd.casic.ci.process.process.dataObject.task.PipTask;
//import cd.casic.ci.process.process.service.pipeline.PipelineService;
//import cd.casic.ci.process.process.service.target.impl.TargetVersionServiceImpl;
//import cd.casic.ci.process.process.service.task.impl.TaskServiceImpl;
//import cd.casic.framework.commons.exception.ServiceException;
//import cd.casic.framework.commons.exception.enums.GlobalErrorCodeConstants;
//import cn.hutool.core.util.ObjectUtil;
//import com.alibaba.fastjson.JSON;
//import com.alibaba.fastjson.JSONObject;
//import jakarta.annotation.Resource;
//import lombok.extern.slf4j.Slf4j;
//import org.apache.commons.lang3.StringUtils;
//import org.springframework.beans.BeanUtils;
//import org.springframework.core.io.FileSystemResource;
//import org.springframework.http.*;
//import org.springframework.util.LinkedMultiValueMap;
//import org.springframework.util.MultiValueMap;
//import org.springframework.web.client.RestTemplate;
//
//import java.io.File;
//import java.security.KeyManagementException;
//import java.security.KeyStoreException;
//import java.security.NoSuchAlgorithmException;
//import java.util.*;
//
///**
// * @author HopeLi
// * @version v1.0
// * @ClassName ScaSbomWorker
// * @Date: 2025/5/21 9:30
// * @Description:
// */
//@Slf4j
//@Plugin(taskType = "ScaSbom")
//public class ScaSbomWorker extends HttpWorker{
//
// private static final int POLLING_INTERVAL = 5000; // 轮询间隔，单位：毫秒
// private static final int MAX_POLLING_TIMES = 100; // 最大退出次数
//
// @Resource
// private PipelineService pipelineService;
//
// @Resource
// private TargetVersionServiceImpl targetVersionService;
//
// @Resource
// private TaskServiceImpl pipelineNodeInfoService;
//
//
// public String work(BaseRunContext workerParam) {
// int statusCode = 0;
//
// PipBaseElement contextDef = workerParam.getContextDef();
// log.info("================SCA-SBOM节点执行===================");
// if (ObjectUtil.isEmpty(contextDef)) {
// log.error("未查询到节点[{}]配置,taskType = ScaSbom");
// return "-1";
// }
// if (ObjectUtil.isEmpty(contextDef)) {
// log.error("未查询到节点[{}]配置,taskType = ScaSbom");
// return "-1";
// }
//
// String filePath = "";
// if (contextDef instanceof PipTask pipTask){
// // 查询并下载目标文件
// String pipelineId = pipTask.getPipelineId();
// //根据流水线id查询流水线信息
// PipPipeline pipeline = pipelineService.getById(pipelineId);
// //根据目标id查询目标信息
// if (StringUtils.isEmpty(pipeline.getTargetVersionId())){
// throw new ServiceException(GlobalErrorCodeConstants.INTERNAL_SERVER_ERROR.getCode(),"目标文件不存在");
// }
// TargetVersion targetVersion = targetVersionService.getById(pipeline.getTargetVersionId());
// filePath = targetVersion.getFilePath();
//
// try {
//
//
// File file = new File(filePath);
// if (!file.exists() || !file.canRead()) {
// log.error("目标文件不存在或不可读");
//// nodeLogger.appendErrorNow("目标文件不存在或不可读");
// return "-1";
// }
//
// handleUpload(workerParam, contextDef, pipTask.getTaskProperties(), file);
// }catch (Exception e){
// throw new ServiceException(GlobalErrorCodeConstants.INTERNAL_SERVER_ERROR.getCode(),"SCA-SBOM节点执行失败");
// }
// }
//
//
// return statusCode + "";
// }
//
// private void handleUpload(BaseRunContext workerParam, PipBaseElement pipelineNodeConfigInfo,
// Map<String,Object> scaSbomConfigInfo, File file) throws NoSuchAlgorithmException, KeyStoreException, KeyManagementException {
// RestTemplate restTemplate = getRestTemplateWithoutSANCheck();
// String scaUploadUrl = ConstantContextHolder.getScaIp() + "/openapi/v1/sbom/detect-file";
// MultiValueMap<String, Object> body = buildRequestBody(scaSbomConfigInfo, file);
// HttpHeaders headers = createHeaders();
// headers.setContentType(MediaType.MULTIPART_FORM_DATA);
// headers.add("OpenApiUserToken", ConstantContextHolder.getScaToken());
// HttpEntity<MultiValueMap<String, Object>> requestEntity = new HttpEntity<>(body, headers);
//
// log.info("SCA上传接口:" + scaUploadUrl);
// JSONObject response = restTemplate.postForObject(scaUploadUrl, requestEntity, JSONObject.class);
// String message = response.getString("message");
//
// if (message.equals("success")) {
// nodeLogger.appendNow("==================SCA上传成功=================");
// JSONObject data = response.getJSONObject("data");
// Integer scaTaskId = data.getInteger("scaTaskId");
// Integer applicationId = data.getInteger("applicationId");
//
// scaSbomConfigInfo.setScaTaskId(scaTaskId);
// scaSbomConfigInfo.setApplicationId(applicationId);
// //更新到节点json数据
// String nodeJson = JSON.toJSONString(scaSbomConfigInfo);
// pipelineNodeConfigInfo.setInfo(nodeJson);
// PipelineNodeInfoParam pipelineNodeInfoParam = new PipelineNodeInfoParam();
// BeanUtils.copyProperties(pipelineNodeConfigInfo, pipelineNodeInfoParam);
// pipelineNodeInfoService.update(pipelineNodeInfoParam);
// workerParam.getPipelineNodeConfigInfo().setInfo(nodeJson);
//
// pollTaskStatus(restTemplate, scaTaskId);
// } else if (message.equals("应用已经存在")) {
// Integer oldScaTaskId = scaSbomConfigInfo.getScaTaskId();
// Integer oldApplicationId = scaSbomConfigInfo.getApplicationId();
// int restartResult = reStartTask(restTemplate, oldApplicationId);
// if (restartResult != 0) {
// return;
// }
// pollTaskStatus(restTemplate, oldScaTaskId);
// } else {
// nodeLogger.appendNow("==================SCA接口异常，调用失败=================");
// }
// }
//
// private MultiValueMap<String, Object> buildRequestBody(ScaSbomConfigInfo scaSbomConfigInfo, File file) {
// MultiValueMap<String, Object> body = new LinkedMultiValueMap<>();
// body.add("file", new FileSystemResource(file));
// body.add("projectName", scaSbomConfigInfo.getProjectName());
// body.add("applicationName", scaSbomConfigInfo.getApplicationName());
// body.add("applicationVersion", scaSbomConfigInfo.getApplicationVersion());
// body.add("applicationDescription", scaSbomConfigInfo.getApplicationDescription());
// return body;
// }
//
// /**
// * 创建请求头
// *
// * @return HttpHeaders
// */
// private HttpHeaders createHeaders() {
// HttpHeaders headers = new HttpHeaders();
// headers.add("OpenApiUserToken", ConstantContextHolder.getScaToken());
// return headers;
// }
//
// /**
// * 轮询请求任务状态
// *
// * @param restTemplate
// * @param scaTaskId
// */
// public void pollTaskStatus(RestTemplate restTemplate, Integer scaTaskId) {
// int currentPollingTimes = 0;
// while (currentPollingTimes < MAX_POLLING_TIMES) {
// try {
// HttpHeaders headers = new HttpHeaders();
// headers.add("OpenApiUserToken", ConstantContextHolder.getScaToken());
// HttpEntity<String> requestEntity = new HttpEntity<>(null, headers);
// String scaStatusUrl = ConstantContextHolder.getScaIp() + "/openapi/v1/task/" + scaTaskId;
// ResponseEntity<JSONObject> response = restTemplate.exchange(scaStatusUrl, HttpMethod.GET, requestEntity, JSONObject.class);
//
// if (Objects.requireNonNull(response.getBody()).getString("message").equals("success")) {
// //"status": 5, //状态 0-未审计 1-未检测 2-排队中 3-检测中 4-检测暂停 5-检测完成 6-检测超时 7-手动停止 8-检测异常 9-已删除 10-拉取中 11-停止中 12-下载中
// int status = response.getBody().getJSONObject("data").getInteger("status");
// log.info("当前任务状态: " + status);
// if (status == 5) {
// System.out.println("任务已完成，停止轮询。");
// log.info("任务已完成，停止轮询。");
// break;
// }
// } else {
// log.error("获取任务状态失败: " + response.getBody().getString("message"));
// break;
// }
// } catch (Exception e) {
// log.error("获取任务状态时发生错误: " + e.getMessage());
// }
// try {
// // 轮询间隔 5 秒
// Thread.sleep(POLLING_INTERVAL);
// } catch (InterruptedException e) {
// Thread.currentThread().interrupt();
// log.error("轮询被中断: " + e.getMessage());
// }
// currentPollingTimes++;
// }
// System.out.println("停止轮询");
// }
//
// /**
// * 重新检测接口
// *
// * @param restTemplate
// * @param applicationId
// */
// public int reStartTask(RestTemplate restTemplate, Integer applicationId) {
// try {
// String url = ConstantContextHolder.getScaIp() + "/openapi/v1/task/batch/detect";
// HttpHeaders headers = new HttpHeaders();
// headers.add("OpenApiUserToken", ConstantContextHolder.getScaToken());
// headers.setContentType(MediaType.APPLICATION_JSON);
// headers.add("Accept", MediaType.APPLICATION_JSON.toString());
// Map<String, List<Integer>> param = new HashMap<>();
// param.put("applicationIds", Arrays.asList(applicationId));
// String s = JSON.toJSONString(param);
// HttpEntity<String> formEntry = new HttpEntity<>(s, headers);
//
// JSONObject res = restTemplate.postForObject(url, formEntry, JSONObject.class);
// if (res.getString("message").equals("success")) {
// log.info("重新检测成功");
// return 0;
// } else {
// log.error("重新检测失败");
// log.error(res.getString("message"));
// return -1;
// }
// } catch (Exception e) {
// log.error("重新检测失败");
// log.error(e.getMessage());
// }
// return 0;
// }
//
// @Override
// public void execute(TaskRunContext context) {
//
// }
//}