From 786383b446a7f5901b2f559ed55ac7206f3fba8c Mon Sep 17 00:00:00 2001 From: "sky.huang" Date: Thu, 8 Jun 2023 19:03:57 +0800 Subject: [PATCH] =?UTF-8?q?Fixes=20=E5=AE=9A=E6=97=B6=E6=A8=A1=E6=9D=BF?= =?UTF-8?q?=E4=BF=9D=E5=AD=98=E5=90=8E,=20CronTask=20=E4=BF=A1=E6=81=AF?= =?UTF-8?q?=E4=B8=A2=E5=A4=B1?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- .../austin/web/service/impl/MessageTemplateServiceImpl.java | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/austin-web/src/main/java/com/java3y/austin/web/service/impl/MessageTemplateServiceImpl.java b/austin-web/src/main/java/com/java3y/austin/web/service/impl/MessageTemplateServiceImpl.java index 15cacb8..c156fd8 100644 --- a/austin-web/src/main/java/com/java3y/austin/web/service/impl/MessageTemplateServiceImpl.java +++ b/austin-web/src/main/java/com/java3y/austin/web/service/impl/MessageTemplateServiceImpl.java @@ -182,6 +182,12 @@ public class MessageTemplateServiceImpl implements MessageTemplateService { messageTemplate.setUpdator(messageTemplate.getUpdator()) .setMsgStatus(MessageStatus.INIT.getCode()).setAuditStatus(AuditStatus.WAIT_AUDIT.getCode()); + // 从数据库查询并注入 定时任务 ID + MessageTemplate dbMsg = queryById(messageTemplate.getId()); + if (Objects.nonNull(dbMsg) && Objects.nonNull(dbMsg.getCronTaskId())) { + messageTemplate.setCronTaskId(dbMsg.getCronTaskId()); + } + if (Objects.nonNull(messageTemplate.getCronTaskId()) && TemplateType.CLOCKING.getCode().equals(messageTemplate.getTemplateType())) { XxlJobInfo xxlJobInfo = xxlJobUtils.buildXxlJobInfo(messageTemplate); cronTaskService.saveCronTask(xxlJobInfo);