fix:nacos配置

pom.xml

@@ -31,7 +31,7 @@
         <dependency>
             <groupId>com.xiang.starter</groupId>
             <artifactId>xmc-common</artifactId>
-            <version>1.0</version>
+            <version>1.1</version>
         </dependency>
         <dependency>
             <groupId>com.xiang.starter</groupId>
@@ -46,7 +46,7 @@
         <dependency>
             <groupId>com.xiang.starter</groupId>
             <artifactId>xmc-logger-starter</artifactId>
-            <version>1.0</version>
+            <version>1.1</version>
         </dependency>
     </dependencies>
 

readme.md

@@ -0,0 +1,48 @@
+# Xxz-job任务调度系统
+
+### （一）
+
+### （二）版本控制
+
+#### （1）v1.0版本-master分支上
+
+1. 设计Xxz-job注解以及EnableXxzJob注解，编写xxz-job注解扫描器以及注解执行器，本机单机执行任务。
+
+```java
+// 第一版Xxz-job注解内容
+@Target(ElementType.METHOD)
+@Retention(RetentionPolicy.RUNTIME)
+@Documented
+public @interface XxzJob {
+
+    /**
+     * bean的名称
+     *
+     * @return
+     */
+    String name();
+
+    /**
+     * cron调度方法
+     * @return
+     */
+    String cron();
+
+    boolean enabled() default true;
+    /**
+     * 是否支持多机分布式运行
+     * 若为false：每台机器都会执行一次
+     * 若为true：仅一台机器会执行
+     *
+     * @return
+     */
+    boolean distributed() default true;
+}
+```
+
+第一版XxzJob注解仅支持单机，并且cron固定的方式进行设计，能够将任务根据cron正常启动。
+
+#### （2）v1.1版本-feat/schedule_v1_0106
+
+1. 动态获取定时任务的cron和开关
+1. 

xservice-quartz-admin/pom.xml

@@ -18,5 +18,35 @@
         <maven.compiler.target>17</maven.compiler.target>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
     </properties>
+    <dependencies>
+        <dependency>
+            <groupId>com.xiang.starter</groupId>
+            <artifactId>xservice-quartz-common</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+    </dependencies>
 
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>2.3.0.RELEASE</version>
+                <configuration>
+                    <classifier>exec</classifier>
+                    <!-- 指定该Main Class为全局的唯一入口 -->
+                    <mainClass>com.xiang.app.Application</mainClass>
+                    <layout>ZIP</layout>
+                </configuration>
+                <executions>
+                    <execution>
+                        <goals>
+                            <goal>repackage</goal><!--可以把依赖的包都打包到生成的Jar包中-->
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
 </project>

xservice-quartz-admin/src/main/java/com/xiang/app/HealthController.java

@@ -0,0 +1,26 @@
+package com.xiang.app;
+
+import com.google.common.collect.Maps;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.beans.factory.annotation.Value;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.Map;
+
+@Slf4j
+@RestController
+public class HealthController {
+
+    @Value("${spring.profiles.active}")
+    private String env;
+
+    @GetMapping("/actuator/health")
+    public Map<String, String> checkHealth() {
+        Map<String, String> map = Maps.newHashMap();
+        map.put("env", env);
+        map.put("status", "UP");
+        log.info("cornucopia application health check success! listening in env:{}, now：{}", env, System.currentTimeMillis());
+        return map;
+    }
+}

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/domain/convert/DynamicTaskConvert.java

@@ -0,0 +1,67 @@
+package com.xiang.app.quartz.admin.domain.convert;
+
+import com.xiang.app.quartz.admin.domain.entity.DynamicTaskDO;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskQueryRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskSaveRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskUpdateRequest;
+import com.xiang.quartz.common.entity.dynamic.response.DynamicTaskInfoResponse;
+
+import java.time.LocalDateTime;
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 11:14
+ */
+public class DynamicTaskConvert {
+    public static DynamicTaskDO convert(DynamicTaskSaveRequest request) {
+        DynamicTaskDO dynamicTaskDO = new DynamicTaskDO();
+        dynamicTaskDO.setId(request.getId());
+        dynamicTaskDO.setTaskName(request.getTaskName());
+        dynamicTaskDO.setTaskGroup(request.getTaskGroup());
+        dynamicTaskDO.setRunTime(request.getRunTime());
+        dynamicTaskDO.setStatus(request.getStatus());
+        dynamicTaskDO.setParameters(request.getParameters());
+        dynamicTaskDO.setCreateTime(LocalDateTime.now());
+        dynamicTaskDO.setUpdateTime(LocalDateTime.now());
+        return dynamicTaskDO;
+    }
+
+    public static DynamicTaskDO convert(DynamicTaskUpdateRequest request) {
+        DynamicTaskDO dynamicTaskDO = new DynamicTaskDO();
+        dynamicTaskDO.setId(request.getId());
+        dynamicTaskDO.setTaskName(request.getTaskName());
+        dynamicTaskDO.setTaskGroup(request.getTaskGroup());
+        dynamicTaskDO.setRunTime(request.getRunTime());
+        dynamicTaskDO.setStatus(request.getStatus());
+        dynamicTaskDO.setParameters(request.getParameters());
+        dynamicTaskDO.setUpdateTime(LocalDateTime.now());
+        return dynamicTaskDO;
+    }
+
+    public static DynamicTaskDO convert(DynamicTaskQueryRequest request) {
+        DynamicTaskDO dynamicTaskDO = new DynamicTaskDO();
+        dynamicTaskDO.setTaskName(request.getTaskName());
+        dynamicTaskDO.setTaskGroup(request.getTaskGroup());
+        dynamicTaskDO.setStatus(request.getStatus());
+        return dynamicTaskDO;
+    }
+
+    public static DynamicTaskInfoResponse convert(DynamicTaskDO entity) {
+        DynamicTaskInfoResponse dynamicTaskInfoResponse = new DynamicTaskInfoResponse();
+        dynamicTaskInfoResponse.setId(entity.getId());
+        dynamicTaskInfoResponse.setTaskName(entity.getTaskName());
+        dynamicTaskInfoResponse.setTaskGroup(entity.getTaskGroup());
+        dynamicTaskInfoResponse.setRunTime(entity.getRunTime());
+        dynamicTaskInfoResponse.setStatus(entity.getStatus());
+        dynamicTaskInfoResponse.setParameters(entity.getParameters());
+        dynamicTaskInfoResponse.setCreatedTime(entity.getCreateTime());
+        dynamicTaskInfoResponse.setUpdatedTime(entity.getUpdateTime());
+        return dynamicTaskInfoResponse;
+    }
+
+    public static List<DynamicTaskInfoResponse> convertList(List<DynamicTaskDO> list) {
+        return list.stream().map(DynamicTaskConvert::convert).toList();
+    }
+
+}

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/domain/entity/DynamicTaskDO.java

@@ -0,0 +1,47 @@
+package com.xiang.app.quartz.admin.domain.entity;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@TableName("xmc_dynamic_task")
+public class DynamicTaskDO {
+    /**
+     * id
+     */
+    private Long id;
+    /**
+     * 任务名称
+     */
+    private String taskName;
+    /**
+     * 任务分组
+     */
+    private String taskGroup;
+    /**
+     * 运行时间
+     */
+    private LocalDateTime runTime;
+    /**
+     * 任务状态
+     */
+    private Integer status;
+    /**
+     * 参数
+     */
+    private String parameters;
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+    /**
+     * 修改时间
+     */
+    private LocalDateTime updateTime;
+}

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/domain/entity/JobConfigDO.java

@@ -81,4 +81,14 @@ public class JobConfigDO implements Serializable {
      * 上次执行时间
      */
     private LocalDateTime lastRunningTime;
+
+    /**
+     * 版本
+     */
+    private Integer version;
+
+    /**
+     * 环境
+     */
+    private Long env;
 }

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/domain/req/TaskRegisterRequest.java

@@ -4,6 +4,9 @@ import lombok.AllArgsConstructor;
 import lombok.Data;
 import lombok.NoArgsConstructor;
 
+import javax.validation.constraints.NotBlank;
+import javax.validation.constraints.NotNull;
+
 /**
  * @Author: xiang
  * @Date: 2026-01-05 15:49
@@ -13,14 +16,19 @@ import lombok.NoArgsConstructor;
 @NoArgsConstructor
 public class TaskRegisterRequest {
 
+    @NotNull(message = "命名空间不能为空")
+    private Long env;
+
     /**
      * 应用名称
      */
+    @NotBlank(message = "应用名称不能为空")
     private String applicationName;
 
     /**
      * 应用地址
      */
+    @NotBlank(message = "应用地址不能为空")
     private String applicationAddress;
 
     /**

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/manage/DynamicTaskManageImpl.java

@@ -0,0 +1,20 @@
+package com.xiang.app.quartz.admin.manage;
+
+import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;
+import com.xiang.app.quartz.admin.domain.entity.DynamicTaskDO;
+import com.xiang.app.quartz.admin.mapper.IScheduledTaskMapper;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 09:57
+ */
+@Service
+public class DynamicTaskManageImpl extends ServiceImpl<IScheduledTaskMapper, DynamicTaskDO> implements IDynamicTaskManage {
+    @Override
+    public List<DynamicTaskDO> getByList(DynamicTaskDO entity) {
+        return baseMapper.getTaskList(entity);
+    }
+}

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/manage/IDynamicTaskManage.java

@@ -0,0 +1,15 @@
+package com.xiang.app.quartz.admin.manage;
+
+import com.baomidou.mybatisplus.extension.service.IService;
+import com.xiang.app.quartz.admin.domain.entity.DynamicTaskDO;
+
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 09:57
+ */
+public interface IDynamicTaskManage extends IService<DynamicTaskDO> {
+
+    List<DynamicTaskDO> getByList(DynamicTaskDO entity);
+}

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/manage/IQuartzConfigManage.java

@@ -13,7 +13,8 @@ import java.util.List;
 public interface IQuartzConfigManage extends IService<JobConfigDO> {
 
 
-    List<JobConfigDO> selectByAppName(String name);
+    List<JobConfigDO> selectByAppName(String name, Long env);
+    List<JobConfigDO> selectByAppNameAndVersion(String name, Integer version);
 
     List<JobConfigDO> loadEnabledJobs();
 

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/manage/QuartzConfigManageImpl.java

@@ -18,10 +18,20 @@ import java.util.List;
 @Service
 public class QuartzConfigManageImpl extends ServiceImpl<IQuartzConfigMapper, JobConfigDO> implements IQuartzConfigManage {
     @Override
-    public List<JobConfigDO> selectByAppName(String name) {
+    public List<JobConfigDO> selectByAppName(String name, Long env) {
         LambdaQueryWrapper<JobConfigDO> lqw = Wrappers.lambdaQuery();
         lqw.eq(JobConfigDO::getApplicationName, name);
         lqw.eq(JobConfigDO::getDelFlag, 0);
+        lqw.eq(JobConfigDO::getEnv, env);
+        return baseMapper.selectList(lqw);
+    }
+
+    @Override
+    public List<JobConfigDO> selectByAppNameAndVersion(String name, Integer version) {
+        LambdaQueryWrapper<JobConfigDO> lqw = Wrappers.lambdaQuery();
+        lqw.eq(JobConfigDO::getApplicationName, name);
+        lqw.eq(JobConfigDO::getDelFlag, 0);
+        lqw.gt(JobConfigDO::getVersion, version);
         return baseMapper.selectList(lqw);
     }
 

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/mapper/IScheduledTaskMapper.java

@@ -0,0 +1,22 @@
+package com.xiang.app.quartz.admin.mapper;
+
+import com.baomidou.mybatisplus.core.mapper.BaseMapper;
+import com.xiang.app.quartz.admin.domain.entity.DynamicTaskDO;
+import org.apache.ibatis.annotations.Mapper;
+import org.apache.ibatis.annotations.Param;
+import org.springframework.stereotype.Repository;
+
+import java.util.List;
+
+@Mapper
+@Repository
+public interface IScheduledTaskMapper extends BaseMapper<DynamicTaskDO> {
+
+    int save(DynamicTaskDO entity);
+
+    int update(DynamicTaskDO entity);
+
+    DynamicTaskDO getTask(@Param("id") Long taskId);
+
+    List<DynamicTaskDO> getTaskList(DynamicTaskDO entity);
+}

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/server/DynamicTaskController.java

@@ -0,0 +1,49 @@
+package com.xiang.app.quartz.admin.server;
+
+import com.xiang.app.quartz.admin.service.IDynamicTaskService;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskQueryRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskSaveRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskUpdateRequest;
+import com.xiang.quartz.common.entity.dynamic.response.DynamicTaskInfoResponse;
+import com.xiang.xservice.basic.common.resp.Result;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.PathVariable;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 10:22
+ */
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/open/dynamic/task")
+public class DynamicTaskController {
+
+    private final IDynamicTaskService dynamicTaskService;
+
+    @PostMapping("/save")
+    public Result<Void> saveTask(@RequestBody DynamicTaskSaveRequest request) {
+        dynamicTaskService.saveTask(request);
+        return Result.success();
+    }
+    @PostMapping("/update")
+    public Result<Void> updateTask(@RequestBody DynamicTaskUpdateRequest request) {
+        dynamicTaskService.updateTask(request);
+        return Result.success();
+    }
+    @GetMapping("/info/{id}")
+    public Result<DynamicTaskInfoResponse> info(@PathVariable("id") Long id) {
+        return Result.data(dynamicTaskService.getTask(id));
+    }
+    @PostMapping("/getList")
+    public Result<List<DynamicTaskInfoResponse>> list(@RequestBody DynamicTaskQueryRequest request) {
+        return Result.data(dynamicTaskService.getTaskList(request));
+    }
+
+}

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/server/XxzJobFetchController.java

@@ -0,0 +1,36 @@
+package com.xiang.app.quartz.admin.server;
+
+import com.xiang.app.quartz.admin.domain.entity.JobConfigDO;
+import com.xiang.app.quartz.admin.service.ITaskConfigService;
+import com.xiang.xservice.basic.common.resp.Result;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RequestParam;
+import org.springframework.web.bind.annotation.RestController;
+
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-06 15:05
+ */
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/open/quartz/fetch")
+public class XxzJobFetchController {
+
+    private final ITaskConfigService taskConfigService;
+    @GetMapping("/list")
+    public Result<List<JobConfigDO>> list(@RequestParam("appName") String appName, @RequestParam("env") Long env) {
+        List<JobConfigDO> jobsByAppName = taskConfigService.getJobsByAppName(appName, env);
+        return Result.data(jobsByAppName);
+    }
+
+    @GetMapping("/listByVersion")
+    public Result<List<JobConfigDO>> listByVersion(@RequestParam("appName") String appName,
+                                             @RequestParam("currVersion") Integer currVersion,
+                                             @RequestParam("env") Long env) {
+        return Result.data(taskConfigService.getJobsByAppNameAndVersion(appName, currVersion, env));
+    }
+}

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/server/XxzJobRegisterController.java

@@ -1,8 +1,19 @@
 package com.xiang.app.quartz.admin.server;
 
+import com.xiang.app.quartz.admin.domain.req.TaskRegisterRequest;
+import com.xiang.app.quartz.admin.service.ITaskConfigService;
+import com.xiang.xservice.basic.common.resp.Result;
 import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.PostMapping;
+import org.springframework.web.bind.annotation.RequestBody;
+import org.springframework.web.bind.annotation.RequestMapping;
 import org.springframework.web.bind.annotation.RestController;
 
+import javax.validation.Valid;
+import javax.validation.constraints.NotEmpty;
+import javax.validation.constraints.NotNull;
+import java.util.List;
+
 /**
  * @Author: xiang
  * @Date: 2026-01-06 09:18
@@ -10,7 +21,21 @@ import org.springframework.web.bind.annotation.RestController;
 
 @RestController
 @RequiredArgsConstructor
+@RequestMapping("/open/quartz/register")
 public class XxzJobRegisterController {
 
+    private final ITaskConfigService taskConfigService;
+
+    @PostMapping("/single")
+    public Result<Void> registerSingle(@RequestBody @Valid @NotNull(message = "请求参数不能为空")  TaskRegisterRequest request){
+        taskConfigService.registerTask(request);
+        return Result.success();
+    }
+
+    @PostMapping("/batch")
+    public Result<Void> batch(@RequestBody @NotEmpty(message = "请求参数不能为空") @Valid List<TaskRegisterRequest> request) {
+        taskConfigService.registerTasks(request);
+        return Result.success();
+    }
 
 }

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/service/IDynamicTaskService.java

@@ -0,0 +1,19 @@
+package com.xiang.app.quartz.admin.service;
+
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskQueryRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskSaveRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskUpdateRequest;
+import com.xiang.quartz.common.entity.dynamic.response.DynamicTaskInfoResponse;
+
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 09:56
+ */
+public interface IDynamicTaskService {
+    Boolean saveTask(DynamicTaskSaveRequest entity);
+    Boolean updateTask(DynamicTaskUpdateRequest entity);
+    DynamicTaskInfoResponse getTask(Long taskId);
+    List<DynamicTaskInfoResponse> getTaskList(DynamicTaskQueryRequest entity);
+}

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/service/ITaskConfigService.java

@@ -1,5 +1,6 @@
 package com.xiang.app.quartz.admin.service;
 
+import com.xiang.app.quartz.admin.domain.entity.JobConfigDO;
 import com.xiang.app.quartz.admin.domain.req.TaskRegisterRequest;
 
 import java.util.List;
@@ -23,4 +24,19 @@ public interface ITaskConfigService {
      * @return
      */
     boolean registerTasks(List<TaskRegisterRequest> request);
+
+    /**
+     * 根据应用获取任务
+     * @param appName
+     * @return
+     */
+    List<JobConfigDO> getJobsByAppName(String appName, Long env);
+
+    /**
+     * 根据应用名称和版本获取任务
+     * @param appName
+     * @param version
+     * @return
+     */
+    List<JobConfigDO> getJobsByAppNameAndVersion(String appName, Integer version, Long env);
 }

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/service/impl/DynamicTaskSchedulerServiceImpl.java

@@ -0,0 +1,40 @@
+package com.xiang.app.quartz.admin.service.impl;
+
+import com.xiang.app.quartz.admin.domain.convert.DynamicTaskConvert;
+import com.xiang.app.quartz.admin.manage.IDynamicTaskManage;
+import com.xiang.app.quartz.admin.service.IDynamicTaskService;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskQueryRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskSaveRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskUpdateRequest;
+import com.xiang.quartz.common.entity.dynamic.response.DynamicTaskInfoResponse;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+@Service
+@RequiredArgsConstructor
+public class DynamicTaskSchedulerServiceImpl implements IDynamicTaskService {
+
+    private final IDynamicTaskManage dynamicTaskManage;
+
+    @Override
+    public Boolean saveTask(DynamicTaskSaveRequest entity) {
+        return dynamicTaskManage.save(DynamicTaskConvert.convert(entity));
+    }
+
+    @Override
+    public Boolean updateTask(DynamicTaskUpdateRequest entity) {
+        return dynamicTaskManage.updateById(DynamicTaskConvert.convert(entity));
+    }
+
+    @Override
+    public DynamicTaskInfoResponse getTask(Long taskId) {
+        return DynamicTaskConvert.convert(dynamicTaskManage.getById(taskId));
+    }
+
+    @Override
+    public List<DynamicTaskInfoResponse> getTaskList(DynamicTaskQueryRequest entity) {
+        return DynamicTaskConvert.convertList(dynamicTaskManage.getByList(DynamicTaskConvert.convert(entity)));
+    }
+}

xservice-quartz-admin/src/main/java/com/xiang/app/quartz/admin/service/impl/TaskConfigServiceImpl.java

@@ -14,6 +14,7 @@ import org.springframework.stereotype.Service;
 import java.util.Collections;
 import java.util.List;
 import java.util.Map;
+import java.util.Objects;
 import java.util.function.Function;
 import java.util.stream.Collectors;
 
@@ -40,7 +41,8 @@ public class TaskConfigServiceImpl implements ITaskConfigService {
             return false;
         }
         String applicationName = request.get(0).getApplicationName();
-        List<JobConfigDO> jobs = quartzConfigManage.selectByAppName(applicationName);
+        Long env = request.get(0).getEnv();
+        List<JobConfigDO> jobs = quartzConfigManage.selectByAppName(applicationName, env);
         Map<String, JobConfigDO> existJobs = Maps.newHashMap();
         if (CollectionUtils.isNotEmpty(jobs)) {
             existJobs.putAll(jobs.stream().collect(Collectors.toMap(JobConfigDO::getBeanName, Function.identity(), (a, b) -> a)));
@@ -67,6 +69,34 @@ public class TaskConfigServiceImpl implements ITaskConfigService {
         return true;
     }
 
+    @Override
+    public List<JobConfigDO> getJobsByAppName(String appName, Long env) {
+        return quartzConfigManage.selectByAppName(appName, env);
+    }
+
+    @Override
+    public List<JobConfigDO> getJobsByAppNameAndVersion(String appName, Integer version, Long env) {
+        List<JobConfigDO> jobConfigDOS = quartzConfigManage.selectByAppName(appName, env);
+        Map<String, List<JobConfigDO>> map = Maps.newHashMap();
+        if (CollectionUtils.isNotEmpty(jobConfigDOS)) {
+            map.putAll(jobConfigDOS.stream().collect(Collectors.groupingBy(JobConfigDO::getBeanName)));
+        }
+        Map<String, JobConfigDO> result = Maps.newHashMap();
+        map.forEach((k, v) -> {
+            v.forEach(item -> {
+                if (result.containsKey(k)) {
+                    JobConfigDO jobConfigDO = result.get(k);
+                    if (item.getVersion() > jobConfigDO.getVersion()) {
+                        result.put(k, item);
+                    }
+                } else {
+                    result.put(k, item);
+                }
+            });
+        });
+        return result.values().stream().toList();
+    }
+
     private static void putDataIntoDo(TaskRegisterRequest item, JobConfigDO jobConfigDO, String applicationName) {
         jobConfigDO.setApplicationName(applicationName);
         jobConfigDO.setApplicationAddress(item.getApplicationAddress());
@@ -74,6 +104,7 @@ public class TaskConfigServiceImpl implements ITaskConfigService {
         jobConfigDO.setCron(item.getCron());
         jobConfigDO.setClazz(item.getClazz());
         jobConfigDO.setMethod(item.getMethod());
-        jobConfigDO.setJobSwitch(0);
+        jobConfigDO.setJobSwitch(Objects.isNull(jobConfigDO.getJobSwitch()) ? 0 : jobConfigDO.getJobSwitch());
+        jobConfigDO.setEnv(item.getEnv());
     }
 }

xservice-quartz-admin/src/main/resources/application-local.yml

@@ -0,0 +1,36 @@
+spring:
+  cloud:
+    nacos:
+      discovery:
+        group: DEFAULT_GROUP
+        namespace: 6f603892-e9f7-4ca4-acbc-538fa09ebec0
+        server-addr: http://192.168.1.10:8848
+        # 是否启用健康检查
+        register-enabled: true
+        username: nacos
+        password: nacos
+  datasource:
+    dynamic:
+      primary: master
+      datasource:
+        master:
+          url: jdbc:mysql://120.27.153.87:3306/xservice_quartz?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
+          username: quartz
+          password: quartz@123
+          driver-class-name: com.mysql.cj.jdbc.Driver
+          sshConnect: false
+
+  redis:
+    host: r-bp1wt59a6nfyt4e3ltpd.redis.rds.aliyuncs.com
+    port: 6379
+    password: Xiang0000  # 如果无密码可以省略
+    database: 10
+    timeout: 5000
+    lettuce:
+      pool:
+        max-active: 8
+        max-idle: 8
+        min-idle: 0
+        max-wait: 1000
+xxz-job:
+  appName: xservice-quartz-admin

xservice-quartz-admin/src/main/resources/application-outside.yml

@@ -4,7 +4,9 @@ spring:
       discovery:
         group: DEFAULT_GROUP
         namespace: 00131110-3ecb-4a35-8bbb-624edde1d937
-        server-addr: general.xiangtech.xyz:8848
+        server-addr: http://general.xiangtech.xyz:8848
+        # 是否启用健康检查
+        register-enabled: false
         username: nacos
         password: nacos
   datasource:

xservice-quartz-admin/src/main/resources/application-prod.yml

@@ -0,0 +1,36 @@
+spring:
+  cloud:
+    nacos:
+      discovery:
+        group: DEFAULT_GROUP
+        namespace: 6f603892-e9f7-4ca4-acbc-538fa09ebec0
+        server-addr: http://192.168.32.3:8848
+        # 是否启用健康检查
+        register-enabled: true
+        username: nacos
+        password: nacos
+  datasource:
+    dynamic:
+      primary: master
+      datasource:
+        master:
+          url: jdbc:mysql://rm-bp15t34gqx62jm069ro.mysql.rds.aliyuncs.com:3306/xservice_quartz?useUnicode=true&characterEncoding=utf-8&serverTimezone=Asia/Shanghai&allowMultiQueries=true
+          username: quartz
+          password: quartz@123
+          driver-class-name: com.mysql.cj.jdbc.Driver
+          sshConnect: false
+
+  redis:
+    host: r-bp1wt59a6nfyt4e3ltpd.redis.rds.aliyuncs.com
+    port: 6379
+    password: Xiang0000  # 如果无密码可以省略
+    database: 0
+    timeout: 5000
+    lettuce:
+      pool:
+        max-active: 8
+        max-idle: 8
+        min-idle: 0
+        max-wait: 1000
+xxz-job:
+  appName: xservice-quartz-admin

xservice-quartz-admin/src/main/resources/application.yml

@@ -2,7 +2,7 @@ server:
   port: 30030
 spring:
   profiles:
-    active: dev
+    active: local
   application:
     name: xservice-quartz-admin
   main:

xservice-quartz-admin/src/main/resources/mapper/ScheduledTaskMapper.xml

@@ -0,0 +1,62 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
+        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
+<mapper namespace="com.xiang.app.quartz.admin.mapper.IScheduledTaskMapper">
+
+    <resultMap id="BaseResultMap" type="com.xiang.app.quartz.admin.domain.entity.DynamicTaskDO" >
+        <result column="id" property="id"/>
+        <result column="task_name" property="taskName"/>
+        <result column="task_group" property="taskGroup"/>
+        <result column="run_time" property="runTime"/>
+        <result column="status" property="status"/>
+        <result column="parameters" property="parameters"/>
+        <result column="create_time" property="createdTime"/>
+        <result column="update_time" property="updatedTime"/>
+    </resultMap>
+
+    <sql id="Base_Column_List">
+        id, task_name, task_group, run_time, status, parameters, create_time, update_time
+    </sql>
+
+    <!-- 插入一条任务 -->
+    <insert id="save" useGeneratedKeys="true" keyProperty="id" parameterType="com.xiang.app.quartz.admin.domain.entity.DynamicTaskDO">
+        INSERT INTO script_schedule_task (id, task_name, task_group, run_time, status, parameters, create_time, update_time)
+        VALUES (#{id}, #{taskName}, #{taskGroup}, #{runTime}, #{status}, #{parameters}, #{createdTime}, #{updatedTime})
+    </insert>
+
+    <!-- 更新任务 -->
+    <update id="update" parameterType="com.xiang.app.quartz.admin.domain.entity.DynamicTaskDO">
+        UPDATE script_schedule_task
+        SET task_name = #{taskName},
+        task_group = #{taskGroup},
+        run_time = #{runTime},
+        status = #{status},
+        parameters = #{parameters},
+        create_time = #{createdTime},
+        update_time = #{updatedTime}
+        WHERE id = #{id}
+    </update>
+
+    <select id="getTask" resultMap="BaseResultMap" parameterType="java.lang.Long">
+        select <include refid="Base_Column_List"/>
+        from script_schedule_task where id = #{id}
+    </select>
+    <select id="getTaskList" resultMap="BaseResultMap">
+        select
+        <include refid="Base_Column_List"/>
+        from script_schedule_task
+        <where>
+            1=1
+            <if test="taskName != null and taskName != ''">
+                and task_name = #{taskName}
+            </if>
+            <if test="taskGroup != null and taskGroup != ''">
+                and task_group = #{taskGroup}
+            </if>
+            <if test="status != null">
+                and status = #{status}
+            </if>
+        </where>
+    </select>
+
+</mapper>

xservice-quartz-common/src/main/java/com/xiang/quartz/common/api/DynamicTaskApi.java

@@ -0,0 +1,44 @@
+package com.xiang.quartz.common.api;
+
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskQueryRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskSaveRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskUpdateRequest;
+import com.xiang.quartz.common.entity.dynamic.response.DynamicTaskInfoResponse;
+import com.xiang.xservice.basic.common.resp.Result;
+
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 10:59
+ */
+public interface DynamicTaskApi {
+
+    /**
+     * 保存任务
+     * @param request   新增请求
+     * @return
+     */
+    Result<Void> saveTask(DynamicTaskSaveRequest request);
+
+    /**
+     * 修改任务
+     * @param request   修改请求
+     * @return
+     */
+    Result<Void> updateTask(DynamicTaskUpdateRequest request);
+
+    /**
+     * 查询任务详情
+     * @param id    任务id
+     * @return  任务详情
+     */
+    Result<DynamicTaskInfoResponse> info(Long id);
+
+    /**
+     * 查询任务列表
+     * @param request   查询参数
+     * @return  任务列表
+     */
+    Result<List<DynamicTaskInfoResponse>> list(DynamicTaskQueryRequest request);
+}

xservice-quartz-common/src/main/java/com/xiang/quartz/common/entity/dynamic/request/DynamicTaskQueryRequest.java

@@ -0,0 +1,33 @@
+package com.xiang.quartz.common.entity.dynamic.request;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.Data;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.time.LocalDateTime;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 11:10
+ */
+@Data
+public class DynamicTaskQueryRequest {
+    /**
+     * 任务名称
+     */
+    private String taskName;
+    /**
+     * 任务分组
+     */
+    private String taskGroup;
+    /**
+     * 运行时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private LocalDateTime runTime;
+    /**
+     * 任务状态
+     */
+    private Integer status;
+}

xservice-quartz-common/src/main/java/com/xiang/quartz/common/entity/dynamic/request/DynamicTaskSaveRequest.java

@@ -0,0 +1,45 @@
+package com.xiang.quartz.common.entity.dynamic.request;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.time.LocalDateTime;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 10:55
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class DynamicTaskSaveRequest {
+    /**
+     * 任务id
+     */
+    private Long id;
+    /**
+     * 任务名称
+     */
+    private String taskName;
+    /**
+     * 任务分组
+     */
+    private String taskGroup;
+    /**
+     * 运行时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private LocalDateTime runTime;
+    /**
+     * 任务状态
+     */
+    private Integer status;
+    /**
+     * 参数
+     */
+    private String parameters;
+}

xservice-quartz-common/src/main/java/com/xiang/quartz/common/entity/dynamic/request/DynamicTaskUpdateRequest.java

@@ -0,0 +1,45 @@
+package com.xiang.quartz.common.entity.dynamic.request;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.time.LocalDateTime;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 10:57
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class DynamicTaskUpdateRequest {
+    /**
+     * id
+     */
+    private Long id;
+    /**
+     * 任务名称
+     */
+    private String taskName;
+    /**
+     * 任务分组
+     */
+    private String taskGroup;
+    /**
+     * 运行时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private LocalDateTime runTime;
+    /**
+     * 任务状态
+     */
+    private Integer status;
+    /**
+     * 参数
+     */
+    private String parameters;
+}

xservice-quartz-common/src/main/java/com/xiang/quartz/common/entity/dynamic/response/DynamicTaskInfoResponse.java

@@ -0,0 +1,58 @@
+package com.xiang.quartz.common.entity.dynamic.response;
+
+import com.fasterxml.jackson.annotation.JsonFormat;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+import org.springframework.format.annotation.DateTimeFormat;
+
+import java.time.LocalDateTime;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 10:58
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class DynamicTaskInfoResponse {
+
+    /**
+     * id
+     */
+    private Long id;
+    /**
+     * 任务名称
+     */
+    private String taskName;
+    /**
+     * 任务分组
+     */
+    private String taskGroup;
+    /**
+     * 运行时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private LocalDateTime runTime;
+    /**
+     * 任务状态
+     */
+    private Integer status;
+    /**
+     * 参数
+     */
+    private String parameters;
+    /**
+     * 创建时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private LocalDateTime createdTime;
+    /**
+     * 修改时间
+     */
+    @JsonFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    @DateTimeFormat(pattern = "yyyy-MM-dd HH:mm:ss")
+    private LocalDateTime updatedTime;
+}

xservice-quartz-common/src/main/java/com/xiang/quartz/common/enums/TaskStatusEnum.java

@@ -0,0 +1,21 @@
+package com.xiang.quartz.common.enums;
+
+import lombok.Getter;
+
+@Getter
+public enum TaskStatusEnum {
+    UN_START(1, "未开始"),
+    PROCEED(2, "进行中"),
+    FINISHED(3, "已完成"),
+    CANCELED(4, "取消"),
+    ERROR(5, "错误"),
+    ;
+
+    private final Integer code;
+    private final String desc;
+
+    TaskStatusEnum(Integer code, String desc) {
+        this.code = code;
+        this.desc = desc;
+    }
+}

xservice-quartz-common/src/main/java/com/xiang/quartz/common/enums/url/DynamicTaskUrlEnum.java

@@ -0,0 +1,26 @@
+package com.xiang.quartz.common.enums.url;
+
+import lombok.AllArgsConstructor;
+import lombok.Getter;
+import org.springframework.http.HttpMethod;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 11:24
+ */
+@Getter
+@AllArgsConstructor
+public enum DynamicTaskUrlEnum {
+
+
+
+    SAVE_TASK("/open/dynamic/task/save", "保存任务", HttpMethod.POST),
+    UPDATE_TASK("/open/dynamic/task/update", "保存任务",HttpMethod.POST),
+    QUERY_TASK_INFO("/open/dynamic/task/info/", "查询任务详情", HttpMethod.GET),
+    QUERY_TASK_LIST("/open/dynamic/task/list", "查询任务列表", HttpMethod.POST),
+
+    ;
+    private final String url;
+    private final String desc;
+    private final HttpMethod method;
+}

xservice-quartz-core/pom.xml

@@ -11,7 +11,7 @@
 
     <groupId>com.xiang.starter</groupId>
     <artifactId>xservice-quartz-core</artifactId>
-    <version>1.0-SNAPSHOT</version>
+    <version>1.2</version>
 
     <properties>
         <maven.compiler.source>17</maven.compiler.source>
@@ -20,10 +20,21 @@
     </properties>
 
     <dependencies>
+        <dependency>
+            <groupId>com.xiang.starter</groupId>
+            <artifactId>xservice-quartz-common</artifactId>
+            <version>1.0-SNAPSHOT</version>
+        </dependency>
+
         <dependency>
             <groupId>com.xiang.starter</groupId>
             <artifactId>xmc-common</artifactId>
-            <version>1.0</version>
+            <version>1.1</version>
+        </dependency>
+        <dependency>
+            <groupId>com.xiang.starter</groupId>
+            <artifactId>xmc-http-starter</artifactId>
+            <version>2.0-SNAPSHOT</version>
         </dependency>
         <dependency>
             <groupId>com.xiang.starter</groupId>

xservice-quartz-core/src/main/java/com/xiang/core/quartz/annotation/XxzJob.java

@@ -22,13 +22,13 @@ public @interface XxzJob {
      */
     String name();
 
-    /**
-     * cron调度方法
-     * @return
-     */
-    String cron();
+//    /**
+//     * cron调度方法
+//     * @return
+//     */
+//    String cron();
 
-    boolean enabled() default true;
+//    boolean enabled() default true;
     /**
      * 是否支持多机分布式运行
      * 若为false：每台机器都会执行一次
@@ -36,5 +36,5 @@ public @interface XxzJob {
      *
      * @return
      */
-    boolean distributed() default true;
+    boolean distributed() default false;
 }

xservice-quartz-core/src/main/java/com/xiang/core/quartz/api/AdminJobClient.java

@@ -0,0 +1,17 @@
+package com.xiang.core.quartz.api;
+
+import com.xiang.core.quartz.model.JobConfigDO;
+import com.xiang.core.quartz.model.JobDefinition;
+
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-06 15:10
+ */
+public interface AdminJobClient {
+
+    List<JobConfigDO> fetchJobByAppName(String appName, Long namespace);
+    List<JobConfigDO> fetchJobByAppNameAndVersion(String appName, Integer version, Long namespace);
+    void registerJob(JobDefinition jobDefinition, String className);
+}

xservice-quartz-core/src/main/java/com/xiang/core/quartz/api/HttpAdminJobClientImpl.java

@@ -0,0 +1,88 @@
+package com.xiang.core.quartz.api;
+
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.JSONObject;
+import com.google.common.collect.Lists;
+import com.google.common.collect.Maps;
+import com.xiang.core.quartz.model.JobConfigDO;
+import com.xiang.core.quartz.model.JobDefinition;
+import com.xiang.core.quartz.model.TaskRegisterRequest;
+import com.xiang.core.quartz.model.XxzJobProperties;
+import com.xiang.xmc.service.http.helper.BaseHttpHelp;
+import com.xiang.xmc.service.http.helper.HttpHelperFactory;
+import lombok.RequiredArgsConstructor;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+import java.util.Map;
+import java.util.Objects;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-06 15:11
+ */
+@Component
+@RequiredArgsConstructor
+public class HttpAdminJobClientImpl implements AdminJobClient {
+
+    private final XxzJobProperties xxzJobProperties;
+    private static final BaseHttpHelp httpHelp = HttpHelperFactory.createQuartzHttp();
+
+    @Override
+    public List<JobConfigDO> fetchJobByAppName(String appName, Long namespace) {
+        String address = xxzJobProperties.getAdminAddress();
+        address = address + "/open/quartz/fetch/list";
+        Map<String, String> params = Maps.newHashMap();
+        params.put("appName", appName);
+        params.put("env", String.valueOf(namespace));
+        String resp = httpHelp.doGet(address, params);
+        if (StringUtils.isNotBlank(resp)) {
+            JSONObject jsonObject = JSON.parseObject(resp);
+            if (Objects.nonNull(jsonObject)) {
+                String data = JSON.toJSONString(jsonObject.get("data"));
+                if (StringUtils.isNotBlank(data)) {
+                    return JSON.parseArray(data, JobConfigDO.class);
+                }
+            }
+        }
+        return Lists.newArrayList();
+    }
+
+    @Override
+    public List<JobConfigDO> fetchJobByAppNameAndVersion(String appName, Integer version, Long namespace) {
+        String address = xxzJobProperties.getAdminAddress();
+        address = address + "/open/quartz/fetch/listByVersion";
+        Map<String, String> params = Maps.newHashMap();
+        params.put("appName", appName);
+        params.put("env", String.valueOf(namespace));
+        params.put("currVersion", String.valueOf(version));
+        String resp = httpHelp.doGet(address, params);
+
+        if (StringUtils.isNotBlank(resp)) {
+            JSONObject jsonObject = JSON.parseObject(resp);
+            if (Objects.nonNull(jsonObject)) {
+                String data = JSON.toJSONString(jsonObject.get("data"));
+                if (StringUtils.isNotBlank(data)) {
+                    return JSON.parseArray(data, JobConfigDO.class);
+                }
+            }
+        }
+        return Lists.newArrayList();
+    }
+
+    @Override
+    public void registerJob(JobDefinition jobDefinition, String className) {
+        TaskRegisterRequest request = new TaskRegisterRequest();
+        request.setApplicationName(xxzJobProperties.getAppName());
+        request.setApplicationAddress(xxzJobProperties.getAdminAddress());
+        request.setBeanName(jobDefinition.getName());
+        request.setCron(jobDefinition.getCron());
+        request.setClazz(className);
+        request.setMethod(jobDefinition.getMethod().getName());
+        request.setEnv(xxzJobProperties.getNamespace());
+        String address = xxzJobProperties.getAdminAddress();
+        address = address + "/open/quartz/register/single";
+        httpHelp.doPost(address, JSON.toJSONString(request));
+    }
+}

xservice-quartz-core/src/main/java/com/xiang/core/quartz/boostrap/JobBootstrap.java

@@ -1,14 +1,22 @@
 package com.xiang.core.quartz.boostrap;
 
+import com.xiang.core.quartz.api.AdminJobClient;
 import com.xiang.core.quartz.holder.JobDefinitionHolder;
-import com.xiang.core.quartz.model.JobDefinition;
+import com.xiang.core.quartz.model.JobConfigDO;
+import com.xiang.core.quartz.model.XxzJobProperties;
 import com.xiang.core.quartz.schedule.JobScheduler;
 import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.collections4.CollectionUtils;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.boot.ApplicationArguments;
 import org.springframework.boot.ApplicationRunner;
 import org.springframework.stereotype.Component;
 
+import java.util.List;
+import java.util.Map;
+import java.util.function.Function;
+import java.util.stream.Collectors;
+
 /**
  * @Author: xiang
  * @Date: 2026-01-06 09:50
@@ -19,13 +27,30 @@ public class JobBootstrap implements ApplicationRunner {
 
     @Autowired
     private JobScheduler scheduler;
+    @Autowired
+    private AdminJobClient adminJobClient;
+    @Autowired
+    private XxzJobProperties xxzJobProperties;
 
     @Override
     public void run(ApplicationArguments args) {
+        // 启动时动态获取此app下面的数据库配置好的定时任务 用于管理cron和开关
+        List<JobConfigDO> jobConfigDOS = adminJobClient.fetchJobByAppName(xxzJobProperties.getAppName(), xxzJobProperties.getNamespace());
+        if (CollectionUtils.isEmpty(jobConfigDOS)) {
+            return;
+        }
+        Map<String, JobConfigDO> map = jobConfigDOS.stream().collect(Collectors.toMap(JobConfigDO::getBeanName, Function.identity(), (a, b) -> a));
         JobDefinitionHolder.getAll()
-                .stream()
-                .filter(JobDefinition::isEnabled)
-                .forEach(scheduler::schedule);
+                .forEach(item -> {
+                    if (map.containsKey(item.getName())) {
+                        JobConfigDO jobConfigDO = map.get(item.getName());
+                        if (jobConfigDO.getJobSwitch() == 1) {
+                            item.setCron(jobConfigDO.getCron());
+                            item.setEnabled(jobConfigDO.getJobSwitch() == 1);
+                            scheduler.schedule(item);
+                        }
+                    }
+                });
     }
 }
 

xservice-quartz-core/src/main/java/com/xiang/core/quartz/config/XxzJobAutoConfiguration.java

@@ -2,11 +2,15 @@ package com.xiang.core.quartz.config;
 
 import com.xiang.core.quartz.executor.JobExecutor;
 import com.xiang.core.quartz.model.XxzJobProperties;
+import com.xiang.core.quartz.trigger.JobTrigger;
+import com.xiang.core.quartz.trigger.TriggerRoute;
 import org.springframework.boot.context.properties.EnableConfigurationProperties;
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.scheduling.annotation.EnableScheduling;
 
+import java.util.List;
+
 /**
  * @Author: xiang
  * @Date: 2026-01-06 09:29
@@ -20,4 +24,9 @@ public class XxzJobAutoConfiguration {
     public JobExecutor jobExecutor() {
         return new JobExecutor();
     }
+
+    @Bean
+    public TriggerRoute triggerRoute(List<JobTrigger> triggers) {
+        return new TriggerRoute(triggers);
+    }
 }

xservice-quartz-core/src/main/java/com/xiang/core/quartz/executor/JobExecutor.java

@@ -15,16 +15,15 @@ import org.springframework.stereotype.Component;
 public class JobExecutor {
 
     private static final Logger log = LoggerFactory.getLogger(JobExecutor.class);
-
     /**
      * v1版本 本地反射调用
-     * @param jobDefinition
+     * @param job
      */
-    public void executor(JobDefinition jobDefinition) {
+    public void executor(JobDefinition job) {
         try {
-            jobDefinition.getMethod().invoke(jobDefinition.getBean());
+            job.getMethod().invoke(job.getBean());
         } catch (Exception e) {
-            log.error("xxz-job execute error, job={}", jobDefinition.getName(), e);
+            log.error("xxz-job execute error, job={}", job.getName(), e);
         }
     }
 }

xservice-quartz-core/src/main/java/com/xiang/core/quartz/holder/JobDefinitionHolder.java

@@ -30,13 +30,6 @@ public class JobDefinitionHolder {
     public static JobDefinition getOne(String name) {
         return MAP.get(name);
     }
-
-    public static void updateOne(JobDefinition jobDefinition) {
-        if (MAP.containsKey(jobDefinition.getName())) {
-            MAP.put(jobDefinition.getName(), jobDefinition);
-        }
-    }
-
     public static void delOne(JobDefinition jobDefinition) {
         MAP.remove(jobDefinition.getName());
     }

xservice-quartz-core/src/main/java/com/xiang/core/quartz/model/JobConfigDO.java

@@ -0,0 +1,84 @@
+package com.xiang.core.quartz.model;
+
+import com.baomidou.mybatisplus.annotation.TableName;
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.io.Serial;
+import java.io.Serializable;
+import java.time.LocalDateTime;
+
+/**
+ * @Author: xiang
+ * @Date: 2025-12-30 09:42
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@TableName("xmc_quartz_config")
+public class JobConfigDO implements Serializable {
+
+    @Serial
+    private static final long serialVersionUID = 1L;
+
+    /**
+     * id
+     */
+    private Long id;
+    /**
+     * 应用名称
+     */
+    private String applicationName;
+
+    /**
+     * 应用地址
+     */
+    private String applicationAddress;
+
+    /**
+     * 定时任务名称
+     */
+    private String beanName;
+
+    /**
+     * 任务执行调度时间
+     */
+    private String cron;
+
+    /**
+     * 类名
+     */
+    private String clazz;
+
+    /**
+     * 方法
+     */
+    private String method;
+
+    /**
+     * 任务开关
+     * 0:关闭 1:开启
+     */
+    private Integer jobSwitch;
+
+    /**
+     * 删除标识（0:未删除 1:已删除）
+     */
+    private Integer delFlag;
+
+    /**
+     * 创建时间
+     */
+    private LocalDateTime createTime;
+
+    /**
+     * 修改时间
+     */
+    private LocalDateTime updateTime;
+
+    /**
+     * 上次执行时间
+     */
+    private LocalDateTime lastRunningTime;
+}

xservice-quartz-core/src/main/java/com/xiang/core/quartz/model/TaskRegisterRequest.java

@@ -0,0 +1,50 @@
+package com.xiang.core.quartz.model;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-05 15:49
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class TaskRegisterRequest {
+
+    /**
+     * 应用名称
+     */
+    private String applicationName;
+
+    /**
+     * 应用地址
+     */
+    private String applicationAddress;
+
+    /**
+     * 定时任务名称
+     */
+    private String beanName;
+
+    /**
+     * 任务执行调度时间
+     */
+    private String cron;
+
+    /**
+     * 类名
+     */
+    private String clazz;
+
+    /**
+     * 方法
+     */
+    private String method;
+
+    /**
+     * 环境
+     */
+    private Long env;
+}

xservice-quartz-core/src/main/java/com/xiang/core/quartz/model/XxzJobProperties.java

@@ -20,4 +20,14 @@ public class XxzJobProperties {
      * DB刷新任务间隔（毫秒）
      */
     private int refreshInterval = 5000;
+
+    /**
+     * 调度中心地址
+     */
+    private String adminAddress;
+
+    /**
+     * 命名空间
+     */
+    private Long namespace;
 }

xservice-quartz-core/src/main/java/com/xiang/core/quartz/scanner/JobScanner.java

@@ -1,6 +1,7 @@
 package com.xiang.core.quartz.scanner;
 
 import com.xiang.core.quartz.annotation.XxzJob;
+import com.xiang.core.quartz.api.AdminJobClient;
 import com.xiang.core.quartz.holder.JobDefinitionHolder;
 import com.xiang.core.quartz.model.JobDefinition;
 import lombok.extern.slf4j.Slf4j;
@@ -26,6 +27,8 @@ public class JobScanner implements SmartInitializingSingleton {
 
     @Autowired
     private ApplicationContext applicationContext;
+    @Autowired
+    private AdminJobClient adminJobClient;
 
     @Override
     public void afterSingletonsInstantiated() {
@@ -50,9 +53,8 @@ public class JobScanner implements SmartInitializingSingleton {
             job.setDistributed(xxzJob.distributed());
             job.setBean(bean);
             job.setMethod(method);
-            job.setEnabled(xxzJob.enabled());
-            job.setCron(xxzJob.cron());
             JobDefinitionHolder.register(job);
+            adminJobClient.registerJob(job, method.getClass().getName());
         }
     }
 }

xservice-quartz-core/src/main/java/com/xiang/core/quartz/schedule/JobConfigRefreshTask.java

@@ -0,0 +1,38 @@
+package com.xiang.core.quartz.schedule;
+
+import com.xiang.core.quartz.api.AdminJobClient;
+import com.xiang.core.quartz.holder.JobDefinitionHolder;
+import com.xiang.core.quartz.model.JobConfigDO;
+import com.xiang.core.quartz.model.JobDefinition;
+import com.xiang.core.quartz.model.XxzJobProperties;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.scheduling.annotation.Scheduled;
+import org.springframework.stereotype.Component;
+
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-06 15:59
+ */
+@Component
+public class JobConfigRefreshTask {
+
+    @Autowired
+    private AdminJobClient adminJobClient;
+    @Autowired
+    private XxzJobProperties xxzJobProperties;
+    @Autowired
+    private JobScheduler jobScheduler;
+    @Scheduled(fixedDelay = 5000)
+    public void refresh() {
+        List<JobConfigDO> jobConfigDOS = adminJobClient.fetchJobByAppName(xxzJobProperties.getAppName(), xxzJobProperties.getNamespace());
+
+        for (JobConfigDO jobConfigDO : jobConfigDOS) {
+            JobDefinition jobDefinition = JobDefinitionHolder.getOne(jobConfigDO.getBeanName());
+            jobScheduler.refresh(jobDefinition, jobConfigDO);
+        }
+    }
+
+
+}

xservice-quartz-core/src/main/java/com/xiang/core/quartz/schedule/JobScheduler.java

@@ -1,12 +1,19 @@
 package com.xiang.core.quartz.schedule;
 
-import com.xiang.core.quartz.executor.JobExecutor;
+import com.google.common.collect.Maps;
+import com.xiang.core.quartz.model.JobConfigDO;
 import com.xiang.core.quartz.model.JobDefinition;
+import com.xiang.core.quartz.trigger.TriggerRoute;
 import lombok.RequiredArgsConstructor;
+import org.apache.commons.lang3.StringUtils;
 import org.springframework.scheduling.TaskScheduler;
 import org.springframework.scheduling.support.CronTrigger;
 import org.springframework.stereotype.Component;
 
+import java.util.Map;
+import java.util.Objects;
+import java.util.concurrent.ScheduledFuture;
+
 /**
  * @Author: xiang
  * @Date: 2026-01-06 09:47
@@ -15,12 +22,50 @@ import org.springframework.stereotype.Component;
 @RequiredArgsConstructor
 public class JobScheduler {
     private final TaskScheduler taskScheduler;
-    private final JobExecutor jobExecutor;
+    private final TriggerRoute triggerRoute;
+    private final Map<String, ScheduledFuture<?>> scheduledTasks = Maps.newConcurrentMap();
 
-    public void schedule(JobDefinition job) {
-        taskScheduler.schedule(
-                () -> jobExecutor.executor(job),
+    public ScheduledFuture<?> schedule(JobDefinition job) {
+        return taskScheduler.schedule(
+                () -> triggerRoute.route(job).trigger(job),
                 new CronTrigger(job.getCron())
         );
     }
+
+    public synchronized void refresh(JobDefinition job, JobConfigDO cfg) {
+        String jobName = job.getName();
+
+        // 1️⃣ 未配置 or 未启用 → 停止
+        if (Objects.isNull(cfg) || Objects.equals(cfg.getJobSwitch(), 0)) {
+            job.setCron(null);
+            cancel(job);
+            return;
+        }
+
+        String newCron = cfg.getCron();
+        String oldCron = job.getCron();
+
+        // 2️⃣ cron 未变 & 已存在 → 不动
+        if (scheduledTasks.containsKey(jobName) && StringUtils.equals(newCron, oldCron)) {
+            return;
+        }
+
+        // 3️⃣ 先取消旧任务
+        cancel(job);
+        // 4️⃣ 创建新任务
+        job.setCron(newCron);
+        job.setEnabled(true);
+        ScheduledFuture<?> future = this.schedule(job);
+        scheduledTasks.put(jobName, future);
+
+    }
+
+    private void cancel(JobDefinition job) {
+        ScheduledFuture<?> future = scheduledTasks.remove(job.getName());
+        if (future != null) {
+            // false 不中断当前任务，等待任务完成
+            future.cancel(true);
+            triggerRoute.route(job).cancel(job.getName());
+        }
+    }
 }

xservice-quartz-core/src/main/java/com/xiang/core/quartz/trigger/DistributeJobTrigger.java

@@ -0,0 +1,61 @@
+package com.xiang.core.quartz.trigger;
+
+import com.xiang.core.quartz.executor.JobExecutor;
+import com.xiang.core.quartz.model.JobDefinition;
+import com.xiang.core.quartz.model.XxzJobProperties;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.apache.commons.lang3.StringUtils;
+import org.redisson.api.RLock;
+import org.redisson.api.RedissonClient;
+import org.springframework.stereotype.Component;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-07 09:33
+ */
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class DistributeJobTrigger implements JobTrigger {
+
+    private final RedissonClient redissonClient;
+    private final JobExecutor jobExecutor;
+    private final XxzJobProperties xxzJobProperties;
+
+    @Override
+    public void trigger(JobDefinition jobDefinition) {
+        if (!jobDefinition.isEnabled() || StringUtils.isEmpty(jobDefinition.getCron())) {
+            log.info("任务:{}已关闭，无需执行!", jobDefinition.getName());
+            return;
+        }
+        // 校验是否支持分布式，这里暂时忽略，先支持单机进行
+        String key = "xxzJob:" + xxzJobProperties.getAppName() + jobDefinition.getName();
+        RLock lock = redissonClient.getLock(key);
+        boolean flag = lock.tryLock();
+        try {
+            if (flag) {
+                jobExecutor.executor(jobDefinition);
+            } else {
+                log.info("其他实例正在执行任务！");
+            }
+        } catch (Exception e) {
+            log.info("xxz-Job：{}获取锁失败", jobDefinition.getName());
+        } finally {
+            // 释放锁
+            if (flag && lock.isHeldByCurrentThread()) {
+                lock.unlock();
+            }
+        }
+    }
+
+    @Override
+    public void cancel(String jobName) {
+
+    }
+
+    @Override
+    public TriggerType type() {
+        return TriggerType.DISTRIBUTE;
+    }
+}

xservice-quartz-core/src/main/java/com/xiang/core/quartz/trigger/JobTrigger.java

@@ -0,0 +1,16 @@
+package com.xiang.core.quartz.trigger;
+
+import com.xiang.core.quartz.model.JobDefinition;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-07 09:27
+ */
+public interface JobTrigger {
+
+    void trigger(JobDefinition jobDefinition);
+
+    void cancel(String jobName);
+
+    TriggerType type();
+}

xservice-quartz-core/src/main/java/com/xiang/core/quartz/trigger/LocalJobTrigger.java

@@ -0,0 +1,57 @@
+package com.xiang.core.quartz.trigger;
+
+import com.xiang.core.quartz.executor.JobExecutor;
+import com.xiang.core.quartz.model.JobDefinition;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+import org.springframework.stereotype.Component;
+
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicBoolean;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-07 09:28
+ */
+@Slf4j
+@Component
+@RequiredArgsConstructor
+public class LocalJobTrigger implements JobTrigger {
+
+    private final JobExecutor jobExecutor;
+    private final ConcurrentHashMap<String, AtomicBoolean> running = new ConcurrentHashMap<>();
+    @Override
+    public void trigger(JobDefinition job) {
+        if (!job.isEnabled()) {
+//            log.info("job {} disabled, skip execution", job.getName());
+            return;
+        }
+
+        AtomicBoolean flag = running.computeIfAbsent(
+                job.getName(), k -> new AtomicBoolean(false)
+        );
+
+        if (!flag.compareAndSet(false, true)) {
+//            log.warn("job {} is already running, skip", job.getName());
+            return;
+        }
+
+        try {
+            jobExecutor.executor(job);
+        } catch (Exception e) {
+            log.error("xxz-job execute error, job={}", job.getName(), e);
+        } finally {
+            flag.set(false);
+        }
+    }
+
+    @Override
+    public void cancel(String jobName) {
+        running.remove(jobName);
+    }
+
+    @Override
+    public TriggerType type() {
+        return TriggerType.LOCAL;
+    }
+}

xservice-quartz-core/src/main/java/com/xiang/core/quartz/trigger/TriggerRoute.java

@@ -0,0 +1,29 @@
+package com.xiang.core.quartz.trigger;
+
+import com.xiang.core.quartz.model.JobDefinition;
+
+import java.util.EnumMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-07 09:48
+ */
+public class TriggerRoute {
+
+    private final Map<TriggerType, JobTrigger> triggerMap;
+
+    public TriggerRoute(List<JobTrigger> triggers) {
+        triggerMap = new EnumMap<>(TriggerType.class);
+        for (JobTrigger trigger : triggers) {
+            triggerMap.put(trigger.type(), trigger);
+        }
+    }
+
+    public JobTrigger route(JobDefinition job) {
+        return job.isDistributed()
+                ? triggerMap.get(TriggerType.DISTRIBUTE)
+                : triggerMap.get(TriggerType.LOCAL);
+    }
+}

xservice-quartz-core/src/main/java/com/xiang/core/quartz/trigger/TriggerType.java

@@ -0,0 +1,19 @@
+package com.xiang.core.quartz.trigger;
+
+import lombok.Getter;
+import lombok.RequiredArgsConstructor;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-01-07 09:46
+ */
+@Getter
+@RequiredArgsConstructor
+public enum TriggerType {
+
+    LOCAL("单机"),
+    DISTRIBUTE("分布式"),
+
+    ;
+    private final String desc;
+}

xservice-quartz-core/src/main/java/com/xiang/core/schedule/api/HttpDynamicTaskClientImpl.java

@@ -0,0 +1,62 @@
+package com.xiang.core.schedule.api;
+
+import com.alibaba.fastjson2.JSON;
+import com.alibaba.fastjson2.TypeReference;
+import com.xiang.core.quartz.model.XxzJobProperties;
+import com.xiang.quartz.common.api.DynamicTaskApi;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskQueryRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskSaveRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskUpdateRequest;
+import com.xiang.quartz.common.entity.dynamic.response.DynamicTaskInfoResponse;
+import com.xiang.quartz.common.enums.url.DynamicTaskUrlEnum;
+import com.xiang.xmc.service.http.helper.BaseHttpHelp;
+import com.xiang.xmc.service.http.helper.HttpHelperFactory;
+import com.xiang.xservice.basic.common.resp.Result;
+import com.xiang.xservice.basic.common.resp.ResultUtils;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 10:04
+ */
+@Service()
+@RequiredArgsConstructor
+public class HttpDynamicTaskClientImpl implements DynamicTaskApi {
+    private final XxzJobProperties xxzJobProperties;
+    private static final BaseHttpHelp httpHelp = HttpHelperFactory.createQuartzHttp();
+
+    @Override
+    public Result<Void> saveTask(DynamicTaskSaveRequest request) {
+        String baseUrl = xxzJobProperties.getAdminAddress();
+        String resp = httpHelp.doPost(baseUrl + DynamicTaskUrlEnum.SAVE_TASK.getUrl(), null, JSON.toJSONString(request));
+        return ResultUtils.getData(resp, new TypeReference<Result<Void>>() {
+        });
+    }
+
+    @Override
+    public Result<Void> updateTask(DynamicTaskUpdateRequest request) {
+        String baseUrl = xxzJobProperties.getAdminAddress();
+        String resp = httpHelp.doPost(baseUrl + DynamicTaskUrlEnum.UPDATE_TASK.getUrl(), null, JSON.toJSONString(request));
+        return ResultUtils.getData(resp, new TypeReference<Result<Void>>() {
+        });
+    }
+
+    @Override
+    public Result<DynamicTaskInfoResponse> info(Long id) {
+        String baseUrl = xxzJobProperties.getAdminAddress();
+        String resp = httpHelp.doGet(baseUrl + DynamicTaskUrlEnum.QUERY_TASK_INFO.getUrl() + id, null);
+        return ResultUtils.getData(resp, new TypeReference<Result<DynamicTaskInfoResponse>>() {
+        });
+    }
+
+    @Override
+    public Result<List<DynamicTaskInfoResponse>> list(DynamicTaskQueryRequest request) {
+        String baseUrl = xxzJobProperties.getAdminAddress();
+        String resp = httpHelp.doPost(baseUrl + DynamicTaskUrlEnum.QUERY_TASK_LIST.getUrl(), null, JSON.toJSONString(request));
+        return ResultUtils.getData(resp, new TypeReference<Result<List<DynamicTaskInfoResponse>>>() {
+        });
+    }
+}

xservice-quartz-core/src/main/java/com/xiang/core/schedule/config/DynamicSchedulerAutoConfiguration.java

@@ -0,0 +1,12 @@
+package com.xiang.core.schedule.config;
+
+import com.xiang.core.schedule.core.DynamicTaskScheduler;
+import com.xiang.core.schedule.core.TaskRegistry;
+import org.springframework.boot.autoconfigure.AutoConfiguration;
+import org.springframework.context.annotation.Import;
+
+@AutoConfiguration
+@Import({DynamicTaskSchedulerConfig.class, DynamicTaskScheduler.class, TaskRegistry.class})
+public class DynamicSchedulerAutoConfiguration {
+
+}

xservice-quartz-core/src/main/java/com/xiang/core/schedule/config/DynamicTaskSchedulerConfig.java

@@ -0,0 +1,19 @@
+package com.xiang.core.schedule.config;
+
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+
+@Configuration
+public class DynamicTaskSchedulerConfig {
+    @Bean
+    public ThreadPoolTaskScheduler globalTaskScheduler() {
+        ThreadPoolTaskScheduler scheduler = new ThreadPoolTaskScheduler();
+        scheduler.setPoolSize(10);
+        scheduler.setThreadNamePrefix("dynamic-task-");
+        scheduler.setWaitForTasksToCompleteOnShutdown(true);
+        scheduler.setAwaitTerminationSeconds(30);
+        scheduler.initialize();
+        return scheduler;
+    }
+}

xservice-quartz-core/src/main/java/com/xiang/core/schedule/core/DynamicTaskScheduler.java

@@ -0,0 +1,51 @@
+package com.xiang.core.schedule.core;
+
+import com.xiang.core.schedule.entity.TaskConfig;
+import lombok.RequiredArgsConstructor;
+import org.springframework.scheduling.concurrent.ThreadPoolTaskScheduler;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.time.ZoneId;
+import java.util.Date;
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ScheduledFuture;
+
+@Component
+@RequiredArgsConstructor
+public class DynamicTaskScheduler {
+    private final ThreadPoolTaskScheduler taskScheduler;
+    private final Map<Long, ScheduledFuture<?>> taskMap = new ConcurrentHashMap<>();
+
+
+    public void schedule(TaskConfig config, Runnable task) {
+        schedule(config, task, LocalDateTime.now());
+    }
+
+    public void schedule(TaskConfig config, Runnable task, LocalDateTime serverTime) {
+        LocalDateTime time = config.getExecutionTime();
+        if (time.isBefore(serverTime)) return;
+
+        ScheduledFuture<?> future = taskScheduler.schedule(() -> {
+            try {
+                task.run();
+            } finally {
+                taskMap.remove(config.getTaskId());
+            }
+        }, Date.from(time.atZone(ZoneId.systemDefault()).toInstant()));
+        taskMap.put(config.getTaskId(), future);
+    }
+
+    public void cancel(Long taskId) {
+        ScheduledFuture<?> future = taskMap.get(taskId);
+        if (future != null) {
+            future.cancel(true);
+            taskMap.remove(taskId);
+        }
+    }
+
+    public Boolean contains(Long taskId) {
+        return taskMap.containsKey(taskId);
+    }
+}

xservice-quartz-core/src/main/java/com/xiang/core/schedule/core/TaskRegistry.java

@@ -0,0 +1,21 @@
+package com.xiang.core.schedule.core;
+
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.function.Consumer;
+
+public class TaskRegistry {
+    private final ConcurrentHashMap<Long, Consumer<Long>> handlers = new ConcurrentHashMap<>();
+
+    public void register(Long taskId, Consumer<Long> consumer) {
+        handlers.put(taskId, consumer);
+    }
+
+    public void run(Long taskId) {
+        Consumer<Long> consumer = handlers.get(taskId);
+        if (consumer != null) consumer.accept(taskId);
+    }
+
+    public void unregister(Long taskId) {
+        handlers.remove(taskId);
+    }
+}

xservice-quartz-core/src/main/java/com/xiang/core/schedule/entity/TaskConfig.java

@@ -0,0 +1,19 @@
+package com.xiang.core.schedule.entity;
+
+import lombok.AllArgsConstructor;
+import lombok.Data;
+import lombok.NoArgsConstructor;
+
+import java.time.LocalDateTime;
+import java.util.Map;
+
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+public class TaskConfig {
+    private Long taskId;
+    private String taskName;
+    private String taskGroup;
+    private LocalDateTime executionTime;
+    private Map<String, Object> parameters;
+}

xservice-quartz-core/src/main/java/com/xiang/core/schedule/enums/TaskGroupEnum.java

@@ -0,0 +1,17 @@
+package com.xiang.core.schedule.enums;
+
+import lombok.Getter;
+
+@Getter
+public enum TaskGroupEnum {
+    SERVICE_SAMPLE_SCHEDULE("sample", "测试动态定时任务"),
+    SERVICE_FWD_SCHEDULE("xs-fwd", "芬玩岛定时任务");
+
+    private final String code;
+    private final String desc;
+
+    TaskGroupEnum(String code, String desc) {
+        this.code = code;
+        this.desc = desc;
+    }
+}

xservice-quartz-core/src/main/java/com/xiang/core/schedule/helper/TaskExecutor.java

@@ -0,0 +1,8 @@
+package com.xiang.core.schedule.helper;
+
+
+import com.xiang.core.schedule.entity.TaskConfig;
+
+public interface TaskExecutor {
+    void execute(TaskConfig taskInfo);
+}

xservice-quartz-core/src/main/java/com/xiang/core/schedule/service/DynamicTaskSchedulerServiceImpl.java

@@ -0,0 +1,107 @@
+package com.xiang.core.schedule.service;
+
+import com.xiang.quartz.common.api.DynamicTaskApi;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskQueryRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskSaveRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskUpdateRequest;
+import com.xiang.quartz.common.entity.dynamic.response.DynamicTaskInfoResponse;
+import com.xiang.quartz.common.enums.TaskStatusEnum;
+import com.xiang.xservice.basic.common.resp.Result;
+import com.xiang.xservice.basic.common.resp.ResultUtils;
+import com.xiang.xservice.basic.exception.BusinessException;
+import lombok.RequiredArgsConstructor;
+import org.apache.commons.lang3.StringUtils;
+import org.springframework.stereotype.Service;
+
+import java.util.List;
+import java.util.Objects;
+
+@Service
+@RequiredArgsConstructor
+public class DynamicTaskSchedulerServiceImpl implements IDynamicTaskSchedulerService{
+
+    private final DynamicTaskApi dynamicTaskApi;
+
+    @Override
+    public Boolean saveTask(DynamicTaskSaveRequest entity) {
+        Result<Void> result = dynamicTaskApi.saveTask(entity);
+        if (StringUtils.equals(Result.SUCCESS_CODE, result.getCode())) {
+            return Boolean.TRUE;
+        }
+        return Boolean.FALSE;
+    }
+
+    @Override
+    public Boolean updateTask(DynamicTaskUpdateRequest entity) {
+        Result<Void> result = dynamicTaskApi.updateTask(entity);
+        if (StringUtils.equals(Result.SUCCESS_CODE, result.getCode())) {
+            return Boolean.TRUE;
+        }
+        return Boolean.FALSE;
+    }
+
+    @Override
+    public DynamicTaskInfoResponse getTask(Long taskId) {
+        return ResultUtils.getData(dynamicTaskApi.info(taskId));
+    }
+
+    @Override
+    public Boolean updateProcess(Long taskId) {
+        DynamicTaskInfoResponse task = getTask(taskId);
+        if (Objects.isNull(task)) {
+            throw new BusinessException("task不存在！");
+        }
+        DynamicTaskUpdateRequest dynamicTaskUpdateRequest = buildUpdateTaskRequest(task);
+        dynamicTaskUpdateRequest.setStatus(TaskStatusEnum.PROCEED.getCode());
+        return updateTask(dynamicTaskUpdateRequest);
+    }
+
+    @Override
+    public Boolean cancelTask(Long taskId) {
+        DynamicTaskInfoResponse task = getTask(taskId);
+        if (Objects.isNull(task)) {
+            throw new BusinessException("task不存在！");
+        }
+        DynamicTaskUpdateRequest dynamicTaskUpdateRequest = buildUpdateTaskRequest(task);
+        dynamicTaskUpdateRequest.setStatus(TaskStatusEnum.CANCELED.getCode());
+        return updateTask(dynamicTaskUpdateRequest);
+    }
+
+    @Override
+    public Boolean finishTask(Long taskId) {
+        DynamicTaskInfoResponse task = getTask(taskId);
+        if (Objects.isNull(task)) {
+            throw new BusinessException("task不存在！");
+        }
+        DynamicTaskUpdateRequest dynamicTaskUpdateRequest = buildUpdateTaskRequest(task);
+        dynamicTaskUpdateRequest.setStatus(TaskStatusEnum.FINISHED.getCode());
+        return updateTask(dynamicTaskUpdateRequest);
+    }
+
+    @Override
+    public Boolean errTask(Long taskId) {
+        DynamicTaskInfoResponse task = getTask(taskId);
+        if (Objects.isNull(task)) {
+            throw new BusinessException("task不存在！");
+        }
+        DynamicTaskUpdateRequest dynamicTaskUpdateRequest = buildUpdateTaskRequest(task);
+        dynamicTaskUpdateRequest.setStatus(TaskStatusEnum.ERROR.getCode());
+        return updateTask(dynamicTaskUpdateRequest);
+    }
+
+    @Override
+    public List<DynamicTaskInfoResponse> getTaskList(DynamicTaskQueryRequest entity) {
+        return ResultUtils.getData(dynamicTaskApi.list(entity));
+    }
+
+    private DynamicTaskUpdateRequest buildUpdateTaskRequest(DynamicTaskInfoResponse response) {
+        DynamicTaskUpdateRequest dynamicTaskUpdateRequest = new DynamicTaskUpdateRequest();
+        dynamicTaskUpdateRequest.setId(response.getId());
+        dynamicTaskUpdateRequest.setTaskName(response.getTaskName());
+        dynamicTaskUpdateRequest.setTaskGroup(response.getTaskGroup());
+        dynamicTaskUpdateRequest.setRunTime(response.getRunTime());
+        dynamicTaskUpdateRequest.setStatus(response.getStatus());
+        dynamicTaskUpdateRequest.setParameters(response.getParameters());
+        return dynamicTaskUpdateRequest;
+    }
+}

xservice-quartz-core/src/main/java/com/xiang/core/schedule/service/IDynamicTaskSchedulerService.java

@@ -0,0 +1,21 @@
+package com.xiang.core.schedule.service;
+
+
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskQueryRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskSaveRequest;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskUpdateRequest;
+import com.xiang.quartz.common.entity.dynamic.response.DynamicTaskInfoResponse;
+
+import java.util.List;
+
+
+public interface IDynamicTaskSchedulerService {
+    Boolean saveTask(DynamicTaskSaveRequest entity);
+    Boolean updateTask(DynamicTaskUpdateRequest entity);
+    DynamicTaskInfoResponse getTask(Long taskId);
+    Boolean updateProcess(Long taskId);
+    Boolean cancelTask(Long taskId);
+    Boolean finishTask(Long taskId);
+    Boolean errTask(Long taskId);
+    List<DynamicTaskInfoResponse> getTaskList(DynamicTaskQueryRequest entity);
+}

xservice-quartz-core/src/main/resources/META-INF/spring.factories

@@ -1,2 +1,3 @@
 org.springframework.boot.autoconfigure.EnableAutoConfiguration=\
-com.xiang.core.quartz.config.XxzJobAutoConfiguration
+com.xiang.core.quartz.config.XxzJobAutoConfiguration, \
+com.xiang.core.schedule.config.DynamicSchedulerAutoConfiguration

xservice-quartz-sample/pom.xml

@@ -22,7 +22,7 @@
         <dependency>
             <groupId>com.xiang.starter</groupId>
             <artifactId>xservice-quartz-core</artifactId>
-            <version>1.0-SNAPSHOT</version>
+            <version>1.2</version>
         </dependency>
 
         <dependency>

xservice-quartz-sample/src/main/java/com/xiang/app/dynamic/task/sample/springboot/server/TestController.java

@@ -0,0 +1,23 @@
+package com.xiang.app.dynamic.task.sample.springboot.server;
+
+import com.xiang.app.dynamic.task.sample.springboot.task.TestTaskService;
+import lombok.RequiredArgsConstructor;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 14:12
+ */
+@RestController
+@RequiredArgsConstructor
+@RequestMapping("/sample/dynamic/task")
+public class TestController {
+    private final TestTaskService testTaskService;
+
+    @GetMapping("/test")
+    public void test() {
+        testTaskService.test();
+    }
+}

xservice-quartz-sample/src/main/java/com/xiang/app/dynamic/task/sample/springboot/task/TestTask.java

@@ -0,0 +1,31 @@
+package com.xiang.app.dynamic.task.sample.springboot.task;
+
+import com.xiang.core.schedule.service.IDynamicTaskSchedulerService;
+import lombok.RequiredArgsConstructor;
+import lombok.extern.slf4j.Slf4j;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 14:11
+ */
+@Slf4j
+@RequiredArgsConstructor
+public class TestTask implements Runnable {
+
+    private final IDynamicTaskSchedulerService dynamicTaskSchedulerService;
+    private final Long taskId;
+
+    @Override
+    public void run() {
+        dynamicTaskSchedulerService.updateProcess(taskId);
+        log.info("动态任务开始运行！！！");
+        try {
+            log.info("模拟任务处理 10秒钟");
+            Thread.sleep(10000);
+        } catch (InterruptedException e) {
+            log.error("处理失败");
+        }
+        log.info("任务处理完成！");
+        dynamicTaskSchedulerService.finishTask(taskId);
+    }
+}

xservice-quartz-sample/src/main/java/com/xiang/app/dynamic/task/sample/springboot/task/TestTaskService.java

@@ -0,0 +1,38 @@
+package com.xiang.app.dynamic.task.sample.springboot.task;
+
+import com.alibaba.fastjson.JSON;
+import com.google.common.collect.Maps;
+import com.xiang.core.schedule.core.DynamicTaskScheduler;
+import com.xiang.core.schedule.entity.TaskConfig;
+import com.xiang.core.schedule.enums.TaskGroupEnum;
+import com.xiang.core.schedule.service.IDynamicTaskSchedulerService;
+import com.xiang.quartz.common.entity.dynamic.request.DynamicTaskSaveRequest;
+import com.xiang.quartz.common.enums.TaskStatusEnum;
+import com.xiang.xservice.basic.utils.PrimaryKeyUtils;
+import lombok.RequiredArgsConstructor;
+import org.springframework.stereotype.Component;
+
+import java.time.LocalDateTime;
+import java.util.Map;
+
+/**
+ * @Author: xiang
+ * @Date: 2026-02-11 14:06
+ */
+@Component
+@RequiredArgsConstructor
+public class TestTaskService {
+    private final DynamicTaskScheduler dynamicTaskScheduler;
+    private final IDynamicTaskSchedulerService dynamicTaskSchedulerService;
+
+    public void test() {
+        long taskId = PrimaryKeyUtils.snowflakeId();
+        Map<String, Object> params = Maps.newHashMap();
+        LocalDateTime runTime = LocalDateTime.of(2026, 2, 11, 15, 23, 00);
+        dynamicTaskSchedulerService.saveTask(new DynamicTaskSaveRequest(taskId, "测试动态任务运行", TaskGroupEnum.SERVICE_SAMPLE_SCHEDULE.getDesc(), runTime, TaskStatusEnum.UN_START.getCode(), JSON.toJSONString(params)));
+        dynamicTaskScheduler.schedule(
+                new TaskConfig(taskId, "测试动态任务运行", TaskGroupEnum.SERVICE_SAMPLE_SCHEDULE.getCode(), runTime, params),
+                new TestTask(dynamicTaskSchedulerService, taskId)
+        );
+    }
+}

xservice-quartz-sample/src/main/java/com/xiang/app/quartz/sample/springboot/schedule/TestXxzJob1.java

@@ -12,7 +12,7 @@ import org.springframework.stereotype.Component;
 @Component
 public class TestXxzJob1 {
 
-    @XxzJob(name = "TestXxzJob", cron = "0/1 * * * * ? ", enabled = true)
+    @XxzJob(name = "TestXxzJob")
     public void test() {
         log.info("任务调度开始");
     }

xservice-quartz-sample/src/main/resources/application.yml

@@ -1,5 +1,7 @@
 xxz-job:
   app-name: springboot-quartz-test
+  admin-address: http://127.0.0.1:30030
+  namespace: 1
 
 spring:
   main: