diff --git a/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/TargetHandleWorker.java b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/TargetHandleWorker.java new file mode 100644 index 00000000..34f46a63 --- /dev/null +++ b/modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/TargetHandleWorker.java @@ -0,0 +1,23 @@ +package cd.casic.ci.process.engine.worker; + +import cd.casic.ci.common.pipeline.annotation.Plugin; +import cd.casic.ci.process.engine.runContext.TaskRunContext; +import cd.casic.ci.process.process.dataObject.base.PipBaseElement; +import com.alibaba.fastjson.JSON; +import lombok.extern.slf4j.Slf4j; + +/** + * 目标处理worker + * + * */ +@Slf4j +@Plugin(taskType = "code") +public class TargetHandleWorker extends BaseWorker{ + @Override + public void execute(TaskRunContext context) { + PipBaseElement contextDef = context.getContextDef(); + String id = contextDef.getId(); + log.info("==============触发worker执行========"); + log.info("==========运行context:{}===========", JSON.toJSONString(context)); + } +} diff --git a/ops-server/src/main/java/cd/casic/server/controller/MachineController.java b/ops-server/src/main/java/cd/casic/server/controller/MachineController.java index faf5ffb4..e297ce1a 100644 --- a/ops-server/src/main/java/cd/casic/server/controller/MachineController.java +++ b/ops-server/src/main/java/cd/casic/server/controller/MachineController.java @@ -4,6 +4,7 @@ import cd.casic.ci.process.process.dataObject.machine.MachineInfo; import cd.casic.ci.process.process.service.machine.MachineInfoService; import cd.casic.framework.commons.pojo.CommonResult; import jakarta.annotation.Resource; +import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; @@ -14,7 +15,7 @@ import java.util.List; public class MachineController { @Resource private MachineInfoService machineInfoService; - + @GetMapping("/list") public CommonResult> list(){ return CommonResult.success(machineInfoService.list()); }