From 4029e7d497a949b78f2a1e15de43eec0d6973e1c Mon Sep 17 00:00:00 2001 From: even <827656971@qq.com> Date: Tue, 27 May 2025 17:29:09 +0800 Subject: [PATCH] =?UTF-8?q?worker=E6=B7=BB=E5=8A=A0=EF=BC=8C=E8=87=AA?= =?UTF-8?q?=E5=AE=9A=E4=B9=89=E9=95=9C=E5=83=8Fworker=E4=BF=AE=E6=94=B9?= =?UTF-8?q?=EF=BC=8C=E6=9C=BA=E5=99=A8=E7=AE=A1=E7=90=86=E6=8E=A5=E5=8F=A3?= =?UTF-8?q?=E6=B7=BB=E5=8A=A0?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../engine/worker/TargetHandleWorker.java | 23 +++++++++++++++++++ .../server/controller/MachineController.java | 3 ++- 2 files changed, 25 insertions(+), 1 deletion(-) create mode 100644 modules/module-ci-process-biz/src/main/java/cd/casic/ci/process/engine/worker/TargetHandleWorker.java 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()); }