使用任务调度

前置条件

在开始使用定时任务之前，要确保服务的choerodon-starters依赖在0.6.3.RELEASE版本及之上，推荐最新版0.11.0.RELEASE。

介绍

定时任务基于quartz的数据库模式，位于asgard-service，消费端依赖于choerodon-starter-asgard。在页面上手动创建定时任务，定时任务支持简单定时任务和cron表达式定时任务，并指定消费端的特定方法去消费。如果下一次定时任务被触发，而上一条定时任务未被消费端执行，则该定时任务状态设置为失败。

使用

消费端添加依赖

<dependency>
    <groupId>io.choerodon</groupId>
    <artifactId>choerodon-starter-asgard</artifactId>
    <version>${choerodon.starters.version}</version>
</dependency>

消费端的配置

choerodon:
  schedule:
    consumer:
      enabled: true # 启用任务调度消费端
      thread-num: 1 # 任务调度消费线程数
      poll-interval-ms: 1000 # 拉取间隔，默认1000毫秒

添加消费端方法

服务启动后，asgard-service通过kafka消息监听服务启动后主动拉取@JobTask定义的方法。
@JobTask注解的方法参数必须为Map。
@JobParam为执行参数, 类型需要为String，Integer，Long，Double，Boolean之一，如果没有设置默认值则创建定时任务时必须指定方法参数。
@JobTask注解的方法返回值为Map或者为void。如果返回值为void则传入的参数为前端传入，不会改变；如果为Map，则下一次的执行参数为上一次执行的返回值，可以动态改变。

@Component
public class Task {
    private static final Logger LOGGER = LoggerFactory.getLogger(Task.class);

    @JobTask(code = "test",
            maxRetryCount = 2, params = {
            @JobParam(name = "isInstantly", defaultValue = "true", type = Boolean.class),
            @JobParam(name = "name", defaultValue = "zh"),
            @JobParam(name = "age", type = Integer.class)
    })
    public Map<String, Object> test(Map<String, Object> data) {
        LOGGER.info("data {}", data);
        Object age = data.get("age");
        if (age != null) {
            data.put("age", (Integer)age + 1);
        }
        return data;
    }
}

创建定时任务

在前端页面的任务调度 –> 任务明细 –> 创建任务，填入任务执行参数以及扫描到的服务执行方法后创建任务。

@TimedTask定时任务

@JobTask只是定义一个可执行程序，具体触发时间要在前端页面创建定时任务，而@TimedTask注解可以定义一个带有触发时间的可执行程序，无需在页面创建

@TimedTask参数

public @interface TimedTask {
    /**
     * 定时任务名称
     */
    String name();
    /**
     * 定时任务描述
     */
    String description();
    /**
     * 是否只执行一次，true：只执行一次；false：每次部署时执行一次
     */
    boolean oneExecution();
    /**
     * 方法执行参数
     */
    TaskParam[] params();
    /**
     * simple-trigger的重复次数
     */
    int repeatCount();
    /**
     * simple-trigger的重复间隔值：重复间隔形如 '100SECONDS' 则为100
     */
    long repeatInterval();
    /**
     * simple-trigger的重复间隔单位：重复间隔形如 '100SECONDS' 则为SECONDS
     */
    QuartzDefinition.SimpleRepeatIntervalUnit repeatIntervalUnit();
}

@TimedTask使用

@Component
public class Task {

     @TimedTask(name = "同步LDAP用户", description = "自定义定时任务", oneExecution = true,
            repeatCount = 0, repeatInterval = 100, repeatIntervalUnit = QuartzDefinition.SimpleRepeatIntervalUnit.HOURS, params = {
            @TaskParam(name = "organizationCode", value = "hand")
    })
    public void syncLdapUserSite(Map<String, Object> map) {
        // 执行方法
    }

}