|
@ -13,8 +13,10 @@ import org.nl.system.service.quartz.dao.SysQuartzJob; |
|
|
import org.nl.system.service.quartz.dao.SysQuartzLog; |
|
|
import org.nl.system.service.quartz.dao.SysQuartzLog; |
|
|
import org.nl.system.service.quartz.dao.mapper.SysQuartzLogMapper; |
|
|
import org.nl.system.service.quartz.dao.mapper.SysQuartzLogMapper; |
|
|
import org.nl.system.service.quartz.impl.SysQuartzJobServiceImpl; |
|
|
import org.nl.system.service.quartz.impl.SysQuartzJobServiceImpl; |
|
|
|
|
|
import org.quartz.DisallowConcurrentExecution; |
|
|
import org.quartz.JobExecutionContext; |
|
|
import org.quartz.JobExecutionContext; |
|
|
import org.quartz.JobExecutionException; |
|
|
import org.quartz.JobExecutionException; |
|
|
|
|
|
import org.quartz.PersistJobDataAfterExecution; |
|
|
import org.springframework.scheduling.annotation.Async; |
|
|
import org.springframework.scheduling.annotation.Async; |
|
|
|
|
|
|
|
|
import java.util.concurrent.Future; |
|
|
import java.util.concurrent.Future; |
|
@ -28,6 +30,7 @@ import java.util.concurrent.ThreadPoolExecutor; |
|
|
@Async |
|
|
@Async |
|
|
@SuppressWarnings({"unchecked", "all"}) |
|
|
@SuppressWarnings({"unchecked", "all"}) |
|
|
@Slf4j |
|
|
@Slf4j |
|
|
|
|
|
@DisallowConcurrentExecution |
|
|
public class ExecutionJob extends TLogQuartzJobBean { |
|
|
public class ExecutionJob extends TLogQuartzJobBean { |
|
|
|
|
|
|
|
|
/** |
|
|
/** |
|
|