diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/CoreLogClearJob.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/CoreLogClearJob.java index 5d1006c..80d7e82 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/CoreLogClearJob.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/CoreLogClearJob.java @@ -23,7 +23,9 @@ import java.util.Date; * @Modify: **/ public class CoreLogClearJob extends BaseImppScheduleJob { + public static final Logger LOGGER = LoggerFactory.getLogger(CoreLogClearJob.class); + private static final long serialVersionUID = 2706787898778108791L; public CoreLogClearJob() { super(CoreLogClearJob.class,"日志清除"); diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/CoreMessagePushJob.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/CoreMessagePushJob.java index 93815e0..6eaa7fc 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/CoreMessagePushJob.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/CoreMessagePushJob.java @@ -19,10 +19,12 @@ import org.springframework.beans.factory.annotation.Autowired; **/ @ApiOperation("通用消息推送job") public class CoreMessagePushJob extends BaseImppScheduleJob { + public static final Logger LOGGER = LoggerFactory.getLogger(CoreMessagePushJob.class); + private static final long serialVersionUID = -8458291754519027369L; public CoreMessagePushJob() { - super(CoreMessagePushJob.class,"通用消息推送job"); + super(CoreMessagePushJob.class, "通用消息推送job"); } /** @@ -33,6 +35,6 @@ public class CoreMessagePushJob extends BaseImppScheduleJob { @Override public void executeImppJob(JobExecutionContext context, ApplicationProperties applicationProperties) { - rabbitTemplate.convertAndSend(getJobParam(),CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue()); + rabbitTemplate.convertAndSend(getJobParam(), CommonEnumUtil.TRUE_OR_FALSE.TRUE.getValue()); } } diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/DemoCloudJob.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/DemoCloudJob.java index 537e121..c57a1a9 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/DemoCloudJob.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/DemoCloudJob.java @@ -17,6 +17,7 @@ import org.slf4j.LoggerFactory; @ApiOperation("测试微服定时任务demo") public class DemoCloudJob extends BaseImppScheduleJob { public static final Logger LOGGER = LoggerFactory.getLogger(DemoJob.class); + private static final long serialVersionUID = 6565382987595461305L; public DemoCloudJob() { super(DemoJob.class, "测试微服定时任务demo"); diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/DemoJob.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/DemoJob.java index edc4a5e..4793845 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/DemoJob.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/DemoJob.java @@ -1,16 +1,13 @@ package cn.estsh.i3plus.core.apiservice.schedulejob; import cn.estsh.i3plus.core.api.iservice.busi.ISysMessageService; -import cn.estsh.i3plus.platform.common.tool.TimeTool; -import cn.estsh.i3plus.platform.common.util.PlatformConstWords; +import cn.estsh.i3plus.platform.common.exception.ImppExceptionEnum; import cn.estsh.i3plus.pojo.base.enumutil.CommonEnumUtil; -import cn.estsh.i3plus.pojo.base.enumutil.ImppEnumUtil; -import cn.estsh.i3plus.pojo.platform.bean.SysMessage; import cn.estsh.impp.framework.base.schedule.BaseImppScheduleJob; import cn.estsh.impp.framework.boot.exception.ImppExceptionBuilder; -import cn.estsh.impp.framework.boot.exception.ImppExceptionEnum; import cn.estsh.impp.framework.boot.init.ApplicationProperties; import io.swagger.annotations.ApiOperation; +import org.apache.commons.lang3.StringUtils; import org.quartz.JobExecutionContext; import org.slf4j.Logger; import org.slf4j.LoggerFactory; @@ -26,6 +23,7 @@ import org.springframework.beans.factory.annotation.Autowired; @ApiOperation("定时任务demo") public class DemoJob extends BaseImppScheduleJob { public static final Logger LOGGER = LoggerFactory.getLogger(DemoJob.class); + private static final long serialVersionUID = 2582480740831583839L; public DemoJob() { super(DemoJob.class,"定时任务demo"); @@ -44,19 +42,14 @@ public class DemoJob extends BaseImppScheduleJob { .setErrorSolution("请检查异常通知邮件") .build(); } + try { + if(getJobParam() != null && StringUtils.isNotBlank(getJobParam())) { + Thread.sleep(Long.parseLong(getJobParam())); + } + } catch (InterruptedException e) { + e.printStackTrace(); + } System.out.println("定时任务被执行"); LOGGER.info("projectName:{},port:{}", applicationProperties.getApplicationName(),applicationProperties.getServerPort()); - - SysMessage sysMessage = new SysMessage(); - sysMessage.setMessageTitle("定时邮件发送"); - sysMessage.setMessageContent("定时任务name:"+context.getJobDetail().getKey().getName() + - "定时任务groupName:"+context.getJobDetail().getKey().getGroup() + - "定时邮件内容"+TimeTool.getNowTime(true)); - sysMessage.setMessageType(ImppEnumUtil.MESSAGE_TYPE.MAIL.getValue()); - sysMessage.setMessageContentType(ImppEnumUtil.MESSAGE_TYPE_CONTENT.HTML.getValue()); - sysMessage.setMessageReceiversId(PlatformConstWords.CONTACT_MAIL); - sysMessage.setMessageReceiversNameRdd(PlatformConstWords.CONTACT_MAIL); - sysMessage.setMessageReceiverType(ImppEnumUtil.MESSAGE_RECEIVER_TYPE.URGENT.getValue()); - sysMessageService.doSendSysMessage(sysMessage); } } diff --git a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/TestCRUDPressure.java b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/TestCRUDPressure.java index 46e8f73..117a72b 100644 --- a/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/TestCRUDPressure.java +++ b/modules/i3plus-core-apiservice/src/main/java/cn/estsh/i3plus/core/apiservice/schedulejob/TestCRUDPressure.java @@ -35,6 +35,7 @@ import org.springframework.beans.factory.annotation.Autowired; **/ public class TestCRUDPressure extends BaseImppScheduleJob { + private static final long serialVersionUID = -5611654157756961800L; @Autowired private ISysToolService sysToolService;