样式修改
This commit is contained in:
@@ -104,17 +104,20 @@ public class SchedulerManager {
|
||||
}
|
||||
|
||||
/**
|
||||
* @description 立即执行一次任务
|
||||
* @description 立即执行一次任务(异步)
|
||||
* @param task 任务对象
|
||||
* @author yslg
|
||||
* @since 2025-10-25
|
||||
*/
|
||||
public void executeTaskOnce(TbCrontabTask task) {
|
||||
try {
|
||||
taskExecutor.executeTask(task);
|
||||
logger.info("立即执行任务: {}", task.getTaskName());
|
||||
taskScheduler.schedule(
|
||||
() -> taskExecutor.executeTask(task),
|
||||
java.time.Instant.now()
|
||||
);
|
||||
logger.info("立即执行任务已提交: {}", task.getTaskName());
|
||||
} catch (Exception e) {
|
||||
logger.error("立即执行任务失败: {}", task.getTaskName(), e);
|
||||
logger.error("立即执行任务提交失败: {}", task.getTaskName(), e);
|
||||
}
|
||||
}
|
||||
|
||||
|
||||
@@ -532,7 +532,7 @@ public class NewsCrawlerTask extends PythonCommandTask {
|
||||
Map<String, String> urlToResourceId = new HashMap<>();
|
||||
|
||||
for (TbDataCollectionItem item : itemList) {
|
||||
if(item.getContent().isEmpty()) continue;
|
||||
if(NonUtils.isEmpty(item.getContent())) continue;
|
||||
try {
|
||||
TbResource resource = new TbResource();
|
||||
resource.setId(IDUtils.generateID());
|
||||
|
||||
Reference in New Issue
Block a user