package cn.besteam.modules.medical.job; import cn.besteam.common.job.AbstractRedisLockJob; import cn.besteam.modules.medical.biz.JobBiz; import com.google.common.util.concurrent.ThreadFactoryBuilder; import lombok.extern.slf4j.Slf4j; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.annotation.Scheduled; import org.springframework.stereotype.Component; import org.springframework.transaction.annotation.Transactional; import java.util.concurrent.CompletableFuture; import java.util.concurrent.ExecutorService; import java.util.concurrent.LinkedBlockingQueue; import java.util.concurrent.ThreadFactory; import java.util.concurrent.ThreadPoolExecutor; import java.util.concurrent.TimeUnit; /** * 预警解除 */ //@Component @Slf4j public class CancelWarningDayJob extends AbstractRedisLockJob { @Autowired private JobBiz jobBiz; @Transactional @Override protected void process() { jobBiz.cancelWarningTimeJobOptimized(1); } @Override @Scheduled(cron = "0 0 0 * * ?") public void doJob() { super.lockKey = "cancel-warning-job-lock-key"; super.doJob(); } }