From a44f1462dbf6e56c728c7ab9dc760eb47cbee784 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=E9=83=91=E5=86=9B=E6=AF=AB?= Date: Fri, 19 May 2023 09:34:55 +0800 Subject: [PATCH] =?UTF-8?q?JobApiController=E5=A2=9E=E5=8A=A0=E8=A7=A6?= =?UTF-8?q?=E5=8F=91=E5=AE=9A=E6=97=B6=E4=BB=BB=E5=8A=A1=E7=9A=84api?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../xxl/job/admin/controller/JobApiController.java | 11 ++++++++++- 1 file changed, 10 insertions(+), 1 deletion(-) diff --git a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobApiController.java b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobApiController.java index aa51e739..aa2989a4 100644 --- a/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobApiController.java +++ b/xxl-job-admin/src/main/java/com/xxl/job/admin/controller/JobApiController.java @@ -2,10 +2,13 @@ package com.xxl.job.admin.controller; import com.xxl.job.admin.controller.annotation.PermissionLimit; import com.xxl.job.admin.core.conf.XxlJobAdminConfig; +import com.xxl.job.admin.core.thread.JobTriggerPoolHelper; +import com.xxl.job.admin.core.trigger.TriggerTypeEnum; import com.xxl.job.core.biz.AdminBiz; import com.xxl.job.core.biz.model.HandleCallbackParam; import com.xxl.job.core.biz.model.RegistryParam; import com.xxl.job.core.biz.model.ReturnT; +import com.xxl.job.core.biz.model.TriggerParam; import com.xxl.job.core.util.GsonTool; import com.xxl.job.core.util.XxlJobRemotingUtil; import org.springframework.stereotype.Controller; @@ -63,7 +66,13 @@ public class JobApiController { } else if ("registryRemove".equals(uri)) { RegistryParam registryParam = GsonTool.fromJson(data, RegistryParam.class); return adminBiz.registryRemove(registryParam); - } else { + }else if ("trigger".equals(uri)){ + // 触发 执行 定时任务 + TriggerParam triggerParam = GsonTool.fromJson(data, TriggerParam.class); + JobTriggerPoolHelper.trigger(triggerParam.getJobId(), TriggerTypeEnum.API, -1, null, + triggerParam.getExecutorParams(), null); + return ReturnT.SUCCESS; + }else { return new ReturnT(ReturnT.FAIL_CODE, "invalid request, uri-mapping("+ uri +") not found."); }