提交 0ba4fe7d authored 作者: fit2cloud-chenyw's avatar fit2cloud-chenyw

fix: 定时报告队列中的任务过期依然执行

上级 b1da1d8b
...@@ -15,6 +15,7 @@ import io.dataease.job.sechedule.strategy.TaskHandler; ...@@ -15,6 +15,7 @@ import io.dataease.job.sechedule.strategy.TaskHandler;
import io.dataease.plugins.common.entity.GlobalTaskEntity; import io.dataease.plugins.common.entity.GlobalTaskEntity;
import io.dataease.plugins.common.entity.GlobalTaskInstance; import io.dataease.plugins.common.entity.GlobalTaskInstance;
import io.dataease.plugins.config.SpringContextUtil; import io.dataease.plugins.config.SpringContextUtil;
import io.dataease.plugins.xpack.email.dto.request.XpackEmailTaskRequest;
import io.dataease.plugins.xpack.email.dto.request.XpackPixelEntity; import io.dataease.plugins.xpack.email.dto.request.XpackPixelEntity;
import io.dataease.plugins.xpack.email.dto.response.XpackEmailTemplateDTO; import io.dataease.plugins.xpack.email.dto.response.XpackEmailTemplateDTO;
import io.dataease.plugins.xpack.email.service.EmailXpackService; import io.dataease.plugins.xpack.email.service.EmailXpackService;
...@@ -127,7 +128,10 @@ public class EmailTaskHandler extends TaskHandler implements Job { ...@@ -127,7 +128,10 @@ public class EmailTaskHandler extends TaskHandler implements Job {
SysUserEntity user) { SysUserEntity user) {
EmailXpackService emailXpackService = SpringContextUtil.getBean(EmailXpackService.class); EmailXpackService emailXpackService = SpringContextUtil.getBean(EmailXpackService.class);
try { try {
XpackEmailTaskRequest taskForm = emailXpackService.taskForm(taskInstance.getTaskId());
if (ObjectUtils.isEmpty(taskForm) || CronUtils.taskExpire(taskForm.getEndTime())) {
return;
}
String panelId = emailTemplateDTO.getPanelId(); String panelId = emailTemplateDTO.getPanelId();
String url = panelUrl(panelId); String url = panelUrl(panelId);
String token = tokenByUser(user); String token = tokenByUser(user);
...@@ -148,7 +152,6 @@ public class EmailTaskHandler extends TaskHandler implements Job { ...@@ -148,7 +152,6 @@ public class EmailTaskHandler extends TaskHandler implements Job {
emailService.sendWithImage(recipients, emailTemplateDTO.getTitle(), emailService.sendWithImage(recipients, emailTemplateDTO.getTitle(),
contentStr, bytes); contentStr, bytes);
Thread.sleep(10000);
success(taskInstance); success(taskInstance);
} catch (Exception e) { } catch (Exception e) {
error(taskInstance, e); error(taskInstance, e);
......
Markdown 格式
0%
您添加了 0 到此讨论。请谨慎行事。
请先完成此评论的编辑!
注册 或者 后发表评论