package cn.stylefeng.roses.kernel.timer.hutool;

import cn.hutool.core.util.StrUtil;
import cn.hutool.cron.CronUtil;
import cn.stylefeng.roses.kernel.timer.api.exception.TimerException;
import cn.stylefeng.roses.kernel.timer.api.exception.enums.TimerExceptionEnum;
import lombok.extern.slf4j.Slf4j;

/**
 * HuToolTimerExeServiceImpl的改造
 * 当引入spring cloud后，需要对原有事件进行改造，使其只执行一次，防止出现错误。
 *
 * @author xielin
 * @date 2022/11/11 16:04
 */
@Slf4j
public class TimerExeServiceImpl extends HutoolTimerExeServiceImpl {

    @Override
    public void start() {

        // 设置秒级别的启用
        CronUtil.setMatchSecond(true);

        // 启动定时器执行器
        if (!CronUtil.getScheduler().isStarted()) {
            CronUtil.start();
            log.info("scheduler{} is not started", CronUtil.getScheduler().toString());
        } else {
            log.info("scheduler{} has already started", CronUtil.getScheduler().toString());
        }
    }

    @Override
    public void startTimer(String taskId, String cron, String className, String params) {

        // 判断任务id是否为空
        if (StrUtil.isBlank(taskId)) {
            throw new TimerException(TimerExceptionEnum.PARAM_HAS_NULL, "taskId");
        }

        // 如果之前有已经在执行的任务，则停止
        if (CronUtil.getScheduler().getTask(taskId) != null) {
            log.info("task ID:{} is existed，then will replace before one", taskId);
            CronUtil.getScheduler().deschedule(taskId);
        }

        // 执行以前的启动定时任务的逻辑
        super.startTimer(taskId, cron, className, params);
    }

}