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();
|
}
|
|
}
|
