|
@@ -20,6 +20,7 @@ import java.util.List;
|
|
|
import java.util.stream.Collectors;
|
|
|
|
|
|
/**
|
|
|
+ * 分析排队任务执行
|
|
|
* @author chy
|
|
|
* @date 2025/2/11 16:18
|
|
|
* @desc 分析任务执行
|
|
@@ -43,7 +44,7 @@ public class AnalysisTask {
|
|
|
|
|
|
@XxlJob(value = "analysisTaskExecute")
|
|
|
public void analysisTaskExecute() {
|
|
|
- log.info("触发自动分析定时任务开始");
|
|
|
+ log.info("排队分析定时任务开始");
|
|
|
try{
|
|
|
int analysisingCount = resultMapper.selectAnalysisProcessingCount();
|
|
|
if (analysisingCount > 0){
|
|
@@ -61,10 +62,10 @@ public class AnalysisTask {
|
|
|
//更新任务优先级状态为已执行
|
|
|
priorityRecordsMapper.updateExecuteStatus(priorityRecordsPo.getTaskId(), AnalysisConstants.ON_CALL);
|
|
|
}catch (Exception e){
|
|
|
- log.error("触发自动分析定时任务异常",e);
|
|
|
+ log.error("排队分析定时任务异常",e);
|
|
|
}
|
|
|
|
|
|
- log.info("触发自动分析定时任务结束");
|
|
|
+ log.info("排队分析定时任务结束");
|
|
|
}
|
|
|
|
|
|
|